diff options
| author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-01-27 14:41:55 +0000 |
|---|---|---|
| committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-01-27 14:41:55 +0000 |
| commit | a7ff22a37baac189c1f433fe7785bd3a637953b1 (patch) | |
| tree | 48768b61cda94e322166fd356e17a4df4ffdd2a1 /python/qmf2/tests/events.py | |
| parent | 6c6128ed113f349b76a70a257b1a7992c164d60c (diff) | |
| download | qpid-python-a7ff22a37baac189c1f433fe7785bd3a637953b1.tar.gz | |
QPID-2261: add wait in tests for agent setup to complete
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@903660 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'python/qmf2/tests/events.py')
| -rw-r--r-- | python/qmf2/tests/events.py | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/python/qmf2/tests/events.py b/python/qmf2/tests/events.py index 171cb80aaa..25c749cffa 100644 --- a/python/qmf2/tests/events.py +++ b/python/qmf2/tests/events.py @@ -75,10 +75,16 @@ class _agentApp(Thread): self.agent.register_object_class(_schema) self.running = False + self.ready = Event() def start_app(self): self.running = True self.start() + self.ready.wait(10) + if not self.ready.is_set(): + raise Exception("Agent failed to connect to broker.") + # time.sleep(1) + print("!!! agent=%s setup complete (%s)" % (self.agent, time.time())) def stop_app(self): self.running = False @@ -100,6 +106,8 @@ class _agentApp(Thread): raise Skipped(e) self.agent.set_connection(conn) + print("!!! agent=%s connection done (%s)" % (self.agent, time.time())) + self.ready.set() counter = 1 while self.running: @@ -164,9 +172,7 @@ class BaseTest(unittest.TestCase): # find the agents for aname in ["agent1", "agent2"]: - print("!!! finding aname=%s (%s)" % (aname, time.time())) agent = self.console.find_agent(aname, timeout=3) - print("!!! agent=%s aname=%s (%s)" % (agent, aname, time.time())) self.assertTrue(agent and agent.get_name() == aname) # now wait for events |