Skip to content

Adjustments to the panic hook API #32282

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 3 commits into from
Mar 18, 2016
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 15 additions & 1 deletion src/libstd/panic.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,21 @@ use sync::{Arc, Mutex, RwLock};
use sys_common::unwind;
use thread::Result;

pub use panicking::{take_handler, set_handler, PanicInfo, Location};
pub use panicking::{take_hook, set_hook, PanicInfo, Location};

///
#[rustc_deprecated(since = "1.9.0", reason = "renamed to set_hook")]
#[unstable(feature = "panic_handler", reason = "awaiting feedback", issue = "30449")]
pub fn set_handler<F>(handler: F) where F: Fn(&PanicInfo) + 'static + Sync + Send {
set_hook(Box::new(handler))
}

///
#[rustc_deprecated(since = "1.9.0", reason = "renamed to take_hook")]
#[unstable(feature = "panic_handler", reason = "awaiting feedback", issue = "30449")]
pub fn take_handler() -> Box<Fn(&PanicInfo) + 'static + Sync + Send> {
take_hook()
}

/// A marker trait which represents "panic safe" types in Rust.
///
Expand Down
62 changes: 30 additions & 32 deletions src/libstd/panicking.rs
Original file line number Diff line number Diff line change
Expand Up @@ -32,73 +32,71 @@ thread_local! {
}

