diff options
author | Alan Conway <aconway@apache.org> | 2010-03-31 18:54:59 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2010-03-31 18:54:59 +0000 |
commit | b20965a3b0aefb52354e817a1400f4da5b345419 (patch) | |
tree | 5d05e92c3081e22622fdc8add8f5cd94c77cfee4 /qpid/cpp | |
parent | 79743ac8120ba318295b911f6204affd9c1e66c2 (diff) | |
download | qpid-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
Diffstat (limited to 'qpid/cpp')
-rwxr-xr-x | qpid/cpp/src/tests/cluster_tests.py | 4 |
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") |