qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (QPID-6487) [Java Broker] [AMQP 1.0] Deadlock in Java Broker AMQP 1.0 with new IO model
Date Fri, 10 Apr 2015 10:21:12 GMT

    [ https://issues.apache.org/jira/browse/QPID-6487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14489318#comment-14489318
] 

ASF subversion and git services commented on QPID-6487:
-------------------------------------------------------

Commit 1672608 from [~godfrer] in branch 'qpid/trunk'
[ https://svn.apache.org/r1672608 ]

QPID-6487 : Run link detached callback outside of scope of AMQP 1.0 connection lock

> [Java Broker] [AMQP 1.0] Deadlock in Java Broker AMQP 1.0 with new IO model
> ---------------------------------------------------------------------------
>
>                 Key: QPID-6487
>                 URL: https://issues.apache.org/jira/browse/QPID-6487
>             Project: Qpid
>          Issue Type: Bug
>          Components: Java Broker
>            Reporter: Rob Godfrey
>            Assignee: Rob Godfrey
>
> With the new threading / I/O model in place a deadlock can occur in the detaching of
links:
> {noformat}
> "IO-/127.0.0.1:59379@2150" prio=5 tid=0x1b nid=NA waiting
>   java.lang.Thread.State: WAITING
> blocks pool-1-thread-8@4354
>  at sun.misc.Unsafe.park(Unsafe.java:-1)
>  at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
>  at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:834)
>  at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:994)
>  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1303)
>  at com.google.common.util.concurrent.AbstractFuture$Sync.get(AbstractFuture.java:292)
>  at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:116)
>  at org.apache.qpid.server.model.AbstractConfiguredObject.doSync(AbstractConfiguredObject.java:1724)
>  at org.apache.qpid.server.model.AbstractConfiguredObject.close(AbstractConfiguredObject.java:637)
>  at org.apache.qpid.server.protocol.v1_0.SendingLink_1_0.remoteDetached(SendingLink_1_0.java:413)
>  at org.apache.qpid.server.protocol.v1_0.Session_1_0$SubjectSpecificSendingLinkListener$2.run(Session_1_0.java:854)
>  at java.security.AccessController.doPrivileged(AccessController.java:-1)
>  at javax.security.auth.Subject.doAs(Subject.java:356)
>  at org.apache.qpid.server.protocol.v1_0.Session_1_0$SubjectSpecificSendingLinkListener.remoteDetached(Session_1_0.java:849)
>  at org.apache.qpid.amqp_1_0.transport.LinkEndpoint.remoteDetached(LinkEndpoint.java:190)
>  - locked <0x1111> (a org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint)
>  at org.apache.qpid.amqp_1_0.transport.SessionEndpoint.detach(SessionEndpoint.java:358)
>  at org.apache.qpid.amqp_1_0.transport.SessionEndpoint.receiveDetach(SessionEndpoint.java:349)
>  at org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint.receiveDetach(ConnectionEndpoint.java:646)
>  at org.apache.qpid.amqp_1_0.type.transport.Detach.invoke(Detach.java:117)
>  at org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint.receive(ConnectionEndpoint.java:808)
>  at org.apache.qpid.amqp_1_0.framing.FrameHandler.parse(FrameHandler.java:241)
>  at org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL$4.run(ProtocolEngine_1_0_0_SASL.java:436)
>  at org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL$4.run(ProtocolEngine_1_0_0_SASL.java:432)
>  at java.security.AccessController.doPrivileged(AccessController.java:-1)
>  at javax.security.auth.Subject.doAs(Subject.java:356)
>  at org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL.received(ProtocolEngine_1_0_0_SASL.java:431)
>  - locked <0x1128> (a
> org.apache.qpid.server.protocol.v1_0.ProtocolEngine_1_0_0_SASL)
>  at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:157)
>  at org.apache.qpid.server.transport.NonBlockingConnection.doRead(NonBlockingConnection.java:375)
>  at org.apache.qpid.server.transport.NonBlockingConnection.doWork(NonBlockingConnection.java:276)
>  at org.apache.qpid.server.transport.NetworkConnectionScheduler.processConnection(NetworkConnectionScheduler.java:89)
>  at org.apache.qpid.server.transport.NetworkConnectionScheduler.access$000(NetworkConnectionScheduler.java:31)
>  at org.apache.qpid.server.transport.NetworkConnectionScheduler$2.run(NetworkConnectionScheduler.java:70)
>  at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
>  at java.util.concurrent.FutureTask.run(FutureTask.java:262)
>  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:178)
>  at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:292)
>  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>  at java.lang.Thread.run(Thread.java:724)
> "VirtualHostNode-default-Configuration-Thread@2029" prio=5 tid=0xe
> nid=NA waiting
>   java.lang.Thread.State: WAITING
>  at sun.misc.Unsafe.park(Unsafe.java:-1)
>  at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
>  at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:834)
>  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:867)
>  at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1197)
>  at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:214)
>  at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:290)
>  at org.apache.qpid.server.consumer.AbstractConsumerTarget.getSendLock(AbstractConsumerTarget.java:161)
>  at org.apache.qpid.server.queue.QueueConsumerImpl.onClose(QueueConsumerImpl.java:253)
>  at org.apache.qpid.server.model.AbstractConfiguredObject$5$1.run(AbstractConfiguredObject.java:665)
>  at org.apache.qpid.server.model.AbstractConfiguredObject$17.onSuccess(AbstractConfiguredObject.java:1879)
>  at org.apache.qpid.server.model.AbstractConfiguredObject$17.onSuccess(AbstractConfiguredObject.java:1873)
>  at com.google.common.util.concurrent.Futures$4.run(Futures.java:1149)
>  at org.apache.qpid.server.configuration.updater.TaskExecutorImpl$ImmediateIfSameThreadExecutor.execute(TaskExecutorImpl.java:406)
>  at com.google.common.util.concurrent.ExecutionList$RunnableExecutorPair.execute(ExecutionList.java:150)
>  at com.google.common.util.concurrent.ExecutionList.add(ExecutionList.java:106)
>  at com.google.common.util.concurrent.AbstractFuture.addListener(AbstractFuture.java:170)
>  at com.google.common.util.concurrent.Futures.addCallback(Futures.java:1152)
>  at org.apache.qpid.server.model.AbstractConfiguredObject.doAfter(AbstractConfiguredObject.java:1872)
>  at org.apache.qpid.server.model.AbstractConfiguredObject$ChainedSettableFuture.then(AbstractConfiguredObject.java:1928)
>  at org.apache.qpid.server.model.AbstractConfiguredObject$5.call(AbstractConfiguredObject.java:653)
>  at org.apache.qpid.server.model.AbstractConfiguredObject$5.call(AbstractConfiguredObject.java:644)
>  at org.apache.qpid.server.model.AbstractConfiguredObject$2.execute(AbstractConfiguredObject.java:505)
>  at org.apache.qpid.server.model.AbstractConfiguredObject$2.execute(AbstractConfiguredObject.java:498)
>  at org.apache.qpid.server.configuration.updater.TaskExecutorImpl.executeTask(TaskExecutorImpl.java:318)
>  at org.apache.qpid.server.configuration.updater.TaskExecutorImpl.access$600(TaskExecutorImpl.java:45)
>  at org.apache.qpid.server.configuration.updater.TaskExecutorImpl$CallableWrapper$1.run(TaskExecutorImpl.java:346)
>  at java.security.AccessController.doPrivileged(AccessController.java:-1)
>  at javax.security.auth.Subject.doAs(Subject.java:356)
>  at org.apache.qpid.server.configuration.updater.TaskExecutorImpl$CallableWrapper.call(TaskExecutorImpl.java:341)
>  at java.util.concurrent.FutureTask.run(FutureTask.java:262)
>  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>  at java.lang.Thread.run(Thread.java:724)
> "pool-1-thread-8@4354" prio=5 tid=0x3a nid=NA waiting for monitor entry
>   java.lang.Thread.State: BLOCKED
> waiting for IO-/127.0.0.1:59379@2150 to release lock on <0x1111> (a
> org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint)
>  at org.apache.qpid.server.protocol.v1_0.ConsumerTarget_1_0.queueEmpty(ConsumerTarget_1_0.java:325)
>  at org.apache.qpid.server.queue.QueueConsumerImpl.queueEmpty(QueueConsumerImpl.java:291)
>  at org.apache.qpid.server.queue.AbstractQueue.processQueue(AbstractQueue.java:2286)
>  at org.apache.qpid.server.queue.QueueRunner$1.run(QueueRunner.java:78)
>  at java.security.AccessController.doPrivileged(AccessController.java:-1)
>  at javax.security.auth.Subject.doAs(Subject.java:356)
>  at org.apache.qpid.server.queue.QueueRunner.run(QueueRunner.java:69)
>  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
>  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
>  at java.lang.Thread.run(Thread.java:724)
> {noformat}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org


Mime
View raw message