Mirror/rayhunter
1
0
Fork 0
mirror of https://github.com/EFForg/rayhunter.git synced 2026-07-29 10:18:12 -07:00
Code Issues Packages Projects Releases Wiki Activity

Debounce key input events

Browse Source
This commit is contained in:
Markus Unterwaditzer
2025-06-16 21:19:02 +02:00
committed by Cooper Quintin
parent cb2092d14f
commit 9f9adea5a1
1 changed files with 32 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
bin/src/key_input.rs
+32 -11
View File
@@ -37,6 +37,7 @@ pub fn run_key_input_thread(
let mut buffer = [0u8; INPUT_EVENT_SIZE]; let mut buffer = [0u8; INPUT_EVENT_SIZE];
let mut last_keyup: Option<Instant> = None; let mut last_keyup: Option<Instant> = None;
let mut last_event_time: Option<Instant> = None;
loop { loop {
if let Err(e) = file.read_exact(&mut buffer).await { if let Err(e) = file.read_exact(&mut buffer).await {
@@ -46,21 +47,41 @@ pub fn run_key_input_thread(
let event = parse_event(buffer); let event = parse_event(buffer);
let now = Instant::now();
// On orbic it was observed that pressing the power button can trigger many successive
// events. Drop events that are too close together.
if let Some(last_time) = last_event_time {
if now.duration_since(last_time) < Duration::from_millis(50) {
last_event_time = Some(now);
continue;
}
}
last_event_time = Some(now);
match event { match event {
Event::KeyUp => { Event::KeyUp => {
if last_keyup.is_some() if let Some(last_keyup_instant) = last_keyup {
&& last_keyup.unwrap().elapsed() < Duration::from_millis(500) let elapsed = now.duration_since(last_keyup_instant);
{
if let Err(e) = diag_tx.send(DiagDeviceCtrlMessage::StopRecording).await { if elapsed >= Duration::from_millis(100)
error!("Failed to send StopRecording: {}", e); && elapsed <= Duration::from_millis(800)
{
if let Err(e) = diag_tx.send(DiagDeviceCtrlMessage::StopRecording).await
{
error!("Failed to send StopRecording: {}", e);
}
if let Err(e) =
diag_tx.send(DiagDeviceCtrlMessage::StartRecording).await
{
error!("Failed to send StartRecording: {}", e);
}
last_keyup = None;
continue;
} }
if let Err(e) = diag_tx.send(DiagDeviceCtrlMessage::StartRecording).await {
error!("Failed to send StartRecording: {}", e);
}
last_keyup = None;
} else {
last_keyup = Some(Instant::now());
} }
last_keyup = Some(now);
} }
Event::KeyDown => {} Event::KeyDown => {}
} }