diff --git a/glide-core/src/socket_listener.rs b/glide-core/src/socket_listener.rs index edaee7187c..a48d517fbf 100644 --- a/glide-core/src/socket_listener.rs +++ b/glide-core/src/socket_listener.rs @@ -621,20 +621,9 @@ async fn listen_on_client_stream(socket: UnixStream) { .await; return; } - 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)); + Err(e @ ClientCreationError::UnhandledError(_)) + | Err(e @ ClientCreationError::IO(_)) + | Err(e @ ClientCreationError::ConnectionError(_)) => { let err_message = e.to_string(); log_error("client creation", &err_message); let _res = write_closing_error( @@ -650,7 +639,6 @@ 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, "client closing").await; };