| // SPDX-License-Identifier: GPL-2.0 | |
| //! Synchronisation primitives. | |
| //! | |
| //! This module contains the kernel APIs related to synchronisation that have been ported or | |
| //! wrapped for usage by Rust code in the kernel. | |
| use crate::prelude::*; | |
| use crate::types::Opaque; | |
| use pin_init; | |
| mod arc; | |
| pub mod aref; | |
| pub mod atomic; | |
| pub mod barrier; | |
| pub mod completion; | |
| mod condvar; | |
| pub mod lock; | |
| mod locked_by; | |
| pub mod poll; | |
| pub mod rcu; | |
| mod refcount; | |
| mod set_once; | |
| pub use arc::{Arc, ArcBorrow, UniqueArc}; | |
| pub use completion::Completion; | |
| pub use condvar::{new_condvar, CondVar, CondVarTimeoutResult}; | |
| pub use lock::global::{global_lock, GlobalGuard, GlobalLock, GlobalLockBackend, GlobalLockedBy}; | |
| pub use lock::mutex::{new_mutex, Mutex, MutexGuard}; | |
| pub use lock::spinlock::{new_spinlock, SpinLock, SpinLockGuard}; | |
| pub use locked_by::LockedBy; | |
| pub use refcount::Refcount; | |
| pub use set_once::SetOnce; | |
| /// Represents a lockdep class. | |
| /// | |
| /// Wraps the kernel's `struct lock_class_key`. | |
| #[repr(transparent)] | |
| #[pin_data(PinnedDrop)] | |
| pub struct LockClassKey { | |
| #[pin] | |
| inner: Opaque<bindings::lock_class_key>, | |
| } | |
| // SAFETY: Unregistering a lock class key from a different thread than where it was registered is | |
| // allowed. | |
| unsafe impl Send for LockClassKey {} | |
| // SAFETY: `bindings::lock_class_key` is designed to be used concurrently from multiple threads and | |
| // provides its own synchronization. | |
| unsafe impl Sync for LockClassKey {} | |
| impl LockClassKey { | |
| /// Initializes a statically allocated lock class key. | |
| /// | |
| /// This is usually used indirectly through the [`static_lock_class!`] macro. See its | |
| /// documentation for more information. | |
| /// | |
| /// # Safety | |
| /// | |
| /// * Before using the returned value, it must be pinned in a static memory location. | |
| /// * The destructor must never run on the returned `LockClassKey`. | |
| pub const unsafe fn new_static() -> Self { | |
| LockClassKey { | |
| inner: Opaque::uninit(), | |
| } | |
| } | |
| /// Initializes a dynamically allocated lock class key. | |
| /// | |
| /// In the common case of using a statically allocated lock class key, the | |
| /// [`static_lock_class!`] macro should be used instead. | |
| /// | |
| /// # Examples | |
| /// | |
| /// ``` | |
| /// use kernel::alloc::KBox; | |
| /// use kernel::types::ForeignOwnable; | |
| /// use kernel::sync::{LockClassKey, SpinLock}; | |
| /// use pin_init::stack_pin_init; | |
| /// | |
| /// let key = KBox::pin_init(LockClassKey::new_dynamic(), GFP_KERNEL)?; | |
| /// let key_ptr = key.into_foreign(); | |
| /// | |
| /// { | |
| /// stack_pin_init!(let num: SpinLock<u32> = SpinLock::new( | |
| /// 0, | |
| /// c"my_spinlock", | |
| /// // SAFETY: `key_ptr` is returned by the above `into_foreign()`, whose | |
| /// // `from_foreign()` has not yet been called. | |
| /// unsafe { <Pin<KBox<LockClassKey>> as ForeignOwnable>::borrow(key_ptr) } | |
| /// )); | |
| /// } | |
| /// | |
| /// // SAFETY: We dropped `num`, the only use of the key, so the result of the previous | |
| /// // `borrow` has also been dropped. Thus, it's safe to use from_foreign. | |
| /// unsafe { drop(<Pin<KBox<LockClassKey>> as ForeignOwnable>::from_foreign(key_ptr)) }; | |
| /// # Ok::<(), Error>(()) | |
| /// ``` | |
| pub fn new_dynamic() -> impl PinInit<Self> { | |
| pin_init!(Self { | |
| // SAFETY: lockdep_register_key expects an uninitialized block of memory | |
| inner <- Opaque::ffi_init(|slot| unsafe { bindings::lockdep_register_key(slot) }) | |
| }) | |
| } | |
| /// Returns a raw pointer to the inner C struct. | |
| /// | |
| /// It is up to the caller to use the raw pointer correctly. | |
| pub fn as_ptr(&self) -> *mut bindings::lock_class_key { | |
| self.inner.get() | |
| } | |
| } | |
| #[pinned_drop] | |
| impl PinnedDrop for LockClassKey { | |
| fn drop(self: Pin<&mut Self>) { | |
| // SAFETY: `self.as_ptr()` was registered with lockdep and `self` is pinned, so the address | |
| // hasn't changed. Thus, it's safe to pass it to unregister. | |
| unsafe { bindings::lockdep_unregister_key(self.as_ptr()) } | |
| } | |
| } | |
| /// Defines a new static lock class and returns a pointer to it. | |
| /// | |
| /// # Examples | |
| /// | |
| /// ``` | |
| /// use kernel::sync::{static_lock_class, Arc, SpinLock}; | |
| /// | |
| /// fn new_locked_int() -> Result<Arc<SpinLock<u32>>> { | |
| /// Arc::pin_init(SpinLock::new( | |
| /// 42, | |
| /// c"new_locked_int", | |
| /// static_lock_class!(), | |
| /// ), GFP_KERNEL) | |
| /// } | |
| /// ``` | |
| #[macro_export] | |
| macro_rules! static_lock_class { | |
| () => {{ | |
| static CLASS: $crate::sync::LockClassKey = | |
| // SAFETY: The returned `LockClassKey` is stored in static memory and we pin it. Drop | |
| // never runs on a static global. | |
| unsafe { $crate::sync::LockClassKey::new_static() }; | |
| $crate::prelude::Pin::static_ref(&CLASS) | |
| }}; | |
| } | |
| pub use static_lock_class; | |
| /// Returns the given string, if one is provided, otherwise generates one based on the source code | |
| /// location. | |
| #[doc(hidden)] | |
| #[macro_export] | |
| macro_rules! optional_name { | |
| () => { | |
| $crate::c_str!(::core::concat!(::core::file!(), ":", ::core::line!())) | |
| }; | |
| ($name:literal) => { | |
| $crate::c_str!($name) | |
| }; | |
| } |