Stream.hpp

Go to the documentation of this file.

#pragma once
#include "../Stream.hpp"
#include "Connection.hpp"

namespace virt {
constexpr Stream::Stream(virStreamPtr ptr) noexcept : underlying(ptr) {}
inline Stream::Stream(const Connection& conn, Flag flags) noexcept : underlying(virStreamNew(conn.underlying, to_integral(flags))) {}
inline Stream::Stream(const Stream& oth) noexcept : underlying(oth.underlying) {
    if (underlying)
        virStreamRef(underlying);
}
constexpr Stream::Stream(Stream&& from) noexcept : underlying(from.underlying) { from.underlying = nullptr; }
inline Stream::~Stream() noexcept {
    if (underlying)
        virStreamFree(underlying);
}
inline Stream& Stream::operator=(const Stream& oth) noexcept {
    this->~Stream();
    if ((underlying = oth.underlying))
        virStreamRef(underlying);
    return *this;
}
constexpr Stream& Stream::operator=(Stream&& from) noexcept {
    underlying = from.underlying;
    from.underlying = nullptr;
    return *this;
}

inline bool Stream::abort() noexcept { return virStreamAbort(underlying) >= 0; }

inline bool Stream::finish() noexcept { return virStreamFinish(underlying) >= 0; }
inline int Stream::recv(gsl::span<char> span) noexcept { return recv(span.data(), span.size()); }
inline int Stream::recv(char* buf, size_t buflen) noexcept { return virStreamRecv(underlying, buf, buflen); }
inline int Stream::recv(gsl::span<char> span, RecvFlag flags) noexcept { return recv(span.data(), span.size(), flags); }
inline int Stream::recv(char* buf, size_t buflen, RecvFlag flags) noexcept { return virStreamRecvFlags(underlying, buf, buflen, to_integral(flags)); }
inline std::optional<long long> Stream::recvHole() {
    std::optional<long long> ret;
    long long& v = ret.emplace();
    return virStreamRecvHole(underlying, &v, 0) >= 0 ? ret : std::nullopt;
}
inline int Stream::send(gsl::span<const char> span) noexcept { return send(span.data(), span.size()); }
inline int Stream::send(const char* buf, size_t buflen) noexcept { return virStreamSend(underlying, buf, buflen); }
inline bool Stream::sendHole(long long len) noexcept { return virStreamSendHole(underlying, len, 0) >= 0; }
}