diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2007-11-26 21:48:37 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2007-11-26 21:48:37 +0000 |
| commit | c598f75a71e141ca8738a4c11cd8d93dd7ae5dd3 (patch) | |
| tree | 8b3431841d1f18e0b21fc69f9a286851007b15c7 /cpp/src/qpid/broker/MessageStoreModule.h | |
| parent | acde3eb25b94333bc7772133fa24441e1771a67c (diff) | |
| download | qpid-python-c598f75a71e141ca8738a4c11cd8d93dd7ae5dd3.tar.gz | |
Switched all regular PersistentMessage* and PersistentMessage& to intrusive_ptr<PersistentMessage>, so as to hook into the refcount for a message while it is in the store.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@598440 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/MessageStoreModule.h')
| -rw-r--r-- | cpp/src/qpid/broker/MessageStoreModule.h | 15 |
1 files changed, 9 insertions, 6 deletions
diff --git a/cpp/src/qpid/broker/MessageStoreModule.h b/cpp/src/qpid/broker/MessageStoreModule.h index 6738f0e539..e7404487b0 100644 --- a/cpp/src/qpid/broker/MessageStoreModule.h +++ b/cpp/src/qpid/broker/MessageStoreModule.h @@ -55,14 +55,17 @@ public: void unbind(const PersistableExchange& exchange, const PersistableQueue& queue, const std::string& key, const framing::FieldTable& args); void recover(RecoveryManager& queues); - void stage(PersistableMessage& msg); - void destroy(PersistableMessage& msg); - void appendContent(const PersistableMessage& msg, const std::string& data); + void stage(intrusive_ptr<PersistableMessage>& msg); + void destroy(intrusive_ptr<PersistableMessage>& msg); + void appendContent(intrusive_ptr<const PersistableMessage>& msg, const std::string& data); void loadContent(const qpid::broker::PersistableQueue& queue, - const PersistableMessage& msg, std::string& data, uint64_t offset, uint32_t length); + intrusive_ptr<const 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); + void enqueue(TransactionContext* ctxt, intrusive_ptr<PersistableMessage>& msg, + const PersistableQueue& queue); + void dequeue(TransactionContext* ctxt, intrusive_ptr<PersistableMessage>& msg, + const PersistableQueue& queue); u_int32_t outstandingQueueAIO(const PersistableQueue& queue); void flush(const qpid::broker::PersistableQueue& queue); |