svn commit: r1348891 - in /qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf: MessageConsumer.cpp MessageProducer.cpp SimplePersistableQueue.cpp

[kpvdr]

Author: kpvdr
Date: Mon Jun 11 15:10:11 2012
New Revision: 1348891

URL: http://svn.apache.org/viewvc?rev=1348891&view=rev
Log:
WIP: Fixed some logic errors in the non-persistent pathway

Modified:
    
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.cpp
    
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp
    
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.cpp

Modified: 
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.cpp
URL: 
http://svn.apache.org/viewvc/qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.cpp?rev=1348891&r1=1348890&r2=1348891&view=diff
==============================================================================
--- 
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.cpp
 (original)
+++ 
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/MessageConsumer.cpp
 Mon Jun 11 15:10:11 2012
@@ -46,7 +46,6 @@ MessageConsumer::~MessageConsumer()
 void*
 MessageConsumer::runConsumers()
 {
-/*
     uint32_t numMsgs = 0;
     while (numMsgs < m_perfTestParams.m_numMsgs) {
         if (m_queue->dispatch()) {
@@ -55,7 +54,6 @@ MessageConsumer::runConsumers()
             ::usleep(1000); // TODO - replace this poller with condition 
variable
         }
     }
-*/
     return 0;
 }
 

Modified: 
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp
URL: 
http://svn.apache.org/viewvc/qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp?rev=1348891&r1=1348890&r2=1348891&view=diff
==============================================================================
--- 
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp
 (original)
+++ 
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp
 Mon Jun 11 15:10:11 2012
@@ -51,7 +51,6 @@ MessageProducer::~MessageProducer()
 void*
 MessageProducer::runProducers()
 {
-    boost::shared_ptr<SimpleTransactionContext> txn;
     for (uint32_t numMsgs=0; numMsgs<m_perfTestParams.m_numMsgs; ++numMsgs) {
         boost::shared_ptr<SimplePersistableMessage> msg(new 
SimplePersistableMessage(m_msgData, m_perfTestParams.m_msgSize, m_store));
         m_queue->deliver(msg);

Modified: 
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.cpp
URL: 
http://svn.apache.org/viewvc/qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.cpp?rev=1348891&r1=1348890&r2=1348891&view=diff
==============================================================================
--- 
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.cpp
 (original)
+++ 
qpid/branches/asyncstore/cpp/src/tests/storePerftools/asyncPerf/SimplePersistableQueue.cpp
 Mon Jun 11 15:10:11 2012
@@ -159,9 +159,8 @@ void
 SimplePersistableQueue::deliver(boost::shared_ptr<SimplePersistableMessage> 
msg)
 {
     QueuedMessage qm(this, msg);
-    if(enqueue((SimpleTransactionContext*)0, qm)) {
-        push(qm);
-    }
+    enqueue((SimpleTransactionContext*)0, qm);
+    push(qm);
 }
 
 bool
@@ -176,7 +175,7 @@ SimplePersistableQueue::dispatch()
 
 bool
 SimplePersistableQueue::enqueue(SimpleTransactionContext* ctxt,
-                              QueuedMessage& qm)
+                                QueuedMessage& qm)
 {
     ScopedUse u(m_barrier);
     if (!u.m_acquired) {
@@ -191,7 +190,7 @@ SimplePersistableQueue::enqueue(SimpleTr
 
 bool
 SimplePersistableQueue::dequeue(SimpleTransactionContext* ctxt,
-                              QueuedMessage& qm)
+                                QueuedMessage& qm)
 {
     ScopedUse u(m_barrier);
     if (!u.m_acquired) {
@@ -201,7 +200,7 @@ SimplePersistableQueue::dequeue(SimpleTr
         qm.payload()->dequeueAsync(shared_from_this(), m_store);
         return asyncDequeue(ctxt, qm);
     }
-    return false;
+    return true;
 }
 
 void
@@ -317,7 +316,7 @@ SimplePersistableQueue::ScopedUse::~Scop
 // private
 void
 SimplePersistableQueue::push(QueuedMessage& qm,
-                           bool /*isRecovery*/)
+                             bool /*isRecovery*/)
 {
     QueuedMessage removed;
     m_messages->push(qm, removed);
@@ -328,7 +327,7 @@ SimplePersistableQueue::push(QueuedMessa
 // private
 bool
 SimplePersistableQueue::asyncEnqueue(SimpleTransactionContext* txn,
-                                   QueuedMessage& qm)
+                                     QueuedMessage& qm)
 {
     qm.payload()->setPersistenceId(m_store->getNextRid());
 //std::cout << "QQQ Queue=\"" << m_name << "\": asyncEnqueue() rid=0x" << 
std::hex << qm.payload()->getPersistenceId() << std::dec << std::endl << 
std::flush;
@@ -347,7 +346,7 @@ SimplePersistableQueue::asyncEnqueue(Sim
 // private
 bool
 SimplePersistableQueue::asyncDequeue(SimpleTransactionContext* txn,
-                                   QueuedMessage& qm)
+                                     QueuedMessage& qm)
 {
 //std::cout << "QQQ Queue=\"" << m_name << "\": asyncDequeue() rid=0x" << 
std::hex << qm.payload()->getPersistenceId() << std::dec << std::endl << 
std::flush;
     boost::shared_ptr<QueueAsyncContext> qac(new 
QueueAsyncContext(shared_from_this(),



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org