src/libstd/sys/windows/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 io;
  14 use libc;
  15 use sys::cvt;
  16 use sys::c;
  17 use sys::handle::Handle;
  18
  19 ////////////////////////////////////////////////////////////////////////////////
  20 // Anonymous pipes
  21 ////////////////////////////////////////////////////////////////////////////////
  22
  23 pub struct AnonPipe {
  24     inner: Handle,
  25 }
  26
  27 pub fn anon_pipe() -> io::Result<(AnonPipe, AnonPipe)> {
  28     let mut reader = libc::INVALID_HANDLE_VALUE;
  29     let mut writer = libc::INVALID_HANDLE_VALUE;
  30     try!(cvt(unsafe {
  31         c::CreatePipe(&mut reader, &mut writer, 0 as *mut _, 0)
  32     }));
  33     let reader = Handle::new(reader);
  34     let writer = Handle::new(writer);
  35     Ok((AnonPipe { inner: reader }, AnonPipe { inner: writer }))
  36 }
  37
  38 impl AnonPipe {
  39     pub fn handle(&self) -> &Handle { &self.inner }
  40
  41     pub fn raw(&self) -> libc::HANDLE { self.inner.raw() }
  42
  43     pub fn read(&self, buf: &mut [u8]) -> io::Result<usize> {
  44         self.inner.read(buf)
  45     }
  46
  47     pub fn write(&self, buf: &[u8]) -> io::Result<usize> {
  48         self.inner.write(buf)
  49     }
  50 }