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:17:01 +04:00
parent d05a02c6a1
commit 3ed08bfe0e
3 changed files with 5 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pybtc/connector/block_loader.py
View File

@ -10,8 +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 msgpack as pickle import _pickle 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 msgpack import loads, dumps from _pickle 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,

19
pybtc/test/block.py
View File

@ -603,15 +603,8 @@ class BlockDeserializeTests(unittest.TestCase):
bt = ( bt = (
Block(fc[:-1], format="raw", keep_raw_tx=False), Block(fc[:-1], format="raw", keep_raw_tx=False),
) )
print("decoded block", time.time() - qt )
import msgpack import _pickle as pickle
qt = time.time()
k = msgpack.dumps(bt)
print("decoded block dump", time.time() - qt)
qt = time.time()
p = msgpack.loads(k)
print("decoded block load", time.time() - qt)
import pickle
qt = time.time() qt = time.time()
k = pickle.dumps(bt) k = pickle.dumps(bt)
print("decoded block dump", time.time() - qt) print("decoded block dump", time.time() - qt)
@ -620,14 +613,6 @@ class BlockDeserializeTests(unittest.TestCase):
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