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-10 02:10:04 +04:00
parent 23a445c244
commit d05a02c6a1
3 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pybtc/connector/block_loader.py
View File

@ -10,7 +10,8 @@ import sys
import aiojsonrpc import aiojsonrpc
import traceback import traceback
from pybtc.connector.utils import decode_block_tx from pybtc.connector.utils import decode_block_tx
import pickle # import pickle
import msgpack as pickle
from lru import LRU from lru import LRU

2
pybtc/connector/connector.py
View File

@ -12,7 +12,7 @@ import zmq
import zmq.asyncio import zmq.asyncio
import asyncio import asyncio
import time import time
from pickle import loads, dumps from msgpack import loads, dumps
class Connector: class Connector:
def __init__(self, node_rpc_url, node_zerromq_url, logger, def __init__(self, node_rpc_url, node_zerromq_url, logger,

11
pybtc/test/block.py
View File

@ -619,6 +619,17 @@ class BlockDeserializeTests(unittest.TestCase):
p = pickle.loads(k) p = pickle.loads(k)
print("decoded block load", time.time() - qt) print("decoded block load", time.time() - qt)
print(p[0]["hash"]) print(p[0]["hash"])
qt = time.time()
k = pickle.dumps(bt, protocol = pickle.HIGHEST_PROTOCOL)
print("decoded block dump", time.time() - qt)
qt = time.time()
p = pickle.loads(k)
print("decoded block load", time.time() - qt)
print(p[0]["hash"])
import cProfile import cProfile
# cProfile.run("import pybtc;" # cProfile.run("import pybtc;"