diff --git a/src/coordinator/coord_state.rs b/src/coordinator/coord_state.rs index a9e6afb..8c1f767 100644 --- a/src/coordinator/coord_state.rs +++ b/src/coordinator/coord_state.rs @@ -95,7 +95,7 @@ impl<'a> CoordState<'a> { this } - #[instrument] + #[instrument(skip(self))] pub async fn socket_send(&mut self, message: Message) { if let Some(mut socket) = self.sck_outbound.take() { if let Err(e) = socket.send(message).await { diff --git a/src/coordinator/mod.rs b/src/coordinator/mod.rs index 72bcfcf..c3fc3d0 100644 --- a/src/coordinator/mod.rs +++ b/src/coordinator/mod.rs @@ -48,7 +48,7 @@ pub enum ApplicationEvent { EnableAutomatic(bool), } -#[instrument] +#[instrument(skip_all)] pub async fn start_coordinator( // Main_Event_Channel mec: Receiver, diff --git a/src/coordinator/remote_video_processor.rs b/src/coordinator/remote_video_processor.rs index 19d15f3..2a35602 100644 --- a/src/coordinator/remote_video_processor.rs +++ b/src/coordinator/remote_video_processor.rs @@ -23,7 +23,7 @@ use super::{ SocketState, }; -#[instrument] +#[instrument(skip_all)] pub async fn remote_video_loop( conn_string: String, appsink: Arc>, diff --git a/src/joystick_source.rs b/src/joystick_source.rs index a0d6297..ed221fa 100644 --- a/src/joystick_source.rs +++ b/src/joystick_source.rs @@ -35,7 +35,7 @@ impl FilterFn for UnknownSlayer { } } -#[tracing::instrument] +#[tracing::instrument(skip(tx))] pub async fn joystick_loop(tx: Sender, is_alive: Arc) { let mut gilrs = GilrsBuilder::new().set_update_state(false).build().unwrap(); diff --git a/src/remote_sources/mod.rs b/src/remote_sources/mod.rs index 2d6fcf1..a81d0ef 100644 --- a/src/remote_sources/mod.rs +++ b/src/remote_sources/mod.rs @@ -37,7 +37,7 @@ pub struct TrackerState { pub identity_boxes: Vec, } -#[instrument] +#[instrument(skip(rt, mec))] pub async fn start_socketserver( rt: Handle, mec: Sender, @@ -70,7 +70,7 @@ pub async fn start_socketserver( connection_state.is_connected.store(false, Ordering::SeqCst); } -#[instrument] +#[instrument(skip(stream, mec))] async fn accept_connection( peer: SocketAddr, stream: TcpStream, @@ -85,7 +85,7 @@ async fn accept_connection( } } -#[instrument] +#[instrument(skip(stream, mec))] async fn handle_connection( peer: SocketAddr, stream: TcpStream,