qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kw...@apache.org
Subject svn commit: r1659577 - /qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
Date Fri, 13 Feb 2015 14:44:28 GMT
Author: kwall
Date: Fri Feb 13 14:44:27 2015
New Revision: 1659577

URL: http://svn.apache.org/r1659577
Log:
eliminate double wakeup on close

Modified:
    qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java

Modified: qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
URL: http://svn.apache.org/viewvc/qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java?rev=1659577&r1=1659576&r2=1659577&view=diff
==============================================================================
--- qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
(original)
+++ qpid/branches/QPID-6262-JavaBrokerNIO/qpid/java/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
Fri Feb 13 14:44:27 2015
@@ -309,7 +309,6 @@ public class NonBlockingConnection imple
                 if(_closed.compareAndSet(false,true))
                 {
                     _protocolEngine.notifyWork();
-                    getSelector().wakeup();
                 }
             }
         }
@@ -628,7 +627,6 @@ public class NonBlockingConnection imple
         {
             throw new SenderClosedException("I/O for thread " + _remoteSocketAddress + "
is already closed");
         }
-        // append to list and do selector wakeup
         _buffers.add(msg);
         _protocolEngine.notifyWork();
     }



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message