andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

add more debug info about discarded message

Browse Source
This commit is contained in:
Norman Maurer 2013-02-19 19:08:04 +01:00
parent 74738fbd08
commit 5bda3a25b0
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java
View File

@ -1159,6 +1159,9 @@ final class DefaultChannelPipeline implements ChannelPipeline {
if (m instanceof ReferenceCounted) { if (m instanceof ReferenceCounted) {
((ReferenceCounted) m).release(); ((ReferenceCounted) m).release();
} }
logger.debug(
"Discarded inbound message {} that reached at the end of the pipeline. " +
"Please check your pipeline configuration.", m);
} }
logger.warn( logger.warn(
"Discarded {} inbound message(s) that reached at the end of the pipeline. " + "Discarded {} inbound message(s) that reached at the end of the pipeline. " +
@ -1295,6 +1298,9 @@ final class DefaultChannelPipeline implements ChannelPipeline {
ByteBuf src = (ByteBuf) m; ByteBuf src = (ByteBuf) m;
byteSink.writeBytes(src, src.readerIndex(), src.readableBytes()); byteSink.writeBytes(src, src.readerIndex(), src.readableBytes());
} else { } else {
logger.debug(
"Discarded outbound message {} that reached at the end of the pipeline. " +
"Please check your pipeline configuration.", m);
discardedMessages ++; discardedMessages ++;
} }