add first skeleton of reco workflow for iotof

Author: maciacco

Detectors/Upgrades/ALICE3/IOTOF/workflow/CMakeLists.txt

@@ -13,15 +13,16 @@ o2_add_library(IOTOFWorkflow
                TARGETVARNAME targetName
                SOURCES src/DigitReaderSpec.cxx
                        src/DigitWriterSpec.cxx
+                       src/RecoWorkflow.cxx
                PUBLIC_LINK_LIBRARIES O2::Framework
                                      O2::DataFormatsIOTOF
                                      O2::DataFormatsITSMFT
                                      O2::DPLUtils
                                      )
 
-#o2_add_executable(reco-workflow
-#                  SOURCES src/iotof-reco-workflow.cxx
-#                  COMPONENT_NAME alice3-iotof
-#                  PUBLIC_LINK_LIBRARIES O2::IOTOFWorkflow
-#                                        O2::IOTOFSimulation
-#                                        )
+o2_add_executable(reco-workflow
+                  SOURCES src/iotof-reco-workflow.cxx
+                  COMPONENT_NAME alice3-iotof
+                  PUBLIC_LINK_LIBRARIES O2::IOTOFWorkflow
+                                        O2::IOTOFSimulation
+                                        )

Detectors/Upgrades/ALICE3/IOTOF/workflow/include/IOTOFWorkflow/RecoWorkflow.h

@@ -0,0 +1,32 @@
+// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
+// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
+// All rights not expressly granted are reserved.
+//
+// This software is distributed under the terms of the GNU General Public
+// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
+//
+// In applying this license CERN does not waive the privileges and immunities
+// granted to it by virtue of its status as an Intergovernmental Organization
+// or submit itself to any jurisdiction.
+
+#ifndef O2_TF3_RECOWORKFLOW_H
+#define O2_TF3_RECOWORKFLOW_H
+
+#include "Framework/WorkflowSpec.h"
+#include <string>
+
+namespace o2::iotof
+{
+namespace reco_workflow
+{
+
+o2::framework::WorkflowSpec getWorkflow(bool useMC,
+                                        // const std::string& hitRecoConfig,
+                                        bool upstreamDigits = false,
+                                        bool upstreamClusters = false,
+                                        bool disableRootOutput = false);
+}
+
+} // namespace o2::iotof
+
+#endif

Detectors/Upgrades/ALICE3/IOTOF/workflow/src/RecoWorkflow.cxx

@@ -0,0 +1,43 @@
+// Copyright 2019-2020 CERN and copyright holders of ALICE O2.
+// See https://alice-o2.web.cern.ch/copyright for details of the copyright holders.
+// All rights not expressly granted are reserved.
+//
+// This software is distributed under the terms of the GNU General Public
+// License v3 (GPL Version 3), copied verbatim in the file "COPYING".
+//
+// In applying this license CERN does not waive the privileges and immunities
+// granted to it by virtue of its status as an Intergovernmental Organization
+// or submit itself to any jurisdiction.
+
+#include "IOTOFWorkflow/RecoWorkflow.h"
+#include "IOTOFWorkflow/DigitReaderSpec.h"
+#include "Framework/CCDBParamSpec.h"
+
+#include <string>
+
+namespace o2::iotof::reco_workflow
+{
+
+framework::WorkflowSpec getWorkflow(bool useMC,
+                                    // const std::string& hitRecoConfig,
+                                    bool upstreamDigits,
+                                    bool upstreamClusters,
+                                    bool disableRootOutput)
+{
+  framework::WorkflowSpec specs;
+
+  if (!(upstreamDigits || upstreamClusters)) {
+    specs.emplace_back(o2::iotof::getIOTOFDigitReaderSpec(useMC, false, "tf3digits.root"));
+  }
+  if (!upstreamClusters) {
+    // specs.emplace_back(o2::iotof::getClustererSpec(useMC));
+  }
+
+  if (!disableRootOutput) {
+    // specs.emplace_back(o2::iotof::getClusterWriterSpec(useMC));
+  }
+
+  return specs;
+}
+
+} // namespace o2::iotof::reco_workflow

Detectors/Upgrades/ALICE3/IOTOF/workflow/src/iotof-reco-workflow.cxx

