Attachment 309116 Details for Bug 451011 – Option 2: change to rhm store

Option 2: change to rhm store

BZ451011_OPTION2_PART2.patch (text/x-patch), 1.31 KB, created by Gordon Sim on 2008-06-12 18:03:53 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Gordon Sim

Created: 2008-06-12 18:03:53 UTC

Size: 1.31 KB

patch

obsolete

>Index: lib/BdbMessageStore.cpp
>===================================================================
>--- lib/BdbMessageStore.cpp	(revision 2149)
>+++ lib/BdbMessageStore.cpp	(working copy)
>@@ -1127,7 +1127,6 @@
>             // add queue* to the txn map..
>             if (ctxt) txn->addXidRecord(queue.getExternalQueueStore());
>         }else{
>-       	    msg->enqueueComplete();  // set enqueued for ack
>             put(mappingDb, txn->get(), key, value);
>         
>             // cct if using Journal do we need to wait for IO to complete before calling thus???
>@@ -1462,6 +1461,13 @@
>     }
> }
> 
>+void BdbMessageStore::routed(intrusive_ptr<PersistableMessage>& msg) 
>+{
>+    if (!usingJrnl()){        
>+        while (!msg->isEnqueueComplete()) msg->enqueueComplete();
>+    }
>+}
>+
> TxnCtxt* BdbMessageStore::check(TransactionContext* ctxt)
> {
>     TxnCtxt* txn = dynamic_cast<TxnCtxt*>(ctxt);
>Index: lib/BdbMessageStore.h
>===================================================================
>--- lib/BdbMessageStore.h	(revision 2149)
>+++ lib/BdbMessageStore.h	(working copy)
>@@ -219,6 +219,7 @@
> 
>     	    u_int32_t outstandingQueueAIO(const qpid::broker::PersistableQueue& queue);
> 
>+            void routed(boost::intrusive_ptr<qpid::broker::PersistableMessage>& msg);
> 
>             void collectPreparedXids(std::set<string>& xids);
>

Actions: View

Attachments on bug 451011: 309111 | 309115 | 309116 | 309139