connector

This commit is contained in:
4tochka 2019-05-03 13:57:46 +04:00
parent 7ff897111c
commit c12af514eb

View File

@ -771,9 +771,6 @@ class UTXO():
c -= 1
continue
break
# if not lb:
# await asyncio.sleep(0)
# return
r = set()
db = set()
@ -788,8 +785,9 @@ class UTXO():
await conn.execute("DELETE FROM connector_utxo WHERE "
"outpoint = ANY($1);", r)
await conn.copy_records_to_table('connector_utxo', columns=["outpoint", "data"], records=rs)
await conn.execute("UPDATE connector_utxo_state SET value = $1 "
"WHERE name = 'last_block';", lb)
if lb:
await conn.execute("UPDATE connector_utxo_state SET value = $1 "
"WHERE name = 'last_block';", lb)
await conn.execute("UPDATE connector_utxo_state SET value = $1 "
"WHERE name = 'last_cached_block';", block_height)
self.saved_utxo += len(rs)