synchronizer: more batching

This commit is contained in:
SomberNight 2018-09-08 18:38:58 +02:00
parent c49e563881
commit b33b2c0945
No known key found for this signature in database
GPG key ID: B33B5F232C6271E9

View file

@ -118,11 +118,12 @@ class Synchronizer(PrintError):
transaction_hashes.append(tx_hash)
self.requested_tx[tx_hash] = tx_height
for tx_hash in transaction_hashes:
await self.get_transaction(tx_hash)
async with TaskGroup() as group:
for tx_hash in transaction_hashes:
await group.spawn(self.get_transaction, tx_hash)
async def get_transaction(self, tx_hash):
result = await self.session.send_request('blockchain.transaction.get', [tx_hash])
result = await asyncio.wait_for(self.session.send_request('blockchain.transaction.get', [tx_hash]), 20)
tx = Transaction(result)
try:
tx.deserialize()