Show More
@@ -27,6 +27,9 import time | |||
|
27 | 27 | |
|
28 | 28 | # System library imports. |
|
29 | 29 | import zmq |
|
30 | # import ZMQError in top-level namespace, to avoid ugly attribute-error messages | |
|
31 | # during garbage collection of threads at exit: | |
|
32 | from zmq import ZMQError | |
|
30 | 33 | from zmq.eventloop import ioloop, zmqstream |
|
31 | 34 | |
|
32 | 35 | # Local imports. |
@@ -116,7 +119,7 class ZMQSocketChannel(Thread): | |||
|
116 | 119 | while True: |
|
117 | 120 | try: |
|
118 | 121 | self.ioloop.start() |
|
119 |
except |
|
|
122 | except ZMQError as e: | |
|
120 | 123 | if e.errno == errno.EINTR: |
|
121 | 124 | continue |
|
122 | 125 | else: |
@@ -505,7 +508,7 class HBSocketChannel(ZMQSocketChannel): | |||
|
505 | 508 | while True: |
|
506 | 509 | try: |
|
507 | 510 | events = self.poller.poll(1000 * until_dead) |
|
508 |
except |
|
|
511 | except ZMQError as e: | |
|
509 | 512 | if e.errno == errno.EINTR: |
|
510 | 513 | # ignore interrupts during heartbeat |
|
511 | 514 | # this may never actually happen |
General Comments 0
You need to be logged in to leave comments.
Login now