From 333293babdc64fc23465e906a2ceb9185654ccd7 Mon Sep 17 00:00:00 2001 From: Shay Banon Date: Thu, 23 Aug 2012 23:35:48 +0200 Subject: [PATCH] ignore cancelled key exception as well --- .../org/elasticsearch/transport/netty/NettyTransport.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java b/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java index de50be2a7e7f2..7f5f185a2ef9a 100644 --- a/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java +++ b/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java @@ -57,6 +57,7 @@ import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.SocketAddress; +import java.nio.channels.CancelledKeyException; import java.util.*; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.CountDownLatch; @@ -471,12 +472,12 @@ void exceptionCaught(ChannelHandlerContext ctx, ExceptionEvent e) throws Excepti disconnectFromNode(entry.getKey()); } } - } else if (isConnectException(e.getCause())) { + } else if (isConnectException(e.getCause()) || e.getCause() instanceof CancelledKeyException) { if (logger.isTraceEnabled()) { - logger.trace("(Ignoring) Exception caught on netty layer [" + ctx.getChannel() + "]", e.getCause()); + logger.trace("(Ignoring) exception caught on netty layer [" + ctx.getChannel() + "]", e.getCause()); } } else { - logger.warn("Exception caught on netty layer [" + ctx.getChannel() + "]", e.getCause()); + logger.warn("exception caught on netty layer [" + ctx.getChannel() + "]", e.getCause()); } }