From 7bcbdf3bb60ef8932bf90935c2d53349fdf11d14 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Tue, 29 Jul 2008 11:23:12 +0000 Subject: 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 --- .../main/java/org/apache/qpidity/transport/network/io/IoSender.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) (limited to 'qpid/java/common') 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 public void close() { - if (closed.getAndSet(true)) + if (!closed.getAndSet(true)) { synchronized (notEmpty) { @@ -244,9 +244,8 @@ final class IoSender extends Thread implements Sender } 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); -- cgit v1.2.1