| /external/libchromeos-rs/src/sync/ |
| D | cv.rs | 55 pub struct Condvar { struct
61 impl Condvar { argument
119 self as *const Condvar as usize, in wait() constant
143 self as *const Condvar as usize, in wait_read() constant
403 unsafe impl Send for Condvar {} implementation
404 unsafe impl Sync for Condvar {} implementation
406 impl Default for Condvar { implementation
468 let condvar = cv as *const Condvar; in cancel_waiter() constant
582 async fn notify(mu: Rc<Mutex<()>>, cv: Rc<Condvar>) { in notify_one_single_thread_async()
587 async fn wait(mu: Rc<Mutex<()>>, cv: Rc<Condvar>, spawner: LocalSpawner) { in notify_one_single_thread_async()
[all …]
|
| D | mu.rs | 2096 async fn read(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in transfer_notify_one()
2103 async fn write(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in transfer_notify_one()
2173 async fn dec(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in transfer_waiters_when_unlocked()
2220 async fn read(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in transfer_reader_writer()
2231 async fn write(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in transfer_reader_writer()
2340 async fn read(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in transfer_readers_with_read_lock()
|
| D | waiter.rs | 111 Condvar = 2, enumerator
|
| /external/crosvm/cros_async/src/sync/ |
| D | cv.rs | 56 pub struct Condvar { struct
62 impl Condvar { implementation
120 self as *const Condvar as usize, in wait() constant
144 self as *const Condvar as usize, in wait_read() constant
370 unsafe impl Send for Condvar {} implementation
371 unsafe impl Sync for Condvar {} implementation
373 impl Default for Condvar { implementation
433 let condvar = cv as *const Condvar; in cancel_waiter() constant
546 async fn notify(mu: Rc<Mutex<()>>, cv: Rc<Condvar>) { in notify_one_single_thread_async()
551 async fn wait(mu: Rc<Mutex<()>>, cv: Rc<Condvar>, spawner: LocalSpawner) { in notify_one_single_thread_async()
[all …]
|
| D | mu.rs | 1976 async fn read(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_one()
1983 async fn write(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_one()
2064 async fn dec(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_when_unlocked()
2110 async fn read(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_reader_writer()
2121 async fn write(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_reader_writer()
2228 async fn read(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_readers_with_read_lock()
|
| D | waiter.rs | 112 Condvar = 2, enumerator
|
| /external/crosvm/sync/src/ |
| D | condvar.rs | 11 pub struct Condvar { struct
12 std: StdCondvar, argument
15 impl Condvar { implementation
55 impl Debug for Condvar { implementation
|
| /external/rust/crates/parking_lot/src/ |
| D | condvar.rs | 90 pub struct Condvar { struct
94 impl Condvar { impl
401 impl Default for Condvar { implementation
408 impl fmt::Debug for Condvar { implementation
735 condition: &Condvar, in wait()
750 fn notify(style: NotifyStyle, condition: &Condvar, should_notify: bool) { in notify()
833 empty_condition: Arc<Condvar>, in consumer_thread()
834 full_condition: Arc<Condvar>, in consumer_thread()
868 empty_condition: Arc<Condvar>, in producer_thread()
869 full_condition: Arc<Condvar>, in producer_thread()
|
| /external/rust/crates/tokio/src/loom/std/ |
| D | parking_lot.rs | 21 pub(crate) struct Condvar(parking_lot::Condvar); struct
69 impl Condvar { implementation
|
| /external/adhd/sound_card_init/dsm/src/ |
| D | zero_player.rs | 158 ready: Arc<(Mutex<bool>, Condvar)>, in new() argument
|
| /external/crosvm/io_uring/src/ |
| D | uring.rs | 1350 fn wait_for_completion_thread(in_flight: &Mutex<isize>, cv: &Condvar) { in submit_from_any_thread()
1435 fn wait_for_completion_thread(in_flight: &Mutex<isize>, cv: &Condvar) { in multi_thread_submit_and_complete()
|