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:39:30 +04:00
parent 2825eb84bc
commit 9d7c9bb7f5
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pybtc/connector.py
View File

@ -155,7 +155,7 @@ class Connector:
# if self.preload: # if self.preload:
# self.loop.create_task(self.preload_block()) # self.loop.create_task(self.preload_block())
# self.loop.create_task(self.preload_block_hashes()) # self.loop.create_task(self.preload_block_hashes())
self.get_next_block_mutex = True
self.loop.create_task(self.get_next_block()) self.loop.create_task(self.get_next_block())
async def utxo_init(self): async def utxo_init(self):
@ -278,7 +278,7 @@ 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() and not self.get_next_block_mutex: if self.active and self.active_block.done() and self.get_next_block_mutex:
try: try:
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()