From 3d6629348aedf2a6863d242d96d64b3492e86f9a Mon Sep 17 00:00:00 2001
From: Ivan Alejandro <ivanalejandro0@gmail.com>
Date: Wed, 16 Jul 2014 11:29:19 -0300
Subject: Increase timeout and retries.

With this change we avoid the communication issues on OSX.
---
 src/leap/bitmask/backend/signaler.py | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

(limited to 'src/leap/bitmask/backend/signaler.py')

diff --git a/src/leap/bitmask/backend/signaler.py b/src/leap/bitmask/backend/signaler.py
index 7401f3a0..574bfa71 100644
--- a/src/leap/bitmask/backend/signaler.py
+++ b/src/leap/bitmask/backend/signaler.py
@@ -38,8 +38,8 @@ class Signaler(object):
     """
     PORT = "5667"
     SERVER = "tcp://localhost:%s" % PORT
-    POLL_TIMEOUT = 1000  # ms
-    POLL_TRIES = 3
+    POLL_TIMEOUT = 2000  # ms
+    POLL_TRIES = 500
 
     def __init__(self):
         """
@@ -156,13 +156,18 @@ class Signaler(object):
         reply = None
         tries = 0
 
-        while tries < self.POLL_TRIES:
+        while True:
             socks = dict(poll.poll(self.POLL_TIMEOUT))
             if socks.get(self._socket) == zmq.POLLIN:
                 reply = self._socket.recv()
                 break
 
             tries += 1
+            if tries < self.POLL_TRIES:
+                logger.warning('Retrying receive... {0}/{1}'.format(
+                    tries, self.POLL_TRIES))
+            else:
+                break
 
         if reply is None:
             msg = "Timeout error contacting backend."
-- 
cgit v1.2.3