netty Architecture Docs
Home / Function/ connectComplete() — netty Function Reference

connectComplete() — netty Function Reference

Architecture documentation for the connectComplete() function in AbstractIoUringChannel.java from the netty codebase.

Function java Buffer Search calls 5 called by 2

Entity Profile

Dependency Diagram

graph TD
  7ca63cf2_401d_5282_550f_f023bb1b2458["connectComplete()"]
  19011d76_ce85_4831_bbdf_3b21a88f2b1b["AbstractUringUnsafe"]
  7ca63cf2_401d_5282_550f_f023bb1b2458 -->|defined in| 19011d76_ce85_4831_bbdf_3b21a88f2b1b
  5f45f466_5da9_76a6_e49e_f54bf3e34ae8["handle()"]
  5f45f466_5da9_76a6_e49e_f54bf3e34ae8 -->|calls| 7ca63cf2_401d_5282_550f_f023bb1b2458
  02484f5e_fddd_74b7_e73c_1b14fb1d53cf["writeComplete()"]
  02484f5e_fddd_74b7_e73c_1b14fb1d53cf -->|calls| 7ca63cf2_401d_5282_550f_f023bb1b2458
  fba8adc4_a17f_4db6_3240_c3e0300aca8e["freeRemoteAddressMemory()"]
  7ca63cf2_401d_5282_550f_f023bb1b2458 -->|calls| fba8adc4_a17f_4db6_3240_c3e0300aca8e
  9297de32_6d49_794c_9a51_19eaa6d72911["schedulePollOut()"]
  7ca63cf2_401d_5282_550f_f023bb1b2458 -->|calls| 9297de32_6d49_794c_9a51_19eaa6d72911
  4af71a65_a4fd_8778_811b_01ce32d090eb["fulfillConnectPromise()"]
  7ca63cf2_401d_5282_550f_f023bb1b2458 -->|calls| 4af71a65_a4fd_8778_811b_01ce32d090eb
  6537cba5_2de7_ad7b_7809_a43f80f2e6f3["doBeginReadNow()"]
  7ca63cf2_401d_5282_550f_f023bb1b2458 -->|calls| 6537cba5_2de7_ad7b_7809_a43f80f2e6f3
  67b2aa6c_a298_76f6_3e5b_4d861b518d3c["cancelConnectTimeoutFuture()"]
  7ca63cf2_401d_5282_550f_f023bb1b2458 -->|calls| 67b2aa6c_a298_76f6_3e5b_4d861b518d3c
  style 7ca63cf2_401d_5282_550f_f023bb1b2458 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringChannel.java lines 1024–1053

        void connectComplete(byte op, int res, int flags, short data) {
            ioState &= ~CONNECT_SCHEDULED;
            freeRemoteAddressMemory();

            if (res == ERRNO_EINPROGRESS_NEGATIVE || res == ERROR_EALREADY_NEGATIVE) {
                // connect not complete yet need to wait for poll_out event
                schedulePollOut();
            } else {
                try {
                    if (res == 0) {
                        fulfillConnectPromise(connectPromise, active);
                        if (readPending) {
                            doBeginReadNow();
                        }
                    } else {
                        try {
                            Errors.throwConnectException("io_uring connect", res);
                        } catch (Throwable cause) {
                            fulfillConnectPromise(connectPromise, cause);
                        }
                    }
                } finally {
                    // Check for null as the connectTimeoutFuture is only created if a connectTimeoutMillis > 0 is
                    // used
                    // See https://github.com/netty/netty/issues/1770
                    cancelConnectTimeoutFuture();
                    connectPromise = null;
                }
            }
        }

Domain

Subdomains

Defined In

Calls

Called By

Source

Frequently Asked Questions

What does connectComplete() do?
connectComplete() is a function in the netty codebase, defined in transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringChannel.java.
Where is connectComplete() defined?
connectComplete() is defined in transport-classes-io_uring/src/main/java/io/netty/channel/uring/AbstractIoUringChannel.java at line 1024.
What does connectComplete() call?
connectComplete() calls 5 function(s): cancelConnectTimeoutFuture, doBeginReadNow, freeRemoteAddressMemory, fulfillConnectPromise, schedulePollOut.
What calls connectComplete()?
connectComplete() is called by 2 function(s): handle, writeComplete.

Analyze Your Own Codebase

Get architecture documentation, dependency graphs, and domain analysis for your codebase in minutes.

Try Supermodel Free