debug

Signed-off-by: Eloi DEMOLIS <[email protected]>
sozu-proxy · Oct 20, 2023 · f362837 · f362837
1 parent 7d3662c
commit f362837
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 5 deletions.
diff --git 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
@@ -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;
                 }