added exclusions to argument logging

This commit is contained in:
Nickiel12 2024-05-30 11:44:08 -07:00
parent a2d303fdfe
commit 6aa1c8789d
5 changed files with 7 additions and 7 deletions

View file

@ -95,7 +95,7 @@ impl<'a> CoordState<'a> {
this this
} }
#[instrument] #[instrument(skip(self))]
pub async fn socket_send(&mut self, message: Message) { pub async fn socket_send(&mut self, message: Message) {
if let Some(mut socket) = self.sck_outbound.take() { if let Some(mut socket) = self.sck_outbound.take() {
if let Err(e) = socket.send(message).await { if let Err(e) = socket.send(message).await {

View file

@ -48,7 +48,7 @@ pub enum ApplicationEvent {
EnableAutomatic(bool), EnableAutomatic(bool),
} }
#[instrument] #[instrument(skip_all)]
pub async fn start_coordinator( pub async fn start_coordinator(
// Main_Event_Channel // Main_Event_Channel
mec: Receiver<ApplicationEvent>, mec: Receiver<ApplicationEvent>,

View file

@ -23,7 +23,7 @@ use super::{
SocketState, SocketState,
}; };
#[instrument] #[instrument(skip_all)]
pub async fn remote_video_loop( pub async fn remote_video_loop(
conn_string: String, conn_string: String,
appsink: Arc<Mutex<AppSink>>, appsink: Arc<Mutex<AppSink>>,

View file

@ -35,7 +35,7 @@ impl FilterFn for UnknownSlayer {
} }
} }
#[tracing::instrument] #[tracing::instrument(skip(tx))]
pub async fn joystick_loop(tx: Sender<ApplicationEvent>, is_alive: Arc<AtomicBool>) { pub async fn joystick_loop(tx: Sender<ApplicationEvent>, is_alive: Arc<AtomicBool>) {
let mut gilrs = GilrsBuilder::new().set_update_state(false).build().unwrap(); let mut gilrs = GilrsBuilder::new().set_update_state(false).build().unwrap();

View file

@ -37,7 +37,7 @@ pub struct TrackerState {
pub identity_boxes: Vec<NormalizedBoxCoords>, pub identity_boxes: Vec<NormalizedBoxCoords>,
} }
#[instrument] #[instrument(skip(rt, mec))]
pub async fn start_socketserver( pub async fn start_socketserver(
rt: Handle, rt: Handle,
mec: Sender<ApplicationEvent>, mec: Sender<ApplicationEvent>,
@ -70,7 +70,7 @@ pub async fn start_socketserver(
connection_state.is_connected.store(false, Ordering::SeqCst); connection_state.is_connected.store(false, Ordering::SeqCst);
} }
#[instrument] #[instrument(skip(stream, mec))]
async fn accept_connection( async fn accept_connection(
peer: SocketAddr, peer: SocketAddr,
stream: TcpStream, stream: TcpStream,
@ -85,7 +85,7 @@ async fn accept_connection(
} }
} }
#[instrument] #[instrument(skip(stream, mec))]
async fn handle_connection( async fn handle_connection(
peer: SocketAddr, peer: SocketAddr,
stream: TcpStream, stream: TcpStream,