#include <PlaybackRawDataProvider.h>

Inheritance diagram for PlaybackRawDataProvider:

Public Member Functions
void	analyze (const edm::Event &, const edm::EventSetup &) override

bool	areFilesClosed ()

void	beginJob () override

void	endJob () override

virtual FEDRawDataCollection *	getFEDRawData ()

virtual FEDRawDataCollection *	getFEDRawData (unsigned int &runNumber, unsigned int &evtNumber)

	PlaybackRawDataProvider (const edm::ParameterSet &)

void	respondToCloseInputFile (edm::FileBlock const &fb) override

void	setFreeToEof ()

	~PlaybackRawDataProvider () 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 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 PlaybackRawDataProvider *	instance ()

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	wantsInputProcessBlocks ()

static bool	wantsProcessBlocks ()

static bool	wantsStreamLuminosityBlocks ()

static bool	wantsStreamRuns ()

Private Member Functions
void	lock ()

void	postReadSem ()

void	postWriteSem ()

void	sem_print ()

void	unlock ()

void	waitReadSem ()

void	waitWriteSem ()

Private Attributes
unsigned int	count_

bool	destroying_

FEDRawDataCollection **	eventQueue_

unsigned int *	evtNumber_

bool	filesClosed_

bool	freeToEof_

sem_t	lock_

unsigned int	queueSize_

unsigned int	readIndex_

sem_t	readSem_

unsigned int *	runNumber_

unsigned int	writeIndex_

sem_t	writeSem_

Static Private Attributes
static PlaybackRawDataProvider *	instance_ = nullptr

Additional Inherited Members
Public Types inherited from edm::EDAnalyzer
typedef EDAnalyzer	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

Definition at line 13 of file PlaybackRawDataProvider.h.

Constructor & Destructor Documentation

◆ PlaybackRawDataProvider()

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

explicit

Definition at line 30 of file PlaybackRawDataProvider.cc.

References TauDecayModes::dec, eventQueue_, evtNumber_, edm::ParameterSet::getUntrackedParameter(), mps_fire::i, instance_, lock_, queueSize_, readSem_, runNumber_, and writeSem_.

     : queueSize_(0),
       eventQueue_(nullptr),
       runNumber_(nullptr),
       evtNumber_(nullptr),
       count_(0),
       writeIndex_(0),
       readIndex_(0),
       freeToEof_(false),
       filesClosed_(false),
       destroying_(false) {
   queueSize_ = iConfig.getUntrackedParameter<unsigned int>("queueSize", 32);
   sem_init(&lock_, 0, 1);
   sem_init(&writeSem_, 0, queueSize_);
   sem_init(&readSem_, 0, 0);
   runNumber_ = new unsigned int[queueSize_];
   evtNumber_ = new unsigned int[queueSize_];
   eventQueue_ = new FEDRawDataCollection*[queueSize_];
   for (unsigned int i = 0; i < queueSize_; i++)
     eventQueue_[i] = nullptr;
   edm::LogInfo("PbImpl") << "Created Concrete RawData Provider 0x" << hex << (unsigned long)this << dec << endl;
   instance_ = this;
 }

◆ ~PlaybackRawDataProvider()

PlaybackRawDataProvider::~PlaybackRawDataProvider ( )

override

Definition at line 55 of file PlaybackRawDataProvider.cc.

References TauDecayModes::dec, destroying_, eventQueue_, evtNumber_, mps_fire::i, instance_, lock_, postReadSem(), postWriteSem(), queueSize_, readSem_, runNumber_, unlock(), and writeSem_.

                                                   {
   if (nullptr != runNumber_)
     delete[] runNumber_;
   if (nullptr != evtNumber_)
     delete[] evtNumber_;
   if (nullptr != eventQueue_) {
     for (unsigned int i = 0; i < queueSize_; i++)
       if (nullptr != eventQueue_[i])
         delete eventQueue_[i];
     delete[] eventQueue_;
   }
   edm::LogInfo("PbImpl") << "Destroyed Concrete RawData Provider 0x" << hex << (unsigned long)this << dec << endl;
   instance_ = nullptr;
 
   destroying_ = true;
   postReadSem();
   postWriteSem();
   unlock();
   sem_destroy(&lock_);
   sem_destroy(&writeSem_);
   sem_destroy(&readSem_);
   usleep(10000);
 }

Member Function Documentation

◆ analyze()

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

overridevirtual

Implements edm::EDAnalyzer.

