From 3d535f661f8ae2b402abf212f3d89404eedab498 Mon Sep 17 00:00:00 2001 From: Steven Fackler Date: Thu, 13 Oct 2016 20:15:26 -0700 Subject: [PATCH] Use stdlib logic for udp --- openssl/src/lib.rs | 3 --- openssl/src/ssl/tests/mod.rs | 40 ++---------------------------------- 2 files changed, 2 insertions(+), 41 deletions(-) diff --git a/openssl/src/lib.rs b/openssl/src/lib.rs index 66c767dc..aa34753c 100644 --- a/openssl/src/lib.rs +++ b/openssl/src/lib.rs @@ -10,9 +10,6 @@ extern crate openssl_sys as ffi; #[cfg(test)] extern crate rustc_serialize as serialize; -#[cfg(test)] -extern crate net2; - #[cfg(test)] extern crate tempdir; diff --git a/openssl/src/ssl/tests/mod.rs b/openssl/src/ssl/tests/mod.rs index 0140e283..2e362b5e 100644 --- a/openssl/src/ssl/tests/mod.rs +++ b/openssl/src/ssl/tests/mod.rs @@ -12,7 +12,6 @@ use std::process::{Command, Child, Stdio, ChildStdin}; use std::thread; use std::time::Duration; -use net2::TcpStreamExt; use tempdir::TempDir; use crypto::hash::Type::SHA256; @@ -29,9 +28,6 @@ use crypto::pkey::PKey; use std::net::UdpSocket; use ssl::SslMethod::Dtls; -#[cfg(feature="sslv2")] -use ssl::SslMethod::Sslv2; -use net2::UdpSocketExt; mod select; @@ -144,45 +140,13 @@ struct UdpConnected(UdpSocket); impl Read for UdpConnected { fn read(&mut self, buf: &mut [u8]) -> io::Result { - self.0.recv_from(buf).map(|(s, _)| s) + self.0.recv(buf) } } impl Write for UdpConnected { - #[cfg(unix)] fn write(&mut self, buf: &[u8]) -> io::Result { - use std::os::unix::prelude::*; - use libc; - let n = unsafe { - libc::send(self.0.as_raw_fd(), - buf.as_ptr() as *const _, - buf.len() as libc::size_t, - 0) - }; - if n < 0 { - Err(io::Error::last_os_error()) - } else { - Ok(n as usize) - } - } - - #[cfg(windows)] - fn write(&mut self, buf: &[u8]) -> io::Result { - extern crate ws2_32; - use std::os::windows::prelude::*; - use libc; - - let n = unsafe { - ws2_32::send(self.0.as_raw_socket(), - buf.as_ptr() as *const _, - buf.len() as libc::c_int, - 0) - }; - if n < 0 { - Err(io::Error::last_os_error()) - } else { - Ok(n as usize) - } + self.0.send(buf) } fn flush(&mut self) -> io::Result<()> {