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

Downgrade UoT and unauthorized probe logs to debug

This commit is contained in:
ospab 2026-06-25 21:24:29 +03:00
parent 9da23b2a4d
commit 1151726415
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -380,14 +380,14 @@ pub async fn run_server(
.unwrap_or(std::time::Duration::MAX); .unwrap_or(std::time::Duration::MAX);
if elapsed >= std::time::Duration::from_secs(30) { if elapsed >= std::time::Duration::from_secs(30) {
if probe_suppressed > 0 { if probe_suppressed > 0 {
tracing::warn!( tracing::debug!(
"(+{} more unauthorized probes suppressed in the previous ~30s)", "(+{} more unauthorized probes suppressed in the previous ~30s)",
probe_suppressed probe_suppressed
); );
} }
probe_window_start = Some(now); probe_window_start = Some(now);
probe_suppressed = 0; probe_suppressed = 0;
tracing::warn!("Unauthorized probe from {peer} ({bytes} bytes): {reason}"); tracing::debug!("Unauthorized probe from {peer} ({bytes} bytes): {reason}");
} else { } else {
probe_suppressed += 1; probe_suppressed += 1;
} }

4
ostp-server/src/transport/uot.rs
View File

@ -16,7 +16,7 @@ pub async fn handle_tcp_connection<S>(
where where
S: tokio::io::AsyncRead + tokio::io::AsyncWrite + Unpin + Send + 'static, S: tokio::io::AsyncRead + tokio::io::AsyncWrite + Unpin + Send + 'static,
{ {
info!("UoT client connected from {}", peer_addr); tracing::debug!("UoT client connected from {}", peer_addr);
// Register this connection in the map // Register this connection in the map
let (tx, mut rx) = mpsc::channel::<Bytes>(16384); let (tx, mut rx) = mpsc::channel::<Bytes>(16384);
@ -54,6 +54,6 @@ where
}); });
let _ = tokio::join!(writer_task, reader_task); let _ = tokio::join!(writer_task, reader_task);
info!("UoT client disconnected: {}", peer_addr); tracing::debug!("UoT client disconnected: {}", peer_addr);
Ok(()) Ok(())
} }