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) throw (std::runtime_error)
int	open (const char *filename) throw (std::runtime_error)
size_t	read (const unsigned short *&buf) throw (std::runtime_error)
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

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

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

(

void

)

Definition at line 16 of file FileReaderDDU.cc.

References acceptCriteria, DDUoversize, end, eventStatus, fd, FFFF, file_buffer, file_buffer_end, 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 ( void  )

virtual

Definition at line 30 of file FileReaderDDU.cc.

References fd.

{ if( fd ) close(fd); }

Member Function Documentation

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

inline

Definition at line 29 of file FileReaderDDU.h.

References acceptCriteria.

Referenced by Vispa.Gui.BoxContentDialog.BoxContentDialog::apply(), and Vispa.Plugins.ConfigEditor.ToolDialog.ToolDialog::apply().

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

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

Definition at line 124 of file FileReaderDDU.cc.

References i, SiPixelLorentzAngle_cfi::read, 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;
}

int FileReaderDDU::open	(	const char *	filename	)
throw	(	std::runtime_error
	)

Definition at line 32 of file FileReaderDDU.cc.

References python.multivaluedict::append(), lut2db_cfg::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;
}

size_t FileReaderDDU::read	(	const unsigned short *&	buf	)
throw	(	std::runtime_error
	)

Definition at line 39 of file FileReaderDDU.cc.

References end, event(), SiPixelLorentzAngle_cfi::read, dqm_diff::start, and Unknown.

                                                                              {
    // 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 = 0;

    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);
}

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

inline

Definition at line 30 of file FileReaderDDU.h.

References rejectCriteria.

Referenced by CSCFileReader::CSCFileReader(), and Vispa.Plugins.ConfigEditor.ToolDialog.ToolDialog::keyPressEvent().

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

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

inline

Definition at line 28 of file FileReaderDDU.h.

References selectCriteria.

Referenced by CSCFileReader::CSCFileReader().

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

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

inline

Definition at line 32 of file FileReaderDDU.h.

References eventStatus.

{ return eventStatus; }

Member Data Documentation

unsigned int FileReaderDDU::acceptCriteria

private

Definition at line 20 of file FileReaderDDU.h.

Referenced by accept(), and FileReaderDDU().

unsigned long long* FileReaderDDU::end

private

Definition at line 14 of file FileReaderDDU.h.

Referenced by Types.LuminosityBlockRange::cppID(), Types.EventRange::cppID(), FileReaderDDU(), and cmsPerfSuite.PerfSuiteTimer::set_end().

unsigned int FileReaderDDU::eventStatus

private

Definition at line 20 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), and status().

int FileReaderDDU::fd

private

Definition at line 22 of file FileReaderDDU.h.

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

unsigned long long FileReaderDDU::file_buffer[4000]

private

Definition at line 12 of file FileReaderDDU.h.

Referenced by FileReaderDDU().

unsigned long long * FileReaderDDU::file_buffer_end

private

Definition at line 14 of file FileReaderDDU.h.

Referenced by FileReaderDDU().

unsigned short FileReaderDDU::raw_event[200000]

private

Definition at line 9 of file FileReaderDDU.h.

Referenced by FileReaderDDU().

unsigned int FileReaderDDU::rejectCriteria

private

Definition at line 20 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), and reject().

unsigned int FileReaderDDU::selectCriteria

private

Definition at line 20 of file FileReaderDDU.h.

Referenced by FileReaderDDU(), and select().

unsigned long long FileReaderDDU::word_0

private

Definition at line 11 of file FileReaderDDU.h.

Referenced by FileReaderDDU().

unsigned long long FileReaderDDU::word_1

private

Definition at line 11 of file FileReaderDDU.h.

Referenced by FileReaderDDU().

unsigned long long FileReaderDDU::word_2

private

Definition at line 11 of file FileReaderDDU.h.

Referenced by FileReaderDDU().