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

connector

Browse Source
This commit is contained in:
4tochka 2019-05-03 13:29:12 +04:00
parent f170d14bf4
commit f45975e5a3
1 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
pybtc/connector.py
View File

@ -400,6 +400,9 @@ class Connector:
"cache size %s M;" % (self.non_cached_blocks, "cache size %s M;" % (self.non_cached_blocks,
self.block_preload.len(), self.block_preload.len(),
round(self.block_preload._store_size / 1024 / 1024, 2))) round(self.block_preload._store_size / 1024 / 1024, 2)))
self.log.info("cache saved utxo %s; "
"cache deleted utxo %s ;" % (self.utxo.saved_utxo,
self.utxo.deleted_utxo))
# after block added handler # after block added handler
if self.after_block_handler and not self.cache_loading: if self.after_block_handler and not self.cache_loading:
@ -722,6 +725,8 @@ class UTXO():
self._requests = 0 self._requests = 0
self._failed_requests = 0 self._failed_requests = 0
self._hit = 0 self._hit = 0
self.saved_utxo = 0
self.deleted_utxo = 0
def set(self, outpoint, pointer, amount, address): def set(self, outpoint, pointer, amount, address):
self.cached[outpoint] = (pointer, amount, address) self.cached[outpoint] = (pointer, amount, address)
@ -742,13 +747,13 @@ class UTXO():
for key in iter(self.destroyed): for key in iter(self.destroyed):
if key < block_height: if key < block_height:
n = set() n = set()
for i in self.destroyed[key]: for outpoint in self.destroyed[key]:
try: try:
del self.cached[i] del self.cached[outpoint]
except: except:
try: try:
del self.loaded[i] del self.loaded[outpoint]
n.add(i) n.add(outpoint)
except: except:
pass pass
self.destroyed[key] = n self.destroyed[key] = n
@ -766,7 +771,8 @@ class UTXO():
c -= 1 c -= 1
continue continue
break break
if not lb:
return
r = set() r = set()
db = set() db = set()
@ -785,7 +791,8 @@ class UTXO():
"WHERE name = 'last_block';", lb) "WHERE name = 'last_block';", lb)
await conn.execute("UPDATE connector_utxo_state SET value = $1 " await conn.execute("UPDATE connector_utxo_state SET value = $1 "
"WHERE name = 'last_cached_block';", block_height) "WHERE name = 'last_cached_block';", block_height)
self.saved_utxo += len(rs)
self.deleted_utxo += len(r)
# remove from cache # remove from cache
for key in ln: for key in ln:
try: try: