Port to OpenBSD

Author: Thomasdezeeuw

.github/workflows/ci.yaml

@@ -65,6 +65,7 @@ jobs:
         - aarch64-apple-tvos
         - aarch64-apple-visionos
         - aarch64-apple-watchos
+        - x86_64-unknown-openbsd
     steps:
     - uses: actions/checkout@v6
     - uses: Swatinem/rust-cache@v2

Cargo.toml

@@ -20,7 +20,7 @@ default = []
 nightly = []
 
 [dependencies]
-libc         = { version = "0.2.179", default-features = false }
+libc         = { version = "0.2.181", default-features = false }
 log          = { version = "0.4.21",  default-features = false, features = ["kv_std"] }
 
 [dev-dependencies]

src/kqueue/fs.rs

@@ -28,7 +28,7 @@ impl DirectOp for OpenOp {
 impl DirectOpExtract for OpenOp {
     type ExtractOutput = (AsyncFd, PathBuf);
 
-    #[allow(clippy::cast_lossless)]
+    #[allow(clippy::cast_lossless, clippy::cast_possible_wrap)]
     fn run_extract(
         sq: &SubmissionQueue,
         (path, kind): Self::Resources,
@@ -276,7 +276,7 @@ impl_fd_op!(TruncateOp);
 pub(crate) use libc::stat as Stat;
 
 pub(crate) const fn file_type(stat: &Stat) -> FileType {
-    FileType(stat.st_mode)
+    FileType(stat.st_mode as u16)
 }
 
 pub(crate) const fn len(stat: &Stat) -> u64 {
@@ -288,7 +288,7 @@ pub(crate) const fn block_size(stat: &Stat) -> u32 {
 }
 
 pub(crate) const fn permissions(stat: &Stat) -> Permissions {
-    Permissions(stat.st_mode)
+    Permissions(stat.st_mode as u16)
 }
 
 pub(crate) fn modified(stat: &Stat) -> SystemTime {

src/kqueue/process.rs

@@ -56,7 +56,11 @@ impl crate::op::Op for WaitIdOp {
                 let options = options.0.cast_signed() | libc::WNOHANG; // Don't block.
                 syscall!(waitid(id_type, pid.into(), &raw mut info.0, options))?;
 
-                if info.0.si_pid == 0 {
+                #[cfg(not(target_os = "openbsd"))]
+                let pid = info.0.si_pid;
+                #[cfg(target_os = "openbsd")]
+                let pid = unsafe { info.0.si_pid() };
+                if pid == 0 {
                     // Got polled without the process stopping, will have to
                     // wait again.
                     Poll::Pending
@@ -134,7 +138,7 @@ fn sigaction(signals: &SignalSet, action: libc::sighandler_t) -> io::Result<()>
         target_os = "watchos",
     ))]
     let sa_mask = 0;
-    #[cfg(target_os = "freebsd")]
+    #[cfg(any(target_os = "freebsd", target_os = "openbsd"))]
     let sa_mask = SignalSet::empty()?.0;
 
     let action = libc::sigaction {

src/net.rs

@@ -51,7 +51,7 @@ new_flag!(
         #[cfg(any(target_os = "android", target_os = "linux"))]
         PACKET = libc::AF_PACKET,
         /// Domain for low-level VSOCK interface.
-        #[cfg(not(target_os = "freebsd"))]
+        #[cfg(not(any(target_os = "freebsd", target_os = "openbsd")))]
         VSOCK = libc::AF_VSOCK,
     }
 
@@ -95,6 +95,7 @@ new_flag!(
         #[cfg(any(target_os = "android", target_os = "freebsd", target_os = "linux"))]
         DCCP = libc::IPPROTO_DCCP,
         /// Stream Control Transport Protocol.
+        #[cfg(not(target_os = "openbsd"))]
         SCTP = libc::IPPROTO_SCTP,
         /// UDP-Lite.
         #[cfg(any(target_os = "android", target_os = "freebsd", target_os = "linux"))]
@@ -628,17 +629,20 @@ new_flag!(
         ADD_MEMBERSHIP = libc::IP_ADD_MEMBERSHIP,
         /// Join a multicast group and allow receiving data only from a
         /// specified source.
+        #[cfg(not(target_os = "openbsd"))]
         ADD_SOURCE_MEMBERSHIP = libc::IP_ADD_SOURCE_MEMBERSHIP,
         /// Do not reserve an ephemeral port when using `bind(2)` with a port
         /// number of 0.
         #[cfg(any(target_os = "android", target_os = "linux"))]
         BIND_ADDRESS_NO_PORT = libc::IP_BIND_ADDRESS_NO_PORT,
         /// Stop receiving multicast data from a specific source in a given
         /// group.
+        #[cfg(not(target_os = "openbsd"))]
         BLOCK_SOURCE = libc::IP_BLOCK_SOURCE,
         /// Leave a multicast group.
         DROP_MEMBERSHIP = libc::IP_DROP_MEMBERSHIP,
         /// Leave a source-specific group.
+        #[cfg(not(target_os = "openbsd"))]
         DROP_SOURCE_MEMBERSHIP = libc::IP_DROP_SOURCE_MEMBERSHIP,
         /// Allow binding to an IP address that is nonlocal or does not (yet)
         /// exist.
@@ -679,7 +683,7 @@ new_flag!(
         #[cfg(any(target_os = "android", target_os = "linux"))]
         PASS_SEC = libc::IP_PASSSEC,
         /// Collect information about this socket.
-        #[cfg(not(target_os = "freebsd"))]
+        #[cfg(not(any(target_os = "freebsd", target_os = "openbsd")))]
         PKT_INFO = libc::IP_PKTINFO,
         /// Enable extended reliable error message passing.
         #[cfg(any(target_os = "android", target_os = "linux"))]
@@ -693,9 +697,11 @@ new_flag!(
         RECV_ORIG_DST_ADDR = libc::IP_RECVORIGDSTADDR,
         /// Enable passing of `IP_TOS` in ancillary message with incoming
         /// packets.
+        #[cfg(not(target_os = "openbsd"))]
         RECV_TOS = libc::IP_RECVTOS,
         /// Enable passing of `IP_TTL` in ancillary message with incoming
         /// packets.
+        #[cfg(not(target_os = "openbsd"))]
         RECV_TTL = libc::IP_RECVTTL,
         /// Identical to [`IPv4Opt::RECV_OPTS`], but returns raw unprocessed
         /// options with timestamp and route record options not filled in for
@@ -716,6 +722,7 @@ new_flag!(
         /// this socket.
         TTL = libc::IP_TTL,
         /// Unblock previously blocked multicast source.
+        #[cfg(not(target_os = "openbsd"))]
         UNBLOCK_SOURCE = libc::IP_UNBLOCK_SOURCE,
     }
 
@@ -765,6 +772,7 @@ new_flag!(
         #[cfg(any(target_os = "android", target_os = "linux"))]
         FLOW_INFO = libc::IPV6_FLOWINFO,
         /// Set hop limit.
+        #[cfg(not(target_os = "openbsd"))]
         HOP_LIMIT = libc::IPV6_HOPLIMIT,
         /// Control receiving of asynchronous error options.
         #[cfg(any(target_os = "android", target_os = "linux"))]
@@ -799,12 +807,14 @@ new_flag!(
         INFO = libc::TCP_INFO,
         /// The maximum number of keepalive probes TCP should send before
         /// dropping the connection.
+        #[cfg(not(target_os = "openbsd"))]
         KEEP_CNT = libc::TCP_KEEPCNT,
         /// The time (in seconds) the connection needs to remain idle before TCP
         /// starts sending keepalive probes.
         #[cfg(any(target_os = "android", target_os = "freebsd", target_os = "linux"))]
         KEEP_IDLE = libc::TCP_KEEPIDLE,
         /// The time (in seconds) between individual keepalive probes.
+        #[cfg(not(target_os = "openbsd"))]
         KEEP_INTVL = libc::TCP_KEEPINTVL,
         /// The lifetime of orphaned FIN_WAIT2 state sockets.
         #[cfg(any(target_os = "android", target_os = "linux"))]
@@ -829,6 +839,7 @@ new_flag!(
         #[cfg(any(target_os = "android", target_os = "linux"))]
         WINDOW_CLAMP = libc::TCP_WINDOW_CLAMP,
         /// This option enables Fast Open on the listener socket.
+        #[cfg(not(target_os = "openbsd"))]
         FASTOPEN = libc::TCP_FASTOPEN,
         /// This option enables an alternative way to perform Fast Open on the
         /// client side.