tor-proto 0.41.0

Asynchronous client-side implementation of the central Tor network protocols
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
77
78

//! Implement a sink-blocking policy based on a simple blocked/unblocked status.

use super::Policy;
use tor_error::{Bug, internal};

/// A simple two-state sink-blocking [`Policy`] .
#[derive(Debug, Clone, Copy)]
pub(crate) enum BooleanPolicy {
    /// The sink is blocked.
    Blocked,
    /// The sink is not blocked.
    Unblocked,
}

impl Policy for BooleanPolicy {
    fn is_blocking(&self) -> bool {
        matches!(self, BooleanPolicy::Blocked)
    }

    // Correctness: This method doesn't change `self`.
    // There are no other methods taking `&mut self`.
    // Therefore the invariants of Policy are trivially preserved.
    fn take_one(&mut self) -> Result<(), Bug> {
        match self {
            BooleanPolicy::Blocked => {
                Err(internal!("Tried to take_one on a blocked BooleanPolicy!"))
            }
            BooleanPolicy::Unblocked => Ok(()),
        }
    }
}

impl<S> super::SinkBlocker<S, BooleanPolicy> {
    /// Put this `SinkBlocker` into a blocked state.
    pub(crate) fn set_blocked(&mut self) {
        self.update_policy(BooleanPolicy::Blocked);
    }

    /// Put this `SinkBlocker` into an unblocked state.
    pub(crate) fn set_unblocked(&mut self) {
        // Correctness: Note that this _replaces_ the Policy object,
        // and does not modify an existing Policy object.
        // This is the permitted way to make a SinkBlocker unblocked.
        self.update_policy(BooleanPolicy::Unblocked);
    }
}

#[cfg(test)]
mod test {
    // @@ begin test lint list maintained by maint/add_warning @@
    #![allow(clippy::bool_assert_comparison)]
    #![allow(clippy::clone_on_copy)]
    #![allow(clippy::dbg_macro)]
    #![allow(clippy::mixed_attributes_style)]
    #![allow(clippy::print_stderr)]
    #![allow(clippy::print_stdout)]
    #![allow(clippy::single_char_pattern)]
    #![allow(clippy::unwrap_used)]
    #![allow(clippy::unchecked_time_subtraction)]
    #![allow(clippy::useless_vec)]
    #![allow(clippy::needless_pass_by_value)]
    //! <!-- @@ end test lint list maintained by maint/add_warning @@ -->

    use super::*;

    #[test]
    fn boolean_policy() {
        let mut blocked = BooleanPolicy::Blocked;
        assert_eq!(blocked.is_blocking(), true);
        assert!(blocked.take_one().is_err());
        assert_eq!(blocked.is_blocking(), true);

        let mut unblocked = BooleanPolicy::Unblocked;
        assert_eq!(unblocked.is_blocking(), false);
        assert!(unblocked.take_one().is_ok());
        assert_eq!(unblocked.is_blocking(), false);
    }
}