You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by "Alex Rudyy (JIRA)" <ji...@apache.org> on 2011/08/22 14:39:29 UTC
[jira] [Created] (QPID-3446) Deadlock is observed on simultaneous
closing of connection on both Java client and broker when java broker is
shut down
Deadlock is observed on simultaneous closing of connection on both Java client and broker when java broker is shut down
------------------------------------------------------------------------------------------------------------------------
Key: QPID-3446
URL: https://issues.apache.org/jira/browse/QPID-3446
Project: Qpid
Issue Type: Bug
Components: Java Broker, Java Client
Affects Versions: 0.10, 0.11, 0.12
Reporter: Alex Rudyy
Assignee: Robbie Gemmell
Attachments: deadlock.txt
Deadlock is observed on simultaneous closing of connection on both client and broker when broker is shut down.
Found one Java-level deadlock:
=============================
"Thread-0":
waiting to lock monitor 0x0000000059d53cf8 (object 0x00000000bbea0000, a java.lang.Object),
which is held by "MinaNetworkTransport(Acceptor)-12"
"MinaNetworkTransport(Acceptor)-12":
waiting for ownable synchronizer 0x00000000bbed8b10, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
which is held by "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c"
"SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
waiting to lock monitor 0x0000000059671c58 (object 0x00000000bbf11540, a [Lorg.apache.qpid.transport.Method;),
which is held by "MinaNetworkTransport(Acceptor)-12"
Java stack information for the threads listed above:
===================================================
"Thread-0":
at org.apache.qpid.transport.Connection.close(Connection.java:586)
- waiting to lock <0x00000000bbea0000> (a java.lang.Object)
at org.apache.qpid.server.transport.ServerConnection.close(ServerConnection.java:269)
at org.apache.qpid.server.connection.ConnectionRegistry.closeConnection(ConnectionRegistry.java:58)
at org.apache.qpid.server.connection.ConnectionRegistry.close(ConnectionRegistry.java:50)
at org.apache.qpid.server.virtualhost.VirtualHostImpl.close(VirtualHostImpl.java:574)
at org.apache.qpid.server.virtualhost.VirtualHostRegistry.close(VirtualHostRegistry.java:105)
at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:443)
at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:470)
at org.apache.qpid.server.registry.ConfigurationFileApplicationRegistry.close(ConfigurationFileApplicationRegistry.java:53)
at org.apache.qpid.server.registry.ApplicationRegistry.remove(ApplicationRegistry.java:203)
at org.apache.qpid.server.registry.ApplicationRegistry$ShutdownService.run(ApplicationRegistry.java:126)
at java.lang.Thread.run(Thread.java:662)
"MinaNetworkTransport(Acceptor)-12":
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x00000000bbed8b10> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
at org.apache.qpid.server.subscription.Subscription_0_10.getSendLock(Subscription_0_10.java:663)
at org.apache.qpid.server.transport.ServerSession.unregister(ServerSession.java:409)
at org.apache.qpid.server.transport.ServerSessionDelegate.closed(ServerSessionDelegate.java:1250)
at org.apache.qpid.transport.Session.closed(Session.java:1041)
- locked <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
at org.apache.qpid.transport.Connection.closed(Connection.java:551)
- locked <0x00000000bbea0000> (a java.lang.Object)
at org.apache.qpid.transport.network.Assembler.closed(Assembler.java:110)
at org.apache.qpid.transport.network.InputHandler.closed(InputHandler.java:202)
at org.apache.qpid.server.protocol.ProtocolEngine_0_10.closed(ProtocolEngine_0_10.java:176)
at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.closed(MultiVersionProtocolEngine.java:86)
at org.apache.qpid.transport.network.mina.MinaNetworkHandler.sessionClosed(MinaNetworkHandler.java:136)
at org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.sessionClosed(AbstractIoFilterChain.java:550)
at org.apache.mina.common.support.AbstractIoFilterChain.callNextSessionClosed(AbstractIoFilterChain.java:269)
at org.apache.mina.common.support.AbstractIoFilterChain.access$800(AbstractIoFilterChain.java:53)
at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.sessionClosed(AbstractIoFilterChain.java:633)
at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:230)
at org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:264)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:51)
at java.lang.Thread.run(Thread.java:662)
"SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
at org.apache.qpid.transport.Session.invoke(Session.java:586)
- waiting to lock <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
at org.apache.qpid.server.transport.ServerSession.sendMessage(ServerSession.java:203)
at org.apache.qpid.server.subscription.Subscription_0_10.send(Subscription_0_10.java:602)
at org.apache.qpid.server.queue.SimpleAMQQueue.deliverMessage(SimpleAMQQueue.java:747)
at org.apache.qpid.server.queue.SimpleAMQQueue.attemptDelivery(SimpleAMQQueue.java:1666)
at org.apache.qpid.server.queue.SimpleAMQQueue.flushSubscription(SimpleAMQQueue.java:1605)
at org.apache.qpid.server.queue.SubFlushRunner.run(SubFlushRunner.java:58)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
Found 1 deadlock.
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
[jira] [Assigned] (QPID-3446) Deadlock is observed on simultaneous
closing of connection on both Java client and broker when java broker is
shut down
Posted by "Alex Rudyy (Assigned) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/QPID-3446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alex Rudyy reassigned QPID-3446:
--------------------------------
Assignee: Robbie Gemmell (was: Alex Rudyy)
Robbie, could you please review and apply an attached patch with fixes?
> Deadlock is observed on simultaneous closing of connection on both Java client and broker when java broker is shut down
> ------------------------------------------------------------------------------------------------------------------------
>
> Key: QPID-3446
> URL: https://issues.apache.org/jira/browse/QPID-3446
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker, Java Client
> Affects Versions: 0.10, 0.11, 0.12
> Reporter: Alex Rudyy
> Assignee: Robbie Gemmell
> Attachments: 0001-QPID-3446-Unregister-existing-subscription-on-closin.patch, deadlock.txt
>
>
> Deadlock is observed on simultaneous closing of connection on both client and broker when broker is shut down.
> Found one Java-level deadlock:
> =============================
> "Thread-0":
> waiting to lock monitor 0x0000000059d53cf8 (object 0x00000000bbea0000, a java.lang.Object),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> "MinaNetworkTransport(Acceptor)-12":
> waiting for ownable synchronizer 0x00000000bbed8b10, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
> which is held by "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c"
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> waiting to lock monitor 0x0000000059671c58 (object 0x00000000bbf11540, a [Lorg.apache.qpid.transport.Method;),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> Java stack information for the threads listed above:
> ===================================================
> "Thread-0":
> at org.apache.qpid.transport.Connection.close(Connection.java:586)
> - waiting to lock <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.server.transport.ServerConnection.close(ServerConnection.java:269)
> at org.apache.qpid.server.connection.ConnectionRegistry.closeConnection(ConnectionRegistry.java:58)
> at org.apache.qpid.server.connection.ConnectionRegistry.close(ConnectionRegistry.java:50)
> at org.apache.qpid.server.virtualhost.VirtualHostImpl.close(VirtualHostImpl.java:574)
> at org.apache.qpid.server.virtualhost.VirtualHostRegistry.close(VirtualHostRegistry.java:105)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:443)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:470)
> at org.apache.qpid.server.registry.ConfigurationFileApplicationRegistry.close(ConfigurationFileApplicationRegistry.java:53)
> at org.apache.qpid.server.registry.ApplicationRegistry.remove(ApplicationRegistry.java:203)
> at org.apache.qpid.server.registry.ApplicationRegistry$ShutdownService.run(ApplicationRegistry.java:126)
> at java.lang.Thread.run(Thread.java:662)
> "MinaNetworkTransport(Acceptor)-12":
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000bbed8b10> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
> at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
> at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
> at org.apache.qpid.server.subscription.Subscription_0_10.getSendLock(Subscription_0_10.java:663)
> at org.apache.qpid.server.transport.ServerSession.unregister(ServerSession.java:409)
> at org.apache.qpid.server.transport.ServerSessionDelegate.closed(ServerSessionDelegate.java:1250)
> at org.apache.qpid.transport.Session.closed(Session.java:1041)
> - locked <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.transport.Connection.closed(Connection.java:551)
> - locked <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.transport.network.Assembler.closed(Assembler.java:110)
> at org.apache.qpid.transport.network.InputHandler.closed(InputHandler.java:202)
> at org.apache.qpid.server.protocol.ProtocolEngine_0_10.closed(ProtocolEngine_0_10.java:176)
> at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.closed(MultiVersionProtocolEngine.java:86)
> at org.apache.qpid.transport.network.mina.MinaNetworkHandler.sessionClosed(MinaNetworkHandler.java:136)
> at org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.sessionClosed(AbstractIoFilterChain.java:550)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextSessionClosed(AbstractIoFilterChain.java:269)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$800(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.sessionClosed(AbstractIoFilterChain.java:633)
> at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:230)
> at org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:264)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:51)
> at java.lang.Thread.run(Thread.java:662)
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> at org.apache.qpid.transport.Session.invoke(Session.java:586)
> - waiting to lock <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.server.transport.ServerSession.sendMessage(ServerSession.java:203)
> at org.apache.qpid.server.subscription.Subscription_0_10.send(Subscription_0_10.java:602)
> at org.apache.qpid.server.queue.SimpleAMQQueue.deliverMessage(SimpleAMQQueue.java:747)
> at org.apache.qpid.server.queue.SimpleAMQQueue.attemptDelivery(SimpleAMQQueue.java:1666)
> at org.apache.qpid.server.queue.SimpleAMQQueue.flushSubscription(SimpleAMQQueue.java:1605)
> at org.apache.qpid.server.queue.SubFlushRunner.run(SubFlushRunner.java:58)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Found 1 deadlock.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
[jira] [Resolved] (QPID-3446) Deadlock is observed on simultaneous
closing of connection on both Java client and broker when java broker is
shut down
Posted by "Robbie Gemmell (Resolved) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/QPID-3446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robbie Gemmell resolved QPID-3446.
----------------------------------
Resolution: Fixed
Fix Version/s: 0.15
Patch applied.
> Deadlock is observed on simultaneous closing of connection on both Java client and broker when java broker is shut down
> ------------------------------------------------------------------------------------------------------------------------
>
> Key: QPID-3446
> URL: https://issues.apache.org/jira/browse/QPID-3446
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker, Java Client
> Affects Versions: 0.10, 0.11, 0.12
> Reporter: Alex Rudyy
> Assignee: Robbie Gemmell
> Fix For: 0.15
>
> Attachments: 0001-QPID-3446-Unregister-existing-subscription-on-closin.patch, deadlock.txt
>
>
> Deadlock is observed on simultaneous closing of connection on both client and broker when broker is shut down.
> Found one Java-level deadlock:
> =============================
> "Thread-0":
> waiting to lock monitor 0x0000000059d53cf8 (object 0x00000000bbea0000, a java.lang.Object),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> "MinaNetworkTransport(Acceptor)-12":
> waiting for ownable synchronizer 0x00000000bbed8b10, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
> which is held by "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c"
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> waiting to lock monitor 0x0000000059671c58 (object 0x00000000bbf11540, a [Lorg.apache.qpid.transport.Method;),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> Java stack information for the threads listed above:
> ===================================================
> "Thread-0":
> at org.apache.qpid.transport.Connection.close(Connection.java:586)
> - waiting to lock <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.server.transport.ServerConnection.close(ServerConnection.java:269)
> at org.apache.qpid.server.connection.ConnectionRegistry.closeConnection(ConnectionRegistry.java:58)
> at org.apache.qpid.server.connection.ConnectionRegistry.close(ConnectionRegistry.java:50)
> at org.apache.qpid.server.virtualhost.VirtualHostImpl.close(VirtualHostImpl.java:574)
> at org.apache.qpid.server.virtualhost.VirtualHostRegistry.close(VirtualHostRegistry.java:105)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:443)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:470)
> at org.apache.qpid.server.registry.ConfigurationFileApplicationRegistry.close(ConfigurationFileApplicationRegistry.java:53)
> at org.apache.qpid.server.registry.ApplicationRegistry.remove(ApplicationRegistry.java:203)
> at org.apache.qpid.server.registry.ApplicationRegistry$ShutdownService.run(ApplicationRegistry.java:126)
> at java.lang.Thread.run(Thread.java:662)
> "MinaNetworkTransport(Acceptor)-12":
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000bbed8b10> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
> at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
> at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
> at org.apache.qpid.server.subscription.Subscription_0_10.getSendLock(Subscription_0_10.java:663)
> at org.apache.qpid.server.transport.ServerSession.unregister(ServerSession.java:409)
> at org.apache.qpid.server.transport.ServerSessionDelegate.closed(ServerSessionDelegate.java:1250)
> at org.apache.qpid.transport.Session.closed(Session.java:1041)
> - locked <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.transport.Connection.closed(Connection.java:551)
> - locked <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.transport.network.Assembler.closed(Assembler.java:110)
> at org.apache.qpid.transport.network.InputHandler.closed(InputHandler.java:202)
> at org.apache.qpid.server.protocol.ProtocolEngine_0_10.closed(ProtocolEngine_0_10.java:176)
> at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.closed(MultiVersionProtocolEngine.java:86)
> at org.apache.qpid.transport.network.mina.MinaNetworkHandler.sessionClosed(MinaNetworkHandler.java:136)
> at org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.sessionClosed(AbstractIoFilterChain.java:550)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextSessionClosed(AbstractIoFilterChain.java:269)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$800(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.sessionClosed(AbstractIoFilterChain.java:633)
> at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:230)
> at org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:264)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:51)
> at java.lang.Thread.run(Thread.java:662)
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> at org.apache.qpid.transport.Session.invoke(Session.java:586)
> - waiting to lock <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.server.transport.ServerSession.sendMessage(ServerSession.java:203)
> at org.apache.qpid.server.subscription.Subscription_0_10.send(Subscription_0_10.java:602)
> at org.apache.qpid.server.queue.SimpleAMQQueue.deliverMessage(SimpleAMQQueue.java:747)
> at org.apache.qpid.server.queue.SimpleAMQQueue.attemptDelivery(SimpleAMQQueue.java:1666)
> at org.apache.qpid.server.queue.SimpleAMQQueue.flushSubscription(SimpleAMQQueue.java:1605)
> at org.apache.qpid.server.queue.SubFlushRunner.run(SubFlushRunner.java:58)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Found 1 deadlock.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
[jira] [Assigned] (QPID-3446) Deadlock is observed on simultaneous
closing of connection on both Java client and broker when java broker is
shut down
Posted by "Alex Rudyy (Assigned) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/QPID-3446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alex Rudyy reassigned QPID-3446:
--------------------------------
Assignee: Alex Rudyy (was: Robbie Gemmell)
> Deadlock is observed on simultaneous closing of connection on both Java client and broker when java broker is shut down
> ------------------------------------------------------------------------------------------------------------------------
>
> Key: QPID-3446
> URL: https://issues.apache.org/jira/browse/QPID-3446
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker, Java Client
> Affects Versions: 0.10, 0.11, 0.12
> Reporter: Alex Rudyy
> Assignee: Alex Rudyy
> Attachments: 0001-QPID-3446-Unregister-existing-subscription-on-closin.patch, deadlock.txt
>
>
> Deadlock is observed on simultaneous closing of connection on both client and broker when broker is shut down.
> Found one Java-level deadlock:
> =============================
> "Thread-0":
> waiting to lock monitor 0x0000000059d53cf8 (object 0x00000000bbea0000, a java.lang.Object),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> "MinaNetworkTransport(Acceptor)-12":
> waiting for ownable synchronizer 0x00000000bbed8b10, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
> which is held by "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c"
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> waiting to lock monitor 0x0000000059671c58 (object 0x00000000bbf11540, a [Lorg.apache.qpid.transport.Method;),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> Java stack information for the threads listed above:
> ===================================================
> "Thread-0":
> at org.apache.qpid.transport.Connection.close(Connection.java:586)
> - waiting to lock <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.server.transport.ServerConnection.close(ServerConnection.java:269)
> at org.apache.qpid.server.connection.ConnectionRegistry.closeConnection(ConnectionRegistry.java:58)
> at org.apache.qpid.server.connection.ConnectionRegistry.close(ConnectionRegistry.java:50)
> at org.apache.qpid.server.virtualhost.VirtualHostImpl.close(VirtualHostImpl.java:574)
> at org.apache.qpid.server.virtualhost.VirtualHostRegistry.close(VirtualHostRegistry.java:105)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:443)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:470)
> at org.apache.qpid.server.registry.ConfigurationFileApplicationRegistry.close(ConfigurationFileApplicationRegistry.java:53)
> at org.apache.qpid.server.registry.ApplicationRegistry.remove(ApplicationRegistry.java:203)
> at org.apache.qpid.server.registry.ApplicationRegistry$ShutdownService.run(ApplicationRegistry.java:126)
> at java.lang.Thread.run(Thread.java:662)
> "MinaNetworkTransport(Acceptor)-12":
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000bbed8b10> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
> at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
> at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
> at org.apache.qpid.server.subscription.Subscription_0_10.getSendLock(Subscription_0_10.java:663)
> at org.apache.qpid.server.transport.ServerSession.unregister(ServerSession.java:409)
> at org.apache.qpid.server.transport.ServerSessionDelegate.closed(ServerSessionDelegate.java:1250)
> at org.apache.qpid.transport.Session.closed(Session.java:1041)
> - locked <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.transport.Connection.closed(Connection.java:551)
> - locked <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.transport.network.Assembler.closed(Assembler.java:110)
> at org.apache.qpid.transport.network.InputHandler.closed(InputHandler.java:202)
> at org.apache.qpid.server.protocol.ProtocolEngine_0_10.closed(ProtocolEngine_0_10.java:176)
> at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.closed(MultiVersionProtocolEngine.java:86)
> at org.apache.qpid.transport.network.mina.MinaNetworkHandler.sessionClosed(MinaNetworkHandler.java:136)
> at org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.sessionClosed(AbstractIoFilterChain.java:550)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextSessionClosed(AbstractIoFilterChain.java:269)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$800(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.sessionClosed(AbstractIoFilterChain.java:633)
> at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:230)
> at org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:264)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:51)
> at java.lang.Thread.run(Thread.java:662)
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> at org.apache.qpid.transport.Session.invoke(Session.java:586)
> - waiting to lock <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.server.transport.ServerSession.sendMessage(ServerSession.java:203)
> at org.apache.qpid.server.subscription.Subscription_0_10.send(Subscription_0_10.java:602)
> at org.apache.qpid.server.queue.SimpleAMQQueue.deliverMessage(SimpleAMQQueue.java:747)
> at org.apache.qpid.server.queue.SimpleAMQQueue.attemptDelivery(SimpleAMQQueue.java:1666)
> at org.apache.qpid.server.queue.SimpleAMQQueue.flushSubscription(SimpleAMQQueue.java:1605)
> at org.apache.qpid.server.queue.SubFlushRunner.run(SubFlushRunner.java:58)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Found 1 deadlock.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
[jira] [Updated] (QPID-3446) Deadlock is observed on simultaneous
closing of connection on both Java client and broker when java broker is
shut down
Posted by "Alex Rudyy (Updated) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/QPID-3446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alex Rudyy updated QPID-3446:
-----------------------------
Attachment: 0001-QPID-3446-Unregister-existing-subscription-on-closin.patch
Attached a patch to unregister existing subscriptions on connection close in order to avoid deadlocks.
> Deadlock is observed on simultaneous closing of connection on both Java client and broker when java broker is shut down
> ------------------------------------------------------------------------------------------------------------------------
>
> Key: QPID-3446
> URL: https://issues.apache.org/jira/browse/QPID-3446
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker, Java Client
> Affects Versions: 0.10, 0.11, 0.12
> Reporter: Alex Rudyy
> Assignee: Alex Rudyy
> Attachments: 0001-QPID-3446-Unregister-existing-subscription-on-closin.patch, deadlock.txt
>
>
> Deadlock is observed on simultaneous closing of connection on both client and broker when broker is shut down.
> Found one Java-level deadlock:
> =============================
> "Thread-0":
> waiting to lock monitor 0x0000000059d53cf8 (object 0x00000000bbea0000, a java.lang.Object),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> "MinaNetworkTransport(Acceptor)-12":
> waiting for ownable synchronizer 0x00000000bbed8b10, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
> which is held by "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c"
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> waiting to lock monitor 0x0000000059671c58 (object 0x00000000bbf11540, a [Lorg.apache.qpid.transport.Method;),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> Java stack information for the threads listed above:
> ===================================================
> "Thread-0":
> at org.apache.qpid.transport.Connection.close(Connection.java:586)
> - waiting to lock <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.server.transport.ServerConnection.close(ServerConnection.java:269)
> at org.apache.qpid.server.connection.ConnectionRegistry.closeConnection(ConnectionRegistry.java:58)
> at org.apache.qpid.server.connection.ConnectionRegistry.close(ConnectionRegistry.java:50)
> at org.apache.qpid.server.virtualhost.VirtualHostImpl.close(VirtualHostImpl.java:574)
> at org.apache.qpid.server.virtualhost.VirtualHostRegistry.close(VirtualHostRegistry.java:105)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:443)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:470)
> at org.apache.qpid.server.registry.ConfigurationFileApplicationRegistry.close(ConfigurationFileApplicationRegistry.java:53)
> at org.apache.qpid.server.registry.ApplicationRegistry.remove(ApplicationRegistry.java:203)
> at org.apache.qpid.server.registry.ApplicationRegistry$ShutdownService.run(ApplicationRegistry.java:126)
> at java.lang.Thread.run(Thread.java:662)
> "MinaNetworkTransport(Acceptor)-12":
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000bbed8b10> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
> at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
> at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
> at org.apache.qpid.server.subscription.Subscription_0_10.getSendLock(Subscription_0_10.java:663)
> at org.apache.qpid.server.transport.ServerSession.unregister(ServerSession.java:409)
> at org.apache.qpid.server.transport.ServerSessionDelegate.closed(ServerSessionDelegate.java:1250)
> at org.apache.qpid.transport.Session.closed(Session.java:1041)
> - locked <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.transport.Connection.closed(Connection.java:551)
> - locked <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.transport.network.Assembler.closed(Assembler.java:110)
> at org.apache.qpid.transport.network.InputHandler.closed(InputHandler.java:202)
> at org.apache.qpid.server.protocol.ProtocolEngine_0_10.closed(ProtocolEngine_0_10.java:176)
> at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.closed(MultiVersionProtocolEngine.java:86)
> at org.apache.qpid.transport.network.mina.MinaNetworkHandler.sessionClosed(MinaNetworkHandler.java:136)
> at org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.sessionClosed(AbstractIoFilterChain.java:550)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextSessionClosed(AbstractIoFilterChain.java:269)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$800(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.sessionClosed(AbstractIoFilterChain.java:633)
> at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:230)
> at org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:264)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:51)
> at java.lang.Thread.run(Thread.java:662)
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> at org.apache.qpid.transport.Session.invoke(Session.java:586)
> - waiting to lock <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.server.transport.ServerSession.sendMessage(ServerSession.java:203)
> at org.apache.qpid.server.subscription.Subscription_0_10.send(Subscription_0_10.java:602)
> at org.apache.qpid.server.queue.SimpleAMQQueue.deliverMessage(SimpleAMQQueue.java:747)
> at org.apache.qpid.server.queue.SimpleAMQQueue.attemptDelivery(SimpleAMQQueue.java:1666)
> at org.apache.qpid.server.queue.SimpleAMQQueue.flushSubscription(SimpleAMQQueue.java:1605)
> at org.apache.qpid.server.queue.SubFlushRunner.run(SubFlushRunner.java:58)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Found 1 deadlock.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
[jira] [Updated] (QPID-3446) Deadlock is observed on simultaneous
closing of connection on both Java client and broker when java broker is
shut down
Posted by "Alex Rudyy (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/QPID-3446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alex Rudyy updated QPID-3446:
-----------------------------
Attachment: deadlock.txt
> Deadlock is observed on simultaneous closing of connection on both Java client and broker when java broker is shut down
> ------------------------------------------------------------------------------------------------------------------------
>
> Key: QPID-3446
> URL: https://issues.apache.org/jira/browse/QPID-3446
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker, Java Client
> Affects Versions: 0.10, 0.11, 0.12
> Reporter: Alex Rudyy
> Assignee: Robbie Gemmell
> Attachments: deadlock.txt
>
>
> Deadlock is observed on simultaneous closing of connection on both client and broker when broker is shut down.
> Found one Java-level deadlock:
> =============================
> "Thread-0":
> waiting to lock monitor 0x0000000059d53cf8 (object 0x00000000bbea0000, a java.lang.Object),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> "MinaNetworkTransport(Acceptor)-12":
> waiting for ownable synchronizer 0x00000000bbed8b10, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
> which is held by "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c"
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> waiting to lock monitor 0x0000000059671c58 (object 0x00000000bbf11540, a [Lorg.apache.qpid.transport.Method;),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> Java stack information for the threads listed above:
> ===================================================
> "Thread-0":
> at org.apache.qpid.transport.Connection.close(Connection.java:586)
> - waiting to lock <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.server.transport.ServerConnection.close(ServerConnection.java:269)
> at org.apache.qpid.server.connection.ConnectionRegistry.closeConnection(ConnectionRegistry.java:58)
> at org.apache.qpid.server.connection.ConnectionRegistry.close(ConnectionRegistry.java:50)
> at org.apache.qpid.server.virtualhost.VirtualHostImpl.close(VirtualHostImpl.java:574)
> at org.apache.qpid.server.virtualhost.VirtualHostRegistry.close(VirtualHostRegistry.java:105)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:443)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:470)
> at org.apache.qpid.server.registry.ConfigurationFileApplicationRegistry.close(ConfigurationFileApplicationRegistry.java:53)
> at org.apache.qpid.server.registry.ApplicationRegistry.remove(ApplicationRegistry.java:203)
> at org.apache.qpid.server.registry.ApplicationRegistry$ShutdownService.run(ApplicationRegistry.java:126)
> at java.lang.Thread.run(Thread.java:662)
> "MinaNetworkTransport(Acceptor)-12":
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000bbed8b10> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
> at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
> at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
> at org.apache.qpid.server.subscription.Subscription_0_10.getSendLock(Subscription_0_10.java:663)
> at org.apache.qpid.server.transport.ServerSession.unregister(ServerSession.java:409)
> at org.apache.qpid.server.transport.ServerSessionDelegate.closed(ServerSessionDelegate.java:1250)
> at org.apache.qpid.transport.Session.closed(Session.java:1041)
> - locked <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.transport.Connection.closed(Connection.java:551)
> - locked <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.transport.network.Assembler.closed(Assembler.java:110)
> at org.apache.qpid.transport.network.InputHandler.closed(InputHandler.java:202)
> at org.apache.qpid.server.protocol.ProtocolEngine_0_10.closed(ProtocolEngine_0_10.java:176)
> at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.closed(MultiVersionProtocolEngine.java:86)
> at org.apache.qpid.transport.network.mina.MinaNetworkHandler.sessionClosed(MinaNetworkHandler.java:136)
> at org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.sessionClosed(AbstractIoFilterChain.java:550)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextSessionClosed(AbstractIoFilterChain.java:269)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$800(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.sessionClosed(AbstractIoFilterChain.java:633)
> at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:230)
> at org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:264)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:51)
> at java.lang.Thread.run(Thread.java:662)
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> at org.apache.qpid.transport.Session.invoke(Session.java:586)
> - waiting to lock <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.server.transport.ServerSession.sendMessage(ServerSession.java:203)
> at org.apache.qpid.server.subscription.Subscription_0_10.send(Subscription_0_10.java:602)
> at org.apache.qpid.server.queue.SimpleAMQQueue.deliverMessage(SimpleAMQQueue.java:747)
> at org.apache.qpid.server.queue.SimpleAMQQueue.attemptDelivery(SimpleAMQQueue.java:1666)
> at org.apache.qpid.server.queue.SimpleAMQQueue.flushSubscription(SimpleAMQQueue.java:1605)
> at org.apache.qpid.server.queue.SubFlushRunner.run(SubFlushRunner.java:58)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Found 1 deadlock.
--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
[jira] [Updated] (QPID-3446) Deadlock observed during broker
shutdown with simultaneous closing of connection and attempted message
delivery
Posted by "Robbie Gemmell (Updated) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/QPID-3446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robbie Gemmell updated QPID-3446:
---------------------------------
Fix Version/s: (was: 0.15)
0.14
Merged to 0.14 branch.
> Deadlock observed during broker shutdown with simultaneous closing of connection and attempted message delivery
> ---------------------------------------------------------------------------------------------------------------
>
> Key: QPID-3446
> URL: https://issues.apache.org/jira/browse/QPID-3446
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker, Java Client
> Affects Versions: 0.10, 0.11, 0.12
> Reporter: Alex Rudyy
> Assignee: Robbie Gemmell
> Fix For: 0.14
>
> Attachments: 0001-QPID-3446-Unregister-existing-subscription-on-closin.patch, deadlock.txt
>
>
> Deadlock is observed on simultaneous closing of connection on both client and broker when broker is shut down.
> Found one Java-level deadlock:
> =============================
> "Thread-0":
> waiting to lock monitor 0x0000000059d53cf8 (object 0x00000000bbea0000, a java.lang.Object),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> "MinaNetworkTransport(Acceptor)-12":
> waiting for ownable synchronizer 0x00000000bbed8b10, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
> which is held by "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c"
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> waiting to lock monitor 0x0000000059671c58 (object 0x00000000bbf11540, a [Lorg.apache.qpid.transport.Method;),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> Java stack information for the threads listed above:
> ===================================================
> "Thread-0":
> at org.apache.qpid.transport.Connection.close(Connection.java:586)
> - waiting to lock <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.server.transport.ServerConnection.close(ServerConnection.java:269)
> at org.apache.qpid.server.connection.ConnectionRegistry.closeConnection(ConnectionRegistry.java:58)
> at org.apache.qpid.server.connection.ConnectionRegistry.close(ConnectionRegistry.java:50)
> at org.apache.qpid.server.virtualhost.VirtualHostImpl.close(VirtualHostImpl.java:574)
> at org.apache.qpid.server.virtualhost.VirtualHostRegistry.close(VirtualHostRegistry.java:105)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:443)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:470)
> at org.apache.qpid.server.registry.ConfigurationFileApplicationRegistry.close(ConfigurationFileApplicationRegistry.java:53)
> at org.apache.qpid.server.registry.ApplicationRegistry.remove(ApplicationRegistry.java:203)
> at org.apache.qpid.server.registry.ApplicationRegistry$ShutdownService.run(ApplicationRegistry.java:126)
> at java.lang.Thread.run(Thread.java:662)
> "MinaNetworkTransport(Acceptor)-12":
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000bbed8b10> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
> at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
> at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
> at org.apache.qpid.server.subscription.Subscription_0_10.getSendLock(Subscription_0_10.java:663)
> at org.apache.qpid.server.transport.ServerSession.unregister(ServerSession.java:409)
> at org.apache.qpid.server.transport.ServerSessionDelegate.closed(ServerSessionDelegate.java:1250)
> at org.apache.qpid.transport.Session.closed(Session.java:1041)
> - locked <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.transport.Connection.closed(Connection.java:551)
> - locked <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.transport.network.Assembler.closed(Assembler.java:110)
> at org.apache.qpid.transport.network.InputHandler.closed(InputHandler.java:202)
> at org.apache.qpid.server.protocol.ProtocolEngine_0_10.closed(ProtocolEngine_0_10.java:176)
> at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.closed(MultiVersionProtocolEngine.java:86)
> at org.apache.qpid.transport.network.mina.MinaNetworkHandler.sessionClosed(MinaNetworkHandler.java:136)
> at org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.sessionClosed(AbstractIoFilterChain.java:550)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextSessionClosed(AbstractIoFilterChain.java:269)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$800(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.sessionClosed(AbstractIoFilterChain.java:633)
> at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:230)
> at org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:264)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:51)
> at java.lang.Thread.run(Thread.java:662)
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> at org.apache.qpid.transport.Session.invoke(Session.java:586)
> - waiting to lock <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.server.transport.ServerSession.sendMessage(ServerSession.java:203)
> at org.apache.qpid.server.subscription.Subscription_0_10.send(Subscription_0_10.java:602)
> at org.apache.qpid.server.queue.SimpleAMQQueue.deliverMessage(SimpleAMQQueue.java:747)
> at org.apache.qpid.server.queue.SimpleAMQQueue.attemptDelivery(SimpleAMQQueue.java:1666)
> at org.apache.qpid.server.queue.SimpleAMQQueue.flushSubscription(SimpleAMQQueue.java:1605)
> at org.apache.qpid.server.queue.SubFlushRunner.run(SubFlushRunner.java:58)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Found 1 deadlock.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
[jira] [Commented] (QPID-3446) Deadlock observed during broker
shutdown with simultaneous closing of connection and attempted message
delivery
Posted by "Justin Ross (Commented) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/QPID-3446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13148578#comment-13148578 ]
Justin Ross commented on QPID-3446:
-----------------------------------
Reviewed and approved for 0.14.
> Deadlock observed during broker shutdown with simultaneous closing of connection and attempted message delivery
> ---------------------------------------------------------------------------------------------------------------
>
> Key: QPID-3446
> URL: https://issues.apache.org/jira/browse/QPID-3446
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker, Java Client
> Affects Versions: 0.10, 0.11, 0.12
> Reporter: Alex Rudyy
> Assignee: Robbie Gemmell
> Fix For: 0.15
>
> Attachments: 0001-QPID-3446-Unregister-existing-subscription-on-closin.patch, deadlock.txt
>
>
> Deadlock is observed on simultaneous closing of connection on both client and broker when broker is shut down.
> Found one Java-level deadlock:
> =============================
> "Thread-0":
> waiting to lock monitor 0x0000000059d53cf8 (object 0x00000000bbea0000, a java.lang.Object),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> "MinaNetworkTransport(Acceptor)-12":
> waiting for ownable synchronizer 0x00000000bbed8b10, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
> which is held by "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c"
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> waiting to lock monitor 0x0000000059671c58 (object 0x00000000bbf11540, a [Lorg.apache.qpid.transport.Method;),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> Java stack information for the threads listed above:
> ===================================================
> "Thread-0":
> at org.apache.qpid.transport.Connection.close(Connection.java:586)
> - waiting to lock <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.server.transport.ServerConnection.close(ServerConnection.java:269)
> at org.apache.qpid.server.connection.ConnectionRegistry.closeConnection(ConnectionRegistry.java:58)
> at org.apache.qpid.server.connection.ConnectionRegistry.close(ConnectionRegistry.java:50)
> at org.apache.qpid.server.virtualhost.VirtualHostImpl.close(VirtualHostImpl.java:574)
> at org.apache.qpid.server.virtualhost.VirtualHostRegistry.close(VirtualHostRegistry.java:105)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:443)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:470)
> at org.apache.qpid.server.registry.ConfigurationFileApplicationRegistry.close(ConfigurationFileApplicationRegistry.java:53)
> at org.apache.qpid.server.registry.ApplicationRegistry.remove(ApplicationRegistry.java:203)
> at org.apache.qpid.server.registry.ApplicationRegistry$ShutdownService.run(ApplicationRegistry.java:126)
> at java.lang.Thread.run(Thread.java:662)
> "MinaNetworkTransport(Acceptor)-12":
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000bbed8b10> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
> at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
> at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
> at org.apache.qpid.server.subscription.Subscription_0_10.getSendLock(Subscription_0_10.java:663)
> at org.apache.qpid.server.transport.ServerSession.unregister(ServerSession.java:409)
> at org.apache.qpid.server.transport.ServerSessionDelegate.closed(ServerSessionDelegate.java:1250)
> at org.apache.qpid.transport.Session.closed(Session.java:1041)
> - locked <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.transport.Connection.closed(Connection.java:551)
> - locked <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.transport.network.Assembler.closed(Assembler.java:110)
> at org.apache.qpid.transport.network.InputHandler.closed(InputHandler.java:202)
> at org.apache.qpid.server.protocol.ProtocolEngine_0_10.closed(ProtocolEngine_0_10.java:176)
> at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.closed(MultiVersionProtocolEngine.java:86)
> at org.apache.qpid.transport.network.mina.MinaNetworkHandler.sessionClosed(MinaNetworkHandler.java:136)
> at org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.sessionClosed(AbstractIoFilterChain.java:550)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextSessionClosed(AbstractIoFilterChain.java:269)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$800(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.sessionClosed(AbstractIoFilterChain.java:633)
> at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:230)
> at org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:264)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:51)
> at java.lang.Thread.run(Thread.java:662)
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> at org.apache.qpid.transport.Session.invoke(Session.java:586)
> - waiting to lock <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.server.transport.ServerSession.sendMessage(ServerSession.java:203)
> at org.apache.qpid.server.subscription.Subscription_0_10.send(Subscription_0_10.java:602)
> at org.apache.qpid.server.queue.SimpleAMQQueue.deliverMessage(SimpleAMQQueue.java:747)
> at org.apache.qpid.server.queue.SimpleAMQQueue.attemptDelivery(SimpleAMQQueue.java:1666)
> at org.apache.qpid.server.queue.SimpleAMQQueue.flushSubscription(SimpleAMQQueue.java:1605)
> at org.apache.qpid.server.queue.SubFlushRunner.run(SubFlushRunner.java:58)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Found 1 deadlock.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
[jira] [Updated] (QPID-3446) Deadlock is observed on simultaneous
closing of connection on both Java client and broker when java broker is
shut down
Posted by "Alex Rudyy (Updated) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/QPID-3446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Alex Rudyy updated QPID-3446:
-----------------------------
Status: Ready To Review (was: In Progress)
> Deadlock is observed on simultaneous closing of connection on both Java client and broker when java broker is shut down
> ------------------------------------------------------------------------------------------------------------------------
>
> Key: QPID-3446
> URL: https://issues.apache.org/jira/browse/QPID-3446
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker, Java Client
> Affects Versions: 0.10, 0.11, 0.12
> Reporter: Alex Rudyy
> Assignee: Alex Rudyy
> Attachments: 0001-QPID-3446-Unregister-existing-subscription-on-closin.patch, deadlock.txt
>
>
> Deadlock is observed on simultaneous closing of connection on both client and broker when broker is shut down.
> Found one Java-level deadlock:
> =============================
> "Thread-0":
> waiting to lock monitor 0x0000000059d53cf8 (object 0x00000000bbea0000, a java.lang.Object),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> "MinaNetworkTransport(Acceptor)-12":
> waiting for ownable synchronizer 0x00000000bbed8b10, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
> which is held by "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c"
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> waiting to lock monitor 0x0000000059671c58 (object 0x00000000bbf11540, a [Lorg.apache.qpid.transport.Method;),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> Java stack information for the threads listed above:
> ===================================================
> "Thread-0":
> at org.apache.qpid.transport.Connection.close(Connection.java:586)
> - waiting to lock <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.server.transport.ServerConnection.close(ServerConnection.java:269)
> at org.apache.qpid.server.connection.ConnectionRegistry.closeConnection(ConnectionRegistry.java:58)
> at org.apache.qpid.server.connection.ConnectionRegistry.close(ConnectionRegistry.java:50)
> at org.apache.qpid.server.virtualhost.VirtualHostImpl.close(VirtualHostImpl.java:574)
> at org.apache.qpid.server.virtualhost.VirtualHostRegistry.close(VirtualHostRegistry.java:105)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:443)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:470)
> at org.apache.qpid.server.registry.ConfigurationFileApplicationRegistry.close(ConfigurationFileApplicationRegistry.java:53)
> at org.apache.qpid.server.registry.ApplicationRegistry.remove(ApplicationRegistry.java:203)
> at org.apache.qpid.server.registry.ApplicationRegistry$ShutdownService.run(ApplicationRegistry.java:126)
> at java.lang.Thread.run(Thread.java:662)
> "MinaNetworkTransport(Acceptor)-12":
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000bbed8b10> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
> at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
> at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
> at org.apache.qpid.server.subscription.Subscription_0_10.getSendLock(Subscription_0_10.java:663)
> at org.apache.qpid.server.transport.ServerSession.unregister(ServerSession.java:409)
> at org.apache.qpid.server.transport.ServerSessionDelegate.closed(ServerSessionDelegate.java:1250)
> at org.apache.qpid.transport.Session.closed(Session.java:1041)
> - locked <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.transport.Connection.closed(Connection.java:551)
> - locked <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.transport.network.Assembler.closed(Assembler.java:110)
> at org.apache.qpid.transport.network.InputHandler.closed(InputHandler.java:202)
> at org.apache.qpid.server.protocol.ProtocolEngine_0_10.closed(ProtocolEngine_0_10.java:176)
> at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.closed(MultiVersionProtocolEngine.java:86)
> at org.apache.qpid.transport.network.mina.MinaNetworkHandler.sessionClosed(MinaNetworkHandler.java:136)
> at org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.sessionClosed(AbstractIoFilterChain.java:550)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextSessionClosed(AbstractIoFilterChain.java:269)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$800(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.sessionClosed(AbstractIoFilterChain.java:633)
> at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:230)
> at org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:264)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:51)
> at java.lang.Thread.run(Thread.java:662)
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> at org.apache.qpid.transport.Session.invoke(Session.java:586)
> - waiting to lock <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.server.transport.ServerSession.sendMessage(ServerSession.java:203)
> at org.apache.qpid.server.subscription.Subscription_0_10.send(Subscription_0_10.java:602)
> at org.apache.qpid.server.queue.SimpleAMQQueue.deliverMessage(SimpleAMQQueue.java:747)
> at org.apache.qpid.server.queue.SimpleAMQQueue.attemptDelivery(SimpleAMQQueue.java:1666)
> at org.apache.qpid.server.queue.SimpleAMQQueue.flushSubscription(SimpleAMQQueue.java:1605)
> at org.apache.qpid.server.queue.SubFlushRunner.run(SubFlushRunner.java:58)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Found 1 deadlock.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
[jira] [Updated] (QPID-3446) Deadlock observed during broker
shutdown with simultaneous closing of connection and attempted message
delivery
Posted by "Robbie Gemmell (Updated) (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/QPID-3446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Robbie Gemmell updated QPID-3446:
---------------------------------
Summary: Deadlock observed during broker shutdown with simultaneous closing of connection and attempted message delivery (was: Deadlock is observed on simultaneous closing of connection on both Java client and broker when java broker is shut down)
> Deadlock observed during broker shutdown with simultaneous closing of connection and attempted message delivery
> ---------------------------------------------------------------------------------------------------------------
>
> Key: QPID-3446
> URL: https://issues.apache.org/jira/browse/QPID-3446
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker, Java Client
> Affects Versions: 0.10, 0.11, 0.12
> Reporter: Alex Rudyy
> Assignee: Robbie Gemmell
> Fix For: 0.15
>
> Attachments: 0001-QPID-3446-Unregister-existing-subscription-on-closin.patch, deadlock.txt
>
>
> Deadlock is observed on simultaneous closing of connection on both client and broker when broker is shut down.
> Found one Java-level deadlock:
> =============================
> "Thread-0":
> waiting to lock monitor 0x0000000059d53cf8 (object 0x00000000bbea0000, a java.lang.Object),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> "MinaNetworkTransport(Acceptor)-12":
> waiting for ownable synchronizer 0x00000000bbed8b10, (a java.util.concurrent.locks.ReentrantLock$NonfairSync),
> which is held by "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c"
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> waiting to lock monitor 0x0000000059671c58 (object 0x00000000bbf11540, a [Lorg.apache.qpid.transport.Method;),
> which is held by "MinaNetworkTransport(Acceptor)-12"
> Java stack information for the threads listed above:
> ===================================================
> "Thread-0":
> at org.apache.qpid.transport.Connection.close(Connection.java:586)
> - waiting to lock <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.server.transport.ServerConnection.close(ServerConnection.java:269)
> at org.apache.qpid.server.connection.ConnectionRegistry.closeConnection(ConnectionRegistry.java:58)
> at org.apache.qpid.server.connection.ConnectionRegistry.close(ConnectionRegistry.java:50)
> at org.apache.qpid.server.virtualhost.VirtualHostImpl.close(VirtualHostImpl.java:574)
> at org.apache.qpid.server.virtualhost.VirtualHostRegistry.close(VirtualHostRegistry.java:105)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:443)
> at org.apache.qpid.server.registry.ApplicationRegistry.close(ApplicationRegistry.java:470)
> at org.apache.qpid.server.registry.ConfigurationFileApplicationRegistry.close(ConfigurationFileApplicationRegistry.java:53)
> at org.apache.qpid.server.registry.ApplicationRegistry.remove(ApplicationRegistry.java:203)
> at org.apache.qpid.server.registry.ApplicationRegistry$ShutdownService.run(ApplicationRegistry.java:126)
> at java.lang.Thread.run(Thread.java:662)
> "MinaNetworkTransport(Acceptor)-12":
> at sun.misc.Unsafe.park(Native Method)
> - parking to wait for <0x00000000bbed8b10> (a java.util.concurrent.locks.ReentrantLock$NonfairSync)
> at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireQueued(AbstractQueuedSynchronizer.java:842)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:1178)
> at java.util.concurrent.locks.ReentrantLock$NonfairSync.lock(ReentrantLock.java:186)
> at java.util.concurrent.locks.ReentrantLock.lock(ReentrantLock.java:262)
> at org.apache.qpid.server.subscription.Subscription_0_10.getSendLock(Subscription_0_10.java:663)
> at org.apache.qpid.server.transport.ServerSession.unregister(ServerSession.java:409)
> at org.apache.qpid.server.transport.ServerSessionDelegate.closed(ServerSessionDelegate.java:1250)
> at org.apache.qpid.transport.Session.closed(Session.java:1041)
> - locked <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.transport.Connection.closed(Connection.java:551)
> - locked <0x00000000bbea0000> (a java.lang.Object)
> at org.apache.qpid.transport.network.Assembler.closed(Assembler.java:110)
> at org.apache.qpid.transport.network.InputHandler.closed(InputHandler.java:202)
> at org.apache.qpid.server.protocol.ProtocolEngine_0_10.closed(ProtocolEngine_0_10.java:176)
> at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.closed(MultiVersionProtocolEngine.java:86)
> at org.apache.qpid.transport.network.mina.MinaNetworkHandler.sessionClosed(MinaNetworkHandler.java:136)
> at org.apache.mina.common.support.AbstractIoFilterChain$TailFilter.sessionClosed(AbstractIoFilterChain.java:550)
> at org.apache.mina.common.support.AbstractIoFilterChain.callNextSessionClosed(AbstractIoFilterChain.java:269)
> at org.apache.mina.common.support.AbstractIoFilterChain.access$800(AbstractIoFilterChain.java:53)
> at org.apache.mina.common.support.AbstractIoFilterChain$EntryImpl$1.sessionClosed(AbstractIoFilterChain.java:633)
> at org.apache.mina.filter.executor.ExecutorFilter.processEvent(ExecutorFilter.java:230)
> at org.apache.mina.filter.executor.ExecutorFilter$ProcessEventsRunnable.run(ExecutorFilter.java:264)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:51)
> at java.lang.Thread.run(Thread.java:662)
> "SubFlushRunner-org.apache.qpid.server.subscription.Subscription_0_10@6ce7ce4c":
> at org.apache.qpid.transport.Session.invoke(Session.java:586)
> - waiting to lock <0x00000000bbf11540> (a [Lorg.apache.qpid.transport.Method;)
> at org.apache.qpid.server.transport.ServerSession.sendMessage(ServerSession.java:203)
> at org.apache.qpid.server.subscription.Subscription_0_10.send(Subscription_0_10.java:602)
> at org.apache.qpid.server.queue.SimpleAMQQueue.deliverMessage(SimpleAMQQueue.java:747)
> at org.apache.qpid.server.queue.SimpleAMQQueue.attemptDelivery(SimpleAMQQueue.java:1666)
> at org.apache.qpid.server.queue.SimpleAMQQueue.flushSubscription(SimpleAMQQueue.java:1605)
> at org.apache.qpid.server.queue.SubFlushRunner.run(SubFlushRunner.java:58)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> Found 1 deadlock.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org