MCPcopy Create free account
hub / github.com/NthTensor/Forte / wake_by_ref

Method wake_by_ref

src/latch.rs:286–290  ·  view source on GitHub ↗
(self: &Arc<Self>)

Source from the content-addressed store, hash-verified

284 // Either way, there is no way we can fail to receive a `wake`.
285 atomic_wait::wait(&self.state, ASLEEP);
286 // Clear the sleeping bit for this worker.
287 waiting_bitmask.fetch_and(!seat_mask, Ordering::Relaxed);
288 }
289 // Set the state back to LOCKED so that we are ready to receive new
290 // signals.
291 self.state.store(LOCKED, Ordering::Relaxed);
292 }
293}

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected