aboutsummaryrefslogtreecommitdiff
path: root/ctr-std/src/sys/unix/rwlock.rs
diff options
context:
space:
mode:
Diffstat (limited to 'ctr-std/src/sys/unix/rwlock.rs')
-rw-r--r--ctr-std/src/sys/unix/rwlock.rs142
1 files changed, 0 insertions, 142 deletions
diff --git a/ctr-std/src/sys/unix/rwlock.rs b/ctr-std/src/sys/unix/rwlock.rs
deleted file mode 100644
index c754d5b..0000000
--- a/ctr-std/src/sys/unix/rwlock.rs
+++ /dev/null
@@ -1,142 +0,0 @@
-// Copyright 2014 The Rust Project Developers. See the COPYRIGHT
-// file at the top-level directory of this distribution and at
-// http://rust-lang.org/COPYRIGHT.
-//
-// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
-// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
-// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
-// option. This file may not be copied, modified, or distributed
-// except according to those terms.
-
-use libc;
-use cell::UnsafeCell;
-use sync::atomic::{AtomicUsize, Ordering};
-
-pub struct RWLock {
- inner: UnsafeCell<libc::pthread_rwlock_t>,
- write_locked: UnsafeCell<bool>,
- num_readers: AtomicUsize,
-}
-
-unsafe impl Send for RWLock {}
-unsafe impl Sync for RWLock {}
-
-impl RWLock {
- pub const fn new() -> RWLock {
- RWLock {
- inner: UnsafeCell::new(libc::PTHREAD_RWLOCK_INITIALIZER),
- write_locked: UnsafeCell::new(false),
- num_readers: AtomicUsize::new(0),
- }
- }
- #[inline]
- pub unsafe fn read(&self) {
- let r = libc::pthread_rwlock_rdlock(self.inner.get());
-
- // According to the pthread_rwlock_rdlock spec, this function **may**
- // fail with EDEADLK if a deadlock is detected. On the other hand
- // pthread mutexes will *never* return EDEADLK if they are initialized
- // as the "fast" kind (which ours always are). As a result, a deadlock
- // situation may actually return from the call to pthread_rwlock_rdlock
- // instead of blocking forever (as mutexes and Windows rwlocks do). Note
- // that not all unix implementations, however, will return EDEADLK for
- // their rwlocks.
- //
- // We roughly maintain the deadlocking behavior by panicking to ensure
- // that this lock acquisition does not succeed.
- //
- // We also check whether this lock is already write locked. This
- // is only possible if it was write locked by the current thread and
- // the implementation allows recursive locking. The POSIX standard
- // doesn't require recursively locking a rwlock to deadlock, but we can't
- // allow that because it could lead to aliasing issues.
- if r == libc::EAGAIN {
- panic!("rwlock maximum reader count exceeded");
- } else if r == libc::EDEADLK || *self.write_locked.get() {
- if r == 0 {
- self.raw_unlock();
- }
- panic!("rwlock read lock would result in deadlock");
- } else {
- debug_assert_eq!(r, 0);
- self.num_readers.fetch_add(1, Ordering::Relaxed);
- }
- }
- #[inline]
- pub unsafe fn try_read(&self) -> bool {
- let r = libc::pthread_rwlock_tryrdlock(self.inner.get());
- if r == 0 {
- if *self.write_locked.get() {
- self.raw_unlock();
- false
- } else {
- self.num_readers.fetch_add(1, Ordering::Relaxed);
- true
- }
- } else {
- false
- }
- }
- #[inline]
- pub unsafe fn write(&self) {
- let r = libc::pthread_rwlock_wrlock(self.inner.get());
- // See comments above for why we check for EDEADLK and write_locked. We
- // also need to check that num_readers is 0.
- if r == libc::EDEADLK || *self.write_locked.get() ||
- self.num_readers.load(Ordering::Relaxed) != 0 {
- if r == 0 {
- self.raw_unlock();
- }
- panic!("rwlock write lock would result in deadlock");
- } else {
- debug_assert_eq!(r, 0);
- }
- *self.write_locked.get() = true;
- }
- #[inline]
- pub unsafe fn try_write(&self) -> bool {
- let r = libc::pthread_rwlock_trywrlock(self.inner.get());
- if r == 0 {
- if *self.write_locked.get() || self.num_readers.load(Ordering::Relaxed) != 0 {
- self.raw_unlock();
- false
- } else {
- *self.write_locked.get() = true;
- true
- }
- } else {
- false
- }
- }
- #[inline]
- unsafe fn raw_unlock(&self) {
- let r = libc::pthread_rwlock_unlock(self.inner.get());
- debug_assert_eq!(r, 0);
- }
- #[inline]
- pub unsafe fn read_unlock(&self) {
- debug_assert!(!*self.write_locked.get());
- self.num_readers.fetch_sub(1, Ordering::Relaxed);
- self.raw_unlock();
- }
- #[inline]
- pub unsafe fn write_unlock(&self) {
- debug_assert_eq!(self.num_readers.load(Ordering::Relaxed), 0);
- debug_assert!(*self.write_locked.get());
- *self.write_locked.get() = false;
- self.raw_unlock();
- }
- #[inline]
- pub unsafe fn destroy(&self) {
- let r = libc::pthread_rwlock_destroy(self.inner.get());
- // On DragonFly pthread_rwlock_destroy() returns EINVAL if called on a
- // rwlock that was just initialized with
- // libc::PTHREAD_RWLOCK_INITIALIZER. Once it is used (locked/unlocked)
- // or pthread_rwlock_init() is called, this behaviour no longer occurs.
- if cfg!(target_os = "dragonfly") {
- debug_assert!(r == 0 || r == libc::EINVAL);
- } else {
- debug_assert_eq!(r, 0);
- }
- }
-}