X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fdmclock%2Fsim%2Fsrc%2Fssched%2Fssched_server.h;fp=src%2Fceph%2Fsrc%2Fdmclock%2Fsim%2Fsrc%2Fssched%2Fssched_server.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=610c2ef665c432ad1b2a9a9d6be4c7ebc0337a21;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/dmclock/sim/src/ssched/ssched_server.h b/src/ceph/src/dmclock/sim/src/ssched/ssched_server.h
deleted file mode 100644
index 610c2ef..0000000
--- a/src/ceph/src/dmclock/sim/src/ssched/ssched_server.h
+++ /dev/null
@@ -1,183 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-/*
- * Copyright (C) 2016 Red Hat Inc.
- */
-
-#pragma once
-
-#include <memory>
-#include <mutex>
-#include <deque>
-
-#include "boost/variant.hpp"
-
-#include "ssched_recs.h"
-
-#ifdef PROFILE
-#include "profile.h"
-#endif
-
-namespace crimson {
-
-  namespace simple_scheduler {
-
-    template<typename C, typename R, typename Time>
-    class SimpleQueue {
-
-    public:
-
-      using RequestRef = std::unique_ptr<R>;
-
-      // a function to see whether the server can handle another request
-      using CanHandleRequestFunc = std::function<bool(void)>;
-
-      // a function to submit a request to the server; the second
-      // parameter is a callback when it's completed
-      using HandleRequestFunc =
-	std::function<void(const C&,RequestRef,NullData)>;
-
-      struct PullReq {
-	enum class Type { returning, none };
-
-	struct Retn {
-	  C           client;
-	  RequestRef  request;
-	};
-
-	Type                 type;
-	boost::variant<Retn> data;
-      };
-
-    protected:
-
-      enum class Mechanism { push, pull };
-
-      struct QRequest {
-	C          client;
-	RequestRef request;
-      };
-
-      bool finishing = false;
-      Mechanism mechanism;
-
-      CanHandleRequestFunc can_handle_f;
-      HandleRequestFunc handle_f;
-
-      mutable std::mutex queue_mtx;
-      using DataGuard = std::lock_guard<decltype(queue_mtx)>;
-
-      std::deque<QRequest> queue;
-
-#ifdef PROFILE
-    public:
-      ProfileTimer<std::chrono::nanoseconds> pull_request_timer;
-      ProfileTimer<std::chrono::nanoseconds> add_request_timer;
-      ProfileTimer<std::chrono::nanoseconds> request_complete_timer;
-    protected:
-#endif
-
-    public:
-
-      // push full constructor
-      SimpleQueue(CanHandleRequestFunc _can_handle_f,
-		  HandleRequestFunc _handle_f) :
-	mechanism(Mechanism::push),
-	can_handle_f(_can_handle_f),
-	handle_f(_handle_f)
-      {
-	// empty
-      }
-
-      SimpleQueue() :
-	mechanism(Mechanism::pull)
-      {
-	// empty
-      }
-
-      ~SimpleQueue() {
-	finishing = true;
-      }
-
-      void add_request(R&& request,
-		       const C& client_id,
-		       const ReqParams& req_params) {
-	add_request(RequestRef(new R(std::move(request))),
-		    client_id, req_params);
-      }
-
-      void add_request(RequestRef&& request,
-		       const C& client_id,
-		       const ReqParams& req_params) {
-	DataGuard g(queue_mtx);
-
-#ifdef PROFILE
-	add_request_timer.start();
-#endif
-	queue.emplace_back(QRequest{client_id, std::move(request)});
-
-	if (Mechanism::push == mechanism) {
-	  schedule_request();
-	}
-
-#ifdef PROFILE
-	add_request_timer.stop();
-#endif
-      } // add_request
-
-      void request_completed() {
-	assert(Mechanism::push == mechanism);
-	DataGuard g(queue_mtx);
-
-#ifdef PROFILE
-	request_complete_timer.start();
-#endif
-	schedule_request();
-
-#ifdef PROFILE
-	request_complete_timer.stop();
-#endif
-      } // request_completed
-
-      PullReq pull_request() {
-	assert(Mechanism::pull == mechanism);
-	PullReq result;
-	DataGuard g(queue_mtx);
-
-#ifdef PROFILE
-	pull_request_timer.start();
-#endif
-
-	if (queue.empty()) {
-	  result.type = PullReq::Type::none;
-	} else {
-	  auto front = queue.front();
-	  result.type = PullReq::Type::returning;
-	  result.data =
-	    typename PullReq::Retn{front.client, std::move(front.request)};
-	  queue.pop();
-	}
-
-#ifdef PROFILE
-	pull_request_timer.stop();
-#endif
-
-	return result;
-      }
-
-    protected:
-
-      // queue_mtx should be held when called; should only be called
-      // when mechanism is push
-      void schedule_request() {
-	if (!queue.empty() && can_handle_f()) {
-	  auto& front = queue.front();
-	  static NullData null_data;
-	  handle_f(front.client, std::move(front.request), null_data);
-	  queue.pop_front();
-	}
-      }
-    };
-  };
-};