notifyHealthCheck() — netty Function Reference

Architecture documentation for the notifyHealthCheck() function in SimpleChannelPool.java from the netty codebase.

Function java Buffer Telemetry calls 3 called by 1

Entity Profile

Buffer→ Telemetry→ notifyHealthCheck() — netty Function Reference

Dependency Diagram

graph TD
  7ba4c5b6_3e78_dd98_af42_a908940f0803["notifyHealthCheck()"]
  e441b5b0_fbd9_848c_9624_3e21f7c56e58["SimpleChannelPool"]
  7ba4c5b6_3e78_dd98_af42_a908940f0803 -->|defined in| e441b5b0_fbd9_848c_9624_3e21f7c56e58
  b79f6ac0_3d07_2cc1_f3d6_7ca1488e3fa0["doHealthCheck()"]
  b79f6ac0_3d07_2cc1_f3d6_7ca1488e3fa0 -->|calls| 7ba4c5b6_3e78_dd98_af42_a908940f0803
  28de780c_cde8_99d0_9e70_ec182dc3ba60["closeChannel()"]
  7ba4c5b6_3e78_dd98_af42_a908940f0803 -->|calls| 28de780c_cde8_99d0_9e70_ec182dc3ba60
  c89f5af0_c810_693d_6240_cf574acc05b1["acquireHealthyFromPoolOrNew()"]
  7ba4c5b6_3e78_dd98_af42_a908940f0803 -->|calls| c89f5af0_c810_693d_6240_cf574acc05b1
  289c2758_bf72_3fdf_f9ce_fa04213a1c12["closeAndFail()"]
  7ba4c5b6_3e78_dd98_af42_a908940f0803 -->|calls| 289c2758_bf72_3fdf_f9ce_fa04213a1c12
  style 7ba4c5b6_3e78_dd98_af42_a908940f0803 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/pool/SimpleChannelPool.java lines 234–248

    private void notifyHealthCheck(Future<Boolean> future, Channel channel, Promise<Channel> promise) {
        try {
            assert channel.eventLoop().inEventLoop();
            if (future.isSuccess() && future.getNow()) {
                channel.attr(POOL_KEY).set(this);
                handler.channelAcquired(channel);
                promise.setSuccess(channel);
            } else {
                closeChannel(channel);
                acquireHealthyFromPoolOrNew(promise);
            }
        } catch (Throwable cause) {
            closeAndFail(channel, cause, promise);
        }
    }