SiStripDetVOffBuilder.h

Go to the documentation of this file.

#ifndef SISTRIPDETVOFF_SRC_BUILDER_H
#define SISTRIPDETVOFF_SRC_BUILDER_H
#define USING_NEW_CORAL

#include "FWCore/ServiceRegistry/interface/Service.h"
#include "FWCore/Framework/interface/ESHandle.h"
#include "FWCore/Framework/interface/EventSetup.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"

#include "CondFormats/SiStripObjects/interface/SiStripDetVOff.h"
#include "CondFormats/DataRecord/interface/SiStripCondDataRecords.h"
#include "CalibTracker/SiStripCommon/interface/SiStripDetInfoFileReader.h"

#include "CalibTracker/SiStripDCS/interface/SiStripCoralIface.h"
#include "CalibTracker/SiStripDCS/interface/SiStripPsuDetIdMap.h"
// #include "CalibTracker/SiStripDCS/interface/SiStripPsuDetIdMapFromFile.h"

#include "CoralBase/TimeStamp.h"
#include "CondFormats/Common/interface/Time.h"
#include "CondFormats/Common/interface/TimeConversions.h"
//#include "DataFormats/Provenance/interface/Timestamp.h"

#include <fstream>
#include <iostream>
#include <memory>

// Unit test class for SiStripDetVOffBuilder
class TestSiStripDetVOffBuilder;

class SiStripDetVOffBuilder {
  friend class TestSiStripDetVOffBuilder;

public:
  ~SiStripDetVOffBuilder();
  SiStripDetVOffBuilder(const edm::ParameterSet&, const edm::ActivityRegistry&);
  void BuildDetVOffObj();
  std::vector<std::pair<SiStripDetVOff*, cond::Time_t> > getModulesVOff() {
    reduction(deltaTmin_, maxIOVlength_);
    return modulesOff;
  }
  std::vector<std::vector<uint32_t> > getPayloadStats() { return payloadStats; }
  void setLastSiStripDetVOff(SiStripDetVOff* lastPayload, cond::Time_t lastTimeStamp);

  void reduce(std::vector<std::pair<SiStripDetVOff*, cond::Time_t> >::iterator& it,
              std::vector<std::pair<SiStripDetVOff*, cond::Time_t> >::iterator& initialIt,
              std::vector<std::pair<SiStripDetVOff*, cond::Time_t> >& resultVec,
              const bool last = false);

  void reduction(const uint32_t deltaTmin, const uint32_t maxIOVlength);

  void discardIOVs(std::vector<std::pair<SiStripDetVOff*, cond::Time_t> >::iterator& it,
                   std::vector<std::pair<SiStripDetVOff*, cond::Time_t> >::iterator& initialIt,
                   std::vector<std::pair<SiStripDetVOff*, cond::Time_t> >& resultVec,
                   const bool last,
                   const unsigned int first);
  bool FileExists(std::string filename);

private:
  // typedefs
  typedef std::vector<std::pair<std::vector<uint32_t>, coral::TimeStamp> > DetIdTimeStampVector;

  bool whichQuery;

  void printPar(std::stringstream& ss, const std::vector<int>& par);

  std::string timeToStream(const coral::TimeStamp& coralTime, const string& comment = "");
  std::string timeToStream(const cond::Time_t& condTime, const string& comment = "");

  int findSetting(uint32_t id,
                  const coral::TimeStamp& changeDate,
                  const std::vector<uint32_t>& settingID,
                  const std::vector<coral::TimeStamp>& settingDate);

  int findSetting(std::string dpname,
                  const coral::TimeStamp& changeDate,
                  const std::vector<std::string>& settingDpname,
                  const std::vector<coral::TimeStamp>& settingDate);

  void readLastValueFromFile(std::vector<uint32_t>& dpIDs,
                             std::vector<float>& vmonValues,
                             std::vector<coral::TimeStamp>& dateChange);

  cond::Time_t getCondTime(const coral::TimeStamp& coralTime);

  coral::TimeStamp getCoralTime(cond::Time_t iovTime);

  void removeDuplicates(std::vector<uint32_t>& vec);
  cond::Time_t findMostRecentTimeStamp(const std::vector<coral::TimeStamp>& coralDate);

  // member data
  std::vector<std::vector<uint32_t> > payloadStats;
  std::vector<std::pair<SiStripDetVOff*, cond::Time_t> > modulesOff;
  std::pair<SiStripDetVOff*, cond::Time_t> lastStoredCondObj;

  // configurable parameters
  std::string onlineDbConnectionString;
  std::string authenticationPath;
  std::string whichTable;
  std::string lastValueFileName;
  bool fromFile;
  std::string psuDetIdMapFile_;
  bool debug_;
  coral::TimeStamp tmax, tmin, tsetmin;
  std::vector<int> tDefault, tmax_par, tmin_par, tset_par;
  uint32_t deltaTmin_, maxIOVlength_;

  std::string detIdListFile_;
  std::string excludedDetIdListFile_;
  // Threshold to consider a high voltage channel on
  double highVoltageOnThreshold_;

  // Structure used to store variables needed when building the database objects
  struct TimesAndValues {
    TimesAndValues() : latestTime(0) {}
    std::vector<coral::TimeStamp> changeDate;  // used by both
    std::vector<std::string> dpname;           // only used by DB access, not file access
    std::vector<float> actualValue;            // only used by DB access, not file access
    std::vector<uint32_t> dpid;                // only used by file access
    std::vector<int> actualStatus;             // filled using actualValue info
    cond::Time_t latestTime;                   // used for timestamp when using lastValue from file
  };

  struct DetIdListTimeAndStatus {
    DetIdListTimeAndStatus() : notMatched(0) {}
    DetIdTimeStampVector detidV;
    std::vector<bool> StatusGood;
    unsigned int notMatched;
    std::vector<std::string> psuName;
    std::vector<unsigned int> isHV;
  };

  void statusChange(cond::Time_t& lastTime, TimesAndValues& tStruct);
  void lastValue(TimesAndValues& tStruct);
  void lastValueFromFile(TimesAndValues& tStruct);

  void buildPSUdetIdMap(TimesAndValues& tStruct, DetIdListTimeAndStatus& dStruct);

  void setPayloadStats(const uint32_t afterV, const uint32_t numAdded, const uint32_t numRemoved);
  std::pair<int, int> extractDetIdVector(const unsigned int i,
                                         SiStripDetVOff* modV,
                                         DetIdListTimeAndStatus& detIdStruct);

  std::unique_ptr<SiStripCoralIface> coralInterface;
};
#endif