56 pub struct Condvar {  struct
62 impl Condvar {  argument
64     pub fn new() -> Condvar {  in new()
65         Condvar {  in new()
120             self as *const Condvar as usize,  in wait()  constant
121             WaitingFor::Condvar,  in wait()
144             self as *const Condvar as usize,  in wait_read()  constant
145             WaitingFor::Condvar,  in wait_read()
332         let old_waiter = if waiter.is_linked() && waiting_for == WaitingFor::Condvar {  in cancel_waiter()
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
470         let cv = Condvar::new();  in smoke()
478         let cv = Arc::new(Condvar::new());  in notify_one()
498         let cv = Arc::new(Condvar::new());  in multi_mutex()
546         async fn notify(mu: Rc<Mutex<()>>, cv: Rc<Condvar>) {  in notify_one_single_thread_async()  argument
551         async fn wait(mu: Rc<Mutex<()>>, cv: Rc<Condvar>, spawner: LocalSpawner) {  in notify_one_single_thread_async()  argument
568         let cv = Rc::new(Condvar::new());  in notify_one_single_thread_async()
579         async fn notify(mu: Arc<Mutex<()>>, cv: Arc<Condvar>) {  in notify_one_multi_thread_async()  argument
584         async fn wait(mu: Arc<Mutex<()>>, cv: Arc<Condvar>, tx: Sender<()>, pool: ThreadPool) {  in notify_one_multi_thread_async()  argument
600         let cv = Arc::new(Condvar::new());  in notify_one_multi_thread_async()
615         async fn observe(mu: &Arc<Mutex<usize>>, cv: &Arc<Condvar>) {  in notify_one_with_cancel()  argument
623         async fn decrement(mu: &Arc<Mutex<usize>>, cv: &Arc<Condvar>) {  in notify_one_with_cancel()  argument
631         async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) {  in notify_one_with_cancel()  argument
642             cv: Arc<Condvar>,  in notify_one_with_cancel()  argument
644             alt_cv: Arc<Condvar>,  in notify_one_with_cancel()  argument
659             cv: Arc<Condvar>,  in notify_one_with_cancel()  argument
661             alt_cv: Arc<Condvar>,  in notify_one_with_cancel()  argument
679         let cv = Arc::new(Condvar::new());  in notify_one_with_cancel()
680         let alt_cv = Arc::new(Condvar::new());  in notify_one_with_cancel()
725         async fn decrement(mu: &Arc<Mutex<usize>>, cv: &Arc<Condvar>) {  in notify_all_with_cancel()  argument
733         async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) {  in notify_all_with_cancel()  argument
744             cv: Arc<Condvar>,  in notify_all_with_cancel()  argument
746             alt_cv: Arc<Condvar>,  in notify_all_with_cancel()  argument
764         let cv = Arc::new(Condvar::new());  in notify_all_with_cancel()
765         let alt_cv = Arc::new(Condvar::new());  in notify_all_with_cancel()
799         let cv = Arc::new(Condvar::new());  in notify_all()
840         async fn reset(mu: Rc<Mutex<usize>>, cv: Rc<Condvar>) {  in notify_all_single_thread_async()  argument
846         async fn watcher(mu: Rc<Mutex<usize>>, cv: Rc<Condvar>, spawner: LocalSpawner) {  in notify_all_single_thread_async()  argument
864         let cv = Rc::new(Condvar::new());  in notify_all_single_thread_async()
879         async fn reset(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) {  in notify_all_multi_thread_async()  argument
887             cv: Arc<Condvar>,  in notify_all_multi_thread_async()  argument
907         let cv = Arc::new(Condvar::new());  in notify_all_multi_thread_async()
922         async fn read(mu: Arc<Mutex<bool>>, cv: Arc<Condvar>) {  in wake_all_readers()  argument
930         let cv = Arc::new(Condvar::new());  in wake_all_readers()
968         async fn dec(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) {  in cancel_before_notify()  argument
979         let cv = Arc::new(Condvar::new());  in cancel_before_notify()
1013         async fn dec(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) {  in cancel_after_notify_one()  argument
1024         let cv = Arc::new(Condvar::new());  in cancel_after_notify_one()
1057         async fn dec(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) {  in cancel_after_notify_all()  argument
1068         let cv = Arc::new(Condvar::new());  in cancel_after_notify_all()
1107             cv: Arc<Condvar>,  in timed_wait()  argument
1133         let cv = Arc::new(Condvar::new());  in timed_wait()