You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2010/03/31 20:54:59 UTC
svn commit: r929660 - /qpid/trunk/qpid/cpp/src/tests/cluster_tests.py
Author: aconway
Date: Wed Mar 31 18:54:59 2010
New Revision: 929660
URL: http://svn.apache.org/viewvc?rev=929660&view=rev
Log:
Fix error in cluster_tests.py test_join_sub_size
Was not setting cluster-size so not testing the intended behaviour.
Modified:
qpid/trunk/qpid/cpp/src/tests/cluster_tests.py
Modified: qpid/trunk/qpid/cpp/src/tests/cluster_tests.py
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/tests/cluster_tests.py?rev=929660&r1=929659&r2=929660&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/tests/cluster_tests.py (original)
+++ qpid/trunk/qpid/cpp/src/tests/cluster_tests.py Wed Mar 31 18:54:59 2010
@@ -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")
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org