ceph/src/librbd/io/ImageDispatch.h

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab
   3
   4 #ifndef CEPH_LIBRBD_IO_IMAGE_DISPATCH_H
   5 #define CEPH_LIBRBD_IO_IMAGE_DISPATCH_H
   6
   7 #include "librbd/io/ImageDispatchInterface.h"
   8 #include "include/int_types.h"
   9 #include "include/buffer.h"
  10 #include "common/zipkin_trace.h"
  11 #include "librbd/io/ReadResult.h"
  12 #include "librbd/io/Types.h"
  13
  14 struct Context;
  15
  16 namespace librbd {
  17
  18 struct ImageCtx;
  19
  20 namespace io {
  21
  22 struct AioCompletion;
  23
  24 template <typename ImageCtxT>
  25 class ImageDispatch : public ImageDispatchInterface {
  26 public:
  27   ImageDispatch(ImageCtxT* image_ctx) : m_image_ctx(image_ctx) {
  28   }
  29
  30   ImageDispatchLayer get_dispatch_layer() const override {
  31     return IMAGE_DISPATCH_LAYER_CORE;
  32   }
  33
  34   void shut_down(Context* on_finish) override;
  35
  36   bool read(
  37       AioCompletion* aio_comp, Extents &&image_extents,
  38       ReadResult &&read_result, IOContext io_context, int op_flags,
  39       int read_flags, const ZTracer::Trace &parent_trace, uint64_t tid,
  40       std::atomic<uint32_t>* image_dispatch_flags,
  41       DispatchResult* dispatch_result, Context** on_finish,
  42       Context* on_dispatched) override;
  43   bool write(
  44       AioCompletion* aio_comp, Extents &&image_extents, bufferlist &&bl,
  45       int op_flags, const ZTracer::Trace &parent_trace,
  46       uint64_t tid, std::atomic<uint32_t>* image_dispatch_flags,
  47       DispatchResult* dispatch_result, Context** on_finish,
  48       Context* on_dispatched) override;
  49   bool discard(
  50       AioCompletion* aio_comp, Extents &&image_extents,
  51       uint32_t discard_granularity_bytes, const ZTracer::Trace &parent_trace,
  52       uint64_t tid, std::atomic<uint32_t>* image_dispatch_flags,
  53       DispatchResult* dispatch_result, Context** on_finish,
  54       Context* on_dispatched) override;
  55   bool write_same(
  56       AioCompletion* aio_comp, Extents &&image_extents, bufferlist &&bl,
  57       int op_flags, const ZTracer::Trace &parent_trace,
  58       uint64_t tid, std::atomic<uint32_t>* image_dispatch_flags,
  59       DispatchResult* dispatch_result, Context** on_finish,
  60       Context* on_dispatched) override;
  61   bool compare_and_write(
  62       AioCompletion* aio_comp, Extents &&image_extents,
  63       bufferlist &&cmp_bl, bufferlist &&bl, uint64_t *mismatch_offset,
  64       int op_flags, const ZTracer::Trace &parent_trace,
  65       uint64_t tid, std::atomic<uint32_t>* image_dispatch_flags,
  66       DispatchResult* dispatch_result, Context** on_finish,
  67       Context* on_dispatched) override;
  68   bool flush(
  69       AioCompletion* aio_comp, FlushSource flush_source,
  70       const ZTracer::Trace &parent_trace, uint64_t tid,
  71       std::atomic<uint32_t>* image_dispatch_flags,
  72       DispatchResult* dispatch_result, Context** on_finish,
  73       Context* on_dispatched) override;
  74
  75   bool list_snaps(
  76       AioCompletion* aio_comp, Extents&& image_extents, SnapIds&& snap_ids,
  77       int list_snaps_flags, SnapshotDelta* snapshot_delta,
  78       const ZTracer::Trace &parent_trace, uint64_t tid,
  79       std::atomic<uint32_t>* image_dispatch_flags,
  80       DispatchResult* dispatch_result, Context** on_finish,
  81       Context* on_dispatched) override;
  82
  83   bool invalidate_cache(Context* on_finish) override;
  84
  85 private:
  86   ImageCtxT* m_image_ctx;
  87
  88 };
  89
  90 } // namespace io
  91 } // namespace librbd
  92
  93 extern template class librbd::io::ImageDispatch<librbd::ImageCtx>;
  94
  95 #endif // CEPH_LIBRBD_IO_IMAGE_DISPATCH_H