diff options
| -rw-r--r-- | python/qpid/util.py | 2 | ||||
| -rw-r--r-- | python/tests/assembler.py | 1 | ||||
| -rw-r--r-- | python/tests/connection.py | 1 | ||||
| -rw-r--r-- | python/tests/framer.py | 1 |
4 files changed, 4 insertions, 1 deletions
diff --git a/python/qpid/util.py b/python/qpid/util.py index 1ca616f1f5..bb7f5090df 100644 --- a/python/qpid/util.py +++ b/python/qpid/util.py @@ -34,8 +34,8 @@ def listen(host, port, predicate = lambda: True, bound = lambda: None): sock = socket.socket() sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) sock.bind((host, port)) - bound() sock.listen(5) + bound() while predicate(): s, a = sock.accept() yield s diff --git a/python/tests/assembler.py b/python/tests/assembler.py index b76924e59d..f4e37084b6 100644 --- a/python/tests/assembler.py +++ b/python/tests/assembler.py @@ -47,6 +47,7 @@ class AssemblerTest(TestCase): self.server.start() started.wait(3) + assert started.isSet() def tearDown(self): self.running = False diff --git a/python/tests/connection.py b/python/tests/connection.py index 23e0c937fb..512fa62189 100644 --- a/python/tests/connection.py +++ b/python/tests/connection.py @@ -87,6 +87,7 @@ class ConnectionTest(TestCase): self.server.start() started.wait(3) + assert started.isSet() def tearDown(self): self.running = False diff --git a/python/tests/framer.py b/python/tests/framer.py index 05bb467bbe..e99166721c 100644 --- a/python/tests/framer.py +++ b/python/tests/framer.py @@ -46,6 +46,7 @@ class FramerTest(TestCase): self.server.start() started.wait(3) + assert started.isSet() def tearDown(self): self.running = False |