summaryrefslogtreecommitdiff
path: root/src/collection/owned.rs
diff options
context:
space:
mode:
authorMica White <botahamec@gmail.com>2024-12-23 15:31:07 -0500
committerMica White <botahamec@gmail.com>2024-12-23 15:33:02 -0500
commit30d0f08b6073e9c2e545a3567838a9e1e885fea2 (patch)
tree5763e820ed5877b39ef9745e2a9380e665ced099 /src/collection/owned.rs
parentfa4fe582f212bec3e4d9fe288aaac8c471b8e987 (diff)
Remove scopeguard
The scopeguard crate was being used for its `defer_on_unwind` macro. The problem was that it runs even if the runtime was already panicking. There aren't any changes to the macro which could have fixed this. I instead wrote my own function to check for a specific panicking closure.
Diffstat (limited to 'src/collection/owned.rs')
-rw-r--r--src/collection/owned.rs23
1 files changed, 2 insertions, 21 deletions
diff --git a/src/collection/owned.rs b/src/collection/owned.rs
index 3ea93b6..69680f4 100644
--- a/src/collection/owned.rs
+++ b/src/collection/owned.rs
@@ -1,4 +1,3 @@
-use std::cell::RefCell;
use std::marker::PhantomData;
use crate::lockable::{Lockable, LockableIntoInner, OwnedLockable, RawLock, Sharable};
@@ -21,16 +20,7 @@ unsafe impl<L: Lockable> RawLock for OwnedLockCollection<L> {
}
unsafe fn raw_lock(&self) {
- let locks = get_locks(&self.data);
- let locked = RefCell::new(Vec::with_capacity(locks.len()));
- scopeguard::defer_on_unwind! {
- utils::attempt_to_recover_locks_from_panic(&locked)
- };
-
- for lock in locks {
- lock.raw_lock();
- locked.borrow_mut().push(lock);
- }
+ utils::ordered_lock(&get_locks(&self.data))
}
unsafe fn raw_try_lock(&self) -> bool {
@@ -46,16 +36,7 @@ unsafe impl<L: Lockable> RawLock for OwnedLockCollection<L> {
}
unsafe fn raw_read(&self) {
- let locks = get_locks(&self.data);
- let locked = RefCell::new(Vec::with_capacity(locks.len()));
- scopeguard::defer_on_unwind! {
- utils::attempt_to_recover_reads_from_panic(&locked)
- };
-
- for lock in locks {
- lock.raw_read();
- locked.borrow_mut().push(lock);
- }
+ utils::ordered_read(&get_locks(&self.data))
}
unsafe fn raw_try_read(&self) -> bool {