|
|
@@ -170,7 +170,7 @@ class Fsck(object): |
|
|
|
|
|
|
|
def check_streams(self): |
|
|
|
ids = self.stream_path.keys() |
|
|
|
log("checking %d streams\n", len(ids)) |
|
|
|
log("checking %s streams\n", "{:,d}".format(len(ids))) |
|
|
|
with Progress(len(ids)) as pbar: |
|
|
|
for i, sid in enumerate(ids): |
|
|
|
pbar.update(i) |
|
|
@@ -306,7 +306,7 @@ class Fsck(object): |
|
|
|
|
|
|
|
def check_intervals(self): |
|
|
|
total_ints = sum(len(x) for x in self.stream_interval.values()) |
|
|
|
log("checking %d intervals\n", total_ints) |
|
|
|
log("checking %s intervals\n", "{:,d}".format(total_ints)) |
|
|
|
done = 0 |
|
|
|
with Progress(total_ints) as pbar: |
|
|
|
for sid in self.stream_interval: |
|
|
@@ -389,7 +389,7 @@ class Fsck(object): |
|
|
|
def check_data(self): |
|
|
|
total_rows = sum(sum((y[3] - y[2]) for y in x) |
|
|
|
for x in self.stream_interval.values()) |
|
|
|
log("checking %d rows of data\n", total_rows) |
|
|
|
log("checking %s rows of data\n", "{:,d}".format(total_rows)) |
|
|
|
done = 0 |
|
|
|
with Progress(total_rows) as pbar: |
|
|
|
for sid in self.stream_interval: |
|
|
|