From 5398792ffa19829bfdc7e9ac02ebdb8952c84032 Mon Sep 17 00:00:00 2001 From: Norman Maurer Date: Thu, 23 May 2013 17:17:21 +0200 Subject: [PATCH] [#1388] Correctly break the loop on exceptions --- .../io/netty/channel/nio/AbstractNioMessageChannel.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/transport/src/main/java/io/netty/channel/nio/AbstractNioMessageChannel.java b/transport/src/main/java/io/netty/channel/nio/AbstractNioMessageChannel.java index 55d022074c..3ab0010a50 100755 --- a/transport/src/main/java/io/netty/channel/nio/AbstractNioMessageChannel.java +++ b/transport/src/main/java/io/netty/channel/nio/AbstractNioMessageChannel.java @@ -84,16 +84,19 @@ public abstract class AbstractNioMessageChannel extends AbstractNioChannel { } if (t instanceof IOException) { - closed = true; + closed = true; } else if (!closed) { firedChannelReadSuspended = true; pipeline.fireChannelReadSuspended(); } pipeline().fireExceptionCaught(t); + + // break the loop now + break; } finally { if (read) { - pipeline.fireInboundBufferUpdated(); + pipeline.fireInboundBufferUpdated(); } if (closed && isOpen()) { close(voidPromise());