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-03 13:36:05 +04:00
parent 0922c7d3f4
commit 7e0ee2a9bb
2 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pybtc/connector/connector.py
View File

@ -92,6 +92,7 @@ class Connector:
self.start_time = time.time() self.start_time = time.time()
self.total_received_tx_last = 0 self.total_received_tx_last = 0
self.start_time_last = time.time() self.start_time_last = time.time()
self.batch_time = time.time()
# cache and system # cache and system
self.block_preload_cache_limit = block_preload_cache_limit self.block_preload_cache_limit = block_preload_cache_limit
self.block_hashes_cache_limit = block_hashes_cache_limit self.block_hashes_cache_limit = block_hashes_cache_limit
@ -464,15 +465,16 @@ class Connector:
self.utxo.deleted_utxo, self.utxo.deleted_utxo,
self.utxo.loaded_utxo)) self.utxo.loaded_utxo))
if self.utxo.read_from_db_time_total: if self.utxo.read_from_db_time_total:
c = round(self.utxo.read_from_db_count c = round(self.utxo.read_from_db_count / self.utxo.read_from_db_batch_time, 4)
/ (time.time() - self.utxo.read_from_db_batch_time), 4)
else: else:
c = 0 c = 0
self.log.debug(" Read from db last batch %s; " self.log.debug(" Read from db last batch %s; "
"count %s; " "count %s; "
"batch time %s; "
"rate %s; " "rate %s; "
"total time %s; " % (round(self.utxo.read_from_db_time, 4), "total time %s; " % (round(self.utxo.read_from_db_time, 4),
self.utxo.read_from_db_count, self.utxo.read_from_db_count,
round(self.utxo.read_from_db_batch_time, 4),
c, c,
int(self.utxo.read_from_db_time_total))) int(self.utxo.read_from_db_time_total)))
self.utxo.read_from_db_batch_time = time.time() self.utxo.read_from_db_batch_time = time.time()
@ -490,8 +492,10 @@ class Connector:
/ self.destroyed_coins, 4))) / self.destroyed_coins, 4)))
self.log.debug("---------------------") self.log.debug("---------------------")
t = int(time.time() - self.start_time) t = int(time.time() - self.start_time)
t2 = int(time.time() - self.batch_time)
self.batch_time = time.time()
h, m, s = t // 3600, (t % 3600 ) // 60, (t % 3600) % 60 h, m, s = t // 3600, (t % 3600 ) // 60, (t % 3600) % 60
self.log.info("Total time %s:%s:%s;" % (h,m,s)) self.log.info("Total time %s:%s:%s; batch time: %s" % (h,m,s, t2))
# after block added handler # after block added handler
if self.after_block_handler and not self.cache_loading: if self.after_block_handler and not self.cache_loading:
try: try:

3
pybtc/connector/utxo.py
View File

@ -44,7 +44,7 @@ class UTXO():
self.deleted_last_block = 0 self.deleted_last_block = 0
self.deleted_utxo = 0 self.deleted_utxo = 0
self.read_from_db_time = 0 self.read_from_db_time = 0
self.read_from_db_batch_time = time.time() self.read_from_db_batch_time = 0
self.read_from_db_count = 0 self.read_from_db_count = 0
self.read_from_db_time_total = 0 self.read_from_db_time_total = 0
self.loaded_utxo = 0 self.loaded_utxo = 0
@ -247,6 +247,7 @@ class UTXO():
except: pass except: pass
self.read_from_db_count += len(l) self.read_from_db_count += len(l)
self.read_from_db_time += time.time() - t self.read_from_db_time += time.time() - t
self.read_from_db_batch_time += time.time() - t
self.read_from_db_time_total += time.time() - t self.read_from_db_time_total += time.time() - t
except: except: