scheduleTimeout() — netty Function Reference

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

Function java Buffer Allocators calls 2 called by 1

Entity Profile

Buffer→ Allocators→ scheduleTimeout() — netty Function Reference

Dependency Diagram

graph TD
  2b53a7eb_61bd_a249_aad8_257450c6dd22["scheduleTimeout()"]
  7b2e459e_2db3_bea4_7583_d545431cfb47["WriteTimeoutHandler"]
  2b53a7eb_61bd_a249_aad8_257450c6dd22 -->|defined in| 7b2e459e_2db3_bea4_7583_d545431cfb47
  7ed311c8_061c_9835_d304_df9aa39d3a34["write()"]
  7ed311c8_061c_9835_d304_df9aa39d3a34 -->|calls| 2b53a7eb_61bd_a249_aad8_257450c6dd22
  8ddddbce_a36c_8313_a972_17e32c804b11["WriteTimeoutTask()"]
  2b53a7eb_61bd_a249_aad8_257450c6dd22 -->|calls| 8ddddbce_a36c_8313_a972_17e32c804b11
  0db099ef_ff56_5d35_0390_5b916332e663["addWriteTimeoutTask()"]
  2b53a7eb_61bd_a249_aad8_257450c6dd22 -->|calls| 0db099ef_ff56_5d35_0390_5b916332e663
  style 2b53a7eb_61bd_a249_aad8_257450c6dd22 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

handler/src/main/java/io/netty/handler/timeout/WriteTimeoutHandler.java lines 130–141

    private void scheduleTimeout(final ChannelHandlerContext ctx, final ChannelPromise promise) {
        // Schedule a timeout.
        final WriteTimeoutTask task = new WriteTimeoutTask(ctx, promise);
        task.scheduledFuture = ctx.executor().schedule(task, timeoutNanos, TimeUnit.NANOSECONDS);

        if (!task.scheduledFuture.isDone()) {
            addWriteTimeoutTask(task);

            // Cancel the scheduled timeout if the flush promise is complete.
            promise.addListener(task);
        }
    }