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-02 00:33:01 +04:00
parent 45a447ac05
commit 612046b5f5
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pybtc/connector.py
View File

@ -329,7 +329,10 @@ class Connector:
self.log.error(str(traceback.format_exc())) self.log.error(str(traceback.format_exc()))
async def _new_block(self, block): async def _new_block(self, block):
if self.block_cache.get(block["hash"]) is not None:
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"]:
return return
@ -435,9 +438,6 @@ class Connector:
self.log.debug("Transactions received: %s [%s] received tx rate tx/s ->> %s <<" % (tx_count, time.time() - q, rate)) self.log.debug("Transactions received: %s [%s] received tx rate tx/s ->> %s <<" % (tx_count, time.time() - q, rate))
async def verify_block_position(self, block): async def verify_block_position(self, block):
if self.block_cache.get(block["hash"]) is not None:
self.log.error("duplicated block %s" % block["hash"])
raise Exception("duplicated block")
if "previousblockhash" not in block : if "previousblockhash" not in block :
return return
lb = self.block_cache.get_last_key() lb = self.block_cache.get_last_key()