From bb081a780bd307b09ad1c773a700233b54e4be48 Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Fri, 17 Apr 2009 18:23:06 +0000 Subject: Small change to ClusterFixture which allows a different path to the cluster.so lib for persistence testing git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@766110 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/ClusterFixture.cpp | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) (limited to 'cpp/src/tests/ClusterFixture.cpp') diff --git a/cpp/src/tests/ClusterFixture.cpp b/cpp/src/tests/ClusterFixture.cpp index d49be76f79..70d60b10b4 100644 --- a/cpp/src/tests/ClusterFixture.cpp +++ b/cpp/src/tests/ClusterFixture.cpp @@ -61,14 +61,14 @@ using boost::assign::list_of; #include "ClusterFixture.h" -ClusterFixture::ClusterFixture(size_t n, int localIndex_, const Args& args_) - : name(Uuid(true).str()), localIndex(localIndex_), userArgs(args_) +ClusterFixture::ClusterFixture(size_t n, int localIndex_, const Args& args_, const string& clusterLib_) + : name(Uuid(true).str()), localIndex(localIndex_), userArgs(args_), clusterLib(clusterLib_) { add(n); } -ClusterFixture::ClusterFixture(size_t n, int localIndex_, boost::function updateArgs_) - : name(Uuid(true).str()), localIndex(localIndex_), updateArgs(updateArgs_) +ClusterFixture::ClusterFixture(size_t n, int localIndex_, boost::function updateArgs_, const string& clusterLib_) + : name(Uuid(true).str()), localIndex(localIndex_), updateArgs(updateArgs_), clusterLib(clusterLib_) { add(n); } @@ -77,10 +77,10 @@ const ClusterFixture::Args ClusterFixture::DEFAULT_ARGS = list_of("--auth=no")("--no-data-dir"); ClusterFixture::Args ClusterFixture::makeArgs(const std::string& prefix, size_t index) { - Args args = list_of("qpidd " __FILE__) + Args args = list_of("qpidd ") ("--no-module-dir") - ("--load-module=../.libs/cluster.so") - ("--cluster-name")(name) + ("--load-module")(clusterLib) + ("--cluster-name")(name) ("--log-prefix")(prefix); args.insert(args.end(), userArgs.begin(), userArgs.end()); if (updateArgs) updateArgs(args, index); @@ -123,7 +123,7 @@ void ClusterFixture::addLocal() { } bool ClusterFixture::hasLocal() const { return localIndex >= 0 && size_t(localIndex) < size(); } - + /** Kill a forked broker with sig, or shutdown localBroker if n==0. */ void ClusterFixture::kill(size_t n, int sig) { if (n == size_t(localIndex)) @@ -153,7 +153,7 @@ std::set knownBrokerPorts(qpid::client::Connection& source, int n) { } } std::set s; - for (std::vector::const_iterator i = urls.begin(); i != urls.end(); ++i) + for (std::vector::const_iterator i = urls.begin(); i != urls.end(); ++i) s.insert((*i)[0].get()->port); return s; } -- cgit v1.2.1