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-06-01 20:38:13 +03:00
parent 7dc4d46ba8
commit 6536c22ed5
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pybtc/connector/utxo.py
View File

@ -4,6 +4,7 @@ import asyncio
from collections import OrderedDict from collections import OrderedDict
from pybtc import MRU from pybtc import MRU
import traceback import traceback
import time
try: import rocksdb try: import rocksdb
except: pass except: pass
@ -60,9 +61,7 @@ class UTXO():
if not self.checkpoints: return if not self.checkpoints: return
self.save_process = True self.save_process = True
try: try:
self.log.debug("create connector utxo checkpoint on block: " + str( self.checkpoints))
i = self.cached.peek_last_item() i = self.cached.peek_last_item()
# self.checkpoints = sorted(self.checkpoints)
checkpoint = self.checkpoints.pop(0) checkpoint = self.checkpoints.pop(0)
lb = 0 lb = 0
block_changed = False block_changed = False
@ -140,7 +139,7 @@ class UTXO():
if self.write_to_db: return if self.write_to_db: return
try: try:
self.write_to_db = True self.write_to_db = True
t = time.time()
if not self.checkpoint: return if not self.checkpoint: return
if self.db_type == "rocksdb": if self.db_type == "rocksdb":
await self.loop.run_in_executor(None, self.rocksdb_atomic_batch) await self.loop.run_in_executor(None, self.rocksdb_atomic_batch)
@ -148,7 +147,7 @@ class UTXO():
await self.loop.run_in_executor(None, self.leveldb_atomic_batch) await self.loop.run_in_executor(None, self.leveldb_atomic_batch)
else: else:
await self.postgresql_atomic_batch() await self.postgresql_atomic_batch()
self.log.debug("utxo checkpoint saved time %s" % round(time.time()-t, 4))
self.saved_utxo += len(self.pending_utxo) self.saved_utxo += len(self.pending_utxo)
self.deleted_utxo += len(self.pending_deleted) self.deleted_utxo += len(self.pending_deleted)
self.pending_deleted = set() self.pending_deleted = set()