taktora-executor 0.1.0

Execution framework for iceoryx2-based Rust applications.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

#![allow(missing_docs)]

use core::time::Duration;
use std::sync::atomic::{AtomicU32, Ordering};
use std::sync::{Arc, Mutex};
use taktora_executor::{ControlFlow, Executor, Observer, UserEvent};

#[derive(Default)]
struct CountingObserver {
    up: AtomicU32,
    down: AtomicU32,
    err: AtomicU32,
    start: AtomicU32,
    stop: AtomicU32,
    user_events: Mutex<Vec<UserEvent>>,
}

impl Observer for CountingObserver {
    fn on_executor_up(&self) {
        self.up.fetch_add(1, Ordering::SeqCst);
    }
    fn on_executor_down(&self) {
        self.down.fetch_add(1, Ordering::SeqCst);
    }
    fn on_executor_error(&self, _: &taktora_executor::ExecutorError) {
        self.err.fetch_add(1, Ordering::SeqCst);
    }
    fn on_app_start(&self, _: taktora_executor::TaskId, _: u32, _: Option<u32>) {
        self.start.fetch_add(1, Ordering::SeqCst);
    }
    fn on_app_stop(&self, _: taktora_executor::TaskId) {
        self.stop.fetch_add(1, Ordering::SeqCst);
    }
    fn on_send_event(&self, _: taktora_executor::TaskId, ev: UserEvent) {
        self.user_events.lock().unwrap().push(ev);
    }
}

struct AppItem;

impl taktora_executor::ExecutableItem for AppItem {
    fn declare_triggers(
        &mut self,
        d: &mut taktora_executor::TriggerDeclarer<'_>,
    ) -> Result<(), taktora_executor::ExecutorError> {
        d.interval(Duration::from_millis(10));
        Ok(())
    }
    fn execute(
        &mut self,
        ctx: &mut taktora_executor::Context<'_>,
    ) -> taktora_executor::ExecuteResult {
        ctx.send_event(UserEvent::new(1, 42));
        Ok(ControlFlow::Continue)
    }
    fn app_id(&self) -> Option<u32> {
        Some(7)
    }
}

#[test]
fn observer_sees_lifecycle_and_user_events() {
    let obs = Arc::new(CountingObserver::default());
    let mut exec = Executor::builder()
        .worker_threads(0)
        .observer(Arc::clone(&obs) as Arc<dyn Observer>)
        .build()
        .unwrap();

    exec.add(AppItem).unwrap();
    exec.run_n(2).unwrap();

    assert_eq!(obs.up.load(Ordering::SeqCst), 1);
    assert_eq!(obs.down.load(Ordering::SeqCst), 1);
    assert!(obs.start.load(Ordering::SeqCst) >= 1);
    assert!(obs.stop.load(Ordering::SeqCst) >= 1);
    assert!(
        obs.user_events
            .lock()
            .unwrap()
            .iter()
            .any(|e| e.int_data == 42)
    );
}