MP7PacketReader.cc

Go to the documentation of this file.

#include "EventFilter/L1TRawToDigi/interface/MP7PacketReader.h"

#include <iostream>

using std::cout;
using std::endl;

MP7PacketReader::MP7PacketReader(const std::string& path, uint32_t striphdr, uint32_t stripftr, uint32_t ikey) : reader_( path ), header_(striphdr), footer_(stripftr), ikey_(ikey) {    
    if ( !reader_.valid() ) return;
    load();
}

//MP7PacketReader::MP7PacketReader(MP7FileReader rdr,
//               uint32_t striphdr,
//               uint32_t stripftr) :
//  reader_( rdr ),
//  header_(striphdr),
//  footer_(stripftr) 
//{    
//  if ( !reader_.valid() ) return;
//  load();
//}

MP7PacketReader::~MP7PacketReader() {
}

void
MP7PacketReader::load() {
    
    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);   
               
        
    }
}

std::vector<PacketRange>
MP7PacketReader::findPackets( std::vector<uint64_t> data ) {
    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;

}