[
https://issues.apache.org/jira/browse/QPID-4197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13430948#comment-13430948
]
Keith Wall edited comment on QPID-4197 at 8/8/12 8:45 AM:
----------------------------------------------------------
Appears to be the same underlying cause as QPID-4162.
The session closure from Slow Consumer Disconnect is racing with the closure of
the connection from tearDown.
In this case, you can see that the the server has abruptly closed the socket
{code}
IoReceiver - /127.0.0.1:40511 2012-08-07 20:16:13,828 DEBUG
[apache.qpid.transport.Connection] connection closed: conn:8c6de0
{code}
shortly after the client sends the SessionTimeout. I suspect that the server
will be throwing a ProtocolViolationException on receipt of the SessionTimeout
and closing the socket as a result.
was (Author: k-wall):
Appears to be the same underlying cause as QPID-4162.
The session closure from Slow Consumer Disconnect is racing with the closure of
the connection from tearDown.
In this case, you can see that the the server has abruptly closed the socket
IoReceiver - /127.0.0.1:40511 2012-08-07 20:16:13,828 DEBUG
[apache.qpid.transport.Connection] connection closed: conn:8c6de0
shortly after the client sends the SessionTimeout. I suspect that the server
will be throwing a ProtocolViolationException on receipt of the SessionTimeout
and closing the socket as a result.
> GlobalQueuesTest.testTopicDurableConsumerMessageCount fails occasionally on
> Apache CI
> -------------------------------------------------------------------------------------
>
> Key: QPID-4197
> URL: https://issues.apache.org/jira/browse/QPID-4197
> Project: Qpid
> Issue Type: Bug
> Components: Java Broker
> Affects Versions: 0.19
> Reporter: Keith Wall
> Assignee: Keith Wall
> Attachments:
> TEST-org.apache.qpid.systest.GlobalQueuesTest.testTopicDurableConsumerMessageCount.err,
>
> TEST-org.apache.qpid.systest.GlobalQueuesTest.testTopicDurableConsumerMessageCount.out
>
>
> As seen in the following build:
> https://builds.apache.org/view/M-R/view/Qpid/job/Qpid-Java-Java-MMS-TestMatrix/jdk=JDK%201.6%20%28latest%29,label=Ubuntu,profile=java-mms.0-10/516/
> org.apache.qpid.systest.GlobalQueuesTest.testTopicDurableConsumerMessageCount
> Failing for the past 1 build (Since Failed#516 )
> Took 1 sec.
> Error Message
> Error closing connection: org.apache.qpid.AMQException:
> java.net.SocketException: Broken pipe
> Stacktrace
> javax.jms.JMSException: Error closing connection:
> org.apache.qpid.AMQException: java.net.SocketException: Broken pipe
> at org.apache.qpid.client.AMQConnection.doClose(AMQConnection.java:897)
> at org.apache.qpid.client.AMQConnection.close(AMQConnection.java:832)
> at org.apache.qpid.client.AMQConnection.close(AMQConnection.java:823)
> at org.apache.qpid.client.AMQConnection.close(AMQConnection.java:818)
> at
> org.apache.qpid.test.utils.QpidBrokerTestCase.tearDown(QpidBrokerTestCase.java:1183)
> at
> org.apache.qpid.test.utils.QpidBrokerTestCase.runBare(QpidBrokerTestCase.java:244)
> at org.apache.qpid.test.utils.QpidTestCase.run(QpidTestCase.java:137)
> Caused by: org.apache.qpid.AMQException: java.net.SocketException: Broken pipe
> at
> org.apache.qpid.client.AMQConnectionDelegate_0_10.closeConnection(AMQConnectionDelegate_0_10.java:274)
> at org.apache.qpid.client.AMQConnection.doClose(AMQConnection.java:881)
> Caused by: org.apache.qpid.transport.ConnectionException:
> java.net.SocketException: Broken pipe
> at org.apache.qpid.transport.Connection.close(Connection.java:627)
> at org.apache.qpid.transport.Connection.close(Connection.java:598)
> at org.apache.qpid.transport.Connection.close(Connection.java:573)
> at
> org.apache.qpid.client.AMQConnectionDelegate_0_10.closeConnection(AMQConnectionDelegate_0_10.java:270)
> Caused by: org.apache.qpid.transport.ConnectionException:
> java.net.SocketException: Broken pipe
> at org.apache.qpid.transport.Connection.exception(Connection.java:521)
> at
> org.apache.qpid.transport.network.Assembler.exception(Assembler.java:107)
> at
> org.apache.qpid.transport.network.InputHandler.exception(InputHandler.java:199)
> at
> org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:169)
> at java.lang.Thread.run(Thread.java:662)
> Caused by: org.apache.qpid.transport.SenderException:
> java.net.SocketException: Broken pipe
> at
> org.apache.qpid.transport.network.io.IoSender.close(IoSender.java:234)
> at
> org.apache.qpid.transport.network.io.IoSender.close(IoSender.java:194)
> at
> org.apache.qpid.transport.network.Disassembler.close(Disassembler.java:88)
> at
> org.apache.qpid.transport.ConnectionDelegate.connectionCloseOk(ConnectionDelegate.java:87)
> at
> org.apache.qpid.transport.ConnectionDelegate.connectionCloseOk(ConnectionDelegate.java:40)
> at
> org.apache.qpid.transport.ConnectionCloseOk.dispatch(ConnectionCloseOk.java:82)
> at
> org.apache.qpid.transport.ConnectionDelegate.control(ConnectionDelegate.java:49)
> at
> org.apache.qpid.transport.ConnectionDelegate.control(ConnectionDelegate.java:40)
> at org.apache.qpid.transport.Method.delegate(Method.java:163)
> at org.apache.qpid.transport.Connection.received(Connection.java:376)
> at org.apache.qpid.transport.Connection.received(Connection.java:67)
> at org.apache.qpid.transport.network.Assembler.emit(Assembler.java:97)
> at
> org.apache.qpid.transport.network.Assembler.assemble(Assembler.java:183)
> at org.apache.qpid.transport.network.Assembler.frame(Assembler.java:131)
> at org.apache.qpid.transport.network.Frame.delegate(Frame.java:128)
> at
> org.apache.qpid.transport.network.Assembler.received(Assembler.java:102)
> at
> org.apache.qpid.transport.network.Assembler.received(Assembler.java:44)
> at
> org.apache.qpid.transport.network.InputHandler.next(InputHandler.java:189)
> at
> org.apache.qpid.transport.network.InputHandler.received(InputHandler.java:105)
> at
> org.apache.qpid.transport.network.InputHandler.received(InputHandler.java:44)
> at
> org.apache.qpid.transport.network.io.IoReceiver.run(IoReceiver.java:152)
> Caused by: java.net.SocketException: Broken pipe
> at java.net.SocketOutputStream.socketWrite0(Native Method)
> at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
> at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
> at org.apache.qpid.transport.network.io.IoSender.run(IoSender.java:313)
--
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
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
