From d5250561905395a5254434aa22e560b3a8572d75 Mon Sep 17 00:00:00 2001 From: Alexandru Vasile <60601340+lexnv@users.noreply.github.com> Date: Mon, 29 Aug 2022 16:20:35 +0300 Subject: [PATCH] core: Fix noisy logs caused by closing the `/feed` browser (#496) Signed-off-by: Alexandru Vasile Signed-off-by: Alexandru Vasile --- backend/telemetry_core/src/main.rs | 15 +++++++++++---- 1 file changed, 11 insertions(+), 4 deletions(-) diff --git a/backend/telemetry_core/src/main.rs b/backend/telemetry_core/src/main.rs index 93051ac..051bcb0 100644 --- a/backend/telemetry_core/src/main.rs +++ b/backend/telemetry_core/src/main.rs @@ -464,23 +464,30 @@ where .await { Err(_) => { - log::warn!("Closing feed websocket that was too slow to keep up (too slow to send messages)"); + log::debug!("Closing feed websocket that was too slow to keep up (too slow to send messages)"); + break 'outer; + } + Ok(Err(soketto::connection::Error::Closed)) => { break 'outer; } Ok(Err(e)) => { - log::warn!("Closing feed websocket due to error sending data: {}", e); + log::debug!("Closing feed websocket due to error sending data: {}", e); break 'outer; } Ok(_) => {} } } + match tokio::time::timeout_at(message_send_deadline, ws_send.flush()).await { Err(_) => { - log::warn!("Closing feed websocket that was too slow to keep up (too slow to flush messages)"); + log::debug!("Closing feed websocket that was too slow to keep up (too slow to flush messages)"); + break; + } + Ok(Err(soketto::connection::Error::Closed)) => { break; } Ok(Err(e)) => { - log::warn!("Closing feed websocket due to error flushing data: {}", e); + log::debug!("Closing feed websocket due to error flushing data: {}", e); break; } Ok(_) => {}