Definition at line 84 of file PlaybackRawDataProvider.cc.

References cms::cuda::assert(), count_, FEDRawData::data(), eventQueue_, evtNumber_, FEDRawDataCollection::FEDData(), EcalFEDMonitor_cfi::FEDRawDataCollection, freeToEof_, mps_fire::i, iEvent, createfilelist::int, edm::HandleBase::isValid(), lock(), FEDNumbering::MAXFEDID, postReadSem(), queueSize_, FEDRawData::resize(), runNumber_, FEDRawData::size(), unlock(), waitWriteSem(), and writeIndex_.

                                                                                    {
   if (freeToEof_)
     return;
   waitWriteSem();
   if (freeToEof_)
     return;
   runNumber_[writeIndex_] = iEvent.id().run();
   evtNumber_[writeIndex_] = iEvent.id().event();
 
   Handle<FEDRawDataCollection> pRawData;
   iEvent.getByLabel("rawDataCollector", pRawData);
 
   if (!pRawData.isValid()) {
     edm::LogError("InvalidHandle") << "no raw data found!" << endl;
     return;
   }
 
   // copy the raw data collection into rawData_, retrievable via getFEDRawData()
   assert(nullptr == eventQueue_[writeIndex_]);
   eventQueue_[writeIndex_] = new FEDRawDataCollection();
   for (unsigned int i = 0; i < (unsigned int)FEDNumbering::MAXFEDID + 1; i++) {
     unsigned int fedSize = pRawData->FEDData(i).size();
     if (fedSize > 0) {
       FEDRawData& fedData = eventQueue_[writeIndex_]->FEDData(i);
       fedData.resize(fedSize);
       memcpy(fedData.data(), pRawData->FEDData(i).data(), fedSize);
     }
   }
 
   lock();
   writeIndex_ = (writeIndex_ + 1) % queueSize_;
   count_++;
   unlock();
 
   postReadSem();
 
   return;
 }

◆ areFilesClosed()

bool PlaybackRawDataProvider::areFilesClosed ( )

Definition at line 188 of file PlaybackRawDataProvider.cc.

References filesClosed_.

188 { return filesClosed_; }

PlaybackRawDataProvider::filesClosed_

bool filesClosed_

Definition: PlaybackRawDataProvider.h:65

◆ beginJob()

void PlaybackRawDataProvider::beginJob ( void )

overridevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 124 of file PlaybackRawDataProvider.cc.

124 {}

◆ endJob()

void PlaybackRawDataProvider::endJob ( void )

overridevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 127 of file PlaybackRawDataProvider.cc.

References count_.

127 { edm::LogInfo("Summary") << count_ << " events read." << endl; }

PlaybackRawDataProvider::count_

unsigned int count_

Definition: PlaybackRawDataProvider.h:57

edm::LogInfo

Log< level::Info, false > LogInfo

Definition: MessageLogger.h:125

◆ getFEDRawData() [1/2]

FEDRawDataCollection * PlaybackRawDataProvider::getFEDRawData ( )

virtual

Definition at line 133 of file PlaybackRawDataProvider.cc.

References destroying_, eventQueue_, lock(), postWriteSem(), queueSize_, readIndex_, mps_fire::result, unlock(), and waitReadSem().

                                                              {
   FEDRawDataCollection* result = nullptr;
   waitReadSem();
   //do not read data if destructor is called
   if (destroying_)
     return nullptr;
   lock();
   result = eventQueue_[readIndex_];
   eventQueue_[readIndex_] = nullptr;
   readIndex_ = (readIndex_ + 1) % queueSize_;
   unlock();
 
   postWriteSem();
   return result;
 }

◆ getFEDRawData() [2/2]

FEDRawDataCollection * PlaybackRawDataProvider::getFEDRawData	(	unsigned int &	runNumber,
		unsigned int &	evtNumber
	)

virtual

Definition at line 150 of file PlaybackRawDataProvider.cc.

References destroying_, eventQueue_, evtNumber_, lock(), postWriteSem(), queueSize_, readIndex_, mps_fire::result, convertSQLiteXML::runNumber, runNumber_, unlock(), and waitReadSem().

                                                                                                              {
   FEDRawDataCollection* result = nullptr;
   waitReadSem();
   //do not read data if destructor is called
   if (destroying_)
     return nullptr;
   lock();
   runNumber = runNumber_[readIndex_];
   evtNumber = evtNumber_[readIndex_];
   result = eventQueue_[readIndex_];
   //  assert(0!=result);
   eventQueue_[readIndex_] = nullptr;
   readIndex_ = (readIndex_ + 1) % queueSize_;
 
   unlock();
 
   postWriteSem();
   return result;
 }

