Searched refs:will_wake (Results 1 – 13 of 13) sorted by relevance
57 assert!(w1.will_wake(&w2)); in ref_wake_same()58 assert!(w2.will_wake(&w3)); in ref_wake_same()
191 unsafe fn will_wake(&self, cx: &mut Context<'_>) -> bool { in will_wake() method192 self.with_task(|w| w.will_wake(cx.waker())) in will_wake()487 let will_notify = unsafe { inner.tx_task.will_wake(cx) }; in poll_closed()743 let will_notify = unsafe { self.rx_task.will_wake(cx) }; in poll_recv()
648 if !w.waker.as_ref().unwrap().will_wake(cx.waker()) { in poll()
377 .map(|waker| !waker.will_wake(cx.waker())) in poll_acquire()
745 Some(ref w) if w.will_wake(waker) => {} in recv_ref()
311 let will_wake = unsafe { in can_read_output() localVariable314 trailer.will_wake(waker) in can_read_output()317 if will_wake { in can_read_output()
314 pub(crate) unsafe fn will_wake(&self, waker: &Waker) -> bool { in will_wake() method316 .with(|ptr| (*ptr).as_ref().unwrap().will_wake(waker)) in will_wake()
63 Some(c) if !w.will_wake(c) => return Some(w), in take()
316 if !existing.will_wake(cx.waker()) { in poll_readiness()499 if !w.waker.as_ref().unwrap().will_wake(cx.waker()) {
98 if guard.waker.is_none() || !guard.waker.as_ref().unwrap().will_wake(cx.waker()) { in poll()
185 Some(ref old_waker) if new_waker.will_wake(old_waker) => {} in record_waker()
56 Self::Waiting(w) if waker.will_wake(w) => {}, in register()
957 - rt: fix `Waker::will_wake` to return true when tasks match ([#2045]).