X-Git-Url: http://git.bitcoin.ninja/index.cgi?a=blobdiff_plain;f=lightning%2Fsrc%2Fsync%2Fmod.rs;h=50ef40e295f50d0a0d9095a0f3dfe4c73916a340;hb=d0b8f455fe86d3e55231d35d35dd96693abe2049;hp=584338031fc060bd5178a2321802767c5792101c;hpb=f66f720fa54cdd28ac998dcc39c859567b2455e0;p=rust-lightning diff --git a/lightning/src/sync/mod.rs b/lightning/src/sync/mod.rs index 58433803..50ef40e2 100644 --- a/lightning/src/sync/mod.rs +++ b/lightning/src/sync/mod.rs @@ -1,9 +1,41 @@ +#[allow(dead_code)] // Depending on the compilation flags some variants are never used +#[derive(Debug, PartialEq, Eq)] +pub(crate) enum LockHeldState { + HeldByThread, + NotHeldByThread, + #[cfg(any(feature = "_bench_unstable", not(test)))] + Unsupported, +} + +pub(crate) trait LockTestExt { + fn held_by_thread(&self) -> LockHeldState; +} + +#[cfg(all(feature = "std", not(feature = "_bench_unstable"), test))] +mod debug_sync; +#[cfg(all(feature = "std", not(feature = "_bench_unstable"), test))] +pub use debug_sync::*; #[cfg(all(feature = "std", not(feature = "_bench_unstable"), test))] -pub use crate::debug_sync::*; +// Note that to make debug_sync's regex work this must not contain `debug_string` in the module name +mod test_lockorder_checks; + +#[cfg(all(feature = "std", any(feature = "_bench_unstable", not(test))))] +pub(crate) mod fairrwlock; #[cfg(all(feature = "std", any(feature = "_bench_unstable", not(test))))] -pub use ::std::sync::{Arc, Mutex, Condvar, MutexGuard, RwLock, RwLockReadGuard, RwLockWriteGuard}; +pub use {std::sync::{Arc, Mutex, Condvar, MutexGuard, RwLock, RwLockReadGuard, RwLockWriteGuard}, fairrwlock::FairRwLock}; + #[cfg(all(feature = "std", any(feature = "_bench_unstable", not(test))))] -pub use crate::util::fairrwlock::FairRwLock; +mod ext_impl { + use super::*; + impl LockTestExt for Mutex { + #[inline] + fn held_by_thread(&self) -> LockHeldState { LockHeldState::Unsupported } + } + impl LockTestExt for RwLock { + #[inline] + fn held_by_thread(&self) -> LockHeldState { LockHeldState::Unsupported } + } +} #[cfg(not(feature = "std"))] mod nostd_sync;