diff options
| author | Alan Conway <aconway@apache.org> | 2009-04-15 21:21:47 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2009-04-15 21:21:47 +0000 |
| commit | 774307d5bea0e169b03980af1bc7b4c16631e48e (patch) | |
| tree | 96e1ab6ab00243223e274e35b53165a6b1af4d0f /qpid/cpp/src/tests/failover_soak.cpp | |
| parent | 4ea5f0d5250bc1ab0a7ea09da243d569e8c95c9d (diff) | |
| download | qpid-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.cpp | 14 |
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; |
