diff options
| author | Keith Wall <kwall@apache.org> | 2015-02-13 14:44:27 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2015-02-13 14:44:27 +0000 |
| commit | 1800527b42b6d8453e7bfc9e381b09dd2a2f94d6 (patch) | |
| tree | fe5694bf633b1956376c2f1535bbb403317c04bb /qpid/java | |
| parent | 44def49f41ce041b740ecbfc11147c9def35b9e7 (diff) | |
| download | qpid-python-1800527b42b6d8453e7bfc9e381b09dd2a2f94d6.tar.gz | |
eliminate double wakeup on close
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1659577 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java | 2 |
1 files changed, 0 insertions, 2 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 0b7d0b303e..12ce46eedb 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 @@ -309,7 +309,6 @@ public class NonBlockingConnection implements NetworkConnection, ByteBufferSende if(_closed.compareAndSet(false,true)) { _protocolEngine.notifyWork(); - getSelector().wakeup(); } } } @@ -628,7 +627,6 @@ public class NonBlockingConnection implements NetworkConnection, ByteBufferSende { throw new SenderClosedException("I/O for thread " + _remoteSocketAddress + " is already closed"); } - // append to list and do selector wakeup _buffers.add(msg); _protocolEngine.notifyWork(); } |
