You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by gs...@apache.org on 2007/04/11 14:10:18 UTC
svn commit: r527467 - in /incubator/qpid/trunk/qpid/cpp/src:
broker/MessageStoreModule.cpp broker/MessageStoreModule.h
broker/NullMessageStore.cpp broker/NullMessageStore.h
broker/TransactionalStore.h tests/TxBufferTest.cpp
Author: gsim
Date: Wed Apr 11 05:10:17 2007
New Revision: 527467
URL: http://svn.apache.org/viewvc?view=rev&rev=527467
Log:
Added extra method to transaction control interface for store plugins.
Modified:
incubator/qpid/trunk/qpid/cpp/src/broker/MessageStoreModule.cpp
incubator/qpid/trunk/qpid/cpp/src/broker/MessageStoreModule.h
incubator/qpid/trunk/qpid/cpp/src/broker/NullMessageStore.cpp
incubator/qpid/trunk/qpid/cpp/src/broker/NullMessageStore.h
incubator/qpid/trunk/qpid/cpp/src/broker/TransactionalStore.h
incubator/qpid/trunk/qpid/cpp/src/tests/TxBufferTest.cpp
Modified: incubator/qpid/trunk/qpid/cpp/src/broker/MessageStoreModule.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/broker/MessageStoreModule.cpp?view=diff&rev=527467&r1=527466&r2=527467
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/broker/MessageStoreModule.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/broker/MessageStoreModule.cpp Wed Apr 11 05:10:17 2007
@@ -107,3 +107,8 @@
{
store->abort(ctxt);
}
+
+void MessageStoreModule::collectPreparedXids(std::set<std::string>& xids)
+{
+ store->collectPreparedXids(xids);
+}
Modified: incubator/qpid/trunk/qpid/cpp/src/broker/MessageStoreModule.h
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/broker/MessageStoreModule.h?view=diff&rev=527467&r1=527466&r2=527467
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/broker/MessageStoreModule.h (original)
+++ incubator/qpid/trunk/qpid/cpp/src/broker/MessageStoreModule.h Wed Apr 11 05:10:17 2007
@@ -44,6 +44,7 @@
void prepare(TPCTransactionContext& txn);
void commit(TransactionContext& txn);
void abort(TransactionContext& txn);
+ void collectPreparedXids(std::set<std::string>& xids);
void create(const PersistableQueue& queue);
void destroy(const PersistableQueue& queue);
Modified: incubator/qpid/trunk/qpid/cpp/src/broker/NullMessageStore.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/broker/NullMessageStore.cpp?view=diff&rev=527467&r1=527466&r2=527467
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/broker/NullMessageStore.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/broker/NullMessageStore.cpp Wed Apr 11 05:10:17 2007
@@ -103,3 +103,8 @@
void NullMessageStore::abort(TransactionContext&)
{
}
+
+void NullMessageStore::collectPreparedXids(std::set<string>&)
+{
+
+}
Modified: incubator/qpid/trunk/qpid/cpp/src/broker/NullMessageStore.h
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/broker/NullMessageStore.h?view=diff&rev=527467&r1=527466&r2=527467
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/broker/NullMessageStore.h (original)
+++ incubator/qpid/trunk/qpid/cpp/src/broker/NullMessageStore.h Wed Apr 11 05:10:17 2007
@@ -42,6 +42,7 @@
virtual void prepare(TPCTransactionContext& txn);
virtual void commit(TransactionContext& txn);
virtual void abort(TransactionContext& txn);
+ virtual void collectPreparedXids(std::set<std::string>& xids);
virtual void create(const PersistableQueue& queue);
virtual void destroy(const PersistableQueue& queue);
Modified: incubator/qpid/trunk/qpid/cpp/src/broker/TransactionalStore.h
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/broker/TransactionalStore.h?view=diff&rev=527467&r1=527466&r2=527467
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/broker/TransactionalStore.h (original)
+++ incubator/qpid/trunk/qpid/cpp/src/broker/TransactionalStore.h Wed Apr 11 05:10:17 2007
@@ -23,6 +23,7 @@
#include <memory>
#include <string>
+#include <set>
namespace qpid {
namespace broker {
@@ -46,6 +47,8 @@
virtual void prepare(TPCTransactionContext& txn) = 0;
virtual void commit(TransactionContext& txn) = 0;
virtual void abort(TransactionContext& txn) = 0;
+
+ virtual void collectPreparedXids(std::set<std::string>& xids) = 0;
virtual ~TransactionalStore(){}
};
Modified: incubator/qpid/trunk/qpid/cpp/src/tests/TxBufferTest.cpp
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/cpp/src/tests/TxBufferTest.cpp?view=diff&rev=527467&r1=527466&r2=527467
==============================================================================
--- incubator/qpid/trunk/qpid/cpp/src/tests/TxBufferTest.cpp (original)
+++ incubator/qpid/trunk/qpid/cpp/src/tests/TxBufferTest.cpp Wed Apr 11 05:10:17 2007
@@ -111,6 +111,11 @@
void prepare(TPCTransactionContext&){
throw "Operation not supported";
}
+ void collectPreparedXids(std::set<std::string>&)
+ {
+ throw "Operation not supported";
+ }
+
std::auto_ptr<TransactionContext> begin(){
actual.push_back(BEGIN);