X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibrbd%2Fjournal%2FCreateRequest.cc;fp=src%2Fceph%2Fsrc%2Flibrbd%2Fjournal%2FCreateRequest.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=033d992c848250b5b8c251aca6c4c19ff87c85a0;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/librbd/journal/CreateRequest.cc b/src/ceph/src/librbd/journal/CreateRequest.cc deleted file mode 100644 index 033d992..0000000 --- a/src/ceph/src/librbd/journal/CreateRequest.cc +++ /dev/null @@ -1,234 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab - -#include "common/dout.h" -#include "common/errno.h" -#include "include/assert.h" -#include "librbd/Utils.h" -#include "common/Timer.h" -#include "common/WorkQueue.h" -#include "journal/Settings.h" -#include "librbd/journal/CreateRequest.h" -#include "librbd/journal/RemoveRequest.h" - -#define dout_subsys ceph_subsys_rbd -#undef dout_prefix -#define dout_prefix *_dout << "librbd::Journal::CreateRequest: " - -namespace librbd { - -using util::create_context_callback; - -namespace journal { - -template -CreateRequest::CreateRequest(IoCtx &ioctx, const std::string &imageid, - uint8_t order, uint8_t splay_width, - const std::string &object_pool, - uint64_t tag_class, TagData &tag_data, - const std::string &client_id, - ContextWQ *op_work_queue, - Context *on_finish) - : m_ioctx(ioctx), m_image_id(imageid), m_order(order), - m_splay_width(splay_width), m_object_pool(object_pool), - m_tag_class(tag_class), m_tag_data(tag_data), m_image_client_id(client_id), - m_op_work_queue(op_work_queue), m_on_finish(on_finish) { - m_cct = reinterpret_cast(m_ioctx.cct()); -} - -template -void CreateRequest::send() { - ldout(m_cct, 20) << this << " " << __func__ << dendl; - - if (m_order > 64 || m_order < 12) { - lderr(m_cct) << "order must be in the range [12, 64]" << dendl; - complete(-EDOM); - return; - } - if (m_splay_width == 0) { - complete(-EINVAL); - return; - } - - get_pool_id(); -} - -template -void CreateRequest::get_pool_id() { - ldout(m_cct, 20) << this << " " << __func__ << dendl; - - if (m_object_pool.empty()) { - create_journal(); - return; - } - - librados::Rados rados(m_ioctx); - IoCtx data_ioctx; - int r = rados.ioctx_create(m_object_pool.c_str(), data_ioctx); - if (r != 0) { - lderr(m_cct) << "failed to create journal: " - << "error opening journal object pool '" << m_object_pool - << "': " << cpp_strerror(r) << dendl; - complete(r); - return; - } - - m_pool_id = data_ioctx.get_id(); - create_journal(); -} - -template -void CreateRequest::create_journal() { - ldout(m_cct, 20) << this << " " << __func__ << dendl; - - ImageCtx::get_timer_instance(m_cct, &m_timer, &m_timer_lock); - m_journaler = new Journaler(m_op_work_queue, m_timer, m_timer_lock, - m_ioctx, m_image_id, m_image_client_id, {}); - - using klass = CreateRequest; - Context *ctx = create_context_callback(this); - - m_journaler->create(m_order, m_splay_width, m_pool_id, ctx); -} - -template -Context *CreateRequest::handle_create_journal(int *result) { - ldout(m_cct, 20) << __func__ << ": r=" << *result << dendl; - - if (*result < 0) { - lderr(m_cct) << "failed to create journal: " << cpp_strerror(*result) << dendl; - shut_down_journaler(*result); - return nullptr; - } - - allocate_journal_tag(); - return nullptr; -} - -template -void CreateRequest::allocate_journal_tag() { - ldout(m_cct, 20) << this << " " << __func__ << dendl; - - using klass = CreateRequest; - Context *ctx = create_context_callback(this); - - ::encode(m_tag_data, m_bl); - m_journaler->allocate_tag(m_tag_class, m_bl, &m_tag, ctx); -} - -template -Context *CreateRequest::handle_journal_tag(int *result) { - ldout(m_cct, 20) << __func__ << ": r=" << *result << dendl; - - if (*result < 0) { - lderr(m_cct) << "failed to allocate tag: " << cpp_strerror(*result) << dendl; - shut_down_journaler(*result); - return nullptr; - } - - register_client(); - return nullptr; -} - -template -void CreateRequest::register_client() { - ldout(m_cct, 20) << this << " " << __func__ << dendl; - - m_bl.clear(); - ::encode(ClientData{ImageClientMeta{m_tag.tag_class}}, m_bl); - - using klass = CreateRequest; - Context *ctx = create_context_callback(this); - - m_journaler->register_client(m_bl, ctx); -} - -template -Context *CreateRequest::handle_register_client(int *result) { - ldout(m_cct, 20) << __func__ << ": r=" << *result << dendl; - - if (*result < 0) { - lderr(m_cct) << "failed to register client: " << cpp_strerror(*result) << dendl; - } - - shut_down_journaler(*result); - return nullptr; -} - -template -void CreateRequest::shut_down_journaler(int r) { - ldout(m_cct, 20) << this << " " << __func__ << dendl; - - m_r_saved = r; - - using klass = CreateRequest; - Context *ctx = create_context_callback(this); - - m_journaler->shut_down(ctx); -} - -template -Context *CreateRequest::handle_journaler_shutdown(int *result) { - ldout(m_cct, 20) << __func__ << ": r=" << *result << dendl; - - if (*result < 0) { - lderr(m_cct) << "failed to shut down journaler: " << cpp_strerror(*result) << dendl; - } - - delete m_journaler; - - if (!m_r_saved) { - complete(0); - return nullptr; - } - - // there was an error during journal creation, so we rollback - // what ever was done. the easiest way to do this is to invoke - // journal remove state machine, although it's not the most - // cleanest approach when it comes to redundancy, but that's - // ok during the failure path. - remove_journal(); - return nullptr; -} - -template -void CreateRequest::remove_journal() { - ldout(m_cct, 20) << this << " " << __func__ << dendl; - - using klass = CreateRequest; - Context *ctx = create_context_callback(this); - - RemoveRequest *req = RemoveRequest::create( - m_ioctx, m_image_id, m_image_client_id, m_op_work_queue, ctx); - req->send(); -} - -template -Context *CreateRequest::handle_remove_journal(int *result) { - ldout(m_cct, 20) << __func__ << ": r=" << *result << dendl; - - if (*result < 0) { - lderr(m_cct) << "error cleaning up journal after creation failed: " - << cpp_strerror(*result) << dendl; - } - - complete(m_r_saved); - return nullptr; -} - -template -void CreateRequest::complete(int r) { - ldout(m_cct, 20) << this << " " << __func__ << dendl; - - if (r == 0) { - ldout(m_cct, 20) << "done." << dendl; - } - - m_on_finish->complete(r); - delete this; -} - -} // namespace journal -} // namespace librbd - -template class librbd::journal::CreateRequest;