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-10 18:50:37 +04:00
parent fc1edf1707
commit 1bdf2b2127
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pybtc/connector/block_loader.py
View File

@ -72,6 +72,8 @@ class BlockLoader:
self.worker_busy[i] = True self.worker_busy[i] = True
if height <= self.parent.last_block_height: if height <= self.parent.last_block_height:
height = self.parent.last_block_height + 1 height = self.parent.last_block_height + 1
self.pipe_sent_msg(self.worker[i].writer, b'rpc_batch_limit',
int_to_bytes(self.rpc_batch_limit))
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
@ -210,7 +212,6 @@ class Worker:
t = 0 t = 0
batch = list() batch = list()
h_list = list() h_list = list()
# rpc_batch_limit = 50
while True: while True:
batch.append(["getblockhash", height]) batch.append(["getblockhash", height])
h_list.append(height) h_list.append(height)
@ -279,6 +280,10 @@ class Worker:
if msg_type == b'get': if msg_type == b'get':
self.loop.create_task(self.load_blocks(bytes_to_int(msg))) self.loop.create_task(self.load_blocks(bytes_to_int(msg)))
continue continue
if msg_type == b'rpc_batch_limit':
self.rpc_batch_limit = bytes_to_int(msg)
continue
except: except:
self.log.critical("exc") self.log.critical("exc")