@@ -20,16 +20,16 @@
 // granted to it by virtue of its status as an Intergovernmental Organization
 // or submit itself to any jurisdiction.
 
-// #include "TRKWorkflow/RecoWorkflow.h"
-// #include "CommonUtils/ConfigurableParam.h"
+#include "IOTOFWorkflow/RecoWorkflow.h"
+#include "CommonUtils/ConfigurableParam.h"
 // #include "ITStracking/TrackingConfigParam.h"
 // #include "ITStracking/Configuration.h"
 
 #include "Framework/CallbacksPolicy.h"
 #include "Framework/ConfigContext.h"
 #include "Framework/CompletionPolicyHelpers.h"
 
-// #include <vector>
+#include <vector>
 
 using namespace o2::framework;
 
@@ -52,11 +52,12 @@ void customize(std::vector<ConfigParamSpec>& workflowOptions)
     {"clusters-from-upstream", VariantType::Bool, false, {"clusters will be provided from upstream, skip clusterizer"}},
     {"disable-root-output", VariantType::Bool, false, {"do not write output root files"}},
     {"disable-mc", VariantType::Bool, false, {"disable MC propagation even if available"}},
-    {"tracking-from-hits-config", VariantType::String, "", {"JSON file with tracking from hits configuration"}},
-    {"disable-tracking", VariantType::Bool, false, {"disable tracking step"}},
-    {"configKeyValues", VariantType::String, "", {"Semicolon separated key=value strings"}},
-    {"use-gpu-workflow", VariantType::Bool, false, {"use GPU workflow (default: false)"}},
-    {"gpu-device", VariantType::Int, 1, {"use gpu device: CPU=1,CUDA=2,HIP=3 (default: CPU)"}}};
+    // {"tracking-from-hits-config", VariantType::String, "", {"JSON file with tracking from hits configuration"}},
+    // {"disable-tracking", VariantType::Bool, false, {"disable tracking step"}},
+    {"configKeyValues", VariantType::String, "", {"Semicolon separated key=value strings"}} //,
+    // {"use-gpu-workflow", VariantType::Bool, false, {"use GPU workflow (default: false)"}},
+    // {"gpu-device", VariantType::Int, 1, {"use gpu device: CPU=1,CUDA=2,HIP=3 (default: CPU)"}}
+    };
   std::swap(workflowOptions, options);
 }
 
@@ -67,9 +68,9 @@ o2::framework::WorkflowSpec defineDataProcessing(o2::framework::ConfigContext co
 {
   // Update the (declared) parameters if changed from the command line
   auto useMC = !configcontext.options().get<bool>("disable-mc");
-  auto hitRecoConfig = configcontext.options().get<std::string>("tracking-from-hits-config");
-  auto useGpuWF = configcontext.options().get<bool>("use-gpu-workflow");
-  auto gpuDevice = static_cast<o2::gpu::gpudatatypes::DeviceType>(configcontext.options().get<int>("gpu-device"));
+  // auto hitRecoConfig = configcontext.options().get<std::string>("tracking-from-hits-config");
+  // auto useGpuWF = configcontext.options().get<bool>("use-gpu-workflow");
+  // auto gpuDevice = static_cast<o2::gpu::gpudatatypes::DeviceType>(configcontext.options().get<int>("gpu-device"));
   auto extDigits = configcontext.options().get<bool>("digits-from-upstream");
   auto extClusters = configcontext.options().get<bool>("clusters-from-upstream");
   auto disableRootOutput = configcontext.options().get<bool>("disable-root-output");
@@ -78,5 +79,5 @@ o2::framework::WorkflowSpec defineDataProcessing(o2::framework::ConfigContext co
   // write the configuration used for the reco workflow
   o2::conf::ConfigurableParam::writeINI("o2itsrecoflow_configuration.ini");
 
-  return o2::iotof::reco_workflow::getWorkflow(useMC, hitRecoConfig, extDigits, extClusters, disableRootOutput, useGpuWF, gpuDevice);
+  return o2::iotof::reco_workflow::getWorkflow(useMC, /*hitRecoConfig,*/ extDigits, extClusters, disableRootOutput/*, useGpuWF, gpuDevice*/);
 }