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-05 00:24:49 +04:00
parent e404867451
commit e209dee950
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pybtc/connector.py
View File

@ -268,7 +268,8 @@ class Connector:
self.zmqContext = None self.zmqContext = None
except: except:
pass pass
self.loop.create_task(self.get_next_block()) if not self.get_next_block_mutex:
self.loop.create_task(self.get_next_block())
except asyncio.CancelledError: except asyncio.CancelledError:
self.log.info("connector watchdog terminated") self.log.info("connector watchdog terminated")
break break
@ -277,8 +278,9 @@ class Connector:
self.log.error("watchdog error %s " % err) self.log.error("watchdog error %s " % err)
async def get_next_block(self): async def get_next_block(self):
if self.active and self.active_block.done(): if self.active and self.active_block.done() and not self.get_next_block_mutex:
try: try:
self.get_next_block_mutex = True
if self.node_last_block <= self.last_block_height + self.backlog: if self.node_last_block <= self.last_block_height + self.backlog:
d = await self.rpc.getblockcount() d = await self.rpc.getblockcount()
if d == self.node_last_block: if d == self.node_last_block:
@ -319,6 +321,8 @@ class Connector:
self.loop.create_task(self._new_block(block)) self.loop.create_task(self._new_block(block))
except Exception as err: except Exception as err:
self.log.error("get next block failed %s" % str(err)) self.log.error("get next block failed %s" % str(err))
finally:
self.get_next_block_mutex = False
async def _get_block_by_hash(self, hash): async def _get_block_by_hash(self, hash):
self.log.debug("get block by hash %s" % hash) self.log.debug("get block by hash %s" % hash)