From cd6b8fc0889fc1c705cc992a31ef50cd167d4d1b Mon Sep 17 00:00:00 2001 From: 4tochka Date: Fri, 10 May 2019 18:40:04 +0400 Subject: [PATCH] connector --- pybtc/connector/block_loader.py | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/pybtc/connector/block_loader.py b/pybtc/connector/block_loader.py index 63bd137..2b13593 100644 --- a/pybtc/connector/block_loader.py +++ b/pybtc/connector/block_loader.py @@ -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