summaryrefslogtreecommitdiff
path: root/src/leap/bitmask/backend/signaler.py
diff options
context:
space:
mode:
authorIvan Alejandro <ivanalejandro0@gmail.com>2014-07-16 11:29:19 -0300
committerIvan Alejandro <ivanalejandro0@gmail.com>2014-07-16 13:05:47 -0300
commit3d6629348aedf2a6863d242d96d64b3492e86f9a (patch)
treee0e25a94f62a635df1a7840b72fc3645358aefde /src/leap/bitmask/backend/signaler.py
parent432fcab9f838b0bfc81ed8d40d92b4b5d3854f24 (diff)
Increase timeout and retries.
With this change we avoid the communication issues on OSX.
Diffstat (limited to 'src/leap/bitmask/backend/signaler.py')
-rw-r--r--src/leap/bitmask/backend/signaler.py11
1 files changed, 8 insertions, 3 deletions
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."