ConfigureImr.h

Go to the documentation of this file.

#ifndef CARMA_UTIL_CONFIGUREIMR_H
#define CARMA_UTIL_CONFIGUREIMR_H

#include "carma/util/ImrClient.h"
#include "carma/util/ImrConfigHandlers.h"

namespace carma {
namespace util {

class ConfigureImr {
public:
    
    ConfigureImr(carma::corba::Client & client,
                 std::string imrHost,
                 carma::util::domainType domain);

    virtual ~ConfigureImr();

    void addOads();

    void addServers( const std::string &oad, 
                     const std::string prioritySpec = "0-9",
                     unsigned long SleepyTimeMs = 0 );

    void startServers( const std::string &oad, 
                       const std::string prioritySpec = "0-9",
                       unsigned int waitForRunningMs = 0,
                       unsigned long sleepyTimeMs = 0,
                       bool waitForEachPriorityStage = false,
                       unsigned long waitAfterEachStageMs = 0,
                       bool verbose = true );

    void stopServers( const std::string &oad, 
                      const std::string prioritySpec = "9-0",
                      unsigned int waitForStoppedMs = 0,
                      bool waitForEachPriorityStage = false );

    void resetServers(const std::string &oad);
    
    void clean(const std::string &oad);

protected:
    
    // Nothing here

private:
    
    void waitForServers( const std::string & oad, 
                         ImrClient::ServerStatus state, // State to wait for.
                         const std::pair<int, int> & inPriorityRange,
                         long waitMaxMs );

    std::vector<OADConfig>::iterator findOAD(const std::string &oad);

    // Reference to IMR Client
    carma::util::ImrClient imr_;
    std::string imrHost_;
    domainType domain_;

};  // End class ConfigureImr
}}  // End namespace carma::util;
#endif