From 899609b19278ec71f5545a2a23f3d4c5419e1385 Mon Sep 17 00:00:00 2001
From: Philip ABBET <philip.abbet@idiap.ch>
Date: Fri, 8 Sep 2017 16:19:33 +0200
Subject: [PATCH] [tests] Fix a problem with the successive binding of lots of
sockets to random ports
---
beat/core/agent.py | 2 +-
beat/core/test/test_dbexecution.py | 2 +-
beat/core/test/test_message_handler.py | 4 ++--
3 files changed, 4 insertions(+), 4 deletions(-)
mode change 100644 => 100755 beat/core/test/test_dbexecution.py
mode change 100644 => 100755 beat/core/test/test_message_handler.py
diff --git a/beat/core/agent.py b/beat/core/agent.py
index c6bce880..152a9e14 100755
--- a/beat/core/agent.py
+++ b/beat/core/agent.py
@@ -59,7 +59,7 @@ class Server(MessageHandler):
self.socket = self.context.socket(zmq.PAIR)
self.address = 'tcp://' + host_address
- port = self.socket.bind_to_random_port(self.address)
+ port = self.socket.bind_to_random_port(self.address, min_port=50000)
self.address += ':%d' % port
logger.debug("zmq server bound to `%s'", self.address)
diff --git a/beat/core/test/test_dbexecution.py b/beat/core/test/test_dbexecution.py
old mode 100644
new mode 100755
index ff5c81c9..a0d28702
--- a/beat/core/test/test_dbexecution.py
+++ b/beat/core/test/test_dbexecution.py
@@ -102,7 +102,7 @@ class HostSide(object):
# 0MQ server
self.socket = zmq_context.socket(zmq.PAIR)
self.address = 'tcp://127.0.0.1'
- port = self.socket.bind_to_random_port(self.address)
+ port = self.socket.bind_to_random_port(self.address, min_port=50000)
self.address += ':%d' % port
database = Database(prefix, 'integers_db/1')
diff --git a/beat/core/test/test_message_handler.py b/beat/core/test/test_message_handler.py
old mode 100644
new mode 100755
index 69394769..e5092fae
--- a/beat/core/test/test_message_handler.py
+++ b/beat/core/test/test_message_handler.py
@@ -100,7 +100,7 @@ class TestMessageHandler(unittest.TestCase):
self.server_context = zmq.Context()
server_socket = self.server_context.socket(zmq.PAIR)
address = 'tcp://127.0.0.1'
- port = server_socket.bind_to_random_port(address)
+ port = server_socket.bind_to_random_port(address, min_port=50000)
address += ':%d' % port
self.message_handler = MessageHandler(self.input_list, self.server_context, server_socket)
@@ -190,7 +190,7 @@ class TestMessageHandlerErrorHandling(unittest.TestCase):
self.server_context = zmq.Context()
server_socket = self.server_context.socket(zmq.PAIR)
address = 'tcp://127.0.0.1'
- port = server_socket.bind_to_random_port(address)
+ port = server_socket.bind_to_random_port(address, min_port=50000)
address += ':%d' % port
self.message_handler = MessageHandler(self.input_list, self.server_context, server_socket)
--
GitLab