DTHVStatusHandler.h

Go to the documentation of this file.

#ifndef DTHVStatusHandler_H
#define DTHVStatusHandler_H

//----------------------
// Base Class Headers --
//----------------------
#include "CondCore/PopCon/interface/PopConSourceHandler.h"

//------------------------------------
// Collaborating Class Declarations --
//------------------------------------
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "CondCore/CondDB/interface/Session.h"
#include "CondFormats/DTObjects/interface/DTHVStatus.h"
#include <string>

namespace coral {
  class TimeStamp;
}
#include "CondTools/DT/interface/DTHVAbstractCheck.h"

//---------------
// C++ Headers --
//---------------

//              ---------------------
//              -- Class Interface --
//              ---------------------

class DTHVStatusHandler : public popcon::PopConSourceHandler<DTHVStatus> {
public:
  DTHVStatusHandler(const edm::ParameterSet& ps);

  ~DTHVStatusHandler() override;

  void getNewObjects() override;
  std::string id() const override;

private:
  typedef DTHVAbstractCheck::timedMeasurement timedMeasurement;
  typedef std::pair<int, float> channelValue;

  void checkNewData();

  void getChannelMap();
  void getLayerSplit();
  void getChannelSplit();
  void dumpHVAliases();

  void createSnapshot();
  int recoverSnapshot();
  cond::Time_t recoverLastTime();
  void dumpSnapshot(const coral::TimeStamp& time);
  void updateHVStatus();
  int checkForPeriod(cond::Time_t condSince, cond::Time_t condUntil, int& missingChannels, bool copyOffline);

  void copyHVData();
  DTHVStatus* offlineList();
  void getLayerValues(int rawId, int type, float& valueL, float& valueR, float& valueS, float& valueC);
  void setChannelFlag(
      DTHVStatus* hv, int whe, int sta, int sec, int qua, int lay, int l_p, const DTHVAbstractCheck::flag& flag);

  int checkStatusChange(int type, float oldValue, float newValue);
  void filterData();

  static DTWireId layerId(int rawId, int l_p);
  static coral::TimeStamp coralTime(const cond::Time_t& time);
  static cond::Time_t condTime(const coral::TimeStamp& time);
  static cond::Time_t condTime(long long int time);

  std::string dataTag;
  std::string onlineConnect;
  std::string utilConnect;
  std::string onlineAuthentication;
  std::string bufferConnect;
  DTHVStatus* lastStatus;

  int ySince;
  int mSince;
  int dSince;
  int hSince;
  int pSince;
  int sSince;
  int yUntil;
  int mUntil;
  int dUntil;
  int hUntil;
  int pUntil;
  int sUntil;
  bool dumpAtStart;
  bool dumpAtEnd;
  long long int bwdTime;
  long long int fwdTime;
  long long int minTime;

  std::map<int, timedMeasurement> snapshotValues;
  DTHVAbstractCheck* hvChecker;

  cond::Time_t procSince;
  cond::Time_t procUntil;
  cond::Time_t lastFound;
  cond::Time_t nextFound;
  cond::Time_t timeLimit;
  long long int lastStamp;
  int maxPayload;

  cond::persistency::Session omds_session;
  cond::persistency::Session util_session;
  cond::persistency::Session buff_session;

  std::string mapVersion;
  std::string splitVersion;
  std::map<int, int> aliasMap;
  std::map<int, int> layerMap;
  std::map<int, int> laySplit;
  std::map<int, std::vector<int>*> channelSplit;
  std::vector<std::pair<DTHVStatus*, cond::Time_t> > tmpContainer;
  bool switchOff;
};

#endif  // DTHVStatusHandler_H