main.cpp

Go to the documentation of this file.

#include "deployment/DeploymentComponent.hpp"
#include "taskbrowser/TaskBrowser.hpp"
#include <rtt/InputPort.hpp>
#include <rtt/os/main.h>
#include <rtt/RTT.hpp>
#include <vector>

using namespace Orocos;

class MyTask
    : public RTT::TaskContext
{
public:
    Property<std::vector<double> > limits;
    InputPort<double> p1;
    OutputPort<double> p2;
    OutputPort<double> p3;
    Attribute<double> a;

    MyTask(std::string n)
        : RTT::TaskContext(n),
          limits("limits","desc", std::vector<double>(2) ),
          p1("p1"),
          p2("p2"),
          p3("p3"),
          a("a")
    {
        this->properties()->addProperty( limits);
        this->ports()->addPort( p1 );
        this->ports()->addPort( p2 );
        this->ports()->addPort( p3 );
        this->addAttribute( a );
        limits.set()[0] = 10;
        limits.set()[1] = 20;
    }
};

class HelloProvider
    : public RTT::TaskContext
{
public:
    bool hello() {
        RTT::Logger::In("connectOperations Test");
        log(Info) << "Hello World!" << endlog();
        return true;
    }

    HelloProvider()
    : RTT::TaskContext("HelloProvider")
    {
        this->provides("hello_service")->addOperation("hello", &HelloProvider::hello, this);
    }
};

class HelloRequester
    : public RTT::TaskContext
{
public:
    RTT::OperationCaller<bool()> helloworld;
    HelloRequester()
    : RTT::TaskContext("HelloRequester"),
      helloworld("helloworld")
    {
        this->requires()->addOperationCaller(helloworld);
    }
    void virtual updateHook() {
        helloworld();
    }
};

int ORO_main(int, char**)
{
    RTT::Logger::Instance()->setLogLevel(RTT::Logger::Info);

    MyTask t1("ComponentA");
    MyTask t2("ComponentB");
    MyTask t3("ComponentC");

    HelloProvider p;
    HelloRequester r;

    {
        DeploymentComponent dc;
        dc.addPeer( &t1 );
        dc.addPeer( &t2 );
        dc.addPeer( &t3 );
        dc.addPeer( &p );
        dc.addPeer( &r );
        dc.kickStart("deployment.cpf");
        TaskBrowser tb(&dc);

        tb.loop();
    }
    return 0;
}