senset/vnpy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

更新cPickle=>pickle

Browse Source
This commit is contained in:
msincenselee 2018-09-30 09:55:47 +08:00
parent 4655a1105d
commit 02edb869c2
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
vnpy/rpc/vnrpc.py
View File

@ -8,7 +8,7 @@ import zmq
from msgpack import packb, unpackb from msgpack import packb, unpackb
from json import dumps, loads from json import dumps, loads
import cPickle import pickle as cPickle
pDumps = cPickle.dumps pDumps = cPickle.dumps
pLoads = cPickle.loads pLoads = cPickle.loads
@ -128,7 +128,7 @@ class RpcServer(RpcObject):
# 工作线程相关 # 工作线程相关
self.__active = False # 服务器的工作状态 self.__active = False # 服务器的工作状态
self.__thread = threading.Thread(target=self.run) # 服务器的工作线程 self.__thread = threading.Thread(target=self.run) # 服务器的工作线程
#---------------------------------------------------------------------- #----------------------------------------------------------------------
def start(self): def start(self):
"""启动服务器""" """启动服务器"""
@ -307,7 +307,7 @@ class RpcClient(RpcObject):
topic = '' topic = ''
else: else:
topic = topic.encode('utf-8') topic = topic.encode('utf-8')
self.__socketSUB.setsockopt(zmq.SUBSCRIBE, topic) self.__socketSUB.setsockopt_string(zmq.SUBSCRIBE, topic)
######################################################################## ########################################################################