OmtfRpcPacker.cc

Go to the documentation of this file.

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

#include "FWCore/Framework/interface/EventSetup.h"
#include "FWCore/Framework/interface/ESTransientHandle.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"

#include "CondFormats/RPCObjects/interface/RPCReadOutMapping.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"

namespace omtf {

  void RpcPacker::initCabling(const edm::EventSetup& es) {
    edm::ESTransientHandle<RPCEMap> readoutMapping;
    es.get<RPCEMapRcd>().get(readoutMapping);
    thePactCabling.reset(readoutMapping->convert());
    LogDebug("OmtfPacker") << " Has PACT readout map, VERSION: " << thePactCabling->version() << std::endl;
  }

  void RpcPacker::init(const edm::EventSetup& es) {
    initCabling(es);
    RpcLinkMap omtfLink2Ele;
    omtfLink2Ele.init(es);
    thePact2Omtf = translatePact2Omtf(omtfLink2Ele, thePactCabling.get());
  }

  void RpcPacker::init(const edm::EventSetup& es, const std::string& connectionFile) {
    initCabling(es);
    RpcLinkMap omtfLink2Ele;
    omtfLink2Ele.init(connectionFile);
    thePact2Omtf = translatePact2Omtf(omtfLink2Ele, thePactCabling.get());
  }

  void RpcPacker::pack(const RPCDigiCollection* digis, FedAmcRawsMap& raws) {
    LogTrace("") << " HERE HERE !!! RPC PACKER" << rpcrawtodigi::DebugDigisPrintout()(digis);
    for (int dcc = 790; dcc <= 792; dcc++) {
      RPCRecordFormatter formatter(dcc, thePactCabling.get());
      const std::vector<rpcrawtodigi::EventRecords>& merged =
          RPCPackingModule::eventRecords(dcc, 200, digis, formatter);
      LogTrace("") << " SIZE OF MERGED, for DCC=" << dcc << " is: " << merged.size() << std::endl;
      for (const auto& rpcEvent : merged) {
        RpcDataWord64 data;
        data.bxNum_ = rpcEvent.dataToTriggerDelay();
        data.frame1_ = rpcEvent.recordCD().data();
        LinkBoardElectronicIndex rpcEle = {
            dcc, rpcEvent.recordSLD().rmb(), rpcEvent.recordSLD().tbLinkInputNumber(), rpcEvent.recordCD().lbInLink()};
        auto it = thePact2Omtf.find(rpcEle);
        if (it != thePact2Omtf.end()) {
          const EleIndex& omtfEle1 = it->second.first;
          const EleIndex& omtfEle2 = it->second.second;
          if (omtfEle1.fed()) {
            data.linkNum_ = omtfEle1.link();
            raws[std::make_pair(omtfEle1.fed(), omtfEle1.amc() * 2 - 1)].push_back(data.rawData);
          }
          if (omtfEle2.fed()) {
            data.linkNum_ = omtfEle2.link();
            raws[std::make_pair(omtfEle2.fed(), omtfEle2.amc() * 2 - 1)].push_back(data.rawData);
          }
        }
      }
    }
  }

};  // namespace omtf