FileReaderDDU Class Reference

#include <FileReaderDDU.h>

Public Types
enum	{   Header = 1, Trailer = 2, DDUoversize = 4, FFFF = 8,   Unknown = 16, EndOfStream = 32 }
enum	{   Type1 = Header | Trailer, Type2 = Header, Type3 = Header | DDUoversize, Type4 = Trailer,   Type5 = Unknown, Type6 = Unknown | DDUoversize, Type7 = FFFF }

Public Member Functions
void	accept (unsigned int criteria) throw ()
	FileReaderDDU (void)
size_t	next (const unsigned short *&buf, int prescaling=1)
int	open (const char *filename)
size_t	read (const unsigned short *&buf)
void	reject (unsigned int criteria) throw ()
void	select (unsigned int criteria) throw ()
unsigned int	status (void) const throw ()
virtual	~FileReaderDDU (void)

Private Attributes
unsigned int	acceptCriteria
unsigned long long *	end
unsigned int	eventStatus
int	fd
unsigned long long	file_buffer [4000]
unsigned long long *	file_buffer_end
unsigned short	raw_event [200000]
unsigned int	rejectCriteria
unsigned int	selectCriteria
unsigned long long	word_0
unsigned long long	word_1
unsigned long long	word_2

Detailed Description

Definition at line 7 of file FileReaderDDU.h.

Member Enumeration Documentation

anonymous enum

anonymous enum

Enumerator
Header
Trailer
DDUoversize
FFFF
Unknown
EndOfStream

Definition at line 17 of file FileReaderDDU.h.

{ Header = 1, Trailer = 2, DDUoversize = 4, FFFF = 8, Unknown = 16, EndOfStream = 32 };

anonymous enum

anonymous enum

Enumerator
Type1
Type2
Type3
Type4
Type5
Type6
Type7

Definition at line 18 of file FileReaderDDU.h.

       {
    Type1 = Header | Trailer,
    Type2 = Header,
    Type3 = Header | DDUoversize,
    Type4 = Trailer,
    Type5 = Unknown,
    Type6 = Unknown | DDUoversize,
    Type7 = FFFF
  };  // Andrey Korytov's notations

Constructor & Destructor Documentation

FileReaderDDU()

FileReaderDDU::FileReaderDDU

(

void

)

Definition at line 15 of file FileReaderDDU.cc.

References acceptCriteria, DDUoversize, end, eventStatus, fd, FFFF, file_buffer, file_buffer_end, Header, raw_event, rejectCriteria, selectCriteria, AlCaHLTBitMon_QueryRunRegistry::string, Trailer, Unknown, word_0, word_1, and word_2.

                                 {
  if (sizeof(unsigned long long) != 8 || sizeof(unsigned short) != 2)
    throw std::runtime_error(std::string("Wrong platform: sizeof(unsigned long long)!=8 || sizeof(unsigned short)!=2"));
  end = (file_buffer_end = file_buffer + sizeof(file_buffer) / sizeof(unsigned long long));
  bzero(raw_event, sizeof(raw_event));
  bzero(file_buffer, sizeof(file_buffer));
  word_0 = 0;
  word_1 = 0;
  word_2 = 0;
  eventStatus = 0;
  selectCriteria = Header | Trailer;
  rejectCriteria = DDUoversize | FFFF | Unknown;
  acceptCriteria = 0x3F;  // Everything
  fd = 0;
}

~FileReaderDDU()

FileReaderDDU::~FileReaderDDU ( void  )

virtual

Definition at line 31 of file FileReaderDDU.cc.

References fd.

                                  {
  if (fd)
    close(fd);
}

Member Function Documentation

accept()

void FileReaderDDU::accept ( unsigned int  criteria ) throw ( )

inline

Definition at line 38 of file FileReaderDDU.h.

References acceptCriteria.

Referenced by esMonitoring.FDJsonServer::handle_accept().

                                             {
    acceptCriteria = criteria;
  }  // return all events satisfying any of criteria

