doReadBytes() — netty Function Reference

Architecture documentation for the doReadBytes() function in AbstractEpollChannel.java from the netty codebase.

Function java Buffer Telemetry

Entity Profile

Buffer→ Telemetry→ doReadBytes() — netty Function Reference

Dependency Diagram

graph TD
  f9c0e947_8e5c_f9c9_5557_7c39fd8251eb["doReadBytes()"]
  6a1b1970_2eef_b28f_03e7_8b11508deece["AbstractEpollChannel"]
  f9c0e947_8e5c_f9c9_5557_7c39fd8251eb -->|defined in| 6a1b1970_2eef_b28f_03e7_8b11508deece
  style f9c0e947_8e5c_f9c9_5557_7c39fd8251eb fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-epoll/src/main/java/io/netty/channel/epoll/AbstractEpollChannel.java lines 361–375

    protected final int doReadBytes(ByteBuf byteBuf) throws Exception {
        int writerIndex = byteBuf.writerIndex();
        int localReadAmount;
        unsafe().recvBufAllocHandle().attemptedBytesRead(byteBuf.writableBytes());
        if (byteBuf.hasMemoryAddress()) {
            localReadAmount = socket.recvAddress(byteBuf.memoryAddress(), writerIndex, byteBuf.capacity());
        } else {
            ByteBuffer buf = byteBuf.internalNioBuffer(writerIndex, byteBuf.writableBytes());
            localReadAmount = socket.recv(buf, buf.position(), buf.limit());
        }
        if (localReadAmount > 0) {
            byteBuf.writerIndex(writerIndex + localReadAmount);
        }
        return localReadAmount;
    }