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:17:09 +04:00
parent 03553c5e8a
commit 31b0d918a7
1 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pybtc/connector.py
View File

@ -457,11 +457,8 @@ class Connector:
block["time"], block["time"],
block["height"], block["height"],
i)) i))
try: await asyncio.wait_for(self.block_txs_request)
await asyncio.wait_for(self.block_txs_request, timeout=self.block_timeout)
except:
self.log.critical(str(self.await_tx))
raise
elif tx_bin_list: elif tx_bin_list:
raise Exception("not emplemted") raise Exception("not emplemted")
@ -577,18 +574,18 @@ class Connector:
async def _new_transaction(self, tx, block_time = None, block_height = None, block_index = None): async def _new_transaction(self, tx, block_time = None, block_height = None, block_index = None):
self.log.debug("1 - %s %s " % (rh2s(tx["txId"]), not(tx["txId"] in self.tx_in_process or self.tx_cache.get(tx["txId"])))) # self.log.debug("1 - %s %s " % (rh2s(tx["txId"]), not(tx["txId"] in self.tx_in_process or self.tx_cache.get(tx["txId"]))))
if not(tx["txId"] in self.tx_in_process or self.tx_cache.get(tx["txId"])): if not(tx["txId"] in self.tx_in_process or self.tx_cache.get(tx["txId"])):
try: try:
stxo = None stxo = None
self.tx_in_process.add(tx["txId"]) self.tx_in_process.add(tx["txId"])
if not tx["coinbase"]: if not tx["coinbase"]:
if block_height is not None: if block_height is not None:
self.log.debug("2 - %s " % rh2s(tx["txId"])) # self.log.debug("2 - %s " % rh2s(tx["txId"]))
await self.wait_block_dependences(tx) await self.wait_block_dependences(tx)
if self.utxo: if self.utxo:
stxo = await self.get_stxo(tx, block_height, block_index) stxo = await self.get_stxo(tx, block_height, block_index)
self.log.debug(" - %s " % rh2s(tx["txId"])) # self.log.debug(" - %s " % rh2s(tx["txId"]))
if self.tx_handler and not self.cache_loading: if self.tx_handler and not self.cache_loading:
await self.tx_handler(tx, stxo, block_time, block_height, block_index) await self.tx_handler(tx, stxo, block_time, block_height, block_index)