Trait CuSrcTask

pub trait CuSrcTask<'cl>: Freezable {
    type Output: CuMsgPack<'cl>;

    // Required methods
    fn new(_config: Option<&ComponentConfig>) -> Result<Self, CuError>
       where Self: Sized;
    fn process(
        &mut self,
        clock: &RobotClock,
        new_msg: Self::Output,
    ) -> Result<(), CuError>;

    // Provided methods
    fn start(&mut self, _clock: &RobotClock) -> Result<(), CuError> { ... }
    fn preprocess(&mut self, _clock: &RobotClock) -> Result<(), CuError> { ... }
    fn postprocess(&mut self, _clock: &RobotClock) -> Result<(), CuError> { ... }
    fn stop(&mut self, _clock: &RobotClock) -> Result<(), CuError> { ... }
}

A Src Task is a task that only produces messages. For example drivers for sensors are Src Tasks. They are in push mode from the runtime. To set the frequency of the pulls and align them to any hw, see the runtime configuration. Note: A source has the priviledge to have a clock passed to it vs a frozen clock.

Required Associated Types

type Output: CuMsgPack<'cl>

Required Methods

fn new(_config: Option<&ComponentConfig>) -> Result<Self, CuError>

where Self: Sized,

Here you need to initialize everything your task will need for the duration of its lifetime. The config allows you to access the configuration of the task.

fn process( &mut self, clock: &RobotClock, new_msg: Self::Output, ) -> Result<(), CuError>

Process is the most critical execution of the task. The goal will be to produce the output message as soon as possible. Use preprocess to prepare the task to make this method as short as possible.

Provided Methods

fn start(&mut self, _clock: &RobotClock) -> Result<(), CuError>

Start is called between the creation of the task and the first call to pre/process.

fn preprocess(&mut self, _clock: &RobotClock) -> Result<(), CuError>

This is a method called by the runtime before “process”. This is a kind of best effort, as soon as possible call to give a chance for the task to do some work before to prepare to make “process” as short as possible.

fn postprocess(&mut self, _clock: &RobotClock) -> Result<(), CuError>

This is a method called by the runtime after “process”. It is best effort a chance for the task to update some state after process is out of the way. It can be use for example to maintain statistics etc. that are not time-critical for the robot.

fn stop(&mut self, _clock: &RobotClock) -> Result<(), CuError>

Called to stop the task. It signals that the *process method won’t be called until start is called again.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<'cl, T> CuSrcTask<'cl> for CuSimSrcTask<T>

where T: CuMsgPayload + 'cl,

type Output = &'cl mut CuMsg<T>