sink() — netty Function Reference

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

Function java Buffer Telemetry calls 2 called by 2

Entity Profile

Buffer→ Telemetry→ sink() — netty Function Reference

Dependency Diagram

graph TD
  38079c4c_340d_7168_bf66_3429ac5a58fd["sink()"]
  ad6253f6_6b27_9dab_4272_9c668d433d62["IntPriorityQueue"]
  38079c4c_340d_7168_bf66_3429ac5a58fd -->|defined in| ad6253f6_6b27_9dab_4272_9c668d433d62
  f2b8e419_4f1e_c5f8_1707_8a1ce3cbfc34["remove()"]
  f2b8e419_4f1e_c5f8_1707_8a1ce3cbfc34 -->|calls| 38079c4c_340d_7168_bf66_3429ac5a58fd
  631c7a78_a97a_92c7_9c70_ba1d86ff15bc["poll()"]
  631c7a78_a97a_92c7_9c70_ba1d86ff15bc -->|calls| 38079c4c_340d_7168_bf66_3429ac5a58fd
  f8d6bc00_3a80_475b_7977_901a2046e948["subord()"]
  38079c4c_340d_7168_bf66_3429ac5a58fd -->|calls| f8d6bc00_3a80_475b_7977_901a2046e948
  af0a88f6_ffad_b27a_c956_98c92ebd697a["swap()"]
  38079c4c_340d_7168_bf66_3429ac5a58fd -->|calls| af0a88f6_ffad_b27a_c956_98c92ebd697a
  style 38079c4c_340d_7168_bf66_3429ac5a58fd fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

buffer/src/main/java/io/netty/buffer/IntPriorityQueue.java lines 84–96

    private void sink(int index) {
        int child;
        while ((child = index << 1) <= size) {
            if (child < size && subord(child, child + 1)) {
                child++;
            }
            if (!subord(index, child)) {
                break;
            }
            swap(index, child);
            index = child;
        }
    }