SiStripDetVOffPrinter Class Reference

Inheritance diagram for SiStripDetVOffPrinter:

Public Member Functions
void	analyze (const edm::Event &evt, const edm::EventSetup &evtSetup) override
void	endJob () override
	SiStripDetVOffPrinter (const edm::ParameterSet &iConfig)
	~SiStripDetVOffPrinter () override
Public Member Functions inherited from edm::one::EDAnalyzer<>
	EDAnalyzer ()=default
SerialTaskQueue *	globalLuminosityBlocksQueue () final
SerialTaskQueue *	globalRunsQueue () final
bool	wantsGlobalLuminosityBlocks () const final
bool	wantsGlobalRuns () const final
Public Member Functions inherited from edm::one::EDAnalyzerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
	EDAnalyzerBase ()
ModuleDescription const &	moduleDescription () const
bool	wantsStreamLuminosityBlocks () const
bool	wantsStreamRuns () const
	~EDAnalyzerBase () override
Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const
void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...
	EDConsumerBase ()
	EDConsumerBase (EDConsumerBase const &)=delete
	EDConsumerBase (EDConsumerBase &&)=default
ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const
void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const
std::vector< ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const
void	labelsForToken (EDGetToken iToken, Labels &oLabels) const
void	modulesWhoseProductsAreConsumed (std::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const
EDConsumerBase const &	operator= (EDConsumerBase const &)=delete
EDConsumerBase &	operator= (EDConsumerBase &&)=default
bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const
bool	registeredToConsumeMany (TypeID const &, BranchType) const
ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const
void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)
virtual	~EDConsumerBase () noexcept(false)

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)
Static Public Member Functions inherited from edm::one::EDAnalyzerBase
static const std::string &	baseType ()
static void	fillDescriptions (ConfigurationDescriptions &descriptions)
static void	prevalidate (ConfigurationDescriptions &descriptions)

Private Attributes
std::map< uint32_t, std::vector< cond::Time_t > >	detidMap
edm::Service< SiStripDetInfoFileReader >	detidReader
std::map< cond::Time_t, std::set< uint32_t > >	iovMap_HVOff
std::map< cond::Time_t, std::set< uint32_t > >	iovMap_LVOff
std::string	m_condDb
cond::persistency::ConnectionPool	m_connectionPool
std::string	m_endTime
std::string	m_output
std::string	m_startTime
std::string	m_tagName

Additional Inherited Members
Public Types inherited from edm::one::EDAnalyzerBase
typedef EDAnalyzerBase	ModuleType
Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels
Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)
EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)
template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)
ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...
template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()
void	consumesMany (const TypeToGet &id)
template<BranchType B>
void	consumesMany (const TypeToGet &id)
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)
template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

Detailed Description

Definition at line 28 of file SiStripDetVOffPrinter.cc.

Constructor & Destructor Documentation

SiStripDetVOffPrinter::SiStripDetVOffPrinter ( const edm::ParameterSet &  iConfig )

explicit

Definition at line 57 of file SiStripDetVOffPrinter.cc.

References cond::persistency::ConnectionPool::configure(), edm::ParameterSet::getParameter(), m_connectionPool, and cond::persistency::ConnectionPool::setParameters().

                                                                          :
  m_connectionPool(),
  m_condDb( iConfig.getParameter< std::string >("conditionDatabase") ),
  m_tagName( iConfig.getParameter< std::string >("tagName") ),
  m_startTime( iConfig.getParameter< std::string >("startTime") ),
  m_endTime( iConfig.getParameter< std::string >("endTime") ),
  m_output( iConfig.getParameter< std::string >("output") )
{
  m_connectionPool.setParameters( iConfig.getParameter<edm::ParameterSet>("DBParameters")  );
  m_connectionPool.configure();
}

SiStripDetVOffPrinter::~SiStripDetVOffPrinter ( )

override

Definition at line 69 of file SiStripDetVOffPrinter.cc.

                                              {
}

Member Function Documentation

void SiStripDetVOffPrinter::analyze ( const edm::Event &  evt, const edm::EventSetup &  evtSetup  )

override

Definition at line 72 of file SiStripDetVOffPrinter.cc.

