notifyConnect() — netty Function Reference

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

Function java Buffer Telemetry calls 2 called by 1

Entity Profile

Buffer→ Telemetry→ notifyConnect() — netty Function Reference

Dependency Diagram

graph TD
  d8986b0c_0cd0_31a4_8611_1debe6366195["notifyConnect()"]
  e441b5b0_fbd9_848c_9624_3e21f7c56e58["SimpleChannelPool"]
  d8986b0c_0cd0_31a4_8611_1debe6366195 -->|defined in| e441b5b0_fbd9_848c_9624_3e21f7c56e58
  c89f5af0_c810_693d_6240_cf574acc05b1["acquireHealthyFromPoolOrNew()"]
  c89f5af0_c810_693d_6240_cf574acc05b1 -->|calls| d8986b0c_0cd0_31a4_8611_1debe6366195
  f7de2118_7e0e_1138_b047_455dbc2dd98f["release()"]
  d8986b0c_0cd0_31a4_8611_1debe6366195 -->|calls| f7de2118_7e0e_1138_b047_455dbc2dd98f
  289c2758_bf72_3fdf_f9ce_fa04213a1c12["closeAndFail()"]
  d8986b0c_0cd0_31a4_8611_1debe6366195 -->|calls| 289c2758_bf72_3fdf_f9ce_fa04213a1c12
  style d8986b0c_0cd0_31a4_8611_1debe6366195 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/pool/SimpleChannelPool.java lines 202–218

    private void notifyConnect(ChannelFuture future, Promise<Channel> promise) {
        Channel channel = null;
        try {
            if (future.isSuccess()) {
                channel = future.channel();
                handler.channelAcquired(channel);
                if (!promise.trySuccess(channel)) {
                    // Promise was completed in the meantime (like cancelled), just release the channel again
                    release(channel);
                }
            } else {
                promise.tryFailure(future.cause());
            }
        } catch (Throwable cause) {
            closeAndFail(channel, cause, promise);
        }
    }