freeChunkReuseQueue() — netty Function Reference

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

Function java Buffer Telemetry calls 1 called by 2

Entity Profile

Buffer→ Telemetry→ freeChunkReuseQueue() — netty Function Reference

Dependency Diagram

graph TD
  fd186d64_9da5_df36_66cb_2167df031bd3["freeChunkReuseQueue()"]
  5c7d3ca5_8d2c_76d2_0628_1864f492365d["MagazineGroup"]
  fd186d64_9da5_df36_66cb_2167df031bd3 -->|defined in| 5c7d3ca5_8d2c_76d2_0628_1864f492365d
  8b849fa9_e590_a1c7_94f9_6de2bdddf91a["offerChunk()"]
  8b849fa9_e590_a1c7_94f9_6de2bdddf91a -->|calls| fd186d64_9da5_df36_66cb_2167df031bd3
  65823112_6744_318f_eee4_bb0a2804a97f["free()"]
  65823112_6744_318f_eee4_bb0a2804a97f -->|calls| fd186d64_9da5_df36_66cb_2167df031bd3
  59c1d0ae_e507_0c96_51fa_359fe1b6411f["release()"]
  fd186d64_9da5_df36_66cb_2167df031bd3 -->|calls| 59c1d0ae_e507_0c96_51fa_359fe1b6411f
  style fd186d64_9da5_df36_66cb_2167df031bd3 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

buffer/src/main/java/io/netty/buffer/AdaptivePoolingAllocator.java lines 503–516

        private void freeChunkReuseQueue(Thread ownerThread) {
            Chunk chunk;
            while ((chunk = chunkCache.pollChunk(0)) != null) {
                if (ownerThread != null && chunk instanceof SizeClassedChunk) {
                    SizeClassedChunk threadLocalChunk = (SizeClassedChunk) chunk;
                    assert ownerThread == threadLocalChunk.ownerThread;
                    // no release segment can ever happen from the owner Thread since it's not running anymore
                    // This is required to let the ownerThread to be GC'ed despite there are AdaptiveByteBuf
                    // that reference some thread local chunk
                    threadLocalChunk.ownerThread = null;
                }
                chunk.release();
            }
        }