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

use tokio::sync::oneshot;

use crate::actor_id::ActorID;
use crate::exit::Exit;

use super::Backend;

#[derive(Debug)]
pub enum SysMsg {
    Link(ActorID),
    Unlink(ActorID),
    SigExit(ActorID, Exit),
    GetInfo(oneshot::Sender<ActorInfo>),
}

#[derive(Debug, Clone)]
#[cfg_attr(feature = "serde", derive(serde::Serialize, serde::Deserialize))]
pub struct ActorInfo {
    pub actor_id: ActorID,
    pub behaviour: &'static str,
    pub args_type: &'static str,
    pub message_type: &'static str,
    pub m_queue_len: (usize, usize),
    pub s_queue_len: (usize, usize),
    pub c_queue_len: (usize, usize),
    pub tasks_count: usize,
    pub trap_exit: bool,
    pub links: Box<[ActorID]>,
}

impl<M> Backend<M> {
    pub(super) async fn send_sys_msg(&self, to: ActorID, sys_msg: SysMsg) -> bool {
        if let Some(system) = self.system_opt.rc_upgrade() {
            system.send_sys_msg(to, sys_msg).await
        } else {
            false
        }
    }
}