releaseInboundBuffers() — netty Function Reference

Architecture documentation for the releaseInboundBuffers() function in LocalChannel.java from the netty codebase.

Function java Buffer Allocators called by 2

Entity Profile

Buffer→ Allocators→ releaseInboundBuffers() — netty Function Reference

Dependency Diagram

graph TD
  67917219_8f92_90b6_97f7_b6c689224093["releaseInboundBuffers()"]
  81a44f54_ab3c_5f8b_4522_05c91e5f8eb8["LocalChannel"]
  67917219_8f92_90b6_97f7_b6c689224093 -->|defined in| 81a44f54_ab3c_5f8b_4522_05c91e5f8eb8
  f1b1c04a_89d4_cfdf_491a_2834d7b50724["doClose()"]
  f1b1c04a_89d4_cfdf_491a_2834d7b50724 -->|calls| 67917219_8f92_90b6_97f7_b6c689224093
  7f95a1bb_b49a_748e_2757_d753b7bb2505["tryClose()"]
  7f95a1bb_b49a_748e_2757_d753b7bb2505 -->|calls| 67917219_8f92_90b6_97f7_b6c689224093
  style 67917219_8f92_90b6_97f7_b6c689224093 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/local/LocalChannel.java lines 450–458

    private void releaseInboundBuffers() {
        assert eventLoop() == null || eventLoop().inEventLoop();
        readInProgress = false;
        Queue<Object> inboundBuffer = this.inboundBuffer;
        Object msg;
        while ((msg = inboundBuffer.poll()) != null) {
            ReferenceCountUtil.release(msg);
        }
    }