summaryrefslogtreecommitdiff
path: root/cpp
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2007-10-18 15:28:11 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2007-10-18 15:28:11 +0000
commitd1fe295cc48c0c26ad2db678a48821d4488be1e4 (patch)
treed71815f6cecc27f2591aa0f0d9b4251fbc27940e /cpp
parent0b39a6d14d796a7b8aeb160f9bdf0f92e2bd07ab (diff)
downloadqpid-python-d1fe295cc48c0c26ad2db678a48821d4488be1e4.tar.gz
- added options for aysnc store & store dir location
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@586005 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp')
-rw-r--r--cpp/src/qpid/broker/Broker.cpp10
-rw-r--r--cpp/src/qpid/broker/Broker.h2
2 files changed, 10 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/Broker.cpp b/cpp/src/qpid/broker/Broker.cpp
index cfbe6a0bcc..92eb6dd380 100644
--- a/cpp/src/qpid/broker/Broker.cpp
+++ b/cpp/src/qpid/broker/Broker.cpp
@@ -59,7 +59,9 @@ Broker::Options::Options(const std::string& name) :
maxConnections(500),
connectionBacklog(10),
store(),
- stagingThreshold(5000000)
+ stagingThreshold(5000000),
+ storeDir("/var"),
+ storeAsync(false)
{
addOptions()
("port,p", optValue(port,"PORT"),
@@ -73,7 +75,11 @@ Broker::Options::Options(const std::string& name) :
("staging-threshold", optValue(stagingThreshold, "N"),
"Stages messages over N bytes to disk")
("store,s", optValue(store,"LIBNAME"),
- "Tells the broker to use the message store shared library LIBNAME for persistence");
+ "Tells the broker to use the message store shared library LIBNAME for persistence")
+ ("store-diretcory", optValue(storeDir,"DIR"),
+ "Store directory location for persistence.")
+ ("store-async", optValue(storeAsync,"yes|no"),
+ "Use async persistence storage - if store supports it, enable AIO 0-DIRECT.");
}
const std::string empty;
diff --git a/cpp/src/qpid/broker/Broker.h b/cpp/src/qpid/broker/Broker.h
index acb059451a..b4b82e8433 100644
--- a/cpp/src/qpid/broker/Broker.h
+++ b/cpp/src/qpid/broker/Broker.h
@@ -64,6 +64,8 @@ class Broker : public sys::Runnable, public Plugin::Target
int connectionBacklog;
std::string store;
long stagingThreshold;
+ string storeDir;
+ bool storeAsync;
};
virtual ~Broker();