55 pub struct Condvar {  struct
61 impl Condvar {  argument
63     pub fn new() -> Condvar {  in new()
64         Condvar {  in new()
119             self as *const Condvar as usize,  in wait()  constant
120             WaitingFor::Condvar,  in wait()
143             self as *const Condvar as usize,  in wait_read()  constant
144             WaitingFor::Condvar,  in wait_read()
353             let old_waiter = if waiter.is_linked() && waiting_for == WaitingFor::Condvar {  in cancel_waiter()
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
505         let cv = Condvar::new();  in smoke()
513         let cv = Arc::new(Condvar::new());  in notify_one()
533         let cv = Arc::new(Condvar::new());  in multi_mutex()
582         async fn notify(mu: Rc<Mutex<()>>, cv: Rc<Condvar>) {  in notify_one_single_thread_async()  argument
587         async fn wait(mu: Rc<Mutex<()>>, cv: Rc<Condvar>, spawner: LocalSpawner) {  in notify_one_single_thread_async()  argument
604         let cv = Rc::new(Condvar::new());  in notify_one_single_thread_async()
615         async fn notify(mu: Arc<Mutex<()>>, cv: Arc<Condvar>) {  in notify_one_multi_thread_async()  argument
620         async fn wait(mu: Arc<Mutex<()>>, cv: Arc<Condvar>, tx: Sender<()>, pool: ThreadPool) {  in notify_one_multi_thread_async()  argument
636         let cv = Arc::new(Condvar::new());  in notify_one_multi_thread_async()
651         async fn observe(mu: &Arc<Mutex<usize>>, cv: &Arc<Condvar>) {  in notify_one_with_cancel()  argument
659         async fn decrement(mu: &Arc<Mutex<usize>>, cv: &Arc<Condvar>) {  in notify_one_with_cancel()  argument
667         async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) {  in notify_one_with_cancel()  argument
678             cv: Arc<Condvar>,  in notify_one_with_cancel()  argument
680             alt_cv: Arc<Condvar>,  in notify_one_with_cancel()  argument
695             cv: Arc<Condvar>,  in notify_one_with_cancel()  argument
697             alt_cv: Arc<Condvar>,  in notify_one_with_cancel()  argument
715         let cv = Arc::new(Condvar::new());  in notify_one_with_cancel()
716         let alt_cv = Arc::new(Condvar::new());  in notify_one_with_cancel()
761         async fn decrement(mu: &Arc<Mutex<usize>>, cv: &Arc<Condvar>) {  in notify_all_with_cancel()  argument
769         async fn increment(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>, done: Sender<()>) {  in notify_all_with_cancel()  argument
780             cv: Arc<Condvar>,  in notify_all_with_cancel()  argument
782             alt_cv: Arc<Condvar>,  in notify_all_with_cancel()  argument
800         let cv = Arc::new(Condvar::new());  in notify_all_with_cancel()
801         let alt_cv = Arc::new(Condvar::new());  in notify_all_with_cancel()
835         let cv = Arc::new(Condvar::new());  in notify_all()
876         async fn reset(mu: Rc<Mutex<usize>>, cv: Rc<Condvar>) {  in notify_all_single_thread_async()  argument
882         async fn watcher(mu: Rc<Mutex<usize>>, cv: Rc<Condvar>, spawner: LocalSpawner) {  in notify_all_single_thread_async()  argument
900         let cv = Rc::new(Condvar::new());  in notify_all_single_thread_async()
915         async fn reset(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) {  in notify_all_multi_thread_async()  argument
923             cv: Arc<Condvar>,  in notify_all_multi_thread_async()  argument
943         let cv = Arc::new(Condvar::new());  in notify_all_multi_thread_async()
958         async fn read(mu: Arc<Mutex<bool>>, cv: Arc<Condvar>) {  in wake_all_readers()  argument
966         let cv = Arc::new(Condvar::new());  in wake_all_readers()
1004         async fn dec(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) {  in cancel_before_notify()  argument
1015         let cv = Arc::new(Condvar::new());  in cancel_before_notify()
1049         async fn dec(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) {  in cancel_after_notify()  argument
1060         let cv = Arc::new(Condvar::new());  in cancel_after_notify()
1093         async fn dec(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) {  in cancel_after_transfer()  argument
1104         let cv = Arc::new(Condvar::new());  in cancel_after_transfer()
1148         async fn dec(mu: Arc<Mutex<usize>>, cv: Arc<Condvar>) {  in cancel_after_transfer_and_wake()  argument
1159         let cv = Arc::new(Condvar::new());  in cancel_after_transfer_and_wake()
1199             cv: Arc<Condvar>,  in timed_wait()  argument
1225         let cv = Arc::new(Condvar::new());  in timed_wait()