diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2008-07-29 11:23:12 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2008-07-29 11:23:12 +0000 |
| commit | 7bcbdf3bb60ef8932bf90935c2d53349fdf11d14 (patch) | |
| tree | a7c2f157397155e03f3fc4532917bdf020b2a2ec /qpid/java/common/src | |
| parent | 404c17dcd4357950a5707595df5446891786eaf8 (diff) | |
| download | qpid-python-7bcbdf3bb60ef8932bf90935c2d53349fdf11d14.tar.gz | |
QPID-1201: fixed some brainos in IoSender
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@680673 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common/src')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java index c358d3bd3b..0c65b583ff 100644 --- a/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java +++ b/qpid/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java @@ -159,7 +159,7 @@ final class IoSender extends Thread implements Sender<ByteBuffer> public void close() { - if (closed.getAndSet(true)) + if (!closed.getAndSet(true)) { synchronized (notEmpty) { @@ -244,9 +244,8 @@ final class IoSender extends Thread implements Sender<ByteBuffer> } 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); |