EcalTPGDBCopy Class Reference

#include <EcalTPGDBCopy.h>

Inheritance diagram for EcalTPGDBCopy:

Public Member Functions
void	analyze (const edm::Event &evt, const edm::EventSetup &evtSetup) override
	EcalTPGDBCopy (const edm::ParameterSet &iConfig)
	~EcalTPGDBCopy () override
Public Member Functions inherited from edm::EDAnalyzer
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)
	EDAnalyzer ()
SerialTaskQueue *	globalLuminosityBlocksQueue ()
SerialTaskQueue *	globalRunsQueue ()
ModuleDescription const &	moduleDescription () const
std::string	workerType () const
	~EDAnalyzer () 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 &&)=default
	EDConsumerBase (EDConsumerBase const &)=delete
ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const
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 &	operator= (EDConsumerBase &&)=default
EDConsumerBase const &	operator= (EDConsumerBase const &)=delete
bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const
bool	registeredToConsumeMany (TypeID const &, BranchType) const
ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const
void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)
void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)
virtual	~EDConsumerBase () noexcept(false)

Private Member Functions
void	copyToDB (const edm::EventSetup &evtSetup, std::string container)
bool	shouldCopy (const edm::EventSetup &evtSetup, std::string container)

Private Attributes
std::map< std::string, unsigned long long >	m_cacheIDs
std::map< std::string, std::string >	m_records
std::string	m_timetype

Additional Inherited Members
Public Types inherited from edm::EDAnalyzer
typedef EDAnalyzer	ModuleType
Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels
Static Public Member Functions inherited from edm::EDAnalyzer
static const std::string &	baseType ()
static void	fillDescriptions (ConfigurationDescriptions &descriptions)
static void	prevalidate (ConfigurationDescriptions &)
static bool	wantsGlobalLuminosityBlocks ()
static bool	wantsGlobalRuns ()
static bool	wantsStreamLuminosityBlocks ()
static bool	wantsStreamRuns ()
Protected Member Functions inherited from edm::EDConsumerBase
EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (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 ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()
template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)
template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

Detailed Description

Definition at line 18 of file EcalTPGDBCopy.h.

Constructor & Destructor Documentation

EcalTPGDBCopy()

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

explicit

Definition at line 47 of file EcalTPGDBCopy.cc.

    : m_timetype(iConfig.getParameter<std::string>("timetype")), m_cacheIDs(), m_records() {
  std::string container;
  std::string tag;
  std::string record;
  typedef std::vector<edm::ParameterSet> Parameters;
  Parameters toCopy = iConfig.getParameter<Parameters>("toCopy");
  for (Parameters::iterator i = toCopy.begin(); i != toCopy.end(); ++i) {
    container = i->getParameter<std::string>("container");
    record = i->getParameter<std::string>("record");
    m_cacheIDs.insert(std::make_pair(container, 0));
    m_records.insert(std::make_pair(container, record));
  }
}

References edm::ParameterSet::getParameter(), mps_fire::i, m_cacheIDs, m_records, GlobalPosition_Frontier_DevDB_cff::record, AlCaHLTBitMon_QueryRunRegistry::string, and GlobalPosition_Frontier_DevDB_cff::tag.

~EcalTPGDBCopy()

EcalTPGDBCopy::~EcalTPGDBCopy ( )

override

Definition at line 62 of file EcalTPGDBCopy.cc.

{}

Member Function Documentation

analyze()

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

overridevirtual

Implements edm::EDAnalyzer.

Definition at line 64 of file EcalTPGDBCopy.cc.

                                                                              {
  std::string container;
  std::string record;
  typedef std::map<std::string, std::string>::const_iterator recordIter;
  for (recordIter i = m_records.begin(); i != m_records.end(); ++i) {
    container = (*i).first;
    record = (*i).second;
    if (shouldCopy(evtSetup, container)) {
      copyToDB(evtSetup, container);
    }
  }
}

References copyToDB(), mps_fire::i, m_records, GlobalPosition_Frontier_DevDB_cff::record, shouldCopy(), and AlCaHLTBitMon_QueryRunRegistry::string.

copyToDB()

void EcalTPGDBCopy::copyToDB ( const edm::EventSetup &  evtSetup, std::string  container  )

private

