diff options
author | Alan Conway <aconway@apache.org> | 2007-07-27 19:27:43 +0000 |
---|---|---|
committer | Alan Conway <aconway@apache.org> | 2007-07-27 19:27:43 +0000 |
commit | ac669123004b6e78468cc4fcea3ffb4b9d7b7bd3 (patch) | |
tree | 366557b336624b8eb8265ec9143762e9eebcf647 /cpp/src/tests/Cluster.cpp | |
parent | 65ea2f177bd0810590895d89a490af8cea60253b (diff) | |
download | qpid-python-ac669123004b6e78468cc4fcea3ffb4b9d7b7bd3.tar.gz |
Drop SessionFrame, UUID is not required and more efficient to transmit plain
AMQFrames.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@560356 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/Cluster.cpp')
-rw-r--r-- | cpp/src/tests/Cluster.cpp | 30 |
1 files changed, 10 insertions, 20 deletions
diff --git a/cpp/src/tests/Cluster.cpp b/cpp/src/tests/Cluster.cpp index 5ace48b736..811fc0133e 100644 --- a/cpp/src/tests/Cluster.cpp +++ b/cpp/src/tests/Cluster.cpp @@ -33,17 +33,11 @@ static const ProtocolVersion VER; /** Verify membership in a cluster with one member. */ BOOST_AUTO_TEST_CASE(testClusterOne) { TestCluster cluster("clusterOne", "amqp:one:1"); - AMQFrame frame(VER, 1, new SessionPingBody(VER)); - Uuid id(true); - SessionFrame send(id, frame, true); + AMQFrame send(VER, 1, new SessionPingBody(VER)); cluster.handle(send); - SessionFrame sf; - BOOST_REQUIRE(cluster.received.waitPop(sf)); - - BOOST_CHECK(sf.isIncoming); - BOOST_CHECK_EQUAL(id, sf.uuid); - BOOST_CHECK_TYPEID_EQUAL(SessionPingBody, *sf.frame.getBody()); - + AMQFrame received; + BOOST_REQUIRE(cluster.received.waitPop(received)); + BOOST_CHECK_TYPEID_EQUAL(SessionPingBody, *received.getBody()); BOOST_CHECK_EQUAL(1u, cluster.size()); Cluster::MemberList members = cluster.getMembers(); BOOST_CHECK_EQUAL(1u, members.size()); @@ -65,18 +59,14 @@ BOOST_AUTO_TEST_CASE(testClusterTwo) { BOOST_REQUIRE(cluster.waitFor(2)); // Myself and child. // Exchange frames with child. - AMQFrame frame(VER, 1, new SessionPingBody(VER)); - Uuid id(true); - SessionFrame send(id, frame, true); + AMQFrame send(VER, 1, new SessionPingBody(VER)); cluster.handle(send); - SessionFrame sf; - BOOST_REQUIRE(cluster.received.waitPop(sf)); - BOOST_CHECK_EQUAL(id, sf.uuid); - BOOST_CHECK(sf.isIncoming); - BOOST_CHECK_TYPEID_EQUAL(SessionPingBody, *sf.frame.getBody()); + AMQFrame received; + BOOST_REQUIRE(cluster.received.waitPop(received)); + BOOST_CHECK_TYPEID_EQUAL(SessionPingBody, *received.getBody()); - BOOST_REQUIRE(cluster.received.waitPop(sf)); - BOOST_CHECK_TYPEID_EQUAL(SessionPongBody, *sf.frame.getBody()); + BOOST_REQUIRE(cluster.received.waitPop(received)); + BOOST_CHECK_TYPEID_EQUAL(SessionPongBody, *received.getBody()); if (!nofork) { // Wait for child to exit. |