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-04 10:53:16 +04:00
parent cb09298ec5
commit da8019ef1f
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
pybtc/connector.py
View File

@ -196,7 +196,7 @@ class Connector:
(self.app_block_height_on_start - self.last_block_height,)) (self.app_block_height_on_start - self.last_block_height,))
else: else:
self.app_block_height_on_start = self.last_block_height self.app_block_height_on_start = self.last_block_utxo_cached_height
async def zeromq_handler(self): async def zeromq_handler(self):
@ -349,6 +349,7 @@ class Connector:
async def _new_block(self, block): async def _new_block(self, block):
if self.block_headers_cache.get(block["hash"]) is not None: if self.block_headers_cache.get(block["hash"]) is not None:
return return
if self.deep_synchronization: if self.deep_synchronization:
block["height"] = self.last_block_height + 1 block["height"] = self.last_block_height + 1
if not self.active or not self.active_block.done() or self.last_block_height >= block["height"]: if not self.active or not self.active_block.done() or self.last_block_height >= block["height"]:
@ -636,7 +637,7 @@ class Connector:
await self.utxo.load_utxo() await self.utxo.load_utxo()
[stxo.add(self.utxo.get_loaded(o, block_height)) for o, s in missed] [stxo.add(self.utxo.get_loaded(o, block_height)) for o, s in missed]
if len(stxo) != len(tx["vIn"]): if len(stxo) != len(tx["vIn"]) and not self.cache_loading:
self.log.critical("utxo get failed " + rh2s(tx["txId"])) self.log.critical("utxo get failed " + rh2s(tx["txId"]))
self.log.critical(str(stxo)) self.log.critical(str(stxo))
raise Exception("utxo get failed ") raise Exception("utxo get failed ")