zestors 0.1.2

A fast and flexible actor-framework for building fault-tolerant Rust applications
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

/*!
# Overview

This module currently just exposes two functions:
- [`set_default_shutdown_time`] and [`get_default_shutdown_time`].

As supervision and distribution get implemented this module will fill further.

| __<--__ [`handler`](crate::handler) | [`supervision`](crate::supervision) __-->__ |
|---|---|
*/
#[allow(unused)]
use crate::all::*;

use std::{
    sync::atomic::{AtomicU32, AtomicU64, Ordering},
    time::Duration,
};

static DEFAULT_SHUTDOWN_TIME_NANOS: AtomicU32 = AtomicU32::new(0);
static DEFAULT_SHUTDOWN_TIME_SECS: AtomicU64 = AtomicU64::new(1);

/// Set the default shutdown time-limit.
/// 
/// This limit is the limit applied to a default [`Link`], and changes how long these processes
/// have to exit before 
pub fn set_default_shutdown_time(duration: Duration) {
    DEFAULT_SHUTDOWN_TIME_NANOS.store(duration.subsec_nanos(), Ordering::Release);
    DEFAULT_SHUTDOWN_TIME_SECS.store(duration.as_secs(), Ordering::Release);
}

/// Get the default shutdown time-limit.
pub fn get_default_shutdown_time() -> Duration {
    Duration::new(
        DEFAULT_SHUTDOWN_TIME_SECS.load(Ordering::Acquire),
        DEFAULT_SHUTDOWN_TIME_NANOS.load(Ordering::Acquire),
    )
}

#[cfg(test)]
mod test {
    use super::*;
    #[test]
    fn default_shutdown_time() {
        assert_eq!(get_default_shutdown_time(), Duration::from_secs(1));
        set_default_shutdown_time(Duration::from_secs(2));
        assert_eq!(get_default_shutdown_time(), Duration::from_secs(2));
    }
}