add BC converter (AliceO2Group#3409)

* bcConverter task (versioning of BC table) * Add bcConverter to CMakeLists * Update Common/TableProducer/bcConverter.cxx Co-authored-by: Jan Fiete <[email protected]> * Update bcConverter.cxx --------- Co-authored-by: Jan Fiete <[email protected]>
BongHwi · Aug 30, 2023 · 9742422 · 9742422
1 parent 4693759
commit 9742422
Show file tree

Hide file tree

Showing 2 changed files with 41 additions and 0 deletions.
diff --git a/Common/TableProducer/CMakeLists.txt b/Common/TableProducer/CMakeLists.txt
@@ -76,6 +76,11 @@ o2physics_add_dpl_workflow(collision-converter
                     PUBLIC_LINK_LIBRARIES
                 COMPONENT_NAME Analysis)
 
+o2physics_add_dpl_workflow(bc-converter
+                    SOURCES bcConverter.cxx
+                    PUBLIC_LINK_LIBRARIES O2::Framework
+                COMPONENT_NAME Analysis)
+
 o2physics_add_dpl_workflow(calo-clusters
                     SOURCES caloClusterProducer.cxx
                     PUBLIC_LINK_LIBRARIES O2::DataFormatsPHOS O2::PHOSBase O2::PHOSReconstruction O2Physics::DataModel

diff --git a/Common/TableProducer/bcConverter.cxx b/Common/TableProducer/bcConverter.cxx
@@ -0,0 +1,36 @@
+// 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 "Framework/runDataProcessing.h"
+#include "Framework/AnalysisTask.h"
+#include "Framework/AnalysisDataModel.h"
+
+using namespace o2;
+using namespace o2::framework;
+
+// Converts bc_000 into bc_001
+struct bcConverter {
+  Produces<aod::BCs_001> bc_001;
+
+  void process(aod::BCs_000 const& bcTable)
+  {
+    for (auto& bc : bcTable) {
+      constexpr uint64_t lEmptyTriggerInputs = 0;
+      bc_001(bc.runNumber(), bc.globalBC(), bc.triggerMask(), lEmptyTriggerInputs);
+    }
+  }
+};
+
+WorkflowSpec defineDataProcessing(ConfigContext const& cfgc)
+{
+  return WorkflowSpec{
+    adaptAnalysisTask<bcConverter>(cfgc),
+  };
+}