---

FUShmReader Class Reference

#include <EventFilter/ShmReader/interface/FUShmReader.h>

Inheritance diagram for FUShmReader:

List of all members.

Public Member Functions
bool	fillRawData (edm::EventID &eID, edm::Timestamp &tstamp, FEDRawDataCollection *&data)
	overload to fill the fed collection to be put in the transient event store.
	FUShmReader ()
virtual	~FUShmReader ()
Private Attributes
FEDRawDataCollection *	event_
unsigned int	evtNumber_
unsigned int	lastCellIndex_
unsigned int	runNumber_
evf::FUShmBuffer *	shmBuffer_

---

Detailed Description

Definition at line 10 of file FUShmReader.h.

---

Constructor & Destructor Documentation

FUShmReader::FUShmReader

(

)

Definition at line 31 of file FUShmReader.cc.

References shmBuffer_.

  : event_(0)
  , shmBuffer_(0)
  , runNumber_(0xffffffff)
  , evtNumber_(0xffffffff)
  , lastCellIndex_(0xffffffff)
{
  shmBuffer_=FUShmBuffer::getShmBuffer();
}

FUShmReader::~FUShmReader

(

)

[virtual]

Definition at line 43 of file FUShmReader.cc.

References lat::endl(), lastCellIndex_, evf::FUShmBuffer::removeClientPrcId(), runNumber_, shmBuffer_, and evf::FUShmBuffer::writeErrorEventData().

{
  if (0!=shmBuffer_) {
    edm::LogInfo("FUShmReader")<<"detach from shared memory segment."<<endl;
    if (lastCellIndex_<0xffffffff) {
      shmBuffer_->writeErrorEventData(runNumber_,getpid(),lastCellIndex_);
      shmBuffer_->removeClientPrcId(getpid());
    }
    shmdt(shmBuffer_);
  }
}

---

Member Function Documentation

bool FUShmReader::fillRawData	(	edm::EventID &	eID,
		edm::Timestamp &	tstamp,
		FEDRawDataCollection *&	data
	)			[virtual]

overload to fill the fed collection to be put in the transient event store.

NOTE: the FEDRawDataCollection data must be created (with new) withing the method; ownership is passed to the caller.

Implements DaqBaseReader.

Definition at line 61 of file FUShmReader.cc.

References FEDRawData::data(), evf::dqm::EMPTY, lat::endl(), event_, evf::FUShmRawCell::evtNumber(), evtNumber_, evf::FUShmBuffer::evtState(), Exception, FEDRawDataCollection::FEDData(), evf::FUShmRawCell::fedSize(), evf::FUShmBuffer::finishReadingRawCell(), i, evf::FUShmRawCell::index(), lastCellIndex_, evf::FUShmRawCell::nFed(), evf::FUShmBuffer::rawCellToRead(), evf::evt::RAWREADING, evf::FUShmRawCell::readFed(), FEDRawData::resize(), runNumber_, evf::FUShmBuffer::scheduleRawCellForDiscard(), evf::FUShmBuffer::scheduleRawEmptyCellForDiscard(), shmBuffer_, and state.

{
  // just in case the reader hasn't yet attached to the shm segment
  if (0==shmBuffer_) {
    shmBuffer_=FUShmBuffer::getShmBuffer();
    if(0==shmBuffer_) {
      edm::LogError("NoShmBuffer")<<"Failed to retrieve shm segment."<<endl;
      throw cms::Exception("NullPointer")<<"Failed to retrieve shm segment."<<endl;
    }
  }
  
  // discard old event
  if(0!=event_) {
    shmBuffer_->scheduleRawCellForDiscard(lastCellIndex_);
    event_ = 0;
  }
  
  // wait for an event to become available, retrieve it
  FUShmRawCell* newCell=shmBuffer_->rawCellToRead();
  
  // if the event is 'empty', the reader is being told to shut down!
  evt::State_t state=shmBuffer_->evtState(newCell->index());
  if (state==evt::EMPTY) {
    edm::LogInfo("ShutDown")<<"Received empty event, shut down."<<endl;
    shmBuffer_->scheduleRawEmptyCellForDiscard(newCell);
    shmdt(shmBuffer_);
    shmBuffer_=0;
    event_=0;
    lastCellIndex_=0xffffffff;
    return false;
  }
  else assert(state==evt::RAWREADING);
  
  // read the event data into the fwk raw data format
  evtNumber_    =newCell->evtNumber();
  lastCellIndex_=newCell->index();
  event_        =new FEDRawDataCollection();
  for (unsigned int i=0;i<newCell->nFed();i++) {
    unsigned int fedSize=newCell->fedSize(i);
    if (fedSize>0) {
      FEDRawData& fedData=event_->FEDData(i);
      fedData.resize(fedSize);
      newCell->readFed(i,fedData.data());
    }
  }
  
  // reading the cell is finished (new state will be 'isProcessing')
  shmBuffer_->finishReadingRawCell(newCell);
  eID=EventID(runNumber_,evtNumber_);
  data=event_;
  
  return true;
}

---

Member Data Documentation

FEDRawDataCollection* FUShmReader::event_ [private]

Definition at line 34 of file FUShmReader.h.

Referenced by fillRawData().

unsigned int FUShmReader::evtNumber_ [private]

Definition at line 38 of file FUShmReader.h.

Referenced by fillRawData().

unsigned int FUShmReader::lastCellIndex_ [private]

Definition at line 39 of file FUShmReader.h.

Referenced by fillRawData(), and ~FUShmReader().

unsigned int FUShmReader::runNumber_ [private]

Definition at line 37 of file FUShmReader.h.

Referenced by fillRawData(), and ~FUShmReader().

evf::FUShmBuffer* FUShmReader::shmBuffer_ [private]

Definition at line 35 of file FUShmReader.h.

Referenced by fillRawData(), FUShmReader(), and ~FUShmReader().

---

The documentation for this class was generated from the following files:

• EventFilter/ShmReader/interface/FUShmReader.h
• EventFilter/ShmReader/src/FUShmReader.cc

---