#include <PixelSLinkDataInputSource.h>

Inheritance diagram for PixelSLinkDataInputSource:

Public Member Functions
	PixelSLinkDataInputSource (const edm::ParameterSet &pset, const edm::InputSourceDescription &desc)

	~PixelSLinkDataInputSource () override

Public Member Functions inherited from edm::ProducerSourceFromFiles
InputFileCatalog &	catalog ()

std::vector< std::string >	fileNames (unsigned iCatalog) const

std::vector< std::string > const &	logicalFileNames () const

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

	~ProducerSourceFromFiles () override

Public Member Functions inherited from edm::ProducerSourceBase
	ProducerSourceBase (ParameterSet const &pset, InputSourceDescription const &desc, bool realData)

	~ProducerSourceBase () noexcept(false) override

Public Member Functions inherited from edm::IDGeneratorSourceBase< PuttableSourceBase >
EventNumber_t	event () const

unsigned int	eventCreationDelay () const

EventID const &	eventID () const

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

LuminosityBlockNumber_t	luminosityBlock () const

unsigned int	numberEventsInLumi () const

unsigned int	numberEventsInRun () const

unsigned int	numberEventsInThisLumi () const

unsigned int	numberEventsInThisRun () const

TimeValue_t	presentTime () const

RunNumber_t	run () const

unsigned int	timeBetweenEvents () const

	~IDGeneratorSourceBase () noexcept(false) override

Public Member Functions inherited from edm::PuttableSourceBase
bool	hasAbilityToProduceInBeginLumis () const final

bool	hasAbilityToProduceInBeginRuns () const final

	PuttableSourceBase (ParameterSet const &, InputSourceDescription const &)

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

void	registerProducts (ProducerBase , ProductRegistry , ModuleDescription const &)

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

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

std::shared_ptr< BranchIDListHelper > &	branchIDListHelper ()

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

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 (InputSource const &)=delete

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

void	issueReports (EventID const &eventID, StreamID streamID)
	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 &	processHistoryRegistry ()

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

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

std::shared_ptr< ProductRegistry > &	productRegistry ()

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

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...

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

void	readEvent (EventPrincipal &ep, StreamContext &)
	Read next 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 > &	thinnedAssociationsHelper ()

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

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

std::vector< bool > const &	recordProvenanceList () 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)

TypeLabelList const &	typeLabelList () const
	used by the fwk to register the list of products of this module More...

	~ProducerBase () noexcept(false) override

Private Member Functions
int	getEventNumberFromFillWords (const std::vector< uint64_t > &data, uint32_t &totword)

void	produce (edm::Event &event) override

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

uint32_t	synchronizeEvents ()

Private Attributes
std::unique_ptr< FEDRawDataCollection >	buffers

uint32_t	m_currenteventnumber

uint32_t	m_currenttriggernumber

uint64_t	m_data

int32_t	m_eventnumber_shift

int	m_fedid

uint32_t	m_fileindex

uint32_t	m_globaleventnumber

int	m_runnumber

std::unique_ptr< Storage >	storage

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::IDGeneratorSourceBase< PuttableSourceBase >
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::ProducerSourceFromFiles
void	incrementFileIndex ()

Protected Member Functions inherited from edm::IDGeneratorSourceBase< PuttableSourceBase >
void	doReadEvent (EventPrincipal &eventPrincipal, F &&f)

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

Protected Member Functions inherited from edm::ProducerBase
template<class ProductType >
BranchAliasSetterT< ProductType >	produces ()
	declare what type of product will make and with which optional label More...

template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType >	produces ()

template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType >	produces ()

BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<BranchType B>
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<Transition B>
BranchAliasSetter	produces (const TypeID &id, std::string instanceName=std::string(), bool recordProvenance=true)

template<typename ProductType , Transition B>
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

template<class ProductType >
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

template<typename ProductType , BranchType B>
BranchAliasSetterT< ProductType >	produces (std::string instanceName)

ProducesCollector	producesCollector ()

Detailed Description

IORawData/SiPixelInputSources/interface/PixelSLinkDataInputSource.h

Description: <one line="" class="" summary>="">

Implementation: <Notes on="" implementation>="">

IORawData/SiPixelInputSources/src/PixelSLinkDataInputSource.cc

Description: <one line="" class="" summary>="">

Implementation: <Notes on="" implementation>="">

Definition at line 39 of file PixelSLinkDataInputSource.h.

