io.netty.channel.ChannelHandlerContext#fireChannelWritabilityChanged ( )源码实例Demo

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
    if (ctx.channel().isWritable()) {
        // channel is writable again try to continue flushing通道再次写入，请尝试继续刷新
        doFlush(ctx);
    }
    ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
    if (logger.isEnabled(internalLevel)) {
        logger.log(internalLevel, format(ctx, "WRITABILITY CHANGED"));
    }
    ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
    if (!ctx.channel().isWritable()) {
        // The writability of the channel changed to false, so flush all consolidated flushes now to free up memory.
        flushIfNeeded(ctx);
    }
    ctx.fireChannelWritabilityChanged();
}
 

private void flushNext(ChannelHandlerContext ctx) {
    if (!outgoing.isEmpty()) {
        unbufferedWrite(ctx, outgoing.element());
    } else {
        ctx.fireChannelWritabilityChanged();
    }
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
    if (ctx.channel().isWritable()) {
        // channel is writable again try to continue flushing
        doFlush(ctx);
    }
    ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(final ChannelHandlerContext ctx) throws Exception {
    if (!ctx.channel().isWritable()) {
        ctx.flush();
    }
    ctx.fireChannelWritabilityChanged();
}
 

public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
    ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
  writeManager.setWritable(ctx.channel().isWritable());
  ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
    String clientId = NettyAttrManager.getAttrClientId(ctx.channel());
    LOG.info("Channel Writable Changed, clientID: {}", clientId);
    ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext nettyctx)
        throws Exception {
    nettyctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext nettyctx)
        throws Exception {
    nettyctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
    maybeRequestMore();
    ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
  writeManager.setWritable(ctx.channel().isWritable());
  ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(final ChannelHandlerContext ctx) throws Exception {
    ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
    maybeRequestMore();
    ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
  Gdx.app.debug(TAG, "channelWritabilityChanged");
  ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
  if (DEBUG_CALLS) Gdx.app.debug(TAG, "channelWritabilityChanged");
  ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
  Gdx.app.debug(TAG, "channelWritabilityChanged");
  ctx.fireChannelWritabilityChanged();
}
 

@Override
public void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception {
  if (DEBUG_CALLS) Gdx.app.debug(TAG, "channelWritabilityChanged");
  ctx.fireChannelWritabilityChanged();
}
 

/**
 * Gets called once the writable state of a {@link Channel} changed. You can check the state with
 * {@link Channel#isWritable()}.
 *
 * @param context {@link ChannelHandlerContext} to which this {@link RntbdRequestManager} belongs
 */
@Override
public void channelWritabilityChanged(final ChannelHandlerContext context) {
    this.traceOperation(context, "channelWritabilityChanged");
    context.fireChannelWritabilityChanged();
}