commit afd98748dbb15d1eaea0b7a634e787f7fa4134dc
author koder aka kdanilov <kdanilov@mirantis.com> Fri Apr 24 01:27:22 2015 +0300
committer koder aka kdanilov <kdanilov@mirantis.com> Fri Apr 24 01:27:22 2015 +0300
tree f2814f08137588daf837790b6f95ce9a48d4e786
parent a4a570f820474accff488bc99d67a4d809d1577b

fixes, fixes, fixes

wally/sensors/api.py

diff --git a/wally/sensors/api.py b/wally/sensors/api.py
index ea73789..e8c6261 100644
--- a/wally/sensors/api.py
+++ b/wally/sensors/api.py
@@ -4,7 +4,7 @@
 
 from .deploy_sensors import (deploy_and_start_sensors,
                              stop_and_remove_sensors)
-from .protocol import create_protocol, Timeout
+from .protocol import create_protocol, Timeout, CantUnpack
 
 
 __all__ = ['Empty', 'recv_main',
@@ -32,9 +32,15 @@
 def recv_main(proto, data_q, cmd_q):
     while True:
         try:
-            data_q.put(proto.recv(0.1))
+            ip, packet = proto.recv(0.1)
+            if packet is not None:
+                data_q.put((ip, packet))
+        except AssertionError as exc:
+            logger.warning("Error in sensor data " + str(exc))
         except Timeout:
             pass
+        except CantUnpack as exc:
+            print exc
 
         try:
             val = cmd_q.get(False)