#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(), bool deleteFile=true, int rawFd=-1, uint64_t fileSize=0, uint16_t rawHeaderSize=0, uint32_t nChunks=0, int nEvents=0, FedRawDataInputSource *parent=nullptr)

	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)

	~InputFile ()

Public Attributes
uint32_t	bufferPosition_ = 0

uint32_t	chunkPosition_ = 0

tbb::concurrent_vector < InputChunk * >	chunks_

unsigned int	currentChunk_ = 0

bool	deleteFile_

std::string	fileName_

uint64_t	fileSize_

unsigned int	lumi_

uint32_t	nChunks_

int	nEvents_

unsigned int	nProcessed_

FedRawDataInputSource *	parent_

int	rawFd_

uint16_t	rawHeaderSize_

evf::EvFDaqDirector::FileStatus	status_

Detailed Description

Definition at line 211 of file FedRawDataInputSource.h.

Constructor & Destructor Documentation

InputFile::InputFile	(	evf::EvFDaqDirector::FileStatus	status,
		unsigned int	lumi = `0`,
		std::string const &	name = `std::string()`,
		bool	deleteFile = `true`,
		int	rawFd = `-1`,
		uint64_t	fileSize = `0`,
		uint16_t	rawHeaderSize = `0`,
		uint32_t	nChunks = `0`,
		int	nEvents = `0`,
		FedRawDataInputSource *	parent = `nullptr`
	)

inline

Definition at line 230 of file FedRawDataInputSource.h.

References chunks_, and mps_fire::i.

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

InputFile::~InputFile ( )

Definition at line 1438 of file FedRawDataInputSource.cc.

References deleteFile_, cppFunctionSkipper::exception, fileName_, dt4ml_dqm_sourceclient-live_cfg::filePath, LogDebug, fed_dqm_sourceclient-live_cfg::path, rawFd_, and MatrixUtil::remove().

                       {
   if (rawFd_ != -1)
     close(rawFd_);
 
   if (deleteFile_ && !fileName_.empty()) {
     const std::filesystem::path filePath(fileName_);
     try {
       //sometimes this fails but file gets deleted
       LogDebug("FedRawDataInputSource:InputFile") << "Deleting input file -:" << fileName_;
       std::filesystem::remove(filePath);
       return;
     } catch (const std::filesystem::filesystem_error& ex) {
       edm::LogError("FedRawDataInputSource:InputFile")
           << " - deleteFile BOOST FILESYSTEM ERROR CAUGHT -: " << ex.what() << ". Trying again.";
     } catch (std::exception& ex) {
       edm::LogError("FedRawDataInputSource:InputFile")
           << " - deleteFile std::exception CAUGHT -: " << ex.what() << ". Trying again.";
     }
     std::filesystem::remove(filePath);
   }
 }

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

inline

Definition at line 256 of file FedRawDataInputSource.h.

256 : fileName_(name) {}

mergeVDriftHistosByStation.name

string name

Definition: mergeVDriftHistosByStation.py:78

InputFile::fileName_

std::string fileName_

Definition: FedRawDataInputSource.h:215

Member Function Documentation

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

inline

Definition at line 1384 of file FedRawDataInputSource.cc.

References cms::cuda::assert(), bufferPosition_, chunkPosition_, chunks_, currentChunk_, FedRawDataInputSource::exceptionState(), evf::FastMonState::inChunkReceived, evf::FastMonState::inWaitChunk, parent_, FedRawDataInputSource::setMonState(), findQualityFiles::size, FedRawDataInputSource::threadError(), and waitForChunk().

                                                                               {
   //wait for chunk
 
   while (!waitForChunk(currentChunk_)) {
     parent_->setMonState(inWaitChunk);
     usleep(100000);
     parent_->setMonState(inChunkReceived);
     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)) {
       parent_->setMonState(inWaitChunk);
       usleep(100000);
       parent_->setMonState(inChunkReceived);
       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 1424 of file FedRawDataInputSource.cc.

References cms::cuda::assert(), bufferPosition_, chunkPosition_, chunks_, currentChunk_, and findQualityFiles::size.

                                                                                  {
   //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 1433 of file FedRawDataInputSource.cc.

References bufferPosition_, chunkPosition_, and findQualityFiles::size.

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

bool InputFile::waitForChunk ( unsigned int chunkid )

inline

Definition at line 258 of file FedRawDataInputSource.h.

References chunks_.

Referenced by advance().

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