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