diff options
| author | Steven Fackler <[email protected]> | 2016-03-17 22:23:51 -0700 |
|---|---|---|
| committer | Steven Fackler <[email protected]> | 2016-03-17 22:23:51 -0700 |
| commit | a9a18cf337f5cf800332b4d4b2ab9d7c4eb5f77d (patch) | |
| tree | 4d4e1382e73230eda66fe042d258111b0a70fa27 /openssl/src/ssl | |
| parent | Merge branch 'release' (diff) | |
| download | rust-openssl-a9a18cf337f5cf800332b4d4b2ab9d7c4eb5f77d.tar.xz rust-openssl-a9a18cf337f5cf800332b4d4b2ab9d7c4eb5f77d.zip | |
Simplify panic safety logic for new nightly
Diffstat (limited to 'openssl/src/ssl')
| -rw-r--r-- | openssl/src/ssl/bio.rs | 49 |
1 files changed, 5 insertions, 44 deletions
diff --git a/openssl/src/ssl/bio.rs b/openssl/src/ssl/bio.rs index aa445562..31658cd0 100644 --- a/openssl/src/ssl/bio.rs +++ b/openssl/src/ssl/bio.rs @@ -74,8 +74,8 @@ unsafe fn state<'a, S: 'a>(bio: *mut BIO) -> &'a mut StreamState<S> { } #[cfg(feature = "nightly")] -fn recover<F, T>(f: F) -> Result<T, Box<Any + Send>> where F: FnOnce() -> T + ::std::panic::RecoverSafe { - ::std::panic::recover(f) +fn recover<F, T>(f: F) -> Result<T, Box<Any + Send>> where F: FnOnce() -> T { + ::std::panic::recover(::std::panic::AssertRecoverSafe::new(f)) } #[cfg(not(feature = "nightly"))] @@ -83,45 +83,13 @@ fn recover<F, T>(f: F) -> Result<T, Box<Any + Send>> where F: FnOnce() -> T { Ok(f()) } -#[cfg(feature = "nightly")] -use std::panic::AssertRecoverSafe; - -#[cfg(not(feature = "nightly"))] -struct AssertRecoverSafe<T>(T); - -#[cfg(not(feature = "nightly"))] -impl<T> AssertRecoverSafe<T> { - fn new(t: T) -> Self { - AssertRecoverSafe(t) - } -} - -#[cfg(not(feature = "nightly"))] -impl<T> ::std::ops::Deref for AssertRecoverSafe<T> { - type Target = T; - - fn deref(&self) -> &T { - &self.0 - } -} - -#[cfg(not(feature = "nightly"))] -impl<T> ::std::ops::DerefMut for AssertRecoverSafe<T> { - fn deref_mut(&mut self) -> &mut T { - &mut self.0 - } -} - unsafe extern "C" fn bwrite<S: Write>(bio: *mut BIO, buf: *const c_char, len: c_int) -> c_int { BIO_clear_retry_flags(bio); let state = state::<S>(bio); let buf = slice::from_raw_parts(buf as *const _, len as usize); - let result = { - let mut youre_not_my_supervisor = AssertRecoverSafe::new(&mut *state); - recover(move || youre_not_my_supervisor.stream.write(buf)) - }; + let result = recover(|| state.stream.write(buf)); match result { Ok(Ok(len)) => len as c_int, @@ -145,11 +113,7 @@ unsafe extern "C" fn bread<S: Read>(bio: *mut BIO, buf: *mut c_char, len: c_int) let state = state::<S>(bio); let buf = slice::from_raw_parts_mut(buf as *mut _, len as usize); - let result = { - let mut youre_not_my_supervisor = AssertRecoverSafe::new(&mut *state); - let mut fuuuu = AssertRecoverSafe::new(buf); - recover(move || youre_not_my_supervisor.stream.read(&mut *fuuuu)) - }; + let result = recover(|| state.stream.read(buf)); match result { Ok(Ok(len)) => len as c_int, @@ -185,10 +149,7 @@ unsafe extern "C" fn ctrl<S: Write>(bio: *mut BIO, -> c_long { if cmd == BIO_CTRL_FLUSH { let state = state::<S>(bio); - let result = { - let mut youre_not_my_supervisor = AssertRecoverSafe::new(&mut *state); - recover(move || youre_not_my_supervisor.stream.flush()) - }; + let result = recover(|| state.stream.flush()); match result { Ok(Ok(())) => 1, |