read_buffer.cpp

 
// UFO
#include <ufo/utility/io/read_buffer.hpp>
 
// STL
#include <algorithm>
#include <cstring>
 
namespace ufo
{
ReadBuffer::ReadBuffer(std::byte const* data, size_type count) : BaseBuffer(data, count)
{
}
 
ReadBuffer& ReadBuffer::read(void* dest, size_type count)
{
    readAt(pos_, dest, count);
    pos_ += count;
    return *this;
}
 
ReadBuffer& ReadBuffer::read(std::ostream& out, size_type count)
{
    readAt(pos_, out, count);
    pos_ += count;
    return *this;
}
 
void ReadBuffer::readAt(pos_type pos, void* dest, size_type count) const
{
    if (size() < pos) [[unlikely]] {
        // TODO: Fill in exception message
        throw std::out_of_range("");
    }
 
    std::memmove(dest, data_ + pos, count);
}
 
void ReadBuffer::readAt(pos_type pos, std::ostream& out, size_type count) const
{
    if (size() < pos) [[unlikely]] {
        // TODO: Fill in exception message
        throw std::out_of_range("");
    }
 
    out.write(reinterpret_cast<char const*>(data_ + pos),
              static_cast<std::streamsize>(count));
}
 
void ReadBuffer::readAt(offset_type off, IODir dir, void* dest, size_type count) const
{
    readAt(pos(pos_, off, dir), dest, count);
}
 
void ReadBuffer::readAt(offset_type off, IODir dir, std::ostream& out,
                        size_type count) const
{
    readAt(pos(pos_, off, dir), out, count);
}
 
bool ReadBuffer::readLine(std::string& line)
{
    // FIXME: Implement correct
    std::byte const* it = std::find_if(data_ + pos_, data_ + size_, [](std::byte b) {
        return '\n' == static_cast<char>(b);
    });
    line.assign(reinterpret_cast<char const*>(data_ + pos_),
                reinterpret_cast<char const*>(it));
    pos_ = std::min(size_, pos_ + line.size() + 1);
    return pos_ != size_;
}
 
ReadBuffer::pos_type ReadBuffer::readPos() const noexcept { return pos_; }
 
ReadBuffer& ReadBuffer::readSeek(pos_type pos) noexcept
{
    pos_ = pos;
    return *this;
}
 
ReadBuffer& ReadBuffer::readSeek(offset_type off, IODir dir) noexcept
{
    return readSeek(pos(pos_, off, dir));
}
 
ReadBuffer::size_type ReadBuffer::readLeft() const noexcept
{
    return size_ < pos_ ? 0 : pos_ - size_;
}
}  // namespace ufo