next()

size_t FileReaderDDU::next	(	const unsigned short *&	buf,
		int	prescaling = 1
	)

Definition at line 142 of file FileReaderDDU.cc.

References acceptCriteria, visDQMUpload::buf, eventStatus, mps_fire::i, read(), rejectCriteria, selectCriteria, and findQualityFiles::size.

Referenced by CSCFileReader::readRUI().

                                                                     {
  size_t size = 0;
  for (int i = 0; i < prescaling; i++) {
    do {
      if ((size = read(buf)) == 0)
        break;
    } while (rejectCriteria & eventStatus || !(acceptCriteria & eventStatus) ||
             (selectCriteria ? selectCriteria != eventStatus : 0));
  }
  return size;
}

open()

int FileReaderDDU::open

(

const char *

filename

)

Definition at line 36 of file FileReaderDDU.cc.

References mps_setup::append, fd, corrVsCorr::filename, O_LARGEFILE, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by CSCFileReader::CSCFileReader(), and CSCFileReader::readRUI().

                                            {
  if (fd)
    close(fd);
  fd = ::open(filename, O_RDONLY | O_LARGEFILE);
  if (fd == -1)
    throw(std::runtime_error(std::string("Error opening ").append(filename).append(" data file.")));
  return fd;
}

read()

size_t FileReaderDDU::read

(

const unsigned short *&

buf

)

Definition at line 45 of file FileReaderDDU.cc.

References visDQMUpload::buf, DDUoversize, end, EndOfStream, eventStatus, fd, FFFF, file_buffer, file_buffer_end, Header, raw_event, isotrackNtupler::start, Trailer, Unknown, word_0, word_1, and word_2.

Referenced by edmIntegrityCheck.PublishToFileSystem::get(), and next().

                                                     {
  // Check for ubnormal situation
  if (end > file_buffer_end || end < file_buffer)
    throw(std::runtime_error("Error of reading"));
  if (!fd)
    throw(std::runtime_error("Open some file first"));

  unsigned long long *start = end;
  unsigned short *event = raw_event;

  eventStatus = 0;
  size_t dduWordCount = 0;
  end = nullptr;

  while (!end && dduWordCount < 50000) {
    unsigned long long *dduWord = start;
    unsigned long long preHeader = 0;

    // Did we reach end of current buffer and want to read next block?
    // If it was first time and we don't have file buffer then we won't get inside
    while (dduWord < file_buffer_end && dduWordCount < 50000) {
      word_0 = word_1;    // delay by 2 DDU words
      word_1 = word_2;    // delay by 1 DDU word
      word_2 = *dduWord;  // current DDU word
      if ((word_2 & 0xFFFFFFFFFFFF0000LL) == 0x8000000180000000LL) {
        if (eventStatus & Header)  // Second header
        {
          word_2 = word_1;  // Fall back to get rigth preHeader next time
          end = dduWord;    // Even if we end with preHeader of next evet put it to the end of this event too
          break;
        }
        if (dduWordCount > 1)  // Extra words between trailer and header
        {
          if ((word_0 & 0xFFFFFFFFFFFF0000LL) == 0xFFFFFFFFFFFF0000LL)
            eventStatus |= FFFF;
          word_2 = word_1;  // Fall back to get rigth preHeader next time
          end = dduWord;
          break;
        }
        eventStatus |= Header;
        if (event == raw_event)
          preHeader = word_1;  // If preHeader not yet in event then put it there
        start = dduWord;
      }
      if ((word_0 & 0xFFFFFFFFFFFF0000LL) == 0x8000FFFF80000000LL) {
        eventStatus |= Trailer;
        end = ++dduWord;
        break;
      }
      // Increase counters by one DDU word
      dduWord++;
      dduWordCount++;
    }

    // If have DDU Header
    if (preHeader) {
      // Need to account first word of DDU Header
      memcpy(event, &preHeader, sizeof(preHeader));
      event += sizeof(preHeader) / sizeof(unsigned short);
    }

    // Take care of the rest
    memcpy(event, start, (dduWord - start) * sizeof(unsigned long long));
    event += (dduWord - start) * sizeof(unsigned long long) / sizeof(unsigned short);

    // If reach max length
    if (dduWordCount == 50000) {
      end = dduWord;
      break;
    }

    if (!end) {
      // Need to read next block for the rest of this event
      ssize_t length = ::read(fd, file_buffer, sizeof(file_buffer));
      if (length == -1)
        throw(std::runtime_error("Error of reading"));
      if (length == 0) {
        eventStatus |= EndOfStream;
        end = (file_buffer_end = file_buffer + sizeof(file_buffer) / sizeof(unsigned long long));
        break;
      }
      file_buffer_end = file_buffer + length / sizeof(unsigned long long);

      // Will start from the beginning of new buffer next time we read it
      start = file_buffer;
    }
  }

  if (!end)
    eventStatus |= DDUoversize;
  if (!(eventStatus & Header) && !(eventStatus & Trailer) && !(eventStatus & FFFF))
    eventStatus |= Unknown;

  buf = (const unsigned short *)raw_event;
  return (eventStatus & FFFF ? event - raw_event - 4 : event - raw_event);
}

