activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Christian Mamen (JIRA)" <j...@apache.org>
Subject [jira] [Created] (AMQCPP-524) Experiencing deadlock while destroying activemq::core::ActiveMQConnection
Date Wed, 06 Nov 2013 01:18:17 GMT
Christian Mamen created AMQCPP-524:
--------------------------------------

             Summary: Experiencing deadlock while destroying activemq::core::ActiveMQConnection
                 Key: AMQCPP-524
                 URL: https://issues.apache.org/jira/browse/AMQCPP-524
             Project: ActiveMQ C++ Client
          Issue Type: Bug
          Components: Decaf
    Affects Versions: 3.8.1
         Environment: windows
            Reporter: Christian Mamen
            Assignee: Timothy Bish


The deadlock occurs while destroying an amq connection, a broker connection as been establish.

I added a break point inside before termination decaf::internal::util::concurrent::PlatformThread::interruptibleWaitOnCondition,
and before the deadlock occurs i can see
the following threads:
{noformat} 
0	 	4396	Main Thread	PorterSvc	decaf::internal::util::concurrent::Threading::join	Normal	0
0	 	8252	Worker Thread	Win32 Thread	776ef959	Normal	0
0	 	5280	Worker Thread	Win32 Thread	776f015d	Normal	0
0	 	8588	Worker Thread	_threadstartex	CtiLocalConnect<CtiOutMessage,INMESS>::CtiLocalConnectRead
Normal	0
0	 	4916	Worker Thread	_threadstartex	_CrtDefaultAllocHook	Normal	0
0	>	5532	Worker Thread	_threadstartex	decaf::internal::util::concurrent::PlatformThread::interruptibleWaitOnCondition
Normal	0
0	 	1956	Worker Thread	_threadstartex	std::_Lockit::~_Lockit	Normal	0
0	 	5784	Worker Thread	Win32 Thread	CtrlHandler	Highest	0
0	 	4512	Worker Thread	Win32 Thread	776f1f46	Normal	0
0	 	7180	Worker Thread	Win32 Thread	776f1f46	Normal	0
0	 	1668	Worker Thread	Win32 Thread	776f1f46	Normal	0
{noformat} 

At this moment, the call stack for thread 5532 is the following:
{noformat} 
decaf::internal::util::concurrent::PlatformThread::interruptibleWaitOnCondition(void * condition=0x000007d8,
_RTL_CRITICAL_SECTION * mutex=0x077dee10, __int64 mills=7659, int nanos=0, decaf::internal::util::concurrent::CompletionCondition
& complete={...})  Line 305 + 0xe bytes	C++
`anonymous namespace'::doWaitOnMonitor(decaf::internal::util::concurrent::MonitorHandle *
monitor=0x0771acf8, decaf::internal::util::concurrent::ThreadHandle * thread=0x05f338a8, __int64
mills=7659, int nanos=0, bool interruptible=true)  Line 752 + 0x23 bytes	C++
decaf::internal::util::concurrent::Threading::waitOnMonitor(decaf::internal::util::concurrent::MonitorHandle
* monitor=0x0771acf8, __int64 mills=7659, int nanos=0)  Line 1558 + 0x1b bytes	C++
decaf::util::concurrent::Mutex::wait(__int64 millisecs=7659, int nanos=0)  Line 180 + 0x1a
bytes	C++
decaf::util::concurrent::Mutex::wait(__int64 millisecs=7659)  Line 162	C++
decaf::internal::util::concurrent::SynchronizableImpl::wait(__int64 millisecs=7659)  Line
54	C++
decaf::util::TimerImpl::run()  Line 102 + 0x1f bytes	C++
`anonymous namespace'::runCallback(void * arg=0x05f338a8)  Line 266 + 0x11 bytes	C++
`anonymous namespace'::threadEntryMethod(void * arg=0x05f338a8)  Line 254 + 0x15 bytes	C++
{noformat} 

Afterwards, only the main thread is left and the deadlock occurs interruptibleWaitOnCondition
at "PlatformThread::unlockMutex(mutex);"
{noformat} 
0	>	4396	Main Thread	PorterSvc	decaf::internal::util::concurrent::PlatformThread::interruptibleWaitOnCondition
Normal	0
{noformat} 

{noformat} 
decaf::internal::util::concurrent::PlatformThread::interruptibleWaitOnCondition(void * condition=0x001293d0,
_RTL_CRITICAL_SECTION * mutex=0x1f13f1e8, __int64 mills=600000, int nanos=0, decaf::internal::util::concurrent::CompletionCondition
& complete={...})  Line 305 + 0xe bytes	C++
decaf::internal::util::concurrent::Threading::join(decaf::internal::util::concurrent::ThreadHandle
* thread=0x043eb370, __int64 mills=600000, int nanos=0)  Line 1168 + 0x23 bytes	C++
decaf::lang::Thread::join(__int64 millisecs=600000)  Line 178 + 0x19 bytes	C++
decaf::util::Timer::awaitTermination(__int64 timeout=10, const decaf::util::concurrent::TimeUnit
& unit={...})  Line 236	C++
decaf::util::concurrent::ExecutorKernel::~ExecutorKernel()  Line 419	C++
decaf::util::concurrent::ExecutorKernel::`scalar deleting destructor'()  + 0xf bytes	C++
decaf::util::concurrent::ThreadPoolExecutor::~ThreadPoolExecutor()  Line 1481 + 0x1f bytes
C++
decaf::util::concurrent::ThreadPoolExecutor::`vector deleting destructor'()  + 0x4d bytes
C++
decaf::lang::Pointer<decaf::util::concurrent::ExecutorService,decaf::util::concurrent::atomic::AtomicRefCounter>::onDeleteFunc(decaf::util::concurrent::ExecutorService
* value=0x1f13b7f8)  Line 317 + 0x20 bytes	C++
decaf::lang::Pointer<decaf::util::concurrent::ExecutorService,decaf::util::concurrent::atomic::AtomicRefCounter>::~Pointer<decaf::util::concurrent::ExecutorService,decaf::util::concurrent::atomic::AtomicRefCounter>()
 Line 148 + 0xf bytes	C++
activemq::core::ConnectionConfig::~ConnectionConfig()  Line 303 + 0x1ba bytes	C++
activemq::core::ConnectionConfig::`scalar deleting destructor'()  + 0xf bytes	C++
activemq::core::ActiveMQConnection::~ActiveMQConnection()  Line 501 + 0x1f bytes	C++
activemq::core::ActiveMQConnection::`vbase destructor'()  + 0xf bytes	C++
activemq::core::ActiveMQConnection::`vector deleting destructor'()  + 0x4d bytes	C++
{noformat} 

