accept() — netty Function Reference

Architecture documentation for the accept() function in IoUringBufferRing.java from the netty codebase.

Function java Buffer Telemetry calls 1

Entity Profile

Buffer→ Telemetry→ accept() — netty Function Reference

Dependency Diagram

graph TD
  0b38b077_5380_bfea_3cae_72023ceebfc5["accept()"]
  0ceb71f6_6540_8338_290b_365306bdbc58["RingConsumer"]
  0b38b077_5380_bfea_3cae_72023ceebfc5 -->|defined in| 0ceb71f6_6540_8338_290b_365306bdbc58
  6957abb8_3a64_9547_a4dc_2a000408aa97["add()"]
  0b38b077_5380_bfea_3cae_72023ceebfc5 -->|calls| 6957abb8_3a64_9547_a4dc_2a000408aa97
  style 0b38b077_5380_bfea_3cae_72023ceebfc5 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/IoUringBufferRing.java lines 128–139

        @Override
        public void accept(ByteBuf byteBuf) {
            if (corrupted || closed) {
                byteBuf.release();
                throw new IllegalStateException("Already closed");
            }
            if (expectedBuffers == num) {
                byteBuf.release();
                throw new IllegalStateException("Produced too many buffers");
            }
            add(oldTail, bid++, num++, byteBuf);
        }