From 61e033516e64709bfcc49860fc83925da57d180a Mon Sep 17 00:00:00 2001 From: 4tochka Date: Fri, 10 May 2019 01:42:46 +0400 Subject: [PATCH] connector --- pybtc/connector/block_loader.py | 6 +++--- pybtc/connector/connector.py | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/pybtc/connector/block_loader.py b/pybtc/connector/block_loader.py index 5a4d7b6..2d27a56 100644 --- a/pybtc/connector/block_loader.py +++ b/pybtc/connector/block_loader.py @@ -10,7 +10,7 @@ import sys import aiojsonrpc import traceback from pybtc.connector.utils import decode_block_tx -import msgpack +from pickle import loads, dumps from lru import LRU @@ -162,7 +162,7 @@ class BlockLoader: if msg_type == b'result': self.worker_busy[index] = False - blocks = msgpack.loads(msg) + blocks = loads(msg) for i in blocks: self.parent.block_preload.set(i, blocks[i]) @@ -258,7 +258,7 @@ class Worker: # blocks[x] = msgpack.dumps(blocks[x]) - self.pipe_sent_msg(b'result', msgpack.dumps(blocks)) + self.pipe_sent_msg(b'result', dumps(blocks)) except: self.log.critical(str(traceback.format_exc())) diff --git a/pybtc/connector/connector.py b/pybtc/connector/connector.py index 4cad3a5..ca8ee40 100644 --- a/pybtc/connector/connector.py +++ b/pybtc/connector/connector.py @@ -12,7 +12,7 @@ import zmq import zmq.asyncio import asyncio import time -import msgpack +from pickle import loads, dumps class Connector: def __init__(self, node_rpc_url, node_zerromq_url, logger,