#include <L1MuGMTHWFileReader.h>

Inheritance diagram for L1MuGMTHWFileReader:

Public Member Functions
	L1MuGMTHWFileReader (edm::ParameterSet const &, edm::InputSourceDescription const &)

void	readNextEvent ()

	~L1MuGMTHWFileReader ()

Public Member Functions inherited from edm::ProducerSourceFromFiles
bool	noFiles () const override

	ProducerSourceFromFiles (ParameterSet const &pset, InputSourceDescription const &desc, bool realData)

	~ProducerSourceFromFiles () override

Public Member Functions inherited from edm::ProducerSourceBase
EventNumber_t	event () const

unsigned int	eventCreationDelay () const

EventID const &	eventID () const

LuminosityBlockNumber_t	luminosityBlock () const

unsigned int	numberEventsInLumi () const

unsigned int	numberEventsInRun () const

unsigned int	numberEventsInThisLumi () const

unsigned int	numberEventsInThisRun () const

TimeValue_t	presentTime () const

	ProducerSourceBase (ParameterSet const &pset, InputSourceDescription const &desc, bool realData)

RunNumber_t	run () const

unsigned int	timeBetweenEvents () const

	~ProducerSourceBase () noexcept(false) override

Public Member Functions inherited from edm::PuttableSourceBase
	PuttableSourceBase (ParameterSet const &, InputSourceDescription const &)

void	registerProducts () final
	Register any produced products. More...

Public Member Functions inherited from edm::InputSource
std::shared_ptr< ActivityRegistry >	actReg () const
	Accessor for Activity Registry. More...

std::shared_ptr< BranchIDListHelper const >	branchIDListHelper () const
	Accessors for branchIDListHelper. More...

std::shared_ptr< BranchIDListHelper > &	branchIDListHelper ()

void	closeFile (FileBlock *, bool cleaningUpAfterException)
	close current file More...

void	doBeginJob ()
	Called by framework at beginning of job. More...

void	doEndJob ()
	Called by framework at end of job. More...

ProcessingController::ForwardState	forwardState () const

bool	goToEvent (EventID const &eventID)

	InputSource (ParameterSet const &, InputSourceDescription const &)
	Constructor. More...

	InputSource (InputSource const &)=delete

void	issueReports (EventID const &eventID)
	issue an event report More...

LuminosityBlockNumber_t	luminosityBlock () const
	Accessor for current luminosity block number. More...

std::shared_ptr< LuminosityBlockAuxiliary >	luminosityBlockAuxiliary () const
	Called by the framework to merge or insert lumi in principal cache. More...

int	maxEvents () const

int	maxLuminosityBlocks () const

ModuleDescription const &	moduleDescription () const
	Accessor for 'module' description. More...

ItemType	nextItemType ()
	Advances the source to the next item. More...

InputSource &	operator= (InputSource const &)=delete

ProcessConfiguration const &	processConfiguration () const
	Accessor for Process Configuration. More...

std::string const &	processGUID () const
	Accessor for global process identifier. More...

ProcessHistoryRegistry const &	processHistoryRegistry () const
	Accessors for process history registry. More...

ProcessHistoryRegistry &	processHistoryRegistry ()

ProcessingMode	processingMode () const
	RunsLumisAndEvents (default), RunsAndLumis, or Runs. More...

std::shared_ptr< ProductRegistry const >	productRegistry () const
	Accessors for product registry. More...

std::shared_ptr< ProductRegistry > &	productRegistry ()

bool	randomAccess () const

void	readAndMergeLumi (LuminosityBlockPrincipal &lbp)
	Read next luminosity block (same as a prior lumi) More...

void	readAndMergeRun (RunPrincipal &rp)
	Read next run (same as a prior run) More...

void	readEvent (EventPrincipal &ep, StreamContext &)
	Read next event. More...

bool	readEvent (EventPrincipal &ep, EventID const &, StreamContext &)
	Read a specific event. More...

std::unique_ptr< FileBlock >	readFile ()
	Read next file. More...

void	readLuminosityBlock (LuminosityBlockPrincipal &lumiPrincipal, HistoryAppender &historyAppender)
	Read next luminosity block (new lumi) More...

std::shared_ptr< LuminosityBlockAuxiliary >	readLuminosityBlockAuxiliary ()
	Read next luminosity block Auxilary. More...

void	readRun (RunPrincipal &runPrincipal, HistoryAppender &historyAppender)
	Read next run (new run) More...

std::shared_ptr< RunAuxiliary >	readRunAuxiliary ()
	Read next run Auxiliary. More...

