activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timothy Bish (JIRA)" <jira+amq...@apache.org>
Subject [jira] [Resolved] (AMQNET-487) Deadlock in Failover Transport when reconnecting
Date Mon, 11 Aug 2014 17:58:12 GMT

     [ https://issues.apache.org/jira/browse/AMQNET-487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Timothy Bish resolved AMQNET-487.
---------------------------------

       Resolution: Fixed
    Fix Version/s: 1.7.0
                   1.6.4
         Assignee: Timothy Bish  (was: Jim Gomes)

Looks good, patch applied to trunk and 1.6.x

> Deadlock in Failover Transport when reconnecting
> ------------------------------------------------
>
>                 Key: AMQNET-487
>                 URL: https://issues.apache.org/jira/browse/AMQNET-487
>             Project: ActiveMQ .Net
>          Issue Type: Bug
>          Components: ActiveMQ
>    Affects Versions: 1.5.2, 1.6.2, 1.6.3
>         Environment: ActiveMQ 5.5.1 on Windows Server 2008 failover with networked brokers.
> Apache.NMS.ActiveMQ 1.6.2 running on .net 4.5/Windows 7
>            Reporter: Laurence Pike
>            Assignee: Timothy Bish
>            Priority: Critical
>             Fix For: 1.6.4, 1.7.0
>
>         Attachments: FixForPossibleDeadlockOnReconnectAMQNET-487.patch
>
>
> Lock ordering issue with reconnectMutex and ((ICollection)connectionState.RecoveringPullConsumers).SyncRoot.
Results in complete deadlock of NMS library.
> The two thread stacks do correctly take the reconnectMutex first but then in FailoverTransport.Oneway
the reconnectMutex is Waited.
> The two stacks are:
> ========================================================================
> ntdll.dll!ZwWaitForMultipleObjects()	 
> KERNELBASE.dll!WaitForMultipleObjectsEx()	 
> kernel32.dll!WaitForMultipleObjectsExImplementation()	 
> [Managed to Native Transition]	 
> mscorlib.dll!System.Threading.Monitor.Wait(object obj, int millisecondsTimeout)	 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransport.Oneway(Apache.NMS.ActiveMQ.Commands.Command
command)	 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.State.ConnectionStateTracker.ConnectionInterruptProcessingComplete(Apache.NMS.ActiveMQ.Transport.ITransport
transport, Apache.NMS.ActiveMQ.Commands.ConnectionId connectionId)	 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransport.ConnectionInterruptProcessingComplete(Apache.NMS.ActiveMQ.Commands.ConnectionId
connectionId)	 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.Connection.SignalInterruptionProcessingComplete()
 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.MessageConsumer.ClearMessagesInProgress()
 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.Threads.TimerEx.TimerImpl.Run()	 
> mscorlib.dll!System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext
executionContext, System.Threading.ContextCallback callback, object state, bool preserveSyncCtx)
 
> mscorlib.dll!System.Threading.ExecutionContext.Run(System.Threading.ExecutionContext
executionContext, System.Threading.ContextCallback callback, object state, bool preserveSyncCtx)
 
> mscorlib.dll!System.Threading.ExecutionContext.Run(System.Threading.ExecutionContext
executionContext, System.Threading.ContextCallback callback, object state)	 
> mscorlib.dll!System.Threading.ThreadHelper.ThreadStart()	 
> [Native to Managed Transition]	 
> kernel32.dll!BaseThreadInitThunk()	 
> ntdll.dll!RtlUserThreadStart()	
> ========================================================================
> ntdll.dll!ZwWaitForMultipleObjects()	 
> KERNELBASE.dll!WaitForMultipleObjectsEx()	 
> kernel32.dll!WaitForMultipleObjectsExImplementation()	 
> [Managed to Native Transition]	 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.State.ConnectionStateTracker.DoRestoreConsumers(Apache.NMS.ActiveMQ.Transport.ITransport
transport, Apache.NMS.ActiveMQ.State.SessionState sessionState)	 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.State.ConnectionStateTracker.DoRestoreSessions(Apache.NMS.ActiveMQ.Transport.ITransport
transport, Apache.NMS.ActiveMQ.State.ConnectionState connectionState)	 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.State.ConnectionStateTracker.DoRestore(Apache.NMS.ActiveMQ.Transport.ITransport
transport)	 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransport.RestoreTransport(Apache.NMS.ActiveMQ.Transport.ITransport
t)	 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransport.DoConnect()
 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransport.FailoverTask.Iterate()
 
> Apache.NMS.ActiveMQ.dll!Apache.NMS.ActiveMQ.Threads.DedicatedTaskRunner.Run()	 
> mscorlib.dll!System.Threading.ExecutionContext.RunInternal(System.Threading.ExecutionContext
executionContext, System.Threading.ContextCallback callback, object state, bool preserveSyncCtx)
 
> mscorlib.dll!System.Threading.ExecutionContext.Run(System.Threading.ExecutionContext
executionContext, System.Threading.ContextCallback callback, object state, bool preserveSyncCtx)
 
> mscorlib.dll!System.Threading.ExecutionContext.Run(System.Threading.ExecutionContext
executionContext, System.Threading.ContextCallback callback, object state)	 
> mscorlib.dll!System.Threading.ThreadHelper.ThreadStart()	 
> [Native to Managed Transition]	 
> kernel32.dll!BaseThreadInitThunk()	 
> ntdll.dll!RtlUserThreadStart()	 



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Mime
View raw message