EMCAL: only request FV0/FT0 trigger inputs in digitizer if detectors are present

Author: ehellbar

Detectors/EMCAL/workflow/include/EMCALWorkflow/EMCALDigitizerSpec.h

@@ -99,7 +99,7 @@ class DigitizerSpec final : public o2::base::BaseDPLDigitizer, public o2::framew
 
 /// \brief Create new digitizer spec
 /// \return Digitizer spec
-o2::framework::DataProcessorSpec getEMCALDigitizerSpec(int channel, bool requireCTPInput, bool mctruth = true, bool useccdb = true);
+o2::framework::DataProcessorSpec getEMCALDigitizerSpec(int channel, bool requireCTPInput, const std::vector<o2::detectors::DetID>& detList, bool mctruth = true, bool useccdb = true);
 
 } // namespace emcal
 } // end namespace o2

Detectors/EMCAL/workflow/src/EMCALDigitizerSpec.cxx

@@ -248,15 +248,19 @@ void DigitizerSpec::run(framework::ProcessingContext& ctx)
     }
     LOG(debug) << "FTO mask: " << std::bitset<64>(ft0mask);
     LOG(debug) << "FVO mask: " << std::bitset<64>(fv0mask);
-    for (const auto& trg : ctx.inputs().get<gsl::span<o2::ft0::DetTrigInput>>("ft0inputs")) {
-      if (trg.mInputs.to_ulong() & ft0mask) {
-        mbtriggers.emplace_back(trg.mIntRecord);
+    if (ft0mask > 0) {
+      for (const auto& trg : ctx.inputs().get<gsl::span<o2::ft0::DetTrigInput>>("ft0inputs")) {
+        if (trg.mInputs.to_ulong() & ft0mask) {
+          mbtriggers.emplace_back(trg.mIntRecord);
+        }
       }
     }
-    for (const auto& trg : ctx.inputs().get<gsl::span<o2::fv0::DetTrigInput>>("fv0inputs")) {
-      if (trg.mInputs.to_ulong() & fv0mask) {
-        if (std::find(mbtriggers.begin(), mbtriggers.end(), trg.mIntRecord) == mbtriggers.end()) {
-          mbtriggers.emplace_back(trg.mIntRecord);
+    if (fv0mask > 0) {
+      for (const auto& trg : ctx.inputs().get<gsl::span<o2::fv0::DetTrigInput>>("fv0inputs")) {
+        if (trg.mInputs.to_ulong() & fv0mask) {
+          if (std::find(mbtriggers.begin(), mbtriggers.end(), trg.mIntRecord) == mbtriggers.end()) {
+            mbtriggers.emplace_back(trg.mIntRecord);
+          }
         }
       }
     }
@@ -460,7 +464,7 @@ void DigitizerSpec::finaliseCCDB(o2::framework::ConcreteDataMatcher& matcher, vo
   }
 }
 
-o2::framework::DataProcessorSpec getEMCALDigitizerSpec(int channel, bool requireCTPInput, bool mctruth, bool useccdb)
+o2::framework::DataProcessorSpec getEMCALDigitizerSpec(int channel, bool requireCTPInput, const std::vector<o2::detectors::DetID>& detList, bool mctruth, bool useccdb)
 {
   // create the full data processor spec using
   //  a name identifier
@@ -486,8 +490,12 @@ o2::framework::DataProcessorSpec getEMCALDigitizerSpec(int channel, bool require
     calibloader->defineInputSpecs(inputs);
   }
   if (requireCTPInput) {
-    inputs.emplace_back("ft0inputs", "FT0", "TRIGGERINPUT", 0, Lifetime::Timeframe);
-    inputs.emplace_back("fv0inputs", "FV0", "TRIGGERINPUT", 0, Lifetime::Timeframe);
+    if (std::find(detList.begin(), detList.end(), o2::detectors::DetID::FT0) != detList.end()) {
+      inputs.emplace_back("ft0inputs", "FT0", "TRIGGERINPUT", 0, Lifetime::Timeframe);
+    }
+    if (std::find(detList.begin(), detList.end(), o2::detectors::DetID::FV0) != detList.end()) {
+      inputs.emplace_back("fv0inputs", "FV0", "TRIGGERINPUT", 0, Lifetime::Timeframe);
+    }
     inputs.emplace_back("ctpconfig", "CTP", "CTPCONFIG", 0, Lifetime::Condition, ccdbParamSpec("CTP/Config/Config", true));
   }
 

Steer/DigitizerWorkflow/src/SimpleDigitizerWorkflow.cxx

@@ -739,7 +739,7 @@ WorkflowSpec defineDataProcessing(ConfigContext const& configcontext)
     bool requireCTPInputs = !configcontext.options().get<bool>("no-require-ctpinputs-emc");
     detList.emplace_back(o2::detectors::DetID::EMC);
     // connect the EMCal digitization
-    digitizerSpecs.emplace_back(o2::emcal::getEMCALDigitizerSpec(fanoutsize++, requireCTPInputs, mctruth, useCCDB));
+    digitizerSpecs.emplace_back(o2::emcal::getEMCALDigitizerSpec(fanoutsize++, requireCTPInputs, detList, mctruth, useCCDB));
     // connect the EMCal digit writer
     writerSpecs.emplace_back(o2::emcal::getEMCALDigitWriterSpec(mctruth));
   }