PerChannel() — netty Function Reference

Architecture documentation for the PerChannel() function in GlobalChannelTrafficShapingHandler.java from the netty codebase.

Function java Buffer Allocators

Entity Profile

Buffer→ Allocators→ PerChannel() — netty Function Reference

Dependency Diagram

graph TD
  7d43593b_79e3_eb5c_d0cc_ce3b2d4788b1["PerChannel()"]
  70857fc2_a134_e299_7b48_1738d53c0016["GlobalChannelTrafficShapingHandler"]
  7d43593b_79e3_eb5c_d0cc_ce3b2d4788b1 -->|defined in| 70857fc2_a134_e299_7b48_1738d53c0016
  style 7d43593b_79e3_eb5c_d0cc_ce3b2d4788b1 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/traffic/GlobalChannelTrafficShapingHandler.java lines 454–471

    private PerChannel getOrSetPerChannel(ChannelHandlerContext ctx) {
        // ensure creation is limited to one thread per channel
        Channel channel = ctx.channel();
        Integer key = channel.hashCode();
        PerChannel perChannel = channelQueues.get(key);
        if (perChannel == null) {
            perChannel = new PerChannel();
            perChannel.messagesQueue = new ArrayDeque<ToSend>();
            // Don't start it since managed through the Global one
            perChannel.channelTrafficCounter = new TrafficCounter(this, null, "ChannelTC" +
                    ctx.channel().hashCode(), checkInterval);
            perChannel.queueSize = 0L;
            perChannel.lastReadTimestamp = TrafficCounter.milliSecondFromNano();
            perChannel.lastWriteTimestamp = perChannel.lastReadTimestamp;
            channelQueues.put(key, perChannel);
        }
        return perChannel;
    }