Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

pause console elapsed timer when no blocks read/save

Browse source
This commit is contained in:
Lex Berezhny 2020-06-27 09:22:52 -04:00
parent 9500be26fd
commit 211f8b2e59
1 changed files with 13 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
lbry/console.py
View file

@ -63,6 +63,8 @@ class Advanced(Basic):
self.single_bar_relative_steps = 0 self.single_bar_relative_steps = 0
self.last_stats = "" self.last_stats = ""
self.sync_steps = [] self.sync_steps = []
self.block_savers = 0
self.block_readers = 0
def get_or_create_bar(self, name, desc, unit, total, leave=False, bar_format=None, postfix=None, position=None): def get_or_create_bar(self, name, desc, unit, total, leave=False, bar_format=None, postfix=None, position=None):
bar = self.bars.get(name) bar = self.bars.get(name)
@ -104,15 +106,25 @@ class Advanced(Basic):
sync_bar.update(sync_done) sync_bar.update(sync_done)
def update_block_bars(self, event, d): def update_block_bars(self, event, d):
total_bar = self.bars[event[-4:]]
if event.endswith("read") and self.block_readers == 0:
total_bar.unpause()
if event.endswith("read") and d['step'] == d['total']:
self.block_readers -= 1
bar_name = f"block-{d['block_file']}" bar_name = f"block-{d['block_file']}"
bar = self.bars.get(bar_name) bar = self.bars.get(bar_name)
if bar is None: if bar is None:
self.block_readers += 1
return self.get_or_create_bar( return self.get_or_create_bar(
bar_name, bar_name,
f" ├─ blk{d['block_file']:05}.dat reading", 'blocks', d['total'] f" ├─ blk{d['block_file']:05}.dat reading", 'blocks', d['total']
) )
if event.endswith("save") and bar.unit == "blocks": if event.endswith("save") and bar.unit == "blocks":
if self.block_savers == 0:
total_bar.unpause()
self.block_savers += 1
bar.desc = f" ├─ blk{d['block_file']:05}.dat saving" bar.desc = f" ├─ blk{d['block_file']:05}.dat saving"
bar.unit = "txs" bar.unit = "txs"
bar.reset(d['total']) bar.reset(d['total'])
@ -121,9 +133,9 @@ class Advanced(Basic):
diff = d['step']-bar.last_print_n diff = d['step']-bar.last_print_n
bar.update(diff) bar.update(diff)
if event.endswith("save") and d['step'] == d['total']: if event.endswith("save") and d['step'] == d['total']:
self.block_savers -= 1
bar.close() bar.close()
total_bar = self.bars[event[-4:]]
total_bar.update(diff) total_bar.update(diff)
if total_bar.total == total_bar.last_print_n: if total_bar.total == total_bar.last_print_n:
self.update_steps_bar(event, {'step': 1, 'total': 1}) self.update_steps_bar(event, {'step': 1, 'total': 1})