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

[Add]添加xtpGateway的断线重连功能

Browse Source
This commit is contained in:
vn.py 2018-01-06 13:30:58 +08:00
parent 61608dd20d
commit d519cfbdfe
1 changed files with 22 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
vnpy/trader/gateway/xtpGateway/xtpGateway.py
View File

@ -261,6 +261,16 @@ class XtpMdApi(QuoteApi):
content = (u'行情服务器连接断开，原因：%s' %reason)
self.writeLog(content)
# 重新连接
n = self.login(self.address, self.port, self.userID, self.password, 1)
if not n:
self.connectionStatus = True
self.loginStatus = True
self.gateway.mdConnected = True
self.writeLog(u'行情服务器登录成功')
else:
self.writeLog(u'行情服务器登录失败，原因:%s' %n)
#----------------------------------------------------------------------
def onError(self, error):
"""错误回报"""
@ -418,7 +428,6 @@ class XtpMdApi(QuoteApi):
os.makedirs(path)
self.createQuoteApi(clientID, path)
print address, port, userID, password
n = self.login(address, port, userID, password, 1)
if not n:
self.connectionStatus = True
@ -501,6 +510,18 @@ class XtpTdApi(TraderApi):
content = (u'交易服务器连接断开，原因：%s' %reason)
self.writeLog(content)
# 发起重新连接
n = self.login(self.address, self.port, self.userID, self.password, 1)
if n:
self.sessionID = n
self.connectionStatus = True
self.loginStatus = True
self.gateway.tdConnected = True
self.writeLog(u'交易服务器登录成功，会话编号：%s' %n)
else:
self.writeLog(u'交易服务器登录失败')
#----------------------------------------------------------------------
def onError(self, data):
"""错误回报"""