diff options
| author | Steven Fackler <[email protected]> | 2015-01-28 08:47:16 -0800 |
|---|---|---|
| committer | Steven Fackler <[email protected]> | 2015-01-28 08:47:16 -0800 |
| commit | 030cf5fe88f292a48b71789f5d0e9a9b133c5c09 (patch) | |
| tree | e105f6e7ddf28efbc6f58f8424f87b1b1bc46da6 /src/ssl/mod.rs | |
| parent | Release v0.2.17 (diff) | |
| download | rust-openssl-030cf5fe88f292a48b71789f5d0e9a9b133c5c09.tar.xz rust-openssl-030cf5fe88f292a48b71789f5d0e9a9b133c5c09.zip | |
Fix for IO changes
Diffstat (limited to 'src/ssl/mod.rs')
| -rw-r--r-- | src/ssl/mod.rs | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/src/ssl/mod.rs b/src/ssl/mod.rs index 3e7cd182..35649e24 100644 --- a/src/ssl/mod.rs +++ b/src/ssl/mod.rs @@ -1,6 +1,6 @@ use libc::{c_int, c_void, c_long}; use std::ffi::{CString, c_str_to_bytes}; -use std::io::{IoResult, IoError, EndOfFile, Stream, Reader, Writer}; +use std::old_io::{IoResult, IoError, EndOfFile, Stream, Reader, Writer}; use std::mem; use std::fmt; use std::num::FromPrimitive; @@ -291,8 +291,8 @@ impl<'ssl> MemBioRef<'ssl> { (&mut self.bio as &mut Reader).read(buf).ok() } - fn write(&mut self, buf: &[u8]) { - let _ = (&mut self.bio as &mut Writer).write(buf); + fn write_all(&mut self, buf: &[u8]) { + let _ = (&mut self.bio as &mut Writer).write_all(buf); } } @@ -357,7 +357,7 @@ impl Ssl { buf.len() as c_int) } } - fn write(&self, buf: &[u8]) -> c_int { + fn write_all(&self, buf: &[u8]) -> c_int { unsafe { ffi::SSL_write(self.ssl.0, buf.as_ptr() as *const c_void, buf.len() as c_int) } } @@ -510,7 +510,7 @@ impl<S: Stream> SslStream<S> { LibSslError::ErrorWantRead => { try_ssl_stream!(self.flush()); let len = try_ssl_stream!(self.stream.read(self.buf.as_mut_slice())); - self.ssl.get_rbio().write(&self.buf[..len]); + self.ssl.get_rbio().write_all(&self.buf[..len]); } LibSslError::ErrorWantWrite => { try_ssl_stream!(self.flush()) } LibSslError::ErrorZeroReturn => return Err(SslSessionClosed), @@ -523,7 +523,7 @@ impl<S: Stream> SslStream<S> { fn write_through(&mut self) -> IoResult<()> { loop { match self.ssl.get_wbio().read(self.buf.as_mut_slice()) { - Some(len) => try!(self.stream.write(&self.buf[..len])), + Some(len) => try!(self.stream.write_all(&self.buf[..len])), None => break }; } @@ -565,11 +565,11 @@ impl<S: Stream> Reader for SslStream<S> { } impl<S: Stream> Writer for SslStream<S> { - fn write(&mut self, buf: &[u8]) -> IoResult<()> { + fn write_all(&mut self, buf: &[u8]) -> IoResult<()> { let mut start = 0; while start < buf.len() { let ret = self.in_retry_wrapper(|ssl| { - ssl.write(buf.split_at(start).1) + ssl.write_all(buf.split_at(start).1) }); match ret { Ok(len) => start += len as usize, @@ -605,10 +605,10 @@ impl<S> Reader for MaybeSslStream<S> where S: Stream { } impl<S> Writer for MaybeSslStream<S> where S: Stream{ - fn write(&mut self, buf: &[u8]) -> IoResult<()> { + fn write_all(&mut self, buf: &[u8]) -> IoResult<()> { match *self { - MaybeSslStream::Ssl(ref mut s) => s.write(buf), - MaybeSslStream::Normal(ref mut s) => s.write(buf), + MaybeSslStream::Ssl(ref mut s) => s.write_all(buf), + MaybeSslStream::Normal(ref mut s) => s.write_all(buf), } } |