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

diff --git a/src/ceph/src/osd/mClockClientQueue.cc b/src/ceph/src/osd/mClockClientQueue.cc
deleted file mode 100644
index 71a6631..0000000
--- a/src/ceph/src/osd/mClockClientQueue.cc
+++ /dev/null
@@ -1,165 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-/*
- * Ceph - scalable distributed file system
- *
- * Copyright (C) 2016 Red Hat Inc.
- *
- * This is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
- * Foundation.  See file COPYING.
- *
- */
-
-
-#include <memory>
-
-#include "osd/mClockClientQueue.h"
-#include "common/dout.h"
-
-
-namespace dmc = crimson::dmclock;
-
-
-#define dout_context cct
-#define dout_subsys ceph_subsys_osd
-#undef dout_prefix
-#define dout_prefix *_dout
-
-
-namespace ceph {
-
-  mClockClientQueue::mclock_op_tags_t::mclock_op_tags_t(CephContext *cct) :
-    client_op(cct->_conf->osd_op_queue_mclock_client_op_res,
-	      cct->_conf->osd_op_queue_mclock_client_op_wgt,
-	      cct->_conf->osd_op_queue_mclock_client_op_lim),
-    osd_subop(cct->_conf->osd_op_queue_mclock_osd_subop_res,
-	      cct->_conf->osd_op_queue_mclock_osd_subop_wgt,
-	      cct->_conf->osd_op_queue_mclock_osd_subop_lim),
-    snaptrim(cct->_conf->osd_op_queue_mclock_snap_res,
-	     cct->_conf->osd_op_queue_mclock_snap_wgt,
-	     cct->_conf->osd_op_queue_mclock_snap_lim),
-    recov(cct->_conf->osd_op_queue_mclock_recov_res,
-	  cct->_conf->osd_op_queue_mclock_recov_wgt,
-	  cct->_conf->osd_op_queue_mclock_recov_lim),
-    scrub(cct->_conf->osd_op_queue_mclock_scrub_res,
-	  cct->_conf->osd_op_queue_mclock_scrub_wgt,
-	  cct->_conf->osd_op_queue_mclock_scrub_lim)
-  {
-    dout(20) <<
-      "mClockClientQueue settings:: " <<
-      "client_op:" << client_op <<
-      "; osd_subop:" << osd_subop <<
-      "; snaptrim:" << snaptrim <<
-      "; recov:" << recov <<
-      "; scrub:" << scrub <<
-      dendl;
-  }
-
-
-  dmc::ClientInfo
-  mClockClientQueue::op_class_client_info_f(
-    const mClockClientQueue::InnerClient& client)
-  {
-    switch(client.second) {
-    case osd_op_type_t::client_op:
-      return mclock_op_tags->client_op;
-    case osd_op_type_t::osd_subop:
-      return mclock_op_tags->osd_subop;
-    case osd_op_type_t::bg_snaptrim:
-      return mclock_op_tags->snaptrim;
-    case osd_op_type_t::bg_recovery:
-      return mclock_op_tags->recov;
-    case osd_op_type_t::bg_scrub:
-      return mclock_op_tags->scrub;
-    default:
-      assert(0);
-      return dmc::ClientInfo(-1, -1, -1);
-    }
-  }
-
-
-  /*
-   * class mClockClientQueue
-   */
-
-  std::unique_ptr<mClockClientQueue::mclock_op_tags_t>
-  mClockClientQueue::mclock_op_tags(nullptr);
-
-  mClockClientQueue::pg_queueable_visitor_t
-  mClockClientQueue::pg_queueable_visitor;
-
-  mClockClientQueue::mClockClientQueue(CephContext *cct) :
-    queue(&mClockClientQueue::op_class_client_info_f)
-  {
-    // manage the singleton
-    if (!mclock_op_tags) {
-      mclock_op_tags.reset(new mclock_op_tags_t(cct));
-    }
-  }
-
-  mClockClientQueue::osd_op_type_t
-  mClockClientQueue::get_osd_op_type(const Request& request) {
-    osd_op_type_t type =
-      boost::apply_visitor(pg_queueable_visitor, request.second.get_variant());
-
-    // if we got client_op back then we need to distinguish between
-    // a client op and an osd subop.
-
-    if (osd_op_type_t::client_op != type) {
-      return type;
-    } else if (MSG_OSD_SUBOP ==
-	       boost::get<OpRequestRef>(
-		 request.second.get_variant())->get_req()->get_header().type) {
-      return osd_op_type_t::osd_subop;
-    } else {
-      return osd_op_type_t::client_op;
-    }
-  }
-
-  mClockClientQueue::InnerClient
-  inline mClockClientQueue::get_inner_client(const Client& cl,
-				      const Request& request) {
-    return InnerClient(cl, get_osd_op_type(request));
-  }
-
-  // Formatted output of the queue
-  inline void mClockClientQueue::dump(ceph::Formatter *f) const {
-    queue.dump(f);
-  }
-
-  inline void mClockClientQueue::enqueue_strict(Client cl,
-						unsigned priority,
-						Request item) {
-    queue.enqueue_strict(get_inner_client(cl, item), priority, item);
-  }
-
-  // Enqueue op in the front of the strict queue
-  inline void mClockClientQueue::enqueue_strict_front(Client cl,
-						      unsigned priority,
-						      Request item) {
-    queue.enqueue_strict_front(get_inner_client(cl, item), priority, item);
-  }
-
-  // Enqueue op in the back of the regular queue
-  inline void mClockClientQueue::enqueue(Client cl,
-					 unsigned priority,
-					 unsigned cost,
-					 Request item) {
-    queue.enqueue(get_inner_client(cl, item), priority, cost, item);
-  }
-
-  // Enqueue the op in the front of the regular queue
-  inline void mClockClientQueue::enqueue_front(Client cl,
-					       unsigned priority,
-					       unsigned cost,
-					       Request item) {
-    queue.enqueue_front(get_inner_client(cl, item), priority, cost, item);
-  }
-
-  // Return an op to be dispatched
-  inline Request mClockClientQueue::dequeue() {
-    return queue.dequeue();
-  }
-} // namespace ceph