handleReadException() — netty Function Reference

Architecture documentation for the handleReadException() function in AbstractOioByteChannel.java from the netty codebase.

Function java Buffer Search calls 1 called by 1

Entity Profile

Buffer→ Search→ handleReadException() — netty Function Reference

Dependency Diagram

graph TD
  6731b7b6_ba29_84b6_72f2_5246e108dfb1["handleReadException()"]
  df30be00_eee6_bc00_48f3_cbf4f80b9065["AbstractOioByteChannel"]
  6731b7b6_ba29_84b6_72f2_5246e108dfb1 -->|defined in| df30be00_eee6_bc00_48f3_cbf4f80b9065
  24847cd2_e242_82c4_873e_ef44313f60e1["doRead()"]
  24847cd2_e242_82c4_873e_ef44313f60e1 -->|calls| 6731b7b6_ba29_84b6_72f2_5246e108dfb1
  e2921b96_0d95_d59d_1b95_b8061971e04f["closeOnRead()"]
  6731b7b6_ba29_84b6_72f2_5246e108dfb1 -->|calls| e2921b96_0d95_d59d_1b95_b8061971e04f
  style 6731b7b6_ba29_84b6_72f2_5246e108dfb1 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/oio/AbstractOioByteChannel.java lines 84–106

    private void handleReadException(ChannelPipeline pipeline, ByteBuf byteBuf, Throwable cause, boolean close,
            RecvByteBufAllocator.Handle allocHandle) {
        if (byteBuf != null) {
            if (byteBuf.isReadable()) {
                readPending = false;
                pipeline.fireChannelRead(byteBuf);
            } else {
                byteBuf.release();
            }
        }
        allocHandle.readComplete();
        pipeline.fireChannelReadComplete();
        pipeline.fireExceptionCaught(cause);

        // If oom will close the read event, release connection.
        // See https://github.com/netty/netty/issues/10434
        if (close ||
                cause instanceof OutOfMemoryError ||
                cause instanceof LeakPresenceDetector.AllocationProhibitedException ||
                cause instanceof IOException) {
            closeOnRead(pipeline);
        }
    }