Author: kpvdr Date: 2007-12-14 09:47:46 -0500 (Fri, 14 Dec 2007) New Revision: 1488 Modified: store/trunk/cpp/lib/BdbMessageStore.cpp store/trunk/cpp/lib/BdbMessageStore.h Log: Undid last checkin's mutex, this way kills performance as the lock is across all queues. Modified: store/trunk/cpp/lib/BdbMessageStore.cpp =================================================================== --- store/trunk/cpp/lib/BdbMessageStore.cpp 2007-12-14 14:44:56 UTC (rev 1487) +++ store/trunk/cpp/lib/BdbMessageStore.cpp 2007-12-14 14:47:46 UTC (rev 1488) @@ -992,7 +992,6 @@ try { if ( queue && usingJrnl()) { - qpid::sys::Mutex::ScopedLock s(jrnlWriteLock); boost::intrusive_ptr<DataTokenImpl> dtokp(new DataTokenImpl); dtokp->addRef(); dtokp->setSourceMessage(message); @@ -1136,7 +1135,6 @@ intrusive_ptr<PersistableMessage>& msg, const PersistableQueue& queue) { - qpid::sys::Mutex::ScopedLock s(jrnlWriteLock); bool written = false; boost::intrusive_ptr<DataTokenImpl> ddtokp(new DataTokenImpl); ddtokp->addRef(); Modified: store/trunk/cpp/lib/BdbMessageStore.h =================================================================== --- store/trunk/cpp/lib/BdbMessageStore.h 2007-12-14 14:44:56 UTC (rev 1487) +++ store/trunk/cpp/lib/BdbMessageStore.h 2007-12-14 14:47:46 UTC (rev 1488) @@ -84,7 +84,6 @@ u_int16_t numJrnlFiles; u_int32_t jrnlFsizePgs; bool isInit; - mutable qpid::sys::Mutex jrnlWriteLock; const char* envPath; static qpid::sys::Duration defJournalGetEventsTimeout; static qpid::sys::Duration defJournalFlushTimeout;