bstein/lesavka
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

client server hid stream fix

Browse Source
This commit is contained in:
Brad Stein 2025-06-26 04:07:22 -05:00
parent 42f9a0f4ff
commit 8bfe17e45c
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
client/src/input/keyboard.rs
View File

@ -1,6 +1,6 @@
// client/src/input/keyboard.rs // client/src/input/keyboard.rs
use std::collections::HashSet; use std::{collections::HashSet, sync::atomic::{AtomicU32, Ordering}};
use evdev::{Device, EventType, InputEvent, KeyCode}; use evdev::{Device, EventType, InputEvent, KeyCode};
use tokio::sync::broadcast::Sender; use tokio::sync::broadcast::Sender;
use tracing::{debug, error, warn}; use tracing::{debug, error, warn};
@ -16,6 +16,10 @@ pub struct KeyboardAggregator {
pressed_keys: HashSet<KeyCode>, pressed_keys: HashSet<KeyCode>,
} }
/*───────── helpers ───────────────────────────────────────────────────*/
/// Monotonically‑increasing ID that can be logged on server & client.
static SEQ: AtomicU32 = AtomicU32::new(0);
impl KeyboardAggregator { impl KeyboardAggregator {
pub fn new(dev: Device, dev_mode: bool, tx: Sender<KeyboardReport>) -> Self { pub fn new(dev: Device, dev_mode: bool, tx: Sender<KeyboardReport>) -> Self {
let _ = dev.set_nonblocking(true); let _ = dev.set_nonblocking(true);
@ -44,11 +48,10 @@ impl KeyboardAggregator {
} }
let report = self.build_report(); let report = self.build_report();
if self.dev_mode { debug!(?report, "kbd"); } // Generate a local sequence number for debugging/log‑merge only.
static COUNTER: AtomicU32 = AtomicU32::new(0); let id = SEQ.fetch_add(1, Ordering::Relaxed);
let id = COUNTER.fetch_add(1, Ordering::Relaxed); if self.dev_mode { debug!(seq = id, ?report, "kbd"); }
let _ = self.tx.send(KeyboardReport { let _ = self.tx.send(KeyboardReport {
seq: id,
data: report.to_vec() data: report.to_vec()
}); });