summaryrefslogtreecommitdiff
path: root/cpp/src/tests/failover_soak.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2009-04-15 21:21:47 +0000
committerAlan Conway <aconway@apache.org>2009-04-15 21:21:47 +0000
commit2ccd734741281b6bf9f9e7f5af6d3697f579ae14 (patch)
tree38ebc613fe92d3fa7061cf096c27743e6d3b8434 /cpp/src/tests/failover_soak.cpp
parent0bd1b0141e46e64debe2b4da971a4250dba5c59c (diff)
downloadqpid-python-2ccd734741281b6bf9f9e7f5af6d3697f579ae14.tar.gz
Clean up temporary data directories in tests.
ForkedBroker.cpp: create/delete tmp data directory if passed arg TMP_DATA_DIR. failover_soak.cpp, PartialFailure.cpp: use tmp data dir feature of ForkedBroker git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@765365 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/failover_soak.cpp')
-rw-r--r--cpp/src/tests/failover_soak.cpp14
1 files changed, 4 insertions, 10 deletions
diff --git a/cpp/src/tests/failover_soak.cpp b/cpp/src/tests/failover_soak.cpp
index 2da60f47b5..c8f67aadd8 100644
--- a/cpp/src/tests/failover_soak.cpp
+++ b/cpp/src/tests/failover_soak.cpp
@@ -326,21 +326,15 @@ startNewBroker ( brokerVector & brokers,
static int brokerId = 0;
stringstream path, prefix;
prefix << "soak-" << brokerId;
- string dataDir("/tmp/failover_soak.XXXXXX");
- if (!mkdtemp(const_cast<char*>(dataDir.c_str())))
- throw qpid::ErrnoException("Can't create data dir");
-
std::vector<std::string> argv = list_of<string>
("qpidd")
("--cluster-name")(clusterName)
("--auth=no")
- ("--data-dir")(dataDir)
("--mgmt-enable=no")
- ("--log-prefix")
- (prefix.str())
- ("--log-to-file")
+ ("--log-prefix")(prefix.str())
+ ("--log-to-file")(prefix.str()+".log")
("--log-enable=error+")
- (prefix.str()+".log");
+ ("TMP_DATA_DIR");
if (endsWith(moduleOrDir, "cluster.so")) {
// Module path specified, load only that module.
@@ -355,7 +349,7 @@ startNewBroker ( brokerVector & brokers,
argv.push_back(string("--module-dir=")+moduleOrDir);
}
- newbie = new ForkedBroker ( argv );
+ newbie = new ForkedBroker (argv);
newbie_port = newbie->getPort();
ForkedBroker * broker = newbie;