From 3227e31301d7e0031f2e7478b677a1fb91fa758d Mon Sep 17 00:00:00 2001 From: Sebastian Steuer Date: Sun, 24 Nov 2013 16:50:16 +0100 Subject: [PATCH] logging changes, fixed refresh bug --- picoreflowd.py | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/picoreflowd.py b/picoreflowd.py index faaf147..5f6e089 100644 --- a/picoreflowd.py +++ b/picoreflowd.py @@ -5,7 +5,7 @@ from gevent.pywsgi import WSGIServer from geventwebsocket import WebSocketHandler, WebSocketError log_format = '%(asctime)s %(levelname)s %(name)s: %(message)s' -logging.basicConfig(level = logging.DEBUG, format = log_format) +logging.basicConfig(level = logging.INFO, format = log_format) log = logging.getLogger("picoreflowd") log.info("Starting picoreflowd") @@ -35,6 +35,7 @@ def get_websocket_from_request(): @app.route('/control') def handle_control(): wsock = get_websocket_from_request() + log.info("websocket (control) opened") while True: try: message = wsock.receive() @@ -47,14 +48,17 @@ def handle_control(): oven.abort_run() except WebSocketError: break + log.info("websocket (control) closed") @app.route('/storage') def handle_storage(): wsock = get_websocket_from_request() - + log.info("websocket (storage) opened") while True: try: message = wsock.receive() + if not message: + break if message == "GET": log.info("GET command recived") wsock.send(get_profiles()) @@ -62,17 +66,20 @@ def handle_storage(): log.info("PUT command received") except WebSocketError: break + log.info("websocket (storage) closed") @app.route('/status') def handle_status(): wsock = get_websocket_from_request() ovenWatcher.addObserver(wsock) + log.info("websocket (status) opened") while True: try: message = wsock.receive() wsock.send("Your message was: %r" % message) except WebSocketError: break + log.info("websocket (status) closed") def get_profiles(): script_dir = os.path.dirname(os.path.realpath(__file__))