Method receiveBytes

src/IO/SilkFiberStreamSocketImpl.cpp:172–213

}

int FiberStreamSocketImpl::receiveBytes(void * buffer, int length, int flags)
{
    if (flags != 0)
        throw DB::Exception(
            DB::ErrorCodes::LOGICAL_ERROR,
            "Silk::FiberStreamSocketImpl::receiveBytes: non-zero flags ({}) not supported",
            flags);

    throttleRecv(static_cast<size_t>(length), getBlocking());

    uint64_t bytes_read = 0;
    silk::FiberScheduler::IoFuture future;
    iovec iov{buffer, static_cast<size_t>(length)};
    silk::FiberScheduler::read(sockfd(), &iov, 1, 0, &bytes_read, &future);

    Poco::Timespan timeout = getReceiveTimeout();
    int r = 0;
    if (timeout.totalMicroseconds() > 0)
    {
        r = silk::FiberFuture::waitWithTimeout(
            &future,
            static_cast<uint64_t>(timeout.totalMicroseconds()) * 1000);
        if (r == ETIMEDOUT)
        {
            future.cancel();
            r = future.wait();
            if (r == ECANCELED)
                throw Poco::TimeoutException("Receive timed out", peerAddress().toString());
        }
    }
    else
    {
        r = future.wait();
    }

    if (r)
        error(r, "recv");

    useRecvThrottlerBudget(static_cast<int>(bytes_read));

    return static_cast<int>(bytes_read);
}

void FiberStreamSocketImpl::setBlocking(bool flag)
{