From 71e6f9d41bf45cdcf0fd0a59f37a9eff52792238 Mon Sep 17 00:00:00 2001 From: 4tochka Date: Mon, 13 May 2019 02:37:35 +0400 Subject: [PATCH] connector --- pybtc/connector/connector.py | 2 +- pybtc/connector/utxo.py | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/pybtc/connector/connector.py b/pybtc/connector/connector.py index 1ed0b19..562edb1 100644 --- a/pybtc/connector/connector.py +++ b/pybtc/connector/connector.py @@ -377,7 +377,7 @@ class Connector: await self.utxo.destroy_utxo() try: self.checkpoints.append(block["checkpoint"]) except: pass - if len(self.utxo.cached) > self.utxo.size_limit: + if len(self.utxo.cached) > self.utxo.size_limit and not self.utxo.save_process: self.loop.create_task(self.utxo.save_utxo()) diff --git a/pybtc/connector/utxo.py b/pybtc/connector/utxo.py index b54d569..4e55509 100644 --- a/pybtc/connector/utxo.py +++ b/pybtc/connector/utxo.py @@ -78,7 +78,7 @@ class UTXO(): i[1][2])))) if block_changed: self.cached.append({i[0]: i[1]}) - self.log.critical(">" + str(len(self.cached))) + # self.log.critical(">" + str(len(self.cached))) # # block_height # for key in iter(self.cached): @@ -170,12 +170,14 @@ class UTXO(): continue break try: + self.load_utxo_future = asyncio.Future() l = set(self.missed) async with self._db_pool.acquire() as conn: rows = await conn.fetch("SELECT outpoint, connector_utxo.data " "FROM connector_utxo " "WHERE outpoint = ANY($1);", l) + self.log.critical("-"+str(len(rows))) for i in l: try: self.missed.remove(i)