#[derive(Copy, Clone)]
enum Handler {
enum Hook {
Default,
Custom(*mut (Fn(&PanicInfo) + 'static + Sync + Send)),
}

static HANDLER_LOCK: StaticRwLock = StaticRwLock::new();
static mut HANDLER: Handler = Handler::Default;
static HOOK_LOCK: StaticRwLock = StaticRwLock::new();
static mut HOOK: Hook = Hook::Default;
static FIRST_PANIC: AtomicBool = AtomicBool::new(true);

/// Registers a custom panic handler, replacing any that was previously
/// registered.
/// Registers a custom panic hook, replacing any that was previously registered.
///
/// The panic handler is invoked when a thread panics, but before it begins
/// unwinding the stack. The default handler prints a message to standard error
/// The panic hook is invoked when a thread panics, but before it begins
/// unwinding the stack. The default hook prints a message to standard error
/// and generates a backtrace if requested, but this behavior can be customized
/// with the `set_handler` and `take_handler` functions.
/// with the `set_hook` and `take_hook` functions.
///
/// The handler is provided with a `PanicInfo` struct which contains information
/// The hook is provided with a `PanicInfo` struct which contains information
/// about the origin of the panic, including the payload passed to `panic!` and
/// the source code location from which the panic originated.
///
/// The panic handler is a global resource.
/// The panic hook is a global resource.
///
/// # Panics
///
/// Panics if called from a panicking thread.
#[unstable(feature = "panic_handler", reason = "awaiting feedback", issue = "30449")]
pub fn set_handler<F>(handler: F) where F: Fn(&PanicInfo) + 'static + Sync + Send {
pub fn set_hook(hook: Box<Fn(&PanicInfo) + 'static + Sync + Send>) {
if thread::panicking() {
panic!("cannot modify the panic handler from a panicking thread");
panic!("cannot modify the panic hook from a panicking thread");
}

let handler = Box::new(handler);
unsafe {
let lock = HANDLER_LOCK.write();
let old_handler = HANDLER;
HANDLER = Handler::Custom(Box::into_raw(handler));
let lock = HOOK_LOCK.write();
let old_hook = HOOK;
HOOK = Hook::Custom(Box::into_raw(hook));
drop(lock);

if let Handler::Custom(ptr) = old_handler {
if let Hook::Custom(ptr) = old_hook {
Box::from_raw(ptr);
}
}
}

/// Unregisters the current panic handler, returning it.
/// Unregisters the current panic hook, returning it.
///
/// If no custom handler is registered, the default handler will be returned.
/// If no custom hook is registered, the default hook will be returned.
///
/// # Panics
///
/// Panics if called from a panicking thread.
#[unstable(feature = "panic_handler", reason = "awaiting feedback", issue = "30449")]
pub fn take_handler() -> Box<Fn(&PanicInfo) + 'static + Sync + Send> {
pub fn take_hook() -> Box<Fn(&PanicInfo) + 'static + Sync + Send> {
if thread::panicking() {
panic!("cannot modify the panic handler from a panicking thread");
panic!("cannot modify the panic hook from a panicking thread");
}

unsafe {
let lock = HANDLER_LOCK.write();
let handler = HANDLER;
HANDLER = Handler::Default;
let lock = HOOK_LOCK.write();
let hook = HOOK;
HOOK = Hook::Default;
drop(lock);

match handler {
Handler::Default => Box::new(default_handler),
Handler::Custom(ptr) => {Box::from_raw(ptr)} // FIXME #30530
match hook {
Hook::Default => Box::new(default_hook),
Hook::Custom(ptr) => {Box::from_raw(ptr)} // FIXME #30530
}
}
}
Expand Down Expand Up @@ -151,7 +149,7 @@ impl<'a> Location<'a> {
}
}

fn default_handler(info: &PanicInfo) {
fn default_hook(info: &PanicInfo) {
let panics = PANIC_COUNT.with(|s| s.get());

// If this is a double panic, make sure that we print a backtrace
Expand Down Expand Up @@ -224,10 +222,10 @@ pub fn on_panic(obj: &(Any+Send), file: &'static str, line: u32) {
};

unsafe {
let _lock = HANDLER_LOCK.read();
match HANDLER {
Handler::Default => default_handler(&info),
Handler::Custom(ptr) => (*ptr)(&info),
let _lock = HOOK_LOCK.read();
match HOOK {
Hook::Default => default_hook(&info),
Hook::Custom(ptr) => (*ptr)(&info),
}
}

Expand Down
10 changes: 5 additions & 5 deletions src/test/run-pass/panic-handler-chain.rs
Original file line number Diff line number Diff line change
Expand Up @@ -17,12 +17,12 @@ static A: AtomicUsize = AtomicUsize::new(0);
static B: AtomicUsize = AtomicUsize::new(0);

fn main() {
panic::set_handler(|_| { A.fetch_add(1, Ordering::SeqCst); });
let handler = panic::take_handler();
panic::set_handler(move |info| {
panic::set_hook(Box::new(|_| { A.fetch_add(1, Ordering::SeqCst); }));
let hook = panic::take_hook();
panic::set_hook(Box::new(move |info| {
B.fetch_add(1, Ordering::SeqCst);
handler(info);
});
hook(info);
}));

let _ = thread::spawn(|| {
panic!();
Expand Down
30 changes: 15 additions & 15 deletions src/test/run-pass/panic-handler-flail-wildly.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,28 +15,28 @@ use std::panic;
use std::thread;

fn a() {
panic::set_handler(|_| println!("hello yes this is a"));
panic::take_handler();
panic::set_handler(|_| println!("hello yes this is a part 2"));
panic::take_handler();
panic::set_hook(Box::new(|_| println!("hello yes this is a")));
panic::take_hook();
panic::set_hook(Box::new(|_| println!("hello yes this is a part 2")));
panic::take_hook();
}

fn b() {
panic::take_handler();
panic::take_handler();
panic::take_handler();
panic::take_handler();
panic::take_handler();
panic::take_hook();
panic::take_hook();
panic::take_hook();
panic::take_hook();
panic::take_hook();
panic!();
}

fn c() {
panic::set_handler(|_| ());
panic::set_handler(|_| ());
panic::set_handler(|_| ());
panic::set_handler(|_| ());
panic::set_handler(|_| ());
panic::set_handler(|_| ());
panic::set_hook(Box::new(|_| ()));
panic::set_hook(Box::new(|_| ()));
panic::set_hook(Box::new(|_| ()));
panic::set_hook(Box::new(|_| ()));
panic::set_hook(Box::new(|_| ()));
panic::set_hook(Box::new(|_| ()));
panic!();
}

Expand Down
4 changes: 2 additions & 2 deletions src/test/run-pass/panic-handler-set-twice.rs
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,8 @@ use std::thread;
static A: AtomicUsize = AtomicUsize::new(0);

fn main() {
panic::set_handler(|_| ());
panic::set_handler(|info| { A.fetch_add(1, Ordering::SeqCst); });
panic::set_hook(Box::new(|_| ()));
panic::set_hook(Box::new(|info| { A.fetch_add(1, Ordering::SeqCst); }));

let _ = thread::spawn(|| {
panic!();
Expand Down