Repository: kafka Updated Branches: refs/heads/0.10.0 9ca393407 -> 5bfba1dec
MINOR: Ensure that selection key is cancelled on close Author: Rajini Sivaram <[email protected]> Reviewers: Ismael Juma <[email protected]> Closes #1368 from rajinisivaram/minor-channelclose (cherry picked from commit e20eba958d8de29cb4e3b6feea37ac3a1e1ab4f9) Signed-off-by: Ismael Juma <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5bfba1de Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5bfba1de Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5bfba1de Branch: refs/heads/0.10.0 Commit: 5bfba1decaf3c11bbd7563c8993d7f68739bedb5 Parents: 9ca3934 Author: Rajini Sivaram <[email protected]> Authored: Wed May 11 13:05:58 2016 +0100 Committer: Ismael Juma <[email protected]> Committed: Wed May 11 14:04:24 2016 +0100 ---------------------------------------------------------------------- .../kafka/common/network/PlaintextTransportLayer.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/5bfba1de/clients/src/main/java/org/apache/kafka/common/network/PlaintextTransportLayer.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/common/network/PlaintextTransportLayer.java b/clients/src/main/java/org/apache/kafka/common/network/PlaintextTransportLayer.java index 3db4345..1135359 100644 --- a/clients/src/main/java/org/apache/kafka/common/network/PlaintextTransportLayer.java +++ b/clients/src/main/java/org/apache/kafka/common/network/PlaintextTransportLayer.java @@ -30,11 +30,8 @@ import java.nio.channels.SelectionKey; import java.security.Principal; import org.apache.kafka.common.security.auth.KafkaPrincipal; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; public class PlaintextTransportLayer implements TransportLayer { - private static final Logger log = LoggerFactory.getLogger(PlaintextTransportLayer.class); private final SelectionKey key; private final SocketChannel socketChannel; private final Principal principal = KafkaPrincipal.ANONYMOUS; @@ -84,10 +81,13 @@ public class PlaintextTransportLayer implements TransportLayer { */ @Override public void close() throws IOException { - socketChannel.socket().close(); - socketChannel.close(); - key.attach(null); - key.cancel(); + try { + socketChannel.socket().close(); + socketChannel.close(); + } finally { + key.attach(null); + key.cancel(); + } } /**
