OmtfRpcUnpacker.cc

Go to the documentation of this file.

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

#include "FWCore/MessageLogger/interface/MessageLogger.h"

#include "EventFilter/RPCRawToDigi/interface/RPCRecordFormatter.h"
#include "EventFilter/RPCRawToDigi/interface/RPCPackingModule.h"
#include "EventFilter/RPCRawToDigi/interface/DebugDigisPrintout.h"
#include "CondFormats/RPCObjects/interface/RPCEMap.h"
#include "CondFormats/DataRecord/interface/RPCEMapRcd.h"
#include "EventFilter/L1TRawToDigi/interface/OmtfRpcDataWord64.h"

#include "DataFormats/RPCDigi/interface/DataRecord.h"
#include "DataFormats/RPCDigi/interface/RecordBX.h"
#include "DataFormats/RPCDigi/interface/RecordSLD.h"
#include "DataFormats/RPCDigi/interface/RecordCD.h"

namespace omtf {

  void RpcUnpacker::initCabling(const RPCEMap& readoutMapping) {
    thePactCabling.reset(readoutMapping.convert());

    LogDebug("OmtfUnpacker") << " Has PACT readout map, VERSION: " << thePactCabling->version() << std::endl;
  }

  void RpcUnpacker::init(const RPCEMap& readoutMapping, const RPCAMCLinkMap& linkMap) {
    initCabling(readoutMapping);
    RpcLinkMap omtfLink2Ele;
    omtfLink2Ele.init(linkMap);
    theOmtf2Pact = translateOmtf2Pact(omtfLink2Ele, thePactCabling.get());
  }

  void RpcUnpacker::init(const RPCEMap& readoutMapping, const std::string& connectionFile) {
    initCabling(readoutMapping);
    RpcLinkMap omtfLink2Ele;
    omtfLink2Ele.init(connectionFile);
    theOmtf2Pact = translateOmtf2Pact(omtfLink2Ele, thePactCabling.get());
  }

  void RpcUnpacker::unpack(
      int triggerBX, unsigned int fed, unsigned int amc, const RpcDataWord64& data, RPCDigiCollection* prod) {
    LogTrace("RpcUnpacker:") << data;

    //  EleIndex omtfEle(fedHeader.sourceID(), bh.getAMCNumber()/2+1, data.linkNum());
    EleIndex omtfEle(fed, amc, data.linkNum());
    LinkBoardElectronicIndex rpcEle = theOmtf2Pact.at(omtfEle);
    RPCRecordFormatter formater(rpcEle.dccId, thePactCabling.get());

    rpcrawtodigi::EventRecords records(triggerBX);
    rpcrawtodigi::RecordBX recordBX(triggerBX + data.bxNum() - 3);
    records.add(recordBX);  // warning: event records must be added in right order
    rpcrawtodigi::RecordSLD recordSLD(rpcEle.tbLinkInputNum, rpcEle.dccInputChannelNum);
    records.add(recordSLD);  // warning: event records must be added in right order

    for (unsigned int iframe = 1; iframe <= 3; iframe++) {
      uint16_t frame = (iframe == 1) ? data.frame1() : ((iframe == 2) ? data.frame2() : data.frame3());
      if (frame == 0)
        continue;
      rpcrawtodigi::RecordCD recordCD(frame);
      records.add(recordCD);

      LogTrace("") << "OMTF->RPC Event isComplete: " << records.complete()
                   << records.print(rpcrawtodigi::DataRecord::StartOfBXData);  // << std::endl;
      LogTrace("") << "OMTF->RPC Event:             "
                   << records.print(rpcrawtodigi::DataRecord::StartOfTbLinkInputNumberData) << std::endl;
      LogTrace("") << "OMTF->RPC Event:             " << records.print(rpcrawtodigi::DataRecord::ChamberData)
                   << " lb:" << recordCD.lbInLink() << " part: " << recordCD.partitionNumber()
                   << " partData: " << recordCD.partitionData() << std::endl
                   << std::endl;

      if (records.complete())
        formater.recordUnpack(records, prod, nullptr, nullptr);
    }
  }
}  // namespace omtf