]>
git.proxmox.com Git - ceph.git/blob - ceph/src/librbd/image/RefreshRequest.h
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