doConnect() — netty Function Reference

Architecture documentation for the doConnect() function in OioSctpChannel.java from the netty codebase.

Function java Buffer Search calls 1

Entity Profile

Buffer→ Search→ doConnect() — netty Function Reference

Dependency Diagram

graph TD
  013d5aeb_9b02_e7ae_c7f1_42eaaf93eb6a["doConnect()"]
  0e982d34_5d94_834c_1668_451f9d08d74b["OioSctpChannel"]
  013d5aeb_9b02_e7ae_c7f1_42eaaf93eb6a -->|defined in| 0e982d34_5d94_834c_1668_451f9d08d74b
  c9c9e289_b3f4_8b4b_b451_fd7f47abaf8b["doClose()"]
  013d5aeb_9b02_e7ae_c7f1_42eaaf93eb6a -->|calls| c9c9e289_b3f4_8b4b_b451_fd7f47abaf8b
  style 013d5aeb_9b02_e7ae_c7f1_42eaaf93eb6a fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

transport-sctp/src/main/java/io/netty/channel/sctp/oio/OioSctpChannel.java lines 388–418

    @Override
    protected void doConnect(SocketAddress remoteAddress,
                             SocketAddress localAddress) throws Exception {
        if (localAddress != null) {
            ch.bind(localAddress);
        }

        boolean success = false;
        try {
            ch.connect(remoteAddress);
            boolean  finishConnect = false;
            while (!finishConnect) {
                if (connectSelector.select(SO_TIMEOUT) >= 0) {
                    final Set<SelectionKey> selectionKeys = connectSelector.selectedKeys();
                    for (SelectionKey key : selectionKeys) {
                       if (key.isConnectable()) {
                           selectionKeys.clear();
                           finishConnect = true;
                           break;
                       }
                    }
                    selectionKeys.clear();
                }
            }
            success = ch.finishConnect();
        } finally {
            if (!success) {
                doClose();
            }
        }
    }