PostProcessingDevice.h

Go to the documentation of this file.

// Copyright CERN and copyright holders of ALICE O2. This software is
// distributed under the terms of the GNU General Public License v3 (GPL
// Version 3), copied verbatim in the file "COPYING".
//
// See http://alice-o2.web.cern.ch/license for full licensing information.
//
// 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 QUALITYCONTROL_POSTPROCESSINGDEVICE_H
#define QUALITYCONTROL_POSTPROCESSINGDEVICE_H

#include <Framework/Task.h>
#include <Framework/DataProcessorSpec.h>
#include <Headers/DataHeader.h>

#include <string>
#include <memory>

namespace o2::quality_control::postprocessing
{

class PostProcessingRunner;

class PostProcessingDevice : public framework::Task
{
 public:
  PostProcessingDevice(const std::string& taskName, const std::string& configurationSource);
  ~PostProcessingDevice() override = default;

  void init(framework::InitContext&) override;
  void run(framework::ProcessingContext&) override;

  const std::string& getDeviceName();
  framework::Inputs getInputsSpecs();
  framework::Outputs getOutputSpecs();
  framework::Options getOptions();

  static std::string createPostProcessingIdString();
  static header::DataOrigin createPostProcessingDataOrigin();
  static header::DataDescription createPostProcessingDataDescription(const std::string& taskName);

 private:
  void start();
  void stop();
  void reset();

 private:
  std::shared_ptr<PostProcessingRunner> mRunner;
  std::string mDeviceName;
  std::string mConfigSource;
};

} // namespace o2::quality_control::postprocessing

#endif //QUALITYCONTROL_POSTPROCESSINGDEVICE_H