From 039c7563cfd84d6c20fac8369fd33cf8786d30b2 Mon Sep 17 00:00:00 2001 From: norman Date: Mon, 27 Aug 2012 11:21:05 +0200 Subject: [PATCH] Cleanup --- .../channel/socket/nio/NioClientSocketPipelineSink.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/jboss/netty/channel/socket/nio/NioClientSocketPipelineSink.java b/src/main/java/org/jboss/netty/channel/socket/nio/NioClientSocketPipelineSink.java index e11bbd0991..178d5c16f2 100644 --- a/src/main/java/org/jboss/netty/channel/socket/nio/NioClientSocketPipelineSink.java +++ b/src/main/java/org/jboss/netty/channel/socket/nio/NioClientSocketPipelineSink.java @@ -469,12 +469,11 @@ class NioClientSocketPipelineSink extends AbstractNioChannelSink { ch.register(newSelector, ops, att); } catch (ClosedChannelException e) { // close the Channel if we can't register it - AbstractNioChannel channel = (AbstractNioChannel) att; - channel.worker.close(channel, succeededFuture(channel)); + close(key); } key.cancel(); - } + try { // time to close the old selector as everything else is registered to the new one selector.close();