From 61193feeace86f2af39fcd8c9d77b7dcee132292 Mon Sep 17 00:00:00 2001 From: Yury-Fridlyand Date: Mon, 22 Jan 2024 14:39:51 -0800 Subject: [PATCH] Experiment Signed-off-by: Yury-Fridlyand --- glide-core/src/socket_listener.rs | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) diff --git a/glide-core/src/socket_listener.rs b/glide-core/src/socket_listener.rs index 7d5ceab1bf..7d931b0213 100644 --- a/glide-core/src/socket_listener.rs +++ b/glide-core/src/socket_listener.rs @@ -604,9 +604,20 @@ async fn listen_on_client_stream(socket: UnixStream) { let _res = write_closing_error(ClosingError { err_message }, u32::MAX, &writer).await; return; } - Err(e @ ClientCreationError::UnhandledError(_)) - | Err(e @ ClientCreationError::IO(_)) - | Err(e @ ClientCreationError::ConnectionError(_)) => { + Err(e @ ClientCreationError::UnhandledError(_)) => { + log_error("ClientCreationError - UnhandledError", format!("{:?}", e)); + let err_message = e.to_string(); + let _res = write_closing_error(ClosingError { err_message }, u32::MAX, &writer).await; + return; + } + Err(e @ ClientCreationError::IO(_)) => { + log_error("ClientCreationError - IO", format!("{:?}", e)); + let err_message = e.to_string(); + let _res = write_closing_error(ClosingError { err_message }, u32::MAX, &writer).await; + return; + } + Err(e @ ClientCreationError::ConnectionError(_)) => { + log_error("ClientCreationError - ConnectionError", format!("{:?}", e)); let err_message = e.to_string(); let _res = write_closing_error(ClosingError { err_message }, u32::MAX, &writer).await; return; @@ -615,6 +626,7 @@ async fn listen_on_client_stream(socket: UnixStream) { log_info("connection", "new connection started"); tokio::select! { reader_closing = read_values_loop(client_listener, &client, writer.clone()) => { + log_error("reader_closing", "BOOM"); if let ClosingReason::UnhandledError(err) = reader_closing { let _res = write_closing_error(ClosingError{err_message: err.to_string()}, u32::MAX, &writer).await; };