Definition at line 124 of file EcalTPGDBCopy.cc.

                                                                               {
  edm::Service<cond::service::PoolDBOutputService> dbOutput;
  if (!dbOutput.isAvailable()) {
    throw cms::Exception("PoolDBOutputService is not available");
  }
 
  std::string recordName = m_records[container];
 
  if (container == "EcalTPGPedestals") {
    edm::ESHandle<EcalTPGPedestals> handle;
    evtSetup.get<EcalTPGPedestalsRcd>().get(handle);
    const EcalTPGPedestals* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGPedestals>(
        new EcalTPGPedestals(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGLinearizationConst") {
    edm::ESHandle<EcalTPGLinearizationConst> handle;
    evtSetup.get<EcalTPGLinearizationConstRcd>().get(handle);
    const EcalTPGLinearizationConst* obj = handle.product();
 
    dbOutput->createNewIOV<const EcalTPGLinearizationConst>(
        new EcalTPGLinearizationConst(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGSlidingWindow") {
    edm::ESHandle<EcalTPGSlidingWindow> handle;
    evtSetup.get<EcalTPGSlidingWindowRcd>().get(handle);
    const EcalTPGSlidingWindow* obj = handle.product();
 
    dbOutput->createNewIOV<const EcalTPGSlidingWindow>(
        new EcalTPGSlidingWindow(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGFineGrainEBIdMap") {
    edm::ESHandle<EcalTPGFineGrainEBIdMap> handle;
    evtSetup.get<EcalTPGFineGrainEBIdMapRcd>().get(handle);
    const EcalTPGFineGrainEBIdMap* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGFineGrainEBIdMap>(
        new EcalTPGFineGrainEBIdMap(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGFineGrainStripEE") {
    edm::ESHandle<EcalTPGFineGrainStripEE> handle;
    evtSetup.get<EcalTPGFineGrainStripEERcd>().get(handle);
    const EcalTPGFineGrainStripEE* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGFineGrainStripEE>(
        new EcalTPGFineGrainStripEE(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGFineGrainTowerEE") {
    edm::ESHandle<EcalTPGFineGrainTowerEE> handle;
    evtSetup.get<EcalTPGFineGrainTowerEERcd>().get(handle);
    const EcalTPGFineGrainTowerEE* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGFineGrainTowerEE>(
        new EcalTPGFineGrainTowerEE(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGLutIdMap") {
    edm::ESHandle<EcalTPGLutIdMap> handle;
    evtSetup.get<EcalTPGLutIdMapRcd>().get(handle);
    const EcalTPGLutIdMap* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGLutIdMap>(
        new EcalTPGLutIdMap(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGWeightIdMap") {
    edm::ESHandle<EcalTPGWeightIdMap> handle;
    evtSetup.get<EcalTPGWeightIdMapRcd>().get(handle);
    const EcalTPGWeightIdMap* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGWeightIdMap>(
        new EcalTPGWeightIdMap(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGWeightGroup") {
    edm::ESHandle<EcalTPGWeightGroup> handle;
    evtSetup.get<EcalTPGWeightGroupRcd>().get(handle);
    const EcalTPGWeightGroup* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGWeightGroup>(
        new EcalTPGWeightGroup(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGLutGroup") {
    edm::ESHandle<EcalTPGLutGroup> handle;
    evtSetup.get<EcalTPGLutGroupRcd>().get(handle);
    const EcalTPGLutGroup* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGLutGroup>(
        new EcalTPGLutGroup(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGFineGrainEBGroup") {
    edm::ESHandle<EcalTPGFineGrainEBGroup> handle;
    evtSetup.get<EcalTPGFineGrainEBGroupRcd>().get(handle);
 
    const EcalTPGFineGrainEBGroup* obj = handle.product();
 
    dbOutput->createNewIOV<const EcalTPGFineGrainEBGroup>(
        new EcalTPGFineGrainEBGroup(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGPhysicsConst") {
    edm::ESHandle<EcalTPGPhysicsConst> handle;
    evtSetup.get<EcalTPGPhysicsConstRcd>().get(handle);
    const EcalTPGPhysicsConst* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGPhysicsConst>(
        new EcalTPGPhysicsConst(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGCrystalStatus") {
    edm::ESHandle<EcalTPGCrystalStatus> handle;
    evtSetup.get<EcalTPGCrystalStatusRcd>().get(handle);
    const EcalTPGCrystalStatus* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGCrystalStatus>(
        new EcalTPGCrystalStatus(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGTowerStatus") {
    edm::ESHandle<EcalTPGTowerStatus> handle;
    evtSetup.get<EcalTPGTowerStatusRcd>().get(handle);
    const EcalTPGTowerStatus* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGTowerStatus>(
        new EcalTPGTowerStatus(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGSpike") {
    edm::ESHandle<EcalTPGSpike> handle;
    evtSetup.get<EcalTPGSpikeRcd>().get(handle);
    const EcalTPGSpike* obj = handle.product();
 
    dbOutput->createNewIOV<const EcalTPGSpike>(
        new EcalTPGSpike(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  } else if (container == "EcalTPGStripStatus") {
    edm::ESHandle<EcalTPGStripStatus> handle;
    evtSetup.get<EcalTPGStripStatusRcd>().get(handle);
    const EcalTPGStripStatus* obj = handle.product();
    dbOutput->createNewIOV<const EcalTPGStripStatus>(
        new EcalTPGStripStatus(*obj), dbOutput->beginOfTime(), dbOutput->endOfTime(), recordName);
 
  }
 
  else {
    throw cms::Exception("Unknown container");
  }
 
  std::cout << "EcalTPGDBCopy wrote " << recordName << std::endl;
}

References cond::service::PoolDBOutputService::beginOfTime(), gather_cfg::cout, cond::service::PoolDBOutputService::createNewIOV(), cond::service::PoolDBOutputService::endOfTime(), Exception, edm::EventSetup::get(), get, patZpeak::handle, edm::Service< T >::isAvailable(), m_records, getGTfromDQMFile::obj, align_cfg::recordName, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by analyze().

shouldCopy()

bool EcalTPGDBCopy::shouldCopy ( const edm::EventSetup &  evtSetup, std::string  container  )

private

Definition at line 77 of file EcalTPGDBCopy.cc.

                                                                                 {
  unsigned long long cacheID = 0;
 
  if (container == "EcalTPGPedestals") {
    cacheID = evtSetup.get<EcalTPGPedestalsRcd>().cacheIdentifier();
  } else if (container == "EcalTPGLinearizationConst") {
    cacheID = evtSetup.get<EcalTPGLinearizationConstRcd>().cacheIdentifier();
  } else if (container == "EcalTPGSlidingWindow") {
    cacheID = evtSetup.get<EcalTPGSlidingWindowRcd>().cacheIdentifier();
  } else if (container == "EcalTPGFineGrainEBIdMap") {
    cacheID = evtSetup.get<EcalTPGFineGrainEBIdMapRcd>().cacheIdentifier();
  } else if (container == "EcalTPGFineGrainStripEE") {
    cacheID = evtSetup.get<EcalTPGFineGrainStripEERcd>().cacheIdentifier();
  } else if (container == "EcalTPGFineGrainTowerEE") {
    cacheID = evtSetup.get<EcalTPGFineGrainTowerEERcd>().cacheIdentifier();
  } else if (container == "EcalTPGLutIdMap") {
    cacheID = evtSetup.get<EcalTPGLutIdMapRcd>().cacheIdentifier();
  } else if (container == "EcalTPGWeightIdMap") {
    cacheID = evtSetup.get<EcalTPGWeightIdMapRcd>().cacheIdentifier();
  } else if (container == "EcalTPGWeightGroup") {
    cacheID = evtSetup.get<EcalTPGWeightGroupRcd>().cacheIdentifier();
  } else if (container == "EcalTPGLutGroup") {
    cacheID = evtSetup.get<EcalTPGLutGroupRcd>().cacheIdentifier();
  } else if (container == "EcalTPGFineGrainEBGroup") {
    cacheID = evtSetup.get<EcalTPGFineGrainEBGroupRcd>().cacheIdentifier();
  } else if (container == "EcalTPGPhysicsConst") {
    cacheID = evtSetup.get<EcalTPGPhysicsConstRcd>().cacheIdentifier();
  } else if (container == "EcalTPGCrystalStatus") {
    cacheID = evtSetup.get<EcalTPGCrystalStatusRcd>().cacheIdentifier();
  } else if (container == "EcalTPGTowerStatus") {
    cacheID = evtSetup.get<EcalTPGTowerStatusRcd>().cacheIdentifier();
  } else if (container == "EcalTPGSpike") {
    cacheID = evtSetup.get<EcalTPGSpikeRcd>().cacheIdentifier();
  } else if (container == "EcalTPGStripStatus") {
    cacheID = evtSetup.get<EcalTPGStripStatusRcd>().cacheIdentifier();
  } else {
    throw cms::Exception("Unknown container");
  }
 
  if (m_cacheIDs[container] == cacheID) {
    return false;
  } else {
    m_cacheIDs[container] = cacheID;
    return true;
  }
}

References Exception, edm::EventSetup::get(), and m_cacheIDs.

Referenced by analyze().

Member Data Documentation

m_cacheIDs

std::map<std::string, unsigned long long> EcalTPGDBCopy::m_cacheIDs

private

Definition at line 30 of file EcalTPGDBCopy.h.

Referenced by EcalTPGDBCopy(), and shouldCopy().

m_records

std::map<std::string, std::string> EcalTPGDBCopy::m_records

private

Definition at line 31 of file EcalTPGDBCopy.h.

Referenced by analyze(), copyToDB(), and EcalTPGDBCopy().

m_timetype

std::string EcalTPGDBCopy::m_timetype

private

Definition at line 29 of file EcalTPGDBCopy.h.