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 23:58:37 +04:00
parent 00618b8144
commit 248957f7f3
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pybtc/connector.py
View File

@ -260,7 +260,7 @@ class Connector:
while True: while True:
try: try:
while True: while True:
await asyncio.sleep(10) await asyncio.sleep(20)
if int(time.time()) - self.last_zmq_msg > 300 and self.zmqContext: if int(time.time()) - self.last_zmq_msg > 300 and self.zmqContext:
self.log.error("ZerroMQ no messages about 5 minutes") self.log.error("ZerroMQ no messages about 5 minutes")
try: try:
@ -278,11 +278,8 @@ class Connector:
async def get_next_block(self): async def get_next_block(self):
if self.active and self.active_block.done(): if self.active and self.active_block.done():
while True: if not self.get_next_block_mutex.done():
if not self.get_next_block_mutex.done(): return
await self.get_next_block_mutex
continue
break
try: try:
self.get_next_block_mutex = asyncio.Future() self.get_next_block_mutex = asyncio.Future()