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-04 13:48:01 +04:00
parent 31b0d918a7
commit fc85f9022b
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pybtc/connector.py
View File

@ -432,6 +432,10 @@ class Connector:
except Exception as err: except Exception as err:
if self.await_tx: if self.await_tx:
self.await_tx = set() self.await_tx = set()
for i in self.await_tx_future:
if not self.await_tx_future.done():
self.await_tx_future[i].cancel()
self.await_tx_future = dict()
self.log.error(str(traceback.format_exc())) self.log.error(str(traceback.format_exc()))
self.log.error("block error %s" % str(err)) self.log.error("block error %s" % str(err))
finally: finally:
@ -457,7 +461,7 @@ class Connector:
block["time"], block["time"],
block["height"], block["height"],
i)) i))
await asyncio.wait_for(self.block_txs_request) await asyncio.wait_for(self.block_txs_request, timeout=1500)
elif tx_bin_list: elif tx_bin_list: