1 files changed, 91 insertions, 0 deletions
diff --git a/cpp/src/tests/ForkedBroker.h b/cpp/src/tests/ForkedBroker.h
new file mode 100644
index 0000000000..843c9ab8e2
--- /dev/null
+++ b/cpp/src/tests/ForkedBroker.h
@@ -0,0 +1,91 @@
+#ifndef TESTS_FORKEDBROKER_H
+#define TESTS_FORKEDBROKER_H
+
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you 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.
+ *
+ */
+
+#include "qpid/sys/Fork.h"
+#include "qpid/log/Logger.h"
+#include "qpid/broker/Broker.h"
+#include "qpid/broker/SignalHandler.h"
+
+#include <boost/lexical_cast.hpp>
+
+#include <string>
+
+#include <signal.h>
+#include <sys/wait.h>
+
+/**
+ * Class to fork a broker child process.
+ * 
+ * For most tests a BrokerFixture may be more convenient as it starts
+ * a broker in the same process which allows you to easily debug into
+ * the broker.
+ *
+ * This useful for tests that need to start multiple brokers where
+ * those brokers can't coexist in the same process (e.g. for cluster
+ * tests where CPG doesn't allow multiple group members in a single
+ * process.)
+ * 
+ */
+class ForkedBroker : public qpid::sys::ForkWithMessage {
+    pid_t childPid;
+    uint16_t port;
+    qpid::broker::Broker::Options opts;
+    std::string prefix;
+
+  public:
+    ForkedBroker(const qpid::broker::Broker::Options& opts_, const std::string& prefix_=std::string())
+        : childPid(0), port(0), opts(opts_), prefix(prefix_) { fork(); } 
+
+    ~ForkedBroker() { stop(); }
+
+    void stop() {
+        if (childPid > 0) {
+            ::kill(childPid, SIGINT);
+                                //FIXME aconway 2008-07-04: ::waitpid(childPid, 0, 0);
+        }
+    }
+
+    void parent(pid_t pid) {
+        childPid = pid;
+        qpid::log::Logger::instance().setPrefix("parent");
+        std::string portStr = wait(2);
+        port = boost::lexical_cast<uint16_t>(portStr);
+    }
+
+    void child() {
+        prefix += boost::lexical_cast<std::string>(long(getpid()));
+        qpid::log::Logger::instance().setPrefix(prefix);
+        opts.port = 0;
+        boost::shared_ptr<qpid::broker::Broker> broker(new qpid::broker::Broker(opts));
+        qpid::broker::SignalHandler::setBroker(broker);
+        QPID_LOG(info, "ForkedBroker started on " << broker->getPort());
+        ready(boost::lexical_cast<std::string>(broker->getPort())); // Notify parent.
+        broker->run();
+        QPID_LOG(notice, "ForkedBroker exiting.");
+    }
+
+    uint16_t getPort() { return port; }
+};
+
+#endif  /*!TESTS_FORKEDBROKER_H*/