References cond::persistency::Transaction::commit(), cond::persistency::ConnectionPool::createSession(), detidMap, cond::persistency::IOVProxy::end(), Exception, cond::persistency::Session::fetchPayload(), spr::find(), cond::persistency::IOVProxy::find(), groupFilesInBlocks::fout, cond::time::from_boost(), iovMap_HVOff, iovMap_LVOff, m_condDb, m_connectionPool, m_endTime, m_output, m_startTime, m_tagName, jets_cff::payload, cond::persistency::Session::readIov(), cond::persistency::Transaction::start(), cond::time::to_boost(), and cond::persistency::Session::transaction().

                                                                                      {
  
  // get total number of modules
  //auto num_modules = detidReader->getAllDetIds().size();

  // use start and end time from config file
  boost::posix_time::ptime p_start, p_end;
  p_start = boost::posix_time::time_from_string(m_startTime);
  p_end   = boost::posix_time::time_from_string(m_endTime);
  cond::Time_t startIov = cond::time::from_boost(p_start);
  cond::Time_t endIov   = cond::time::from_boost(p_end);
  if (startIov > endIov)
    throw cms::Exception("endTime must be greater than startTime!");
  edm::LogInfo("SiStripDetVOffPrinter") << "[SiStripDetVOffPrinter::" << __func__ << "] "
                    << "Set start time " << startIov << " (" << boost::posix_time::to_simple_string(p_start) << ")"
                    << "\n ... Set end time " << endIov << " (" << boost::posix_time::to_simple_string(p_end) << ")" ;

  // open db session
  edm::LogInfo("SiStripDetVOffPrinter") << "[SiStripDetVOffPrinter::" << __func__ << "] "
                    << "Query the condition database " << m_condDb;
  cond::persistency::Session condDbSession = m_connectionPool.createSession( m_condDb );
  condDbSession.transaction().start( true );

  std::stringstream ss;
  // list of times with new IOVs within the time range
  std::vector< cond::Time_t > vTime;
  
  // query the database
  edm::LogInfo("SiStripDetVOffPrinter") << "[SiStripDetVOffPrinter::" << __func__ << "] "
                    << "Reading IOVs from tag " << m_tagName;
  cond::persistency::IOVProxy iovProxy = condDbSession.readIov(m_tagName, true); // load all?
  auto iiov = iovProxy.find(startIov);
  auto eiov = iovProxy.find(endIov);
  int niov = 0;
  while (iiov != iovProxy.end() && (*iiov).since <= (*eiov).since){
    // convert cond::Time_t to seconds since epoch
    if ((*iiov).since<startIov){
      vTime.push_back(startIov);
    } else {
      vTime.push_back((*iiov).since);
    }
    auto payload = condDbSession.fetchPayload<SiStripDetVOff>( (*iiov).payloadId );
    // print IOVs summary
    ss  << boost::posix_time::to_simple_string(cond::time::to_boost((*iiov).since))
    << " (" << (*iiov).since <<  ")"
    << ", # HV Off=" << std::setw(6) << payload->getHVoffCounts()
    << ", # LV Off=" << std::setw(6) << payload->getLVoffCounts() << std::endl;

    // list of detids with HV/LV Off
    std::vector<uint32_t> detIds;
    payload->getDetIds(detIds);
    std::set<uint32_t> detIds_HVOff;
    std::set<uint32_t> detIds_LVOff;
    std::vector<uint32_t>::const_iterator it = detIds.begin();
    for( ; it!=detIds.end(); ++it ) {
      if(payload->IsModuleHVOff(*it) ) detIds_HVOff.insert(*it);
      if(payload->IsModuleLVOff(*it) ) detIds_LVOff.insert(*it);
      
      if(detidMap.find(*it)==detidMap.end()) {
    std::vector< cond::Time_t > vec;
    detidMap[*it] = vec;          
      }
      
      // for each module concerned by the IOV, add the time in an history vector
      detidMap[*it].push_back(vTime.back());
    }
    
    // fill list of channels Off at a given time
    iovMap_HVOff[vTime.back()] = detIds_HVOff;
    iovMap_LVOff[vTime.back()] = detIds_LVOff;
    
    /*std::vector<uint32_t>::const_iterator it = detIds.begin();
      for( ; it!=detIds.end(); ++it ) {
      std::cout << *it << std::endl;
      }*/
    
    ++iiov;
    ++niov;
  }
  vTime.push_back(endIov); // used to compute last IOV duration

  edm::LogInfo("SiStripDetVOffPrinter") << "[SiStripDetVOffPrinter::" << __func__ << "] "
                    << "Read " << niov << " IOVs from tag " << m_tagName << " corresponding to the specified time interval.\n" << ss.str();


  // Create a map of IOVs time_duration
  std::map< cond::Time_t, boost::posix_time::time_duration > mIOVsDuration;
  std::vector< cond::Time_t >::const_iterator itTime = ++vTime.begin();
  std::vector< cond::Time_t >::const_iterator itPreviousTime = vTime.begin();
  //std::vector< cond::Time_t >::const_iterator itLastTime = --vTime.end();
  for( ; itTime!=vTime.end(); ++itTime ) {
    mIOVsDuration[ *itPreviousTime ] = cond::time::to_boost(*itTime) - cond::time::to_boost(*itPreviousTime);
    itPreviousTime = itTime;
  }
  boost::posix_time::time_duration time_period = cond::time::to_boost(*(--vTime.end())) - cond::time::to_boost(*(vTime.begin()));
  
  // debug
  /*for( itTime=vTime.begin(); itTime!=itLastTime; ++itTime ) {
    std::cout<<boost::posix_time::to_simple_string( cond::time::to_boost(*itTime) ) << "    " <<boost::posix_time::to_simple_string(mIOVsDuration[ *itTime ])<<std::endl;
  }*/

  // Print summary per module   
  edm::LogInfo("SiStripDetVOffPrinter") << "[SiStripDetVOffPrinter::" << __func__ << "] "
                    << detidMap.size() << " modules were Off at some point during the time interval";
  ss.str("");
  
  // Loop over detIds
  std::map<uint32_t, std::vector< cond::Time_t > >::const_iterator itMap = detidMap.begin();
  for( ; itMap!=detidMap.end(); ++itMap ) {
    std::vector< cond::Time_t > vecTime = itMap->second;
    
    boost::posix_time::time_duration cumul_time_HVOff(0,0,0,0);
    boost::posix_time::time_duration cumul_time_LVOff(0,0,0,0);
    // Loop over IOVs
    std::vector< cond::Time_t >::const_iterator itTime = vecTime.begin();
    for( ; itTime!=vecTime.end(); ++itTime ) {
      if(iovMap_HVOff[*itTime].find(itMap->first) != iovMap_HVOff[*itTime].end()) cumul_time_HVOff+=mIOVsDuration[*itTime];
      if(iovMap_LVOff[*itTime].find(itMap->first) != iovMap_LVOff[*itTime].end()) cumul_time_LVOff+=mIOVsDuration[*itTime];
    }
    ss<<"detId "<< itMap->first <<" #IOVs: "<<vecTime.size()
      <<"  HVOff: "<<cumul_time_HVOff<<" "<<cumul_time_HVOff.total_milliseconds()*100.0/time_period.total_milliseconds()<<"% "
      <<"  LVOff: "<<cumul_time_LVOff<<" "<<cumul_time_LVOff.total_milliseconds()*100.0/time_period.total_milliseconds()<<"%"<<std::endl;
    
  }

  condDbSession.transaction().commit();
 
  if (!m_output.empty()) {
    std::ofstream fout;
    fout.open(m_output);
    fout << ss.str();
    fout.close();
  }  
}

