AnalysisSupportHelpers.h

Go to the documentation of this file.

// 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_FRAMEWORK_ANALYSISSUPPORTHELPERS_H_
#define O2_FRAMEWORK_ANALYSISSUPPORTHELPERS_H_
 
#include "Framework/OutputSpec.h"
#include "Framework/InputSpec.h"
#include "Framework/DataProcessorSpec.h"
#include "Framework/DanglingEdgesContext.h"
#include "Headers/DataHeader.h"
#include <array>
 
namespace o2::framework
{
static constexpr std::array<header::DataOrigin, 5> AODOrigins{header::DataOrigin{"AOD"}, header::DataOrigin{"AOD1"}, header::DataOrigin{"AOD2"}, header::DataOrigin{"EMB"}, header::DataOrigin{"AMD"}};
static constexpr std::array<header::DataOrigin, 3> writableAODOrigins{header::DataOrigin{"AOD"}, header::DataOrigin{"AOD1"}, header::DataOrigin{"AOD2"}};
 
class DataOutputDirector;
struct ConfigContext;
 
// Helper class to be moved in the AnalysisSupport plugin at some point
struct AnalysisSupportHelpers {
  static void addMissingOutputsToReader(std::vector<OutputSpec> const& providedOutputs,
                                        std::vector<InputSpec> const& requestedInputs,
                                        DataProcessorSpec& publisher);
  static void addMissingOutputsToSpawner(std::vector<OutputSpec> const& providedSpecials,
                                         std::vector<InputSpec> const& requestedSpecials,
                                         std::vector<InputSpec>& requestedAODs,
                                         DataProcessorSpec& publisher);
  static void addMissingOutputsToBuilder(std::vector<InputSpec> const& requestedSpecials,
                                         std::vector<InputSpec>& requestedAODs,
                                         std::vector<InputSpec>& requestedDYNs,
                                         DataProcessorSpec& publisher);
 
  static DataProcessorSpec getOutputObjHistSink(ConfigContext const&);
  static DataProcessorSpec getGlobalAODSink(ConfigContext const&);
  static std::shared_ptr<DataOutputDirector> getDataOutputDirector(ConfigContext const& ctx);
};
 
}; // namespace o2::framework
 
#endif // O2_FRAMEWORK_ANALYSISSUPPORTHELPERS_H_