doHealthCheckOnRelease() — netty Function Reference

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

Function java Buffer Search calls 1 called by 1

Entity Profile

Buffer→ Search→ doHealthCheckOnRelease() — netty Function Reference

Dependency Diagram

graph TD
  372c81d4_671e_eced_ddf9_8148d4635f01["doHealthCheckOnRelease()"]
  e441b5b0_fbd9_848c_9624_3e21f7c56e58["SimpleChannelPool"]
  372c81d4_671e_eced_ddf9_8148d4635f01 -->|defined in| e441b5b0_fbd9_848c_9624_3e21f7c56e58
  edd5c18f_fdf6_5dbc_4d9f_3143ea1106e2["doReleaseChannel()"]
  edd5c18f_fdf6_5dbc_4d9f_3143ea1106e2 -->|calls| 372c81d4_671e_eced_ddf9_8148d4635f01
  8eb21ab9_3ebf_30a3_6c36_dbceab52adb8["releaseAndOfferIfHealthy()"]
  372c81d4_671e_eced_ddf9_8148d4635f01 -->|calls| 8eb21ab9_3ebf_30a3_6c36_dbceab52adb8
  style 372c81d4_671e_eced_ddf9_8148d4635f01 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/pool/SimpleChannelPool.java lines 309–316

    private void doHealthCheckOnRelease(final Channel channel, final Promise<Void> promise) throws Exception {
        final Future<Boolean> f = healthCheck.isHealthy(channel);
        if (f.isDone()) {
            releaseAndOfferIfHealthy(channel, promise, f);
        } else {
            f.addListener((FutureListener<Boolean>) future -> releaseAndOfferIfHealthy(channel, promise, f));
        }
    }