aboutsummaryrefslogtreecommitdiff
path: root/ctr-std/src/sys/unix/process/process_fuchsia.rs
diff options
context:
space:
mode:
authorVivian Lim <[email protected]>2021-02-06 22:11:59 -0800
committerVivian Lim <[email protected]>2021-02-06 22:11:59 -0800
commit64423f0e34cc4a7d78c15b345b3b8f58243d8286 (patch)
treecc20e2e7f0fc35abf470e20e61d3d48f0d954f3b /ctr-std/src/sys/unix/process/process_fuchsia.rs
parentSupport libctru 2.0 (diff)
downloadctru-rs-64423f0e34cc4a7d78c15b345b3b8f58243d8286.tar.xz
ctru-rs-64423f0e34cc4a7d78c15b345b3b8f58243d8286.zip
Delete ctr-std to use my fork of the rust repo instead
Diffstat (limited to 'ctr-std/src/sys/unix/process/process_fuchsia.rs')
-rw-r--r--ctr-std/src/sys/unix/process/process_fuchsia.rs181
1 files changed, 0 insertions, 181 deletions
diff --git a/ctr-std/src/sys/unix/process/process_fuchsia.rs b/ctr-std/src/sys/unix/process/process_fuchsia.rs
deleted file mode 100644
index fa48001..0000000
--- a/ctr-std/src/sys/unix/process/process_fuchsia.rs
+++ /dev/null
@@ -1,181 +0,0 @@
-// Copyright 2016 The Rust Project Developers. See the COPYRIGHT
-// file at the top-level directory of this distribution and at
-// http://rust-lang.org/COPYRIGHT.
-//
-// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
-// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
-// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
-// option. This file may not be copied, modified, or distributed
-// except according to those terms.
-
-use io;
-use libc::{self, size_t};
-use mem;
-use ptr;
-
-use sys::process::zircon::{Handle, zx_handle_t};
-use sys::process::process_common::*;
-
-////////////////////////////////////////////////////////////////////////////////
-// Command
-////////////////////////////////////////////////////////////////////////////////
-
-impl Command {
- pub fn spawn(&mut self, default: Stdio, needs_stdin: bool)
- -> io::Result<(Process, StdioPipes)> {
- let envp = self.capture_env();
-
- if self.saw_nul() {
- return Err(io::Error::new(io::ErrorKind::InvalidInput,
- "nul byte found in provided data"));
- }
-
- let (ours, theirs) = self.setup_io(default, needs_stdin)?;
-
- let process_handle = unsafe { self.do_exec(theirs, envp.as_ref())? };
-
- Ok((Process { handle: Handle::new(process_handle) }, ours))
- }
-
- pub fn exec(&mut self, default: Stdio) -> io::Error {
- if self.saw_nul() {
- return io::Error::new(io::ErrorKind::InvalidInput,
- "nul byte found in provided data")
- }
-
- match self.setup_io(default, true) {
- Ok((_, _)) => {
- // FIXME: This is tough because we don't support the exec syscalls
- unimplemented!();
- },
- Err(e) => e,
- }
- }
-
- unsafe fn do_exec(&mut self, stdio: ChildPipes, maybe_envp: Option<&CStringArray>)
- -> io::Result<zx_handle_t> {
- use sys::process::zircon::*;
-
- let envp = match maybe_envp {
- Some(envp) => envp.as_ptr(),
- None => ptr::null(),
- };
-
- let transfer_or_clone = |opt_fd, target_fd| if let Some(local_fd) = opt_fd {
- fdio_spawn_action_t {
- action: FDIO_SPAWN_ACTION_TRANSFER_FD,
- local_fd,
- target_fd,
- ..Default::default()
- }
- } else {
- fdio_spawn_action_t {
- action: FDIO_SPAWN_ACTION_CLONE_FD,
- local_fd: target_fd,
- target_fd,
- ..Default::default()
- }
- };
-
- // Clone stdin, stdout, and stderr
- let action1 = transfer_or_clone(stdio.stdin.fd(), 0);
- let action2 = transfer_or_clone(stdio.stdout.fd(), 1);
- let action3 = transfer_or_clone(stdio.stderr.fd(), 2);
- let actions = [action1, action2, action3];
-
- // We don't want FileDesc::drop to be called on any stdio. fdio_spawn_etc
- // always consumes transferred file descriptors.
- mem::forget(stdio);
-
- for callback in self.get_closures().iter_mut() {
- callback()?;
- }
-
- let mut process_handle: zx_handle_t = 0;
- zx_cvt(fdio_spawn_etc(
- 0,
- FDIO_SPAWN_CLONE_JOB | FDIO_SPAWN_CLONE_LDSVC | FDIO_SPAWN_CLONE_NAMESPACE,
- self.get_argv()[0], self.get_argv().as_ptr(), envp, 3, actions.as_ptr(),
- &mut process_handle,
- ptr::null_mut(),
- ))?;
- // FIXME: See if we want to do something with that err_msg
-
- Ok(process_handle)
- }
-}
-
-////////////////////////////////////////////////////////////////////////////////
-// Processes
-////////////////////////////////////////////////////////////////////////////////
-
-pub struct Process {
- handle: Handle,
-}
-
-impl Process {
- pub fn id(&self) -> u32 {
- self.handle.raw() as u32
- }
-
- pub fn kill(&mut self) -> io::Result<()> {
- use sys::process::zircon::*;
-
- unsafe { zx_cvt(zx_task_kill(self.handle.raw()))?; }
-
- Ok(())
- }
-
- pub fn wait(&mut self) -> io::Result<ExitStatus> {
- use default::Default;
- use sys::process::zircon::*;
-
- let mut proc_info: zx_info_process_t = Default::default();
- let mut actual: size_t = 0;
- let mut avail: size_t = 0;
-
- unsafe {
- zx_cvt(zx_object_wait_one(self.handle.raw(), ZX_TASK_TERMINATED,
- ZX_TIME_INFINITE, ptr::null_mut()))?;
- zx_cvt(zx_object_get_info(self.handle.raw(), ZX_INFO_PROCESS,
- &mut proc_info as *mut _ as *mut libc::c_void,
- mem::size_of::<zx_info_process_t>(), &mut actual,
- &mut avail))?;
- }
- if actual != 1 {
- return Err(io::Error::new(io::ErrorKind::InvalidData,
- "Failed to get exit status of process"));
- }
- Ok(ExitStatus::new(proc_info.rec.return_code))
- }
-
- pub fn try_wait(&mut self) -> io::Result<Option<ExitStatus>> {
- use default::Default;
- use sys::process::zircon::*;
-
- let mut proc_info: zx_info_process_t = Default::default();
- let mut actual: size_t = 0;
- let mut avail: size_t = 0;
-
- unsafe {
- let status = zx_object_wait_one(self.handle.raw(), ZX_TASK_TERMINATED,
- 0, ptr::null_mut());
- match status {
- 0 => { }, // Success
- x if x == ERR_TIMED_OUT => {
- return Ok(None);
- },
- _ => { panic!("Failed to wait on process handle: {}", status); },
- }
- zx_cvt(zx_object_get_info(self.handle.raw(), ZX_INFO_PROCESS,
- &mut proc_info as *mut _ as *mut libc::c_void,
- mem::size_of::<zx_info_process_t>(), &mut actual,
- &mut avail))?;
- }
- if actual != 1 {
- return Err(io::Error::new(io::ErrorKind::InvalidData,
- "Failed to get exit status of process"));
- }
- Ok(Some(ExitStatus::new(proc_info.rec.return_code)))
- }
-}