From 8b7dabd256515baf0629bace7f61d173a9cf2138 Mon Sep 17 00:00:00 2001 From: Lance-Drane Date: Mon, 30 Sep 2024 11:00:53 -0400 Subject: [PATCH] more explicit logging for broker2http SSE receivers Signed-off-by: Lance-Drane --- broker-2-http/src/routes/subscribe.rs | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/broker-2-http/src/routes/subscribe.rs b/broker-2-http/src/routes/subscribe.rs index 948a2f2..6496e41 100644 --- a/broker-2-http/src/routes/subscribe.rs +++ b/broker-2-http/src/routes/subscribe.rs @@ -34,7 +34,14 @@ fn sse_response( yield Ok(event); }, Err(e) => { - tracing::error!(error = ?e, "SSE somehow didn't get message from broadcaster"); + match e { + tokio::sync::broadcast::error::RecvError::Closed => { + tracing::error!(error = ?e, "Broadcasting pipeline to SSE somehow closed, should not see this message!") + }, + tokio::sync::broadcast::error::RecvError::Lagged(lag_count) => { + tracing::error!(error = ?e, "SSE has missed {} messages from broadcaster", lag_count) + }, + }; }, } },