Supports configuration of all TCP Keepalive parameters

examples/configure_addr_incoming.rs

@@ -15,6 +15,8 @@ async fn main() {
         .tcp_nodelay(true)
         .tcp_sleep_on_accept_errors(true)
         .tcp_keepalive(Some(Duration::from_secs(32)))
+        .tcp_keepalive_interval(Some(Duration::from_secs(1)))
+        .tcp_keepalive_retries(Some(1))
         .build();
 
     let addr = SocketAddr::from(([127, 0, 0, 1], 3000));

src/addr_incoming_config.rs

@@ -5,6 +5,8 @@ use std::time::Duration;
 pub struct AddrIncomingConfig {
     pub(crate) tcp_sleep_on_accept_errors: bool,
     pub(crate) tcp_keepalive: Option<Duration>,
+    pub(crate) tcp_keepalive_interval: Option<Duration>,
+    pub(crate) tcp_keepalive_retries: Option<u32>,
     pub(crate) tcp_nodelay: bool,
 }
 
@@ -20,6 +22,8 @@ impl AddrIncomingConfig {
         Self {
             tcp_sleep_on_accept_errors: true,
             tcp_keepalive: None,
+            tcp_keepalive_interval: None,
+            tcp_keepalive_retries: None,
             tcp_nodelay: false,
         }
     }
@@ -39,12 +43,29 @@ impl AddrIncomingConfig {
 
     /// Set how often to send TCP keepalive probes.
     ///
-    /// Default is `false`.
+    /// By default TCP keepalive probes is disabled.
     pub fn tcp_keepalive(&mut self, val: Option<Duration>) -> &mut Self {
         self.tcp_keepalive = val;
         self
     }
 
+    /// Set the duration between two successive TCP keepalive retransmissions,
+    /// if acknowledgement to the previous keepalive transmission is not received.
+    ///
+    /// Default is no interval.
+    pub fn tcp_keepalive_interval(&mut self, val: Option<Duration>) -> &mut Self {
+        self.tcp_keepalive_interval = val;
+        self
+    }
+
+    /// Set the number of retransmissions to be carried out before declaring that remote end is not available.
+    ///
+    /// Default is no retry.
+    pub fn tcp_keepalive_retries(&mut self, val: Option<u32>) -> &mut Self {
+        self.tcp_keepalive_retries = val;
+        self
+    }
+
     /// Set the value of `TCP_NODELAY` option for accepted connections.
     ///
     /// Default is `false`.

src/server.rs

@@ -241,6 +241,8 @@ async fn bind_incoming(
 
     incoming.set_sleep_on_errors(addr_incoming_conf.tcp_sleep_on_accept_errors);
     incoming.set_keepalive(addr_incoming_conf.tcp_keepalive);
+    incoming.set_keepalive_interval(addr_incoming_conf.tcp_keepalive_interval);
+    incoming.set_keepalive_retries(addr_incoming_conf.tcp_keepalive_retries);
     incoming.set_nodelay(addr_incoming_conf.tcp_nodelay);
 
     Ok(incoming)