Example: Timed Execution

This example shows the timed execution of one CCA node. Timed execution means, processing of the node is determined by the Timed Processing strategy.

1. At first a new node is defined, which inherits from the CCA base node class (lines 15-25).
2. In the main function of this example we create a node and configure it to be timed (line 30-31, see Timed Processing).
3. To run the program we need to send a timing signal to the node. We create a Beat and assign the node to it (lines 34-35).

#include <iostream>

#include "cca/Component.h"
#include "cca/processing/Timed.h"
#include "cca/timing/PeriodicBeat.h"

#include "rsc/logging/LoggerFactory.h"

using namespace std;
using namespace boost;
using namespace cca;
using namespace rsc;
using namespace rsc::logging;

class FooComp: public Component {
public:
    FooComp(const std::string &cname) :
        Component(cname), fooport() {

        fooport = InputPort<std::string>::create();
        registerPort("foo", fooport, Port::OPTIONAL);

    }
    ~FooComp() {
    }
    void onProcess() {
        std::cout << "onProcess()" << std::endl;
        if (fooport->empty()) {
            std::cout << "empty" << std::endl;
        }
    }
protected:
    InputPort<std::string>::Ptr fooport;
};

int main() {
	LoggerFactory::getInstance().reconfigure(Logger::LEVEL_DEBUG);

    NodePtr comp = NodePtr(new FooComp("Timed Node"));
    comp->setProcessingStrategy(Timed::samplerate(2));
    std::cout << std::endl << comp->print() << std::endl;

    BeatPtr beat = PeriodicBeat::create(10);
    beat->registerReceiver(comp);

    beat->run();

    return EXIT_SUCCESS;
}