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

server: default UVC control to nonblocking

Browse Source
This commit is contained in:
Brad Stein 2026-01-06 20:33:04 -03:00
parent d8b0d739a5
commit dccc6601b1
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/src/bin/lesavka-uvc.rs
View File

@ -120,6 +120,8 @@ fn main() -> Result<()> {
); );
let debug = env::var("LESAVKA_UVC_DEBUG").is_ok(); let debug = env::var("LESAVKA_UVC_DEBUG").is_ok();
let nonblock = env::var("LESAVKA_UVC_BLOCKING").is_err();
eprintln!("[lesavka-uvc] nonblock={}", if nonblock { 1 } else { 0 });
let mut setup_seen: u64 = 0; let mut setup_seen: u64 = 0;
let mut data_seen: u64 = 0; let mut data_seen: u64 = 0;
let mut dq_err_seen: u64 = 0; let mut dq_err_seen: u64 = 0;
@ -302,10 +304,11 @@ fn read_interface(path: &str) -> Option<u8> {
} }
fn open_with_retry(path: &str) -> Result<std::fs::File> { fn open_with_retry(path: &str) -> Result<std::fs::File> {
let nonblock = env::var("LESAVKA_UVC_BLOCKING").is_err();
for attempt in 1..=200 { for attempt in 1..=200 {
let mut opts = OpenOptions::new(); let mut opts = OpenOptions::new();
opts.read(true).write(true); opts.read(true).write(true);
if env::var("LESAVKA_UVC_NONBLOCK").is_ok() { if nonblock {
opts.custom_flags(libc::O_NONBLOCK); opts.custom_flags(libc::O_NONBLOCK);
} }
match opts.open(path) { match opts.open(path) {