Searched refs:NOTIFIED (Results 1 – 6 of 6) sorted by relevance
| /external/rust/crates/tokio/src/runtime/ |
| D | park.rs | 40 const NOTIFIED: usize = 3; constant
127 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park()
152 Err(NOTIFIED) => { in park_condvar()
160 debug_assert_eq!(old, NOTIFIED, "park state changed unexpectedly"); in park_condvar()
172 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park_condvar()
189 Err(NOTIFIED) => { in park_driver()
197 debug_assert_eq!(old, NOTIFIED, "park state changed unexpectedly"); in park_driver()
208 NOTIFIED => {} // got a notification, hurray! in park_driver()
220 match self.state.swap(NOTIFIED, SeqCst) { in unpark()
222 NOTIFIED => {} // already unparked in unpark()
|
| /external/rust/crates/tokio/src/park/ |
| D | thread.rs | 32 const NOTIFIED: usize = 2; constant
85 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park()
96 Err(NOTIFIED) => { in park()
104 debug_assert_eq!(old, NOTIFIED, "park state changed unexpectedly"); in park()
116 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park()
132 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park_timeout()
146 Err(NOTIFIED) => { in park_timeout()
149 debug_assert_eq!(old, NOTIFIED, "park state changed unexpectedly"); in park_timeout()
163 NOTIFIED => {} // got a notification, hurray! in park_timeout()
175 match self.state.swap(NOTIFIED, SeqCst) { in unpark()
[all …]
|
| /external/rust/crates/crossbeam-utils/src/sync/ |
| D | parker.rs | 306 const NOTIFIED: usize = 2; constant
319 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park()
338 Err(NOTIFIED) => { in park()
345 assert_eq!(old, NOTIFIED, "park state changed unexpectedly"); in park()
365 NOTIFIED | PARKED => return, in park()
374 .compare_exchange(NOTIFIED, EMPTY, SeqCst, SeqCst) in park()
391 match self.state.swap(NOTIFIED, SeqCst) { in unpark()
393 NOTIFIED => return, // already unparked in unpark()
|
| /external/rust/crates/tokio/src/sync/ |
| D | notify.rs | 177 const NOTIFIED: usize = 2; constant
322 while let EMPTY | NOTIFIED = get_state(curr) { in notify_one()
326 let new = set_state(curr, NOTIFIED); in notify_one()
396 if let EMPTY | NOTIFIED = get_state(curr) { in notify_waiters()
466 EMPTY | NOTIFIED => { in notify_locked()
467 let res = state.compare_exchange(curr, set_state(curr, NOTIFIED), SeqCst, SeqCst); in notify_locked()
473 assert!(actual_state == EMPTY || actual_state == NOTIFIED); in notify_locked()
474 state.store(set_state(actual, NOTIFIED), SeqCst); in notify_locked()
543 set_state(curr, NOTIFIED), in poll()
582 assert_eq!(get_state(actual), NOTIFIED); in poll()
[all …]
|
| /external/rust/crates/grpcio/src/task/ |
| D | executor.rs | 79 const NOTIFIED: u8 = 1; constant
114 NOTIFIED, in mark_notified()
121 NOTIFIED, in mark_notified()
185 let mut init_state = if woken { NOTIFIED } else { IDLE }; in poll()
219 Err(NOTIFIED) => { in poll()
220 init_state = NOTIFIED; in poll()
|
| /external/rust/crates/tokio/src/runtime/task/ |
| D | state.rs | 29 const NOTIFIED: usize = 0b100; constant
41 const STATE_MASK: usize = LIFECYCLE_MASK | NOTIFIED | JOIN_INTEREST | JOIN_WAKER | CANCELLED;
58 const INITIAL_STATE: usize = (REF_ONE * 2) | JOIN_INTEREST | NOTIFIED;
176 let prev = Snapshot(self.val.fetch_or(NOTIFIED, AcqRel)); in transition_to_notified()
352 self.0 & NOTIFIED == NOTIFIED in is_notified()
356 self.0 &= !NOTIFIED in unset_notified()
|