gmt_dos-systems_m2 0.1.2

GMT DOS M2 System
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

use std::sync::Arc;

use gmt_dos_clients_io::{
    Assembly,
    gmt_m2::fsm::{
        M2FSMFsmCommand, M2FSMPiezoForces, M2FSMPiezoNodes,
        segment::{FsmCommand, PiezoForces, PiezoNodes},
    },
};
use interface::{Data, Read, Size, Update, Write, WriteFlatten};
use serde::{Deserialize, Serialize};

impl Assembly for DispatchIn {}
impl Assembly for DispatchOut {}

/// Inputs dispatch
///
/// Distributes the FSMS command and piezostack actuator motions to the segments
#[derive(Debug, Default, Serialize, Deserialize)]
pub struct DispatchIn
where
    Self: Assembly,
{
    fsms_command: Arc<Vec<Arc<Vec<f64>>>>,
    fsms_pzt_motion: Arc<Vec<Arc<Vec<f64>>>>,
}
impl DispatchIn
where
    Self: Assembly,
{
    pub fn new() -> Self {
        Self {
            fsms_command: Arc::new(vec![Arc::new(vec![0f64; 3]); <Self as Assembly>::N]),
            fsms_pzt_motion: Arc::new(vec![Arc::new(vec![0f64; 6]); <Self as Assembly>::N]),
        }
    }
}

/// Outputs dispatch
///
/// Collects the FSMS piezostack actuator forces from the segments
#[derive(Debug, Default, Serialize, Deserialize)]
pub struct DispatchOut
where
    Self: Assembly,
{
    fsms_pzt_forces: Vec<Arc<Vec<f64>>>,
}
impl DispatchOut
where
    Self: Assembly,
{
    pub fn new() -> Self {
        Self {
            fsms_pzt_forces: vec![Arc::new(vec![0f64; 6]); <Self as Assembly>::N],
        }
    }
}

impl Update for DispatchIn {}
impl Update for DispatchOut {}

impl Read<M2FSMPiezoNodes> for DispatchIn {
    fn read(&mut self, data: Data<M2FSMPiezoNodes>) {
        self.fsms_pzt_motion =
            Arc::new(data.chunks(6).map(|data| Arc::new(data.to_vec())).collect());
    }
}
impl<const ID: u8> Write<PiezoNodes<ID>> for DispatchIn {
    fn write(&mut self) -> Option<Data<PiezoNodes<ID>>> {
        <Self as Assembly>::position::<ID>().and_then(|idx| {
            self.fsms_pzt_motion
                .get(idx)
                .map(|data| data.clone().into())
        })
    }
}
impl Read<M2FSMFsmCommand> for DispatchIn {
    fn read(&mut self, data: Data<M2FSMFsmCommand>) {
        self.fsms_command = Arc::new(data.chunks(3).map(|data| Arc::new(data.to_vec())).collect());
    }
}
impl<const ID: u8> Write<FsmCommand<ID>> for DispatchIn {
    fn write(&mut self) -> Option<Data<FsmCommand<ID>>> {
        <Self as Assembly>::position::<ID>()
            .and_then(|idx| self.fsms_command.get(idx).map(|data| data.clone().into()))
    }
}
impl<const ID: u8> Read<PiezoForces<ID>> for DispatchOut {
    fn read(&mut self, data: Data<PiezoForces<ID>>) {
        if let Some(idx) = <Self as Assembly>::position::<ID>() {
            let forces = data.into_arc();
            self.fsms_pzt_forces[idx] = forces;
        }
    }
}
impl Write<M2FSMPiezoForces> for DispatchOut {
    fn write(&mut self) -> Option<Data<M2FSMPiezoForces>> {
        Some(Data::new(
            self.fsms_pzt_forces
                .iter()
                .flat_map(|data| data.as_slice().to_vec())
                .collect(),
        ))
    }
}

impl Size<M2FSMPiezoForces> for DispatchOut {
    fn len(&self) -> usize {
        42
    }
}

impl WriteFlatten for DispatchOut {}