(self: &Arc<Self>)
| 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 | } |
nothing calls this directly
no outgoing calls
no test coverage detected