Constructor & Destructor Documentation

◆ PixelSLinkDataInputSource()

PixelSLinkDataInputSource::PixelSLinkDataInputSource	(	const edm::ParameterSet &	pset,
		const edm::InputSourceDescription &	desc
	)

explicit

Definition at line 193 of file PixelSLinkDataInputSource.cc.

     : ProducerSourceFromFiles(pset, desc, true),
       m_fedid(pset.getUntrackedParameter<int>("fedid")),
       m_fileindex(0),
       m_runnumber(pset.getUntrackedParameter<int>("runNumber", -1)),
       m_currenteventnumber(0),
       m_currenttriggernumber(0),
       m_eventnumber_shift(0) {
   produces<FEDRawDataCollection>();
  
   if (m_fileindex >= fileNames(0).size()) {
     edm::LogInfo("") << "no more file to read " << std::endl;
     return;  // ???
   }
   std::string currentfilename = fileNames(0)[m_fileindex];
   edm::LogInfo("") << "now examining file " << currentfilename;
   m_fileindex++;
   // reading both castor and other ('normal'/dcap) files.
   IOOffset size = -1;
   StorageFactory::getToModify()->enableAccounting(true);
  
   edm::LogInfo("PixelSLinkDataInputSource")
       << " unsigned long int size = " << sizeof(unsigned long int)
       << "\n unsigned long size = " << sizeof(unsigned long)
       << "\n unsigned long long size = " << sizeof(unsigned long long) << "\n uint32_t size = " << sizeof(uint32_t)
       << "\n uint64_t size = " << sizeof(uint64_t) << std::endl;
  
   bool exists = StorageFactory::get()->check(currentfilename, &size);
  
   edm::LogInfo("PixelSLinkDataInputSource") << "file size " << size << std::endl;
  
   if (!exists) {
     edm::LogInfo("") << "file " << currentfilename << " cannot be found.";
     return;
   }
   // now open the file stream:
   storage = StorageFactory::get()->open(currentfilename);
   // (throw if storage is 0)
  
   // check run number by opening up data file...
  
   Storage &temp_file = *storage;
   //  IOSize n =
   temp_file.read((char *)&m_data, 8);
   if ((m_data >> 60) != 0x5) {
     uint32_t runnum = m_data;
     if (m_runnumber != -1)
       edm::LogInfo("") << "WARNING: observed run number encoded in S-Link dump. Overwriting "
                           "run number as defined in .cfg file!!! Run number now set to "
                        << runnum << " (was " << m_runnumber << ")";
     m_runnumber = runnum;
   }
   temp_file.read((char *)&m_data, 8);
   m_currenteventnumber = (m_data >> 32) & 0x00ffffff;
 }

References StorageFactory::check(), StorageFactory::enableAccounting(), edm::FromFiles::fileNames(), StorageFactory::get(), StorageFactory::getToModify(), createfilelist::int, m_currenteventnumber, m_data, m_fileindex, m_runnumber, StorageFactory::open(), Storage::read(), findQualityFiles::size, storage, and AlCaHLTBitMon_QueryRunRegistry::string.

◆ ~PixelSLinkDataInputSource()

PixelSLinkDataInputSource::~PixelSLinkDataInputSource ( )

override

Definition at line 251 of file PixelSLinkDataInputSource.cc.

251 {}

Member Function Documentation

◆ getEventNumberFromFillWords()

int PixelSLinkDataInputSource::getEventNumberFromFillWords	(	const std::vector< uint64_t > &	data,
		uint32_t &	totword
	)

private

