diff options
Diffstat (limited to 'rust/kernel/sync')
| -rw-r--r-- | rust/kernel/sync/arc.rs | 28 | 
1 files changed, 20 insertions, 8 deletions
| diff --git a/rust/kernel/sync/arc.rs b/rust/kernel/sync/arc.rs index e6d206242465..172f563976a9 100644 --- a/rust/kernel/sync/arc.rs +++ b/rust/kernel/sync/arc.rs @@ -146,13 +146,15 @@ impl<T: ?Sized + Unsize<U>, U: ?Sized> core::ops::DispatchFromDyn<Arc<U>> for Ar  // SAFETY: It is safe to send `Arc<T>` to another thread when the underlying `T` is `Sync` because  // it effectively means sharing `&T` (which is safe because `T` is `Sync`); additionally, it needs -// `T` to be `Send` because any thread that has an `Arc<T>` may ultimately access `T` directly, for -// example, when the reference count reaches zero and `T` is dropped. +// `T` to be `Send` because any thread that has an `Arc<T>` may ultimately access `T` using a +// mutable reference when the reference count reaches zero and `T` is dropped.  unsafe impl<T: ?Sized + Sync + Send> Send for Arc<T> {} -// SAFETY: It is safe to send `&Arc<T>` to another thread when the underlying `T` is `Sync` for the -// same reason as above. `T` needs to be `Send` as well because a thread can clone an `&Arc<T>` -// into an `Arc<T>`, which may lead to `T` being accessed by the same reasoning as above. +// SAFETY: It is safe to send `&Arc<T>` to another thread when the underlying `T` is `Sync` +// because it effectively means sharing `&T` (which is safe because `T` is `Sync`); additionally, +// it needs `T` to be `Send` because any thread that has a `&Arc<T>` may clone it and get an +// `Arc<T>` on that thread, so the thread may ultimately access `T` using a mutable reference when +// the reference count reaches zero and `T` is dropped.  unsafe impl<T: ?Sized + Sync + Send> Sync for Arc<T> {}  impl<T> Arc<T> { @@ -185,7 +187,7 @@ impl<T> Arc<T> {      /// Use the given initializer to in-place initialize a `T`.      /// -    /// This is equivalent to [`pin_init`], since an [`Arc`] is always pinned. +    /// This is equivalent to [`Arc<T>::pin_init`], since an [`Arc`] is always pinned.      #[inline]      pub fn init<E>(init: impl Init<T, E>) -> error::Result<Self>      where @@ -221,6 +223,11 @@ impl<T: ?Sized> Arc<T> {          // reference can be created.          unsafe { ArcBorrow::new(self.ptr) }      } + +    /// Compare whether two [`Arc`] pointers reference the same underlying object. +    pub fn ptr_eq(this: &Self, other: &Self) -> bool { +        core::ptr::eq(this.ptr.as_ptr(), other.ptr.as_ptr()) +    }  }  impl<T: 'static> ForeignOwnable for Arc<T> { @@ -236,8 +243,7 @@ impl<T: 'static> ForeignOwnable for Arc<T> {          let inner = NonNull::new(ptr as *mut ArcInner<T>).unwrap();          // SAFETY: The safety requirements of `from_foreign` ensure that the object remains alive -        // for the lifetime of the returned value. Additionally, the safety requirements of -        // `ForeignOwnable::borrow_mut` ensure that no new mutable references are created. +        // for the lifetime of the returned value.          unsafe { ArcBorrow::new(inner) }      } @@ -259,6 +265,12 @@ impl<T: ?Sized> Deref for Arc<T> {      }  } +impl<T: ?Sized> AsRef<T> for Arc<T> { +    fn as_ref(&self) -> &T { +        self.deref() +    } +} +  impl<T: ?Sized> Clone for Arc<T> {      fn clone(&self) -> Self {          // INVARIANT: C `refcount_inc` saturates the refcount, so it cannot overflow to zero. |