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

use parking_lot::Mutex;

use super::{SendSystemIndex, UnsendSystemIndex};
use crate::system;

pub(in crate::world::scheduler) struct SyncState {
    pub(in crate::world::scheduler) send_systems: Vec<(String, Mutex<Box<dyn system::Sendable>>)>,
}

impl SyncState {
    pub(in crate::world::scheduler) fn get_send_system(
        &self,
        index: SendSystemIndex,
    ) -> (&str, &Mutex<Box<dyn system::Sendable>>) {
        let (debug_name, system) = self.send_systems.get(index.0).expect("invalid node index");
        (debug_name, system)
    }
}

pub(in crate::world::scheduler) struct UnsyncState {
    pub(in crate::world::scheduler) unsend_systems: Vec<(String, Box<dyn system::Unsendable>)>,
}

impl UnsyncState {
    pub(in crate::world::scheduler) fn get_unsend_system_mut(
        &mut self,
        index: UnsendSystemIndex,
    ) -> (&str, &mut dyn system::Unsendable) {
        let (debug_name, system) =
            self.unsend_systems.get_mut(index.0).expect("invalid node index");
        (debug_name, &mut **system)
    }
}

#[cfg(test)]
static_assertions::assert_impl_all!(SyncState: Send, Sync);