Definition at line 34 of file PixelSLinkDataInputSource.cc.

                                                                                                                {
   // buffer validity, should already be pretty clean as this is exactly what
   // goes into the FEDRawDataobject.
  
   // code copied directly from A. Ryd's fill word checker in
   // PixelFEDInterface::PwordSlink64
  
   int fif2cnt = 0;
   int dumcnt = 0;
   int gapcnt = 0;
   uint32_t gap[9];
   uint32_t dum[9];
   uint32_t word[2] = {0, 0};
   uint32_t chan = 0;
   uint32_t roc = 0;
  
   const uint32_t rocmsk = 0x3e00000;
   const uint32_t chnlmsk = 0xfc000000;
  
   for (int jk = 1; jk < 9; jk++)
     gap[jk] = 0;
   for (int jk = 1; jk < 9; jk++)
     dum[jk] = 0;
  
   int fifcnt = 1;
   for (size_t kk = 0; kk < buffer.size(); ++kk) {
     word[0] = (uint32_t)buffer[kk];
     word[1] = (uint32_t)(buffer[kk] >> 32);
  
     for (size_t iw = 0; iw < 2; iw++) {
       chan = ((word[iw] & chnlmsk) >> 26);
       roc = ((word[iw] & rocmsk) >> 21);
  
       // count non-error words
       if (roc < 25) {
         if ((chan > 4) && (chan < 10) && (fifcnt != 2)) {
           fif2cnt = 0;
           fifcnt = 2;
         }
         if ((chan > 9) && (chan < 14) && (fifcnt != 3)) {
           fif2cnt = 0;
           fifcnt = 3;
         }
         if ((chan > 13) && (chan < 19) && (fifcnt != 4)) {
           fif2cnt = 0;
           fifcnt = 4;
         }
         if ((chan > 18) && (chan < 23) && (fifcnt != 5)) {
           fif2cnt = 0;
           fifcnt = 5;
         }
         if ((chan > 22) && (chan < 28) && (fifcnt != 6)) {
           fif2cnt = 0;
           fifcnt = 6;
         }
         if ((chan > 27) && (chan < 32) && (fifcnt != 7)) {
           fif2cnt = 0;
           fifcnt = 7;
         }
         if ((chan > 31) && (fifcnt != 8)) {
           fif2cnt = 0;
           fifcnt = 8;
         }
         fif2cnt++;
       }
       if (roc == 26) {
         gap[fifcnt] = (0x1000 + (word[iw] & 0xff));
         gapcnt++;
       }
  
       if ((roc == 27) && ((fif2cnt + dumcnt) < 6)) {
         dumcnt++;
         dum[fifcnt] = (0x1000 + (word[iw] & 0xff));
       } else if ((roc == 27) && ((fif2cnt + dumcnt) > 6)) {
         dumcnt = 1;
         fif2cnt = 0;
         fifcnt++;
       }
     }
  
     // word check complete
     if (((fif2cnt + dumcnt) == 6) && (dumcnt > 0))  // done with this fifo
     {
       dumcnt = 0;
       fif2cnt = 0;
       fifcnt++;
     }
     if ((gapcnt > 0) && ((dumcnt + fif2cnt) > 5))  // done with this fifo
     {
       gapcnt = 0;
       fifcnt++;
       fif2cnt = 0;
       dumcnt = 0;
     } else if ((gapcnt > 0) && ((dumcnt + fif2cnt) < 6))
       gapcnt = 0;
  
   }  // end of fifo-3 word loop-see what we got!
  
   int status = 0;
  
   if (gap[1] > 0) {
     totword = (gap[1] & 0xff);
     status = 1;
   } else if (gap[2] > 0) {
     totword = (gap[2] & 0xff);
     status = 1;
   } else if (dum[1] > 0) {
     totword = (dum[1] & 0xff);
     status = 1;
   } else if (dum[2] > 0) {
     totword = (dum[2] & 0xff);
     status = 1;
   }
  
   if (gap[3] > 0) {
     totword = totword | ((gap[3] & 0xff) << 8);
     status = status | 0x2;
   } else if (gap[4] > 0) {
     totword = totword | ((gap[4] & 0xff) << 8);
     status = status | 0x2;
   } else if (dum[3] > 0) {
     totword = totword | ((dum[3] & 0xff) << 8);
     status = status | 0x2;
   } else if (dum[4] > 0) {
     totword = totword | ((dum[4] & 0xff) << 8);
     status = status | 0x2;
   }
  
   if (gap[5] > 0) {
     totword = totword | ((gap[5] & 0xff) << 16);
     status = status | 0x4;
   } else if (gap[6] > 0) {
     totword = totword | ((gap[6] & 0xff) << 16);
     status = status | 0x4;
   } else if (dum[5] > 0) {
     totword = totword | ((dum[5] & 0xff) << 16);
     status = status | 0x4;
   } else if (dum[6] > 0) {
     totword = totword | ((dum[6] & 0xff) << 16);
     status = status | 0x4;
   }
  
   if (gap[7] > 0) {
     totword = totword | ((gap[7] & 0xff) << 24);
     status = status | 0x8;
   } else if (gap[8] > 0) {
     totword = totword | ((gap[8] & 0xff) << 24);
     status = status | 0x8;
   } else if (dum[7] > 0) {
     totword = totword | ((dum[7] & 0xff) << 24);
     status = status | 0x8;
   } else if (dum[8] > 0) {
     totword = totword | ((dum[8] & 0xff) << 24);
     status = status | 0x8;
   }
   return (status);
 }

