setBytes() — netty Function Reference

Architecture documentation for the setBytes() function in CompositeByteBuf.java from the netty codebase.

Function java Buffer Search calls 2 called by 1

Entity Profile

Buffer→ Search→ setBytes() — netty Function Reference

Dependency Diagram

graph TD
  58ef5d22_93d0_55a5_4256_c3bde8df53ef["setBytes()"]
  6b8e4d93_5aed_4ff7_ccdd_9c021b0fe7d6["CompositeByteBuf"]
  58ef5d22_93d0_55a5_4256_c3bde8df53ef -->|defined in| 6b8e4d93_5aed_4ff7_ccdd_9c021b0fe7d6
  e9920c4e_d91d_be1d_34e0_9c0ddc060f5d["CompositeByteBuf()"]
  e9920c4e_d91d_be1d_34e0_9c0ddc060f5d -->|calls| 58ef5d22_93d0_55a5_4256_c3bde8df53ef
  56df3e62_e22d_e17d_1a00_60ba703c8e92["toComponentIndex0()"]
  58ef5d22_93d0_55a5_4256_c3bde8df53ef -->|calls| 56df3e62_e22d_e17d_1a00_60ba703c8e92
  d3be0b0f_c8ba_dc16_970f_8a5302e005af["idx()"]
  58ef5d22_93d0_55a5_4256_c3bde8df53ef -->|calls| d3be0b0f_c8ba_dc16_970f_8a5302e005af
  style 58ef5d22_93d0_55a5_4256_c3bde8df53ef fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

buffer/src/main/java/io/netty/buffer/CompositeByteBuf.java lines 1400–1435

    @Override
    public int setBytes(int index, InputStream in, int length) throws IOException {
        checkIndex(index, length);
        if (length == 0) {
            return in.read(EmptyArrays.EMPTY_BYTES);
        }

        int i = toComponentIndex0(index);
        int readBytes = 0;
        do {
            Component c = components[i];
            int localLength = Math.min(length, c.endOffset - index);
            if (localLength == 0) {
                // Skip empty buffer
                i++;
                continue;
            }
            int localReadBytes = c.buf.setBytes(c.idx(index), in, localLength);
            if (localReadBytes < 0) {
                if (readBytes == 0) {
                    return -1;
                } else {
                    break;
                }
            }

            index += localReadBytes;
            length -= localReadBytes;
            readBytes += localReadBytes;
            if (localReadBytes == localLength) {
                i ++;
            }
        } while (length > 0);

        return readBytes;
    }