gmt_dos-actors 10.1.3

Giant Magellan Telescope Dynamic Optical Simulation Actor Model
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
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122

use crate::{
    actor::{Actor, PlainActor},
    framework::{
        model::{Check, CheckError, Task, TaskError},
        network::{ActorOutput, AddActorInput},
    },
    prelude::{AddActorOutput, GetName, Model, Unknown},
};

use super::{
    interfaces::{System, SystemInput, SystemOutput},
    Sys,
};

#[async_trait::async_trait]
impl<T> Task for Sys<T>
where
    T: System,
    for<'a> &'a T: IntoIterator<Item = Box<&'a dyn Check>>,
    Box<T>: IntoIterator<Item = Box<dyn Task>>,
{
    async fn async_run(&mut self) -> std::result::Result<(), TaskError> {
        todo!()
    }

    async fn task(mut self: Box<Self>) -> std::result::Result<(), TaskError> {
        let name = self.name();
        let q = *self;
        let w = q.sys;
        let b = Box::new(w);
        Model::<Unknown>::from_iter(b)
            .name(name)
            .skip_check()
            .run()
            .await?;
        Ok(())
    }

    fn as_plain(&self) -> PlainActor {
        self.plain()
    }
}

impl<T> Check for Sys<T>
where
    T: System,
    for<'a> &'a T: IntoIterator<Item = Box<&'a dyn Check>>,
{
    fn check_inputs(&self) -> std::result::Result<(), CheckError> {
        self.into_iter()
            .map(|a| a.check_inputs())
            .collect::<Result<Vec<_>, _>>()
            .map(|_| ())
    }

    fn check_outputs(&self) -> std::result::Result<(), CheckError> {
        self.into_iter()
            .map(|a| a.check_outputs())
            .collect::<Result<Vec<_>, _>>()
            .map(|_| ())
    }

    fn n_inputs(&self) -> usize {
        self.into_iter()
            .map(|a: Box<&dyn Check>| a.n_inputs())
            .sum()
    }
    fn n_outputs(&self) -> usize {
        self.into_iter()
            .map(|a: Box<&dyn Check>| a.n_outputs())
            .sum()
    }

    fn inputs_hashes(&self) -> Vec<u64> {
        self.into_iter()
            .flat_map(|a: Box<&dyn Check>| a.inputs_hashes())
            .collect()
    }

    fn outputs_hashes(&self) -> Vec<u64> {
        self.into_iter()
            .flat_map(|a: Box<&dyn Check>| a.outputs_hashes())
            .collect()
    }

    fn _as_plain(&self) -> PlainActor {
        self.plain()
    }

    fn is_system(&self) -> bool {
        true
    }
}

impl<T: System> GetName for T {
    fn get_name(&self) -> String {
        self.name()
    }
}

impl<'a, T, CO, const NI: usize, const NO: usize> AddActorOutput<'a, CO, NI, NO> for Sys<T>
where
    T: System,
    Sys<T>: SystemOutput<CO, NI, NO>,
    CO: interface::Update + 'static,
{
    fn add_output(&'a mut self) -> ActorOutput<'a, Actor<CO, NI, NO>> {
        AddActorOutput::add_output(self.output())
    }
}

impl<U, T, CI, const NI: usize, const NO: usize> AddActorInput<U, CI, NI, NO> for Sys<T>
where
    T: System,
    Sys<T>: SystemInput<CI, NI, NO>,
    U: 'static + interface::UniqueIdentifier,
    CI: interface::Read<U> + 'static,
{
    fn add_input(&mut self, rx: flume::Receiver<interface::Data<U>>, hash: u64) {
        AddActorInput::add_input(self.input(), rx, hash)
    }
}