#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.

24 {

25 }

Member Function Documentation

const_iterator MP7PacketReader::begin ( void ) const

inline

Definition at line 60 of file MP7PacketReader.h.

Referenced by findPackets().

60 { return buffers_.begin(); }

MP7PacketReader::buffers_

std::vector< PacketData > buffers_

Definition: MP7PacketReader.h:71

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().

62 { return buffers_.end(); }

MP7PacketReader::buffers_

std::vector< PacketData > buffers_

Definition: MP7PacketReader.h:71

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.

58 { return buffers_.at(i); }

mps_fire.i

i

Definition: mps_fire.py:329

MP7PacketReader::buffers_

std::vector< PacketData > buffers_

Definition: MP7PacketReader.h:71

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