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

Member Typedef Documentation

const_iterator

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

Definition at line 46 of file MP7PacketReader.h.

Constructor & Destructor Documentation

MP7PacketReader()

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::~MP7PacketReader ( )

virtual

Definition at line 26 of file MP7PacketReader.cc.

{}

Member Function Documentation

begin()

const_iterator MP7PacketReader::begin ( void  ) const

inline

Definition at line 58 of file MP7PacketReader.h.

References buffers_.

Referenced by findPackets().

{ return buffers_.begin(); }

end()

const_iterator MP7PacketReader::end ( void  ) const

inline

Definition at line 60 of file MP7PacketReader.h.

References buffers_.

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

{ return buffers_.end(); }

findPackets()

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

staticprivate

Definition at line 79 of file MP7PacketReader.cc.

References begin(), data, 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;
}

get()

const PacketData& MP7PacketReader::get ( size_t  i )

inline

Definition at line 56 of file MP7PacketReader.h.

References buffers_, and mps_fire::i.

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), submitPVValidationJobs.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(), submitPVValidationJobs.BetterConfigParser::getResultingSection(), util.rrapi.RRApi::report(), rrapi.RRApi::report(), util.rrapi.RRApi::reports(), rrapi.RRApi::reports(), rrapi.RRApi::tables(), util.rrapi.RRApi::tables(), util.rrapi.RRApi::tags(), rrapi.RRApi::tags(), rrapi.RRApi::templates(), util.rrapi.RRApi::templates(), rrapi.RRApi::workspaces(), and util.rrapi.RRApi::workspaces().

{ return buffers_.at(i); }

load()

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_, ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, dqmdumpme::k, Packet::last_, FileData::link(), Packet::links_, FileData::name(), AlCaHLTBitMon_ParallelJobs::p, 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()

size_t MP7PacketReader::size ( void  ) const

inline

Definition at line 62 of file MP7PacketReader.h.

References buffers_.

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

{ return buffers_.size(); }

valid()

bool MP7PacketReader::valid ( ) const

inline

Definition at line 54 of file MP7PacketReader.h.

References reader_, and MP7FileReader::valid().

{ return reader_.valid(); }

Member Data Documentation

buffers_

std::vector<PacketData> MP7PacketReader::buffers_

private

Definition at line 68 of file MP7PacketReader.h.

Referenced by begin(), end(), get(), load(), and size().

footer_

uint32_t MP7PacketReader::footer_

private

Definition at line 71 of file MP7PacketReader.h.

Referenced by load().

header_

uint32_t MP7PacketReader::header_

private

Definition at line 70 of file MP7PacketReader.h.

Referenced by load().

ikey_

uint32_t MP7PacketReader::ikey_

private

Definition at line 72 of file MP7PacketReader.h.

Referenced by load().

reader_

MP7FileReader MP7PacketReader::reader_

private

Definition at line 69 of file MP7PacketReader.h.

Referenced by load(), MP7PacketReader(), and valid().