fix: limit linger to 5s

Author: 0x416e746f6e

crates/rproxy/src/server/metrics.rs

@@ -341,15 +341,15 @@ impl Metrics {
         socket.set_nonblocking(true)?;
 
         // allow time to flush buffers on close
-        socket.set_linger(Some(Duration::from_secs(1)))?;
+        socket.set_linger(Some(Duration::from_millis(5000)))?;
 
         // allow binding to the socket while there are still TIME_WAIT connections
         socket.set_reuse_address(true)?;
 
         socket.set_tcp_keepalive(
             &TcpKeepalive::new()
-                .with_time(Duration::from_secs(15))
-                .with_interval(Duration::from_secs(15))
+                .with_time(Duration::from_millis(15000))
+                .with_interval(Duration::from_millis(15000))
                 .with_retries(4),
         )?;
 

crates/rproxy/src/server/proxy/circuit_breaker.rs

@@ -51,7 +51,7 @@ impl CircuitBreaker {
 
     #[inline]
     fn timeout(config: &ConfigCircuitBreaker) -> Duration {
-        std::cmp::min(Duration::from_secs(5), config.poll_interval * 3 / 4)
+        std::cmp::min(Duration::from_millis(5000), config.poll_interval * 3 / 4)
     }
 
     #[inline]

crates/rproxy/src/server/proxy/http/authrpc.rs

@@ -36,7 +36,7 @@ impl ProxyHttpInner<ConfigAuthrpc> for ProxyHttpInnerAuthrpc {
         Self {
             config,
             fcu_cache: Cache::builder()
-                .time_to_live(Duration::from_secs(60))
+                .time_to_live(Duration::from_millis(60000))
                 .max_capacity(4096)
                 .build_with_hasher(FxBuildHasher),
         }

crates/rproxy/src/server/proxy/http/proxy.rs

@@ -311,7 +311,7 @@ where
         socket.set_nonblocking(true)?;
 
         // allow time to flush buffers on close
-        socket.set_linger(Some(config.backend_timeout()))?;
+        socket.set_linger(Some(Duration::from_millis(5000)))?;
 
         // allow binding while there are still residual connections in TIME_WAIT
         socket.set_reuse_address(true)?;

crates/rproxy/src/server/proxy/ws/proxy.rs

@@ -229,7 +229,7 @@ where
         socket.set_nonblocking(true)?;
 
         // allow time to flush buffers on close
-        socket.set_linger(Some(config.backend_timeout()))?;
+        socket.set_linger(Some(Duration::from_millis(5000)))?;
 
         // allow binding to the socket while there are still TIME_WAIT connections
         socket.set_reuse_address(true)?;
@@ -686,7 +686,8 @@ where
             "Starting websocket pump..."
         );
 
-        let mut heartbeat = tokio::time::interval(Duration::from_secs(WS_PING_INTERVAL_SECONDS));
+        let mut heartbeat =
+            tokio::time::interval(Duration::from_millis(WS_PING_INTERVAL_SECONDS * 1000));
 
         let mut pumping: Result<(), &str> = Ok(());