C_SaferCond ctx;
auto req = mirror::EnableRequest<I>::create(
- image_ctx->md_ctx, image_ctx->id,
- static_cast<mirror_image_mode_t>(mirror_image_mode), "",
+ image_ctx->md_ctx, image_ctx->id, mirror_image_mode, "",
image_ctx->op_work_queue, &ctx);
req->send();
r = ctx.wait();
}
C_SaferCond ctx;
- auto req = mirror::EnableRequest<ImageCtx>::create(ictx, mode, &ctx);
+ auto req = mirror::EnableRequest<ImageCtx>::create(
+ ictx, static_cast<cls::rbd::MirrorImageMode>(mode), &ctx);
req->send();
r = ctx.wait();
ContextWQ *op_work_queue;
ImageCtx::get_thread_pool_instance(cct, &thread_pool, &op_work_queue);
C_SaferCond ctx;
- auto req = mirror::EnableRequest<I>::create(io_ctx, image_id,
- RBD_MIRROR_IMAGE_MODE_JOURNAL, "",
- op_work_queue, &ctx);
+ auto req = mirror::EnableRequest<I>::create(
+ io_ctx, image_id, cls::rbd::MIRROR_IMAGE_MODE_JOURNAL, "", op_work_queue,
+ &ctx);
req->send();
r = ctx.wait();
if (r < 0) {
// TODO: in future rbd-mirror will want to enable mirroring
// not only in journal mode.
mirror::EnableRequest<I> *req = mirror::EnableRequest<I>::create(
- m_imctx->md_ctx, m_id, RBD_MIRROR_IMAGE_MODE_JOURNAL,
+ m_imctx->md_ctx, m_id, cls::rbd::MIRROR_IMAGE_MODE_JOURNAL,
m_non_primary_global_image_id, m_imctx->op_work_queue, ctx);
req->send();
}
// TODO: in future rbd-mirror will want to enable mirroring
// not only in journal mode.
- auto req = mirror::EnableRequest<I>::create(m_io_ctx, m_image_id,
- RBD_MIRROR_IMAGE_MODE_JOURNAL,
- m_non_primary_global_image_id,
- m_op_work_queue, ctx);
+ auto req = mirror::EnableRequest<I>::create(
+ m_io_ctx, m_image_id, cls::rbd::MIRROR_IMAGE_MODE_JOURNAL,
+ m_non_primary_global_image_id, m_op_work_queue, ctx);
req->send();
}
template <typename I>
EnableRequest<I>::EnableRequest(librados::IoCtx &io_ctx,
const std::string &image_id,
- mirror_image_mode_t mode,
+ cls::rbd::MirrorImageMode mode,
const std::string &non_primary_global_image_id,
ContextWQ *op_work_queue, Context *on_finish)
: m_io_ctx(io_ctx), m_image_id(image_id),
- m_mode(static_cast<cls::rbd::MirrorImageMode>(mode)),
- m_non_primary_global_image_id(non_primary_global_image_id),
+ m_mode(mode), m_non_primary_global_image_id(non_primary_global_image_id),
m_op_work_queue(op_work_queue), m_on_finish(on_finish),
m_cct(reinterpret_cast<CephContext*>(io_ctx.cct())) {
}
template <typename ImageCtxT = ImageCtx>
class EnableRequest {
public:
- static EnableRequest *create(ImageCtxT *image_ctx, mirror_image_mode_t mode,
+ static EnableRequest *create(ImageCtxT *image_ctx,
+ cls::rbd::MirrorImageMode mode,
Context *on_finish) {
return create(image_ctx->md_ctx, image_ctx->id, mode, "",
image_ctx->op_work_queue, on_finish);
}
static EnableRequest *create(librados::IoCtx &io_ctx,
const std::string &image_id,
- mirror_image_mode_t mode,
+ cls::rbd::MirrorImageMode mode,
const std::string &non_primary_global_image_id,
ContextWQ *op_work_queue, Context *on_finish) {
return new EnableRequest(io_ctx, image_id, mode,
*/
EnableRequest(librados::IoCtx &io_ctx, const std::string &image_id,
- mirror_image_mode_t mode,
+ cls::rbd::MirrorImageMode mode,
const std::string &non_primary_global_image_id,
ContextWQ *op_work_queue, Context *on_finish);
&EnableFeaturesRequest<I>::handle_enable_mirror_image>(this);
mirror::EnableRequest<I> *req = mirror::EnableRequest<I>::create(
- &image_ctx, RBD_MIRROR_IMAGE_MODE_JOURNAL, ctx);
+ &image_ctx, cls::rbd::MIRROR_IMAGE_MODE_JOURNAL, ctx);
req->send();
}
static EnableRequest* s_instance;
static EnableRequest* create(librados::IoCtx &io_ctx,
const std::string &image_id,
- mirror_image_mode_t mode,
+ cls::rbd::MirrorImageMode mode,
const std::string &non_primary_global_image_id,
MockContextWQ *op_work_queue,
Context *on_finish) {
Context *on_finish = nullptr;
static EnableRequest *create(MockOperationImageCtx *image_ctx,
- mirror_image_mode_t mirror_image_mode,
+ cls::rbd::MirrorImageMode mirror_image_mode,
Context *on_finish) {
ceph_assert(s_instance != nullptr);
s_instance->on_finish = on_finish;