MergerBuilder.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 ALICEO2_MERGERBUILDER_H
#define ALICEO2_MERGERBUILDER_H
 
 
#include "Mergers/MergerConfig.h"
 
#include "Framework/DataProcessorSpec.h"
 
#include <string>
 
namespace o2
{
namespace framework
{
class CompletionPolicy;
}
 
namespace mergers
{
 
class MergerBuilder
{
 public:
  MergerBuilder();
  ~MergerBuilder() = default;
 
  void setName(std::string);
  void setInputSpecs(const framework::Inputs&);
  void setOutputSpec(const framework::OutputSpec& outputSpec);
  void setOutputSpecMovingWindow(const framework::OutputSpec& outputSpec);
  void setTopologyPosition(size_t layer, size_t id);
  void setTimePipeline(size_t timepipeline);
  void setConfig(MergerConfig);
 
  framework::DataProcessorSpec buildSpec();
 
  static void customizeInfrastructure(std::vector<framework::CompletionPolicy>&);
 
  static inline framework::DataProcessorLabel mergerLabel() { return {"merger"}; }
  static inline std::string mergerIntegralOutputBinding() { return "out"; };
  static inline std::string mergerMovingWindowOutputBinding() { return "mw_out"; };
  static inline std::string mergerIdString() { return "MERGER"; };
  static inline header::DataOrigin mergerDataOrigin() { return {"MRGR"}; };
  static inline header::DataDescription mergerDataDescription(std::string name)
  {
    header::DataDescription description;
    description.runtimeInit(name.substr(0, 16).c_str());
    return description;
  };
  static inline header::DataHeader::SubSpecificationType mergerSubSpec(size_t layer, size_t id)
  {
    return (layer << 16) + id;
  };
 
 private:
  std::string mName;
  size_t mId{0};
  size_t mLayer{1};
  size_t mTimePipeline{1};
  framework::Inputs mInputSpecs;
  framework::OutputSpec mOutputSpecIntegral;
  framework::OutputSpec mOutputSpecMovingWindow;
  MergerConfig mConfig;
};
 
} // namespace mergers
} // namespace o2
 
#endif //ALICEO2_MERGERBUILDER_H