Deadlock on transacted session
------------------------------
Key: AMQCPP-174
URL: https://issues.apache.org/activemq/browse/AMQCPP-174
Project: ActiveMQ C++ Client
Issue Type: Bug
Components: CMS Impl
Affects Versions: 2.1.3
Environment: Windows XP
Visual Studio 2003 & 2005
activemq-cpp 2.1.3
apache-activemq 5.0.0
Reporter: Nick Cooper
Assignee: Nathan Mittler
Fix For: 2.1.3
Attachments: request_response.zip
I am implementing a request/response client and require the ability to do transactions. I
initially created one connection with one session with a producer and a consumer. This worked
fine when creating the session with Session::AUTO_ACKNOWLEDGE. When I changed this to use
Session::SESSION_TRANSACTED
with session->commit() the application stopped working. To help work out the issue I created
separate connections and sessions for the producer and consumer which did not help.
Looking at the application in the debugger it looks like when session->commit() is called,
a dead lock occurs.
In ActiveMQSessionExecutor::stop() the following line is executed:
// Wakeup the thread so that it can acknowledge the stop request.
mutex.notifyAll();
but eventQ.size() is 0, that is no thread is notified. The next line is then executed:
// Wait for the thread to notify us that it has acknowledged
// the stop request.
mutex.wait();
but there is no other thread to ever come and wake it up, thus it hangs and the session is
never committed.
Am I using the API incorrectly or is this a real issue?
Note this looks very similar to issue 155 https://issues.apache.org/activemq/browse/AMQCPP-155
Thread Summary
--------------
2000 main tool::DefaultCounter::`scalar deleting destructor' Normal 0
1896 _threadstartex activemq::concurrent::Mutex::wait Normal 0
3984 _threadstartex activemq::network::SocketInputStream::read Normal 0
> 1544 _threadstartex activemq::concurrent::Mutex::notifyAll Normal
0
Thread 1544 Stacktrace....
> ppl_worker_d.exe!activemq::concurrent::Mutex::notifyAll() Line 233 C++
ppl_worker_d.exe!activemq::core::ActiveMQSessionExecutor::stop() Line 150 + 0x11 C++
ppl_worker_d.exe!activemq::core::ActiveMQSession::stop() Line 847 + 0x1b C++
ppl_worker_d.exe!activemq::core::ActiveMQTransaction::commit() Line 205 C++
ppl_worker_d.exe!activemq::core::ActiveMQSession::commit() Line 150 + 0x13 C++
ppl_worker_d.exe!dist::TransactedConnector::onMessage(const cms::Message * message=0x014df8c0)
Line 176 + 0x30 C++
ppl_worker_d.exe!activemq::core::ActiveMQConsumer::dispatch(activemq::core::DispatchData
& data={...}) Line 429 + 0x3a C++
ppl_worker_d.exe!activemq::core::ActiveMQSessionExecutor::dispatch(activemq::core::DispatchData
& data={...}) Line 188 + 0x15 C++
ppl_worker_d.exe!activemq::core::ActiveMQSessionExecutor::dispatchAll() Line 273 + 0x11
C++
ppl_worker_d.exe!activemq::core::ActiveMQSessionExecutor::run() Line 213 C++
ppl_worker_d.exe!activemq::concurrent::Thread::runCallback(void * param=0x014dc3e8) Line
152 + 0x13 C++
msvcr71d.dll!_threadstartex(void * ptd=0x014df798) Line 241 + 0xd C
kernel32.dll!7c80b683()
Thread 3984 Stacktrace....
> ppl_worker_d.exe!activemq::network::SocketInputStream::read(unsigned char * buffer=0x014d8f70,
unsigned int bufferSize=1) Line 152 + 0x19 C++
ppl_worker_d.exe!activemq::io::BufferedInputStream::bufferData() Line 190 + 0x2c C++
ppl_worker_d.exe!activemq::io::BufferedInputStream::read(unsigned char * targetBuffer=0x017ff6f4,
unsigned int targetBufferSize=4) Line 125 C++
ppl_worker_d.exe!activemq::io::DataInputStream::readAllData(unsigned char * buffer=0x017ff6f4,
unsigned int length=4) Line 369 + 0x21 C++
ppl_worker_d.exe!activemq::io::DataInputStream::readInt() Line 168 C++
ppl_worker_d.exe!activemq::connector::openwire::OpenWireFormat::unmarshal(activemq::io::DataInputStream
* dis=0x014dcbe8) Line 218 + 0xd C++
ppl_worker_d.exe!activemq::connector::openwire::OpenWireCommandReader::readCommand() Line
71 + 0x1a C++
ppl_worker_d.exe!activemq::transport::IOTransport::run() Line 166 + 0x13 C++
ppl_worker_d.exe!activemq::concurrent::Thread::runCallback(void * param=0x014dce40) Line
152 + 0x13 C++
msvcr71d.dll!_threadstartex(void * ptd=0x014ddd10) Line 241 + 0xd C
kernel32.dll!7c80b683()
Thread 1896 Stacktrace....
> ppl_worker_d.exe!activemq::concurrent::Mutex::wait(unsigned long millisecs=4294967295)
Line 178 + 0x10 C++
ppl_worker_d.exe!activemq::concurrent::Mutex::wait() Line 102 + 0xf C++
ppl_worker_d.exe!activemq::util::Queue<activemq::transport::Command *>::wait() Line
206 + 0x11 C++
ppl_worker_d.exe!activemq::transport::filters::AsyncSendTransport::run() Line 118 + 0x11
C++
ppl_worker_d.exe!activemq::concurrent::Thread::runCallback(void * param=0x014dcad0) Line
152 + 0x13 C++
msvcr71d.dll!_threadstartex(void * ptd=0x014dcd78) Line 241 + 0xd C
kernel32.dll!7c80b683()
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
|