diff options
| author | Steven Fackler <sfackler@gmail.com> | 2019-02-11 19:31:37 -0800 |
|---|---|---|
| committer | Steven Fackler <sfackler@gmail.com> | 2019-02-13 19:40:17 -0800 |
| commit | 596f18201c7863d8b02fe6fa1872cf3ba2b6b381 (patch) | |
| tree | 1b152d89591c590eb92bf1b18591836e88ccf347 /src/libstd/io | |
| parent | 31bcec648aa57391115f877a2ca022d7ff6415aa (diff) | |
| download | rust-596f18201c7863d8b02fe6fa1872cf3ba2b6b381.tar.gz rust-596f18201c7863d8b02fe6fa1872cf3ba2b6b381.zip | |
impl Deref/DerefMut for IoVec types
Returning &'a mut [u8] was unsound, and we may as well just have them directly deref to their slices to make it easier to work with them.
Diffstat (limited to 'src/libstd/io')
| -rw-r--r-- | src/libstd/io/buffered.rs | 4 | ||||
| -rw-r--r-- | src/libstd/io/cursor.rs | 4 | ||||
| -rw-r--r-- | src/libstd/io/impls.rs | 8 | ||||
| -rw-r--r-- | src/libstd/io/mod.rs | 36 | ||||
| -rw-r--r-- | src/libstd/io/util.rs | 4 |
5 files changed, 31 insertions, 25 deletions
diff --git a/src/libstd/io/buffered.rs b/src/libstd/io/buffered.rs index a5edc4360ca..d8a5f5a4d8c 100644 --- a/src/libstd/io/buffered.rs +++ b/src/libstd/io/buffered.rs @@ -236,7 +236,7 @@ impl<R: Read> Read for BufReader<R> { } fn read_vectored(&mut self, bufs: &mut [IoVecMut<'_>]) -> io::Result<usize> { - let total_len = bufs.iter().map(|b| b.as_slice().len()).sum::<usize>(); + let total_len = bufs.iter().map(|b| b.len()).sum::<usize>(); if self.pos == self.cap && total_len >= self.buf.len() { return self.inner.read_vectored(bufs); } @@ -595,7 +595,7 @@ impl<W: Write> Write for BufWriter<W> { } fn write_vectored(&mut self, bufs: &[IoVec<'_>]) -> io::Result<usize> { - let total_len = bufs.iter().map(|b| b.as_slice().len()).sum::<usize>(); + let total_len = bufs.iter().map(|b| b.len()).sum::<usize>(); if self.buf.len() + total_len > self.buf.capacity() { self.flush_buf()?; } diff --git a/src/libstd/io/cursor.rs b/src/libstd/io/cursor.rs index ef636cc6f8c..d1739894a27 100644 --- a/src/libstd/io/cursor.rs +++ b/src/libstd/io/cursor.rs @@ -224,7 +224,6 @@ impl<T> Read for Cursor<T> where T: AsRef<[u8]> { fn read_vectored(&mut self, bufs: &mut [IoVecMut<'_>]) -> io::Result<usize> { let mut nread = 0; for buf in bufs { - let buf = buf.as_mut_slice(); let n = self.read(buf)?; nread += n; if n < buf.len() { @@ -272,7 +271,6 @@ fn slice_write_vectored( { let mut nwritten = 0; for buf in bufs { - let buf = buf.as_slice(); let n = slice_write(pos_mut, slice, buf)?; nwritten += n; if n < buf.len() { @@ -317,7 +315,7 @@ fn vec_write_vectored( { let mut nwritten = 0; for buf in bufs { - nwritten += vec_write(pos_mut, vec, buf.as_slice())?; + nwritten += vec_write(pos_mut, vec, buf)?; } Ok(nwritten) } diff --git a/src/libstd/io/impls.rs b/src/libstd/io/impls.rs index 4bba4af77c4..57d8cf40a79 100644 --- a/src/libstd/io/impls.rs +++ b/src/libstd/io/impls.rs @@ -196,7 +196,7 @@ impl<'a> Read for &'a [u8] { fn read_vectored(&mut self, bufs: &mut [IoVecMut<'_>]) -> io::Result<usize> { let mut nread = 0; for buf in bufs { - nread += self.read(buf.as_mut_slice())?; + nread += self.read(buf)?; if self.is_empty() { break; } @@ -269,7 +269,7 @@ impl<'a> Write for &'a mut [u8] { fn write_vectored(&mut self, bufs: &[IoVec<'_>]) -> io::Result<usize> { let mut nwritten = 0; for buf in bufs { - nwritten += self.write(buf.as_slice())?; + nwritten += self.write(buf)?; if self.is_empty() { break; } @@ -303,10 +303,10 @@ impl Write for Vec<u8> { #[inline] fn write_vectored(&mut self, bufs: &[IoVec<'_>]) -> io::Result<usize> { - let len = bufs.iter().map(|b| b.as_slice().len()).sum(); + let len = bufs.iter().map(|b| b.len()).sum(); self.reserve(len); for buf in bufs { - self.extend_from_slice(buf.as_slice()); + self.extend_from_slice(buf); } Ok(len) } diff --git a/src/libstd/io/mod.rs b/src/libstd/io/mod.rs index b9765605f8e..7f9c5a0316c 100644 --- a/src/libstd/io/mod.rs +++ b/src/libstd/io/mod.rs @@ -264,6 +264,7 @@ use fmt; use slice; use str; use memchr; +use ops::{Deref, DerefMut}; use ptr; use sys; @@ -531,7 +532,7 @@ pub trait Read { /// `read`. #[unstable(feature = "iovec", issue = "0")] fn read_vectored(&mut self, bufs: &mut [IoVecMut<'_>]) -> Result<usize> { - match bufs.iter_mut().map(|b| b.as_mut_slice()).find(|b| !b.is_empty()) { + match bufs.iter_mut().find(|b| !b.is_empty()) { Some(buf) => self.read(buf), None => Ok(0), } @@ -896,7 +897,7 @@ pub struct IoVecMut<'a>(sys::io::IoVecMut<'a>); #[unstable(feature = "iovec", issue = "0")] impl<'a> fmt::Debug for IoVecMut<'a> { fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result { - fmt::Debug::fmt(self.as_slice(), fmt) + fmt::Debug::fmt(self.0.as_slice(), fmt) } } @@ -911,18 +912,22 @@ impl<'a> IoVecMut<'a> { pub fn new(buf: &'a mut [u8]) -> IoVecMut<'a> { IoVecMut(sys::io::IoVecMut::new(buf)) } +} + +#[unstable(feature = "iovec", issue = "0")] +impl<'a> Deref for IoVecMut<'a> { + type Target = [u8]; - /// Returns a shared reference to the inner slice. - #[unstable(feature = "iovec", issue = "0")] #[inline] - pub fn as_slice(&self) -> &'a [u8] { + fn deref(&self) -> &[u8] { self.0.as_slice() } +} - /// Returns a mutable reference to the inner slice. - #[unstable(feature = "iovec", issue = "0")] +#[unstable(feature = "iovec", issue = "0")] +impl<'a> DerefMut for IoVecMut<'a> { #[inline] - pub fn as_mut_slice(&mut self) -> &'a mut [u8] { + fn deref_mut(&mut self) -> &mut [u8] { self.0.as_mut_slice() } } @@ -939,7 +944,7 @@ pub struct IoVec<'a>(sys::io::IoVec<'a>); #[unstable(feature = "iovec", issue = "0")] impl<'a> fmt::Debug for IoVec<'a> { fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result { - fmt::Debug::fmt(self.as_slice(), fmt) + fmt::Debug::fmt(self.0.as_slice(), fmt) } } @@ -954,11 +959,14 @@ impl<'a> IoVec<'a> { pub fn new(buf: &'a [u8]) -> IoVec<'a> { IoVec(sys::io::IoVec::new(buf)) } +} + +#[unstable(feature = "iovec", issue = "0")] +impl<'a> Deref for IoVec<'a> { + type Target = [u8]; - /// Returns a shared reference to the inner slice. - #[unstable(feature = "iovec", issue = "0")] #[inline] - pub fn as_slice(&self) -> &'a [u8] { + fn deref(&self) -> &[u8] { self.0.as_slice() } } @@ -1103,7 +1111,7 @@ pub trait Write { /// `write`. #[unstable(feature = "iovec", issue = "0")] fn write_vectored(&mut self, bufs: &[IoVec<'_>]) -> Result<usize> { - match bufs.iter().map(|b| b.as_slice()).find(|b| !b.is_empty()) { + match bufs.iter().find(|b| !b.is_empty()) { Some(buf) => self.write(buf), None => Ok(0), } @@ -1813,7 +1821,7 @@ impl<T: Read, U: Read> Read for Chain<T, U> { fn read_vectored(&mut self, bufs: &mut [IoVecMut<'_>]) -> Result<usize> { if !self.done_first { match self.first.read_vectored(bufs)? { - 0 if bufs.iter().any(|b| !b.as_slice().is_empty()) => self.done_first = true, + 0 if bufs.iter().any(|b| !b.is_empty()) => self.done_first = true, n => return Ok(n), } } diff --git a/src/libstd/io/util.rs b/src/libstd/io/util.rs index 6743018793f..5ce955eb1e4 100644 --- a/src/libstd/io/util.rs +++ b/src/libstd/io/util.rs @@ -156,7 +156,7 @@ impl Read for Repeat { fn read_vectored(&mut self, bufs: &mut [IoVecMut<'_>]) -> io::Result<usize> { let mut nwritten = 0; for buf in bufs { - nwritten += self.read(buf.as_mut_slice())?; + nwritten += self.read(buf)?; } Ok(nwritten) } @@ -207,7 +207,7 @@ impl Write for Sink { #[inline] fn write_vectored(&mut self, bufs: &[IoVec<'_>]) -> io::Result<usize> { - let total_len = bufs.iter().map(|b| b.as_slice().len()).sum(); + let total_len = bufs.iter().map(|b| b.len()).sum(); Ok(total_len) } |
