MP7PacketReader Class Reference

#include <MP7PacketReader.h>

Public Types
typedef std::vector< PacketData >::const_iterator	const_iterator

Public Member Functions
const_iterator	begin () const
const_iterator	end () const
const PacketData &	get (size_t i)
	MP7PacketReader (const std::string &path, uint32_t striphdr=0, uint32_t stripftr=0, uint32_t ikey=0)
size_t	size () const
bool	valid () const
virtual	~MP7PacketReader ()

Private Member Functions
void	load ()

Static Private Member Functions
static std::vector< PacketRange >	findPackets (std::vector< uint64_t > data)

Private Attributes
std::vector< PacketData >	buffers_
uint32_t	footer_
uint32_t	header_
uint32_t	ikey_
MP7FileReader	reader_

Detailed Description

Definition at line 46 of file MP7PacketReader.h.

Member Typedef Documentation

typedef std::vector<PacketData>::const_iterator MP7PacketReader::const_iterator

Definition at line 48 of file MP7PacketReader.h.

Constructor & Destructor Documentation

MP7PacketReader::MP7PacketReader	(	const std::string &	path,
		uint32_t	striphdr = 0,
		uint32_t	stripftr = 0,
		uint32_t	ikey = 0
	)

Definition at line 8 of file MP7PacketReader.cc.

References load(), reader_, and MP7FileReader::valid().

                                                                                                           : reader_( path ), header_(striphdr), footer_(stripftr), ikey_(ikey) {    
    if ( !reader_.valid() ) return;
    load();
}

MP7PacketReader::~MP7PacketReader ( )

virtual

Definition at line 24 of file MP7PacketReader.cc.

                                  {
}

Member Function Documentation

const_iterator MP7PacketReader::begin ( void  ) const

inline

Definition at line 60 of file MP7PacketReader.h.

Referenced by findPackets().

{ return buffers_.begin(); }

const_iterator MP7PacketReader::end ( void  ) const

inline

Definition at line 62 of file MP7PacketReader.h.

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

{ return buffers_.end(); }

std::vector< PacketRange > MP7PacketReader::findPackets ( std::vector< uint64_t >  data )

staticprivate

Definition at line 86 of file MP7PacketReader.cc.

References begin(), end(), mps_fire::i, diffTwoXMLs::ranges, findQualityFiles::v, and x.

Referenced by load().

                                                       {
    std::vector<PacketRange> ranges;
    bool v = false;
    int32_t begin(-1), end(-1);
    for ( size_t i(0); i < data.size(); ++i) {
        uint64_t x = data[i];
        if (not v) {
            if ((x >> 32) & 1) {
                v = true;
                begin = i;
            }
            continue;
        } else {
            if ( not ((x >> 32 ) & 1 ) ) {
                v = false;
                end = i-1;
                ranges.push_back(std::make_pair(begin,end) );
            }
            continue;
        }
    }
    
    if ( v && (begin != -1 ) ) {
        end = data.size()-1;
        ranges.push_back(std::make_pair(begin,end) );
    }
    
    return ranges;

}

const PacketData& MP7PacketReader::get ( size_t  i )

inline

Definition at line 58 of file MP7PacketReader.h.

References mps_fire::i.

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), rrapi.RRApi::columns(), util.rrapi.RRApi::columns(), rrapi.RRApi::count(), util.rrapi.RRApi::count(), rrapi.RRApi::data(), util.rrapi.RRApi::data(), l1t::MP7BufferDumpToRaw::getBlocks(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), betterConfigParser.BetterConfigParser::getResultingSection(), rrapi.RRApi::report(), util.rrapi.RRApi::report(), rrapi.RRApi::reports(), util.rrapi.RRApi::reports(), util.rrapi.RRApi::tables(), rrapi.RRApi::tables(), util.rrapi.RRApi::tags(), rrapi.RRApi::tags(), util.rrapi.RRApi::templates(), rrapi.RRApi::templates(), rrapi.RRApi::workspaces(), and util.rrapi.RRApi::workspaces().

{ return buffers_.at(i); }

void MP7PacketReader::load ( )

private

Definition at line 28 of file MP7PacketReader.cc.

References FileData::begin(), MP7FileReader::begin(), buffers_, data, FileData::end(), MP7FileReader::end(), findPackets(), Packet::first_, footer_, header_, ikey_, gen::k, Packet::last_, FileData::link(), Packet::links_, FileData::name(), PacketData::name_, AlCaHLTBitMon_ParallelJobs::p, PacketData::packets_, diffTwoXMLs::ranges, reader_, FileData::size(), and MP7FileReader::size().

Referenced by MP7PacketReader().

                      {
    
    buffers_.reserve(reader_.size());
    MP7FileReader::const_iterator it = reader_.begin();
    for( ; it != reader_.end(); ++it ) {
        const FileData& raw = *it;
        
        // Check channel alignment
        std::set< std::vector<PacketRange > > rangeSet;
        
        for( size_t k(0); k<raw.size(); ++k) {
            std::vector<PacketRange > ranges = findPackets(raw.link(ikey_)); 
            rangeSet.insert(ranges);
        }
        //cout << "Number of different patterns: " << rangeSet.size() << endl;
        if ( rangeSet.size() != 1 )
            throw std::runtime_error("Links are not aligned!");
        
        std::vector<PacketRange > pr = *(rangeSet.begin());

        // Create the container
        PacketData data;
        data.name_ = raw.name();

        data.packets_.reserve(pr.size());
        
        // loop over the ranges to build packets
        for(auto const& p : pr) {
            
            // Check if the header/footer zeroed the packet
            if ( p.second-p.first-header_-footer_<= 0 ) {
                // Turn this into an error message
                //cout << "Error: packet length is zero (or less) after header/footer stripping. Skipping." << endl;
                continue;
            }
            
            Packet pkt;
            FileData::const_iterator lIt = raw.begin();
            for( ; lIt != raw.end(); ++lIt ) {
                // Here the 64 bit uint is converted into a 32 bit uint, the data valid bit is stripped in the 64->32 bit conversion.
                pkt.links_[lIt->first] = std::vector<uint32_t>(
                        lIt->second.begin() + p.first + header_,
                        lIt->second.begin() + p.second - footer_ + 1
                        );
            }
            pkt.first_ = p.first + header_;
            pkt.last_ = p.second - footer_;
                    
            data.packets_.push_back(pkt);
        }
        
        buffers_.push_back(data);   
               
        
    }
}

size_t MP7PacketReader::size ( void  ) const

inline

Definition at line 64 of file MP7PacketReader.h.

References data, and svgfig::load().

Referenced by ntupleDataFormat._Collection::__iter__(), and ntupleDataFormat._Collection::__len__().

{ return buffers_.size(); }

bool MP7PacketReader::valid ( ) const

inline

Definition at line 56 of file MP7PacketReader.h.

{ return reader_.valid(); }

Member Data Documentation

std::vector< PacketData > MP7PacketReader::buffers_

private

Definition at line 71 of file MP7PacketReader.h.

Referenced by load().

uint32_t MP7PacketReader::footer_

private

Definition at line 74 of file MP7PacketReader.h.

Referenced by load().

uint32_t MP7PacketReader::header_

private

Definition at line 73 of file MP7PacketReader.h.

Referenced by load().

uint32_t MP7PacketReader::ikey_

private

Definition at line 75 of file MP7PacketReader.h.

Referenced by load().

MP7FileReader MP7PacketReader::reader_

private

Definition at line 72 of file MP7PacketReader.h.

Referenced by load(), and MP7PacketReader().