Issue: #523

src/sys/unix.rs

@@ -1618,6 +1618,68 @@ impl crate::Socket {
         }
     }
 
+    /// Get the value of the `SO_RCVLOWAT` option on this socket.
+    ///
+    /// For more information about this option, see [`set_rcv_lowat`].
+    ///
+    /// [`set_rcv_lowat`]: crate::Socket::set_rcv_lowat
+    // TODO: add Redox support, but I'm not sure if Redox supports SO_RCVLOWAT
+    #[cfg(all(feature = "all", not(target_os = "redox")))]
+    pub fn rcv_lowat(&self) -> io::Result<u32> {
+        unsafe {
+            getsockopt::<c_int>(self.as_raw(), libc::SOL_SOCKET, libc::SO_RCVLOWAT)
+                .map(|rcv_lowat| { rcv_lowat as u32})
+        }
+    }
+
+    /// Set the value of the `SO_RCVLOWAT` option on this socket.
+    ///
+    /// This option sets the minimum number of bytes that must be available in the
+    /// receive buffer before a recv() or read() call will return.
+    // TODO: add Redox support, but I'm not sure if Redox supports SO_RCVLOWAT
+    #[cfg(all(feature = "all", not(target_os = "redox")))]
+    pub fn set_rcv_lowat(&self, rcv_lowat: u32) -> io::Result<()> {
+        unsafe {
+            setsockopt::<c_int>(
+                self.as_raw(),
+                libc::SOL_SOCKET,
+                libc::SO_RCVLOWAT,
+                rcv_lowat as c_int,
+            )
+        }
+    }
+
+    /// Get the value of the `SO_SNDLOWAT` option on this socket.
+    ///
+    /// For more information about this option, see [`set_snd_lowat`].
+    ///
+    /// [`set_snd_lowat`]: crate::Socket::set_snd_lowat
+    // TODO: add Redox support, but I'm not sure if Redox supports SO_SNDLOWAT
+    #[cfg(all(feature = "all", not(target_os = "redox")))]
+    pub fn snd_lowat(&self) -> io::Result<u32> {
+        unsafe {
+            getsockopt::<c_int>(self.as_raw(), libc::SOL_SOCKET, libc::SO_RCVLOWAT)
+                .map(|snd_lowat| { snd_lowat as u32})
+        }
+    }
+
+    /// Set the value of the `SO_SNDLOWAT` option on this socket.
+    ///
+    /// This option sets the minimum number of bytes that must be available in the send buffer
+    /// before a send() or write() call will return.
+    // TODO: add Redox support, but I'm not sure if Redox supports SO_SNDLOWAT
+    #[cfg(all(feature = "all", not(target_os = "redox")))]
+    pub fn set_snd_lowat(&self, snd_lowat: u32) -> io::Result<()> {
+        unsafe {
+            setsockopt::<c_int>(
+                self.as_raw(),
+                libc::SOL_SOCKET,
+                libc::SO_RCVLOWAT,
+                snd_lowat as c_int,
+            )
+        }
+    }
+
     /// Gets the value of the `TCP_MAXSEG` option on this socket.
     ///
     /// For more information about this option, see [`set_mss`].