RawInputFile Class Reference

#include <DAQSource.h>

Inheritance diagram for RawInputFile:

Public Member Functions
bool	advance (unsigned char *&dataPosition, const size_t size)
	RawInputFile (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, DAQSource *parent=nullptr)
Public Member Functions inherited from InputFile
bool	advance (unsigned char *&dataPosition, const size_t size)
void	appendFile (std::string const &name, uint64_t size)
uint64_t	currentChunkSize () const
	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, uint16_t nChunks=0, int nEvents=0, FedRawDataInputSource *parent=nullptr)
void	moveToPreviousChunk (const size_t size, const size_t offset)
void	randomizeOrder (std::default_random_engine &rng)
void	rewindChunk (const size_t size)
void	setChunks (uint16_t nChunks)
void	unsetDeleteFile ()
bool	waitForChunk (unsigned int chunkid)
virtual	~InputFile ()

Private Attributes
DAQSource *	sourceParent_

Additional Inherited Members
Public Attributes inherited from InputFile
std::vector< uint64_t >	bufferOffsets_
uint32_t	bufferPosition_ = 0
uint32_t	chunkPosition_ = 0
tbb::concurrent_vector< InputChunk * >	chunks_
unsigned int	currentChunk_ = 0
bool	deleteFile_
std::vector< uint64_t >	diskFileSizes_
std::string	fileName_
std::vector< std::string >	fileNames_
std::vector< unsigned int >	fileOrder_
uint64_t	fileSize_
std::vector< uint64_t >	fileSizes_
unsigned int	lumi_
uint16_t	nChunks_
int	nEvents_
unsigned int	nProcessed_
uint16_t	numFiles_
FedRawDataInputSource *	parent_
int	rawFd_
uint16_t	rawHeaderSize_
evf::EvFDaqDirector::FileStatus	status_

Detailed Description

Definition at line 180 of file DAQSource.h.

Constructor & Destructor Documentation

RawInputFile()

RawInputFile::RawInputFile ( 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, DAQSource *  parent = nullptr  )

inline

Definition at line 182 of file DAQSource.h.

      : InputFile(status, lumi, name, deleteFile, rawFd, fileSize, rawHeaderSize, nChunks, nEvents, nullptr),
        sourceParent_(parent) {}

Member Function Documentation

advance()

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

Definition at line 1321 of file DAQSource.cc.

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

                                                                          {
  //wait for chunk

  while (!waitForChunk(currentChunk_)) {
    sourceParent_->setMonState(inWaitChunk);
    usleep(100000);
    sourceParent_->setMonState(inChunkReceived);
    if (sourceParent_->exceptionState())
      sourceParent_->threadError();
  }

  dataPosition = chunks_[currentChunk_]->buf_ + chunkPosition_;
  size_t currentLeft = chunks_[currentChunk_]->size_ - chunkPosition_;

  if (currentLeft < size) {
    //we need next chunk
    while (!waitForChunk(currentChunk_ + 1)) {
      sourceParent_->setMonState(inWaitChunk);
      usleep(100000);
      sourceParent_->setMonState(inChunkReceived);
      if (sourceParent_->exceptionState())
        sourceParent_->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;
  }
}

Member Data Documentation

sourceParent_

DAQSource* RawInputFile::sourceParent_

private

Definition at line 197 of file DAQSource.h.

Referenced by advance().