RunController.h

Go to the documentation of this file.

#ifndef _fwk_RunManager_h_
#define _fwk_RunManager_h_

#include <fwk/VModule.h>
#include <fwk/RunData.h>
#include <utl/Stopwatch.h>
#include <utl/RealTimeStopwatch.h>
#include <utl/Singleton.h>
#include <string>
#include <set>
#include <map>


namespace utl {
  class Reader;
  class Branch;
}

namespace evt {
  class Event;
}


namespace fwk {

  class RunController : public utl::Singleton<RunController> {

  public:
    enum BreakStatus {
      eNoBreak,
      eBreak,
      eContinue
    };

    int GetNumberOfRegisteredModules() const;

    // Should this be removed?  Note that it will create modules that don't
    // already exist.
    std::string GetRegisteredModuleNames() const;

    const std::set<std::string>& GetUsedModuleNames() const
    { return fUsedModuleNames; }

    VModule& GetModule(const std::string& moduleName) const;
    bool HasModule(const std::string& moduleName) const;

    evt::Event& GetCurrentEvent() const { return *fCurEvent; }

    const std::string& GetCurrentModule() const { return fCurrentModule; }

    RunData& GetRunData() const { return fRunData; }

    virtual void Init();
    virtual void Run();
    virtual void Finish();

  protected:
    RunController();
    virtual ~RunController();

    void InitBranch(utl::Branch& currentB);
    void RunBranch(utl::Branch& currentB);
    void FinishBranch(utl::Branch& currentB);

  private:
    static std::string GetBreakStatusByName(const BreakStatus status);
    void DoRunSequence(utl::Branch& currentB);
    BreakStatus DoNextInSequence(utl::Branch& currentB);
    void GetNextModuleName(utl::Branch& currentB);

    std::set<std::string> fUniqueModuleNames;

    mutable std::set<std::string> fUsedModuleNames;

    evt::Event* fCurEvent = nullptr;

    utl::Stopwatch fStopwatch;
    utl::RealTimeStopwatch fRealTimeStopwatch;
    std::string fCurrentModule;
    mutable RunData fRunData;

    friend class utl::Singleton<RunController>;

  };


}


#endif