EcalDQMStatusWriter.cc

Go to the documentation of this file.

#include "DQM/EcalMonitorDbModule/interface/EcalDQMStatusWriter.h"
 
#include "DQM/EcalCommon/interface/StatusManager.h"
 
#include "CondCore/DBOutputService/interface/PoolDBOutputService.h"
#include "FWCore/ServiceRegistry/interface/Service.h"
 
#include "CommonTools/Utils/interface/Exception.h"
 
#include "FWCore/Framework/interface/MakerMacros.h"
 
#include <fstream>
 
EcalDQMStatusWriter::EcalDQMStatusWriter(edm::ParameterSet const &_ps)
    : channelStatus_(), towerStatus_(), firstRun_(_ps.getUntrackedParameter<unsigned>("firstRun")) {
  std::ifstream inputFile(_ps.getUntrackedParameter<std::string>("inputFile"));
  if (!inputFile.is_open())
    throw cms::Exception("Invalid input for EcalDQMStatusWriter");
 
  ecaldqm::StatusManager statusManager;
 
  statusManager.readFromStream(inputFile);
  statusManager.writeToObj(channelStatus_, towerStatus_);
}
 
void EcalDQMStatusWriter::analyze(edm::Event const &, edm::EventSetup const &_es) {
  cond::service::PoolDBOutputService &dbOutput(*edm::Service<cond::service::PoolDBOutputService>());
  if (firstRun_ == dbOutput.endOfTime())
    return;
 
  dbOutput.writeOne(&channelStatus_, firstRun_, "EcalDQMChannelStatusRcd");
  dbOutput.writeOne(&towerStatus_, firstRun_, "EcalDQMTowerStatusRcd");
 
  firstRun_ = dbOutput.endOfTime();  // avoid accidentally re-writing the conditions
}
 
DEFINE_FWK_MODULE(EcalDQMStatusWriter);