| /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 | 67 pub struct Condvar { struct
73 impl Condvar { impl
134 self as *const Condvar as usize, in wait() constant
158 self as *const Condvar as usize, in wait_read() constant
384 unsafe impl Send for Condvar {} implementation
385 unsafe impl Sync for Condvar {} implementation
387 impl Default for Condvar { implementation
447 let condvar = cv as *const Condvar; in cancel_waiter() constant
569 async fn notify(mu: Rc<Mutex<()>>, cv: Rc<Condvar>) { in notify_one_single_thread_async()
574 async fn wait(mu: Rc<Mutex<()>>, cv: Rc<Condvar>, spawner: LocalSpawner) { in notify_one_single_thread_async()
[all …]
|
| D | mu.rs | 1994 async fn read(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_one()
2001 async fn write(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_one()
2082 async fn dec(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_when_unlocked()
2128 async fn read(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_reader_writer()
2139 async fn write(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_reader_writer()
2246 async fn read(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) { in notify_readers_with_read_lock()
|
| D | waiter.rs | 119 Condvar = 2, enumerator
|
| /external/crosvm/common/sync/src/ |
| D | condvar.rs | 16 pub struct Condvar { struct
17 std: StdCondvar, argument
20 impl Condvar { impl
80 impl Debug for Condvar { implementation
|
| /external/rust/crates/parking_lot/src/ |
| D | condvar.rs | 90 pub struct Condvar { struct
94 impl Condvar { impl
510 impl Default for Condvar { implementation
517 impl fmt::Debug for Condvar { implementation
701 cv: Arc<Condvar>, in spawn_wait_while_notifier()
949 condition: &Condvar, in wait()
964 fn notify(style: NotifyStyle, condition: &Condvar, should_notify: bool) { in notify()
1047 empty_condition: Arc<Condvar>, in consumer_thread()
1048 full_condition: Arc<Condvar>, in consumer_thread()
1082 empty_condition: Arc<Condvar>, in producer_thread()
[all …]
|
| /external/rust/crates/tokio/src/loom/std/ |
| D | parking_lot.rs | 28 pub(crate) struct Condvar(PhantomData<std::sync::Condvar>, parking_lot::Condvar); struct
129 impl Condvar { implementation
|
| /external/crosvm/src/crosvm/sys/unix/ |
| D | vcpu.rs | 227 _guest_suspended_cvar: &Arc<(Mutex<bool>, Condvar)>, in handle_s2idle_request() argument
234 fn handle_s2idle_request(privileged_vm: bool, guest_suspended_cvar: &Arc<(Mutex<bool>, Condvar)>) { in handle_s2idle_request() argument
286 guest_suspended_cvar: Arc<(Mutex<bool>, Condvar)>, in vcpu_loop() argument
530 pub fn run_vcpu<V>( in run_vcpu()
|
| /external/crosvm/devices/src/virtio/snd/common_backend/ |
| D | async_funcs.rs | 528 async fn await_reset_signal(reset_signal_option: Option<&(AsyncMutex<bool>, Condvar)>) { in await_reset_signal() argument
545 reset_signal: Option<&(AsyncMutex<bool>, Condvar)>, in send_pcm_response_worker() argument
589 reset_signal: Option<&(AsyncMutex<bool>, Condvar)>, in handle_pcm_queue() argument
680 reset_signal: Option<&(AsyncMutex<bool>, Condvar)>, in handle_ctrl_queue() argument
|
| D | mod.rs | 578 async fn notify_reset_signal(reset_signal: &(AsyncMutex<bool>, Condvar)) { in notify_reset_signal() argument
|
| /external/crosvm/io_uring/tests/ |
| D | uring.rs | 535 fn wait_for_completion_thread(in_flight: &Mutex<isize>, cv: &Condvar) { in submit_from_any_thread()
620 fn wait_for_completion_thread(in_flight: &Mutex<isize>, cv: &Condvar) { in multi_thread_submit_and_complete()
|
| /external/crosvm/src/crosvm/sys/ |
| D | unix.rs | 2417 guest_suspended_cvar: Arc<(Mutex<bool>, Condvar)>, in trigger_vm_suspend_and_wait_for_entry() argument
|