PlaybackRawDataProvider Class Reference

#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 () noexcept
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...
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 ( 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 ( )

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

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(), edm::EventID::event(), eventQueue_, evtNumber_, FEDRawDataCollection::FEDData(), freeToEof_, edm::Event::getByLabel(), mps_fire::i, edm::EventBase::id(), edm::HandleBase::isValid(), lock(), FEDNumbering::MAXFEDID, postReadSem(), queueSize_, FEDRawData::resize(), edm::EventID::run(), runNumber_, 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;
}

bool PlaybackRawDataProvider::areFilesClosed

(

)

Definition at line 188 of file PlaybackRawDataProvider.cc.

References filesClosed_.

{ return filesClosed_; }

void PlaybackRawDataProvider::beginJob ( void  )

overridevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 124 of file PlaybackRawDataProvider.cc.

{}

void PlaybackRawDataProvider::endJob ( void  )

overridevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 127 of file PlaybackRawDataProvider.cc.

References count_.

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

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

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

PlaybackRawDataProvider * PlaybackRawDataProvider::instance ( )

inlinestatic

Definition at line 74 of file PlaybackRawDataProvider.h.

References instance_.

{ return instance_; }

void PlaybackRawDataProvider::lock ( )

inlineprivate

Definition at line 40 of file PlaybackRawDataProvider.h.

References lock_.

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

{ sem_wait(&lock_); }

void PlaybackRawDataProvider::postReadSem ( )

inlineprivate

Definition at line 45 of file PlaybackRawDataProvider.h.

References readSem_.

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

{ sem_post(&readSem_); }

void PlaybackRawDataProvider::postWriteSem ( )

inlineprivate

Definition at line 43 of file PlaybackRawDataProvider.h.

References writeSem_.

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

{ sem_post(&writeSem_); }

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

overridevirtual

Reimplemented from edm::EDAnalyzer.

Definition at line 130 of file PlaybackRawDataProvider.cc.

References filesClosed_.

{ filesClosed_ = true; }

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

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

void PlaybackRawDataProvider::unlock ( )

inlineprivate

Definition at line 41 of file PlaybackRawDataProvider.h.

References lock_.

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

{ sem_post(&lock_); }

void PlaybackRawDataProvider::waitReadSem ( )

inlineprivate

Definition at line 44 of file PlaybackRawDataProvider.h.

References readSem_.

Referenced by getFEDRawData().

{ sem_wait(&readSem_); }

void PlaybackRawDataProvider::waitWriteSem ( )

inlineprivate

Definition at line 42 of file PlaybackRawDataProvider.h.

References writeSem_.

Referenced by analyze().

{ sem_wait(&writeSem_); }

Member Data Documentation

unsigned int PlaybackRawDataProvider::count_

private

Definition at line 57 of file PlaybackRawDataProvider.h.

Referenced by analyze(), and endJob().

bool PlaybackRawDataProvider::destroying_

private

Definition at line 66 of file PlaybackRawDataProvider.h.

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

FEDRawDataCollection** PlaybackRawDataProvider::eventQueue_

private

Definition at line 54 of file PlaybackRawDataProvider.h.

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

unsigned int* PlaybackRawDataProvider::evtNumber_

private

Definition at line 56 of file PlaybackRawDataProvider.h.

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

bool PlaybackRawDataProvider::filesClosed_

private

Definition at line 65 of file PlaybackRawDataProvider.h.

Referenced by areFilesClosed(), and respondToCloseInputFile().

bool PlaybackRawDataProvider::freeToEof_

private

Definition at line 64 of file PlaybackRawDataProvider.h.

Referenced by analyze(), and setFreeToEof().

PlaybackRawDataProvider * PlaybackRawDataProvider::instance_ = nullptr

staticprivate

Definition at line 36 of file PlaybackRawDataProvider.h.

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

sem_t PlaybackRawDataProvider::lock_

private

Definition at line 59 of file PlaybackRawDataProvider.h.

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

unsigned int PlaybackRawDataProvider::queueSize_

private

Definition at line 53 of file PlaybackRawDataProvider.h.

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

unsigned int PlaybackRawDataProvider::readIndex_

private

Definition at line 63 of file PlaybackRawDataProvider.h.

Referenced by getFEDRawData(), and sem_print().

sem_t PlaybackRawDataProvider::readSem_

private

Definition at line 61 of file PlaybackRawDataProvider.h.

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

unsigned int* PlaybackRawDataProvider::runNumber_

private

Definition at line 55 of file PlaybackRawDataProvider.h.

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

unsigned int PlaybackRawDataProvider::writeIndex_

private

Definition at line 62 of file PlaybackRawDataProvider.h.

Referenced by analyze(), and sem_print().

sem_t PlaybackRawDataProvider::writeSem_

private

Definition at line 60 of file PlaybackRawDataProvider.h.

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