connector
This commit is contained in:
parent
0cae41341c
commit
2d657f7fb5
@ -105,7 +105,6 @@ class UTXO():
|
|||||||
[batch.delete(k) for k in self.pending_deleted]
|
[batch.delete(k) for k in self.pending_deleted]
|
||||||
for k in self.pending_utxo:
|
for k in self.pending_utxo:
|
||||||
batch.put(k[0], k[1])
|
batch.put(k[0], k[1])
|
||||||
self.log.critical(str(k))
|
|
||||||
batch.put(b"last_block", int_to_bytes(self.checkpoint))
|
batch.put(b"last_block", int_to_bytes(self.checkpoint))
|
||||||
batch.put(b"last_cached_block", int_to_bytes(self.deleted_last_block))
|
batch.put(b"last_cached_block", int_to_bytes(self.deleted_last_block))
|
||||||
self.db.write(batch)
|
self.db.write(batch)
|
||||||
@ -156,8 +155,7 @@ class UTXO():
|
|||||||
self.load_utxo_future = asyncio.Future()
|
self.load_utxo_future = asyncio.Future()
|
||||||
l = set(self.missed)
|
l = set(self.missed)
|
||||||
rows = []
|
rows = []
|
||||||
[rows.append({"outpoint": k, "data": self.get(k)}) for k in l]
|
[rows.append({"outpoint": k, "data": self.db.get(k)}) for k in l]
|
||||||
self.log.critical(str(rows))
|
|
||||||
for i in l:
|
for i in l:
|
||||||
try:
|
try:
|
||||||
self.missed.remove(i)
|
self.missed.remove(i)
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user