L1TTwinMuxProducer.cc

Go to the documentation of this file.

//-------------------------------------------------
//
//   Class: L1TwinMuxProducer
//
//   L1TwinMuxProducer EDProducer
//
//
//   Author :
//   G. Flouris               U Ioannina    Feb. 2015
//   Mod.: g Karathanasis
//--------------------------------------------------
 
#include "FWCore/Framework/interface/MakerMacros.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Framework/interface/MakerMacros.h"
#include <FWCore/Framework/interface/ConsumesCollector.h>
#include <FWCore/ParameterSet/interface/ParameterSet.h>
#include "FWCore/Framework/interface/stream/EDProducer.h"
 
#include "L1Trigger/L1TTwinMux/interface/L1TTwinMuxAlgorithm.h"
 
#include <iostream>
#include <iomanip>
#include <memory>
 
using namespace std;
 
//class L1TTwinMuxProducer: public edm::one::EDProducer<edm::one::SharedResources>
//class L1TTwinMuxProducer: public edm::EDProducer
class L1TTwinMuxProducer : public edm::stream::EDProducer<> {
public:
  L1TTwinMuxProducer(const edm::ParameterSet& pset);
  ~L1TTwinMuxProducer() override {}
  void produce(edm::Event& e, const edm::EventSetup& c) override;
 
private:
  //L1TTwinMuxAlgorithm *  m_l1tma;
  //  std::unique_ptr<L1TTwinMuxAlgorithm> m_l1tma(new L1TTwinMuxAlgorithm());
  edm::EDGetToken m_dtdigi, m_dtthetadigi, m_rpcsource;
  edm::ESHandle<L1TTwinMuxParams> tmParamsHandle;
};
 
L1TTwinMuxProducer::L1TTwinMuxProducer(const edm::ParameterSet& pset) {
  //m_l1tma = new L1TTwinMuxAlgorithm();
  // std::unique_ptr<L1TTwinMuxAlgorithm> m_l1tma(new L1TTwinMuxAlgorithm());
 
  m_dtdigi = consumes<L1MuDTChambPhContainer>(pset.getParameter<edm::InputTag>("DTDigi_Source"));
  m_dtthetadigi = consumes<L1MuDTChambThContainer>(pset.getParameter<edm::InputTag>("DTThetaDigi_Source"));
  m_rpcsource = consumes<RPCDigiCollection>(pset.getParameter<edm::InputTag>("RPC_Source"));
 
  produces<L1MuDTChambPhContainer>();
  produces<L1MuDTChambThContainer>();
}
 
void L1TTwinMuxProducer::produce(edm::Event& e, const edm::EventSetup& c) {
  std::unique_ptr<L1TTwinMuxAlgorithm> m_l1tma(new L1TTwinMuxAlgorithm());
  const L1TTwinMuxParamsRcd& tmParamsRcd = c.get<L1TTwinMuxParamsRcd>();
  tmParamsRcd.get(tmParamsHandle);
  const L1TTwinMuxParams& tmParams = *tmParamsHandle.product();
 
  bool onlyRPC = tmParams.get_UseOnlyRPC();
  bool onlyDT = tmParams.get_UseOnlyDT();
 
  if (onlyDT && onlyRPC) {
    edm::LogWarning("Inconsistent configuration") << "onlyRPC and onlyDT options";
    return;
  }
 
  edm::Handle<L1MuDTChambPhContainer> phiDigis;
  edm::Handle<L1MuDTChambThContainer> thetaDigis;
  e.getByToken(m_dtdigi, phiDigis);
  e.getByToken(m_dtthetadigi, thetaDigis);
 
  edm::Handle<RPCDigiCollection> rpcDigis;
  e.getByToken(m_rpcsource, rpcDigis);
 
  if (!phiDigis.isValid()) {
    edm::LogWarning("Inconsistent digis") << "input DT phi digis not valid";
  }
 
  //std::unique_ptr<L1MuDTChambPhContainer> l1ttmp(new L1MuDTChambPhContainer);
  auto l1ttmp = std::make_unique<L1MuDTChambPhContainer>();
  m_l1tma->run(phiDigis, thetaDigis, rpcDigis, c);
  *l1ttmp = m_l1tma->get_ph_tm_output();
  //null transfer of theta digis
  auto l1ttmth = std::make_unique<L1MuDTChambThContainer>();
  const std::vector<L1MuDTChambThDigi>* theta = thetaDigis->getContainer();
  l1ttmth->setContainer(*theta);
 
  e.put(std::move(l1ttmp));
  e.put(std::move(l1ttmth));
}
 
DEFINE_FWK_MODULE(L1TTwinMuxProducer);