summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2010-03-31 18:54:59 +0000
committerAlan Conway <aconway@apache.org>2010-03-31 18:54:59 +0000
commitb20965a3b0aefb52354e817a1400f4da5b345419 (patch)
tree5d05e92c3081e22622fdc8add8f5cd94c77cfee4
parent79743ac8120ba318295b911f6204affd9c1e66c2 (diff)
downloadqpid-python-b20965a3b0aefb52354e817a1400f4da5b345419.tar.gz
Fix error in cluster_tests.py test_join_sub_size
Was not setting cluster-size so not testing the intended behaviour. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@929660 13f79535-47bb-0310-9956-ffa450edef68
-rwxr-xr-xqpid/cpp/src/tests/cluster_tests.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/qpid/cpp/src/tests/cluster_tests.py b/qpid/cpp/src/tests/cluster_tests.py
index 0c4b0350a7..504bad4083 100755
--- a/qpid/cpp/src/tests/cluster_tests.py
+++ b/qpid/cpp/src/tests/cluster_tests.py
@@ -333,6 +333,7 @@ class StoreTests(BrokerTest):
c = cluster.start("c", expect=EXPECT_EXIT_OK, wait=True)
a.send_message("q", Message("4", durable=True))
a.kill()
+ time.sleep(0.1) # pause for b to write status.
b.kill()
self.assertEqual(c.get_message("q").content, "4")
c.send_message("q", Message("clean", durable=True))
@@ -441,13 +442,14 @@ class StoreTests(BrokerTest):
def test_join_sub_size(self):
"""Verify that after starting a cluster with cluster-size=N,
we can join new members even if size < N-1"""
- cluster = self.cluster(0, self.args())
+ cluster = self.cluster(0, self.args()+["--cluster-size=3"])
a = cluster.start("a", wait=False, expect=EXPECT_EXIT_FAIL)
b = cluster.start("b", wait=False, expect=EXPECT_EXIT_FAIL)
c = cluster.start("c")
a.send_message("q", Message("x", durable=True))
a.send_message("q", Message("y", durable=True))
a.kill()
+ time.sleep(0.1) # pause for b to write status.
b.kill()
a = cluster.start("a")
self.assertEqual(c.get_message("q").content, "x")