ProcessHistoryID const &	reducedProcessHistoryID () const

int	remainingEvents () const

int	remainingLuminosityBlocks () const

void	repeat ()
	Reset the remaining number of events/lumis to the maximum number. More...

std::pair< SharedResourcesAcquirer , std::recursive_mutex >	resourceSharedWithDelayedReader ()
	Returns nullptr if no resource shared between the Source and a DelayedReader. More...

ProcessingController::ReverseState	reverseState () const

void	rewind ()
	Begin again at the first event. More...

RunNumber_t	run () const
	Accessor for current run number. More...

std::shared_ptr< RunAuxiliary >	runAuxiliary () const
	Called by the framework to merge or insert run in principal cache. More...

void	setLuminosityBlockNumber_t (LuminosityBlockNumber_t lb)
	Set the luminosity block ID. More...

void	setRunNumber (RunNumber_t r)
	Set the run number. More...

void	skipEvents (int offset)

std::shared_ptr< ThinnedAssociationsHelper const >	thinnedAssociationsHelper () const
	Accessors for thinnedAssociationsHelper. More...

std::shared_ptr< ThinnedAssociationsHelper > &	thinnedAssociationsHelper ()

Timestamp const &	timestamp () const
	Accessor for the current time, as seen by the input source. More...

virtual	~InputSource () noexcept(false)
	Destructor. More...

Public Member Functions inherited from edm::ProducerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

std::vector< edm::ProductResolverIndex > const &	indiciesForPutProducts (BranchType iBranchType) const

	ProducerBase ()

std::vector< edm::ProductResolverIndex > const &	putTokenIndexToProductResolverIndex () const

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

std::function< void(BranchDescription const &)>	registrationCallback () const
	used by the fwk to register list of products More...

void	resolvePutIndicies (BranchType iBranchType, ModuleToResolverIndicies const &iIndicies, std::string const &moduleLabel)

virtual	~ProducerBase () noexcept(false)

Private Member Functions
virtual void	produce (edm::Event &)

virtual bool	setRunAndEventInfo (edm::EventID &id, edm::TimeValue_t &time, edm::EventAuxiliary::ExperimentType &eType)

Private Attributes
L1MuGMTInputEvent	m_evt

std::ifstream	m_in

Additional Inherited Members
Public Types inherited from edm::InputSource
enum	ItemType { IsInvalid, IsStop, IsFile, IsRun, IsLumi, IsEvent, IsRepeat, IsSynchronize }

enum	ProcessingMode { Runs, RunsAndLumis, RunsLumisAndEvents }

Public Types inherited from edm::ProducerBase
using	ModuleToResolverIndicies = std::unordered_multimap< std::string, std::tuple< edm::TypeID const , const char , edm::ProductResolverIndex >>

typedef ProductRegistryHelper::TypeLabelList	TypeLabelList

Static Public Member Functions inherited from edm::ProducerSourceFromFiles
static void	fillDescription (ParameterSetDescription &desc)

Static Public Member Functions inherited from edm::ProducerSourceBase
static void	fillDescription (ParameterSetDescription &desc)

Static Public Member Functions inherited from edm::InputSource
static const std::string &	baseType ()

static void	fillDescription (ParameterSetDescription &desc)

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &)

Public Attributes inherited from edm::InputSource
signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)>	postEventReadFromSourceSignal_

signalslot::Signal< void(StreamContext const &, ModuleCallingContext const &)>	preEventReadFromSourceSignal_

Protected Member Functions inherited from edm::PuttableSourceBase
void	beginJob () override

Protected Member Functions inherited from edm::InputSource
void	decreaseRemainingEventsBy (int iSkipped)

bool	eventCached () const

bool	newLumi () const

bool	newRun () const

ProcessHistoryRegistry &	processHistoryRegistryForUpdate ()

ProductRegistry &	productRegistryUpdate ()

void	reset () const

void	resetEventCached ()

void	resetLuminosityBlockAuxiliary (bool isNewLumi=true) const

void	resetNewLumi ()

void	resetNewRun ()

void	resetRunAuxiliary (bool isNewRun=true) const

void	setEventCached ()
	Called by the framework to merge or ached() const {return eventCached_;}. More...

void	setLuminosityBlockAuxiliary (LuminosityBlockAuxiliary *lbp)

void	setNewLumi ()

void	setNewRun ()

void	setRunAuxiliary (RunAuxiliary *rp)

void	setTimestamp (Timestamp const &theTime)
	To set the current time, as seen by the input source. More...

