1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 #ifndef CEPH_LIBRBD_IMAGE_REFRESH_REQUEST_H
5 #define CEPH_LIBRBD_IMAGE_REFRESH_REQUEST_H
7 #include "include/int_types.h"
8 #include "include/buffer.h"
9 #include "include/utime.h"
10 #include "common/snap_types.h"
11 #include "cls/lock/cls_lock_types.h"
12 #include "librbd/ImageCtx.h"
13 #include "librbd/Types.h"
25 template<typename> class RefreshParentRequest;
27 template<typename ImageCtxT = ImageCtx>
28 class RefreshRequest {
30 static RefreshRequest *create(ImageCtxT &image_ctx, bool acquiring_lock,
31 bool skip_open_parent, Context *on_finish) {
32 return new RefreshRequest(image_ctx, acquiring_lock, skip_open_parent,
36 RefreshRequest(ImageCtxT &image_ctx, bool acquiring_lock,
37 bool skip_open_parent, Context *on_finish);
49 * |-----> V1_READ_HEADER ---> V1_GET_SNAPSHOTS ---> V1_GET_LOCKS
52 * \-----> V2_GET_MUTABLE_METADATA <apply>
61 * V2_GET_SNAPSHOTS (skip if no snaps) |
64 * V2_GET_SNAP_TIMESTAMPS |
67 * V2_GET_SNAP_NAMESPACES |
70 * V2_REFRESH_PARENT (skip if no parent or |
71 * | refresh not needed) |
73 * V2_INIT_EXCLUSIVE_LOCK (skip if lock |
74 * | active or disabled) |
76 * V2_OPEN_OBJECT_MAP (skip if map |
77 * | active or disabled) |
79 * V2_OPEN_JOURNAL (skip if journal |
80 * | active or disabled) |
82 * V2_BLOCK_WRITES (skip if journal not |
88 * V2_FINALIZE_REFRESH_PARENT (skip if refresh |
91 * * * * * > V2_SHUT_DOWN_EXCLUSIVE_LOCK (skip if lock |
92 * | active or enabled) |
94 * V2_CLOSE_JOURNAL (skip if journal inactive |
97 * V2_CLOSE_OBJECT_MAP (skip if map inactive |
100 * \-------------------\/--------------------/
103 * FLUSH (skip if no new
111 ImageCtxT &m_image_ctx;
112 bool m_acquiring_lock;
113 bool m_skip_open_parent_image;
114 Context *m_on_finish;
118 decltype(m_image_ctx.exclusive_lock) m_exclusive_lock;
119 decltype(m_image_ctx.object_map) m_object_map;
120 decltype(m_image_ctx.journal) m_journal;
121 RefreshParentRequest<ImageCtxT> *m_refresh_parent;
128 uint64_t m_incompatible_features;
130 std::string m_object_prefix;
131 ParentInfo m_parent_md;
132 cls::rbd::GroupSpec m_group_spec;
134 ::SnapContext m_snapc;
135 std::vector<std::string> m_snap_names;
136 std::vector<cls::rbd::SnapshotNamespace> m_snap_namespaces;
137 std::vector<uint64_t> m_snap_sizes;
138 std::vector<ParentInfo> m_snap_parents;
139 std::vector<uint8_t> m_snap_protection;
140 std::vector<uint64_t> m_snap_flags;
141 std::vector<utime_t> m_snap_timestamps;
143 std::map<rados::cls::lock::locker_id_t,
144 rados::cls::lock::locker_info_t> m_lockers;
145 std::string m_lock_tag;
146 bool m_exclusive_locked;
148 bool m_blocked_writes = false;
149 bool m_incomplete_update = false;
151 void send_v1_read_header();
152 Context *handle_v1_read_header(int *result);
154 void send_v1_get_snapshots();
155 Context *handle_v1_get_snapshots(int *result);
157 void send_v1_get_locks();
158 Context *handle_v1_get_locks(int *result);
160 void send_v1_apply();
161 Context *handle_v1_apply(int *result);
163 void send_v2_get_mutable_metadata();
164 Context *handle_v2_get_mutable_metadata(int *result);
166 void send_v2_get_flags();
167 Context *handle_v2_get_flags(int *result);
169 void send_v2_get_group();
170 Context *handle_v2_get_group(int *result);
172 void send_v2_get_snapshots();
173 Context *handle_v2_get_snapshots(int *result);
175 void send_v2_get_snap_namespaces();
176 Context *handle_v2_get_snap_namespaces(int *result);
178 void send_v2_get_snap_timestamps();
179 Context *handle_v2_get_snap_timestamps(int *result);
181 void send_v2_refresh_parent();
182 Context *handle_v2_refresh_parent(int *result);
184 void send_v2_init_exclusive_lock();
185 Context *handle_v2_init_exclusive_lock(int *result);
187 void send_v2_open_journal();
188 Context *handle_v2_open_journal(int *result);
190 void send_v2_block_writes();
191 Context *handle_v2_block_writes(int *result);
193 void send_v2_open_object_map();
194 Context *handle_v2_open_object_map(int *result);
196 void send_v2_apply();
197 Context *handle_v2_apply(int *result);
199 Context *send_v2_finalize_refresh_parent();
200 Context *handle_v2_finalize_refresh_parent(int *result);
202 Context *send_v2_shut_down_exclusive_lock();
203 Context *handle_v2_shut_down_exclusive_lock(int *result);
205 Context *send_v2_close_journal();
206 Context *handle_v2_close_journal(int *result);
208 Context *send_v2_close_object_map();
209 Context *handle_v2_close_object_map(int *result);
211 Context *send_flush_aio();
212 Context *handle_flush_aio(int *result);
214 Context *handle_error(int *result);
216 void save_result(int *result) {
217 if (m_error_result == 0 && *result < 0) {
218 m_error_result = *result;
223 int get_parent_info(uint64_t snap_id, ParentInfo *parent_md);
227 } // namespace librbd
229 extern template class librbd::image::RefreshRequest<librbd::ImageCtx>;
231 #endif // CEPH_LIBRBD_IMAGE_REFRESH_REQUEST_H