Method receive_bytes

C++/dgramoverstream.cpp:216–233

Places up to n bytes into this->RECV_BUF.

// Places up to n bytes into this->RECV_BUF.
ssize_t dgram_over_stream::receive_bytes(size_t n) {
    if (n == 0) return 0;

    // Ignore rest of message.
    ssize_t rest_len = n > RECV_BUF_SIZE ? RECV_BUF_SIZE : n;
    size_t pos = 0;

    while (rest_len > 0) {
        ssize_t recvd = inner->rcv(RECV_BUF + pos, rest_len, 0);

        if (recvd <= 0) return n - rest_len;

        rest_len -= recvd;
        pos += recvd;
    }

    return pos;
}

/**
 * @brief Receive and decode length header.