diff --git a/std/src/process.rs b/std/src/process.rs index 1ff7bba85..17aff342c 100644 --- a/std/src/process.rs +++ b/std/src/process.rs @@ -911,10 +911,8 @@ impl Command { /// ``` #[stable(feature = "process", since = "1.0.0")] pub fn output(&mut self) -> io::Result { - self.inner - .spawn(imp::Stdio::MakePipe, false) - .map(Child::from_inner) - .and_then(|p| p.wait_with_output()) + let (status, stdout, stderr) = self.inner.output()?; + Ok(Output { status: ExitStatus(status), stdout, stderr }) } /// Executes a command as a child process, waiting for it to finish and diff --git a/std/src/sys/unix/process/process_fuchsia.rs b/std/src/sys/unix/process/process_fuchsia.rs index 66ea3db20..4c99d758c 100644 --- a/std/src/sys/unix/process/process_fuchsia.rs +++ b/std/src/sys/unix/process/process_fuchsia.rs @@ -35,6 +35,11 @@ impl Command { Ok((Process { handle: Handle::new(process_handle) }, ours)) } + pub fn output(&mut self) -> io::Result<(ExitStatus, Vec, Vec)> { + let (proc, pipes) = self.spawn(Stdio::MakePipe, false)?; + crate::sys_common::process::wait_with_output(proc, pipes) + } + pub fn exec(&mut self, default: Stdio) -> io::Error { if self.saw_nul() { return io::const_io_error!( diff --git a/std/src/sys/unix/process/process_unix.rs b/std/src/sys/unix/process/process_unix.rs index 56a805cef..45616850a 100644 --- a/std/src/sys/unix/process/process_unix.rs +++ b/std/src/sys/unix/process/process_unix.rs @@ -132,6 +132,11 @@ impl Command { } } + pub fn output(&mut self) -> io::Result<(ExitStatus, Vec, Vec)> { + let (proc, pipes) = self.spawn(Stdio::MakePipe, false)?; + crate::sys_common::process::wait_with_output(proc, pipes) + } + // Attempts to fork the process. If successful, returns Ok((0, -1)) // in the child, and Ok((child_pid, -1)) in the parent. #[cfg(not(target_os = "linux"))] diff --git a/std/src/sys/unix/process/process_unsupported.rs b/std/src/sys/unix/process/process_unsupported.rs index 72f9f3f9c..f28ca58d0 100644 --- a/std/src/sys/unix/process/process_unsupported.rs +++ b/std/src/sys/unix/process/process_unsupported.rs @@ -20,6 +20,10 @@ impl Command { unsupported() } + pub fn output(&mut self) -> io::Result<(ExitStatus, Vec, Vec)> { + unsupported() + } + pub fn exec(&mut self, _default: Stdio) -> io::Error { unsupported_err() } diff --git a/std/src/sys/unix/process/process_vxworks.rs b/std/src/sys/unix/process/process_vxworks.rs index 200ef6719..f549d37c3 100644 --- a/std/src/sys/unix/process/process_vxworks.rs +++ b/std/src/sys/unix/process/process_vxworks.rs @@ -108,6 +108,11 @@ impl Command { } } + pub fn output(&mut self) -> io::Result<(ExitStatus, Vec, Vec)> { + let (proc, pipes) = self.spawn(Stdio::MakePipe, false)?; + crate::sys_common::process::wait_with_output(proc, pipes) + } + pub fn exec(&mut self, default: Stdio) -> io::Error { let ret = Command::spawn(self, default, false); match ret { diff --git a/std/src/sys/unsupported/pipe.rs b/std/src/sys/unsupported/pipe.rs index 75ce75467..0bba673b4 100644 --- a/std/src/sys/unsupported/pipe.rs +++ b/std/src/sys/unsupported/pipe.rs @@ -15,7 +15,7 @@ impl AnonPipe { self.0 } - pub fn read_to_end(&self, buf: &mut Vec) -> io::Result { + pub fn read_to_end(&self, _buf: &mut Vec) -> io::Result { self.0 } diff --git a/std/src/sys/unsupported/process.rs b/std/src/sys/unsupported/process.rs index 633f17c05..a494f2d6b 100644 --- a/std/src/sys/unsupported/process.rs +++ b/std/src/sys/unsupported/process.rs @@ -75,6 +75,10 @@ impl Command { ) -> io::Result<(Process, StdioPipes)> { unsupported() } + + pub fn output(&mut self) -> io::Result<(ExitStatus, Vec, Vec)> { + unsupported() + } } impl From for Stdio { diff --git a/std/src/sys/windows/process.rs b/std/src/sys/windows/process.rs index 31e9b34fb..10bc949e1 100644 --- a/std/src/sys/windows/process.rs +++ b/std/src/sys/windows/process.rs @@ -351,6 +351,11 @@ impl Command { )) } } + + pub fn output(&mut self) -> io::Result<(ExitStatus, Vec, Vec)> { + let (proc, pipes) = self.spawn(Stdio::MakePipe, false)?; + crate::sys_common::process::wait_with_output(proc, pipes) + } } impl fmt::Debug for Command { diff --git a/std/src/sys_common/process.rs b/std/src/sys_common/process.rs index 9f978789a..ae1141206 100644 --- a/std/src/sys_common/process.rs +++ b/std/src/sys_common/process.rs @@ -4,7 +4,9 @@ use crate::collections::BTreeMap; use crate::env; use crate::ffi::{OsStr, OsString}; -use crate::sys::process::EnvKey; +use crate::io; +use crate::sys::pipe::read2; +use crate::sys::process::{EnvKey, ExitStatus, Process, StdioPipes}; // Stores a set of changes to an environment #[derive(Clone, Debug)] @@ -117,3 +119,30 @@ impl<'a> ExactSizeIterator for CommandEnvs<'a> { self.iter.is_empty() } } + +pub fn wait_with_output( + mut process: Process, + mut pipes: StdioPipes, +) -> io::Result<(ExitStatus, Vec, Vec)> { + drop(pipes.stdin.take()); + + let (mut stdout, mut stderr) = (Vec::new(), Vec::new()); + match (pipes.stdout.take(), pipes.stderr.take()) { + (None, None) => {} + (Some(out), None) => { + let res = out.read_to_end(&mut stdout); + res.unwrap(); + } + (None, Some(err)) => { + let res = err.read_to_end(&mut stderr); + res.unwrap(); + } + (Some(out), Some(err)) => { + let res = read2(out, &mut stdout, err, &mut stderr); + res.unwrap(); + } + } + + let status = process.wait()?; + Ok((status, stdout, stderr)) +}