#include <FUShmReader.h>

Inheritance diagram for FUShmReader:

Public Member Functions
int	fillRawData (edm::EventID &eID, edm::Timestamp &tstamp, FEDRawDataCollection *&data)

	FUShmReader ()

virtual void	setRunNumber (edm::RunNumber_t runNumber)
	set the run number More...

virtual	~FUShmReader ()

Public Member Functions inherited from DaqBaseReader
	DaqBaseReader ()

virtual	~DaqBaseReader ()

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.

   : 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 lastCellIndex_, evf::FUShmBuffer::removeClientPrcId(), runNumber_, shmBuffer_, summarizeEdmComparisonLogfiles::success, and evf::FUShmBuffer::writeErrorEventData().

 {
   if (0!=shmBuffer_) {
     edm::LogInfo("FUShmReader")<<"detach from shared memory segment."<<endl;
     if (lastCellIndex_<0xffffffff) {
       edm::LogWarning("FUShmReader") << "Class destructor called without received STOP event!"<<endl;
       if (lastCellIndex_<0xfffffffe)//not sending lumi cell to the error stream
         shmBuffer_->writeErrorEventData(runNumber_,getpid(),lastCellIndex_,true);
       bool success = shmBuffer_->removeClientPrcId(getpid());
       if (!success)
         edm::LogWarning("ShmMissingPID")<<"Destructor: did not find pid in shared memory index"<<endl;
     }
     shmdt(shmBuffer_);
   }
 }

Member Function Documentation

int 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) within the method; ownership is passed to the caller.

Implements DaqBaseReader.

Definition at line 65 of file FUShmReader.cc.

References gather_cfg::cout, FEDRawData::data(), evf::evt::EMPTY, evf::evt::EOL, event_, evf::FUShmRawCell::evtNumber(), evtNumber_, evf::FUShmBuffer::evtState(), edm::hlt::Exception, FEDRawDataCollection::FEDData(), evf::FUShmRawCell::fedSize(), evf::FUShmBuffer::finishReadingRawCell(), evf::FUShmRawCell::getEventType(), evf::FUShmRawCell::getLumiSection(), i, evf::FUShmRawCell::index(), lastCellIndex_, python.rootplot.utilities::ls(), evf::evt::LUMISECTION, evf::FUShmRawCell::nFed(), evf::FUShmBuffer::rawCellToRead(), evf::evt::RAWREADING, evf::FUShmRawCell::readFed(), FEDRawData::resize(), runNumber_, evf::FUShmBuffer::scheduleRawCellForDiscard(), evf::FUShmBuffer::scheduleRawEmptyCellForDiscard(), evf::FUShmBuffer::sem_print(), shmBuffer_, evf::utils::state, evf::evt::STOP, evf::evt::STOPPER, and summarizeEdmComparisonLogfiles::success.

 {
   // 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 'stop', the reader is being told to shut down!
   evt::State_t state=shmBuffer_->evtState(newCell->index());
   if (state==evt::STOP) {
     edm::LogInfo("ShutDown")<<"Received STOP event, shut down."<<endl;
     std::cout << getpid() << " Received STOP event, shut down." << std::endl;
     if(newCell->getEventType() != evt::STOPPER){
       edm::LogError("InconsistentStopCell") << getpid() 
                       << " GOT what claims to be a STOPPER event but eventType is " 
                       <<  newCell->getEventType()
                       << std::endl;
     }
     bool pidstatus=true;
     bool success = shmBuffer_->scheduleRawEmptyCellForDiscard(newCell,pidstatus);
     if (!success) //should not happen for STOPPER cell
         edm::LogError("InconsistentStopCell")<<"fillRawData:STOP: failed to discard STOP event raw cell!"<<endl;
     else if (!pidstatus) 
         edm::LogWarning("ShmMissingPID")<<"fillRawData:STOP: did not find pid in shared memory pid index"<<endl;
     shmdt(shmBuffer_);
     shmBuffer_=0;
     event_=0;
     lastCellIndex_=0xffffffff;
     return 0;
   }
   else if(state==evt::LUMISECTION){
     unsigned int ls = newCell->getLumiSection();
     if(newCell->getEventType() != evt::EOL){
       edm::LogError("InconsistentLsCell") << getpid() 
                       << " GOT what claims to be an EOL event but eventType is " 
                       <<  newCell->getEventType()
                       << " and ls is " << ls
                       << std::endl;
       shmBuffer_->sem_print();
     }
     shmBuffer_->scheduleRawCellForDiscard(newCell->index());
     lastCellIndex_=0xfffffffe;
     if(ls==0){
       edm::LogError("ZeroLsCell") << getpid() 
                   << " GOT an EOL event for ls 0!!!" 
                   << std::endl;
       return fillRawData(eID, tstamp, data);
     }
     return (-1)*ls;
   }
   // getting an 'empty' event here is a pathological condition !!!
   else if(state==evt::EMPTY){
     edm::LogError("EmptyRawCell")
       <<"Received empty event, this should not happen !!!" <<endl;
     std::cout << getpid() << "Received EPTY event!!! ERROR." << std::endl;
     return fillRawData(eID, tstamp, data);
   }
   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_,1U,evtNumber_);
   data=event_;
   if(evtNumber_==0) 
     std::cout << getpid() << " ShmReader got event number zero !!! " 
           << std::endl;
   return 1;
 }