run() — netty Function Reference

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

Function java Buffer Allocators calls 2

Entity Profile

Buffer→ Allocators→ run() — netty Function Reference

Dependency Diagram

graph TD
  c648ed62_c9a2_bda9_3781_a21c17f43d8a["run()"]
  31b01ed4_f756_395a_3500_81e356092658["WriteTimeoutTask"]
  c648ed62_c9a2_bda9_3781_a21c17f43d8a -->|defined in| 31b01ed4_f756_395a_3500_81e356092658
  043f5eaa_2242_aa7e_eb93_13a5893c806d["writeTimedOut()"]
  c648ed62_c9a2_bda9_3781_a21c17f43d8a -->|calls| 043f5eaa_2242_aa7e_eb93_13a5893c806d
  a29cd7e7_658b_eddc_cda5_3a2f3771e34e["removeWriteTimeoutTask()"]
  c648ed62_c9a2_bda9_3781_a21c17f43d8a -->|calls| a29cd7e7_658b_eddc_cda5_3a2f3771e34e
  style c648ed62_c9a2_bda9_3781_a21c17f43d8a fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/timeout/WriteTimeoutHandler.java lines 202–215

        @Override
        public void run() {
            // Was not written yet so issue a write timeout
            // The promise itself will be failed with a ClosedChannelException once the close() was issued
            // See https://github.com/netty/netty/issues/2159
            if (!promise.isDone()) {
                try {
                    writeTimedOut(ctx);
                } catch (Throwable t) {
                    ctx.fireExceptionCaught(t);
                }
            }
            removeWriteTimeoutTask(this);
        }