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

server hid stream fix

Browse Source
This commit is contained in:
Brad Stein 2025-06-26 03:00:04 -05:00
parent b63e04ff95
commit ae5c9f4f25
1 changed files with 14 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
server/src/main.rs
View File

@ -158,7 +158,13 @@ impl Relay for Handler {
.map(|b| format!("{b:02X}")).collect::<Vec<_>>().join(" ")); .map(|b| format!("{b:02X}")).collect::<Vec<_>>().join(" "));
break; break;
}, },
Err(e) if matches!(e.raw_os_error(), Some(libc::EBUSY) | Some(libc::EAGAIN)) => { Err(e)
if matches!(e.raw_os_error(),
Some(libc::EBUSY) | // still opening
Some(libc::ENODEV) | // gadget not‑yet configured
Some(libc::EPIPE) | // host vanished
Some(libc::EAGAIN)) // non‑blocking
=> {
tokio::time::sleep(Duration::from_millis(10)).await; tokio::time::sleep(Duration::from_millis(10)).await;
continue; continue;
} }
@ -191,7 +197,13 @@ impl Relay for Handler {
.map(|b| format!("{b:02X}")).collect::<Vec<_>>().join(" ")); .map(|b| format!("{b:02X}")).collect::<Vec<_>>().join(" "));
break; break;
} }
Err(e) if matches!(e.raw_os_error(), Some(libc::EBUSY) | Some(libc::EAGAIN)) => { Err(e)
if matches!(e.raw_os_error(),
Some(libc::EBUSY) | // still opening
Some(libc::ENODEV) | // gadget not‑yet configured
Some(libc::EPIPE) | // host vanished
Some(libc::EAGAIN)) // non‑blocking
=> {
tokio::time::sleep(Duration::from_millis(10)).await; tokio::time::sleep(Duration::from_millis(10)).await;
continue; continue;
} }