openstack/deb-python-websocket-client
Code Issues Proposed changes

fixed #53

Browse Source
This commit is contained in:
juanmb
2013-10-02 22:39:11 +02:00
parent 70dc014b07
commit 6d5fb70ddf
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
websocket.py
View File

@@ -820,8 +820,11 @@ class WebSocketApp(object):
self.sock.close() self.sock.close()
def _send_ping(self, interval): def _send_ping(self, interval):
while self.keep_running: while True:
time.sleep(interval) for i in range(interval):
time.sleep(1)
if not self.keep_running:
return
self.sock.ping() self.sock.ping()
def run_forever(self, sockopt=None, sslopt=None, ping_interval=0): def run_forever(self, sockopt=None, sslopt=None, ping_interval=0):
@@ -862,6 +865,7 @@ class WebSocketApp(object):
self._callback(self.on_error, e) self._callback(self.on_error, e)
finally: finally:
if thread: if thread:
self.keep_running = False
thread.join() thread.join()
self.sock.close() self.sock.close()
self._callback(self.on_close) self._callback(self.on_close)