TriggerOutputFields Class Reference

#include <TriggerOutputFields.h>

Public Member Functions
void	createFields (const edm::EventForOutput &event, RNTupleModel &model)
void	fill (const edm::EventForOutput &event)
	TriggerOutputFields ()=default
	TriggerOutputFields (const std::string &processName, const edm::EDGetToken &token)

Private Member Functions
void	makeUniqueFieldName (RNTupleModel &model, std::string &name)
void	updateTriggerFields (const edm::TriggerResults &triggerResults)

Static Private Member Functions
static std::vector< std::string >	getTriggerNames (const edm::TriggerResults &triggerResults)

Private Attributes
long	m_lastRun
std::string	m_processName
edm::EDGetToken	m_token
std::vector< TriggerFieldPtr >	m_triggerFields

Detailed Description

Definition at line 28 of file TriggerOutputFields.h.

Constructor & Destructor Documentation

TriggerOutputFields() [1/2]

TriggerOutputFields::TriggerOutputFields ( )

default

TriggerOutputFields() [2/2]

TriggerOutputFields::TriggerOutputFields ( const std::string &  processName, const edm::EDGetToken &  token  )

inlineexplicit

Definition at line 31 of file TriggerOutputFields.h.

      : m_token(token), m_lastRun(-1), m_processName(processName) {}

Member Function Documentation

createFields()

void TriggerOutputFields::createFields	(	const edm::EventForOutput &	event,
		RNTupleModel &	model
	)

Definition at line 71 of file TriggerOutputFields.cc.

References submitPVResolutionJobs::desc, getTriggerNames(), patZpeak::handle, mps_fire::i, m_lastRun, m_processName, m_token, m_triggerFields, makeUniqueFieldName(), ReggeGribovPartonMC_EposLHC_2760GeV_PbPb_cfi::model, ecalBarrelClusterFastTimer_cfi::modelName, Skims_PA_cff::name, AlCaHLTBitMon_QueryRunRegistry::string, L1TEGammaOffline_cfi::triggerNames, and triggerResults.

                                                                                          {
  m_lastRun = event.id().run();
  edm::Handle<edm::TriggerResults> handle;
  event.getByToken(m_token, handle);
  const edm::TriggerResults& triggerResults = *handle;
  std::vector<std::string> triggerNames(TriggerOutputFields::getTriggerNames(triggerResults));
  m_triggerFields.reserve(triggerNames.size());
  for (std::size_t i = 0; i < triggerNames.size(); i++) {
    auto& name = triggerNames[i];
    if (!isNanoaodTrigger(name)) {
      continue;
    }
    trimVersionSuffix(name);
    std::string modelName = name;
    makeUniqueFieldName(model, modelName);
    std::string desc = std::string("Trigger/flag bit (process: ") + m_processName + ")";
    m_triggerFields.emplace_back(TriggerFieldPtr(name, i, modelName, desc, model));
  }
}

fill()

void TriggerOutputFields::fill

(

const edm::EventForOutput &

event

)

Definition at line 136 of file TriggerOutputFields.cc.

References patZpeak::handle, m_lastRun, m_token, m_triggerFields, submitPVValidationJobs::t, and updateTriggerFields().

                                                             {
  edm::Handle<edm::TriggerResults> handle;
  event.getByToken(m_token, handle);
  const edm::TriggerResults& triggers = *handle;
  if (m_lastRun != event.id().run()) {
    m_lastRun = event.id().run();
    updateTriggerFields(triggers);
  }
  for (auto& t : m_triggerFields) {
    t.fill(triggers);
  }
}

getTriggerNames()

std::vector< std::string > TriggerOutputFields::getTriggerNames ( const edm::TriggerResults &  triggerResults )

staticprivate

Definition at line 49 of file TriggerOutputFields.cc.

References Exception, edm::pset::Registry::getMapped(), edm::pset::Registry::instance(), names, muonDTDigis_cfi::pset, L1TEGammaOffline_cfi::triggerNames, and triggerResults.

