qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acon...@apache.org
Subject svn commit: r882218 - in /qpid/trunk/qpid/cpp/src: qpid/broker/MessageStore.h qpid/broker/MessageStoreModule.cpp qpid/broker/MessageStoreModule.h qpid/broker/NullMessageStore.cpp qpid/broker/NullMessageStore.h tests/QueueTest.cpp
Date Thu, 19 Nov 2009 17:50:35 GMT
Author: aconway
Date: Thu Nov 19 17:50:34 2009
New Revision: 882218

URL: http://svn.apache.org/viewvc?rev=882218&view=rev
Log:
Added getStoreDir() to MessageStore

Modified:
    qpid/trunk/qpid/cpp/src/qpid/broker/MessageStore.h
    qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.cpp
    qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.h
    qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.cpp
    qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.h
    qpid/trunk/qpid/cpp/src/tests/QueueTest.cpp

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/MessageStore.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStore.h?rev=882218&r1=882217&r2=882218&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/MessageStore.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/MessageStore.h Thu Nov 19 17:50:34 2009
@@ -192,6 +192,8 @@
      */
     virtual uint32_t outstandingQueueAIO(const PersistableQueue& queue) = 0;
 
+    /**@return store directory or empty string if this is a null store.  */
+    virtual std::string getStoreDir() const = 0;
 
     virtual ~MessageStore(){}
 };

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.cpp?rev=882218&r1=882217&r2=882218&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.cpp Thu Nov 19 17:50:34 2009
@@ -176,4 +176,6 @@
     return NullMessageStore::isNullStore(store.get());
 }
 
+std::string MessageStoreModule::getStoreDir() const { return store->getStoreDir(); }
+
 }} // namespace qpid::broker

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.h?rev=882218&r1=882217&r2=882218&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/MessageStoreModule.h Thu Nov 19 17:50:34 2009
@@ -77,6 +77,7 @@
     void flush(const qpid::broker::PersistableQueue& queue);
     bool isNull() const;
 
+    virtual std::string getStoreDir() const;
     ~MessageStoreModule();
 };
 

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.cpp?rev=882218&r1=882217&r2=882218&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.cpp Thu Nov 19 17:50:34 2009
@@ -162,4 +162,5 @@
     }
 }
 
+std::string NullMessageStore::getStoreDir() const { return std::string(); }
 }}  // namespace qpid::broker

Modified: qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.h
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.h?rev=882218&r1=882217&r2=882218&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.h (original)
+++ qpid/trunk/qpid/cpp/src/qpid/broker/NullMessageStore.h Thu Nov 19 17:50:34 2009
@@ -89,6 +89,8 @@
 
     QPID_BROKER_EXTERN virtual bool isNull() const;
     static bool isNullStore(const MessageStore*);
+
+    std::string getStoreDir() const;
 };
 
 }

Modified: qpid/trunk/qpid/cpp/src/tests/QueueTest.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/tests/QueueTest.cpp?rev=882218&r1=882217&r2=882218&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/tests/QueueTest.cpp (original)
+++ qpid/trunk/qpid/cpp/src/tests/QueueTest.cpp Thu Nov 19 17:50:34 2009
@@ -409,6 +409,8 @@
     void collectPreparedXids(std::set<std::string>& out) { out.insert(prepared.begin(),
prepared.end()); }
 
     void recover(RecoveryManager&) {}
+
+    std::string getStoreDir() const { return std::string(); }
 };
 
 



---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project:      http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org


Mime
View raw message