JsonMonitorable.h

Go to the documentation of this file.

/*
 * JsonMonitorable.h
 *
 *  Created on: Oct 29, 2012
 *      Author: aspataru
 */
 
#ifndef JSON_MONITORABLE_H
#define JSON_MONITORABLE_H
 
#include <string>
#include <sstream>
#include <vector>
#include <memory>
//#include "EventFilter/Utilities/interface/Utils.h"
#include <iostream>
#include "json.h"
 
namespace jsoncollector {
 
  enum MonType { TYPEINT, TYPEUINT, TYPEDOUBLE, TYPESTRING, TYPEUNDEFINED };
  enum OperationType { OPSUM, OPAVG, OPSAME, OPHISTO, OPCAT, OPUNKNOWN };
 
  class JsonMonitorable {
  public:
    JsonMonitorable() : updates_(0), notSame_(false) {}
 
    virtual ~JsonMonitorable() {}
 
    virtual std::string toString() const = 0;
 
    virtual void resetValue() = 0;
 
    unsigned int getUpdates() { return updates_; }
 
    bool getNotSame() { return notSame_; }
 
    virtual void setName(std::string name) { name_ = name; }
 
    virtual std::string& getName() { return name_; }
 
  protected:
    std::string name_;
    unsigned int updates_;
    bool notSame_;
  };
 
  class JsonMonPtr {
  public:
    JsonMonPtr() : ptr_(nullptr) {}
    JsonMonPtr(JsonMonitorable* ptr) : ptr_(ptr) {}
    void operator=(JsonMonitorable* ptr) { ptr_ = ptr; }
    ~JsonMonPtr() {
      if (ptr_)
        delete ptr_;
      ptr_ = nullptr;
    }
    JsonMonitorable* operator->() { return ptr_; }
    JsonMonitorable* get() { return ptr_; }
    //JsonMonPtr& operator=(JsonMonPtr& ) = delete;
    //JsonMonPtr& operator=(JsonMonPtr&& other){ptr_=other.ptr_;return *this;}
  private:
    JsonMonitorable* ptr_;
  };
 
  class IntJ : public JsonMonitorable {
  public:
    IntJ() : JsonMonitorable(), theVar_(0) {}
    IntJ(long val) : JsonMonitorable(), theVar_(val) {}
 
    ~IntJ() override {}
 
    std::string toString() const override {
      std::stringstream ss;
      ss << theVar_;
      return ss.str();
    }
    void resetValue() override {
      theVar_ = 0;
      updates_ = 0;
      notSame_ = false;
    }
    void operator=(long sth) {
      theVar_ = sth;
      updates_ = 1;
      notSame_ = false;
    }
    long& value() { return theVar_; }
 
    void update(long sth) {
      theVar_ = sth;
      if (updates_ && theVar_ != sth)
        notSame_ = true;
      updates_++;
    }
 
    void add(long sth) {
      theVar_ += sth;
      updates_++;
    }
 
  private:
    long theVar_;
  };
 
  class DoubleJ : public JsonMonitorable {
  public:
    DoubleJ() : JsonMonitorable(), theVar_(0) {}
    DoubleJ(double val) : JsonMonitorable(), theVar_(val) {}
 
    ~DoubleJ() override {}
 
    std::string toString() const override {
      std::stringstream ss;
      ss << theVar_;
      return ss.str();
    }
    void resetValue() override {
      theVar_ = 0;
      updates_ = 0;
      notSame_ = false;
    }
    void operator=(double sth) {
      theVar_ = sth;
      updates_ = 1;
      notSame_ = false;
    }
    double& value() { return theVar_; }
    void update(double sth) {
      theVar_ = sth;
      if (updates_ && theVar_ != sth)
        notSame_ = true;
      updates_++;
    }
 
  private:
    double theVar_;
  };
 
  class StringJ : public JsonMonitorable {
  public:
    StringJ() : JsonMonitorable() {}
 
    ~StringJ() override {}
 
    std::string toString() const override { return theVar_; }
    void resetValue() override {
      theVar_ = std::string();
      updates_ = 0;
      notSame_ = false;
    }
    void operator=(std::string sth) {
      theVar_ = sth;
      updates_ = 1;
      notSame_ = false;
    }
    std::string& value() { return theVar_; }
    void concatenate(std::string const& added) {
      if (!updates_)
        theVar_ = added;
      else
        theVar_ += "," + added;
      updates_++;
    }
    void update(std::string const& newStr) {
      theVar_ = newStr;
      updates_ = 1;
    }
 
  private:
    std::string theVar_;
  };
 
  //histograms filled at time intervals (later converted to full histograms)
  template <class T>
  class HistoJ : public JsonMonitorable {
  public:
    HistoJ(int expectedUpdates = 1, unsigned int maxUpdates = 0) {
      expectedSize_ = expectedUpdates;
      updates_ = 0;
      maxUpdates_ = maxUpdates;
      if (maxUpdates_ && maxUpdates_ < expectedSize_)
        expectedSize_ = maxUpdates_;
      histo_.reserve(expectedSize_);
    }
    ~HistoJ() override {}
 
    std::string toCSV() const {
      std::stringstream ss;
      for (unsigned int i = 0; i < updates_; i++) {
        ss << histo_[i];
        if (i != histo_.size() - 1)
          ss << ",";
      }
      return ss.str();
    }
 
    std::string toString() const override {
      std::stringstream ss;
      ss << "[";
      if (!histo_.empty())
        for (unsigned int i = 0; i < histo_.size(); i++) {
          ss << histo_[i];
          if (i < histo_.size() - 1)
            ss << ",";
        }
      ss << "]";
      return ss.str();
    }
    virtual Json::Value toJsonValue() const {  //TODO
      Json::Value jsonValue(Json::arrayValue);
      for (unsigned int i = 0; i < histo_.size(); i++) {
        jsonValue.append(histo_[i]);
      }
      return jsonValue;
    }
    void resetValue() override {
      histo_.clear();
      histo_.reserve(expectedSize_);
      updates_ = 0;
    }
    void operator=(std::vector<T>& sth) { histo_ = sth; }
 
    std::vector<T>& value() { return histo_; }
 
    unsigned int getExpectedSize() { return expectedSize_; }
 
    unsigned int getMaxUpdates() { return maxUpdates_; }
 
    void setMaxUpdates(unsigned int maxUpdates) {
      maxUpdates_ = maxUpdates;
      if (!maxUpdates_)
        return;
      if (expectedSize_ > maxUpdates_)
        expectedSize_ = maxUpdates_;
      //truncate what is over the limit
      if (maxUpdates_ && histo_.size() > maxUpdates_) {
        histo_.resize(maxUpdates_);
      } else
        histo_.reserve(expectedSize_);
    }
 
    unsigned int getSize() { return histo_.size(); }
 
    void update(T val) {
      if (maxUpdates_ && updates_ >= maxUpdates_)
        return;
      histo_.push_back(val);
      updates_++;
    }
 
  private:
    std::vector<T> histo_;
    unsigned int expectedSize_;
    unsigned int maxUpdates_;
  };
 
}  // namespace jsoncollector
 
#endif