diff --git a/src/cli.rs b/src/cli.rs index 467edea..1fd2a5a 100644 --- a/src/cli.rs +++ b/src/cli.rs @@ -41,10 +41,6 @@ pub struct Cli { #[arg(long)] pub no_hwencode: bool, - /// Use low-latency SRT transport instead of HTTP MPEG-TS (Phase 2/3). - #[arg(long)] - pub low_latency: bool, - /// Maximum number of concurrent viewers. Additional connections are /// politely refused with a "host full" message. Defaults to the /// connection-aware recommendation from the bandwidth pre-flight if @@ -88,7 +84,6 @@ pub struct HostOpts { pub bitrate: u32, pub framerate: u32, pub no_hwencode: bool, - pub low_latency: bool, pub max_viewers: Option, pub interactive: bool, } @@ -109,7 +104,6 @@ impl Cli { bitrate: self.bitrate, framerate: self.framerate, no_hwencode: self.no_hwencode, - low_latency: self.low_latency, max_viewers: self.max_viewers, interactive, } diff --git a/src/host/mod.rs b/src/host/mod.rs index f0a9eb6..6bfbac7 100644 --- a/src/host/mod.rs +++ b/src/host/mod.rs @@ -147,13 +147,10 @@ async fn handle_peer( let bridge = tunnel::bridge(quic_send, quic_recv, tcp); tokio::select! { - res = bridge => { - if let Err(e) = res { - tracing::warn!(%remote, "bridge ended with error: {e:#}"); - } else { - tracing::info!(%remote, "bridge closed cleanly"); - } - } + res = bridge => match res { + Ok(()) => tracing::info!(%remote, "bridge closed cleanly"), + Err(e) => tracing::info!(%remote, "bridge ended: {e:#}"), + }, _ = cancel.cancelled() => { tracing::info!(%remote, "cancellation during stream"); }