Method ReceiveAndProcess

src/torcontrol.cpp:148–177

}

bool TorControlConnection::ReceiveAndProcess()
{
    if (!m_sock) return false;

    std::byte buf[4096];
    ssize_t nread = m_sock->Recv(buf, sizeof(buf), MSG_DONTWAIT);

    if (nread < 0) {
        int err = WSAGetLastError();
        if (err == WSAEWOULDBLOCK || err == WSAEINTR || err == WSAEINPROGRESS) {
            // No data available currently
            return true;
        }
        LogWarning("tor: Error reading from socket: %s", NetworkErrorString(err));
        return false;
    }

    if (nread == 0) {
        LogDebug(BCLog::TOR, "End of stream");
        return false;
    }

    m_recv_buffer.insert(m_recv_buffer.end(), buf, buf + nread);
    try {
        return ProcessBuffer();
    } catch (const std::runtime_error& e) {
        LogWarning("tor: Error processing receive buffer: %s", e.what());
        return false;
    }
}

bool TorControlConnection::ProcessBuffer()
{