diff options
Diffstat (limited to 'src/librbd/io/Utils.h')
-rw-r--r-- | src/librbd/io/Utils.h | 79 |
1 files changed, 79 insertions, 0 deletions
diff --git a/src/librbd/io/Utils.h b/src/librbd/io/Utils.h new file mode 100644 index 000000000..9f7e0b946 --- /dev/null +++ b/src/librbd/io/Utils.h @@ -0,0 +1,79 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab + +#ifndef CEPH_LIBRBD_IO_UTILS_H +#define CEPH_LIBRBD_IO_UTILS_H + +#include "include/int_types.h" +#include "include/buffer_fwd.h" +#include "include/rados/rados_types.hpp" +#include "common/zipkin_trace.h" +#include "librbd/Types.h" +#include "librbd/io/Types.h" +#include <map> + +class ObjectExtent; + +namespace neorados { struct Op; } + +namespace librbd { + +struct ImageCtx; + +namespace io { +namespace util { + +void apply_op_flags(uint32_t op_flags, uint32_t flags, neorados::Op* op); + +bool assemble_write_same_extent(const LightweightObjectExtent &object_extent, + const ceph::bufferlist& data, + ceph::bufferlist *ws_data, + bool force_write); + +template <typename ImageCtxT = librbd::ImageCtx> +void read_parent(ImageCtxT *image_ctx, uint64_t object_no, + ReadExtents* extents, librados::snap_t snap_id, + const ZTracer::Trace &trace, Context* on_finish); + +template <typename ImageCtxT = librbd::ImageCtx> +int clip_request(ImageCtxT *image_ctx, Extents *image_extents); + +inline uint64_t get_extents_length(const Extents &extents) { + uint64_t total_bytes = 0; + for (auto [_, extent_length] : extents) { + total_bytes += extent_length; + } + return total_bytes; +} + +void unsparsify(CephContext* cct, ceph::bufferlist* bl, + const Extents& extent_map, uint64_t bl_off, + uint64_t out_bl_len); + +template <typename ImageCtxT = librbd::ImageCtx> +bool trigger_copyup(ImageCtxT *image_ctx, uint64_t object_no, + IOContext io_context, Context* on_finish); + +template <typename ImageCtxT = librbd::ImageCtx> +void file_to_extents(ImageCtxT *image_ctx, uint64_t offset, uint64_t length, + uint64_t buffer_offset, + striper::LightweightObjectExtents* object_extents); + +template <typename ImageCtxT = librbd::ImageCtx> +void extent_to_file(ImageCtxT *image_ctx, uint64_t object_no, uint64_t offset, + uint64_t length, + std::vector<std::pair<uint64_t, uint64_t> >& extents); + +template <typename ImageCtxT = librbd::ImageCtx> +uint64_t get_file_offset(ImageCtxT *image_ctx, uint64_t object_no, + uint64_t offset); + +inline ObjectDispatchLayer get_previous_layer(ObjectDispatchLayer layer) { + return (ObjectDispatchLayer)(((int)layer) - 1); +} + +} // namespace util +} // namespace io +} // namespace librbd + +#endif // CEPH_LIBRBD_IO_UTILS_H |