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);