RanchiMall/pyflo
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

connector

Browse Source
This commit is contained in:
4tochka 2019-05-07 18:23:14 +04:00
parent ffd9baac83
commit 1a9ffa00b5
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pybtc/connector/block_loader.py
View File

@ -48,22 +48,19 @@ class BlockLoader:
async def loading(self): async def loading(self):
self.log.info("loading")
self.worker_tasks = [self.loop.create_task(self.start_worker(i)) for i in range(self.worker_limit)] self.worker_tasks = [self.loop.create_task(self.start_worker(i)) for i in range(self.worker_limit)]
target_height = self.parent.node_last_block - self.parent.deep_sync_limit target_height = self.parent.node_last_block - self.parent.deep_sync_limit
height = self.parent.last_block_height + 1 height = self.parent.last_block_height + 1
self.log.info(str(height)) self.log.info(str(height))
while height < target_height: while height < target_height:
self.log.info("height")
new_requests = 0 new_requests = 0
if self.parent.block_preload._store_size < self.parent.block_preload_cache_limit: if self.parent.block_preload._store_size < self.parent.block_preload_cache_limit:
try: try:
if height <= self.parent.last_block_height:
height = self.parent.last_block_height + 1
for i in self.worker_busy: for i in self.worker_busy:
if not self.worker_busy[i]: if not self.worker_busy[i]:
self.worker_busy[i] = True self.worker_busy[i] = True
self.log.info(">>>") if height <= self.parent.last_block_height:
height = self.parent.last_block_height + 1
self.pipe_sent_msg(self.worker[i].writer, b'get', int_to_bytes(height)) self.pipe_sent_msg(self.worker[i].writer, b'get', int_to_bytes(height))
height += self.rpc_batch_limit height += self.rpc_batch_limit
new_requests += 1 new_requests += 1