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:40:04 +04:00
parent 1b53bb02c2
commit cd6b8fc088
1 changed files with 1 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pybtc/connector/block_loader.py
View File

@ -72,8 +72,6 @@ class BlockLoader:
self.worker_busy[i] = True
if height <= self.parent.last_block_height:
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))
height += self.rpc_batch_limit
new_requests += 1
@ -165,10 +163,6 @@ class BlockLoader:
if msg_type == b'result':
self.worker_busy[index] = False
# if len(msg) < 80000000 and self.rpc_batch_limit < 300:
# self.rpc_batch_limit += 10
# elif len(msg) > 100000000 and self.rpc_batch_limit > 10:
# self.rpc_batch_limit -= 10
blocks = pickle.loads(msg)
for i in blocks:
@ -281,9 +275,7 @@ class Worker:
msg_type, msg = await self.pipe_get_msg(self.reader)
if msg_type == b'pipe_read_error':
return
if msg_type == b'rpc_batch_limit':
self.rpc_batch_limit = bytes_to_int(msg)
continue
if msg_type == b'get':
self.loop.create_task(self.load_blocks(bytes_to_int(msg)))
continue