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-06 11:26:52 +04:00
parent 5e84bcd28f
commit d31ba1fa36
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pybtc/connector.py
View File

@ -464,6 +464,7 @@ class Connector:
self.await_tx = set(tx_bin_list) self.await_tx = set(tx_bin_list)
self.await_tx_future = {i: asyncio.Future() for i in tx_bin_list} self.await_tx_future = {i: asyncio.Future() for i in tx_bin_list}
self.block_txs_request = asyncio.Future() self.block_txs_request = asyncio.Future()
tx_count = len(block["rawTx"])
for i in block["rawTx"]: for i in block["rawTx"]:
self.loop.create_task(self._new_transaction(block["rawTx"][i], self.loop.create_task(self._new_transaction(block["rawTx"][i],
block["time"], block["time"],
@ -490,7 +491,7 @@ class Connector:
await self.rpc.close() await self.rpc.close()
self.rpc = aiojsonrpc.rpc(self.rpc_url, self.loop, timeout=self.rpc_timeout) self.rpc = aiojsonrpc.rpc(self.rpc_url, self.loop, timeout=self.rpc_timeout)
raise RuntimeError("block transaction request timeout") raise RuntimeError("block transaction request timeout")
tx_count = len(block["tx"]) tx_count = len(block["tx"])
self.total_received_tx += tx_count self.total_received_tx += tx_count
self.total_received_tx_time += time.time() - q self.total_received_tx_time += time.time() - q
rate = round(self.total_received_tx/self.total_received_tx_time) rate = round(self.total_received_tx/self.total_received_tx_time)