handlerRemoved() — netty Function Reference

Architecture documentation for the handlerRemoved() function in ChannelTrafficShapingHandler.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ handlerRemoved() — netty Function Reference

Dependency Diagram

graph TD
  9e0f814d_7a6a_c08a_b1f5_4c590da72ce7["handlerRemoved()"]
  3ab3cf0d_ce70_e3dd_bab1_dbf87d133f02["ChannelTrafficShapingHandler"]
  9e0f814d_7a6a_c08a_b1f5_4c590da72ce7 -->|defined in| 3ab3cf0d_ce70_e3dd_bab1_dbf87d133f02
  style 9e0f814d_7a6a_c08a_b1f5_4c590da72ce7 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/traffic/ChannelTrafficShapingHandler.java lines 139–163

    @Override
    public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
        trafficCounter.stop();
        // write order control
        synchronized (this) {
            if (ctx.channel().isActive()) {
                for (ToSend toSend : messagesQueue) {
                    long size = calculateSize(toSend.toSend);
                    trafficCounter.bytesRealWriteFlowControl(size);
                    queueSize -= size;
                    ctx.write(toSend.toSend, toSend.promise);
                }
            } else {
                for (ToSend toSend : messagesQueue) {
                    if (toSend.toSend instanceof ByteBuf) {
                        ((ByteBuf) toSend.toSend).release();
                    }
                }
            }
            messagesQueue.clear();
        }
        releaseWriteSuspended(ctx);
        releaseReadSuspended(ctx);
        super.handlerRemoved(ctx);
    }