|
|
@ -209,9 +209,9 @@ class BlockProcessor(object): |
|
|
|
await self._maybe_flush() |
|
|
|
if not self.db.first_sync: |
|
|
|
s = '' if len(blocks) == 1 else 's' |
|
|
|
self.logger.info('processed {:,d} block{} in {:.1f}s' |
|
|
|
.format(len(blocks), s, |
|
|
|
time.time() - start)) |
|
|
|
blocks_size = sum(len(block) for block in raw_blocks) / 1_000_000 |
|
|
|
self.logger.info(f'processed {len(blocks):,d} block{s} size {blocks_size:.2f} MB ' |
|
|
|
f'in {time.time() - start:.1f}s') |
|
|
|
if self._caught_up_event.is_set(): |
|
|
|
await self.notifications.on_block(self.touched, self.height) |
|
|
|
self.touched = set() |
|
|
|