[
https://issues.apache.org/activemq/browse/AMQ-2108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Colin MacNaughton updated AMQ-2108:
-----------------------------------
Attachment: AMQ2108patch.txt
Fix for issue
> activemq-flow Deadlock in FlowController
> ----------------------------------------
>
> Key: AMQ-2108
> URL: https://issues.apache.org/activemq/browse/AMQ-2108
> Project: ActiveMQ
> Issue Type: Bug
> Affects Versions: incubation
> Environment: n/a
> Reporter: Colin MacNaughton
> Fix For: incubation
>
> Attachments: AMQ2108patch.txt
>
>
> The following deadlock can occur in FlowController.offer(). FlowController
> shouldn't hold onto the mutex when calling flowElementAccepted
> Thread [pipe://Broker#2] (Suspended)
> Object.wait(long, int) line: not available [native method]
> ExclusivePriorityQueue<E>(Object).wait() line: 199 [local variables
> unavailable]
> FlowController<E>.waitForResume() line: 372
> FlowController<E>.blockSource(ISourceController<E>) line: 315
> FlowController<E>.add(E, ISourceController<E>) line: 229
> PriorityFlowController<E>.add(E, ISourceController<E>) line: 60
> ExclusivePriorityQueue<E>.add(E, ISourceController<E>) line: 66
> Router.route(ISourceController<Message>, Message) line: 30
> RemoteConnection$1.flowElemAccepted(ISourceController<Message>,
> Message) line: 92
> RemoteConnection$1.flowElemAccepted(ISourceController, Object) line: 1
> FlowController<E>.offer(E, ISourceController<E>) line: 266
> RemoteConnection.onCommand(Object) line: 73
> PipeTransportFactory$PipeTransport.run() line: 66
> Thread.run() line: 788
> Thread [consumer1-outbound] (Suspended)
> FlowController<E>.onFlowResume(ISinkController<E>) line: 136
> FlowController$2.run() line: 400
> IDispatcher$RunnableAdapter.dispatch() line: 90
> PriorityDispatcher$PriorityDispatchContext.dispatch() line: 183
> PriorityDispatcher.run() line: 263
> Thread.run() line: 788
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
