From 1d4a3f86159853386965fdaeda11721dd0a162af Mon Sep 17 00:00:00 2001 From: Brad Stein Date: Wed, 25 Jun 2025 18:23:38 -0500 Subject: [PATCH] updates --- server/src/main.rs | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/server/src/main.rs b/server/src/main.rs index bf08720..6613abd 100644 --- a/server/src/main.rs +++ b/server/src/main.rs @@ -7,7 +7,8 @@ use std::{pin::Pin, sync::Arc, time::Duration}; use futures_util::{Stream, StreamExt}; use tokio::{fs::{OpenOptions}, io::AsyncWriteExt, sync::Mutex}; use tokio_stream::{wrappers::ReceiverStream}; -use tonic::{transport::Server, Request, Response, Status}; +use tonic::{transport::Server, Request, Response, Status}; +use anyhow::Context as _; use tracing::{info, trace, warn}; use tracing_subscriber::{filter::EnvFilter, fmt, prelude::*}; use tracing_appender::non_blocking; @@ -64,10 +65,12 @@ impl Handler { let kb = OpenOptions::new() .write(true).custom_flags(libc::O_NONBLOCK) - .open("/dev/hidg0").await?; + .open("/dev/hidg0").await + .context("opening /dev/hidg0")?; let ms = OpenOptions::new() .write(true).custom_flags(libc::O_NONBLOCK) - .open("/dev/hidg1").await?; + .open("/dev/hidg1").await + .context("opening /dev/hidg1")?; Ok(Self { kb: Arc::new(Mutex::new(kb)), ms: Arc::new(Mutex::new(ms)), @@ -195,7 +198,7 @@ impl Relay for Handler { #[tokio::main(flavor = "multi_thread", worker_threads = 4)] async fn main() -> anyhow::Result<()> { /* logging */ - let _log_guard = init_tracing()?; + let _log_guard: WorkerGuard = init_tracing()?; /* auto‑cycle task */ // tokio::spawn(async { monitor_gc311_disconnect().await.ok(); });