#include <FedRawDataInputSource.h>

Public Member Functions
bool	advance (unsigned char *&dataPosition, const size_t size)

	InputFile (evf::EvFDaqDirector::FileStatus status, unsigned int lumi=0, std::string const &name=std::string(), uint64_t fileSize=0, uint32_t nChunks=0, int nEvents=0, FedRawDataInputSource *parent=0)

	InputFile (std::string &name)

void	moveToPreviousChunk (const size_t size, const size_t offset)

void	rewindChunk (const size_t size)

bool	waitForChunk (unsigned int chunkid)

Public Attributes
uint32_t	bufferPosition_ = 0

uint32_t	chunkPosition_ = 0

tbb::concurrent_vector< InputChunk * >	chunks_

unsigned int	currentChunk_ = 0

std::string	fileName_

uint64_t	fileSize_

unsigned int	lumi_

uint32_t	nChunks_

int	nEvents_

unsigned int	nProcessed_

FedRawDataInputSource *	parent_

evf::EvFDaqDirector::FileStatus	status_

Detailed Description

Definition at line 202 of file FedRawDataInputSource.h.

Constructor & Destructor Documentation

InputFile::InputFile	(	evf::EvFDaqDirector::FileStatus	status,
		unsigned int	lumi = `0`,
		std::string const &	name = `std::string()`,
		uint64_t	fileSize = `0`,
		uint32_t	nChunks = `0`,
		int	nEvents = `0`,
		FedRawDataInputSource *	parent = `0`
	)

inline

Definition at line 218 of file FedRawDataInputSource.h.

References mps_fire::i.

                                                                                                        :
     parent_(parent),
     status_(status),
     lumi_(lumi),
     fileName_(name),
     fileSize_(fileSize),
     nChunks_(nChunks),
     nEvents_(nEvents),
     nProcessed_(0)
   {
     for (unsigned int i=0;i<nChunks;i++)
       chunks_.push_back(nullptr);
   }

InputFile::InputFile ( std::string & name )

inline

Definition at line 233 of file FedRawDataInputSource.h.

233 :fileName_(name) {}

InputFile::fileName_

std::string fileName_

Definition: FedRawDataInputSource.h:206

dataset.name

name

Definition: dataset.py:45

Member Function Documentation

bool InputFile::advance	(	unsigned char *&	dataPosition,
		const size_t	size
	)

inline

Definition at line 1221 of file FedRawDataInputSource.cc.

References findQualityFiles::size.

Referenced by FedRawDataInputSource::getNextEvent().

 {
   //wait for chunk
   while (!waitForChunk(currentChunk_)) {
     usleep(100000);
     if (parent_->exceptionState()) parent_->threadError();
   }
 
   dataPosition = chunks_[currentChunk_]->buf_+ chunkPosition_;
   size_t currentLeft = chunks_[currentChunk_]->size_ - chunkPosition_;
 
   if (currentLeft < size) {
 
     //we need next chunk
     while (!waitForChunk(currentChunk_+1)) {
       usleep(100000);
       if (parent_->exceptionState()) parent_->threadError();
     }
     //copy everything to beginning of the first chunk
     dataPosition-=chunkPosition_;
     assert(dataPosition==chunks_[currentChunk_]->buf_);
     memmove(chunks_[currentChunk_]->buf_, chunks_[currentChunk_]->buf_+chunkPosition_, currentLeft);
     memcpy(chunks_[currentChunk_]->buf_ + currentLeft, chunks_[currentChunk_+1]->buf_, size - currentLeft);
     //set pointers at the end of the old data position
     bufferPosition_+=size;
     chunkPosition_=size-currentLeft;
     currentChunk_++;
     return true;
   }
   else {
     chunkPosition_+=size;
     bufferPosition_+=size;
     return false;
   }
 }

void InputFile::moveToPreviousChunk	(	const size_t	size,
		const size_t	offset
	)

inline

Definition at line 1257 of file FedRawDataInputSource.cc.

References findQualityFiles::size.

Referenced by FedRawDataInputSource::getNextEvent().

 {
   //this will fail in case of events that are too large
   assert(size < chunks_[currentChunk_]->size_ - chunkPosition_);
   assert(size - offset < chunks_[currentChunk_]->size_);
   memcpy(chunks_[currentChunk_-1]->buf_+offset,chunks_[currentChunk_]->buf_+chunkPosition_,size);
   chunkPosition_+=size;
   bufferPosition_+=size;
 }

void InputFile::rewindChunk ( const size_t size )

inline

Definition at line 1267 of file FedRawDataInputSource.cc.

References findQualityFiles::size.

Referenced by FedRawDataInputSource::getNextEvent().

                                                     {
   chunkPosition_-=size;
   bufferPosition_-=size;
 }

bool InputFile::waitForChunk ( unsigned int chunkid )

inline

Definition at line 235 of file FedRawDataInputSource.h.

References PFRecoTauDiscriminationByIsolation_cfi::offset, and findQualityFiles::size.

Referenced by FedRawDataInputSource::getNextEvent().

                                           {
     //some atomics to make sure everything is cache synchronized for the main thread
     return chunks_[chunkid]!=nullptr && chunks_[chunkid]->readComplete_;
   }