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-15 20:28:20 +04:00
parent 8a44ec2560
commit 940045d6df
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/block_loader.py
View File

@ -121,9 +121,9 @@ class BlockLoader:
# start message loop # start message loop
self.loop.create_task(self.message_loop(index)) self.loop.create_task(self.message_loop(index))
# wait if process crash # wait if process crash
await self.loop.run_in_executor(None, worker.join) r = await self.loop.run_in_executor(None, worker.join)
del self.worker[index] del self.worker[index]
self.log.warning('Block loader worker %s is stopped' % index) self.log.warning('Block loader worker %s is stopped [%s]' % (index, r))
@ -286,6 +286,7 @@ class Worker:
while True: while True:
msg_type, msg = await self.pipe_get_msg(self.reader) msg_type, msg = await self.pipe_get_msg(self.reader)
if msg_type == b'pipe_read_error': if msg_type == b'pipe_read_error':
self.log.critical("pipe_read_error")
return return
if msg_type == b'get': if msg_type == b'get':