a little experiment with zmq polling2

7 years ago · 1c2af31314
parent 2e561bbed9
commit 1c2af31314
1 changed files with 6 additions and 7 deletions
--- a/screenless/bureau/bureau.py
+++ b/screenless/bureau/bureau.py
@ -312,13 +312,12 @@ class Bureau(object):
        poller.register(self._recv, zmq.POLLIN)

        while True:
-            try:
-                msgs = dict(poller.poll(500))
-                if msgs:
-                    if msgs.get(self._recv) == zmq.POLLIN:
-                        msg = self._recv.recv_string(flags=zmq.NOBLOCK)
-                else:
-                    continue
+            msgs = dict(poller.poll(500))
+            if msgs:
+                if msgs.get(self._recv) == zmq.POLLIN:
+                    msg = self._recv.recv_string(flags=zmq.NOBLOCK)
+            else:
+                continue
            #    msg = self._recv.recv_string(flags=zmq.NOBLOCK)
            #except zmq.ZMQError:
            #    time.sleep(0.05)  # don't waste CPU