summaryrefslogtreecommitdiff
path: root/cpp/src/tests/ClusterFixture.cpp
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2009-04-17 18:23:06 +0000
committerKim van der Riet <kpvdr@apache.org>2009-04-17 18:23:06 +0000
commitbb081a780bd307b09ad1c773a700233b54e4be48 (patch)
treefcaa6ca17fd35a7b2d360b5e9bca4c4376c3bd57 /cpp/src/tests/ClusterFixture.cpp
parent714084b661b4e0f6d121eb61d54f049909b27b18 (diff)
downloadqpid-python-bb081a780bd307b09ad1c773a700233b54e4be48.tar.gz
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
Diffstat (limited to 'cpp/src/tests/ClusterFixture.cpp')
-rw-r--r--cpp/src/tests/ClusterFixture.cpp18
1 files changed, 9 insertions, 9 deletions
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<void (Args&, size_t)> updateArgs_)
- : name(Uuid(true).str()), localIndex(localIndex_), updateArgs(updateArgs_)
+ClusterFixture::ClusterFixture(size_t n, int localIndex_, boost::function<void (Args&, size_t)> 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<string>("--auth=no")("--no-data-dir");
ClusterFixture::Args ClusterFixture::makeArgs(const std::string& prefix, size_t index) {
- Args args = list_of<string>("qpidd " __FILE__)
+ Args args = list_of<string>("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<int> knownBrokerPorts(qpid::client::Connection& source, int n) {
}
}
std::set<int> s;
- for (std::vector<qpid::Url>::const_iterator i = urls.begin(); i != urls.end(); ++i)
+ for (std::vector<qpid::Url>::const_iterator i = urls.begin(); i != urls.end(); ++i)
s.insert((*i)[0].get<qpid::TcpAddress>()->port);
return s;
}