futuresdr 0.6.0

An Experimental Async SDR Runtime for Heterogeneous Architectures.
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

pub fn init() {
    #[cfg(all(target_os = "android", not(target_arch = "wasm32")))]
    android::init();
    #[cfg(all(not(target_os = "android"), not(target_arch = "wasm32")))]
    native::init();
    #[cfg(target_arch = "wasm32")]
    wasm::init();
}

#[cfg(not(target_arch = "wasm32"))]
fn env_filter(level: tracing::level_filters::LevelFilter) -> tracing_subscriber::filter::EnvFilter {
    tracing_subscriber::filter::EnvFilter::builder()
        .with_default_directive(level.into())
        .with_env_var("FUTURESDR_LOG")
        .from_env_lossy()
}

#[cfg(all(not(target_os = "android"), not(target_arch = "wasm32")))]
mod native {
    use tracing_subscriber::fmt;
    use tracing_subscriber::prelude::*;

    use crate::runtime::config;

    pub(super) fn init() {
        let format = fmt::layer()
            .with_level(true)
            .with_target(true)
            .with_thread_ids(false)
            .with_thread_names(true)
            .compact();

        let level = config::config().log_level;
        let filter = super::env_filter(level);
        let subscriber = tracing_subscriber::registry().with(filter).with(format);

        if subscriber.try_init().is_err() {
            tracing::debug!("logger already initialized");
        }
    }
}

#[cfg(all(target_os = "android", not(target_arch = "wasm32")))]
mod android {
    use once_cell::sync::OnceCell;
    use tracing_android::layer;
    use tracing_subscriber::prelude::*;

    use crate::runtime::config;

    // Make sure tracing is only initialized once.
    static TRACING_INIT: OnceCell<()> = OnceCell::new();

    pub(super) fn init() {
        TRACING_INIT.get_or_init(|| match layer("FutureSDR") {
            Ok(android_layer) => {
                let level = config::config().log_level;
                let filter = super::env_filter(level);
                let subscriber = tracing_subscriber::registry()
                    .with(filter)
                    .with(android_layer);
                if let Err(e) = subscriber.try_init() {
                    eprintln!("tracing already initialized or failed: {e}");
                }
            }
            Err(e) => {
                eprintln!("failed to initialize Android tracing layer: {e}");
            }
        });
    }
}

#[cfg(target_arch = "wasm32")]
mod wasm {
    pub(super) fn init() {
        let _ = tracing_wasm::try_set_as_global_default();
    }
}