finishConnect() — netty Function Reference

Architecture documentation for the finishConnect() function in AbstractNioChannel.java from the netty codebase.

Function java Buffer Telemetry calls 2 called by 1

Entity Profile

Buffer→ Telemetry→ finishConnect() — netty Function Reference

Dependency Diagram

graph TD
  82689713_a74b_195b_07e2_42d37565a5fd["finishConnect()"]
  60188589_9b31_b825_db5f_7e5167ad54a1["AbstractNioUnsafe"]
  82689713_a74b_195b_07e2_42d37565a5fd -->|defined in| 60188589_9b31_b825_db5f_7e5167ad54a1
  f0fa666e_fa90_46ee_6be6_10964a525a9b["handle()"]
  f0fa666e_fa90_46ee_6be6_10964a525a9b -->|calls| 82689713_a74b_195b_07e2_42d37565a5fd
  4bb57aac_5ddf_9de7_5326_9db47cddbd26["doFinishConnect()"]
  82689713_a74b_195b_07e2_42d37565a5fd -->|calls| 4bb57aac_5ddf_9de7_5326_9db47cddbd26
  123c8fda_87a2_fec2_8833_5ca69a354b9a["fulfillConnectPromise()"]
  82689713_a74b_195b_07e2_42d37565a5fd -->|calls| 123c8fda_87a2_fec2_8833_5ca69a354b9a
  style 82689713_a74b_195b_07e2_42d37565a5fd fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport/src/main/java/io/netty/channel/nio/AbstractNioChannel.java lines 375–396

        @Override
        public final void finishConnect() {
            // Note this method is invoked by the event loop only if the connection attempt was
            // neither cancelled nor timed out.

            assert eventLoop().inEventLoop();

            try {
                boolean wasActive = isActive();
                doFinishConnect();
                fulfillConnectPromise(connectPromise, wasActive);
            } catch (Throwable t) {
                fulfillConnectPromise(connectPromise, annotateConnectException(t, requestedRemoteAddress));
            } finally {
                // Check for null as the connectTimeoutFuture is only created if a connectTimeoutMillis > 0 is used
                // See https://github.com/netty/netty/issues/1770
                if (connectTimeoutFuture != null) {
                    connectTimeoutFuture.cancel(false);
                }
                connectPromise = null;
            }
        }