summaryrefslogtreecommitdiff
path: root/qpid/cpp/src
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
commitb51d1464ebe67161eb3b7d8772ae7093001b324d (patch)
treeae664cd9f0b07012e11d23e185706b5ec4257bea /qpid/cpp/src
parent0eb63f8a4f7172c793d1bf36ebdb051d5257fb16 (diff)
downloadqpid-python-b51d1464ebe67161eb3b7d8772ae7093001b324d.tar.gz
- added options for aysnc store & store dir location
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@586005 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src')
-rw-r--r--qpid/cpp/src/qpid/broker/Broker.cpp10
-rw-r--r--qpid/cpp/src/qpid/broker/Broker.h2
2 files changed, 10 insertions, 2 deletions
diff --git a/qpid/cpp/src/qpid/broker/Broker.cpp b/qpid/cpp/src/qpid/broker/Broker.cpp
index cfbe6a0bcc..92eb6dd380 100644
--- a/qpid/cpp/src/qpid/broker/Broker.cpp
+++ b/qpid/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/qpid/cpp/src/qpid/broker/Broker.h b/qpid/cpp/src/qpid/broker/Broker.h
index acb059451a..b4b82e8433 100644
--- a/qpid/cpp/src/qpid/broker/Broker.h
+++ b/qpid/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();