PoolChunk() — netty Function Reference

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

Function java Buffer Telemetry calls 2

Entity Profile

Buffer→ Telemetry→ PoolChunk() — netty Function Reference

Dependency Diagram

graph TD
  da669453_f4ef_44ec_3f52_421ec821d319["PoolChunk()"]
  271be16e_fb25_9fe6_0749_cf5dd80dd903["PoolChunk"]
  da669453_f4ef_44ec_3f52_421ec821d319 -->|defined in| 271be16e_fb25_9fe6_0749_cf5dd80dd903
  e4d6cf66_a04d_42c0_c24f_7b5cd6cb4301["newRunsAvailqueueArray()"]
  da669453_f4ef_44ec_3f52_421ec821d319 -->|calls| e4d6cf66_a04d_42c0_c24f_7b5cd6cb4301
  9adde7b9_78be_7351_d13f_4b1e178b71e5["insertAvailRun()"]
  da669453_f4ef_44ec_3f52_421ec821d319 -->|calls| 9adde7b9_78be_7351_d13f_4b1e178b71e5
  style da669453_f4ef_44ec_3f52_421ec821d319 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

buffer/src/main/java/io/netty/buffer/PoolChunk.java lines 198–224

    @SuppressWarnings("unchecked")
    PoolChunk(PoolArena<T> arena, CleanableDirectBuffer cleanable, Object base, T memory, int pageSize, int pageShifts,
              int chunkSize, int maxPageIdx) {
        unpooled = false;
        this.arena = arena;
        this.cleanable = cleanable;
        this.base = base;
        this.memory = memory;
        this.pageSize = pageSize;
        this.pageShifts = pageShifts;
        this.chunkSize = chunkSize;
        this.maxPageIdx = maxPageIdx;
        freeBytes = chunkSize;

        runsAvail = newRunsAvailqueueArray(maxPageIdx);
        runsAvailLock = new ReentrantLock();
        runsAvailMap = new LongLongHashMap(-1);
        subpages = new PoolSubpage[chunkSize >> pageShifts];

        //insert initial run, offset = 0, pages = chunkSize / pageSize
        int pages = chunkSize >> pageShifts;
        long initHandle = (long) pages << SIZE_SHIFT;
        insertAvailRun(0, pages, initHandle);

        cachedNioBuffers = new ArrayDeque<>(8);
        this.pinnedBytes = trackPinnedMemory ? new LongAdder() : null;
    }