References edmScanValgrind::buffer, officialStyle::chan, HLT_2018_cff::gap, GetRecoTauVFromDQM_MC_cff::kk, PixelMapPlotter::roc, and mps_update::status.

◆ produce()

void PixelSLinkDataInputSource::produce ( edm::Event & event )

overrideprivatevirtual

Implements edm::ProducerSourceBase.

Definition at line 350 of file PixelSLinkDataInputSource.cc.

                                                        {
   event.put(std::move(buffers));
   buffers.reset();
 }

References buffers, and eostools::move().

◆ setRunAndEventInfo()

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

overrideprivatevirtual

Implements edm::IDGeneratorSourceBase< PuttableSourceBase >.

Definition at line 253 of file PixelSLinkDataInputSource.cc.

                                                                                       {
   Storage &m_file = *storage;
  
   // create product (raw data)
   buffers.reset(new FEDRawDataCollection);
  
   //  uint32_t currenteventnumber = (m_data >> 32)&0x00ffffff;
   uint32_t eventnumber = (m_data >> 32) & 0x00ffffff;
  
   do {
     std::vector<uint64_t> buffer;
  
     uint16_t count = 0;
     eventnumber = (m_data >> 32) & 0x00ffffff;
     if (m_currenteventnumber == 0)
       m_currenteventnumber = eventnumber;
     edm::LogInfo("PixelSLinkDataInputSource::produce()")
         << "**** event number = " << eventnumber << " global event number " << m_currenteventnumber << " data "
         << std::hex << m_data << std::dec << std::endl;
     while ((m_data >> 60) != 0x5) {
       //  std::cout << std::hex << m_data << std::dec << std::endl;
       if (count == 0) {
         edm::LogWarning("") << "DATA CORRUPTION!";
         edm::LogWarning("") << "Expected to find header, but read: 0x" << std::hex << m_data << std::dec;
       }
  
       count++;
       int n = m_file.read((char *)&m_data, 8);
       edm::LogWarning("") << "next data " << std::hex << m_data << std::dec << std::endl;
  
       if (n != 8) {
         edm::LogInfo("") << "End of input file";
         return false;
       }
     }
  
     if (count > 0) {
       edm::LogWarning("") << "Had to read " << count << " words before finding header!" << std::endl;
     }
  
     if (m_fedid > -1) {
       m_data = (m_data & 0xfffffffffff000ffLL) | ((m_fedid & 0xfff) << 8);
     }
  
     uint16_t fed_id = (m_data >> 8) & 0xfff;
     //   std::cout << "fed id = " << fed_id << std::endl;
     buffer.push_back(m_data);
  
     do {
       m_file.read((char *)&m_data, 8);
       buffer.push_back(m_data);
     } while ((m_data >> 60) != 0xa);
     //  std::cout << "read " <<  buffer.size() << " long words" << std::endl;
  
     auto rawData = std::make_unique<FEDRawData>(8 * buffer.size());
     //  FEDRawData * rawData = new FEDRawData(8*buffer.size());
     unsigned char *dataptr = rawData->data();
  
     for (uint16_t i = 0; i < buffer.size(); i++) {
       ((uint64_t *)dataptr)[i] = buffer[i];
     }
     uint32_t thetriggernumber = 0;
     int nfillwords = 0;  // getEventNumberFromFillWords(buffer,thetriggernumber);
  
     if (nfillwords > 0) {
       LogInfo("") << "n fill words = " << nfillwords << ", trigger numbers: " << thetriggernumber << ","
                   << m_currenttriggernumber << std::endl;
       m_eventnumber_shift = thetriggernumber - m_currenttriggernumber;
     }
     m_currenttriggernumber = thetriggernumber;
     FEDRawData &fedRawData = buffers->FEDData(fed_id);
     fedRawData = *rawData;
  
     // read the first data member of the next blob to check on event number
     int n = m_file.read((char *)&m_data, 8);
     if (n == 0) {
       edm::LogInfo("") << "End of input file";
     }
     m_currenteventnumber = (m_data >> 32) & 0x00ffffff;
     if (m_currenteventnumber < eventnumber)
       LogError("PixelSLinkDataInputSource")
           << " error, the previous event number (" << eventnumber << ") is LARGER than the next event number ("
           << m_currenteventnumber << ")" << std::endl;
  
   } while (eventnumber == m_currenteventnumber);
  
   uint32_t realeventno = synchronizeEvents();
   if (m_runnumber != 0)
     id = edm::EventID(m_runnumber, id.luminosityBlock(), realeventno);
   else
     id = edm::EventID(id.run(), id.luminosityBlock(), realeventno);
   return true;
 }

