aboutsummaryrefslogtreecommitdiff
path: root/src/checked.rs
diff options
context:
space:
mode:
authorJorge Aparicio <japaricious@gmail.com>2017-04-07 18:14:48 -0500
committerJorge Aparicio <japaricious@gmail.com>2017-04-07 18:14:48 -0500
commitf2bab47aa4bdd04f79e608debe64e3ddcea07702 (patch)
tree5626aba835b65a100fbefdb6f1f33a27bcfe81ce /src/checked.rs
parent8e1c72057c6fdd09ad14e9b69596e17fcfd9335f (diff)
allow returns from checked::Resource.lock{,mut}
also add compiler barriers
Diffstat (limited to 'src/checked.rs')
-rw-r--r--src/checked.rs18
1 files changed, 12 insertions, 6 deletions
diff --git a/src/checked.rs b/src/checked.rs
index fbdf692..4c91c05 100644
--- a/src/checked.rs
+++ b/src/checked.rs
@@ -51,27 +51,33 @@ where
/// Locks the resource, blocking tasks with priority equal or smaller than
/// the ceiling `C`
- pub fn lock<F>(&'static self, f: F)
+ pub fn lock<R, F>(&'static self, f: F) -> R
where
- F: FnOnce(&T),
+ F: FnOnce(&T) -> R,
{
unsafe {
let old_basepri = acquire(&self.locked, C::ceiling());
- f(&*self.data.get());
+ ::compiler_barrier();
+ let ret = f(&*self.data.get());
+ ::compiler_barrier();
release(&self.locked, old_basepri);
+ ret
}
}
/// Mutably locks the resource, blocking tasks with priority equal or
/// smaller than the ceiling `C`
- pub fn lock_mut<F>(&'static self, f: F)
+ pub fn lock_mut<R, F>(&'static self, f: F) -> R
where
- F: FnOnce(&mut T),
+ F: FnOnce(&mut T) -> R,
{
unsafe {
let old_basepri = acquire(&self.locked, C::ceiling());
- f(&mut *self.data.get());
+ ::compiler_barrier();
+ let ret = f(&mut *self.data.get());
+ ::compiler_barrier();
release(&self.locked, old_basepri);
+ ret
}
}
}