Referenced by createFields(), and updateTriggerFields().

                                                                                                 {
  // Trigger names are either stored in the TriggerResults object (e.g. L1) or
  // need to be looked up in the registry (e.g. HLT)
  auto triggerNames = triggerResults.getTriggerNames();
  if (!triggerNames.empty()) {
    return triggerNames;
  }
  edm::pset::Registry* psetRegistry = edm::pset::Registry::instance();
  edm::ParameterSet const* pset = psetRegistry->getMapped(triggerResults.parameterSetID());
  if (nullptr == pset || !pset->existsAs<std::vector<std::string>>("@trigger_paths", true)) {
    return {};
  }
  edm::TriggerNames names(*pset);
  if (names.size() != triggerResults.size()) {
    throw cms::Exception("LogicError") << "TriggerOutputFields::getTriggerNames "
                                          "Encountered vector\n of trigger names and a TriggerResults object with\n"
                                          "different sizes.  This should be impossible.\n"
                                          "Please send information to reproduce this problem to\nthe edm developers.\n";
  }
  return names.triggerNames();
}

makeUniqueFieldName()

void TriggerOutputFields::makeUniqueFieldName ( RNTupleModel &  model, std::string &  name  )

private

Definition at line 124 of file TriggerOutputFields.cc.

References m_processName, ReggeGribovPartonMC_EposLHC_2760GeV_PbPb_cfi::model, Skims_PA_cff::name, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by createFields().

                                                                                  {
  // Could also use a cache of names in a higher-level object, don't ask the RNTupleModel each time
  const auto* existing_field = model.Get<bool>(name);
  if (!existing_field) {
    return;
  }
  edm::LogWarning("TriggerOutputFields") << "Found a branch with name " << name
                                         << " already present. Will add suffix _p" << m_processName
                                         << " to the new branch.\n";
  name += std::string("_p") + m_processName;
}

updateTriggerFields()

void TriggerOutputFields::updateTriggerFields ( const edm::TriggerResults &  triggerResults )

private

Definition at line 92 of file TriggerOutputFields.cc.

References getTriggerNames(), dqmiolumiharvest::j, m_triggerFields, Skims_PA_cff::name, and submitPVValidationJobs::t.

Referenced by fill().

                                                                               {
  std::vector<std::string> newNames(TriggerOutputFields::getTriggerNames(triggers));
  // adjust existing trigger indices
  for (auto& t : m_triggerFields) {
    t.setIndex(-1);
    for (std::size_t j = 0; j < newNames.size(); j++) {
      auto& name = newNames[j];
      if (!isNanoaodTrigger(name)) {
        continue;
      }
      trimVersionSuffix(name);
      if (name == t.getTriggerName()) {
        t.setIndex(j);
      }
    }
  }
  // find new triggers
  for (std::size_t j = 0; j < newNames.size(); j++) {
    auto& name = newNames[j];
    if (!isNanoaodTrigger(name)) {
      continue;
    }
    trimVersionSuffix(name);
    if (std::none_of(m_triggerFields.cbegin(), m_triggerFields.cend(), [&](const TriggerFieldPtr& t) {
          return t.getTriggerName() == name;
        })) {
      // TODO backfill / friend ntuples
      edm::LogWarning("TriggerOutputFields") << "Skipping output of TriggerField " << name << "\n";
    }
  }
}

Member Data Documentation

m_lastRun

long TriggerOutputFields::m_lastRun

private

Definition at line 43 of file TriggerOutputFields.h.

Referenced by createFields(), and fill().

m_processName

std::string TriggerOutputFields::m_processName

private

Definition at line 44 of file TriggerOutputFields.h.

Referenced by createFields(), and makeUniqueFieldName().

m_token

edm::EDGetToken TriggerOutputFields::m_token

private

Definition at line 42 of file TriggerOutputFields.h.

Referenced by createFields(), and fill().

m_triggerFields

std::vector<TriggerFieldPtr> TriggerOutputFields::m_triggerFields

private

Definition at line 45 of file TriggerOutputFields.h.

Referenced by createFields(), fill(), and updateTriggerFields().