acquire() — netty Function Reference

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

Function java Buffer Telemetry calls 2 called by 3

Entity Profile

Buffer→ Telemetry→ acquire() — netty Function Reference

Dependency Diagram

graph TD
  1d51fd53_2c69_0470_07c7_4631383a891c["acquire()"]
  379a0f3e_d35d_8054_6f12_48a2cfebefb5["FixedChannelPool"]
  1d51fd53_2c69_0470_07c7_4631383a891c -->|defined in| 379a0f3e_d35d_8054_6f12_48a2cfebefb5
  042c49b1_3970_851b_6732_1c9d4df9b1bb["FixedChannelPool()"]
  042c49b1_3970_851b_6732_1c9d4df9b1bb -->|calls| 1d51fd53_2c69_0470_07c7_4631383a891c
  58ce3254_7910_e246_bd60_e2c3b0165bc0["acquire0()"]
  58ce3254_7910_e246_bd60_e2c3b0165bc0 -->|calls| 1d51fd53_2c69_0470_07c7_4631383a891c
  f449fa2c_e258_1aba_423a_5369445ba398["runTaskQueue()"]
  f449fa2c_e258_1aba_423a_5369445ba398 -->|calls| 1d51fd53_2c69_0470_07c7_4631383a891c
  58ce3254_7910_e246_bd60_e2c3b0165bc0["acquire0()"]
  1d51fd53_2c69_0470_07c7_4631383a891c -->|calls| 58ce3254_7910_e246_bd60_e2c3b0165bc0
  24f665bf_9852_2540_7b1a_564ff32355be["run()"]
  1d51fd53_2c69_0470_07c7_4631383a891c -->|calls| 24f665bf_9852_2540_7b1a_564ff32355be
  style 1d51fd53_2c69_0470_07c7_4631383a891c fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/pool/FixedChannelPool.java lines 225–242

    @Override
    public Future<Channel> acquire(final Promise<Channel> promise) {
        try {
            if (executor.inEventLoop()) {
                acquire0(promise);
            } else {
                executor.execute(new Runnable() {
                    @Override
                    public void run() {
                        acquire0(promise);
                    }
                });
            }
        } catch (Throwable cause) {
            promise.tryFailure(cause);
        }
        return promise;
    }