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-04-28 16:28:23 +04:00
parent 4df814e7cf
commit 54273d23e9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pybtc/connector.py
View File

@ -145,6 +145,8 @@ class Connector:
msg = await self.zmqSubSocket.recv_multipart() msg = await self.zmqSubSocket.recv_multipart()
topic = msg[0] topic = msg[0]
body = msg[1] body = msg[1]
if self.deep_synchronization:
continue
if topic == b"hashblock": if topic == b"hashblock":
self.last_zmq_msg = int(time.time()) self.last_zmq_msg = int(time.time())
hash = body.hex() hash = body.hex()
@ -152,8 +154,6 @@ class Connector:
self.loop.create_task(self._get_block_by_hash(hash)) self.loop.create_task(self._get_block_by_hash(hash))
elif topic == b"rawtx": elif topic == b"rawtx":
self.last_zmq_msg = int(time.time()) self.last_zmq_msg = int(time.time())
if self.deep_synchronization:
continue
try: try:
self.loop.create_task(self._new_transaction(Transaction(body, format="raw"))) self.loop.create_task(self._new_transaction(Transaction(body, format="raw")))
except: except: