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-06 01:27:33 +04:00
parent e0bba56e59
commit 0e32571dfe
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pybtc/connector.py
View File

@ -358,7 +358,7 @@ class Connector:
self.active_block = asyncio.Future() self.active_block = asyncio.Future()
self.log.debug("Block %s %s" % (block["height"], block["hash"])) self.log.debug("Block %s %s" % (block["height"], block["hash"]))
bt = time.time()
self.cache_loading = True if self.last_block_height < self.app_block_height_on_start else False self.cache_loading = True if self.last_block_height < self.app_block_height_on_start else False
@ -379,11 +379,14 @@ class Connector:
self.block_headers_cache.set(block["hash"], block["height"]) self.block_headers_cache.set(block["hash"], block["height"])
self.last_block_height = block["height"] self.last_block_height = block["height"]
if self.utxo_data: if self.utxo_data:
self.utxo.destroy_utxo(block["height"]) if not self.deep_synchronization:
self.utxo.destroy_utxo(block["height"])
elif block["height"] % 100 == 0:
self.utxo.destroy_utxo(block["height"])
self.blocks_processed_count += 1 self.blocks_processed_count += 1
[self.tx_cache.pop(h) for h in tx_bin_list] for h in tx_bin_list: self.tx_cache.pop(h)
tx_rate = round(self.total_received_tx / (time.time() - self.start_time), 4) tx_rate = round(self.total_received_tx / (time.time() - self.start_time), 4)
t = 10000 if not self.deep_synchronization else 10000 t = 10000 if not self.deep_synchronization else 10000
@ -791,10 +794,10 @@ class UTXO():
except: except:
try: try:
del self.loaded[outpoint] del self.loaded[outpoint]
# self.destroyed_utxo += 1 self.destroyed_utxo += 1
n.add(outpoint) n.add(outpoint)
except: except:
# self.destroyed_utxo += 1 self.destroyed_utxo += 1
pass pass
self.deleted[key] = n self.deleted[key] = n
self.destroyed.pop(key) self.destroyed.pop(key)