reduce cpu and network usage with websockets
This commit is contained in:
parent
d58025fa9e
commit
e207c54181
@ -1,5 +1,6 @@
|
|||||||
#!/usr/bin/env python
|
#!/usr/bin/env python
|
||||||
|
|
||||||
|
import time
|
||||||
import os
|
import os
|
||||||
import sys
|
import sys
|
||||||
import logging
|
import logging
|
||||||
@ -162,6 +163,7 @@ def handle_control():
|
|||||||
elif msgdict.get("cmd") == "STOP":
|
elif msgdict.get("cmd") == "STOP":
|
||||||
log.info("Stop command received")
|
log.info("Stop command received")
|
||||||
oven.abort_run()
|
oven.abort_run()
|
||||||
|
time.sleep(1)
|
||||||
except WebSocketError as e:
|
except WebSocketError as e:
|
||||||
log.error(e)
|
log.error(e)
|
||||||
break
|
break
|
||||||
@ -209,6 +211,7 @@ def handle_storage():
|
|||||||
|
|
||||||
wsock.send(json.dumps(msgdict))
|
wsock.send(json.dumps(msgdict))
|
||||||
wsock.send(get_profiles())
|
wsock.send(get_profiles())
|
||||||
|
time.sleep(1)
|
||||||
except WebSocketError:
|
except WebSocketError:
|
||||||
break
|
break
|
||||||
log.info("websocket (storage) closed")
|
log.info("websocket (storage) closed")
|
||||||
@ -224,6 +227,7 @@ def handle_config():
|
|||||||
wsock.send(get_config())
|
wsock.send(get_config())
|
||||||
except WebSocketError:
|
except WebSocketError:
|
||||||
break
|
break
|
||||||
|
time.sleep(1)
|
||||||
log.info("websocket (config) closed")
|
log.info("websocket (config) closed")
|
||||||
|
|
||||||
|
|
||||||
@ -238,6 +242,7 @@ def handle_status():
|
|||||||
wsock.send("Your message was: %r" % message)
|
wsock.send("Your message was: %r" % message)
|
||||||
except WebSocketError:
|
except WebSocketError:
|
||||||
break
|
break
|
||||||
|
time.sleep(1)
|
||||||
log.info("websocket (status) closed")
|
log.info("websocket (status) closed")
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user