mars-xlog-core 0.1.0

Core runtime building blocks for the Rust-native xlog engine.
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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105

#[cfg(any(
    target_os = "macos",
    target_os = "ios",
    target_os = "tvos",
    target_os = "watchos"
))]
use std::sync::OnceLock;

/// Return the current platform thread id, or `-1` on unsupported targets.
pub fn current_tid() -> i64 {
    #[cfg(any(target_os = "linux", target_os = "android"))]
    {
        unsafe { libc::syscall(libc::SYS_gettid) as i64 }
    }

    #[cfg(any(
        target_os = "macos",
        target_os = "ios",
        target_os = "tvos",
        target_os = "watchos"
    ))]
    {
        let mut tid: u64 = 0;
        unsafe {
            libc::pthread_threadid_np(0, &mut tid);
        }
        tid as i64
    }

    #[cfg(not(any(
        target_os = "linux",
        target_os = "android",
        target_os = "macos",
        target_os = "ios",
        target_os = "tvos",
        target_os = "watchos"
    )))]
    {
        -1
    }
}

/// Return the platform "main thread id" used by Mars-compatible metadata.
///
/// On Linux/Android this follows the historical Mars behavior and returns the
/// process id. On Apple targets the first observed thread id is memoized.
pub fn main_tid() -> i64 {
    #[cfg(any(target_os = "linux", target_os = "android"))]
    {
        // Matches Mars unix/android behavior where maintid tracks process main tid (pid).
        std::process::id() as i64
    }

    #[cfg(any(
        target_os = "macos",
        target_os = "ios",
        target_os = "tvos",
        target_os = "watchos"
    ))]
    {
        static MAIN_TID: OnceLock<i64> = OnceLock::new();
        *MAIN_TID.get_or_init(current_tid)
    }

    #[cfg(not(any(
        target_os = "linux",
        target_os = "android",
        target_os = "macos",
        target_os = "ios",
        target_os = "tvos",
        target_os = "watchos"
    )))]
    {
        -1
    }
}

#[cfg(test)]
mod tests {
    use super::{current_tid, main_tid};

    #[test]
    fn main_tid_is_stable_across_calls() {
        let first = main_tid();
        let second = main_tid();

        assert_eq!(first, second);

        #[cfg(any(target_os = "linux", target_os = "android"))]
        assert_eq!(first, std::process::id() as i64);
    }

    #[test]
    fn current_tid_is_positive_on_supported_targets() {
        #[cfg(any(
            target_os = "linux",
            target_os = "android",
            target_os = "macos",
            target_os = "ios",
            target_os = "tvos",
            target_os = "watchos"
        ))]
        assert!(current_tid() > 0);
    }
}