Method connect

src/SFML/Network/Sftp.cpp:562–650

///////////////////////////////////////////////////////

////////////////////////////////////////////////////////////
Sftp::Result Sftp::connect(IpAddress server, unsigned short port, const TimeoutWithPredicate& timeout)
{
    (void)disconnect(timeout);

    if (const auto status = m_impl->socket.connect(server, port);
        (status == Socket::Status::Error) || (status == Socket::Status::Disconnected))
        return Result(Result::Value::Disconnected);

    m_impl->selectorRecv.clear();
    m_impl->selectorSend.clear();
    m_impl->selectorEither.clear();
    m_impl->selectorRecv.add(m_impl->socket, sf::SocketSelector::Receive);
    m_impl->selectorSend.add(m_impl->socket, sf::SocketSelector::Send);
    m_impl->selectorEither.add(m_impl->socket, sf::SocketSelector::Receive | sf::SocketSelector::Send);

    // Wait for the socket to become connected
    while (true)
    {
        if (m_impl->selectorSend.wait(timeout.getPeriod()))
            break;

        if (!timeout.getPredicate()())
        {
            m_impl->selectorRecv.clear();
            m_impl->selectorSend.clear();
            m_impl->selectorEither.clear();
            m_impl->socket.disconnect();
            return Result(Result::Value::Timeout);
        }
    }

    // Check if our connection was actually accepted or refused
    if (!m_impl->socket.getRemoteAddress().has_value())
    {
        m_impl->selectorRecv.clear();
        m_impl->selectorSend.clear();
        m_impl->selectorEither.clear();
        m_impl->socket.disconnect();
        return Result(Result::Value::Refused);
    }

    // At this point the TCP connection is established

    // Reset POSIX rename supported flag to assume true for new connections
    m_impl->posixRenameSupported = true;

    // Set up SSH session
    m_impl->ssh2Session.reset(libssh2_session_init_ex(nullptr, nullptr, nullptr, m_impl.get()));
    assert(m_impl->ssh2Session);

    // Tell libssh2 we will take care of waiting on socket readiness ourselves
    libssh2_session_set_blocking(m_impl->ssh2Session.get(), 0);

    // Set send and receive callbacks to make use of TcpSocket as the underlying transport
#if (LIBSSH2_VERSION_NUM >= 0x010b01)
    libssh2_session_callback_set2(m_impl->ssh2Session.get(),
                                  LIBSSH2_CALLBACK_SEND,
                                  reinterpret_cast<libssh2_cb_generic*>(Impl::handleSend));