From e4048674513d364085396261844ef221aeea0b77 Mon Sep 17 00:00:00 2001 From: 4tochka Date: Sun, 5 May 2019 00:16:13 +0400 Subject: [PATCH] connector --- pybtc/connector.py | 6 ------ 1 file changed, 6 deletions(-) diff --git a/pybtc/connector.py b/pybtc/connector.py index fd3b3b2..b826b4b 100644 --- a/pybtc/connector.py +++ b/pybtc/connector.py @@ -278,11 +278,7 @@ class Connector: async def get_next_block(self): if self.active and self.active_block.done(): - if not self.get_next_block_mutex.done(): - return try: - self.get_next_block_mutex = asyncio.Future() - if self.node_last_block <= self.last_block_height + self.backlog: d = await self.rpc.getblockcount() if d == self.node_last_block: @@ -323,8 +319,6 @@ class Connector: self.loop.create_task(self._new_block(block)) except Exception as err: self.log.error("get next block failed %s" % str(err)) - finally: - self.get_next_block_mutex.set_result(True) async def _get_block_by_hash(self, hash): self.log.debug("get block by hash %s" % hash)