ExecutionFlowManager.h

Go to the documentation of this file.

#ifndef EXECUTIONFLOWMANAGER_H_
#define EXECUTIONFLOWMANAGER_H_

#include "ExecutionFlowGraph.h"
#include "EFGraphVisitors.h"

namespace concurrency {

  struct IExecutionFlowManager {
    virtual ~IExecutionFlowManager() {}
  };

  class ExecutionFlowManager  : public CommonMessaging<IExecutionFlowManager> {
  public:
    ExecutionFlowManager() : m_name("ExecutionFlowManager"), m_EFGraph(0) {};
    ~ExecutionFlowManager() override = default;
    StatusCode initialize(ExecutionFlowGraph* CFGraph,
                            const std::unordered_map<std::string,unsigned int>& algname_index_map);
    StatusCode initialize(ExecutionFlowGraph* CFGraph,
                          const std::unordered_map<std::string,unsigned int>& algname_index_map,
                          std::vector<EventSlot>& eventSlots,
                          const std::string& mode);
    void simulateExecutionFlow(IGraphVisitor& visitor) const;
    inline ExecutionFlowGraph* getExecutionFlowGraph() const {return m_EFGraph;}
    bool needsAlgorithmToRun(const unsigned int iAlgo) const;
    void updateEventState(AlgsExecutionStates & algo_states,
                          std::vector<int>& node_decisions) const;
    void updateDecision(const std::string& algo_name,
                        const int& slotNum,
                        AlgsExecutionStates& states,
                        std::vector<int>& node_decisions) const;
    void updateEventState(AlgsExecutionStates& algo_states) const;
    void promoteToControlReadyState(AlgsExecutionStates& algo_states,
                                    std::vector<int>& node_decisions,
                                    const int& slotNum=-1) const;
    bool algoDataDependenciesSatisfied(const std::string& algo_name, const int& slotNum) const;
    bool rootDecisionResolved(const std::vector<int>& node_decisions) const;
    void printEventState(std::stringstream& ss,
                         AlgsExecutionStates& states,
                         const std::vector<int>& node_decisions,
                         const unsigned int& recursionLevel) const {m_EFGraph->printState(ss,states,node_decisions,recursionLevel);}
    void touchReadyAlgorithms(IGraphVisitor& visitor) const;
    const std::string& name() const override {return m_name;}
    SmartIF<ISvcLocator>& serviceLocator() const override {return m_EFGraph->serviceLocator();}
  private:
    std::string m_name;
    ExecutionFlowGraph* m_EFGraph;
  };

} // namespace concurrency

#endif /* EXECUTIONFLOWMANAGER_H_ */