summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/MessageStoreModule.h
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2007-08-15 18:13:02 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2007-08-15 18:13:02 +0000
commit7c966bd1fcb801e14e001237096470b9c7e87f1f (patch)
tree36409d01a360e3150a587fec1b9a30bcb5e8d89b /cpp/src/qpid/broker/MessageStoreModule.h
parent3f2ac50fdb042c2c48ebbdc1e70e442f0bf1ab86 (diff)
downloadqpid-python-7c966bd1fcb801e14e001237096470b9c7e87f1f.tar.gz
async IO for broker store
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@566289 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/MessageStoreModule.h')
-rw-r--r--cpp/src/qpid/broker/MessageStoreModule.h2
1 files changed, 2 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/MessageStoreModule.h b/cpp/src/qpid/broker/MessageStoreModule.h
index 078d2c1fdf..0da12a1a75 100644
--- a/cpp/src/qpid/broker/MessageStoreModule.h
+++ b/cpp/src/qpid/broker/MessageStoreModule.h
@@ -59,8 +59,10 @@ public:
void destroy(PersistableMessage& msg);
void appendContent(PersistableMessage& msg, const std::string& data);
void loadContent(PersistableMessage& msg, std::string& data, uint64_t offset, uint32_t length);
+
void enqueue(TransactionContext* ctxt, PersistableMessage& msg, const PersistableQueue& queue);
void dequeue(TransactionContext* ctxt, PersistableMessage& msg, const PersistableQueue& queue);
+ u_int32_t outstandingQueueAIO(const PersistableQueue& queue);
~MessageStoreModule(){}
};