yes: use tee syscall as fast-path

Author: oech3

Cargo.lock

@@ -22,7 +22,8 @@ path = "src/yes.rs"
 clap = { workspace = true }
 itertools = { workspace = true }
 fluent = { workspace = true }
-uucore = { workspace = true }
+rustix = { workspace = true, features = ["pipe"] }
+uucore = { workspace = true, features = ["pipes"] }
 
 [[bin]]
 name = "yes"

src/uu/yes/Cargo.toml

@@ -12,7 +12,14 @@ use uucore::error::{UResult, USimpleError, strip_errno};
 use uucore::format_usage;
 use uucore::translate;
 
+#[cfg(any(target_os = "linux", target_os = "android"))]
+const PAGE_SIZE: usize = 4096;
+#[cfg(any(target_os = "linux", target_os = "android"))]
+use uucore::pipes::MAX_ROOTLESS_PIPE_SIZE;
+#[cfg(any(target_os = "linux", target_os = "android"))]
+const BUF_SIZE: usize = MAX_ROOTLESS_PIPE_SIZE;
 // it's possible that using a smaller or larger buffer might provide better performance
+#[cfg(not(any(target_os = "linux", target_os = "android")))]
 const BUF_SIZE: usize = 16 * 1024;
 
 #[uucore::main]
@@ -21,9 +28,13 @@ pub fn uumain(args: impl uucore::Args) -> UResult<()> {
 
     #[allow(clippy::unwrap_used, reason = "clap provides 'y' by default")]
     let mut buffer = args_into_buffer(matches.get_many::<OsString>("STRING").unwrap())?;
-    prepare_buffer(&mut buffer);
+    #[cfg(any(target_os = "linux", target_os = "android"))]
+    let aligned = PAGE_SIZE.is_multiple_of(buffer.len());
+    #[cfg(not(any(target_os = "linux", target_os = "android")))]
+    let aligned = false;
 
-    match exec(&buffer) {
+    prepare_buffer(&mut buffer);
+    match exec(&buffer, aligned) {
         Ok(()) => Ok(()),
         // On Windows, silently handle broken pipe since there's no SIGPIPE
         #[cfg(windows)]
@@ -100,10 +111,35 @@ fn prepare_buffer(buf: &mut Vec<u8>) {
     }
 }
 
-pub fn exec(bytes: &[u8]) -> io::Result<()> {
+pub fn exec(bytes: &[u8], aligned: bool) -> io::Result<()> {
     let stdout = io::stdout();
+    #[cfg(any(target_os = "linux", target_os = "android"))]
+    {
+        use uucore::pipes::{pipe, splice, tee};
+        // don't catch any error at fast-path and fallback to write for proper message
+        if let Ok((p_read, mut p_write)) = pipe()
+            && p_write.write_all(bytes).is_ok()
+        {
+            if aligned && tee(&p_read, &stdout, PAGE_SIZE).is_ok() {
+                let _ = rustix::pipe::fcntl_setpipe_size(&stdout, MAX_ROOTLESS_PIPE_SIZE);
+                while let Ok(1..) = tee(&p_read, &stdout, usize::MAX) {}
+            } else if let Ok((broker_read, broker_write)) = pipe() {
+                // tee() cannot control offset and write to non-pipe
+                'hybrid: while let Ok(mut remain) = tee(&p_read, &broker_write, usize::MAX) {
+                    debug_assert!(remain == bytes.len(), "splice() should cleanup pipe");
+                    while remain > 0 {
+                        if let Ok(s) = splice(&broker_read, &stdout, remain) {
+                            remain -= s;
+                        } else {
+                            break 'hybrid;
+                        }
+                    }
+                }
+            }
+        }
+    }
+    let _ = aligned; // used only on Linux
     let mut stdout = stdout.lock();
-
     loop {
         stdout.write_all(bytes)?;
     }
@@ -114,6 +150,7 @@ mod tests {
     use super::*;
 
     #[test]
+    #[cfg(not(any(target_os = "linux", target_os = "android")))] // Linux uses different buffer size
     fn test_prepare_buffer() {
         let tests = [
             (150, 16350),

src/uu/yes/src/yes.rs

@@ -87,3 +87,15 @@ pub fn dev_null() -> Option<File> {
         None
     }
 }
+
+// Less noisy wrapper around [`rustix::pipe::tee`]
+#[inline]
+#[cfg(any(target_os = "linux", target_os = "android"))]
+pub fn tee(source: &impl AsFd, target: &impl AsFd, len: usize) -> std::io::Result<usize> {
+    Ok(rustix::pipe::tee(
+        source,
+        target,
+        len,
+        SpliceFlags::empty(),
+    )?)
+}

src/uucore/src/lib/features/pipes.rs

@@ -70,7 +70,7 @@ fn test_long_input() {
     #[cfg(windows)]
     const TIMES: usize = 500;
     let arg = "abcdef".repeat(TIMES) + "\n";
-    let expected_out = arg.repeat(30);
+    let expected_out = arg.repeat(5);
     run(&[&arg[..arg.len() - 1]], expected_out.as_bytes());
 }