diff options
| author | Kim van der Riet <kpvdr@apache.org> | 2012-06-25 19:11:55 +0000 |
|---|---|---|
| committer | Kim van der Riet <kpvdr@apache.org> | 2012-06-25 19:11:55 +0000 |
| commit | cbd4f9c22974db5f53b42a4326486ec8325b79cc (patch) | |
| tree | 95986a4f10104ea2b9cc79c7463d0bc9ab451bcf /cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp | |
| parent | b95f9427ede4a2045ac6424a6341de9185a13602 (diff) | |
| download | qpid-python-cbd4f9c22974db5f53b42a4326486ec8325b79cc.tar.gz | |
WIP - transactional consume path completed, still some testing to be done.
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1353703 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp')
| -rw-r--r-- | cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp b/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp index 0cab537fb0..7d9aaceb11 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp +++ b/cpp/src/tests/storePerftools/asyncPerf/MessageProducer.cpp @@ -56,7 +56,7 @@ void* MessageProducer::runProducers() { const bool useTxns = m_perfTestParams.m_enqTxnBlockSize > 0U; - uint16_t txnCnt = 0U; + uint16_t recsInTxnCnt = 0U; qpid::broker::TxnBuffer* tb = 0; if (useTxns) { tb = new qpid::broker::TxnBuffer(m_resultQueue); @@ -67,27 +67,26 @@ MessageProducer::runProducers() boost::shared_ptr<TxnPublish> op(new TxnPublish(msg)); op->deliverTo(m_queue); tb->enlist(op); - if (++txnCnt >= m_perfTestParams.m_enqTxnBlockSize) { + if (++recsInTxnCnt >= m_perfTestParams.m_enqTxnBlockSize) { if (m_perfTestParams.m_durable) { tb->commitLocal(m_store); // TxnBuffer instance tb carries async state that precludes it being re-used for the next // transaction until the current commit cycle completes. So use another instance. This // instance should auto-delete when the async commit cycle completes. - if (numMsgs<m_perfTestParams.m_numMsgs) { - //tb = boost::shared_ptr<qpid::broker::TxnBuffer>(new qpid::broker::TxnBuffer(m_resultQueue)); + if ((numMsgs + 1) < m_perfTestParams.m_numMsgs) { tb = new qpid::broker::TxnBuffer(m_resultQueue); } } else { tb->commit(); } - txnCnt = 0U; + recsInTxnCnt = 0U; } } else { m_queue->deliver(msg); } } - if (txnCnt) { + if (recsInTxnCnt) { if (m_perfTestParams.m_durable) { tb->commitLocal(m_store); } else { |