close0() — netty Function Reference

Architecture documentation for the close0() function in FixedChannelPool.java from the netty codebase.

Function java Buffer Search calls 1 called by 1

Entity Profile

Buffer→ Search→ close0() — netty Function Reference

Dependency Diagram

graph TD
  95e658c7_942f_e6e6_11e0_8027e4c5999a["close0()"]
  379a0f3e_d35d_8054_6f12_48a2cfebefb5["FixedChannelPool"]
  95e658c7_942f_e6e6_11e0_8027e4c5999a -->|defined in| 379a0f3e_d35d_8054_6f12_48a2cfebefb5
  82816a6e_9b06_c34a_e9c2_c740b5363f67["closeAsync()"]
  82816a6e_9b06_c34a_e9c2_c740b5363f67 -->|calls| 95e658c7_942f_e6e6_11e0_8027e4c5999a
  9ac1ba40_078b_abc6_6da9_14f7a9e33ed8["close()"]
  95e658c7_942f_e6e6_11e0_8027e4c5999a -->|calls| 9ac1ba40_078b_abc6_6da9_14f7a9e33ed8
  style 95e658c7_942f_e6e6_11e0_8027e4c5999a fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/pool/FixedChannelPool.java lines 481–512

    private Future<Void> close0() {
        assert executor.inEventLoop();

        if (!closed) {
            closed = true;
            for (;;) {
                AcquireTask task = pendingAcquireQueue.poll();
                if (task == null) {
                    break;
                }
                ScheduledFuture<?> f = task.timeoutFuture;
                if (f != null) {
                    f.cancel(false);
                }
                task.promise.setFailure(new ClosedChannelException());
            }
            acquiredChannelCount.set(0);
            pendingAcquireCount = 0;

            // Ensure we dispatch this on another Thread as close0 will be called from the EventExecutor and we need
            // to ensure we will not block in a EventExecutor.
            return GlobalEventExecutor.INSTANCE.submit(new Callable<Void>() {
                @Override
                public Void call() throws Exception {
                    FixedChannelPool.super.close();
                    return null;
                }
            });
        }

        return GlobalEventExecutor.INSTANCE.newSucceededFuture(null);
    }