ax-input 0.6.3

Input device management for ArceOS
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

//! [ArceOS](https://github.com/arceos-org/arceos) input module.

#![no_std]

extern crate alloc;

mod device;
mod event;
mod id;
pub mod rdif;

use alloc::vec::Vec;
use core::mem;

use ax_lazyinit::LazyInit;
use ax_sync::Mutex;
pub use device::{ErasedInputDevice, InputDevice, InputError, InputIrqEvent, InputResult};
pub use event::{AbsInfo, Event, EventType};
pub use id::InputDeviceId;

static DEVICES: LazyInit<Mutex<Vec<ErasedInputDevice>>> = LazyInit::new();

/// Initializes the input subsystem by underlayer devices.
pub fn init_input(input_devs: impl IntoIterator<Item = ErasedInputDevice>) {
    log::info!("Initialize input subsystem...");

    let mut devices = Vec::new();
    for dev in input_devs {
        log::info!("  registered a new input device: {}", dev.name());
        devices.push(dev);
    }
    DEVICES.init_once(Mutex::new(devices));
}

/// Takes the initialized input devices.
pub fn take_inputs() -> Vec<ErasedInputDevice> {
    mem::take(&mut DEVICES.lock())
}

/// Returns whether an evdev polling fallback should actively drain the device
/// queue.
pub fn input_polling_fallback_should_drain(
    polling_requested: bool,
    now_ns: u64,
    last_irq_event_ns: u64,
    irq_alive_ns: u64,
) -> bool {
    polling_requested && now_ns.wrapping_sub(last_irq_event_ns) > irq_alive_ns
}

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

    const IRQ_ALIVE_NS: u64 = 1_000_000_000;

    #[test]
    fn polling_fallback_stays_idle_without_user_interest_even_when_irq_is_stale() {
        assert!(!input_polling_fallback_should_drain(
            false,
            IRQ_ALIVE_NS + 1,
            0,
            IRQ_ALIVE_NS
        ));
    }

    #[test]
    fn polling_fallback_drains_after_user_interest_when_irq_is_stale() {
        assert!(input_polling_fallback_should_drain(
            true,
            IRQ_ALIVE_NS + 1,
            0,
            IRQ_ALIVE_NS
        ));
    }

    #[test]
    fn polling_fallback_stays_idle_while_irq_is_recent() {
        assert!(!input_polling_fallback_should_drain(
            true,
            IRQ_ALIVE_NS,
            0,
            IRQ_ALIVE_NS
        ));
    }
}