From 1800527b42b6d8453e7bfc9e381b09dd2a2f94d6 Mon Sep 17 00:00:00 2001
From: Keith Wall <kwall@apache.org>
Date: Fri, 13 Feb 2015 14:44:27 +0000
Subject: 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
---
 .../java/org/apache/qpid/server/transport/NonBlockingConnection.java    | 2 --
 1 file changed, 2 deletions(-)

(limited to 'qpid/java')

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();
     }
-- 
cgit v1.2.1