summaryrefslogtreecommitdiff
path: root/src/collection/owned.rs
diff options
context:
space:
mode:
authorMica White <botahamec@gmail.com>2024-07-16 17:18:33 -0400
committerMica White <botahamec@gmail.com>2024-07-17 16:37:21 -0400
commit32f972a26a0066291873445088718deec3ed4233 (patch)
tree95f83e15d08ebca4ae4f377b0e359a2f7ce01671 /src/collection/owned.rs
parentdf7c467005756433b2627b766bd086efda8689f4 (diff)
Impl Lock for LockCollection
Diffstat (limited to 'src/collection/owned.rs')
-rw-r--r--src/collection/owned.rs40
1 files changed, 40 insertions, 0 deletions
diff --git a/src/collection/owned.rs b/src/collection/owned.rs
index d180ed2..2b6e974 100644
--- a/src/collection/owned.rs
+++ b/src/collection/owned.rs
@@ -11,6 +11,46 @@ fn get_locks<L: Lockable>(data: &L) -> Vec<&dyn RawLock> {
locks
}
+unsafe impl<L: Lockable + Send + Sync> RawLock for OwnedLockCollection<L> {
+ unsafe fn lock(&self) {
+ let locks = get_locks(&self.data);
+ for lock in locks {
+ lock.lock();
+ }
+ }
+
+ unsafe fn try_lock(&self) -> bool {
+ let locks = get_locks(&self.data);
+ utils::ordered_try_lock(&locks)
+ }
+
+ unsafe fn unlock(&self) {
+ let locks = get_locks(&self.data);
+ for lock in locks {
+ lock.unlock();
+ }
+ }
+
+ unsafe fn read(&self) {
+ let locks = get_locks(&self.data);
+ for lock in locks {
+ lock.read();
+ }
+ }
+
+ unsafe fn try_read(&self) -> bool {
+ let locks = get_locks(&self.data);
+ utils::ordered_try_read(&locks)
+ }
+
+ unsafe fn unlock_read(&self) {
+ let locks = get_locks(&self.data);
+ for lock in locks {
+ lock.unlock_read();
+ }
+ }
+}
+
unsafe impl<L: Lockable> Lockable for OwnedLockCollection<L> {
type Guard<'g> = L::Guard<'g> where Self: 'g;