#include <CondTools/BeamSpot/plugins/BeamSpotOnlineRecordsReader.cc>

Inheritance diagram for BeamSpotOnlineRecordsReader:

Classes
struct	theBSOfromDB

Public Member Functions
	BeamSpotOnlineRecordsReader (const edm::ParameterSet &)

	~BeamSpotOnlineRecordsReader () override

Public Member Functions inherited from edm::one::EDAnalyzer< edm::one::SharedResources >
	EDAnalyzer ()=default

	EDAnalyzer (const EDAnalyzer &)=delete

SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

const EDAnalyzer &	operator= (const EDAnalyzer &)=delete

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

bool	wantsInputProcessBlocks () const final

bool	wantsProcessBlocks () 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

ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const

std::vector< ESProxyIndex > const &	esGetTokenIndicesVector (edm::Transition iTrans) const

std::vector< ESRecordIndex > const &	esGetTokenRecordIndicesVector (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::array< std::vector< ModuleDescription const * > , NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, 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

void	selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

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 Member Functions
void	analyze (const edm::Event &, const edm::EventSetup &) override

void	beginJob () override

template<class Record >
void	dump (const edm::Event &, const edm::EventSetup &, const edm::ESGetToken< BeamSpotOnlineObjects, Record > &)

Private Attributes
TTree *	bstree_

edm::ESWatcher < BeamSpotOnlineHLTObjectsRcd >	hlt_watcher_

const edm::ESGetToken < BeamSpotOnlineObjects, BeamSpotOnlineHLTObjectsRcd >	hltToken

bool	isHLT_

edm::ESWatcher < BeamSpotOnlineLegacyObjectsRcd >	legacy_watcher_

const edm::ESGetToken < BeamSpotOnlineObjects, BeamSpotOnlineLegacyObjectsRcd >	legacyToken

std::unique_ptr< std::ofstream >	output_

edm::Service< TFileService >	tFileService

struct BeamSpotOnlineRecordsReader::theBSOfromDB	theBSOfromDB_

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)

template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept

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 ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

template<Transition Tr = Transition::Event>
constexpr auto	esConsumes ()

template<Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag tag)

template<Transition Tr = Transition::Event>
ESGetTokenGeneric	esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
	Used with EventSetupRecord::doGet. More...

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)

void	resetItemsToGetFrom (BranchType iType)

Detailed Description

Description: EDAnalyzer to read the BeamSpotOnlineHLTObjectsRcd or BeamSpotOnlineLegacyObjectsRcd and dump it into a txt and root file

Implementation: [Notes on implementation]

Definition at line 50 of file BeamSpotOnlineRecordsReader.cc.

Constructor & Destructor Documentation

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

explicit

Definition at line 95 of file BeamSpotOnlineRecordsReader.cc.

References MillePedeFileConverter_cfg::fileName, edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), isHLT_, output_, and AlCaHLTBitMon_QueryRunRegistry::string.

     : bstree_(nullptr), hltToken(esConsumes()), legacyToken(esConsumes()) {
   //now do what ever initialization is needed
   isHLT_ = iConfig.getParameter<bool>("isHLT");
   usesResource("TFileService");
   std::string fileName(iConfig.getUntrackedParameter<std::string>("rawFileName"));
   if (!fileName.empty()) {
     output_ = std::make_unique<std::ofstream>(fileName.c_str());
     if (!output_->good()) {
       edm::LogError("IOproblem") << "Could not open output file " << fileName << ".";
       output_.reset();
     }
   }
 }

BeamSpotOnlineRecordsReader::~BeamSpotOnlineRecordsReader ( )

overridedefault

Member Function Documentation

void BeamSpotOnlineRecordsReader::analyze	(	const edm::Event &	iEvent,
		const edm::EventSetup &	iSetup
	)

overrideprivatevirtual

Implements edm::one::EDAnalyzerBase.

Definition at line 135 of file BeamSpotOnlineRecordsReader.cc.

References edm::ESWatcher< T >::check(), hlt_watcher_, hltToken, iEvent, isHLT_, legacy_watcher_, and legacyToken.

                                                                                              {
   using namespace edm;
 
   if (isHLT_) {
     if (hlt_watcher_.check(iSetup)) {
       dump<BeamSpotOnlineHLTObjectsRcd>(iEvent, iSetup, hltToken);
     }  // check for new IOV for this run / LS
   } else {
     if (legacy_watcher_.check(iSetup)) {
       dump<BeamSpotOnlineLegacyObjectsRcd>(iEvent, iSetup, legacyToken);
     }  // check for new IOV for this run / LS
   }
 }

