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 2007/06/26 06:44:14 UTC

svn commit: r550682 - /incubator/qpid/trunk/qpid/cpp/src/tests/Cluster_child.cpp

Author: aconway
Date: Mon Jun 25 21:44:13 2007
New Revision: 550682

URL: http://svn.apache.org/viewvc?view=rev&rev=550682
Log:
Missing file from last commit

Added:
    incubator/qpid/trunk/qpid/cpp/src/tests/Cluster_child.cpp   (with props)

Added: incubator/qpid/trunk/qpid/cpp/src/tests/Cluster_child.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/tests/Cluster_child.cpp?view=auto&rev=550682
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/tests/Cluster_child.cpp (added)
+++ incubator/qpid/trunk/qpid/cpp/src/tests/Cluster_child.cpp Mon Jun 25 21:44:13 2007
@@ -0,0 +1,51 @@
+/*
+ *
+ * Copyright (c) 2006 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+// Child process for the Cluster test suite multi-process tests.
+
+#include "Cluster.h"
+#include "test_tools.h"
+
+using namespace std;
+using namespace qpid;
+using namespace qpid::cluster;
+using namespace qpid::framing;
+using namespace qpid::sys;
+
+
+static const ProtocolVersion VER;
+
+/** Chlid part of Cluster::clusterTwo test */
+void clusterTwo() {
+    VectorFrameHandler received;
+    TestCluster cluster("Test", "amqp::2", received, VER);
+    BOOST_REQUIRE(cluster.waitFor(2));
+    
+    BOOST_REQUIRE(received.waitFor(1));
+    BOOST_CHECK_TYPEID_EQUAL(ChannelOkBody, *received[0].getBody());
+    AMQFrame frame(VER, 1, new BasicGetOkBody(VER));
+    cluster.handle(frame);
+    BOOST_REQUIRE(received.waitFor(2));
+    BOOST_CHECK_TYPEID_EQUAL(BasicGetOkBody, *received[1].getBody());
+} 
+
+int test_main(int, char**) {
+    clusterTwo();
+    return 0;
+}
+

Propchange: incubator/qpid/trunk/qpid/cpp/src/tests/Cluster_child.cpp
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/qpid/trunk/qpid/cpp/src/tests/Cluster_child.cpp
------------------------------------------------------------------------------
    svn:keywords = Rev Date