From 01c561a923b7499a56dbd55585531794870b6a39 Mon Sep 17 00:00:00 2001 From: 4tochka Date: Sat, 11 May 2019 10:45:56 +0400 Subject: [PATCH] connector --- pybtc/connector/utxo.py | 26 +++----------------------- 1 file changed, 3 insertions(+), 23 deletions(-) diff --git a/pybtc/connector/utxo.py b/pybtc/connector/utxo.py index 5cb98cc..0d72fde 100644 --- a/pybtc/connector/utxo.py +++ b/pybtc/connector/utxo.py @@ -6,7 +6,7 @@ from lru import LRU class UTXO(): def __init__(self, db_pool, loop, log, cache_size): - self.cached = LRU(cache_size) + self.cached = LRU() self.missed = set() self.destroyed = deque() self.deleted = LRU(200000) @@ -56,30 +56,10 @@ class UTXO(): self.destroyed_utxo += 1 pass - return + # if len(self.cached) - self._cache_size > 0 and not self.save_process: + # self.loop.create_task(self.save_utxo()) - block_height -= self.maturity - for key in range(self.destroyed_utxo_block + 1, block_height + 1): - if key not in self.destroyed: continue - n = set() - for outpoint in self.destroyed[key]: - try: - del self.cached[outpoint] - self.destroyed_utxo += 1 - except: - try: - del self.loaded[outpoint] - self.destroyed_utxo += 1 - n.add(outpoint) - except: - self.destroyed_utxo += 1 - pass - self.deleted[key] = n - del self.destroyed[key] - self.destroyed_utxo_block = block_height - if len(self.cached) - self._cache_size > 0 and not self.save_process: - self.loop.create_task(self.save_utxo(block_height)) async def save_utxo(self, block_height): # save to db tail from cache