diff options
| author | Keith Wall <kwall@apache.org> | 2015-04-04 10:32:40 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2015-04-04 10:32:40 +0000 |
| commit | 6d26c23ecbf3acf878e8217b10e5c9c63506118e (patch) | |
| tree | f50d3f1c6e036cbd099c1b51d4ceeb78b5dcc1f1 | |
| parent | 98d5e956d080eb15f0ec660ed58458ccf35fb2a5 (diff) | |
| download | qpid-python-6d26c23ecbf3acf878e8217b10e5c9c63506118e.tar.gz | |
QPID-6429: [Java Broker] Add more logging to investigate the failure to close AMQPS Port on CI Instance (sporadic SSLTest failure)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1671262 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java index 551d1c5bae..b0dc85eb0b 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java @@ -405,6 +405,12 @@ public class NonBlockingConnection implements NetworkConnection, ByteBufferSende ByteBuffer.allocate(_sslEngine.getSession().getApplicationBufferSize() + 50); _status = _sslEngine.unwrap(_netInputBuffer, appInputBuffer); + if (_status.getStatus() == SSLEngineResult.Status.CLOSED) + { + // KW If SSLEngine changes state to CLOSED, what will ever set _closed to true? + LOGGER.debug("SSLEngine closed"); + } + tasksRun = runSSLEngineTasks(_status); appInputBuffer.flip(); |