Spawner.hpp

Go to the documentation of this file.

#ifndef SPAWNER_H
#define SPAWNER_H

#include <unistd.h>
#include <string>
#include <vector>
#include <base/Time.hpp>
#include "NameService.hpp"
#include "Deployment.hpp"
#include <boost/noncopyable.hpp>

namespace orocos_cpp
{

class Spawner : public boost::noncopyable
{
    std::string logDir;
    
    //list of tasks that were spawned, but are not yet reachable.
    std::vector<std::string> notReadyList;
    
    NameService *nameService;
    
    
    Spawner();    

public:
    class ProcessHandle
    {
        mutable bool isRunning;
        pid_t pid;
        void redirectOutput(const std::string &filename);
        std::string processName;
        
        Deployment *deployment;
    public:
        ProcessHandle(Deployment *deployment, bool redirectOutput, const std::string &logDir);
        
        const Deployment &getDeployment() const;
        bool alive() const;
        void sendSigInt() const;
        void sendSigTerm() const;
        void sendSigKill() const;
    };

public:
    
    static Spawner &getInstace();
    
    ProcessHandle &spawnTask(const std::string &cmp1, const std::string &as = std::string(), bool redirectOutput = true);
    
    ProcessHandle &spawnDeployment(const std::string &dplName, bool redirectOutput = true);

    ProcessHandle &spawnDeployment(Deployment *deployment, bool redirectOutput = true);
    
    bool checkAllProcesses();

    bool allReady();
    
    void waitUntilAllReady(const base::Time &timeout);
    
    void killAll();
    
    void sendSigTerm();
    
    std::vector<const Deployment *> getRunningDeployments();
    
    
    bool isRunning(const Deployment *instance);

    void setLogDirectory(const std::string& log_folder);
    
private:
    
    std::vector<ProcessHandle *> handles;
};
}//end of namespace.

#endif // SPAWNER_H