net-pool 0.3.0

A set of types for network connection pool.
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

#[macro_export]
macro_rules! base_pool_impl {
    (
        $state:ident
    ) => {
        fn set_max_conn(&self, mut max: Option<usize>) {
            if let Some(0) = max {
                max = None;
            }
            match max {
                None => self
                    .$state
                    .max_conn
                    .store(usize::MAX, std::sync::atomic::Ordering::Relaxed),
                Some(v) => self
                    .$state
                    .max_conn
                    .store(v, std::sync::atomic::Ordering::Relaxed),
            }
        }

        fn get_max_conn(&self) -> Option<usize> {
            match self
                .$state
                .max_conn
                .load(std::sync::atomic::Ordering::Relaxed)
            {
                usize::MAX => None,
                v => Some(v),
            }
        }

        fn get_cur_conn(&self) -> usize {
            self.$state
                .cur_conn
                .load(std::sync::atomic::Ordering::Relaxed)
        }

        fn set_keepalive(&self, mut duration: Option<std::time::Duration>) {
            if let Some(d) = duration {
                if d.is_zero() {
                    duration = None;
                }
            }

            match duration {
                None => self
                    .$state
                    .keepalive
                    .store(u64::MAX, std::sync::atomic::Ordering::Relaxed),
                Some(v) => self
                    .$state
                    .keepalive
                    .store(v.as_secs(), std::sync::atomic::Ordering::Relaxed),
            }
        }

        fn get_keepalive(&self) -> Option<std::time::Duration> {
            match self
                .$state
                .keepalive
                .load(std::sync::atomic::Ordering::Relaxed)
            {
                u64::MAX => None,
                v => Some(std::time::Duration::from_secs(v)),
            }
        }

        fn get_strategy(&self) -> Arc<dyn LbStrategy> {
            self.$state.lb_strategy.clone()
        }
    };
}

#[allow(unused_imports)]
pub use base_pool_impl;