Method Recv

src/bitcoin-cli.cpp:1121–1153

}

std::optional<std::string> HTTPClient::Recv(const std::chrono::time_point<std::chrono::steady_clock> deadline)
{
    auto wait_for_readable{[this](std::chrono::milliseconds timeout) -> bool {
        Sock::Event event{0};
        if (!m_socket->Wait(timeout, Sock::RecvEvent, &event)) {
            return false;
        }
        return (event & Sock::RecvEvent) != 0;
    }};

    auto time_left = std::chrono::duration_cast<std::chrono::milliseconds>(
        deadline - std::chrono::steady_clock::now());
    if (time_left.count() <= 0 || !wait_for_readable(time_left)) {
        throw CConnectionFailed{"timeout"};
    }

    char recv_buf[4096];
    ssize_t nrecv = m_socket->Recv(recv_buf, sizeof(recv_buf), /*flags=*/0);

    if (nrecv < 0) {
        int err = WSAGetLastError();
        if (!IOErrorIsPermanent(err)) {
            return std::nullopt;
        }
        throw CConnectionFailed{strprintf("Read error: %s", NetworkErrorString(err))};
    }

    if (nrecv == 0) {
        throw RecvEOF{"EOF"};
    }

    return std::string{recv_buf, static_cast<size_t>(nrecv)};
}

static UniValue CallRPC(BaseRequestHandler* rh, const std::string& strMethod, const std::vector<std::string>& args, const std::string& endpoint, const std::string& username)
{