sendAllValid() — netty Function Reference

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

Function java Buffer Allocators called by 1

Entity Profile

Buffer→ Allocators→ sendAllValid() — netty Function Reference

Dependency Diagram

graph TD
  e4f33061_39c5_e7d9_db16_146de71ad694["sendAllValid()"]
  3ab3cf0d_ce70_e3dd_bab1_dbf87d133f02["ChannelTrafficShapingHandler"]
  e4f33061_39c5_e7d9_db16_146de71ad694 -->|defined in| 3ab3cf0d_ce70_e3dd_bab1_dbf87d133f02
  1b713933_a184_93c1_9ea9_dd7bde595461["submitWrite()"]
  1b713933_a184_93c1_9ea9_dd7bde595461 -->|calls| e4f33061_39c5_e7d9_db16_146de71ad694
  style e4f33061_39c5_e7d9_db16_146de71ad694 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/traffic/ChannelTrafficShapingHandler.java lines 203–223

    private void sendAllValid(final ChannelHandlerContext ctx, final long now) {
        // write order control
        synchronized (this) {
            ToSend newToSend = messagesQueue.pollFirst();
            for (; newToSend != null; newToSend = messagesQueue.pollFirst()) {
                if (newToSend.relativeTimeAction <= now) {
                    long size = calculateSize(newToSend.toSend);
                    trafficCounter.bytesRealWriteFlowControl(size);
                    queueSize -= size;
                    ctx.write(newToSend.toSend, newToSend.promise);
                } else {
                    messagesQueue.addFirst(newToSend);
                    break;
                }
            }
            if (messagesQueue.isEmpty()) {
                releaseWriteSuspended(ctx);
            }
        }
        ctx.flush();
    }