From 9b208028ef1300b1a49eb1315ba58e58c2b87152 Mon Sep 17 00:00:00 2001 From: Trustin Lee Date: Thu, 21 Mar 2013 20:22:25 +0900 Subject: [PATCH] Use clearer term when data is discarded by pipeline --- .../io/netty/channel/DefaultChannelPipeline.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java b/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java index 268a6288c5..3efe734423 100755 --- a/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java +++ b/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java @@ -1194,7 +1194,7 @@ final class DefaultChannelPipeline implements ChannelPipeline { @Override public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { logger.warn( - "An exceptionCaught() event was fired, and it reached at the end of the pipeline. " + + "An exceptionCaught() event was fired, and it reached at the tail of the pipeline. " + "It usually means the last handler in the pipeline did not handle the exception.", cause); } @@ -1215,7 +1215,7 @@ final class DefaultChannelPipeline implements ChannelPipeline { if (byteSinkSize != 0) { byteSink.clear(); logger.warn( - "Discarded {} inbound byte(s) that reached at the end of the pipeline. " + + "Discarded {} inbound byte(s) that reached at the tail of the pipeline. " + "Please check your pipeline configuration.", byteSinkSize); } @@ -1232,11 +1232,11 @@ final class DefaultChannelPipeline implements ChannelPipeline { ((ReferenceCounted) m).release(); } logger.debug( - "Discarded inbound message {} that reached at the end of the pipeline. " + + "Discarded inbound message {} that reached at the tail of the pipeline. " + "Please check your pipeline configuration.", m); } logger.warn( - "Discarded {} inbound message(s) that reached at the end of the pipeline. " + + "Discarded {} inbound message(s) that reached at the tail of the pipeline. " + "Please check your pipeline configuration.", msgSinkSize); } } @@ -1368,7 +1368,7 @@ final class DefaultChannelPipeline implements ChannelPipeline { byteSink.writeBytes(src, src.readerIndex(), src.readableBytes()); } else { logger.debug( - "Discarded outbound message {} that reached at the end of the pipeline. " + + "Discarded outbound message {} that reached at the head of the pipeline. " + "Please check your pipeline configuration.", m); discardedMessages ++; } @@ -1380,7 +1380,7 @@ final class DefaultChannelPipeline implements ChannelPipeline { if (discardedMessages != 0) { logger.warn( - "Discarded {} outbound message(s) that reached at the end of the pipeline. " + + "Discarded {} outbound message(s) that reached at the head of the pipeline. " + "Please check your pipeline configuration.", discardedMessages); } @@ -1400,7 +1400,7 @@ final class DefaultChannelPipeline implements ChannelPipeline { if (byteSinkSize != 0) { byteSink.clear(); logger.warn( - "Discarded {} outbound byte(s) that reached at the end of the pipeline. " + + "Discarded {} outbound byte(s) that reached at the head of the pipeline. " + "Please check your pipeline configuration.", byteSinkSize); } unsafe.flush(promise);