SubprocessManager.h

Go to the documentation of this file.

#pragma once
 
// Service header
#include "DataBaseInfo.h"
 
// OpenTwin header
#include "OTCore/JSON.h"
#include "OTCore/OTClassHelper.h"
 
// std header
#include <mutex>
 
class Application;
class SubprocessHandler;
class CommunicationHandler;
 
namespace std { class thread; }
 
class SubprocessManager {
    OT_DECL_NOCOPY(SubprocessManager)
    OT_DECL_NODEFAULT(SubprocessManager)
public:
    SubprocessManager(Application* _app);
    ~SubprocessManager();
    
    void setModelUrl(const std::string& _url);
    void setFrontendUrl(const std::string& _url);
    void setDataBaseInfo(const DataBaseInfo& _info);
 
    bool sendRequest(const ot::JsonDocument& _document, std::string& _response);
 
    bool sendSingleRequest(const ot::JsonDocument& _document, std::string& _response);
 
    bool ensureSubprocessRunning(void);
 
    void stopConnectionHandlingAfterCrash(void);
 
private:
    void shutdownSubprocess(void);
 
    bool ensureWorkerRunning(void);
 
    bool isWorkerAlive(void);
 
    void worker(std::string _projectName);
 
    std::thread* m_workerThread;
    std::mutex m_mutex;
 
    Application* m_app;
 
    SubprocessHandler* m_subprocessHandler;
    CommunicationHandler* m_communicationHandler;
};