1 use std::sync::{self, RwLockReadGuard, RwLockWriteGuard, TryLockError};
2 
3 /// Adapter for `std::sync::RwLock` that removes the poisoning aspects
4 /// from its api.
5 #[derive(Debug)]
6 pub(crate) struct RwLock<T: ?Sized>(sync::RwLock<T>);
7 
8 #[allow(dead_code)]
9 impl<T> RwLock<T> {
10     #[inline]
new(t: T) -> Self11     pub(crate) fn new(t: T) -> Self {
12         Self(sync::RwLock::new(t))
13     }
14 
15     #[inline]
read(&self) -> RwLockReadGuard<'_, T>16     pub(crate) fn read(&self) -> RwLockReadGuard<'_, T> {
17         match self.0.read() {
18             Ok(guard) => guard,
19             Err(p_err) => p_err.into_inner(),
20         }
21     }
22 
23     #[inline]
try_read(&self) -> Option<RwLockReadGuard<'_, T>>24     pub(crate) fn try_read(&self) -> Option<RwLockReadGuard<'_, T>> {
25         match self.0.try_read() {
26             Ok(guard) => Some(guard),
27             Err(TryLockError::Poisoned(p_err)) => Some(p_err.into_inner()),
28             Err(TryLockError::WouldBlock) => None,
29         }
30     }
31 
32     #[inline]
write(&self) -> RwLockWriteGuard<'_, T>33     pub(crate) fn write(&self) -> RwLockWriteGuard<'_, T> {
34         match self.0.write() {
35             Ok(guard) => guard,
36             Err(p_err) => p_err.into_inner(),
37         }
38     }
39 
40     #[inline]
try_write(&self) -> Option<RwLockWriteGuard<'_, T>>41     pub(crate) fn try_write(&self) -> Option<RwLockWriteGuard<'_, T>> {
42         match self.0.try_write() {
43             Ok(guard) => Some(guard),
44             Err(TryLockError::Poisoned(p_err)) => Some(p_err.into_inner()),
45             Err(TryLockError::WouldBlock) => None,
46         }
47     }
48 }
49