summaryrefslogtreecommitdiff
path: root/qpid/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
commit774307d5bea0e169b03980af1bc7b4c16631e48e (patch)
tree96e1ab6ab00243223e274e35b53165a6b1af4d0f /qpid/cpp/src/tests/failover_soak.cpp
parent4ea5f0d5250bc1ab0a7ea09da243d569e8c95c9d (diff)
downloadqpid-python-774307d5bea0e169b03980af1bc7b4c16631e48e.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@765365 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/failover_soak.cpp')
-rw-r--r--qpid/cpp/src/tests/failover_soak.cpp14
1 files changed, 4 insertions, 10 deletions
diff --git a/qpid/cpp/src/tests/failover_soak.cpp b/qpid/cpp/src/tests/failover_soak.cpp
index 2da60f47b5..c8f67aadd8 100644
--- a/qpid/cpp/src/tests/failover_soak.cpp
+++ b/qpid/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;