#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 44 of file MP7PacketReader.h.

Member Typedef Documentation

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

Definition at line 46 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 26 of file MP7PacketReader.cc.

26 {}

Member Function Documentation

const_iterator MP7PacketReader::begin ( void ) const

inline

Definition at line 58 of file MP7PacketReader.h.

Referenced by findPackets().

58 { return buffers_.begin(); }

MP7PacketReader::buffers_

std::vector< PacketData > buffers_

Definition: MP7PacketReader.h:68

const_iterator MP7PacketReader::end ( void ) const

inline

Definition at line 60 of file MP7PacketReader.h.

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

60 { return buffers_.end(); }

MP7PacketReader::buffers_

std::vector< PacketData > buffers_

Definition: MP7PacketReader.h:68

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

staticprivate

Definition at line 79 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 56 of file MP7PacketReader.h.

References mps_fire::i.

56 { return buffers_.at(i); }

mps_fire.i

i

Definition: mps_fire.py:341

MP7PacketReader::buffers_

std::vector< PacketData > buffers_

Definition: MP7PacketReader.h:68

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_, dqmdumpme::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);
   }
 }