# HG changeset patch
# User Matt Johnston <matt@ucc.asn.au>
# Date 1428757753 -28800
# Node ID a01b7bccccd3f89feebb4679b74d7fdaafa3247a
# Parent  e39ed85d87a59cda18142c17e003a450aecb24f2
improve exception handling

diff -r e39ed85d87a5 -r a01b7bccccd3 py/fridge.py
--- a/py/fridge.py	Sat Apr 11 00:16:05 2015 +0800
+++ b/py/fridge.py	Sat Apr 11 21:09:13 2015 +0800
@@ -36,7 +36,10 @@
             L("Fridge is disabled")
         while True:
             self.do()
-            yield from self.server.sleep(config.FRIDGE_SLEEP)
+            try:
+                yield from self.server.sleep(config.FRIDGE_SLEEP)
+            except Exception as e:
+                EX("fridge failed")
 
     def do(self):
         """ this is the main fridge control logic """
diff -r e39ed85d87a5 -r a01b7bccccd3 py/sensor_test.py
--- a/py/sensor_test.py	Sat Apr 11 00:16:05 2015 +0800
+++ b/py/sensor_test.py	Sat Apr 11 21:09:13 2015 +0800
@@ -11,7 +11,7 @@
     def make_vals(self):
         def try_read(f, fallback):
             try:
-                return open(f, 'r').read()
+                return float(open(f, 'r').read())
             except Exception as e:
                 return fallback
 
@@ -22,7 +22,6 @@
         return vals
 
     def run(self):
-
         while True:
             yield from asyncio.sleep(1)
             vals = self.make_vals()
diff -r e39ed85d87a5 -r a01b7bccccd3 py/tempserver.py
--- a/py/tempserver.py	Sat Apr 11 00:16:05 2015 +0800
+++ b/py/tempserver.py	Sat Apr 11 21:09:13 2015 +0800
@@ -24,7 +24,7 @@
         self.readings = []
         self.current = (None, None)
         self.fridge = None
-        self._wakeup = asyncio.Event()
+        self._wakeup = asyncio.Condition()
 
     def __enter__(self):
         self.params = params.Params()
@@ -51,12 +51,11 @@
             self.sensors.run(),
             self.uploader.run(),
         )
+
         loop = asyncio.get_event_loop()
-        try:
-            loop.run_until_complete(asyncio.wait(tasks))
-            # not reached
-        except KeyboardInterrupt:
-            pass
+        result_tasks = loop.run_until_complete(asyncio.wait(tasks, return_when=asyncio.FIRST_EXCEPTION))
+        # use the results so that exceptions get thrown
+        [t.result() for x in result_tasks for t in x]
 
     def now(self):
         return utils.monotonic_time()
@@ -90,25 +89,33 @@
 
     def current_temps(self):
         """ returns (wort_temp, fridge_temp) tuple """
+        D("current: %s" % str(self.current))
         return self.current
 
+    @asyncio.coroutine
     def sleep(self, timeout):
         """ sleeps for timeout seconds, though wakes if the server's config is updated """
-        asyncio.wait_for(self._wakeup, timeout=timeout)
+        # XXX fixme - we should wake on _wakeup but asyncio Condition with wait_for is a bit broken? 
+        # https://groups.google.com/forum/#!topic/python-tulip/eSm7rZAe9LM
+        # For now we just sleep, ignore the _wakeup
+        yield from asyncio.sleep(timeout)
         
+    @asyncio.coroutine
     def _reload_signal(self):
         try:
             self.params.load()
             L("Reloaded.")
-            self._wakeup.set()
-            self._wakeup.clear()
+            yield from self._wakeup.acquire()
+            self._wakeup.notify_all()
+            self._wakeup.release()
         except Error as e:
             W("Problem reloading: %s" % str(e))
 
 def setup_logging():
     logging.basicConfig(format='%(asctime)s %(message)s', 
             datefmt='%m/%d/%Y %I:%M:%S %p',
-            level=logging.INFO)
+            level=logging.DEBUG)
+    logging.getLogger("asyncio").setLevel(logging.DEBUG)
 
 def start():
     with Tempserver() as server: