diff options
Diffstat (limited to 'tokio/src/process/unix/mod.rs')
-rw-r--r-- | tokio/src/process/unix/mod.rs | 30 |
1 files changed, 16 insertions, 14 deletions
diff --git a/tokio/src/process/unix/mod.rs b/tokio/src/process/unix/mod.rs index dfb69f21..72f6f0bf 100644 --- a/tokio/src/process/unix/mod.rs +++ b/tokio/src/process/unix/mod.rs @@ -22,14 +22,16 @@ //! bad in theory... mod orphan; +use orphan::{OrphanQueue, OrphanQueueImpl, Wait}; + mod reap; +use reap::Reaper; -use self::orphan::{OrphanQueue, OrphanQueueImpl, Wait}; -use self::reap::Reaper; -use super::SpawnedChild; use crate::net::util::PollEvented; use crate::process::kill::Kill; +use crate::process::SpawnedChild; use crate::signal::unix::{signal, Signal, SignalKind}; + use mio::event::Evented; use mio::unix::{EventedFd, UnixReady}; use mio::{Poll as MioPoll, PollOpt, Ready, Token}; @@ -38,11 +40,11 @@ use std::future::Future; use std::io; use std::os::unix::io::{AsRawFd, RawFd}; use std::pin::Pin; -use std::process::{self, ExitStatus}; +use std::process::ExitStatus; use std::task::Context; use std::task::Poll; -impl Wait for process::Child { +impl Wait for std::process::Child { fn id(&self) -> u32 { self.id() } @@ -52,14 +54,14 @@ impl Wait for process::Child { } } -impl Kill for process::Child { +impl Kill for std::process::Child { fn kill(&mut self) -> io::Result<()> { self.kill() } } lazy_static::lazy_static! { - static ref ORPHAN_QUEUE: OrphanQueueImpl<process::Child> = OrphanQueueImpl::new(); + static ref ORPHAN_QUEUE: OrphanQueueImpl<std::process::Child> = OrphanQueueImpl::new(); } struct GlobalOrphanQueue; @@ -70,8 +72,8 @@ impl fmt::Debug for GlobalOrphanQueue { } } -impl OrphanQueue<process::Child> for GlobalOrphanQueue { - fn push_orphan(&self, orphan: process::Child) { +impl OrphanQueue<std::process::Child> for GlobalOrphanQueue { + fn push_orphan(&self, orphan: std::process::Child) { ORPHAN_QUEUE.push_orphan(orphan) } @@ -82,7 +84,7 @@ impl OrphanQueue<process::Child> for GlobalOrphanQueue { #[must_use = "futures do nothing unless polled"] pub(crate) struct Child { - inner: Reaper<process::Child, GlobalOrphanQueue, Signal>, + inner: Reaper<std::process::Child, GlobalOrphanQueue, Signal>, } impl fmt::Debug for Child { @@ -93,7 +95,7 @@ impl fmt::Debug for Child { } } -pub(crate) fn spawn_child(cmd: &mut process::Command) -> io::Result<SpawnedChild> { +pub(crate) fn spawn_child(cmd: &mut std::process::Command) -> io::Result<SpawnedChild> { let mut child = cmd.spawn()?; let stdin = stdio(child.stdin.take())?; let stdout = stdio(child.stdout.take())?; @@ -196,9 +198,9 @@ where } } -pub(crate) type ChildStdin = PollEvented<Fd<process::ChildStdin>>; -pub(crate) type ChildStdout = PollEvented<Fd<process::ChildStdout>>; -pub(crate) type ChildStderr = PollEvented<Fd<process::ChildStderr>>; +pub(crate) type ChildStdin = PollEvented<Fd<std::process::ChildStdin>>; +pub(crate) type ChildStdout = PollEvented<Fd<std::process::ChildStdout>>; +pub(crate) type ChildStderr = PollEvented<Fd<std::process::ChildStderr>>; fn stdio<T>(option: Option<T>) -> io::Result<Option<PollEvented<Fd<T>>>> where |