rain_server 0.3.0-rc3

Distributed computational framework for large-scale task-based pipelines. Server and governor binaries.
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

use rain_core::{errors::*, types::*, utils::*};
use std::net::SocketAddr;

use super::SessionRef;
use wrapped::WrappedRcRefCell;

#[derive(Debug)]
pub struct Client {
    pub(in super::super) id: ClientId,
    pub(in super::super) sessions: RcSet<SessionRef>,
}

pub type ClientRef = WrappedRcRefCell<Client>;

impl ClientRef {
    /// Create new Client object
    pub fn new(address: SocketAddr) -> Self {
        ClientRef::wrap(Client {
            id: address.clone(),
            sessions: Default::default(),
        })
    }

    /// Return the object ID in graph.
    pub fn get_id(&self) -> ClientId {
        self.get().id
    }
}

impl ConsistencyCheck for ClientRef {
    /// Check for state and relationships consistency. Only explores adjacent objects but still
    /// may be slow.
    fn check_consistency(&self) -> Result<()> {
        let s = self.get();
        for sref in s.sessions.iter() {
            if sref.get().client != *self {
                bail!("session ref {:?} inconsistency in {:?}", sref, s)
            }
        }
        Ok(())
    }
}

impl ::std::fmt::Debug for ClientRef {
    fn fmt(&self, f: &mut ::std::fmt::Formatter) -> ::std::fmt::Result {
        write!(f, "ClientRef {}", self.get_id())
    }
}