Websocket: changes to include closing websocket
This commit is contained in:
parent
c3f0abd671
commit
b251a2ebbb
@ -43,6 +43,7 @@ class KlippyWebsocket(threading.Thread):
|
|||||||
self._screen = screen
|
self._screen = screen
|
||||||
self._callback = callback
|
self._callback = callback
|
||||||
self.klippy = MoonrakerApi(self)
|
self.klippy = MoonrakerApi(self)
|
||||||
|
self.closing = False
|
||||||
|
|
||||||
self._url = "%s:%s" % (host, port)
|
self._url = "%s:%s" % (host, port)
|
||||||
|
|
||||||
@ -73,6 +74,9 @@ class KlippyWebsocket(threading.Thread):
|
|||||||
except Exception:
|
except Exception:
|
||||||
logger.debug("Error starting web socket")
|
logger.debug("Error starting web socket")
|
||||||
|
|
||||||
|
def close(self):
|
||||||
|
self.closing = True
|
||||||
|
|
||||||
def is_connected(self):
|
def is_connected(self):
|
||||||
return self.connected
|
return self.connected
|
||||||
|
|
||||||
@ -133,6 +137,11 @@ class KlippyWebsocket(threading.Thread):
|
|||||||
logger.debug("Connection already closed")
|
logger.debug("Connection already closed")
|
||||||
return
|
return
|
||||||
|
|
||||||
|
if self.closing == True:
|
||||||
|
logger.debug("Closing websocket")
|
||||||
|
self.ws.stop()
|
||||||
|
return
|
||||||
|
|
||||||
logger.info("Moonraker Websocket Closed")
|
logger.info("Moonraker Websocket Closed")
|
||||||
self.connected = False
|
self.connected = False
|
||||||
if self.timeout == None:
|
if self.timeout == None:
|
||||||
|
Loading…
x
Reference in New Issue
Block a user