void SiStripDetVOffPrinter::endJob ( void  )

overridevirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 229 of file SiStripDetVOffPrinter.cc.

References DEFINE_FWK_MODULE.

Referenced by o2olib.O2ORunMgr::executeJob().

                                   {
}

void SiStripDetVOffPrinter::fillDescriptions ( edm::ConfigurationDescriptions &  descriptions )

static

Definition at line 208 of file SiStripDetVOffPrinter.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::add(), edm::ParameterSetDescription::addUntracked(), and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                   {

  edm::ParameterSetDescription desc;
  desc.add<std::string>("conditionDatabase","frontier://FrontierProd/CMS_CONDITIONS");
  desc.add<std::string>("tagName","SiStripDetVOff_1hourDelay_v1_Validation");
  desc.add<std::string>("startTime","2002-01-20 23:59:59.000");
  desc.add<std::string>("endTime","2002-01-20 23:59:59.000");
  desc.add<std::string>("output","PerModuleSummary.txt");
  desc.add<std::string>("connect","");

  edm::ParameterSetDescription descDBParameters;
  descDBParameters.addUntracked<std::string>("authenticationPath","");  
  descDBParameters.addUntracked<int>("authenticationSystem",0);  
  descDBParameters.addUntracked<std::string>("security","");  
  descDBParameters.addUntracked<int>("messageLevel",0);  

  desc.add<edm::ParameterSetDescription>("DBParameters",descDBParameters);
  descriptions.add("siStripDetVOffPrinter", desc);
}

Member Data Documentation

std::map<uint32_t, std::vector< cond::Time_t > > SiStripDetVOffPrinter::detidMap

private

Definition at line 54 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

edm::Service<SiStripDetInfoFileReader> SiStripDetVOffPrinter::detidReader

private

Definition at line 48 of file SiStripDetVOffPrinter.cc.

std::map<cond::Time_t, std::set< uint32_t > > SiStripDetVOffPrinter::iovMap_HVOff

private

Definition at line 51 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

std::map<cond::Time_t, std::set< uint32_t > > SiStripDetVOffPrinter::iovMap_LVOff

private

Definition at line 52 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

std::string SiStripDetVOffPrinter::m_condDb

private

Definition at line 40 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

cond::persistency::ConnectionPool SiStripDetVOffPrinter::m_connectionPool

private

Definition at line 39 of file SiStripDetVOffPrinter.cc.

Referenced by analyze(), and SiStripDetVOffPrinter().

std::string SiStripDetVOffPrinter::m_endTime

private

Definition at line 45 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

std::string SiStripDetVOffPrinter::m_output

private

Definition at line 47 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

std::string SiStripDetVOffPrinter::m_startTime

private

Definition at line 44 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

std::string SiStripDetVOffPrinter::m_tagName

private

Definition at line 41 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().