summaryrefslogtreecommitdiff
path: root/cpp/src/tests/ForkedBroker.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/ForkedBroker.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/ForkedBroker.cpp')
-rw-r--r--cpp/src/tests/ForkedBroker.cpp22
1 files changed, 18 insertions, 4 deletions
diff --git a/cpp/src/tests/ForkedBroker.cpp b/cpp/src/tests/ForkedBroker.cpp
index 383dcc496c..24ada12739 100644
--- a/cpp/src/tests/ForkedBroker.cpp
+++ b/cpp/src/tests/ForkedBroker.cpp
@@ -31,14 +31,28 @@
using namespace std;
using qpid::ErrnoException;
-ForkedBroker::ForkedBroker(const Args& args) { init(args); }
-
-ForkedBroker::ForkedBroker(int argc, const char* const argv[]) { init(Args(argv, argc+argv)); }
+ForkedBroker::ForkedBroker(const Args& constArgs) {
+ Args args(constArgs);
+ Args::iterator i = find(args.begin(), args.end(), string("TMP_DATA_DIR"));
+ if (i != args.end()) {
+ args.erase(i);
+ char dd[] = "/tmp/ForkedBroker.XXXXXX";
+ if (!mkdtemp(dd))
+ throw qpid::ErrnoException("Can't create data dir");
+ dataDir = dd;
+ args.push_back("--data-dir");
+ args.push_back(dataDir);
+ }
+ init(args);
+}
ForkedBroker::~ForkedBroker() {
- try { kill(); } catch(const std::exception& e) {
+ try { kill(); }
+ catch (const std::exception& e) {
QPID_LOG(error, QPID_MSG("Killing forked broker: " << e.what()));
}
+ if (!dataDir.empty())
+ ::system(("rm -rf "+dataDir).c_str());
}
void ForkedBroker::kill(int sig) {