svn commit: r680673 - /incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java

[rhs]

Author: rhs
Date: Tue Jul 29 04:23:12 2008
New Revision: 680673

URL: http://svn.apache.org/viewvc?rev=680673&view=rev
Log:
QPID-1201: fixed some brainos in IoSender

Modified:
    
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java

Modified: 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java
URL: 
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java?rev=680673&r1=680672&r2=680673&view=diff
==============================================================================
--- 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java
 (original)
+++ 
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java
 Tue Jul 29 04:23:12 2008
@@ -159,7 +159,7 @@
 
     public void close()
     {
-        if (closed.getAndSet(true))
+        if (!closed.getAndSet(true))
         {
             synchronized (notEmpty)
             {
@@ -244,9 +244,8 @@
             }
             catch (IOException e)
             {
-                log.error(e, "error in read thread");
+                log.error(e, "error in write thread");
                 exception = e;
-                closed.set(true);
                 break;
             }
             tail.getAndAdd(length);