You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Avadhut Lele (JIRA)" <ji...@apache.org> on 2017/10/04 06:23:00 UTC
[jira] [Commented] (AMQ-6793) Could not accept connection during
shutdown : {} java.lang.InterruptedException
[ https://issues.apache.org/jira/browse/AMQ-6793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16190873#comment-16190873 ]
Avadhut Lele commented on AMQ-6793:
-----------------------------------
I would be interested to test any of the scenario once where we observe InterruptedException. Could you provide the reproducer if possible or reproducer steps?
> Could not accept connection during shutdown : {} java.lang.InterruptedException
> --------------------------------------------------------------------------------
>
> Key: AMQ-6793
> URL: https://issues.apache.org/jira/browse/AMQ-6793
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.15.0
> Environment: Linux 4.10.0-32-generic #36-Ubuntu SMP Tue Aug 8 12:10:06 UTC 2017 x86_64 x86_64 x86_64 GNU/Linux
> java version "1.8.0_131"
> Java(TM) SE Runtime Environment (build 1.8.0_131-b11)
> Java HotSpot(TM) 64-Bit Server VM (build 25.131-b11, mixed mode)
> Reporter: Donald Kwakkel
>
> Sometimes I get following exception when shutting down:
> {code}
> 2017-08-14 21:47:57,470 [ActiveMQ Transport Server Thread Handler: tcp://localhost:28007] INFO org.apache.activemq.broker.TransportConnector - Could not accept connection during shutdown : {}
> java.lang.InterruptedException
> at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
> at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2088)
> at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
> at org.apache.activemq.transport.tcp.TcpTransportServer$1.run(TcpTransportServer.java:479)
> at java.lang.Thread.run(Thread.java:748)
> {code}
> When I look at line 495 of http://activemq.apache.org/maven/apidocs/src-html/org/apache/activemq/transport/tcp/TcpTransportServer.html:
> {code}
> if (!isStopped() || !isStopping()) {
> {code}
> I wonder if it must not be an '&&' iso '||' like line 478:
> {code}
> while (!isStopped() && !isStopping()) {
> {code}
> Or maybe the doStop must join the socketHandlerThread after this.socketHandlerThread.interrupt(); Because now doStop just continues, and ServiceSupport.stop method could call this.stopping.set(false); while the interrupt is not yet processed in some cases by the socketHandlerThread.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)