qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r..@apache.org
Subject svn commit: r680673 - /incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java
Date Tue, 29 Jul 2008 11:23:12 GMT
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);



Mime
View raw message