ItemType	state () const

Detailed Description

Definition at line 39 of file L1MuGMTHWFileReader.h.

Constructor & Destructor Documentation

L1MuGMTHWFileReader::L1MuGMTHWFileReader	(	edm::ParameterSet const &	ps,
		edm::InputSourceDescription const &	desc
	)

explicit

Definition at line 37 of file L1MuGMTHWFileReader.cc.

References edm::FromFiles::fileNames(), spr::find(), and m_in.

                                                                                 :
                                          ProducerSourceFromFiles(ps, desc, true) {
 
   produces<std::vector<L1MuRegionalCand> >("DT");
   produces<std::vector<L1MuRegionalCand> >("CSC");
   produces<std::vector<L1MuRegionalCand> >("RPCb");
   produces<std::vector<L1MuRegionalCand> >("RPCf");
 
   produces<L1CaloRegionCollection>();
 
   if(!fileNames().size()) {
     throw std::runtime_error("L1MuGMTHWFileReader: no input file");
   }
   edm::LogInfo("GMT_HWFileReader_info") << "opening file " << fileNames()[0];
   m_in.open((fileNames()[0].substr(fileNames()[0].find(":")+1)).c_str());
   if(!m_in) {
     throw std::runtime_error("L1MuGMTHWFileReader: file " + fileNames()[0]
             + " could not be openned");
   }
 
 }

L1MuGMTHWFileReader::~L1MuGMTHWFileReader ( )

Definition at line 63 of file L1MuGMTHWFileReader.cc.

References m_in.

                                           {
   m_in.close();
 }

Member Function Documentation

void L1MuGMTHWFileReader::produce ( edm::Event & e )

privatevirtual

Implements edm::ProducerSourceBase.

Definition at line 80 of file L1MuGMTHWFileReader.cc.

References L1MuGMTInputEvent::getInputMuon(), L1MuGMTInputEvent::getIsoBit(), L1MuGMTInputEvent::getMipBit(), mps_fire::i, m_evt, eostools::move(), RPCpg::mu, and edm::Event::put().

                                              {
   L1MuRegionalCand empty_mu;
 
 
   std::unique_ptr<std::vector<L1MuRegionalCand> > DTCands(new std::vector<L1MuRegionalCand>);
   for (unsigned i = 0; i < 4; i++) {
     const L1MuRegionalCand *mu = m_evt.getInputMuon("IND", i);
     if (!mu) mu = &empty_mu;
     DTCands->push_back(*mu);
   }
   e.put(std::move(DTCands),"DT");
 
   std::unique_ptr<std::vector<L1MuRegionalCand> > CSCCands(new std::vector<L1MuRegionalCand>);
   for (unsigned i = 0; i < 4; i++) {
     const L1MuRegionalCand *mu = m_evt.getInputMuon("INC", i);
     if (!mu) mu = &empty_mu;
     CSCCands->push_back(*mu);
   }
   e.put(std::move(CSCCands),"CSC");
 
   std::unique_ptr<std::vector<L1MuRegionalCand> > RPCbCands(new std::vector<L1MuRegionalCand>);
   for (unsigned i = 0; i < 4; i++) {
     const L1MuRegionalCand *mu = m_evt.getInputMuon("INB", i);
     if (!mu) mu = &empty_mu;
     RPCbCands->push_back(*mu);
   }
   e.put(std::move(RPCbCands),"RPCb");
 
   std::unique_ptr<std::vector<L1MuRegionalCand> > RPCfCands(new std::vector<L1MuRegionalCand>);
   for (unsigned i = 0; i < 4; i++) {
     const L1MuRegionalCand *mu = m_evt.getInputMuon("INF", i);
     if (!mu) mu = &empty_mu;
     RPCfCands->push_back(*mu);
   }
   e.put(std::move(RPCfCands),"RPCf");
 
   std::unique_ptr<L1CaloRegionCollection> rctRegions (new L1CaloRegionCollection);
   for(int ieta = 4; ieta < 18; ieta++) {
     for(int iphi = 0; iphi < 18; iphi++) {
       rctRegions->push_back(L1CaloRegion(0,false,true,m_evt.getMipBit(ieta-4,iphi),m_evt.getIsoBit(ieta-4,iphi),ieta,iphi));
     }
   }
 
   e.put(std::move(rctRegions));
 }

void L1MuGMTHWFileReader::readNextEvent ( )

Definition at line 126 of file L1MuGMTHWFileReader.cc.

