#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 &&)=default

	EDConsumerBase (EDConsumerBase const &)=delete

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::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)

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
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 = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept

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<Transition Tr = Transition::Event>
constexpr auto	esConsumes () noexcept

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

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

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

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 13 of file PlaybackRawDataProvider.h.

Constructor & Destructor Documentation

◆ PlaybackRawDataProvider()

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

explicit

Definition at line 30 of file PlaybackRawDataProvider.cc.

     : 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;
 }

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

◆ ~PlaybackRawDataProvider()

PlaybackRawDataProvider::~PlaybackRawDataProvider ( )

override

Definition at line 55 of file PlaybackRawDataProvider.cc.

                                                   {
   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);
 }

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

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.

                                                                                    {
   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;
 }

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

◆ areFilesClosed()

bool PlaybackRawDataProvider::areFilesClosed ( )

Definition at line 188 of file PlaybackRawDataProvider.cc.

188 { return filesClosed_; }

References filesClosed_.

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

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

References count_.

◆ getFEDRawData() [1/2]

FEDRawDataCollection * PlaybackRawDataProvider::getFEDRawData ( )

virtual

Definition at line 133 of file PlaybackRawDataProvider.cc.

                                                              {
   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;
 }

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

◆ getFEDRawData() [2/2]

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

virtual

Definition at line 150 of file PlaybackRawDataProvider.cc.

                                                                                                              {
   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;
 }

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

◆ instance()

PlaybackRawDataProvider * PlaybackRawDataProvider::instance ( )

inlinestatic

Definition at line 74 of file PlaybackRawDataProvider.h.

74 { return instance_; }

References instance_.

◆ lock()

void PlaybackRawDataProvider::lock ( )

inlineprivate

Definition at line 40 of file PlaybackRawDataProvider.h.

40 { sem_wait(&lock_); }

References lock_.

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

◆ postReadSem()

void PlaybackRawDataProvider::postReadSem ( )

inlineprivate

Definition at line 45 of file PlaybackRawDataProvider.h.

45 { sem_post(&readSem_); }

References readSem_.

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

◆ postWriteSem()

void PlaybackRawDataProvider::postWriteSem ( )

inlineprivate

Definition at line 43 of file PlaybackRawDataProvider.h.

43 { sem_post(&writeSem_); }

References writeSem_.

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

◆ respondToCloseInputFile()

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

overridevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 130 of file PlaybackRawDataProvider.cc.

130 { filesClosed_ = true; }

References filesClosed_.

◆ sem_print()

void PlaybackRawDataProvider::sem_print ( )

private

Definition at line 171 of file PlaybackRawDataProvider.cc.

                                         {
   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();
 }

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

◆ setFreeToEof()

void PlaybackRawDataProvider::setFreeToEof ( )

Definition at line 181 of file PlaybackRawDataProvider.cc.

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

References freeToEof_, and postWriteSem().

◆ unlock()

void PlaybackRawDataProvider::unlock ( )

inlineprivate

Definition at line 41 of file PlaybackRawDataProvider.h.

41 { sem_post(&lock_); }

References lock_.

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

◆ waitReadSem()

void PlaybackRawDataProvider::waitReadSem ( )

inlineprivate

Definition at line 44 of file PlaybackRawDataProvider.h.

44 { sem_wait(&readSem_); }

References readSem_.

Referenced by getFEDRawData().

◆ waitWriteSem()

void PlaybackRawDataProvider::waitWriteSem ( )

inlineprivate

Definition at line 42 of file PlaybackRawDataProvider.h.

42 { sem_wait(&writeSem_); }

References writeSem_.

Referenced by analyze().

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_