src/libstd/sys/unix/pipe.rs

   1 // Copyright 2015 The Rust Project Developers. See the COPYRIGHT
   2 // file at the top-level directory of this distribution and at
   3 // http://rust-lang.org/COPYRIGHT.
   4 //
   5 // Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
   6 // http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
   7 // <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
   8 // option. This file may not be copied, modified, or distributed
   9 // except according to those terms.
  10
  11 use prelude::v1::*;
  12
  13 use sys::fd::FileDesc;
  14 use io;
  15 use libc;
  16
  17 ////////////////////////////////////////////////////////////////////////////////
  18 // Anonymous pipes
  19 ////////////////////////////////////////////////////////////////////////////////
  20
  21 pub struct AnonPipe(FileDesc);
  22
  23 pub fn anon_pipe() -> io::Result<(AnonPipe, AnonPipe)> {
  24     let mut fds = [0; 2];
  25     if unsafe { libc::pipe(fds.as_mut_ptr()) == 0 } {
  26         Ok((AnonPipe::from_fd(fds[0]), AnonPipe::from_fd(fds[1])))
  27     } else {
  28         Err(io::Error::last_os_error())
  29     }
  30 }
  31
  32 impl AnonPipe {
  33     pub fn from_fd(fd: libc::c_int) -> AnonPipe {
  34         let fd = FileDesc::new(fd);
  35         fd.set_cloexec();
  36         AnonPipe(fd)
  37     }
  38
  39     pub fn read(&self, buf: &mut [u8]) -> io::Result<usize> {
  40         self.0.read(buf)
  41     }
  42
  43     pub fn write(&self, buf: &[u8]) -> io::Result<usize> {
  44         self.0.write(buf)
  45     }
  46
  47     pub fn raw(&self) -> libc::c_int { self.0.raw() }
  48     pub fn fd(&self) -> &FileDesc { &self.0 }
  49     pub fn into_fd(self) -> FileDesc { self.0 }
  50 }