berkus
/
actix-net
mirror of https://github.com/fafhrd91/actix-net
1
0
Fork 0
Code Issues Releases Wiki Activity

local-waker: Add safety docs

This commit is contained in:
Nur 2026-02-01 19:31:57 +06:00
parent 8ea3b14779
commit 08c16c4597
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
local-waker/src/lib.rs
View File

@ -44,12 +44,18 @@ impl LocalWaker {
#[inline] #[inline]
pub fn register(&self, waker: &Waker) -> bool { pub fn register(&self, waker: &Waker) -> bool {
let mut registered = false; let mut registered = false;
// SAFETY: `LocalWaker` is `!Send`, threfore this cannot be called from a separate thread.
// And this is an unique access before the assignment below.
if let Some(prev) = unsafe { &*self.waker.get() } { if let Some(prev) = unsafe { &*self.waker.get() } {
if waker.will_wake(prev) { if waker.will_wake(prev) {
return true; return true;
} }
registered = true; registered = true;
} }
// SAFETY: This can cause data races if called from a separate thread,
// but `LocalWaker` is `!Send` + `!Sync` so this won't happen.
unsafe { *self.waker.get() = Some(waker.clone()) } unsafe { *self.waker.get() = Some(waker.clone()) }
registered registered
} }