collapsePast() — netty Function Reference

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

Function java Buffer Telemetry calls 5 called by 1

Entity Profile

Buffer→ Telemetry→ collapsePast() — netty Function Reference

Dependency Diagram

graph TD
  c0ff4822_02b1_af55_da13_566b386e84c6["collapsePast()"]
  271be16e_fb25_9fe6_0749_cf5dd80dd903["PoolChunk"]
  c0ff4822_02b1_af55_da13_566b386e84c6 -->|defined in| 271be16e_fb25_9fe6_0749_cf5dd80dd903
  ef3c5aae_1376_7df3_1784_9bef85c2d5a9["collapseRuns()"]
  ef3c5aae_1376_7df3_1784_9bef85c2d5a9 -->|calls| c0ff4822_02b1_af55_da13_566b386e84c6
  22016f68_b853_63ea_32c8_c288b8996440["runOffset()"]
  c0ff4822_02b1_af55_da13_566b386e84c6 -->|calls| 22016f68_b853_63ea_32c8_c288b8996440
  dc13ebd8_c529_7ebf_35cc_4cc9171ec3d6["runPages()"]
  c0ff4822_02b1_af55_da13_566b386e84c6 -->|calls| dc13ebd8_c529_7ebf_35cc_4cc9171ec3d6
  a2a90b64_46c7_8d33_34bc_ad92c06e2eca["getAvailRunByOffset()"]
  c0ff4822_02b1_af55_da13_566b386e84c6 -->|calls| a2a90b64_46c7_8d33_34bc_ad92c06e2eca
  7a27929c_739b_b7b7_3775_2a30a6eff48c["removeAvailRun()"]
  c0ff4822_02b1_af55_da13_566b386e84c6 -->|calls| 7a27929c_739b_b7b7_3775_2a30a6eff48c
  ad10cf92_7c56_46e4_64cc_cf0d8d87aa22["toRunHandle()"]
  c0ff4822_02b1_af55_da13_566b386e84c6 -->|calls| ad10cf92_7c56_46e4_64cc_cf0d8d87aa22
  style c0ff4822_02b1_af55_da13_566b386e84c6 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

buffer/src/main/java/io/netty/buffer/PoolChunk.java lines 552–574

    private long collapsePast(long handle) {
        for (;;) {
            int runOffset = runOffset(handle);
            int runPages = runPages(handle);

            long pastRun = getAvailRunByOffset(runOffset - 1);
            if (pastRun == -1) {
                return handle;
            }

            int pastOffset = runOffset(pastRun);
            int pastPages = runPages(pastRun);

            //is continuous
            if (pastRun != handle && pastOffset + pastPages == runOffset) {
                //remove past run
                removeAvailRun(pastRun);
                handle = toRunHandle(pastOffset, pastPages + runPages, 0);
            } else {
                return handle;
            }
        }
    }