write() — netty Function Reference

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

Function java Buffer Telemetry calls 2 called by 2

Entity Profile

Buffer→ Telemetry→ write() — netty Function Reference

Dependency Diagram

graph TD
  d3c15c2b_89df_c6f8_2627_eddb52f353a8["write()"]
  b35c8769_b4a5_98d3_cef5_77dd9b4e5869["CountingWriter"]
  d3c15c2b_89df_c6f8_2627_eddb52f353a8 -->|defined in| b35c8769_b4a5_98d3_cef5_77dd9b4e5869
  3df43039_e242_a821_b58b_3c86357eff75["write()"]
  3df43039_e242_a821_b58b_3c86357eff75 -->|calls| d3c15c2b_89df_c6f8_2627_eddb52f353a8
  a7eb557c_1242_3959_11ef_d3cf6e5dcbac["addData()"]
  a7eb557c_1242_3959_11ef_d3cf6e5dcbac -->|calls| d3c15c2b_89df_c6f8_2627_eddb52f353a8
  3df43039_e242_a821_b58b_3c86357eff75["write()"]
  d3c15c2b_89df_c6f8_2627_eddb52f353a8 -->|calls| 3df43039_e242_a821_b58b_3c86357eff75
  c05b6618_aafc_23bd_b1d4_d787e83c70cd["add()"]
  d3c15c2b_89df_c6f8_2627_eddb52f353a8 -->|calls| c05b6618_aafc_23bd_b1d4_d787e83c70cd
  style d3c15c2b_89df_c6f8_2627_eddb52f353a8 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

microbench/src/main/java/io/netty/microbench/http2/NoPriorityByteDistributionBenchmark.java lines 274–293

            @Override
            public void write(Http2Stream stream, int numBytes) {
                if (numBytes > 0) {
                    // Add the data to the refresher so that it can be given back to the
                    // stream at the end of the iteration.
                    DataRefresher refresher = dataRefresher(stream);
                    refresher.add(numBytes);

                    ++counters.numWrites;
                    counters.totalBytes += numBytes;
                    if (numBytes < counters.minWriteSize) {
                        counters.minWriteSize = numBytes;
                    }
                    if (numBytes > counters.maxWriteSize) {
                        counters.maxWriteSize = numBytes;
                    }
                }

                delegate.write(stream, numBytes);
            }