aboutsummaryrefslogtreecommitdiff
path: root/src/ssl/mod.rs
diff options
context:
space:
mode:
authorSteven Fackler <[email protected]>2015-01-28 08:47:16 -0800
committerSteven Fackler <[email protected]>2015-01-28 08:47:16 -0800
commit030cf5fe88f292a48b71789f5d0e9a9b133c5c09 (patch)
treee105f6e7ddf28efbc6f58f8424f87b1b1bc46da6 /src/ssl/mod.rs
parentRelease v0.2.17 (diff)
downloadrust-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.rs22
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),
}
}