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 | 53f57f5271d44349493c9c344f6e427a9f4e726e (patch) | |
| tree | 4d798a14a5fee52b5d32598243c240e9c40a4e50 /cpp/src | |
| parent | 18f96b2ee2c426a9d0a6fa4181bf8e5dd7f69a11 (diff) | |
| download | qpid-python-53f57f5271d44349493c9c344f6e427a9f4e726e.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/qpid@929660 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
| -rwxr-xr-x | cpp/src/tests/cluster_tests.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/src/tests/cluster_tests.py b/cpp/src/tests/cluster_tests.py index 0c4b0350a7..504bad4083 100755 --- a/cpp/src/tests/cluster_tests.py +++ b/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") |