platformmanagerApi.h

Go to the documentation of this file.

#pragma once

#include <boost/function.hpp>
#include <boost/system/error_code.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/thread.hpp>
#include <boost/asio.hpp>
#include <vector>

#include "platformManagerTypes.h"


class PlatformManagerClient;

namespace dpyPlatformmanager {

enum EvaluationResult{
    OK = 0, 
    ERROR = 1 
};


struct Options
{
    std::string processExec; 
    std::string processPath; 
    std::vector<std::string> args; 
    bool relaunch; 
    int delayOnLaunch; 
    bool critical; 
};

enum ProcessListEvent{
    ADDED = 0, 
    REMOVED = 1, 
};


struct Info
{
    std::string name; 
    Options option; 
    Status status; 
};


typedef boost::function<void(const bool &available)> service_availability_handler;

typedef boost::function<void(boost::system::error_code error_code, std::vector<dpyPlatformmanager::Info> info)> process_status_handler_function;


typedef boost::function<void(boost::system::error_code error_code, std::vector<dpyPlatformmanager::ExtendedProcessInfo> info)> extended_process_status_handler_function;

typedef boost::function<void(boost::system::error_code error_code, const dpyPlatformmanager::EvaluationStatus& status)> evaluation_status_handler_function;

typedef boost::function<void(boost::system::error_code error_code)> result_handler_function;


typedef boost::function<void(boost::system::error_code error_code, std::string name, ProcessListEvent event, Options options )> process_list_event_handler_function;

typedef boost::function<void(boost::system::error_code error_code, std::string name, ProcessListEvent event, dpyPlatformmanager::ExtendedProcessOptions options )> process_list_event_extended_handler_function;

typedef boost::function<void(boost::system::error_code error_code, std::string name, ProcessEvent event)> process_event_handler_function;

}

class PlatformManagerObserver
{
    public:
        virtual void availabilityStatusChange(__attribute__((unused)) bool available) {};
        virtual void evaluationStatusChange(__attribute__((unused)) const dpyPlatformmanager::EvaluationStatus& status) {};
        virtual void processStatusChange(__attribute__((unused)) std::vector<dpyPlatformmanager::Info> info) {};

        virtual void processStatusChange(__attribute__((unused)) std::vector<dpyPlatformmanager::ExtendedProcessInfo> info) {};

        virtual void processListEvent(__attribute__((unused)) std::string name, __attribute__((unused)) dpyPlatformmanager::ProcessListEvent event, __attribute__((unused)) dpyPlatformmanager::Options options) {};

       virtual void processListEvent(__attribute__((unused)) std::string name, __attribute__((unused)) dpyPlatformmanager::ProcessListEvent event, __attribute__((unused)) dpyPlatformmanager::ExtendedProcessOptions options) {};

        virtual void processEvent(__attribute__((unused)) std::string name, __attribute__((unused)) dpyPlatformmanager::ProcessEvent event) {};
        virtual ~PlatformManagerObserver()
        {
        }
};

class PlatformManager
{

private:
    boost::shared_ptr<PlatformManagerClient> mClient;
    std::vector<PlatformManagerObserver*> observersList;
public:


    explicit PlatformManager(std::string ip = "127.0.0.1");
    virtual ~PlatformManager();

    bool isAlive();
    void monitorServiceAvailability_S(dpyPlatformmanager::service_availability_handler handler);
    void monitorServiceAvailability_U();
    [[deprecated("asyncGetProcessStatus is deprecated, use the version of asyncGetProcessStatus using extended_process_status_handler_function handler")]]
    void asyncGetProcessStatus(dpyPlatformmanager::process_status_handler_function handler, std::string name = "");
    void asyncGetExtendedProcessStatus(dpyPlatformmanager::extended_process_status_handler_function handler, std::string name = "");
    void asyncStartProcess(dpyPlatformmanager::result_handler_function handler, std::string name);
    void asyncStopProcess(dpyPlatformmanager::result_handler_function handler, std::string name);
    [[deprecated("asyncAddProcess is deprecated, use the version of asyncAddProcess using dpyPlatformmanager::ExtendedProcessOptions struct")]]
    void asyncAddProcess(dpyPlatformmanager::result_handler_function handler, std::string name, dpyPlatformmanager::Options options);
    void asyncAddProcess(dpyPlatformmanager::result_handler_function handler, std::string name, dpyPlatformmanager::ExtendedProcessOptions options);

    void asyncDelProcess(dpyPlatformmanager::result_handler_function handler, std::string name);
    void asyncKickWatchdog(dpyPlatformmanager::result_handler_function handler, std::string name);
    void asyncKickWatchdog(dpyPlatformmanager::result_handler_function handler, std::string name, int deadline);

#ifdef TESTING
    virtual void asyncWait(dpyPlatformmanager::result_handler_function handler, std::string processName);
    virtual void asyncFinished(dpyPlatformmanager::result_handler_function handler, std::string processName, dpyPlatformmanager::EvaluationResult);
    //Observer
    virtual boost::system::error_code subscribe(PlatformManagerObserver *observer);
    virtual boost::system::error_code unsubscribe(PlatformManagerObserver *observer);
#else
    void asyncWait(dpyPlatformmanager::result_handler_function handler, std::string processName);
    void asyncFinished(dpyPlatformmanager::result_handler_function handler, std::string processName, dpyPlatformmanager::EvaluationResult);
    //Observer
    boost::system::error_code subscribe(PlatformManagerObserver *observer);
    boost::system::error_code unsubscribe(PlatformManagerObserver *observer);
#endif

};