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-07 02:30:26 +04:00
parent 6ccaaf21b4
commit a3d80f9906
1 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
pybtc/connector/block_loader.py
View File

@ -143,17 +143,21 @@ class Worker:
self.loop.run_forever() self.loop.run_forever()
async def message_loop(self): async def message_loop(self):
self.rpc = aiojsonrpc.rpc(self.rpc_url, self.loop, timeout=self.rpc_timeout) self.log.critical("xxx")
self.reader = await self.get_pipe_reader(self.in_reader) try:
while True: self.rpc = aiojsonrpc.rpc(self.rpc_url, self.loop, timeout=self.rpc_timeout)
msg_type, msg = await self.pipe_get_msg(self.reader) self.reader = await self.get_pipe_reader(self.in_reader)
self.log.critical(str(len(msg))) while True:
if msg_type == b'pipe_read_error': msg_type, msg = await self.pipe_get_msg(self.reader)
return
if msg_type == b'get':
self.log.critical(str(len(msg))) self.log.critical(str(len(msg)))
continue if msg_type == b'pipe_read_error':
return
if msg_type == b'get':
self.log.critical(str(len(msg)))
continue
except:
self.log.critical("exc")