From 56ae875861ab260b80a030f50c4aff9f9dc8fff0 Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sat, 13 Apr 2024 13:32:39 +0200 Subject: Adding upstream version 2.14.2. Signed-off-by: Daniel Baumann --- lib/base/fifo.hpp | 48 ++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 48 insertions(+) create mode 100644 lib/base/fifo.hpp (limited to 'lib/base/fifo.hpp') diff --git a/lib/base/fifo.hpp b/lib/base/fifo.hpp new file mode 100644 index 0000000..a8273c1 --- /dev/null +++ b/lib/base/fifo.hpp @@ -0,0 +1,48 @@ +/* Icinga 2 | (c) 2012 Icinga GmbH | GPLv2+ */ + +#ifndef FIFO_H +#define FIFO_H + +#include "base/i2-base.hpp" +#include "base/stream.hpp" + +namespace icinga +{ + +/** + * A byte-based FIFO buffer. + * + * @ingroup base + */ +class FIFO final : public Stream +{ +public: + DECLARE_PTR_TYPEDEFS(FIFO); + + static const size_t BlockSize = 512; + + ~FIFO() override; + + size_t Peek(void *buffer, size_t count, bool allow_partial = false) override; + size_t Read(void *buffer, size_t count, bool allow_partial = false) override; + void Write(const void *buffer, size_t count) override; + void Close() override; + bool IsEof() const override; + bool SupportsWaiting() const override; + bool IsDataAvailable() const override; + + size_t GetAvailableBytes() const; + +private: + char *m_Buffer{nullptr}; + size_t m_DataSize{0}; + size_t m_AllocSize{0}; + size_t m_Offset{0}; + + void ResizeBuffer(size_t newSize, bool decrease); + void Optimize(); +}; + +} + +#endif /* FIFO_H */ -- cgit v1.2.3