ServerHandler.java 文件源码

/**
 * <p>
 * {@inheritDoc}
 * </p>
 * <p>
 * Overriden to log ChannelStateEvents if they have a state other than
 * {@link ChannelState#INTEREST_OPS}, i. e. OPEN, BOUND, CONNECTED.
 * </p>
 * 
 * @param ctx
 *            the context object for this handler
 * @param e
 *            the upstream event to process or intercept
 */
@Override
public void handleUpstream(final ChannelHandlerContext ctx, final ChannelEvent e) throws Exception {
    if (e instanceof ChannelStateEvent) {
        ChannelStateEvent stateEvent = (ChannelStateEvent) e;
        if (stateEvent.getState() != ChannelState.INTEREST_OPS) {
            log.info(e.toString());
            if (stateEvent.getState() == ChannelState.CONNECTED && stateEvent.getValue() == null) {
                // Remove channel from container when client disconnects
                channelContainer.removeChannel(e.getChannel());
            }
        }

    }
    super.handleUpstream(ctx, e);
}