1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 #include "librbd/operation/SnapshotRollbackRequest.h"
5 #include "include/rados/librados.hpp"
6 #include "common/dout.h"
7 #include "common/errno.h"
8 #include "librbd/AsyncObjectThrottle.h"
9 #include "librbd/ImageCtx.h"
10 #include "librbd/ObjectMap.h"
11 #include "librbd/Utils.h"
12 #include "librbd/io/ImageRequestWQ.h"
13 #include "librbd/operation/ResizeRequest.h"
14 #include "osdc/Striper.h"
15 #include <boost/lambda/bind.hpp>
16 #include <boost/lambda/construct.hpp>
18 #define dout_subsys ceph_subsys_rbd
20 #define dout_prefix *_dout << "librbd::SnapshotRollbackRequest: "
25 using util::create_context_callback;
26 using util::create_rados_callback;
31 class C_RollbackObject : public C_AsyncObjectThrottle<I> {
33 C_RollbackObject(AsyncObjectThrottle<I> &throttle, I *image_ctx,
34 uint64_t snap_id, uint64_t object_num)
35 : C_AsyncObjectThrottle<I>(throttle, *image_ctx), m_snap_id(snap_id),
36 m_object_num(object_num) {
40 I &image_ctx = this->m_image_ctx;
41 CephContext *cct = image_ctx.cct;
42 ldout(cct, 20) << "C_RollbackObject: " << __func__ << ": object_num="
43 << m_object_num << dendl;
45 std::string oid = image_ctx.get_object_name(m_object_num);
47 librados::ObjectWriteOperation op;
48 op.selfmanaged_snap_rollback(m_snap_id);
50 librados::AioCompletion *rados_completion =
51 util::create_rados_callback(this);
52 image_ctx.data_ctx.aio_operate(oid, rados_completion, &op);
53 rados_completion->release();
59 uint64_t m_object_num;
62 } // anonymous namespace
65 SnapshotRollbackRequest<I>::SnapshotRollbackRequest(I &image_ctx,
67 const cls::rbd::SnapshotNamespace &snap_namespace,
68 const std::string &snap_name,
71 ProgressContext &prog_ctx)
72 : Request<I>(image_ctx, on_finish), m_snap_namespace(snap_namespace),
73 m_snap_name(snap_name), m_snap_id(snap_id),
74 m_snap_size(snap_size), m_prog_ctx(prog_ctx), m_object_map(nullptr) {
78 SnapshotRollbackRequest<I>::~SnapshotRollbackRequest() {
79 I &image_ctx = this->m_image_ctx;
80 if (m_blocking_writes) {
81 image_ctx.io_work_queue->unblock_writes();
87 void SnapshotRollbackRequest<I>::send_op() {
92 void SnapshotRollbackRequest<I>::send_block_writes() {
93 I &image_ctx = this->m_image_ctx;
94 CephContext *cct = image_ctx.cct;
95 ldout(cct, 5) << this << " " << __func__ << dendl;
97 m_blocking_writes = true;
98 image_ctx.io_work_queue->block_writes(create_context_callback<
99 SnapshotRollbackRequest<I>,
100 &SnapshotRollbackRequest<I>::handle_block_writes>(this));
103 template <typename I>
104 Context *SnapshotRollbackRequest<I>::handle_block_writes(int *result) {
105 I &image_ctx = this->m_image_ctx;
106 CephContext *cct = image_ctx.cct;
107 ldout(cct, 5) << this << " " << __func__ << ": r=" << *result << dendl;
110 lderr(cct) << "failed to block writes: " << cpp_strerror(*result) << dendl;
111 return this->create_context_finisher(*result);
118 template <typename I>
119 void SnapshotRollbackRequest<I>::send_resize_image() {
120 I &image_ctx = this->m_image_ctx;
122 uint64_t current_size;
124 RWLock::RLocker owner_locker(image_ctx.owner_lock);
125 RWLock::RLocker snap_locker(image_ctx.snap_lock);
126 current_size = image_ctx.get_image_size(CEPH_NOSNAP);
129 if (current_size == m_snap_size) {
130 send_rollback_object_map();
134 CephContext *cct = image_ctx.cct;
135 ldout(cct, 5) << this << " " << __func__ << dendl;
137 Context *ctx = create_context_callback<
138 SnapshotRollbackRequest<I>,
139 &SnapshotRollbackRequest<I>::handle_resize_image>(this);
140 ResizeRequest<I> *req = ResizeRequest<I>::create(image_ctx, ctx, m_snap_size,
141 true, m_no_op_prog_ctx, 0, true);
145 template <typename I>
146 Context *SnapshotRollbackRequest<I>::handle_resize_image(int *result) {
147 I &image_ctx = this->m_image_ctx;
148 CephContext *cct = image_ctx.cct;
149 ldout(cct, 5) << this << " " << __func__ << ": r=" << *result << dendl;
152 lderr(cct) << "failed to resize image for rollback: "
153 << cpp_strerror(*result) << dendl;
154 return this->create_context_finisher(*result);
157 send_rollback_object_map();
161 template <typename I>
162 void SnapshotRollbackRequest<I>::send_rollback_object_map() {
163 I &image_ctx = this->m_image_ctx;
166 RWLock::RLocker owner_locker(image_ctx.owner_lock);
167 RWLock::RLocker snap_locker(image_ctx.snap_lock);
168 RWLock::WLocker object_map_lock(image_ctx.object_map_lock);
169 if (image_ctx.object_map != nullptr) {
170 CephContext *cct = image_ctx.cct;
171 ldout(cct, 5) << this << " " << __func__ << dendl;
173 Context *ctx = create_context_callback<
174 SnapshotRollbackRequest<I>,
175 &SnapshotRollbackRequest<I>::handle_rollback_object_map>(this);
176 image_ctx.object_map->rollback(m_snap_id, ctx);
181 send_rollback_objects();
184 template <typename I>
185 Context *SnapshotRollbackRequest<I>::handle_rollback_object_map(int *result) {
186 I &image_ctx = this->m_image_ctx;
187 CephContext *cct = image_ctx.cct;
188 ldout(cct, 5) << this << " " << __func__ << ": r=" << *result << dendl;
190 assert(*result == 0);
191 send_rollback_objects();
195 template <typename I>
196 void SnapshotRollbackRequest<I>::send_rollback_objects() {
197 I &image_ctx = this->m_image_ctx;
198 CephContext *cct = image_ctx.cct;
199 ldout(cct, 5) << this << " " << __func__ << dendl;
201 RWLock::RLocker owner_locker(image_ctx.owner_lock);
202 uint64_t num_objects;
204 RWLock::RLocker snap_locker(image_ctx.snap_lock);
205 num_objects = Striper::get_num_objects(image_ctx.layout,
206 image_ctx.get_current_size());
209 Context *ctx = create_context_callback<
210 SnapshotRollbackRequest<I>,
211 &SnapshotRollbackRequest<I>::handle_rollback_objects>(this);
212 typename AsyncObjectThrottle<I>::ContextFactory context_factory(
213 boost::lambda::bind(boost::lambda::new_ptr<C_RollbackObject<I> >(),
214 boost::lambda::_1, &image_ctx, m_snap_id, boost::lambda::_2));
215 AsyncObjectThrottle<I> *throttle = new AsyncObjectThrottle<I>(
216 this, image_ctx, context_factory, ctx, &m_prog_ctx, 0, num_objects);
217 throttle->start_ops(image_ctx.concurrent_management_ops);
220 template <typename I>
221 Context *SnapshotRollbackRequest<I>::handle_rollback_objects(int *result) {
222 I &image_ctx = this->m_image_ctx;
223 CephContext *cct = image_ctx.cct;
224 ldout(cct, 5) << this << " " << __func__ << ": r=" << *result << dendl;
226 if (*result == -ERESTART) {
227 ldout(cct, 5) << "snapshot rollback operation interrupted" << dendl;
228 return this->create_context_finisher(*result);
229 } else if (*result < 0) {
230 lderr(cct) << "failed to rollback objects: " << cpp_strerror(*result)
232 return this->create_context_finisher(*result);
235 return send_refresh_object_map();
238 template <typename I>
239 Context *SnapshotRollbackRequest<I>::send_refresh_object_map() {
240 I &image_ctx = this->m_image_ctx;
242 bool object_map_enabled;
244 RWLock::RLocker owner_locker(image_ctx.owner_lock);
245 RWLock::RLocker snap_locker(image_ctx.snap_lock);
246 object_map_enabled = (image_ctx.object_map != nullptr);
248 if (!object_map_enabled) {
249 return send_invalidate_cache();
252 CephContext *cct = image_ctx.cct;
253 ldout(cct, 5) << this << " " << __func__ << dendl;
255 m_object_map = image_ctx.create_object_map(CEPH_NOSNAP);
257 Context *ctx = create_context_callback<
258 SnapshotRollbackRequest<I>,
259 &SnapshotRollbackRequest<I>::handle_refresh_object_map>(this);
260 m_object_map->open(ctx);
264 template <typename I>
265 Context *SnapshotRollbackRequest<I>::handle_refresh_object_map(int *result) {
266 I &image_ctx = this->m_image_ctx;
267 CephContext *cct = image_ctx.cct;
268 ldout(cct, 5) << this << " " << __func__ << ": r=" << *result << dendl;
270 assert(*result == 0);
271 return send_invalidate_cache();
274 template <typename I>
275 Context *SnapshotRollbackRequest<I>::send_invalidate_cache() {
276 I &image_ctx = this->m_image_ctx;
279 if (image_ctx.object_cacher == NULL) {
280 return this->create_context_finisher(0);
283 CephContext *cct = image_ctx.cct;
284 ldout(cct, 5) << this << " " << __func__ << dendl;
286 RWLock::RLocker owner_lock(image_ctx.owner_lock);
287 Context *ctx = create_context_callback<
288 SnapshotRollbackRequest<I>,
289 &SnapshotRollbackRequest<I>::handle_invalidate_cache>(this);
290 image_ctx.invalidate_cache(true, ctx);
294 template <typename I>
295 Context *SnapshotRollbackRequest<I>::handle_invalidate_cache(int *result) {
296 I &image_ctx = this->m_image_ctx;
297 CephContext *cct = image_ctx.cct;
298 ldout(cct, 5) << this << " " << __func__ << ": r=" << *result << dendl;
301 lderr(cct) << "failed to invalidate cache: " << cpp_strerror(*result)
304 return this->create_context_finisher(*result);
307 template <typename I>
308 void SnapshotRollbackRequest<I>::apply() {
309 I &image_ctx = this->m_image_ctx;
311 RWLock::RLocker owner_locker(image_ctx.owner_lock);
312 RWLock::WLocker snap_locker(image_ctx.snap_lock);
313 if (image_ctx.object_map != nullptr) {
314 std::swap(m_object_map, image_ctx.object_map);
318 } // namespace operation
319 } // namespace librbd
321 template class librbd::operation::SnapshotRollbackRequest<librbd::ImageCtx>;