Method rcvmsg

C++/dgramoverstream.cpp:81–110

* @brief Receive a message and place it into dst. * * No more than dst.size() bytes will be received and placed into dst. */

 * No more than dst.size() bytes will be received and placed into dst.
 */
ssize_t dgram_over_stream::rcvmsg(std::string* dst) {
    uint32_t expected = receive_header();

    if (expected <= dst->size()) dst->resize(expected);

    size_t to_receive = dst->size();
    size_t received = 0;

    while (received < to_receive) {
        ssize_t result = receive_bytes(to_receive - received);

        if (result < 0)
            throw socket_exception(
                __FILE__, __LINE__,
                "dgram_over_stream::rcvmsg(): Could not receive message!",
                false);

        dst->replace(received, result, RECV_BUF);

        received += (size_t)result;
    }

    // Consume remaining frame that doesn't fit into dst.
    ssize_t rest = expected - to_receive;
    while (rest > 0) {
        rest -= receive_bytes(rest);
    }

    return received;
}

/**
 * @brief Send the message `msg` as one frame.