remove ceph code
[stor4nfv.git] / src / ceph / src / common / DecayCounter.h
diff --git a/src/ceph/src/common/DecayCounter.h b/src/ceph/src/common/DecayCounter.h
deleted file mode 100644 (file)
index e45aed8..0000000
+++ /dev/null
@@ -1,152 +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) 2004-2006 Sage Weil <sage@newdream.net>
- *
- * 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.
- * 
- */
-
-#ifndef CEPH_DECAYCOUNTER_H
-#define CEPH_DECAYCOUNTER_H
-
-#include "include/utime.h"
-
-/**
- *
- * TODO: normalize value based on some fucntion of half_life, 
- *  so that it can be interpreted as an approximation of a
- *  moving average of N seconds.  currently, changing half-life
- *  skews the scale of the value, even at steady state.  
- *
- */
-
-class DecayRate {
-  double k;             // k = ln(.5)/half_life
-
-  friend class DecayCounter;
-
-public:
-  DecayRate() : k(0) {}
-  DecayRate(const DecayRate &dr) : k(dr.k) {}
-
-  // cppcheck-suppress noExplicitConstructor
-  DecayRate(double hl) { set_halflife(hl); }
-  void set_halflife(double hl) {
-    k = ::log(.5) / hl;
-  }    
-};
-
-class DecayCounter {
-public:
-  double val;           // value
-  double delta;         // delta since last decay
-  double vel;           // recent velocity
-  utime_t last_decay;   // time of last decay
-  DecayRate rate;
-
-  void encode(bufferlist& bl) const;
-  void decode(const utime_t &t, bufferlist::iterator& p);
-  void dump(Formatter *f) const;
-  static void generate_test_instances(list<DecayCounter*>& ls);
-
-  explicit DecayCounter(const utime_t &now)
-    : val(0), delta(0), vel(0), last_decay(now)
-  {
-  }
-
-  explicit DecayCounter(const utime_t &now, const DecayRate &rate)
-    : val(0), delta(0), vel(0), last_decay(now), rate(rate)
-  {
-  }
-
-  // these two functions are for the use of our dencoder testing infrastructure
-  DecayCounter() : val(0), delta(0), vel(0), last_decay() {}
-
-  void decode(bufferlist::iterator& p) {
-    utime_t fake_time;
-    decode(fake_time, p);
-  }
-
-  /**
-   * reading
-   */
-
-  double get(utime_t now, const DecayRate& rate) {
-    decay(now, rate);
-    return val+delta;
-  }
-  double get(utime_t now) {
-    decay(now, rate);
-    return val+delta;
-  }
-
-  double get_last() {
-    return val;
-  }
-  
-  double get_last_vel() {
-    return vel;
-  }
-
-  utime_t get_last_decay() { 
-    return last_decay; 
-  }
-
-  /**
-   * adjusting
-   */
-
-  double hit(utime_t now, const DecayRate& rate, double v = 1.0) {
-    decay(now, rate);
-    delta += v;
-    return val+delta;
-  }
-  double hit(utime_t now, double v = 1.0) {
-    decay(now, rate);
-    delta += v;
-    return val+delta;
-  }
-
-  void adjust(double a) {
-    val += a;
-  }
-  void adjust(utime_t now, const DecayRate& rate, double a) {
-    decay(now, rate);
-    val += a;
-  }
-  void scale(double f) {
-    val *= f;
-    delta *= f;    
-    vel *= f;
-  }
-
-  /**
-   * decay etc.
-   */
-
-  void reset(utime_t now) {
-    last_decay = now;
-    val = delta = 0;
-  }
-
-  void decay(utime_t now, const DecayRate &rate);
-};
-
-inline void encode(const DecayCounter &c, bufferlist &bl) { c.encode(bl); }
-inline void decode(DecayCounter &c, const utime_t &t, bufferlist::iterator &p) {
-  c.decode(t, p);
-}
-// for dencoder
-inline void decode(DecayCounter &c, bufferlist::iterator &p) {
-  utime_t t;
-  c.decode(t, p);
-}
-
-
-#endif