QualityMetric.h

Go to the documentation of this file.

#ifndef Utilities_XrdAdaptor_QualityMetric_h
#define Utilities_XrdAdaptor_QualityMetric_h
 
#include <ctime>
 
#include <mutex>
#include <memory>
 
#include "tbb/concurrent_unordered_map.h"
#include <boost/utility.hpp>
 
#include "FWCore/Utilities/interface/propagate_const.h"
#include "FWCore/Utilities/interface/thread_safety_macros.h"
 
namespace XrdAdaptor {
 
  class QualityMetric;
  class QualityMetricSource;
  class QualityMetricUniqueSource;
 
  class QualityMetricWatch : boost::noncopyable {
    friend class QualityMetricSource;
 
  public:
    QualityMetricWatch() : m_parent1(nullptr), m_parent2(nullptr) {}
    QualityMetricWatch(QualityMetricWatch &&);
    ~QualityMetricWatch();
 
    void swap(QualityMetricWatch &);
 
  private:
    QualityMetricWatch(QualityMetric *parent1, QualityMetric *parent2);
    timespec m_start;
    edm::propagate_const<QualityMetric *> m_parent1;
    edm::propagate_const<QualityMetric *> m_parent2;
  };
 
  class QualityMetric : boost::noncopyable {
    friend class QualityMetricWatch;
 
  public:
    QualityMetric(timespec now, int default_value = 260);
    unsigned get();
 
  private:
    void finishWatch(timespec now, int ms);
 
    static const unsigned interval_length = 60;
 
    int m_value;
    int m_interval0_n;
    int m_interval0_val;
    time_t m_interval0_start;
    int m_interval1_val;
    int m_interval2_val;
    int m_interval3_val;
    int m_interval4_val;
 
    std::mutex m_mutex;
  };
 
  class QualityMetricFactory {
    friend class Source;
 
  private:
    static std::unique_ptr<QualityMetricSource> get(timespec now, const std::string &id);
 
    CMS_THREAD_SAFE static QualityMetricFactory m_instance;
 
    typedef tbb::concurrent_unordered_map<std::string, QualityMetricUniqueSource *> MetricMap;
    MetricMap m_sources;
  };
 
  class QualityMetricSource final : public QualityMetric {
    friend class QualityMetricUniqueSource;
 
  public:
    void startWatch(QualityMetricWatch &);
 
  private:
    QualityMetricSource(QualityMetricUniqueSource &parent, timespec now, int default_value);
 
    QualityMetricUniqueSource &m_parent;
  };
 
  /*
 * This quality metric tracks all accesses to a given source ID.
 */
  class QualityMetricUniqueSource final : public QualityMetric {
    friend class QualityMetricFactory;
 
  private:
    QualityMetricUniqueSource(timespec now);
    std::unique_ptr<QualityMetricSource> newSource(timespec now);
  };
 
}  // namespace XrdAdaptor
 
#endif  // Utilities_XrdAdaptor_QualityMetric_h