svn commit: r689174 - /incubator/qpid/trunk/qpid/cpp/src/tests/cluster_test.cpp

[ac...@apache.org]

Author: aconway
Date: Tue Aug 26 12:19:44 2008
New Revision: 689174

URL: http://svn.apache.org/viewvc?rev=689174&view=rev
Log:
Added ClusterFixture::kill

Modified:
    incubator/qpid/trunk/qpid/cpp/src/tests/cluster_test.cpp

Modified: incubator/qpid/trunk/qpid/cpp/src/tests/cluster_test.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/tests/cluster_test.cpp?rev=689174&r1=689173&r2=689174&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/tests/cluster_test.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/tests/cluster_test.cpp Tue Aug 26 12:19:44 2008
@@ -68,6 +68,10 @@
     void add(size_t n) { for (size_t i=0; i < n; ++i) add(); }
     void add();
     void setup();
+    void kill(size_t n) {
+        if (n) forkedBrokers[n-1]->stop();
+        else broker0.shutdown();
+    }
 };
 
 ClusterFixture::ClusterFixture(size_t n) : name(Uuid(true).str()) {
@@ -127,41 +131,6 @@
     return o;
 }
 
-struct Callback : public Cpg::Handler {
-    Callback(const string group_) : group(group_) {}
-    string group;
-    vector<string> delivered;
-    vector<int> configChanges;
-
-    void deliver (
-        cpg_handle_t /*handle*/,
-        struct cpg_name *grp,
-        uint32_t /*nodeid*/,
-        uint32_t /*pid*/,
-        void* msg,
-        int msg_len)
-    {
-        BOOST_CHECK_EQUAL(group, Cpg::str(*grp));
-        delivered.push_back(string((char*)msg,msg_len));
-    }
-
-    void configChange(
-        cpg_handle_t /*handle*/,
-        struct cpg_name *grp,
-        struct cpg_address */*members*/, int nMembers,
-        struct cpg_address */*left*/, int nLeft,
-        struct cpg_address */*joined*/, int nJoined
-    )
-    {
-        BOOST_CHECK_EQUAL(group, Cpg::str(*grp));
-        configChanges.push_back(nMembers);
-        BOOST_MESSAGE("configChange: "<<
-                      nLeft<<" left "<<
-                      nJoined<<" joined "<<
-                      nMembers<<" members.");
-    }
-};
-
 QPID_AUTO_TEST_CASE(testForkedBroker) {
     // Verify the ForkedBroker works as expected.
     const char* argv[] = { "", "--auth=no", "--no-data-dir", "--log-prefix=testForkedBroker" };