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
use super::*;
use std::sync::atomic::{AtomicUsize, Ordering};
#[derive(Clone, Debug)]
pub enum ControlEvent {
Start,
Stop,
Kill,
}
pub struct ControlPort;
impl Port for ControlPort {
type Indication = ();
type Request = ControlEvent;
}
const PASSIVE: usize = 0;
const ACTIVE: usize = 1;
const DESTROYED: usize = 2;
pub(crate) fn initial_state() -> AtomicUsize {
AtomicUsize::new(PASSIVE)
}
pub(crate) fn set_active(state: &AtomicUsize) {
state.store(ACTIVE, Ordering::SeqCst);
}
pub(crate) fn set_passive(state: &AtomicUsize) {
state.store(PASSIVE, Ordering::SeqCst);
}
pub(crate) fn set_destroyed(state: &AtomicUsize) {
state.store(DESTROYED, Ordering::SeqCst);
}
pub(crate) fn is_active(state: &AtomicUsize) -> bool {
state.load(Ordering::SeqCst) == ACTIVE
}
pub(crate) fn is_destroyed(state: &AtomicUsize) -> bool {
state.load(Ordering::SeqCst) == DESTROYED
}