RPCTwinMuxPacker.cc

Go to the documentation of this file.

#include "EventFilter/RPCRawToDigi/interface/RPCTwinMuxPacker.h"

#include "CondFormats/RPCObjects/interface/RPCInverseAMCLinkMap.h"
#include "EventFilter/RPCRawToDigi/interface/RPCLBPacker.h"

void RPCTwinMuxPacker::getRPCTwinMuxRecords(RPCInverseLBLinkMap const & lb_map, RPCInverseAMCLinkMap const & amc_map
                                            , int min_bx, int max_bx, unsigned int bcn
                                            , RPCDigiCollection const & digis
                                            , std::map<RPCAMCLink, std::vector<std::pair<int, rpctwinmux::RPCRecord> > > & amc_bx_tmrecord
                                            , bool ignore_eod)
{
    std::map<RPCLBLink, std::vector<std::pair<int, RPCLBRecord> > > mlb_bx_lbrecord;
    RPCLBPacker::getRPCLBRecords(lb_map
                                 , min_bx, max_bx, bcn
                                 , digis
                                 , mlb_bx_lbrecord
                                 , ignore_eod);

    for (std::map<RPCLBLink, std::vector<std::pair<int, RPCLBRecord> > >::const_iterator mlb_bx_lbrecord_it = mlb_bx_lbrecord.begin()
             ; mlb_bx_lbrecord_it != mlb_bx_lbrecord.end() ; ++mlb_bx_lbrecord_it) {
        // multimap, but no splitting for TwinMux inputs
        RPCInverseAMCLinkMap::map_type::const_iterator amc_it(amc_map.getMap().find(mlb_bx_lbrecord_it->first));
        if (amc_it == amc_map.getMap().end()) {
            continue;
        }

        RPCAMCLink amc_id(amc_it->second);
        int amc_input(amc_id.getAMCInput());
        amc_id.setAMCInput();
        std::vector<std::pair<int, rpctwinmux::RPCRecord> > & bx_tmrecord(amc_bx_tmrecord[amc_id]);
        std::vector<std::pair<int, rpctwinmux::RPCRecord> >::iterator tmrecord_it(bx_tmrecord.begin());
        for (std::vector<std::pair<int, RPCLBRecord> >::const_iterator bx_lbrecord = mlb_bx_lbrecord_it->second.begin()
                 ; bx_lbrecord != mlb_bx_lbrecord_it->second.end() ; ++bx_lbrecord) {
            // find the first record at this bx for this amc without this input
            for ( ; tmrecord_it != bx_tmrecord.end() && tmrecord_it->first < bx_lbrecord->first; ++tmrecord_it);
            if (tmrecord_it == bx_tmrecord.end() || tmrecord_it->first != bx_lbrecord->first) {
                tmrecord_it = bx_tmrecord.insert(tmrecord_it
                                                 , std::pair<int, rpctwinmux::RPCRecord>(bx_lbrecord->first
                                                                                         , rpctwinmux::RPCRecord()));
                tmrecord_it->second.setBXOffset(bx_lbrecord->first);
            }
            rpctwinmux::RPCLinkRecord tm_link_record;
            tm_link_record.setAcknowledge(true);
            tm_link_record.setEOD(bx_lbrecord->second.isEOD());
            tm_link_record.setDelay(bx_lbrecord->second.getDelay());
            tm_link_record.setLinkBoard(bx_lbrecord->second.getLinkBoard());
            tm_link_record.setConnector(bx_lbrecord->second.getConnector());
            tm_link_record.setPartition(bx_lbrecord->second.getPartition());
            tm_link_record.setPartitionData(bx_lbrecord->second.getPartitionData());

            tmrecord_it->second.setRPCLinkRecord(amc_input, tm_link_record);
            // make sure we don't fill this input twice if ignore_eod == true
            ++tmrecord_it;
        }
    }
}