ospab
/
ostp
mirror of https://github.com/ospab/ostp.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

chore: reduce client and server logging verbosity for outbound datagrams and relays

This commit is contained in:
ospab 2026-05-29 00:37:08 +03:00
parent 73b3b4cc02
commit bc0f739cee
2 changed files with 14 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
ostp-client/src/bridge.rs
View File

@ -614,12 +614,10 @@ impl Bridge {
Ok(ProtocolAction::SendDatagram(frame)) => {
if send_datagram(&session.socket, &frame, self.transport_mode == "udp" ).await.is_ok() {
self.metrics.bytes_sent.fetch_add(frame.len() as u64, Ordering::Relaxed);
if self.debug {
let _ = tx.send(UiEvent::Log(format!(
"Outbound datagram sent stream_id={stream_id} bytes={}",
frame.len()
))).await;
}
tracing::trace!(
"Outbound datagram sent stream_id={stream_id} bytes={}",
frame.len()
);
}
}
Ok(ProtocolAction::Multiple(list)) => {
@ -632,25 +630,19 @@ impl Bridge {
}
}
}
if self.debug {
let _ = tx.send(UiEvent::Log(format!(
"Outbound datagram batch stream_id={stream_id} sent={sent}"
))).await;
}
tracing::trace!(
"Outbound datagram batch stream_id={stream_id} sent={sent}"
);
}
Ok(ProtocolAction::Noop) => {
if self.debug {
let _ = tx.send(UiEvent::Log(format!(
"Outbound datagram noop stream_id={stream_id}"
))).await;
}
tracing::trace!(
"Outbound datagram noop stream_id={stream_id}"
);
}
Ok(_) => {
if self.debug {
let _ = tx.send(UiEvent::Log(format!(
"Outbound datagram unexpected action stream_id={stream_id}"
))).await;
}
tracing::trace!(
"Outbound datagram unexpected action stream_id={stream_id}"
);
}
Err(e) => {
tracing::warn!("Protocol error packing outbound stream_id={}: {}", stream_id, e);

4
ostp-server/src/lib.rs
View File

@ -289,8 +289,6 @@ pub async fn run_server(
|| msg.starts_with("Listening")
|| msg.starts_with("Shutdown")
|| msg.starts_with("Session ")
|| msg.starts_with("Relay CONNECT")
|| msg.starts_with("Relay CLOSE")
|| msg.starts_with("Relay error");
if debug || is_essential {
tracing::info!("{msg}");
@ -592,7 +590,7 @@ async fn run_server_loop(
let _ = ui_event_tx.send(UiEvent::Log(format!("Relay CONNECT ok for [{session_id}:{stream_id}] -> {target}")));
}
Err(err) => {
let _ = ui_event_tx.send(UiEvent::Log(format!("Relay CONNECT failed for [{session_id}:{stream_id}] -> {target}: {err}")));
let _ = ui_event_tx.send(UiEvent::Log(format!("Relay error: CONNECT failed for [{session_id}:{stream_id}] -> {target}: {err}")));
let _ = relay::send_relay_to_stream(session_id, stream_id, RelayMessage::Error(format!("connect failed: {err}")), &mut dispatcher, &socket, &ui_event_tx, &tcp_map).await;
}
}