third-party-mirrors/zfs_autobackup
1
0
Fork 1
mirror of https://github.com/psy0rz/zfs_autobackup.git synced 2025-04-11 22:40:01 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

progress output

Browse Source
This commit is contained in:
Edwin Eefting 2022-02-22 18:00:06 +01:00
parent f530cf40f3
commit f4e81bddb7
2 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/test_treehasher.py
View File

@ -56,4 +56,4 @@ class TestTreeHasher(unittest2.TestCase):
shelltest("rm /tmp/treehashertest/whole")
self.assertEqual(list(tree_hasher.compare("/tmp/treehashertest", generator)),
[('whole', '-', '-', "ERROR: [Errno 2] No such file or directory: 'whole'")])
[('whole', '-', '-', "ERROR: [Errno 2] No such file or directory: '/tmp/treehashertest/whole'")])

21
zfs_autobackup/ZfsCheck.py
View File

@ -43,8 +43,7 @@ class ZfsCheck(CliBase):
args = super(ZfsCheck, self).parse_args(argv)
if args.test:
self.warning("TEST MODE - NOT DOING ANYTHING USEFULL")
self.log.show_debug = True # show at least what we would do
self.warning("TEST MODE - WILL ONLY DO READ-ONLY STUFF")
if args.target is None:
self.error("Please specify TARGET")
@ -198,15 +197,27 @@ class ZfsCheck(CliBase):
else:
input_fh=open(file_name, 'r')
last_progress_time = time.time()
progress_count = 0
for line in input_fh:
i=line.rstrip().split("\t")
#ignores lines without tabs
if (len(i)>1):
yield i
progress_count=progress_count+1
if self.args.progress and time.time() - last_progress_time > 1:
last_progress_time = time.time()
self.progress("Checked {} hashes.".format(progress_count))
def run(self):
try:
last_progress_time = time.time()
progress_count = 0
#run as generator
if self.args.check==None:
for i in self.generate(input_generator=None):
@ -214,6 +225,12 @@ class ZfsCheck(CliBase):
print("{}\t{}\t{}".format(*i))
else:
print("{}\t{}".format(*i))
progress_count=progress_count+1
if self.args.progress and time.time()-last_progress_time>1:
last_progress_time=time.time()
self.progress("Generated {} hashes.".format(progress_count))
sys.stdout.flush()
return 0