mirror of
https://github.com/bspeice/qadapt
synced 2024-11-23 06:18:10 -05:00
Merge pull request #7 from bspeice/no_panic_unused
Don't panic when calling guards without QADAPT enabled
This commit is contained in:
commit
66d7da873a
1
.gitignore
vendored
1
.gitignore
vendored
@ -1,3 +1,4 @@
|
|||||||
/target
|
/target
|
||||||
**/*.rs.bk
|
**/*.rs.bk
|
||||||
Cargo.lock
|
Cargo.lock
|
||||||
|
*.swp
|
||||||
|
135
src/lib.rs
135
src/lib.rs
@ -17,18 +17,31 @@
|
|||||||
//! Actually making use of QADAPT is straight-forward. To set up the allocator,
|
//! Actually making use of QADAPT is straight-forward. To set up the allocator,
|
||||||
//! place the following snippet in either your program binaries (main.rs) or tests:
|
//! place the following snippet in either your program binaries (main.rs) or tests:
|
||||||
//!
|
//!
|
||||||
//! ```rust,ignore
|
//! ```rust
|
||||||
//! use qadapt::QADAPT;
|
//! use qadapt::QADAPT;
|
||||||
//!
|
//!
|
||||||
//! #[global_allocator]
|
//! #[global_allocator]
|
||||||
//! static Q: QADAPT = QADAPT;
|
//! static Q: QADAPT = QADAPT;
|
||||||
|
//!
|
||||||
|
//! fn main() {
|
||||||
|
//! # // Because `debug_assertions` are on for doctests in release mode
|
||||||
|
//! # // we have to add an extra guard.
|
||||||
|
//! # if qadapt::is_active() {
|
||||||
|
//! assert!(qadapt::is_active());
|
||||||
|
//! # }
|
||||||
|
//! }
|
||||||
//! ```
|
//! ```
|
||||||
//!
|
//!
|
||||||
//! After that, there are two ways of telling QADAPT that it should trigger a panic:
|
//! After that, there are two ways of telling QADAPT that it should trigger a panic:
|
||||||
//!
|
//!
|
||||||
//! 1. Annotate functions with the `#[no_alloc]` proc macro:
|
//! 1. Annotate functions with the `#[no_alloc]` proc macro:
|
||||||
//! ```rust,no_run
|
//! ```rust
|
||||||
//! use qadapt::no_alloc;
|
//! use qadapt::no_alloc;
|
||||||
|
//! use qadapt::QADAPT;
|
||||||
|
//! use std::panic::catch_unwind;
|
||||||
|
//!
|
||||||
|
//! #[global_allocator]
|
||||||
|
//! static Q: QADAPT = QADAPT;
|
||||||
//!
|
//!
|
||||||
//! // This function is fine, there are no allocations here
|
//! // This function is fine, there are no allocations here
|
||||||
//! #[no_alloc]
|
//! #[no_alloc]
|
||||||
@ -44,15 +57,23 @@
|
|||||||
//!
|
//!
|
||||||
//! fn main() {
|
//! fn main() {
|
||||||
//! do_math();
|
//! do_math();
|
||||||
//! does_panic();
|
//!
|
||||||
|
//! let err = catch_unwind(|| does_panic());
|
||||||
|
//! # if qadapt::is_active() {
|
||||||
|
//! assert!(err.is_err());
|
||||||
|
//! # }
|
||||||
//! }
|
//! }
|
||||||
//! ```
|
//! ```
|
||||||
//!
|
//!
|
||||||
//! 2. Evaluate expressions with the `assert_no_alloc!` macro
|
//! 2. Evaluate expressions with the `assert_no_alloc!` macro
|
||||||
//! ```rust,no_run
|
//! ```rust
|
||||||
//! use qadapt::assert_no_alloc;
|
//! use qadapt::assert_no_alloc;
|
||||||
|
//! use qadapt::QADAPT;
|
||||||
//!
|
//!
|
||||||
//! fn do_work() {
|
//! #[global_allocator]
|
||||||
|
//! static Q: QADAPT = QADAPT;
|
||||||
|
//!
|
||||||
|
//! fn main() {
|
||||||
//! // This code is allowed to trigger an allocation
|
//! // This code is allowed to trigger an allocation
|
||||||
//! let b = Box::new(8);
|
//! let b = Box::new(8);
|
||||||
//!
|
//!
|
||||||
@ -60,6 +81,7 @@
|
|||||||
//! let x = assert_no_alloc!(*b + 2);
|
//! let x = assert_no_alloc!(*b + 2);
|
||||||
//! assert_eq!(x, 10);
|
//! assert_eq!(x, 10);
|
||||||
//! }
|
//! }
|
||||||
|
//! ```
|
||||||
#![deny(missing_docs)]
|
#![deny(missing_docs)]
|
||||||
|
|
||||||
// thread_id is necessary because `std::thread::current()` panics if we have not yet
|
// thread_id is necessary because `std::thread::current()` panics if we have not yet
|
||||||
@ -78,17 +100,25 @@ use std::thread;
|
|||||||
thread_local! {
|
thread_local! {
|
||||||
static PROTECTION_LEVEL: RwLock<usize> = RwLock::new(0);
|
static PROTECTION_LEVEL: RwLock<usize> = RwLock::new(0);
|
||||||
}
|
}
|
||||||
|
static IS_ACTIVE: RwLock<bool> = RwLock::new(false);
|
||||||
|
static INTERNAL_ALLOCATION: RwLock<usize> = RwLock::new(usize::max_value());
|
||||||
|
|
||||||
/// The QADAPT allocator itself
|
/// The QADAPT allocator itself
|
||||||
///
|
///
|
||||||
/// To make use of the allocator, include this code block in your program
|
/// To make use of the allocator, include this code block in your program
|
||||||
/// binaries/tests:
|
/// binaries/tests:
|
||||||
///
|
///
|
||||||
/// ```rust,ignore
|
/// ```rust
|
||||||
/// use qadapt::QADAPT;
|
/// use qadapt::QADAPT;
|
||||||
///
|
///
|
||||||
/// #[global_allocator]
|
/// #[global_allocator]
|
||||||
/// static Q: QADAPT = QADAPT;
|
/// static Q: QADAPT = QADAPT;
|
||||||
|
///
|
||||||
|
/// fn main() {
|
||||||
|
/// # if qadapt::is_active() {
|
||||||
|
/// assert!(qadapt::is_active());
|
||||||
|
/// # }
|
||||||
|
/// }
|
||||||
/// ```
|
/// ```
|
||||||
pub struct QADAPT;
|
pub struct QADAPT;
|
||||||
|
|
||||||
@ -99,9 +129,13 @@ static SYSTEM_ALLOC: System = System;
|
|||||||
///
|
///
|
||||||
/// **Example**:
|
/// **Example**:
|
||||||
///
|
///
|
||||||
/// ```rust,no_run
|
/// ```rust
|
||||||
/// use qadapt::enter_protected;
|
/// use qadapt::enter_protected;
|
||||||
/// use qadapt::exit_protected;
|
/// use qadapt::exit_protected;
|
||||||
|
/// use qadapt::QADAPT;
|
||||||
|
///
|
||||||
|
/// #[global_allocator]
|
||||||
|
/// static Q: QADAPT = QADAPT;
|
||||||
///
|
///
|
||||||
/// fn main() {
|
/// fn main() {
|
||||||
/// // Force an allocation by using a Box
|
/// // Force an allocation by using a Box
|
||||||
@ -119,14 +153,10 @@ static SYSTEM_ALLOC: System = System;
|
|||||||
pub fn enter_protected() {
|
pub fn enter_protected() {
|
||||||
#[cfg(debug_assertions)]
|
#[cfg(debug_assertions)]
|
||||||
{
|
{
|
||||||
if thread::panicking() {
|
if thread::panicking() || !is_active() {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if !*IS_ACTIVE.read() {
|
|
||||||
panic!("QADAPT not initialized when using allocation guards; please verify `#[global_allocator]` is set!");
|
|
||||||
}
|
|
||||||
|
|
||||||
PROTECTION_LEVEL
|
PROTECTION_LEVEL
|
||||||
.try_with(|v| {
|
.try_with(|v| {
|
||||||
*v.write() += 1;
|
*v.write() += 1;
|
||||||
@ -140,9 +170,13 @@ pub fn enter_protected() {
|
|||||||
///
|
///
|
||||||
/// **Example**:
|
/// **Example**:
|
||||||
///
|
///
|
||||||
/// ```rust,no_run
|
/// ```rust
|
||||||
/// use qadapt::enter_protected;
|
/// use qadapt::enter_protected;
|
||||||
/// use qadapt::exit_protected;
|
/// use qadapt::exit_protected;
|
||||||
|
/// use qadapt::QADAPT;
|
||||||
|
///
|
||||||
|
/// #[global_allocator]
|
||||||
|
/// static Q: QADAPT = QADAPT;
|
||||||
///
|
///
|
||||||
/// fn main() {
|
/// fn main() {
|
||||||
/// // Force an allocation by using a Box
|
/// // Force an allocation by using a Box
|
||||||
@ -160,7 +194,7 @@ pub fn enter_protected() {
|
|||||||
pub fn exit_protected() {
|
pub fn exit_protected() {
|
||||||
#[cfg(debug_assertions)]
|
#[cfg(debug_assertions)]
|
||||||
{
|
{
|
||||||
if thread::panicking() {
|
if thread::panicking() || !is_active() {
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -183,8 +217,12 @@ pub fn exit_protected() {
|
|||||||
///
|
///
|
||||||
/// **Example**:
|
/// **Example**:
|
||||||
///
|
///
|
||||||
/// ```rust,no_run
|
/// ```rust
|
||||||
/// use qadapt::assert_no_alloc;
|
/// use qadapt::assert_no_alloc;
|
||||||
|
/// use qadapt::QADAPT;
|
||||||
|
///
|
||||||
|
/// #[global_allocator]
|
||||||
|
/// static Q: QADAPT = QADAPT;
|
||||||
///
|
///
|
||||||
/// fn main() {
|
/// fn main() {
|
||||||
/// assert_no_alloc!(2 + 2);
|
/// assert_no_alloc!(2 + 2);
|
||||||
@ -196,8 +234,13 @@ pub fn exit_protected() {
|
|||||||
/// in code that was not intended to be allocation-free. The compiler will warn you
|
/// in code that was not intended to be allocation-free. The compiler will warn you
|
||||||
/// that there is an unreachable statement if this happens.
|
/// that there is an unreachable statement if this happens.
|
||||||
///
|
///
|
||||||
/// ```rust,no_run
|
/// ```rust
|
||||||
/// use qadapt::assert_no_alloc;
|
/// use qadapt::assert_no_alloc;
|
||||||
|
/// use qadapt::QADAPT;
|
||||||
|
/// use std::panic::catch_unwind;
|
||||||
|
///
|
||||||
|
/// #[global_allocator]
|
||||||
|
/// static Q: QADAPT = QADAPT;
|
||||||
///
|
///
|
||||||
/// fn early_return() -> usize {
|
/// fn early_return() -> usize {
|
||||||
/// assert_no_alloc!(return 8);
|
/// assert_no_alloc!(return 8);
|
||||||
@ -206,10 +249,14 @@ pub fn exit_protected() {
|
|||||||
/// fn main() {
|
/// fn main() {
|
||||||
/// let x = early_return();
|
/// let x = early_return();
|
||||||
///
|
///
|
||||||
/// // This triggers a panic - `Box::new` forces an allocation,
|
/// // Even though only the `early_return` function contains
|
||||||
/// // and QADAPT still thinks we're in a protected region because
|
/// // QADAPT allocation guards, this triggers a panic:
|
||||||
/// // of a return in the `early_return()` function
|
/// // `Box::new` forces an allocation, and QADAPT still thinks
|
||||||
/// let b = Box::new(x);
|
/// // we're in a protected region because of the return in `early_return()`
|
||||||
|
/// # if qadapt::is_active() {
|
||||||
|
/// let res = catch_unwind(|| Box::new(x));
|
||||||
|
/// assert!(res.is_err());
|
||||||
|
/// # }
|
||||||
/// }
|
/// }
|
||||||
#[macro_export]
|
#[macro_export]
|
||||||
macro_rules! assert_no_alloc {
|
macro_rules! assert_no_alloc {
|
||||||
@ -221,19 +268,23 @@ macro_rules! assert_no_alloc {
|
|||||||
}};
|
}};
|
||||||
}
|
}
|
||||||
|
|
||||||
static IS_ACTIVE: RwLock<bool> = RwLock::new(false);
|
/// Get the current "protection level" in QADAPT: calls to `enter_protected() - exit_protected()`.
|
||||||
static INTERNAL_ALLOCATION: RwLock<usize> = RwLock::new(usize::max_value());
|
///
|
||||||
|
/// **Note**: For release builds, `protection_level()` will always return 0.
|
||||||
/// Get the current "protection level" in QADAPT: calls to enter_protected() - exit_protected()
|
|
||||||
///
|
///
|
||||||
/// **Example**:
|
/// **Example**:
|
||||||
///
|
///
|
||||||
/// ```rust,no_run
|
/// ```rust
|
||||||
/// use qadapt::enter_protected;
|
/// use qadapt::enter_protected;
|
||||||
/// use qadapt::exit_protected;
|
/// use qadapt::exit_protected;
|
||||||
|
/// use qadapt::QADAPT;
|
||||||
/// use qadapt::protection_level;
|
/// use qadapt::protection_level;
|
||||||
///
|
///
|
||||||
|
/// #[global_allocator]
|
||||||
|
/// static Q: QADAPT = QADAPT;
|
||||||
|
///
|
||||||
/// fn main() {
|
/// fn main() {
|
||||||
|
/// # if qadapt::is_active() {
|
||||||
/// enter_protected();
|
/// enter_protected();
|
||||||
/// // We're now in an allocation-protected code region
|
/// // We're now in an allocation-protected code region
|
||||||
/// assert_eq!(1, protection_level());
|
/// assert_eq!(1, protection_level());
|
||||||
@ -243,14 +294,44 @@ static INTERNAL_ALLOCATION: RwLock<usize> = RwLock::new(usize::max_value());
|
|||||||
/// assert_eq!(2, protection_level());
|
/// assert_eq!(2, protection_level());
|
||||||
/// exit_protected();
|
/// exit_protected();
|
||||||
/// exit_protected();
|
/// exit_protected();
|
||||||
|
/// # }
|
||||||
///
|
///
|
||||||
/// // It's now safe to allocate/drop
|
/// // It's now safe to allocate/drop
|
||||||
/// }
|
/// }
|
||||||
pub fn protection_level() -> usize {
|
pub fn protection_level() -> usize {
|
||||||
|
PROTECTION_LEVEL.try_with(|v| *v.read()).unwrap_or(0)
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Determine whether QADAPT will trigger thread panics if an allocation happens
|
||||||
|
/// during protected code. This should be used for making sure that QADAPT is
|
||||||
|
/// properly set up and initialized.
|
||||||
|
///
|
||||||
|
/// Note that this will return `false` in release builds even if QADAPT is set
|
||||||
|
/// as the `#[global_allocator]`.
|
||||||
|
///
|
||||||
|
/// **Example**:
|
||||||
|
///
|
||||||
|
/// ```rust
|
||||||
|
/// use qadapt::is_active;
|
||||||
|
/// use qadapt::QADAPT;
|
||||||
|
///
|
||||||
|
/// #[global_allocator]
|
||||||
|
/// static Q: QADAPT = QADAPT;
|
||||||
|
///
|
||||||
|
/// pub fn main() {
|
||||||
|
/// # if qadapt::is_active() {
|
||||||
|
/// assert!(is_active());
|
||||||
|
/// # }
|
||||||
|
/// }
|
||||||
|
/// ```
|
||||||
|
pub fn is_active() -> bool {
|
||||||
if cfg!(debug_assertions) {
|
if cfg!(debug_assertions) {
|
||||||
PROTECTION_LEVEL.try_with(|v| *v.read()).unwrap_or(0)
|
// Because there are heap allocations that happen before `fn main()`,
|
||||||
|
// we don't need to force an extra allocation here to guarantee that
|
||||||
|
// IS_ACTIVE is set
|
||||||
|
*IS_ACTIVE.read()
|
||||||
} else {
|
} else {
|
||||||
0
|
false
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
4
tests/inactive.rs
Normal file
4
tests/inactive.rs
Normal file
@ -0,0 +1,4 @@
|
|||||||
|
#[test]
|
||||||
|
fn is_inactive() {
|
||||||
|
assert!(!qadapt::is_active());
|
||||||
|
}
|
10
tests/inactive_release.rs
Normal file
10
tests/inactive_release.rs
Normal file
@ -0,0 +1,10 @@
|
|||||||
|
use qadapt::QADAPT;
|
||||||
|
|
||||||
|
#[global_allocator]
|
||||||
|
static Q: QADAPT = QADAPT;
|
||||||
|
|
||||||
|
#[cfg(not(debug_assertions))]
|
||||||
|
#[test]
|
||||||
|
fn release_only_inactive() {
|
||||||
|
assert!(!qadapt::is_active());
|
||||||
|
}
|
@ -1,11 +0,0 @@
|
|||||||
use qadapt::enter_protected;
|
|
||||||
|
|
||||||
#[test]
|
|
||||||
#[should_panic]
|
|
||||||
fn guard_without_initialization() {
|
|
||||||
if cfg!(debug_assertions) {
|
|
||||||
enter_protected();
|
|
||||||
} else {
|
|
||||||
panic!("Intentional")
|
|
||||||
}
|
|
||||||
}
|
|
Loading…
Reference in New Issue
Block a user