From 19fcec84d8d7d21e796c7624e521b60d28ee21ed Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 7 Apr 2024 20:45:59 +0200 Subject: Adding upstream version 16.2.11+ds. Signed-off-by: Daniel Baumann --- src/rbd_replay/BufferReader.h | 34 ++++++++++++++++++++++++++++++++++ 1 file changed, 34 insertions(+) create mode 100644 src/rbd_replay/BufferReader.h (limited to 'src/rbd_replay/BufferReader.h') diff --git a/src/rbd_replay/BufferReader.h b/src/rbd_replay/BufferReader.h new file mode 100644 index 000000000..38a105774 --- /dev/null +++ b/src/rbd_replay/BufferReader.h @@ -0,0 +1,34 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab + +#ifndef CEPH_RBD_REPLAY_BUFFER_READER_H +#define CEPH_RBD_REPLAY_BUFFER_READER_H + +#include "include/int_types.h" +#include "include/buffer.h" + +namespace rbd_replay { + +class BufferReader { +public: + static const size_t DEFAULT_MIN_BYTES = 1<<20; + static const size_t DEFAULT_MAX_BYTES = 1<<22; + + BufferReader(int fd, size_t min_bytes = DEFAULT_MIN_BYTES, + size_t max_bytes = DEFAULT_MAX_BYTES); + + int fetch(bufferlist::const_iterator **it); + +private: + int m_fd; + size_t m_min_bytes; + size_t m_max_bytes; + bufferlist m_bl; + bufferlist::const_iterator m_bl_it; + bool m_eof_reached; + +}; + +} // namespace rbd_replay + +#endif // CEPH_RBD_REPLAY_BUFFER_READER_H -- cgit v1.2.3