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-6502) Close connection in response to a CSRE condition rather than sending a execution exception
Date Sat, 18 Apr 2015 22:34:59 GMT

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

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

Commit 1674585 from [~k-wall] in branch 'java/trunk'
[ https://svn.apache.org/r1674585 ]

QPID-6502: [Java Broker] 0-10 close connection in response to CSRE

> Close connection in response to a CSRE condition rather than sending a execution exception
> ------------------------------------------------------------------------------------------
>
>                 Key: QPID-6502
>                 URL: https://issues.apache.org/jira/browse/QPID-6502
>             Project: Qpid
>          Issue Type: Bug
>          Components: Java Broker
>            Reporter: Keith Wall
>             Fix For: 6.0 [Java]
>
>
> The Java Broker internally throws a ConnectionScopeRuntimeException in response to abnormal
conditions encountered whilst processing commands from the wire.  The intention is that this
exception causes the Broker to close the messaging connection.
> This is currently not the case within the 0-10 implementation.  A CSRE originating from
beneath ServerSessionDelegate#command currently causes a execution exception to be sent down
the wire, but the connection remains open.
> This problem is currently causing MultiNodeTest#testTransferMasterWhilstMessagesInFlight
to fail consistently on the 0-10 BDB profile.   Here the execution exception causes the client
to close the JMS Session.  The JE thread, in response to lost of mastership,  then causes
the  connection to be closed, and the client then fails-over.  However on reconnection to
the new master the JMS connection no longer has a Session so the test fails.
> Broker side:
> {noformat}
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) - org.apache.qpid.server.util.ConnectionScopedRuntimeException:
Environment 'nodetestTransferMasterWhilstMessagesInFlight10001' cannot finish JE operation
because master is unknown
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.store.berkeleydb.replication.ReplicatedEnvironmentFacade.handleDatabaseException(ReplicatedEnvironmentFacade.java:409)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.store.berkeleydb.replication.ReplicatedEnvironmentFacade.commit(ReplicatedEnvironmentFacade.java:288)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore.commitTranImpl(AbstractBDBMessageStore.java:788)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore.access$1200(AbstractBDBMessageStore.java:74)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.store.berkeleydb.AbstractBDBMessageStore$BDBTransaction.commitTran(AbstractBDBMessageStore.java:1367)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.txn.LocalTransaction.commit(LocalTransaction.java:348)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.txn.LocalTransaction.commit(LocalTransaction.java:338)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.v0_10.ServerSession.commit(ServerSession.java:672)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.v0_10.ServerSessionDelegate.txCommit(ServerSessionDelegate.java:552)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.v0_10.ServerSessionDelegate.txCommit(ServerSessionDelegate.java:86)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.TxCommit.dispatch(TxCommit.java:82)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.SessionDelegate.command(SessionDelegate.java:55)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.v0_10.ServerSessionDelegate.command(ServerSessionDelegate.java:103)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.v0_10.ServerSessionDelegate.command(ServerSessionDelegate.java:86)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.Method.delegate(Method.java:159)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.Session.received(Session.java:596)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.Connection.dispatch(Connection.java:463)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegate.java:64)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegate.java:40)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.MethodDelegate.txCommit(MethodDelegate.java:152)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.TxCommit.dispatch(TxCommit.java:82)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.ConnectionDelegate.command(ConnectionDelegate.java:54)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.ConnectionDelegate.command(ConnectionDelegate.java:40)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.Method.delegate(Method.java:159)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.Connection.received(Connection.java:416)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.v0_10.ServerConnection.access$001(ServerConnection.java:70)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.v0_10.ServerConnection$2.run(ServerConnection.java:347)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.v0_10.ServerConnection$2.run(ServerConnection.java:343)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at java.security.AccessController.doPrivileged(Native
Method)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at javax.security.auth.Subject.doAs(Subject.java:360)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.v0_10.ServerConnection.received(ServerConnection.java:342)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.network.Assembler.emit(Assembler.java:98)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.network.Assembler.assemble(Assembler.java:199)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.network.Assembler.frame(Assembler.java:132)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.network.Frame.delegate(Frame.java:128)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.network.Assembler.received(Assembler.java:103)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.v0_10.ServerAssembler.received(ServerAssembler.java:48)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.network.InputHandler.next(InputHandler.java:200)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.transport.network.InputHandler.received(InputHandler.java:115)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.v0_10.ProtocolEngine_0_10.received(ProtocolEngine_0_10.java:218)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.protocol.MultiVersionProtocolEngine.received(MultiVersionProtocolEngine.java:159)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.transport.NonBlockingConnection.doRead(NonBlockingConnection.java:375)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.transport.NonBlockingConnection.doWork(NonBlockingConnection.java:276)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.transport.NetworkConnectionScheduler.processConnection(NetworkConnectionScheduler.java:94)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.transport.NetworkConnectionScheduler.access$000(NetworkConnectionScheduler.java:34)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.transport.NetworkConnectionScheduler$2.run(NetworkConnectionScheduler.java:75)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at java.lang.Thread.run(Thread.java:745)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) - Caused by: com.sleepycat.je.rep.UnknownMasterException:
(JE 5.0.104) Problem closing transaction -68. The current state is:UNKNOWN. The node transitioned
to this state at:Fri Apr 17 22:49:01 BST 2015
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at com.sleepycat.je.rep.impl.RepImpl.checkIfMaster(RepImpl.java:872)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at com.sleepycat.je.rep.txn.MasterTxn.checkIfFrozen(MasterTxn.java:631)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at com.sleepycat.je.txn.Txn.commit(Txn.java:834)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at com.sleepycat.je.Transaction.doCommit(Transaction.java:609)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at com.sleepycat.je.Transaction.commit(Transaction.java:410)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    at org.apache.qpid.server.store.berkeleydb.replication.ReplicatedEnvironmentFacade.commit(ReplicatedEnvironmentFacade.java:284)
> 2015-04-17 22:49:01,624 INFO  [STD] (BROKER-10000) -    ... 47 more
> {noformat}
> Client side:
> {noformat}
>        at org.apache.qpid.client.AMQSession_0_10.setCurrentException(AMQSession_0_10.java:1082)
>         at org.apache.qpid.client.AMQSession_0_10.exception(AMQSession_0_10.java:936)
>         at org.apache.qpid.transport.SessionDelegate.executionException(SessionDelegate.java:182)
>         at org.apache.qpid.transport.SessionDelegate.executionException(SessionDelegate.java:32)
>         at org.apache.qpid.transport.ExecutionException.dispatch(ExecutionException.java:103)
>         at org.apache.qpid.transport.SessionDelegate.command(SessionDelegate.java:55)
>         at org.apache.qpid.transport.SessionDelegate.command(SessionDelegate.java:50)
>         at org.apache.qpid.transport.SessionDelegate.command(SessionDelegate.java:32)
>         at org.apache.qpid.transport.Method.delegate(Method.java:159)
>         at org.apache.qpid.transport.Session.received(Session.java:596)
>         at org.apache.qpid.transport.Connection.dispatch(Connection.java:463)
>         at org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegate.java:64)
>         at org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegate.java:40)
>         at org.apache.qpid.transport.MethodDelegate.executionException(MethodDelegate.java:110)
>         at org.apache.qpid.transport.ExecutionException.dispatch(ExecutionException.java:103)
>         at org.apache.qpid.transport.ConnectionDelegate.command(ConnectionDelegate.java:54)
>         at org.apache.qpid.transport.ConnectionDelegate.command(ConnectionDelegate.java:40)
>         at org.apache.qpid.transport.Method.delegate(Method.java:159)
>         at org.apache.qpid.transport.Connection.received(Connection.java:416)
>         at org.apache.qpid.transport.network.Assembler.emit(Assembler.java:98)
>         at org.apache.qpid.transport.network.Assembler.assemble(Assembler.java:199)
>         at org.apache.qpid.transport.network.Assembler.frame(Assembler.java:132)
>         at org.apache.qpid.transport.network.Frame.delegate(Frame.java:128)
>         at org.apache.qpid.transport.network.Assembler.received(Assembler.java:103)
>         at org.apache.qpid.transport.network.InputHandler.next(InputHandler.java:200)
>         at org.apache.qpid.transport.network.InputHandler.received(InputHandler.java:115)
>         at org.apache.qpid.transport.network.io.IoReceiver.run(
> {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