Merge pull request #965 from sozu-proxy/devel/fdubois/issue/956

fix: update `start_tcp_worker` to use `TCPListen` variant of `Protocol` enum
sozu-proxy · Jul 11, 2023 · eadcc04 · eadcc04
2 parents 16c7399 + 97034bd
commit eadcc04
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/lib/src/tcp.rs b/lib/src/tcp.rs
@@ -1534,29 +1534,29 @@ pub fn start_tcp_worker(
         let entry = sessions.vacant_entry();
         info!("taking token {:?} for channel", entry.key());
         entry.insert(Rc::new(RefCell::new(ListenSession {
-            protocol: Protocol::HTTPListen,
+            protocol: Protocol::TCPListen,
         })));
     }
     {
         let entry = sessions.vacant_entry();
         info!("taking token {:?} for timer", entry.key());
         entry.insert(Rc::new(RefCell::new(ListenSession {
-            protocol: Protocol::HTTPListen,
+            protocol: Protocol::TCPListen,
         })));
     }
     {
         let entry = sessions.vacant_entry();
         info!("taking token {:?} for metrics", entry.key());
         entry.insert(Rc::new(RefCell::new(ListenSession {
-            protocol: Protocol::HTTPListen,
+            protocol: Protocol::TCPListen,
         })));
     }
 
     let token = {
         let entry = sessions.vacant_entry();
         let key = entry.key();
         let _e = entry.insert(Rc::new(RefCell::new(ListenSession {
-            protocol: Protocol::HTTPListen,
+            protocol: Protocol::TCPListen,
         })));
         Token(key)
     };