From 2e907a3ac2fcaa799f570e07c35f54efae39829b Mon Sep 17 00:00:00 2001 From: Brian Anderson Date: Mon, 8 Apr 2013 16:07:54 -0700 Subject: core: Remove all but one drop block in favor of `finally` --- src/libcore/task/mod.rs | 69 ++++++++++++------------------------------------- 1 file changed, 17 insertions(+), 52 deletions(-) (limited to 'src/libcore/task') diff --git a/src/libcore/task/mod.rs b/src/libcore/task/mod.rs index ee454312e04..502efcf9dc6 100644 --- a/src/libcore/task/mod.rs +++ b/src/libcore/task/mod.rs @@ -42,6 +42,7 @@ use result; use task::rt::{task_id, sched_id, rust_task}; use util; use util::replace; +use unstable::finally::Finally; #[cfg(test)] use comm::SharedChan; @@ -565,51 +566,27 @@ pub fn get_scheduler() -> Scheduler { * ~~~ */ pub unsafe fn unkillable(f: &fn() -> U) -> U { - struct AllowFailure { - t: *rust_task, - drop { - unsafe { - rt::rust_task_allow_kill(self.t); - } - } - } - - fn AllowFailure(t: *rust_task) -> AllowFailure{ - AllowFailure { - t: t - } - } - unsafe { let t = rt::rust_get_task(); - let _allow_failure = AllowFailure(t); rt::rust_task_inhibit_kill(t); - f() + do (|| { + f() + }).finally { + rt::rust_task_allow_kill(t); + } } } /// The inverse of unkillable. Only ever to be used nested in unkillable(). pub unsafe fn rekillable(f: &fn() -> U) -> U { - struct DisallowFailure { - t: *rust_task, - drop { - unsafe { - rt::rust_task_inhibit_kill(self.t); - } - } - } - - fn DisallowFailure(t: *rust_task) -> DisallowFailure { - DisallowFailure { - t: t - } - } - unsafe { let t = rt::rust_get_task(); - let _allow_failure = DisallowFailure(t); rt::rust_task_allow_kill(t); - f() + do (|| { + f() + }).finally { + rt::rust_task_inhibit_kill(t); + } } } @@ -618,28 +595,16 @@ pub unsafe fn rekillable(f: &fn() -> U) -> U { * For use with exclusive ARCs, which use pthread mutexes directly. */ pub unsafe fn atomically(f: &fn() -> U) -> U { - struct DeferInterrupts { - t: *rust_task, - drop { - unsafe { - rt::rust_task_allow_yield(self.t); - rt::rust_task_allow_kill(self.t); - } - } - } - - fn DeferInterrupts(t: *rust_task) -> DeferInterrupts { - DeferInterrupts { - t: t - } - } - unsafe { let t = rt::rust_get_task(); - let _interrupts = DeferInterrupts(t); rt::rust_task_inhibit_kill(t); rt::rust_task_inhibit_yield(t); - f() + do (|| { + f() + }).finally { + rt::rust_task_allow_yield(t); + rt::rust_task_allow_kill(t); + } } } -- cgit 1.4.1-3-g733a5