diff options
| author | bors <bors@rust-lang.org> | 2015-05-08 01:32:59 +0000 | 
|---|---|---|
| committer | bors <bors@rust-lang.org> | 2015-05-08 01:32:59 +0000 | 
| commit | cf76e637450a861e94ef583340b8f080379a159a (patch) | |
| tree | f01e7c305dbe832c5283d229168223c5e8a24cf7 /src/libstd/sys/unix/pipe.rs | |
| parent | b402c43f088882db8a03bfcbb5eb8429ef7def0e (diff) | |
| parent | 7529bd60c3cbc4c7b635ee43a89d5b14f6fb8bf7 (diff) | |
| download | rust-cf76e637450a861e94ef583340b8f080379a159a.tar.gz rust-cf76e637450a861e94ef583340b8f080379a159a.zip | |
Auto merge of #25136 - alexcrichton:drop-the-two, r=aturon
* Remove the 2-suffix from some modules * Remove some unused files * Remove double-boxing for `ReentrantMutex`
Diffstat (limited to 'src/libstd/sys/unix/pipe.rs')
| -rw-r--r-- | src/libstd/sys/unix/pipe.rs | 50 | 
1 files changed, 50 insertions, 0 deletions
| diff --git a/src/libstd/sys/unix/pipe.rs b/src/libstd/sys/unix/pipe.rs new file mode 100644 index 00000000000..e9d8c69fefb --- /dev/null +++ b/src/libstd/sys/unix/pipe.rs @@ -0,0 +1,50 @@ +// Copyright 2015 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 prelude::v1::*; + +use sys::fd::FileDesc; +use io; +use libc; + +//////////////////////////////////////////////////////////////////////////////// +// Anonymous pipes +//////////////////////////////////////////////////////////////////////////////// + +pub struct AnonPipe(FileDesc); + +pub fn anon_pipe() -> io::Result<(AnonPipe, AnonPipe)> { + let mut fds = [0; 2]; + if unsafe { libc::pipe(fds.as_mut_ptr()) == 0 } { + Ok((AnonPipe::from_fd(fds[0]), AnonPipe::from_fd(fds[1]))) + } else { + Err(io::Error::last_os_error()) + } +} + +impl AnonPipe { + pub fn from_fd(fd: libc::c_int) -> AnonPipe { + let fd = FileDesc::new(fd); + fd.set_cloexec(); + AnonPipe(fd) + } + + pub fn read(&self, buf: &mut [u8]) -> io::Result<usize> { + self.0.read(buf) + } + + pub fn write(&self, buf: &[u8]) -> io::Result<usize> { + self.0.write(buf) + } + + pub fn into_fd(self) -> FileDesc { + self.0 + } +} | 
