// SPDX-License-Identifier: BSD-2-Clause // author: Max Kellermann #pragma once #include #include #include #include #include /** * A first-in-first-out buffer: you can append data at the end, and * read data from the beginning. This class automatically shifts the * buffer as needed. It is not thread safe. */ template class StaticFifoBuffer { public: using size_type = std::size_t; using Range = std::span; protected: size_type head = 0, tail = 0; T data[size]; public: constexpr size_type GetCapacity() const noexcept { return size; } void Shift() noexcept { if (head == 0) return; assert(head <= size); assert(tail <= size); assert(tail >= head); std::move(data + head, data + tail, data); tail -= head; head = 0; } void Clear() noexcept { head = tail = 0; } constexpr bool empty() const noexcept { return head == tail; } constexpr bool IsFull() const noexcept { return head == 0 && tail == size; } /** * Prepares writing. Returns a buffer range which may be written. * When you are finished, call Append(). */ Range Write() noexcept { if (empty()) Clear(); else if (tail == size) Shift(); return Range(data + tail, size - tail); } /** * Expands the tail of the buffer, after data has been written to * the buffer returned by Write(). */ void Append(size_type n) noexcept { assert(tail <= size); assert(n <= size); assert(tail + n <= size); tail += n; } constexpr size_type GetAvailable() const noexcept { return tail - head; } /** * Return a buffer range which may be read. The buffer pointer is * writable, to allow modifications while parsing. */ constexpr Range Read() noexcept { return Range(data + head, tail - head); } /** * Marks a chunk as consumed. */ void Consume(size_type n) noexcept { assert(tail <= size); assert(head <= tail); assert(n <= tail); assert(head + n <= tail); head += n; } };