svn commit: r586005 - in /incubator/qpid/trunk/qpid/cpp/src/qpid/broker: Broker.cpp Broker.h

[cctrieloff]

Author: cctrieloff
Date: Thu Oct 18 08:28:11 2007
New Revision: 586005

URL: http://svn.apache.org/viewvc?rev=586005&view=rev
Log:

 - added options for aysnc store & store dir location


Modified:
    incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.cpp
    incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.h

Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.cpp
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.cpp?rev=586005&r1=586004&r2=586005&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.cpp Thu Oct 18 
08:28:11 2007
@@ -59,7 +59,9 @@
     maxConnections(500),
     connectionBacklog(10),
     store(),
-    stagingThreshold(5000000)
+    stagingThreshold(5000000),
+       storeDir("/var"),
+       storeAsync(false)
 {
     addOptions()
         ("port,p", optValue(port,"PORT"),
@@ -73,7 +75,11 @@
         ("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;

Modified: incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.h
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.h?rev=586005&r1=586004&r2=586005&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.h (original)
+++ incubator/qpid/trunk/qpid/cpp/src/qpid/broker/Broker.h Thu Oct 18 08:28:11 
2007
@@ -64,6 +64,8 @@
         int connectionBacklog;
         std::string store;      
         long stagingThreshold;
+               string storeDir;
+               bool storeAsync;
     };
     
     virtual ~Broker();