1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
#include "common/Timer.h"
#include "librbd/plugin/Api.h"
#include "librbd/ImageCtx.h"
#include "librbd/io/AioCompletion.h"
#include "librbd/io/Utils.h"
#include "librbd/Operations.h"
#include "librbd/Utils.h"
namespace librbd {
namespace plugin {
template <typename I>
void Api<I>::read_parent(
I *image_ctx, uint64_t object_no, io::ReadExtents* extents,
librados::snap_t snap_id, const ZTracer::Trace &trace,
Context* on_finish) {
io::util::read_parent<I>(image_ctx, object_no, extents, snap_id, trace,
on_finish);
}
template <typename I>
void Api<I>::execute_image_metadata_set(
I *image_ctx, const std::string &key,
const std::string &value, Context *on_finish) {
ImageCtx* ictx = util::get_image_ctx(image_ctx);
ictx->operations->execute_metadata_set(key, value, on_finish);
}
template <typename I>
void Api<I>::execute_image_metadata_remove(
I *image_ctx, const std::string &key, Context *on_finish) {
ImageCtx* ictx = util::get_image_ctx(image_ctx);
ictx->operations->execute_metadata_remove(key, on_finish);
}
template <typename I>
void Api<I>::get_image_timer_instance(
CephContext *cct, SafeTimer **timer, ceph::mutex **timer_lock) {
ImageCtx::get_timer_instance(cct, timer, timer_lock);
}
template <typename I>
bool Api<I>::test_image_features(I *image_ctx, uint64_t features) {
return image_ctx->test_features(features);
}
template <typename I>
void Api<I>::update_aio_comp(io::AioCompletion* aio_comp,
uint32_t request_count,
io::ReadResult &read_result,
io::Extents &image_extents) {
aio_comp->set_request_count(request_count);
aio_comp->read_result = std::move(read_result);
aio_comp->read_result.set_image_extents(image_extents);
start_in_flight_io(aio_comp);
}
template <typename I>
void Api<I>::update_aio_comp(
io::AioCompletion* aio_comp, uint32_t request_count) {
aio_comp->set_request_count(request_count);
start_in_flight_io(aio_comp);
}
template <typename I>
io::ReadResult::C_ImageReadRequest* Api<I>::create_image_read_request(
io::AioCompletion* aio_comp, uint64_t buffer_offset,
const Extents& image_extents) {
return new io::ReadResult::C_ImageReadRequest(
aio_comp, buffer_offset, image_extents);
}
template <typename I>
io::C_AioRequest* Api<I>::create_aio_request(io::AioCompletion* aio_comp) {
io::C_AioRequest *req_comp = new io::C_AioRequest(aio_comp);
return req_comp;
}
template <typename I>
void Api<I>::start_in_flight_io(io::AioCompletion* aio_comp) {
if (!aio_comp->async_op.started()) {
aio_comp->start_op();
}
}
} // namespace plugin
} // namespace librbd
template class librbd::plugin::Api<librbd::ImageCtx>;
|