References L1MuGMTInputEvent::addInputMuon(), PVValHelper::eta, mps_fire::i, m_evt, m_in, phi, L1MuGMTInputEvent::reset(), L1MuRegionalCand::setBx(), L1MuGMTInputEvent::setEventNumber(), L1MuGMTInputEvent::setIsoBit(), L1MuGMTInputEvent::setMipBit(), L1MuGMTInputEvent::setRunNumber(), L1MuRegionalCand::setType(), AlCaHLTBitMon_QueryRunRegistry::string, and heppy_batch::val.

Referenced by setRunAndEventInfo().

                                         {
   m_evt.reset();
 
   std::string line_id;
   do {
     int bx = 0;
 
     m_in >> line_id;
     if (line_id == "--") continue;
 
     if (line_id == "RUN") {
       unsigned long runnr;
       m_in >> runnr;
       m_evt.setRunNumber(runnr);
     }
 
     if (line_id == "EVT") {
       unsigned long evtnr;
       m_in >> evtnr;
       m_evt.setEventNumber(evtnr);
     }
 
 
     if (line_id == "DT" || line_id == "CSC" || line_id == "BRPC" || line_id == "FRPC")
     {
 
       // decode input muon
 
       unsigned inpmu = 0;
       unsigned val;
       m_in >> val; inpmu |= (val & 0x01) << 24; // valid charge
       m_in >> val; inpmu |= (val & 0x01) << 23; // charge
       m_in >> val; inpmu |= (val & 0x01) << 22; // halo / fine
       m_in >> val; inpmu |= (val & 0x3f) << 16; // eta
       m_in >> val; inpmu |= (val & 0x07) << 13; // quality
       m_in >> val; inpmu |= (val & 0x1f) <<  8; // pt
       m_in >> val; inpmu |= (val & 0xff)      ; // phi
 
       std::string chipid("IN");
       chipid += line_id[0];
 
       int type=0;
       if (line_id == "DT") type = 0;
       if (line_id == "CSC") type = 2;
       if (line_id == "BRPC") type = 1;
       if (line_id == "FRPC") type = 3;
 
 
       L1MuRegionalCand cand(inpmu);
       cand.setType(type);
       cand.setBx(bx);
       m_evt.addInputMuon(chipid, cand);
     }
 
     if (line_id == "MIP") {
       int nPairs;
       m_in >> nPairs;
       for (int i=0; i<nPairs; i++) {
         unsigned eta;
         unsigned phi;
         m_in >> eta;
         m_in >> phi;
         if (phi >= 9) phi-=9;
         else phi+=9;
         m_evt.setMipBit(eta, phi, true);
       }
     }
 
     if (line_id == "NQ") {
       int nPairs;
       m_in >> nPairs;
       for (int i=0; i<nPairs; i++) {
         unsigned eta;
         unsigned phi;
         m_in >> eta;
         m_in >> phi;
         if (phi >= 9) phi-=9;
         else phi+=9;
         m_evt.setIsoBit(eta, phi, false);
       }
     }
 
     //read the rest of the line
     const int sz=4000; char buf[sz];
     m_in.getline(buf, sz);
 
   } while (line_id != "NQ" && !m_in.eof());
 
 }

bool L1MuGMTHWFileReader::setRunAndEventInfo	(	edm::EventID &	id,
		edm::TimeValue_t &	time,
		edm::EventAuxiliary::ExperimentType &	eType
	)

privatevirtual

Implements edm::ProducerSourceBase.

Definition at line 70 of file L1MuGMTHWFileReader.cc.

References L1MuGMTInputEvent::getEventNumber(), L1MuGMTInputEvent::getRunNumber(), m_evt, and readNextEvent().

                                                                                                                          {
   readNextEvent();
   if(!m_evt.getRunNumber() && !m_evt.getEventNumber()) return false;
   id = edm::EventID(m_evt.getRunNumber(), id.luminosityBlock(), m_evt.getEventNumber());
 
   edm::LogInfo("GMT_HWFileReader_info") << "run: " << m_evt.getRunNumber() << 
           "   evt: " << m_evt.getEventNumber();
   return true;
 }

Member Data Documentation

L1MuGMTInputEvent L1MuGMTHWFileReader::m_evt

private

Definition at line 57 of file L1MuGMTHWFileReader.h.

Referenced by produce(), readNextEvent(), and setRunAndEventInfo().

std::ifstream L1MuGMTHWFileReader::m_in

private

Definition at line 56 of file L1MuGMTHWFileReader.h.

Referenced by L1MuGMTHWFileReader(), readNextEvent(), and ~L1MuGMTHWFileReader().

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation