Method connect

src/socket.cpp:1499–1575

}

int SIPpSocket::connect(struct sockaddr_storage* dest)
{
    if (dest)
    {
        memcpy(&ss_dest, dest, sizeof(*dest));
    }

    int ret;

    assert(ss_transport == T_TCP || ss_transport == T_TLS || ss_transport == T_SCTP);

    if (ss_transport == T_TCP || ss_transport == T_TLS) {
        struct sockaddr_storage with_optional_port;
        int port = -1;
        memcpy(&with_optional_port, &local_sockaddr, sizeof(struct sockaddr_storage));
        if (local_ip_is_ipv6) {
            (_RCAST(struct sockaddr_in6*, &with_optional_port))->sin6_port = htons(ss_bind_port);
        } else {
            (_RCAST(struct sockaddr_in*, &with_optional_port))->sin_port = htons(ss_bind_port);
        }
        sipp_bind_socket(this, &with_optional_port, &port);
#ifdef USE_SCTP
    } else if (ss_transport == T_SCTP) {
        int port = -1;
        sipp_bind_socket(this, &local_sockaddr, &port);
#endif
    }

    int flags = fcntl(ss_fd, F_GETFL, 0);
    fcntl(ss_fd, F_SETFL, flags | O_NONBLOCK);

    errno = 0;
    ret = ::connect(ss_fd, _RCAST(struct sockaddr *, &ss_dest), socklen_from_addr(&ss_dest));
    if (ret < 0) {
        if (errno == EINPROGRESS) {
            /* Block this socket until the connect completes - this is very similar to entering congestion, but we don't want to increment congestion statistics. */
            enter_congestion(0);
            nb_net_cong--;
        } else {
            return ret;
        }
    }

    fcntl(ss_fd, F_SETFL, flags);

    if (ss_transport == T_TLS) {
#if defined(USE_OPENSSL) || defined(USE_WOLFSSL)
        int rc;
        int i = 0;
        while ((rc = SSL_connect(ss_ssl)) < 0) {
            int err = SSL_get_error(ss_ssl, rc);
            if ((err == SSL_ERROR_WANT_READ || err == SSL_ERROR_WANT_WRITE) &&
                    i < SIPP_SSL_MAX_RETRIES) {
                /* These errors are benign we just need to wait for the socket
                 * to be readable/writable again. */
                WARNING("SSL_connect failed with error: %s. Attempt %d. "
                        "Retrying...", SSL_error_string(err, rc), ++i);
                sipp_usleep(SIPP_SSL_RETRY_TIMEOUT);