References edmScanValgrind::buffer, buffers, KineDebug3::count(), TauDecayModes::dec, l1t_dqm_sourceclient-live_cfg::fedRawData, mps_fire::i, L1DTConfigFromDB_cfi::LL, edm::IDGeneratorSourceBase< PuttableSourceBase >::luminosityBlock(), m_currenteventnumber, m_currenttriggernumber, m_data, m_eventnumber_shift, m_fedid, m_runnumber, dqmiodumpmetadata::n, l1tstage2_dqm_sourceclient-live_cfg::rawData, Storage::read(), edm::IDGeneratorSourceBase< PuttableSourceBase >::run(), storage, and synchronizeEvents().

◆ synchronizeEvents()

uint32_t PixelSLinkDataInputSource::synchronizeEvents ( )

private

Definition at line 357 of file PixelSLinkDataInputSource.cc.

                                                       {
   int32_t result = m_currenteventnumber - 1;
  
   return (uint32_t)result;
 }

References m_currenteventnumber, and mps_fire::result.

Referenced by setRunAndEventInfo().

Member Data Documentation

◆ buffers

std::unique_ptr<FEDRawDataCollection> PixelSLinkDataInputSource::buffers

private

Definition at line 60 of file PixelSLinkDataInputSource.h.

Referenced by produce(), and setRunAndEventInfo().

◆ m_currenteventnumber

uint32_t PixelSLinkDataInputSource::m_currenteventnumber

private

Definition at line 55 of file PixelSLinkDataInputSource.h.

Referenced by PixelSLinkDataInputSource(), setRunAndEventInfo(), and synchronizeEvents().

◆ m_currenttriggernumber

uint32_t PixelSLinkDataInputSource::m_currenttriggernumber

private

Definition at line 56 of file PixelSLinkDataInputSource.h.

Referenced by setRunAndEventInfo().

◆ m_data

uint64_t PixelSLinkDataInputSource::m_data

private

Definition at line 54 of file PixelSLinkDataInputSource.h.

Referenced by PixelSLinkDataInputSource(), and setRunAndEventInfo().

◆ m_eventnumber_shift

int32_t PixelSLinkDataInputSource::m_eventnumber_shift

private

Definition at line 58 of file PixelSLinkDataInputSource.h.

Referenced by setRunAndEventInfo().

◆ m_fedid

int PixelSLinkDataInputSource::m_fedid

private

Definition at line 50 of file PixelSLinkDataInputSource.h.

Referenced by setRunAndEventInfo().

◆ m_fileindex

uint32_t PixelSLinkDataInputSource::m_fileindex

private

Definition at line 51 of file PixelSLinkDataInputSource.h.

Referenced by PixelSLinkDataInputSource().

◆ m_globaleventnumber

uint32_t PixelSLinkDataInputSource::m_globaleventnumber

private

Definition at line 57 of file PixelSLinkDataInputSource.h.

◆ m_runnumber

int PixelSLinkDataInputSource::m_runnumber

private

Definition at line 53 of file PixelSLinkDataInputSource.h.

Referenced by PixelSLinkDataInputSource(), and setRunAndEventInfo().

◆ storage

std::unique_ptr<Storage> PixelSLinkDataInputSource::storage

private

Definition at line 52 of file PixelSLinkDataInputSource.h.

Referenced by PixelSLinkDataInputSource(), and setRunAndEventInfo().

Public Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ PixelSLinkDataInputSource()

◆ ~PixelSLinkDataInputSource()

Member Function Documentation

◆ getEventNumberFromFillWords()

◆ produce()

◆ setRunAndEventInfo()

◆ synchronizeEvents()

Member Data Documentation

◆ buffers

◆ m_currenteventnumber

◆ m_currenttriggernumber

◆ m_data

◆ m_eventnumber_shift

◆ m_fedid

◆ m_fileindex

◆ m_globaleventnumber

◆ m_runnumber

◆ storage