connector
This commit is contained in:
parent
07ad03bb6a
commit
2de3d7e73e
@ -200,6 +200,7 @@ class Worker:
|
|||||||
self.loop.run_forever()
|
self.loop.run_forever()
|
||||||
|
|
||||||
async def load_blocks(self, height):
|
async def load_blocks(self, height):
|
||||||
|
try:
|
||||||
batch = list()
|
batch = list()
|
||||||
h_list = list()
|
h_list = list()
|
||||||
while True:
|
while True:
|
||||||
@ -250,6 +251,8 @@ class Worker:
|
|||||||
blocks[x] = pickle.dumps(blocks[x])
|
blocks[x] = pickle.dumps(blocks[x])
|
||||||
|
|
||||||
self.pipe_sent_msg(b'result', pickle.dumps(blocks))
|
self.pipe_sent_msg(b'result', pickle.dumps(blocks))
|
||||||
|
except:
|
||||||
|
self.log.critical(str(traceback.format_exc()))
|
||||||
|
|
||||||
async def message_loop(self):
|
async def message_loop(self):
|
||||||
try:
|
try:
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user