fix: update start_tcp_worker to use TCPListen variant of `Protoco…

…l` enum Signed-off-by: Florentin Dubois <[email protected]>
sozu-proxy · Jul 11, 2023 · 97034bd · 97034bd
1 parent 16c7399
commit 97034bd
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)
     };