From e6918187568dbd01842d8d1d2c808ce16a894239 Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 21 Apr 2024 13:54:28 +0200 Subject: Adding upstream version 18.2.2. Signed-off-by: Daniel Baumann --- src/librbd/io/ObjectDispatcher.h | 60 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 60 insertions(+) create mode 100644 src/librbd/io/ObjectDispatcher.h (limited to 'src/librbd/io/ObjectDispatcher.h') diff --git a/src/librbd/io/ObjectDispatcher.h b/src/librbd/io/ObjectDispatcher.h new file mode 100644 index 000000000..1e5e78d8b --- /dev/null +++ b/src/librbd/io/ObjectDispatcher.h @@ -0,0 +1,60 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab + +#ifndef CEPH_LIBRBD_IO_OBJECT_DISPATCHER_H +#define CEPH_LIBRBD_IO_OBJECT_DISPATCHER_H + +#include "include/int_types.h" +#include "common/ceph_mutex.h" +#include "librbd/io/Dispatcher.h" +#include "librbd/io/ObjectDispatchInterface.h" +#include "librbd/io/ObjectDispatchSpec.h" +#include "librbd/io/ObjectDispatcherInterface.h" +#include "librbd/io/Types.h" +#include + +struct Context; + +namespace librbd { + +struct ImageCtx; + +namespace io { + +template +class ObjectDispatcher + : public Dispatcher { +public: + ObjectDispatcher(ImageCtxT* image_ctx); + + void invalidate_cache(Context* on_finish) override; + void reset_existence_cache(Context* on_finish) override; + + void extent_overwritten( + uint64_t object_no, uint64_t object_off, uint64_t object_len, + uint64_t journal_tid, uint64_t new_journal_tid) override; + + int prepare_copyup( + uint64_t object_no, + SnapshotSparseBufferlist* snapshot_sparse_bufferlist) override; + + using typename Dispatcher::C_LayerIterator; + + using typename Dispatcher::C_InvalidateCache; + +protected: + bool send_dispatch(ObjectDispatchInterface* object_dispatch, + ObjectDispatchSpec* object_dispatch_spec) override; + +private: + struct C_ResetExistenceCache; + struct SendVisitor; + +}; + +} // namespace io +} // namespace librbd + +extern template class librbd::io::ObjectDispatcher; + +#endif // CEPH_LIBRBD_IO_OBJECT_DISPATCHER_H -- cgit v1.2.3