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 19:14:26 +04:00
parent 28f819d15a
commit d09abbe4d9
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pybtc/connector/block_loader.py
View File

@ -74,7 +74,8 @@ class BlockLoader:
self.log.error("Loading task error %s " % err)
else:
await asyncio.sleep(1)
[p.terminate() for p in self.worker_tasks]
[self.worker_tasks[p].terminate() for p in self.worker_tasks]
for p in self.worker_busy: self.worker_busy[p] = False
@ -154,9 +155,10 @@ class BlockLoader:
blocks = pickle.loads(msg)
for i in blocks:
self.parent.block_preload.set(i, blocks[i])
self.worker_busy[index] = False
# def disconnect(self,ip):
# def disconnect(self,ip):
# """ Disconnect peer """
# p = self.out_connection_pool[self.outgoing_connection[ip]["pool"]]
# pipe_sent_msg(p.writer, b'disconnect', ip.encode())