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-12 19:07:09 +04:00
parent c57919aacd
commit fcc83e69da
2 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pybtc/connector/connector.py
View File

@ -377,6 +377,8 @@ class Connector:
await self.utxo.destroy_utxo()
try: self.checkpoints.append(block["checkpoint"])
except: pass
if len(self.utxo.cached) > self.utxo.size_limit:
self.loop.create_task(self.utxo.save_utxo())
self.blocks_processed_count += 1

12
pybtc/connector/utxo.py
View File

@ -5,17 +5,15 @@ from collections import OrderedDict, deque as LRU
from pybtc import LRU
class UTXO():
def __init__(self, db_pool, loop, log, cache_size, block_txo_max = 500000):
self.cached = LRU(cache_size)
def __init__(self, db_pool, loop, log, cache_size):
self.cached = LRU()
self.missed = set()
self.destroyed = deque()
self.deleted = LRU(200000)
self.deleted = LRU()
self.log = log
self.loaded = OrderedDict()
self.maturity = 100
self.block_txo_max = block_txo_max
self._cache_hard_limit = cache_size - block_txo_max
self._cache_soft_limit = cache_size - block_txo_max * 2
self.size_limit = cache_size
self._db_pool = db_pool
self.loop = loop
self.clear_tail = False
@ -60,6 +58,8 @@ class UTXO():
async def save_utxo(self):
# save to db tail from cache
self.log.critical("save utxo>>>>")
return
if not self.save_future.done():
await self.save_future.done()
return