◆ instance()

PlaybackRawDataProvider * PlaybackRawDataProvider::instance ( )

inlinestatic

Definition at line 74 of file PlaybackRawDataProvider.h.

References instance_.

74 { return instance_; }

PlaybackRawDataProvider::instance_

static PlaybackRawDataProvider * instance_

Definition: PlaybackRawDataProvider.h:36

◆ lock()

void PlaybackRawDataProvider::lock ( )

inlineprivate

Definition at line 40 of file PlaybackRawDataProvider.h.

References lock_.

Referenced by analyze(), getFEDRawData(), and sem_print().

40 { sem_wait(&lock_); }

PlaybackRawDataProvider::lock_

sem_t lock_

Definition: PlaybackRawDataProvider.h:59

◆ postReadSem()

void PlaybackRawDataProvider::postReadSem ( )

inlineprivate

Definition at line 45 of file PlaybackRawDataProvider.h.

References readSem_.

Referenced by analyze(), and ~PlaybackRawDataProvider().

45 { sem_post(&readSem_); }

PlaybackRawDataProvider::readSem_

sem_t readSem_

Definition: PlaybackRawDataProvider.h:61

◆ postWriteSem()

void PlaybackRawDataProvider::postWriteSem ( )

inlineprivate

Definition at line 43 of file PlaybackRawDataProvider.h.

References writeSem_.

Referenced by getFEDRawData(), setFreeToEof(), and ~PlaybackRawDataProvider().

43 { sem_post(&writeSem_); }

PlaybackRawDataProvider::writeSem_

sem_t writeSem_

Definition: PlaybackRawDataProvider.h:60

◆ respondToCloseInputFile()

void PlaybackRawDataProvider::respondToCloseInputFile ( edm::FileBlock const & fb )

overridevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 130 of file PlaybackRawDataProvider.cc.

References filesClosed_.

130 { filesClosed_ = true; }

PlaybackRawDataProvider::filesClosed_

bool filesClosed_

Definition: PlaybackRawDataProvider.h:65

◆ sem_print()

void PlaybackRawDataProvider::sem_print ( )

private

Definition at line 171 of file PlaybackRawDataProvider.cc.

References gather_cfg::cout, lock(), readIndex_, readSem_, unlock(), writeIndex_, and writeSem_.

                                         {
   lock();
   int wsem, rsem;
   sem_getvalue(&writeSem_, &wsem);
   sem_getvalue(&readSem_, &rsem);
   cout << "sem_print():"
        << " wsem=" << wsem << " rsem=" << rsem << " writeIndex=" << writeIndex_ << " readIndex=" << readIndex_ << endl;
   unlock();
 }

◆ setFreeToEof()

void PlaybackRawDataProvider::setFreeToEof ( )

Definition at line 181 of file PlaybackRawDataProvider.cc.

References freeToEof_, and postWriteSem().

                                            {
   //  cout << "  PlaybackRawDataProvider::setFreeToEof()" << endl;
   freeToEof_ = true;
   //  cout << "  PlaybackRawDataProvider::setFreeToEof() call postReadSem" << endl;
   postWriteSem();
 }

◆ unlock()

void PlaybackRawDataProvider::unlock ( )

inlineprivate

Definition at line 41 of file PlaybackRawDataProvider.h.

References lock_.

Referenced by analyze(), getFEDRawData(), sem_print(), and ~PlaybackRawDataProvider().

41 { sem_post(&lock_); }

PlaybackRawDataProvider::lock_

sem_t lock_

Definition: PlaybackRawDataProvider.h:59

◆ waitReadSem()

void PlaybackRawDataProvider::waitReadSem ( )

inlineprivate

Definition at line 44 of file PlaybackRawDataProvider.h.

References readSem_.

Referenced by getFEDRawData().

44 { sem_wait(&readSem_); }

PlaybackRawDataProvider::readSem_

sem_t readSem_

Definition: PlaybackRawDataProvider.h:61

◆ waitWriteSem()

void PlaybackRawDataProvider::waitWriteSem ( )

inlineprivate

Definition at line 42 of file PlaybackRawDataProvider.h.

References writeSem_.

Referenced by analyze().

42 { sem_wait(&writeSem_); }

PlaybackRawDataProvider::writeSem_

sem_t writeSem_

