retry poll() on EINTR

pika · Jun 4, 2013 · baf23dd · baf23dd
1 parent 7cd8762
commit baf23dd
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/pika/adapters/blocking_connection.py b/pika/adapters/blocking_connection.py
@@ -15,6 +15,7 @@
 import socket
 import time
 import warnings
+import errno
 
 from pika import callback
 from pika import channel
@@ -59,7 +60,14 @@ def ready(self):
 
         """
         if self.poller:
-            events = self.poller.poll(self.poll_timeout)
+            while True:
+                try:
+                    events = self.poller.poll(self.poll_timeout)
+                    break
+                except select.error as e:
+                    if e[0] != errno.EINTR:
+                        raise
+
             return True if events else False
         else:
             ready, unused_wri, unused_err = select.select([self.fd], [], [],