impl Clone for UnixClock

src/unix.rs

@@ -437,6 +437,21 @@ impl Drop for UnixClock {
     }
 }
 
+impl Clone for UnixClock {
+    fn clone(&self) -> Self {
+        match self.fd {
+            Some(fd) => {
+                let new_fd = unsafe { libc::dup(fd) };
+                Self::safe_from_raw_fd(new_fd)
+            }
+            None => {
+                let clock = self.clock;
+                Self { clock, fd: None }
+            }
+        }
+    }
+}
+
 impl FromRawFd for UnixClock {
     unsafe fn from_raw_fd(fd: RawFd) -> Self {
         Self::safe_from_raw_fd(fd)
@@ -870,4 +885,38 @@ mod tests {
 
         assert_ne!(resolution, Timestamp::default());
     }
+
+    #[cfg(target_os = "linux")]
+    fn is_valid_fd(fd: RawFd) -> bool {
+        let flags = unsafe { libc::fcntl(fd, libc::F_GETFD) };
+
+        // fd is valid if its flags are not -1
+        flags != -1
+    }
+
+    #[test]
+    #[cfg(target_os = "linux")]
+    fn test_clone_and_drop() {
+        use std::fs::File;
+
+        // make some fd that we can open
+        let path = std::env::temp_dir().join("clock-steering-test-clock");
+        File::create(&path).unwrap();
+
+        let clock = UnixClock::open(&path).unwrap();
+        let original_fd = clock.fd.unwrap();
+
+        let new_clock = clock.clone();
+        let new_fd = new_clock.fd.unwrap();
+
+        assert_ne!(original_fd, new_fd);
+
+        assert!(is_valid_fd(original_fd));
+        drop(clock);
+        assert!(!is_valid_fd(original_fd));
+
+        assert!(is_valid_fd(new_fd));
+        drop(new_clock);
+        assert!(!is_valid_fd(new_fd));
+    }
 }