CMS 3D CMS Logo

SiStripDetVOffHandler.cc
Go to the documentation of this file.
6 
7 #include <iostream>
8 #include <sstream>
9 
11 
13 
15 public:
16  explicit SiStripDetVOffHandler(const edm::ParameterSet& iConfig);
17  ~SiStripDetVOffHandler() override;
18  void analyze(const edm::Event& evt, const edm::EventSetup& evtSetup) override;
19  void endJob() override;
20 
21 private:
26 
28 
29  std::vector<std::pair<SiStripDetVOff*, cond::Time_t> > newPayloads;
31 };
32 
34  : m_connectionPool(),
35  m_condDb(iConfig.getParameter<std::string>("conditionDatabase")),
36  m_localCondDbFile(iConfig.getParameter<std::string>("condDbFile")),
37  m_targetTag(iConfig.getParameter<std::string>("targetTag")),
38  maxTimeBeforeNewIOV_(iConfig.getUntrackedParameter<int>("maxTimeBeforeNewIOV", 24)) {
41  // get last IOV from local sqlite file if "conditionDatabase" is empty
42  if (m_condDb.empty())
44 }
45 
47 
48 void SiStripDetVOffHandler::analyze(const edm::Event& evt, const edm::EventSetup& evtSetup) {
49  // get last payload from condDb
50  cond::Time_t lastIov = 0;
51  std::shared_ptr<SiStripDetVOff> lastPayload;
52 
53  edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
54  << "Retrieve last IOV from " << m_condDb;
56  condDbSession.transaction().start(true);
57  if (m_condDb.find("sqlite") == 0 && (!condDbSession.existsDatabase())) {
58  // Source of last IOV is empty
59  edm::LogInfo("SiStripDetVOffHandler")
60  << "[SiStripDetVOffHandler::" << __func__ << "] "
61  << "No information can be retrieved from " << m_condDb << " because the file is empty.\n"
62  << "Will assume all HV/LV's are off.";
63  } else {
64  cond::persistency::IOVProxy iovProxy = condDbSession.readIov(m_targetTag);
65  cond::Hash lastPayloadHash = iovProxy.getLast().payloadId;
66  if (!lastPayloadHash.empty()) {
67  lastPayload = condDbSession.fetchPayload<SiStripDetVOff>(lastPayloadHash);
68  lastIov = iovProxy.getLast().since; // move to LastValidatedTime?
69  }
70  edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
71  << " ... last IOV: " << lastIov << " , "
72  << "last Payload: " << lastPayloadHash;
73  }
74  condDbSession.transaction().commit();
75 
76  // build the object!
77  newPayloads.clear();
78  modHVBuilder->setLastSiStripDetVOff(lastPayload.get(), lastIov);
81  edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
82  << "Finished building " << newPayloads.size() << " new payloads.";
83 
84  // write the payloads to sqlite file
85  edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
86  << "Write new payloads to sqlite file " << m_localCondDbFile;
88  localFileSession.transaction().start(false);
89  if (lastPayload && newPayloads.size() == 1 && *newPayloads[0].first == *lastPayload) {
90  // if no HV/LV transition was found in this period
91  edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
92  << "No HV/LV transition was found from PVSS query.";
93  bool forceNewIOV = true;
94  if (maxTimeBeforeNewIOV_ < 0)
95  forceNewIOV = false;
96  else {
97  auto deltaT = cond::time::to_boost(newPayloads[0].second) - cond::time::to_boost(lastIov);
98  forceNewIOV = deltaT > boost::posix_time::hours(maxTimeBeforeNewIOV_);
99  }
100  if (!forceNewIOV) {
101  newPayloads.erase(newPayloads.begin());
102  edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] "
103  << " ... No payload transfered.";
104  } else {
105  edm::LogInfo("SiStripDetVOffHandler")
106  << "[SiStripDetVOffHandler::" << __func__ << "] "
107  << " ... The last IOV is too old. Will start a new IOV from " << newPayloads[0].second << "("
108  << boost::posix_time::to_simple_string(cond::time::to_boost(newPayloads[0].second))
109  << ") with the same payload.";
110  }
111  }
112 
114  if (localFileSession.existsDatabase() && localFileSession.existsIov(m_targetTag)) {
115  edm::LogWarning("SiStripDetVOffHandler")
116  << "[SiStripDetVOffHandler::" << __func__ << "] "
117  << "IOV of tag " << m_targetTag << " already exists in sqlite file " << m_localCondDbFile;
118  iovEditor = localFileSession.editIov(m_targetTag);
119  } else {
120  iovEditor = localFileSession.createIov<SiStripDetVOff>(m_targetTag, cond::timestamp);
121  iovEditor.setDescription("New IOV");
122  }
123  for (const auto& payload : newPayloads) {
124  cond::Hash thePayloadHash = localFileSession.storePayload<SiStripDetVOff>(*payload.first);
125  iovEditor.insert(payload.second, thePayloadHash);
126  }
127  iovEditor.flush();
128  localFileSession.transaction().commit();
129 
130  edm::LogInfo("SiStripDetVOffHandler") << "[SiStripDetVOffHandler::" << __func__ << "] " << newPayloads.size()
131  << " payloads written to sqlite file.";
132 }
133 
135 
136 // -------------------------------------------------------
T getParameter(std::string const &) const
Definition: ParameterSet.h:307
#define DEFINE_FWK_MODULE(type)
Definition: MakerMacros.h:16
void start(bool readOnly=true)
Definition: Session.cc:18
void analyze(const edm::Event &evt, const edm::EventSetup &evtSetup) override
Time_t since
Definition: Types.h:53
IOVEditor createIov(const std::string &tag, cond::TimeType timeType, cond::SynchronizationType synchronizationType=cond::SYNCH_ANY)
Definition: Session.h:179
std::unique_ptr< T > fetchPayload(const cond::Hash &payloadHash)
Definition: Session.h:213
void setDescription(const std::string &description)
Definition: IOVEditor.cc:139
Transaction & transaction()
Definition: Session.cc:52
void setParameters(const edm::ParameterSet &connectionPset)
U second(std::pair< T, U > const &p)
unsigned long long Time_t
Definition: Time.h:14
edm::Service< SiStripDetVOffBuilder > modHVBuilder
Hash payloadId
Definition: Types.h:55
Session createSession(const std::string &connectionString, bool writeCapable=false)
std::string Hash
Definition: Types.h:43
cond::persistency::ConnectionPool m_connectionPool
IOVProxy readIov(const std::string &tag)
Definition: Session.cc:63
IOVEditor editIov(const std::string &tag)
Definition: Session.cc:130
Log< level::Info, false > LogInfo
~SiStripDetVOffHandler() override
void insert(cond::Time_t since, const cond::Hash &payloadHash, bool checkType=false)
Definition: IOVEditor.cc:159
std::vector< std::pair< SiStripDetVOff *, cond::Time_t > > newPayloads
bool existsIov(const std::string &tag)
Definition: Session.cc:77
void setLastSiStripDetVOff(SiStripDetVOff *lastPayload, cond::Time_t lastTimeStamp)
cond::Hash storePayload(const T &payload, const boost::posix_time::ptime &creationTime=boost::posix_time::microsec_clock::universal_time())
Definition: Session.h:186
std::vector< std::pair< SiStripDetVOff *, cond::Time_t > > getModulesVOff()
SiStripDetVOffHandler SiStripO2ODetVOff
SiStripDetVOffHandler(const edm::ParameterSet &iConfig)
Log< level::Warning, false > LogWarning
boost::posix_time::ptime to_boost(Time_t iValue)