ProcessUnitPipeline.h

Go to the documentation of this file.

// Copyright 2002-2013 CEA LIST
// SPDX-FileCopyrightText: 2022 CEA LIST <gael.de-chalendar@cea.fr>
//
// SPDX-License-Identifier: MIT
 
/***************************************************************************
 *   Copyright (C) 2004-2012 by CEA LIST                               *
 *                                                                         *
 ***************************************************************************/
#ifndef LIMA_COMMON_PROCESSUNITFRAMEWORK_PROCESSUNITPIPELINE_H
#define LIMA_COMMON_PROCESSUNITFRAMEWORK_PROCESSUNITPIPELINE_H
 
#include "common/ProcessUnitFramework/AnalysisContent.h"
#include <list>
#include <set>
 
namespace Lima
{
 
 
class InactiveUnitsData : public std::set<std::string>, public AnalysisData
{
public:
    InactiveUnitsData() {}
    virtual ~InactiveUnitsData() {}
};
 
template <typename ProcessUnit>
class ProcessUnitPipeline : public ProcessUnit
{
public:
  ProcessUnitPipeline();
  virtual ~ProcessUnitPipeline();
 
  virtual void init(
    Common::XMLConfigurationFiles::GroupConfigurationStructure& unitConfiguration,
    typename ProcessUnit::Manager* manager) override;
 
  virtual LimaStatusCode process(
    AnalysisContent& analysis) const override;
 
  void setActiveProcessUnit(const std::string& processUnitId);
  void setInactiveProcessUnit(const std::string& processUnitId);
 
  void push_back(
    const std::string& unitId,
    typename ProcessUnit::Manager* manager);
 
  void push_back(std::shared_ptr<ProcessUnit> pu);
 
private:
  void debugPrintInactiveUnits() const;
 
  typedef typename std::list<std::shared_ptr<ProcessUnit>> ProcessUnitSequence;
  typedef typename std::list<std::shared_ptr<ProcessUnit>>::const_iterator ProcessUnitSequenceCItr;
  ProcessUnitSequence m_processUnitSequence;
 
  std::set<std::string> m_inactiveUnitsIds;
};
 
} // Lima
 
#include "ProcessUnitPipeline.tcc"
 
#endif