PulseScenarioExec.h

/* Distributed under the Apache License, Version 2.0.
   See accompanying NOTICE file for details.*/
 
#pragma once
 
#include "engine/CommonDefs.h"
#include "engine/PulseScenario.h"
#include "cdm/scenario/SEScenarioExec.h"
#include <thread>
 
class PULSE_DECL PulseScenarioExec : public SEScenarioExec
{
  
public:
  PulseScenarioExec(Logger* logger) : SEScenarioExec(logger) { Clear(); }
 
  void Clear() override;
  void Copy(const PulseScenarioExec& src);
 
  eModelType GetModelType() const { return m_ModelType; }
  void SetModelType(eModelType mt) { m_ModelType = mt; }
 
  bool SerializeToString(std::string& output, eSerializationFormat m, Logger* logger = nullptr) const;
  bool SerializeToFile(const std::string& filename) const; 
  bool SerializeFromString(const std::string& src, eSerializationFormat m, Logger* logger = nullptr);
  bool SerializeFromFile(const std::string& filename);
 
  bool Execute();
 
protected:
  size_t ComputeNumThreads();
  bool Execute(PulseScenario& sce, SEScenarioExecStatus* status=nullptr);
  bool ConvertLog();
 
  // For threaded scenario excution
  static void ControllerLoop(const std::string copy,
                             std::mutex* m,
                             std::vector<SEScenarioExecStatus>* s,
                             size_t* completed,
                             const std::string fn,
                             Logger* logger);
 
  std::vector<std::thread>           m_Threads;
  std::mutex                         m_Mutex;
  std::vector<SEScenarioExecStatus>  m_Statuses;
  size_t                             m_Completed;
 
  eModelType m_ModelType = eModelType::HumanAdultWholeBody;
};