X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Flibrbd%2Fio%2FAsyncOperation.cc;fp=src%2Fceph%2Fsrc%2Flibrbd%2Fio%2FAsyncOperation.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=ca8daa4c098b18da111da17695548f715253d56f;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/librbd/io/AsyncOperation.cc b/src/ceph/src/librbd/io/AsyncOperation.cc
deleted file mode 100644
index ca8daa4..0000000
--- a/src/ceph/src/librbd/io/AsyncOperation.cc
+++ /dev/null
@@ -1,84 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#include "librbd/io/AsyncOperation.h"
-#include "librbd/ImageCtx.h"
-#include "common/dout.h"
-#include "common/WorkQueue.h"
-#include "include/assert.h"
-
-#define dout_subsys ceph_subsys_rbd
-#undef dout_prefix
-#define dout_prefix *_dout << "librbd::io::AsyncOperation: "
-
-namespace librbd {
-namespace io {
-
-namespace {
-
-struct C_CompleteFlushes : public Context {
-  ImageCtx *image_ctx;
-  std::list<Context *> flush_contexts;
-
-  explicit C_CompleteFlushes(ImageCtx *image_ctx, std::list<Context *> &&flush_contexts)
-    : image_ctx(image_ctx), flush_contexts(std::move(flush_contexts)) {
-  }
-  void finish(int r) override {
-    RWLock::RLocker owner_locker(image_ctx->owner_lock);
-    while (!flush_contexts.empty()) {
-      Context *flush_ctx = flush_contexts.front();
-      flush_contexts.pop_front();
-
-      ldout(image_ctx->cct, 20) << "completed flush: " << flush_ctx << dendl;
-      flush_ctx->complete(0);
-    }
-  }
-};
-
-} // anonymous namespace
-
-void AsyncOperation::start_op(ImageCtx &image_ctx) {
-  assert(m_image_ctx == NULL);
-  m_image_ctx = &image_ctx;
-
-  ldout(m_image_ctx->cct, 20) << this << " " << __func__ << dendl;
-  Mutex::Locker l(m_image_ctx->async_ops_lock);
-  m_image_ctx->async_ops.push_front(&m_xlist_item);
-}
-
-void AsyncOperation::finish_op() {
-  ldout(m_image_ctx->cct, 20) << this << " " << __func__ << dendl;
-
-  {
-    Mutex::Locker l(m_image_ctx->async_ops_lock);
-    xlist<AsyncOperation *>::iterator iter(&m_xlist_item);
-    ++iter;
-    assert(m_xlist_item.remove_myself());
-
-    // linked list stored newest -> oldest ops
-    if (!iter.end() && !m_flush_contexts.empty()) {
-      ldout(m_image_ctx->cct, 20) << "moving flush contexts to previous op: "
-                                  << *iter << dendl;
-      (*iter)->m_flush_contexts.insert((*iter)->m_flush_contexts.end(),
-                                       m_flush_contexts.begin(),
-                                       m_flush_contexts.end());
-      return;
-    }
-  }
-
-  if (!m_flush_contexts.empty()) {
-    C_CompleteFlushes *ctx = new C_CompleteFlushes(m_image_ctx,
-                                                   std::move(m_flush_contexts));
-    m_image_ctx->op_work_queue->queue(ctx);
-  }
-}
-
-void AsyncOperation::add_flush_context(Context *on_finish) {
-  assert(m_image_ctx->async_ops_lock.is_locked());
-  ldout(m_image_ctx->cct, 20) << this << " " << __func__ << ": "
-                              << "flush=" << on_finish << dendl;
-  m_flush_contexts.push_back(on_finish);
-}
-
-} // namespace io
-} // namespace librbd