#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

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

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_