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

[Mod] md, td并行连接，加快td响应速度。

Browse Source
This commit is contained in:
nanoric 2019-03-08 07:33:36 -04:00
parent 7eaa0c19f6
commit 9b694fce07
1 changed files with 11 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
vnpy/gateway/oes/oes_gateway.py
View File

@ -38,10 +38,6 @@ class OesGateway(BaseGateway):
self.td_api = OesTdApi(self)
def connect(self, setting: dict):
""""""
return self._connect_async(setting)
def _connect_sync(self, setting: dict):
""""""
if not setting['password'].startswith("md5:"):
setting['password'] = "md5:" + hashlib.md5(setting['password'].encode()).hexdigest()
@ -67,14 +63,10 @@ class OesGateway(BaseGateway):
log_path=log_path)
f.write(content)
self.md_api.config_path = config_path
self.md_api.username = username
self.md_api.password = password
if self.md_api.connect():
self.md_api.start()
else:
self.write_log(_("无法连接到行情服务器，请检查你的配置"))
Thread(target=self._connect_md_sync, args=(config_path, username, password)).start()
Thread(target=self._connect_td_sync, args=(config_path, username, password)).start()
def _connect_td_sync(self, config_path, username, password):
self.td_api.config_path = config_path
self.td_api.username = username
self.td_api.password = password
@ -89,9 +81,14 @@ class OesGateway(BaseGateway):
else:
self.write_log(_("无法连接到交易服务器，请检查你的配置"))
def _connect_async(self, setting: dict):
""""""
Thread(target=self._connect_sync, args=(setting,)).start()
def _connect_md_sync(self, config_path, username, password):
self.md_api.config_path = config_path
self.md_api.username = username
self.md_api.password = password
if self.md_api.connect():
self.md_api.start()
else:
self.write_log(_("无法连接到行情服务器，请检查你的配置"))
def subscribe(self, req: SubscribeRequest):
""""""