openstack/oslo.messaging
Code Issues Proposed changes

[zmq] Fix zmq-specific f-tests from periodic hangs

Browse Source 
Change-Id: Ie7f7b5a61229db80194a26bc0cefa45e2a7614a9
This commit is contained in:
Gevorg Davoian 2016-11-25 17:05:13 +02:00
parent f1d3dbd068
commit 7b841040c9
1 changed files with 4 additions and 6 deletions

10
oslo_messaging/tests/functional/zmq/test_startup.py

@ -33,18 +33,16 @@ class StartupOrderTestCase(multiproc_utils.MultiprocTestCase):
sys.stdout = open(log_path, "w", buffering=0)
def test_call_client_wait_for_server(self):
self.spawn_servers(3, wait_for_server=True, common_topic=True)
servers = self.spawned
client = self.get_client(servers[0].topic)
server = self.spawn_server(wait_for_server=True)
client = self.get_client(server.topic)
for _ in range(3):
reply = client.call_a()
self.assertIsNotNone(reply)
self.assertEqual(3, len(client.replies))
def test_call_client_dont_wait_for_server(self):
self.spawn_servers(3, wait_for_server=False, common_topic=True)
servers = self.spawned
client = self.get_client(servers[0].topic)
server = self.spawn_server(wait_for_server=False)
client = self.get_client(server.topic)
for _ in range(3):
reply = client.call_a()
self.assertIsNotNone(reply)