RanchiMall/electrumx
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Yield during mempool updates

Browse Source
This commit is contained in:
Neil Booth 2016-11-09 06:45:24 +09:00
parent c6a57daf6a
commit 212d653b5b
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
server/block_processor.py
View File

@ -211,7 +211,10 @@ class MemPool(LoggedClass):
def txout_pair(txout): def txout_pair(txout):
return (script_hash168(txout.pk_script), txout.value) return (script_hash168(txout.pk_script), txout.value)
for hex_hash, tx in new_txs.items(): for n, (hex_hash, tx) in enumerate(new_txs.items()):
# Yield to process e.g. signals
if n % 500 == 0:
await asyncio.sleep(0)
txout_pairs = [txout_pair(txout) for txout in tx.outputs] txout_pairs = [txout_pair(txout) for txout in tx.outputs]
self.txs[hex_hash] = (None, txout_pairs, None) self.txs[hex_hash] = (None, txout_pairs, None)
@ -237,10 +240,15 @@ class MemPool(LoggedClass):
# Now add the inputs # Now add the inputs
for n, (hex_hash, tx) in enumerate(new_txs.items()): for n, (hex_hash, tx) in enumerate(new_txs.items()):
# Yield to process e.g. signals
if n % 100 == 0:
await asyncio.sleep(0)
if initial and time.time() > next_log: if initial and time.time() > next_log:
next_log = time.time() + 10 next_log = time.time() + 10
self.logger.info('{:,d} done ({:d}%)' self.logger.info('{:,d} done ({:d}%)'
.format(n, int(n / len(new_txs) * 100))) .format(n, int(n / len(new_txs) * 100)))
txout_pairs = self.txs[hex_hash][1] txout_pairs = self.txs[hex_hash][1]
try: try:
infos = (txin_info(txin) for txin in tx.inputs) infos = (txin_info(txin) for txin in tx.inputs)