void BeamSpotOnlineRecordsReader::beginJob ( void )

overrideprivatevirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 187 of file BeamSpotOnlineRecordsReader.cc.

                                            {
   bstree_ = tFileService->make<TTree>("BSONtuple", "BeamSpotOnline analyzer ntuple");
 
   //Tree Branches
   bstree_->Branch("run", &theBSOfromDB_.run, "run/I");
   bstree_->Branch("ls", &theBSOfromDB_.ls, "ls/I");
   bstree_->Branch("BSx0", &theBSOfromDB_.BSx0_, "BSx0/F");
   bstree_->Branch("BSy0", &theBSOfromDB_.BSy0_, "BSy0/F");
   bstree_->Branch("BSz0", &theBSOfromDB_.BSz0_, "BSz0/F");
   bstree_->Branch("Beamsigmaz", &theBSOfromDB_.Beamsigmaz_, "Beamsigmaz/F");
   bstree_->Branch("Beamdxdz", &theBSOfromDB_.Beamdxdz_, "Beamdxdz/F");
   bstree_->Branch("BeamWidthX", &theBSOfromDB_.BeamWidthX_, "BeamWidthX/F");
   bstree_->Branch("BeamWidthY", &theBSOfromDB_.BeamWidthY_, "BeamWidthY/F");
   bstree_->Branch("LastAnalyzedLumi", &theBSOfromDB_.lastAnalyzedLumi_, "LastAnalyzedLumi/I");
   bstree_->Branch("LastAnalyzedRun", &theBSOfromDB_.lastAnalyzedRun_, "LastAnalyzedRun/I");
   bstree_->Branch("LastAnalyzedFill", &theBSOfromDB_.lastAnalyzedFill_, "LastAnalyzedFill/I");
 }

template<class Record >

void BeamSpotOnlineRecordsReader::dump	(	const edm::Event &	iEvent,
		const edm::EventSetup &	iSetup,
		const edm::ESGetToken< BeamSpotOnlineObjects, Record > &	token
	)

private

Definition at line 150 of file BeamSpotOnlineRecordsReader.cc.

                                                                                                   {
   std::ostringstream output;
   // initialize the ntuple
   theBSOfromDB_.init();
   output << " for runs: " << iEvent.id().run() << " - " << iEvent.id().luminosityBlock() << std::endl;
 
   // Get BeamSpot from EventSetup:
   const BeamSpotOnlineObjects* mybeamspot = &iSetup.getData(token);
 
   theBSOfromDB_.run = iEvent.id().run();
   theBSOfromDB_.ls = iEvent.id().luminosityBlock();
   theBSOfromDB_.BSx0_ = mybeamspot->x();
   theBSOfromDB_.BSy0_ = mybeamspot->y();
   theBSOfromDB_.BSz0_ = mybeamspot->z();
   theBSOfromDB_.Beamsigmaz_ = mybeamspot->sigmaZ();
   theBSOfromDB_.Beamdxdz_ = mybeamspot->dxdz();
   theBSOfromDB_.BeamWidthX_ = mybeamspot->beamWidthX();
   theBSOfromDB_.BeamWidthY_ = mybeamspot->beamWidthY();
   theBSOfromDB_.lastAnalyzedLumi_ = mybeamspot->lastAnalyzedLumi();
   theBSOfromDB_.lastAnalyzedRun_ = mybeamspot->lastAnalyzedRun();
   theBSOfromDB_.lastAnalyzedFill_ = mybeamspot->lastAnalyzedFill();
 
   bstree_->Fill();
 
   output << *mybeamspot << std::endl;
 
   // Final output - either message logger or output file:
   if (output_.get()) {
     *output_ << output.str();
   } else {
     edm::LogInfo("BeamSpotOnlineRecordsReader") << output.str();
   }
 }

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

static

Definition at line 206 of file BeamSpotOnlineRecordsReader.cc.

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

                                                                                              {
   edm::ParameterSetDescription desc;
   desc.add<bool>("isHLT", true);
   desc.addUntracked<std::string>("rawFileName", "");
   descriptions.addDefault(desc);
 }