#2055: Mark inactive channels as closed

This commit is contained in:
md_5 2017-02-07 08:58:37 +11:00
parent 950d504bd8
commit 01f44483df
2 changed files with 6 additions and 0 deletions

View File

@ -57,6 +57,11 @@ public class ChannelWrapper
}
}
public void markClosed()
{
closed = closing = true;
}
public void close()
{
close( null );

View File

@ -52,6 +52,7 @@ public class HandlerBoss extends ChannelInboundHandlerAdapter
{
if ( handler != null )
{
channel.markClosed();
handler.disconnected( channel );
if ( !( handler instanceof InitialHandler || handler instanceof PingHandler ) )