Experiment

Signed-off-by: Yury-Fridlyand <[email protected]>
Bit-Quill · Jan 22, 2024 · 61193fe · 61193fe
1 parent ada0187
commit 61193fe
Showing 1 changed file with 15 additions and 3 deletions.
diff --git 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;
                 };