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

Show up to 3 missing UTXOs

Browse Source 
Fixes #15
This commit is contained in:
Neil Booth 2016-11-10 23:50:55 +09:00
parent c6b5c577ab
commit 56098e0c52
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
server/block_processor.py
View File

@ -181,7 +181,7 @@ class MemPool(LoggedClass):
''' '''
hex_hashes = set(hex_hashes) hex_hashes = set(hex_hashes)
touched = set() touched = set()
missing_utxos = 0 missing_utxos = []
initial = self.count < 0 initial = self.count < 0
if initial: if initial:
@ -235,6 +235,7 @@ class MemPool(LoggedClass):
if entry == NO_CACHE_ENTRY: if entry == NO_CACHE_ENTRY:
# This happens when the daemon is a block ahead of us # This happens when the daemon is a block ahead of us
# and has mempool txs spending new txs in that block # and has mempool txs spending new txs in that block
missing_utxos.append(txin)
raise MissingUTXOError raise MissingUTXOError
value, = struct.unpack('<Q', entry[-8:]) value, = struct.unpack('<Q', entry[-8:])
return (entry[:21], value), False return (entry[:21], value), False
@ -264,7 +265,6 @@ class MemPool(LoggedClass):
# it's harmless - next time the mempool is refreshed # it's harmless - next time the mempool is refreshed
# they'll either be cleaned up or the UTXOs will no # they'll either be cleaned up or the UTXOs will no
# longer be missing. # longer be missing.
missing_utxos += 1
del self.txs[hex_hash] del self.txs[hex_hash]
continue continue
self.txs[hex_hash] = (txin_pairs, txout_pairs, any(unconfs)) self.txs[hex_hash] = (txin_pairs, txout_pairs, any(unconfs))
@ -279,8 +279,12 @@ class MemPool(LoggedClass):
if missing_utxos: if missing_utxos:
self.logger.info('{:,d} txs had missing UTXOs; probably the ' self.logger.info('{:,d} txs had missing UTXOs; probably the '
'daemon is a block or two ahead of us' 'daemon is a block or two ahead of us.'
.format(missing_utxos)) .format(len(missing_utxos)))
first = ', '.join('{} / {:,d}'.format(hash_to_str(txin.prev_hash),
txin.prev_idx)
for txin in sorted(missing_utxos)[:3])
self.logger.info('first ones are {}'.format(first))
self.count += 1 self.count += 1
if self.count % 25 == 0 or gone: if self.count % 25 == 0 or gone: