From 58337ca40df3a57a16cdee9b7f6b4fe0361b0018 Mon Sep 17 00:00:00 2001 From: Kim van der Riet Date: Fri, 15 Jun 2012 19:21:07 +0000 Subject: QPID-3858: WIP - async txns for msg publish pathway, but there are some race/thread issues to sort out. git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/asyncstore@1350745 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp') diff --git a/cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp b/cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp index fbfebbac2b..7941e761ca 100644 --- a/cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp +++ b/cpp/src/tests/storePerftools/asyncPerf/PerfTest.cpp @@ -80,7 +80,7 @@ PerfTest::run() tests::storePerftools::common::ScopedTimer st(m_testResult); for (uint16_t q = 0; q < m_testOpts.m_numQueues; q++) { - boost::shared_ptr mp(new MessageProducer(m_testOpts, m_msgData, m_store, m_queueList[q])); + boost::shared_ptr mp(new MessageProducer(m_testOpts, m_msgData, m_store, m_resultQueue, m_queueList[q])); m_producers.push_back(mp); for (uint16_t t = 0; t < m_testOpts.m_numEnqThreadsPerQueue; t++) { // TODO - replace with qpid threads boost::shared_ptr tp(new tests::storePerftools::common::Thread(mp->startProducers, -- cgit v1.2.1