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:43:52 +04:00
parent a3d80f9906
commit abadd34aeb
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pybtc/connector/block_loader.py
View File

@ -147,7 +147,9 @@ class Worker:
try: try:
self.rpc = aiojsonrpc.rpc(self.rpc_url, self.loop, timeout=self.rpc_timeout) self.rpc = aiojsonrpc.rpc(self.rpc_url, self.loop, timeout=self.rpc_timeout)
self.reader = await self.get_pipe_reader(self.in_reader) self.reader = await self.get_pipe_reader(self.in_reader)
self.log.critical("reader")
while True: while True:
self.log.critical("get pos")
msg_type, msg = await self.pipe_get_msg(self.reader) msg_type, msg = await self.pipe_get_msg(self.reader)
self.log.critical(str(len(msg))) self.log.critical(str(len(msg)))
if msg_type == b'pipe_read_error': if msg_type == b'pipe_read_error':