summaryrefslogtreecommitdiff
path: root/qpid/java
diff options
context:
space:
mode:
authorKeith Wall <kwall@apache.org>2015-02-13 14:44:27 +0000
committerKeith Wall <kwall@apache.org>2015-02-13 14:44:27 +0000
commit1800527b42b6d8453e7bfc9e381b09dd2a2f94d6 (patch)
treefe5694bf633b1956376c2f1535bbb403317c04bb /qpid/java
parent44def49f41ce041b740ecbfc11147c9def35b9e7 (diff)
downloadqpid-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.java2
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();
}