From 2fe926431bb198a052a5eae92ff820a4f572fd92 Mon Sep 17 00:00:00 2001 From: Alex Crichton Date: Fri, 30 May 2014 17:18:12 -0700 Subject: [PATCH] std: Support consuming a Process without waiting Forking off a child which survives the parent is often a useful task, and is currently not possible because the Process type will invoke `wait()` in its destructor in order to prevent leaking resources. This function adds a new safe method, `forget`, which can be used to consume an instance of `Process` which will then not call `wait` in the destructor. This new method is clearly documented as a leak of resources, but it must be forcibly opted in to. Closes #14467 --- src/libstd/io/process.rs | 23 +++++++++++++++++++++++ 1 file changed, 23 insertions(+) diff --git a/src/libstd/io/process.rs b/src/libstd/io/process.rs index 38d8475ddf7..1dcf08b2322 100644 --- a/src/libstd/io/process.rs +++ b/src/libstd/io/process.rs @@ -59,6 +59,7 @@ /// ``` pub struct Process { handle: Box, + forget: bool, /// Handle to the child's stdin, if the `stdin` field of this process's /// `ProcessConfig` was `CreatePipe`. By default, this handle is `Some`. @@ -262,6 +263,7 @@ fn to_rtio(p: StdioContainer) -> rtio::StdioContainer { }); Process { handle: p, + forget: false, stdin: io.next().unwrap(), stdout: io.next().unwrap(), stderr: io.next().unwrap(), @@ -540,10 +542,23 @@ fn read(stream: Option) -> Receiver>> { error: stderr.recv().ok().unwrap_or(Vec::new()), }) } + + /// Forgets this process, allowing it to outlive the parent + /// + /// This function will forcefully prevent calling `wait()` on the child + /// process in the destructor, allowing the child to outlive the + /// parent. Note that this operation can easily lead to leaking the + /// resources of the child process, so care must be taken when + /// invoking this method. + pub fn forget(mut self) { + self.forget = true; + } } impl Drop for Process { fn drop(&mut self) { + if self.forget { return } + // Close all I/O before exiting to ensure that the child doesn't wait // forever to print some text or something similar. drop(self.stdin.take()); @@ -933,4 +948,12 @@ pub fn sleeper() -> Process { rx.recv(); rx.recv(); }) + + iotest!(fn forget() { + let p = sleeper(); + let id = p.id(); + p.forget(); + assert!(Process::kill(id, 0).is_ok()); + assert!(Process::kill(id, PleaseExitSignal).is_ok()); + }) } -- 2.44.0