reject()

void FileReaderDDU::reject ( unsigned int  criteria ) throw ( )

inline

Definition at line 41 of file FileReaderDDU.h.

References rejectCriteria.

Referenced by CSCFileReader::CSCFileReader().

                                             {
    rejectCriteria = criteria;
  }  // return events not satisfying any of criteria

select()

void FileReaderDDU::select ( unsigned int  criteria ) throw ( )

inline

Definition at line 37 of file FileReaderDDU.h.

References selectCriteria.

Referenced by CSCFileReader::CSCFileReader().

{ selectCriteria = criteria; }  // return events satisfying all criteria

status()

unsigned int FileReaderDDU::status ( void  ) const throw ( )

inline

Definition at line 45 of file FileReaderDDU.h.

References eventStatus.

{ return eventStatus; }

Member Data Documentation

acceptCriteria

unsigned int FileReaderDDU::acceptCriteria

private

Definition at line 28 of file FileReaderDDU.h.

Referenced by accept(), FileReaderDDU(), and next().

end

unsigned long long* FileReaderDDU::end

private

Definition at line 14 of file FileReaderDDU.h.

Referenced by Types.LuminosityBlockRange::cppID(), Types.EventRange::cppID(), FileReaderDDU(), and read().

eventStatus

unsigned int FileReaderDDU::eventStatus

private

Definition at line 28 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), next(), read(), and status().

fd

int FileReaderDDU::fd

private

Definition at line 30 of file FileReaderDDU.h.

Referenced by progressbar.ProgressBar::_handle_resize(), FileReaderDDU(), progressbar.ProgressBar::finish(), open(), read(), and ~FileReaderDDU().

file_buffer

unsigned long long FileReaderDDU::file_buffer[4000]

private

Definition at line 12 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), and read().

file_buffer_end

unsigned long long * FileReaderDDU::file_buffer_end

private

Definition at line 14 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), and read().

raw_event

unsigned short FileReaderDDU::raw_event[200000]

private

Definition at line 9 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), and read().

rejectCriteria

unsigned int FileReaderDDU::rejectCriteria

private

Definition at line 28 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), next(), and reject().

selectCriteria

unsigned int FileReaderDDU::selectCriteria

private

Definition at line 28 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), next(), and select().

word_0

unsigned long long FileReaderDDU::word_0

private

Definition at line 11 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), and read().

word_1

unsigned long long FileReaderDDU::word_1

private

Definition at line 11 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), and read().

word_2

unsigned long long FileReaderDDU::word_2

private

Definition at line 11 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), and read().