Skip to content
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -405,12 +405,12 @@ private String serializeReport(FSORepairTool.Report report) {
report.getReachable().getDirs(),
report.getReachable().getFiles(),
report.getReachable().getBytes(),
report.getUnreachable().getDirs(),
report.getUnreachable().getFiles(),
report.getUnreachable().getBytes(),
report.getUnreferenced().getDirs(),
report.getUnreferenced().getFiles(),
report.getUnreferenced().getBytes()
report.getPendingToDelete().getDirs(),
report.getPendingToDelete().getFiles(),
report.getPendingToDelete().getBytes(),
report.getOrphaned().getDirs(),
report.getOrphaned().getFiles(),
report.getOrphaned().getBytes()
);
}

Expand Down Expand Up @@ -462,14 +462,14 @@ private static FSORepairTool.Report buildEmptyTree() throws IOException {
fs.mkdirs(new Path("/vol-empty/bucket-empty"));
FSORepairTool.ReportStatistics reachableCount =
new FSORepairTool.ReportStatistics(0, 0, 0);
FSORepairTool.ReportStatistics unreachableCount =
FSORepairTool.ReportStatistics pendingToDeleteCount =
new FSORepairTool.ReportStatistics(0, 0, 0);
FSORepairTool.ReportStatistics unreferencedCount =
FSORepairTool.ReportStatistics orphanedCount =
new FSORepairTool.ReportStatistics(0, 0, 0);
return new FSORepairTool.Report.Builder()
.setReachable(reachableCount)
.setUnreachable(unreachableCount)
.setUnreferenced(unreferencedCount)
.setPendingToDelete(pendingToDeleteCount)
.setOrphaned(orphanedCount)
.build();
}

Expand Down Expand Up @@ -507,14 +507,14 @@ private static FSORepairTool.Report buildTreeWithUnreachableObjects(String volum

FSORepairTool.ReportStatistics reachableCount =
new FSORepairTool.ReportStatistics(1, 1, fileSize);
FSORepairTool.ReportStatistics unreachableCount =
FSORepairTool.ReportStatistics pendingToDeleteCount =
new FSORepairTool.ReportStatistics(1, 2, fileSize * 2L);
FSORepairTool.ReportStatistics unreferencedCount =
FSORepairTool.ReportStatistics orphanedCount =
new FSORepairTool.ReportStatistics(0, 0, 0);
return new FSORepairTool.Report.Builder()
.setReachable(reachableCount)
.setUnreachable(unreachableCount)
.setUnreferenced(unreferencedCount)
.setPendingToDelete(pendingToDeleteCount)
.setOrphaned(orphanedCount)
.build();
}

Expand Down Expand Up @@ -581,15 +581,15 @@ private static FSORepairTool.Report buildDisconnectedTree(String volume, String

assertDisconnectedTreePartiallyReadable(volume, bucket);

// dir1 does not count towards the unreferenced directories the tool
// dir1 does not count towards the orphaned directories the tool
// will see. It was deleted completely so the tool will never see it.
FSORepairTool.ReportStatistics reachableCount =
new FSORepairTool.ReportStatistics(1, 1, fileSize);
FSORepairTool.ReportStatistics unreferencedCount =
FSORepairTool.ReportStatistics orphanedCount =
new FSORepairTool.ReportStatistics(1, 3, fileSize * 3L);
return new FSORepairTool.Report.Builder()
.setReachable(reachableCount)
.setUnreferenced(unreferencedCount)
.setOrphaned(orphanedCount)
.build();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -416,7 +416,7 @@ public static DBStore loadDB(OzoneConfiguration configuration, File metaDir, int
.build();
}

private static DBStoreBuilder newDBStoreBuilder(OzoneConfiguration conf, String name, File dir) {
public static DBStoreBuilder newDBStoreBuilder(OzoneConfiguration conf, String name, File dir) {
return DBStoreBuilder.newBuilder(conf, OMDBDefinition.get(), name, dir.toPath());
}

Expand Down
Loading