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 | 96cf9c928819c08090856b5b33d8173f884ddb68 (patch) | |
| tree | 9771bff0c5eced7ab817d32cd30ed5b60c84febb /java/common/src | |
| parent | 188748bd3e3fba0e16d3d3d4bc7b1de72e285d09 (diff) | |
| download | qpid-python-96cf9c928819c08090856b5b33d8173f884ddb68.tar.gz | |
QPID-1201: fixed some brainos in IoSender
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@680673 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java b/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java index c358d3bd3b..0c65b583ff 100644 --- a/java/common/src/main/java/org/apache/qpidity/transport/network/io/IoSender.java +++ b/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); |