adze-concurrency-init-classifier-core 0.1.0

Classifier utilities for Rayon global thread-pool initialization errors.
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

//! Message classification helpers for Rayon global thread-pool initialization errors.

#![forbid(unsafe_op_in_unsafe_fn)]
#![deny(missing_docs)]
#![cfg_attr(feature = "strict_api", deny(unreachable_pub))]
#![cfg_attr(not(feature = "strict_api"), warn(unreachable_pub))]
#![cfg_attr(feature = "strict_docs", deny(missing_docs))]
#![cfg_attr(not(feature = "strict_docs"), allow(missing_docs))]

/// Return whether the provided message represents a Rayon global-pool
/// already-initialized error.
#[must_use]
pub fn is_already_initialized_error(message: &str) -> bool {
    let message = message.to_ascii_lowercase();
    message.contains("global") && message.contains("already")
}

#[cfg(test)]
mod tests {
    use super::is_already_initialized_error;

    #[test]
    fn already_initialized_error_classifier_is_case_insensitive() {
        assert!(is_already_initialized_error(
            "The GlObAl thread pool has AlReAdY been initialized"
        ));
    }

    #[test]
    fn already_initialized_error_classifier_requires_both_tokens() {
        assert!(!is_already_initialized_error(
            "thread pool already initialized"
        ));
        assert!(!is_already_initialized_error(
            "global thread pool initialized"
        ));
    }

    #[test]
    fn empty_string_is_not_already_initialized_error() {
        assert!(!is_already_initialized_error(""));
    }

    #[test]
    fn unrelated_message_is_not_detected() {
        assert!(!is_already_initialized_error("something went wrong"));
    }

    #[test]
    fn reversed_token_order_is_still_detected() {
        assert!(is_already_initialized_error(
            "already set on the global pool"
        ));
    }

    #[test]
    fn adjacent_tokens_are_detected() {
        assert!(is_already_initialized_error("globalalready"));
    }

    #[test]
    fn only_global_token_is_not_detected() {
        assert!(!is_already_initialized_error("global"));
    }

    #[test]
    fn only_already_token_is_not_detected() {
        assert!(!is_already_initialized_error("already"));
    }
}