If i look into the ThreadHandle object, i can see the threadId	5532 and state == 4 (Thread::TIMED_WAITING),
however the thread at this point is not running
{noformat} 
-		thread	0x06054520 {parent=0x060543c0 handle=0x000007bc mutex=0x062ad498 ...}	decaf::internal::util::concurrent::ThreadHandle
*
+		parent	0x060543c0 {heap={...} cancelled=true }	decaf::lang::Thread *
		handle	0x000007bc	void *
+		mutex	0x062ad498 {DebugInfo=0x00373658 LockCount=-2 RecursionCount=1 ...}	_RTL_CRITICAL_SECTION
*
		condition	0x000007b8	void *
		state	4	volatile int
		references	2	volatile int
		priority	5	int
		interrupted	false	bool
		interruptible	true	bool
		timerSet	true	bool
		canceled	false	bool
		unparked	false	bool
		parked	false	bool
		sleeping	false	bool
		waiting	false	bool
		notified	true	bool
		blocked	true	bool
		suspended	false	bool
+		name	0x062ad580 "Thread-2"	char *
		stackSize	32768	__int64
+		tls	0x06054558	void * [384]
		threadMain	0x00ecbf7c `anonymous namespace'::runCallback(void *)	void (void *)*
		threadArg	0x06054520	void *
		threadId	5532	__int64
		osThread	false	bool
+		interruptingThread	0x00000000 {parent=??? handle=??? mutex=??? ...}	decaf::internal::util::concurrent::ThreadHandle
*
		numAttached	0	int
+		next	0x00000000 {parent=??? handle=??? mutex=??? ...}	decaf::internal::util::concurrent::ThreadHandle
*
+		joiners	0x060e65c0 {parent=0x077a1d90 handle=0xfffffffe mutex=0x05fcf318 ...}	decaf::internal::util::concurrent::ThreadHandle
*
+		monitor	0x052e47e8 {name=0xcdcdcdcd <Bad Ptr> mutex=0x06bfed80 lock=0x06bff148 ...}
decaf::internal::util::concurrent::MonitorHandle *
{noformat} 

I'm not sure if this is a race condition or if the flags are not updated properly.








--
This message was sent by Atlassian JIRA
(v6.1#6144)

Mime
View raw message