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

Merge pull request #1552 from qqqlyx/master

Browse Source 
[Add] ping_interval
This commit is contained in:
vn.py 2019-04-04 15:25:05 +08:00 committed by GitHub
commit 0addc94ed2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
vnpy/api/websocket/websocket_client.py
View File

@ -48,14 +48,18 @@ class WebsocketClient(object):
self.proxy_host = None
self.proxy_port = None
self.ping_interval = 60 # seconds
# For debugging
self._last_sent_text = None
self._last_received_text = None
def init(self, host: str, proxy_host: str = "", proxy_port: int = 0):
""""""
def init(self, host: str, proxy_host: str = "", proxy_port: int = 0, ping_interval: int = 60):
"""
:param ping_interval: unit: seconds, type: int
"""
self.host = host
self.ping_interval = ping_interval # seconds
if proxy_host and proxy_port:
self.proxy_host = proxy_host
@ -206,7 +210,7 @@ class WebsocketClient(object):
et, ev, tb = sys.exc_info()
self.on_error(et, ev, tb)
self._reconnect()
for i in range(60):
for i in range(self.ping_interval):
if not self._active:
break
sleep(1)