Definition: PlaybackRawDataProvider.h:60

Member Data Documentation

◆ count_

unsigned int PlaybackRawDataProvider::count_

private

Definition at line 57 of file PlaybackRawDataProvider.h.

Referenced by analyze(), and endJob().

◆ destroying_

bool PlaybackRawDataProvider::destroying_

private

Definition at line 66 of file PlaybackRawDataProvider.h.

Referenced by getFEDRawData(), and ~PlaybackRawDataProvider().

◆ eventQueue_

FEDRawDataCollection** PlaybackRawDataProvider::eventQueue_

private

Definition at line 54 of file PlaybackRawDataProvider.h.

Referenced by analyze(), getFEDRawData(), PlaybackRawDataProvider(), and ~PlaybackRawDataProvider().

◆ evtNumber_

unsigned int* PlaybackRawDataProvider::evtNumber_

private

Definition at line 56 of file PlaybackRawDataProvider.h.

Referenced by analyze(), getFEDRawData(), PlaybackRawDataProvider(), and ~PlaybackRawDataProvider().

◆ filesClosed_

bool PlaybackRawDataProvider::filesClosed_

private

Definition at line 65 of file PlaybackRawDataProvider.h.

Referenced by areFilesClosed(), and respondToCloseInputFile().

◆ freeToEof_

bool PlaybackRawDataProvider::freeToEof_

private

Definition at line 64 of file PlaybackRawDataProvider.h.

Referenced by analyze(), and setFreeToEof().

◆ instance_

PlaybackRawDataProvider * PlaybackRawDataProvider::instance_ = nullptr

staticprivate

Definition at line 36 of file PlaybackRawDataProvider.h.

Referenced by instance(), PlaybackRawDataProvider(), and ~PlaybackRawDataProvider().

◆ lock_

sem_t PlaybackRawDataProvider::lock_

private

Definition at line 59 of file PlaybackRawDataProvider.h.

Referenced by lock(), PlaybackRawDataProvider(), unlock(), and ~PlaybackRawDataProvider().

◆ queueSize_

unsigned int PlaybackRawDataProvider::queueSize_

private

Definition at line 53 of file PlaybackRawDataProvider.h.

Referenced by analyze(), getFEDRawData(), PlaybackRawDataProvider(), and ~PlaybackRawDataProvider().

◆ readIndex_

unsigned int PlaybackRawDataProvider::readIndex_

private

Definition at line 63 of file PlaybackRawDataProvider.h.

Referenced by getFEDRawData(), and sem_print().

◆ readSem_

sem_t PlaybackRawDataProvider::readSem_

private

Definition at line 61 of file PlaybackRawDataProvider.h.

Referenced by PlaybackRawDataProvider(), postReadSem(), sem_print(), waitReadSem(), and ~PlaybackRawDataProvider().

◆ runNumber_

unsigned int* PlaybackRawDataProvider::runNumber_

private

Definition at line 55 of file PlaybackRawDataProvider.h.

Referenced by analyze(), getFEDRawData(), PlaybackRawDataProvider(), and ~PlaybackRawDataProvider().

◆ writeIndex_

unsigned int PlaybackRawDataProvider::writeIndex_

private

Definition at line 62 of file PlaybackRawDataProvider.h.

Referenced by analyze(), and sem_print().

◆ writeSem_

sem_t PlaybackRawDataProvider::writeSem_

private

Definition at line 60 of file PlaybackRawDataProvider.h.

Referenced by PlaybackRawDataProvider(), postWriteSem(), sem_print(), waitWriteSem(), and ~PlaybackRawDataProvider().

Public Member Functions

Static Public Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ PlaybackRawDataProvider()

◆ ~PlaybackRawDataProvider()

Member Function Documentation

◆ analyze()

◆ areFilesClosed()

◆ beginJob()

◆ endJob()

◆ getFEDRawData() [1/2]

◆ getFEDRawData() [2/2]

◆ instance()

◆ lock()

◆ postReadSem()

◆ postWriteSem()

◆ respondToCloseInputFile()

◆ sem_print()

◆ setFreeToEof()

◆ unlock()

◆ waitReadSem()

◆ waitWriteSem()

Member Data Documentation

◆ count_

◆ destroying_

◆ eventQueue_

◆ evtNumber_

◆ filesClosed_

◆ freeToEof_

◆ instance_

◆ lock_

◆ queueSize_

◆ readIndex_

◆ readSem_

◆ runNumber_

◆ writeIndex_

◆ writeSem_