An execution engine serialises (executes one after the other) the execution of all commands, programs, state machines and incomming events for a task. More...
#include <rtt/ExecutionEngine.hpp>
Public Member Functions | |
ExecutionEngine (TaskCore *owner=0) | |
Create an execution engine with a CommandProcessor, ProgramProcessor and StateMachineProcessor. | |
bool | activate () |
Run the Execution Engine's processors, but not the updateHook() functions of the TaskCores. | |
bool | start () |
Run the Execution Engine's processors and the updateHook() functions of the TaskCores. | |
bool | stop () |
Stop the processors and all TaskCores. | |
virtual bool | initialize () |
The method that will be called before the first periodical execution of step() ( or non periodical execution of loop() ), when the thread is started. | |
virtual void | step () |
Executes (in that order) programs, state machines, commands, events and the TaskCore's update() function. | |
virtual bool | breakLoop () |
This method is called by the framework to break out of the loop() method. | |
virtual void | finalize () |
The method that will be called after the last periodical execution of step() ( or non periodical execution of loop() ), when the RunnableInterface is stopped. | |
virtual void | setActivity (ActivityInterface *t) |
Set the task this interface is run in. | |
virtual bool | hasWork () |
This method is for 'intelligent' activity implementations that wish to see if it is required to call step() (again). | |
TaskCore * | getParent () |
The TaskCore which created this ExecutionEngine. | |
virtual void | addChild (TaskCore *tc) |
Add a TaskCore to execute. | |
virtual void | removeChild (TaskCore *tc) |
Remove a TaskCore from execution. | |
TaskCore * | getTaskCore () const |
Returns the owner of this execution engine. | |
CommandProcessor * | commands () const |
Return the CommandProcessor of this engine. | |
ProgramProcessor * | programs () const |
Return the ProgramProcessor of this engine. | |
StateMachineProcessor * | states () const |
Return the StateMachineProcessor of this engine. | |
EventProcessor * | events () const |
Return the EventProcessor of this engine. | |
virtual void | setCommandProcessor (CommandProcessor *c) |
Install a new CommandProcessor. | |
virtual void | setProgramProcessor (ProgramProcessor *p) |
Install a new ProgramProcessor. | |
virtual void | setStateMachineProcessor (StateMachineProcessor *s) |
Install a new StateMachineProcessor. | |
virtual void | setEventProcessor (EventProcessor *e) |
Install a new EventProcessor. | |
ActivityInterface * | getActivity () const |
Query for the task this interface is run in. | |
virtual OS::ThreadInterface * | getThread () const |
Get the thread this object is run in. | |
virtual void | loop () |
The method that will be executed once when this class RTT_API is run in a non periodic thread. | |
virtual void | setThread (ThreadInterface *t) |
Set the thread this object will be run in. | |
Protected Types | |
enum | EngineState { Stopped, Activating, Active, Running } |
Protected Member Functions | |
void | setup () |
Install new Processors. | |
bool | startContexts () |
Call all necessary hook functions of parent and children TaskContexts. | |
Protected Attributes | |
TaskCore * | taskc |
The parent or 'owner' of this ExecutionEngine, may be null. | |
EngineState | estate |
The ExecutionEngine keeps a state of its own which is synchronised with the parent and child TaskCore states. | |
RunnableInterface * | cproc |
We store the Processors as RunnableInterface pointers, and dynamic_cast them back to the correct type. | |
RunnableInterface * | pproc |
RunnableInterface * | smproc |
RunnableInterface * | eproc |
std::vector< TaskCore * > | children |
All tasks which execute in this ExecutionEngine. |
An execution engine serialises (executes one after the other) the execution of all commands, programs, state machines and incomming events for a task.
Any function executing in the same execution engine is guaranteed to be thread-safe with respect to other functions executing in the same execution engine.
The ExecutionEngine bundles a CommandProcessor, ProgramProcessor, StateMachineProcessor and EventProcessor.
Definition at line 86 of file ExecutionEngine.hpp.
RTT::ExecutionEngine::ExecutionEngine | ( | TaskCore * | owner = 0 |
) |
Create an execution engine with a CommandProcessor, ProgramProcessor and StateMachineProcessor.
virtual bool RTT::ExecutionEngine::breakLoop | ( | ) | [virtual] |
This method is called by the framework to break out of the loop() method.
Reimplement this method to signal loop() to return and return true on success. When this method is not reimplemented by you, it will always return false, denoting that the loop can not be broken. If breakLoop() returns true, the caller will wait until loop() returns.
Reimplemented from RTT::OS::RunnableInterface.
ActivityInterface * RTT::RunnableInterface::getActivity | ( | ) | const [inline, inherited] |
Query for the task this interface is run in.
Zero denotes that no task is present to run it, and hence no detailed information is available.
Definition at line 106 of file RunnableInterface.hpp.
virtual OS::ThreadInterface* RTT::RunnableInterface::getThread | ( | ) | const [virtual, inherited] |
Get the thread this object is run in.
Reimplemented from RTT::OS::RunnableInterface.
virtual bool RTT::ExecutionEngine::hasWork | ( | ) | [virtual] |
This method is for 'intelligent' activity implementations that wish to see if it is required to call step() (again).
By default, false is returned. You should only return true in case there is a temporary reason to (re-)run step.
Reimplemented from RTT::RunnableInterface.
virtual void RTT::OS::RunnableInterface::loop | ( | ) | [virtual, inherited] |
The method that will be executed once when this class RTT_API is run in a non periodic thread.
The default implementation calls step() once.
Reimplemented in RTT::Timer.
virtual void RTT::ExecutionEngine::setActivity | ( | ActivityInterface * | task | ) | [virtual] |
Set the task this interface is run in.
A Zero means no task is running it.
task | The ActivityInterface running this interface. |
Reimplemented from RTT::RunnableInterface.
virtual void RTT::ExecutionEngine::setCommandProcessor | ( | CommandProcessor * | c | ) | [virtual] |
Install a new CommandProcessor.
c | becomes owned by this object and is returned in commands(). |
virtual void RTT::ExecutionEngine::setEventProcessor | ( | EventProcessor * | e | ) | [virtual] |
Install a new EventProcessor.
e | becomes owned by this object and is returned in events(). |
virtual void RTT::ExecutionEngine::setProgramProcessor | ( | ProgramProcessor * | p | ) | [virtual] |
Install a new ProgramProcessor.
p | becomes owned by this object and is returned in programs(). |
virtual void RTT::ExecutionEngine::setStateMachineProcessor | ( | StateMachineProcessor * | s | ) | [virtual] |
Install a new StateMachineProcessor.
s | becomes owned by this object and is returned in states(). |