runPendingTasks() — netty Function Reference

Architecture documentation for the runPendingTasks() function in EmbeddedChannel.java from the netty codebase.

Function java Buffer Telemetry calls 1 called by 4

Entity Profile

Buffer→ Telemetry→ runPendingTasks() — netty Function Reference

Dependency Diagram

graph TD
  af353ce5_1ef0_a5fe_9c65_65651743b5a2["runPendingTasks()"]
  0bb3a58a_67ea_3870_31f9_00e0edf95132["EmbeddedChannel"]
  af353ce5_1ef0_a5fe_9c65_65651743b5a2 -->|defined in| 0bb3a58a_67ea_3870_31f9_00e0edf95132
  68c36e43_fbb1_f160_224c_0235666d6f76["ChannelFuture()"]
  68c36e43_fbb1_f160_224c_0235666d6f76 -->|calls| af353ce5_1ef0_a5fe_9c65_65651743b5a2
  559e3175_ce9d_28f8_2409_73365664ed18["writeOutbound()"]
  559e3175_ce9d_28f8_2409_73365664ed18 -->|calls| af353ce5_1ef0_a5fe_9c65_65651743b5a2
  10460cae_06a7_41c7_b61d_1d0585247e82["flushOutbound0()"]
  10460cae_06a7_41c7_b61d_1d0585247e82 -->|calls| af353ce5_1ef0_a5fe_9c65_65651743b5a2
  fb4fa721_0ffb_13af_d1b0_d9acaa6268de["maybeRunPendingTasks()"]
  fb4fa721_0ffb_13af_d1b0_d9acaa6268de -->|calls| af353ce5_1ef0_a5fe_9c65_65651743b5a2
  7a0b636d_b15b_cbcf_fa5b_2074f256ceb4["recordException()"]
  af353ce5_1ef0_a5fe_9c65_65651743b5a2 -->|calls| 7a0b636d_b15b_cbcf_fa5b_2074f256ceb4
  style af353ce5_1ef0_a5fe_9c65_65651743b5a2 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/embedded/EmbeddedChannel.java lines 833–845

    public void runPendingTasks() {
        try {
            embeddedEventLoop().runTasks();
        } catch (Exception e) {
            recordException(e);
        }

        try {
            embeddedEventLoop().runScheduledTasks();
        } catch (Exception e) {
            recordException(e);
        }
    }