From f362837fcda04172ce22d9ad9fb6a28e984d29f6 Mon Sep 17 00:00:00 2001
From: Eloi DEMOLIS <eloi.demolis@clever-cloud.com>
Date: Fri, 20 Oct 2023 17:24:49 +0200
Subject: [PATCH] debug

Signed-off-by: Eloi DEMOLIS <eloi.demolis@clever-cloud.com>
---
 lib/src/protocol/kawa_h1/mod.rs | 18 +++++++++++++-----
 lib/src/socket.rs               |  1 +
 2 files changed, 14 insertions(+), 5 deletions(-)

diff --git a/lib/src/protocol/kawa_h1/mod.rs b/lib/src/protocol/kawa_h1/mod.rs
index fd9f4bf7f..e590b9ec1 100644
--- a/lib/src/protocol/kawa_h1/mod.rs
+++ b/lib/src/protocol/kawa_h1/mod.rs
@@ -220,6 +220,12 @@ impl<Front: SocketHandler, L: ListenerHandler + L7ListenerHandler> Http<Front, L
         self.context.keep_alive_frontend = true;
         self.context.keep_alive_backend = true;
         self.context.sticky_session_found = None;
+        self.context.method = None;
+        self.context.authority = None;
+        self.context.path = None;
+        self.context.status = None;
+        self.context.reason = None;
+        self.context.user_agent = None;
         self.context.id = Ulid::generate();
 
         self.request_stream.clear();
@@ -782,6 +788,8 @@ impl<Front: SocketHandler, L: ListenerHandler + L7ListenerHandler> Http<Front, L
     }
     pub fn log_request_error(&mut self, metrics: &mut SessionMetrics, message: &str) {
         incr!("http.errors");
+        self.print_state("ACCESS-DEBUG");
+        warn!("=====acces_log_error:{}", message);
         self.log_request(metrics, Some(message));
     }
 
@@ -1377,12 +1385,12 @@ impl<Front: SocketHandler, L: ListenerHandler + L7ListenerHandler> Http<Front, L
             && self.backend_readiness.interest.is_readable()
         {
             // there might still data we can read on the socket
-            // println!("=====backend_hup:continue");
+            warn!("=====backend_hup:continue");
             return StateResult::Continue;
         }
         if self.response_stream.is_terminated() {
             // the backend finished to answer we can close
-            // println!("=====backend_hup:terminated");
+            warn!("=====backend_hup:terminated");
             return StateResult::CloseBackend;
         }
         match (
@@ -1391,17 +1399,17 @@ impl<Front: SocketHandler, L: ListenerHandler + L7ListenerHandler> Http<Front, L
         ) {
             // the backend started to answer so we close
             (_, false) => {
-                // println!("=====backend_hup:close");
+                warn!("=====backend_hup:close");
                 StateResult::CloseSession
             }
             // probably backend hup between keep alive request, change backend
             (true, true) => {
-                // println!("=====backend_hup:close_backend");
+                warn!("=====backend_hup:close_backend");
                 StateResult::CloseBackend
             }
             // the frontend already transmitted data so we can't redirect
             (false, true) => {
-                // println!("=====backend_hup:503");
+                warn!("=====backend_hup:503");
                 self.set_answer(DefaultAnswerStatus::Answer503, None);
                 self.backend_readiness.interest = Ready::EMPTY;
                 StateResult::Continue
diff --git a/lib/src/socket.rs b/lib/src/socket.rs
index b1e6a6edf..2ea69cb8d 100644
--- a/lib/src/socket.rs
+++ b/lib/src/socket.rs
@@ -183,6 +183,7 @@ impl SocketHandler for FrontRustls {
 
             match self.session.read_tls(&mut self.stream) {
                 Ok(0) => {
+                    warn!("=====read_tls:OK(0)");
                     can_read = false;
                     is_closed = true;
                 }