Searched refs:poll_lock (Results 1 – 5 of 5) sorted by relevance
16 let mut lock = match a.poll_lock() { in smoke()23 assert!(b.poll_lock().is_pending()); in smoke()24 assert!(a.poll_lock().is_pending()); in smoke()27 assert!(b.poll_lock().is_ready()); in smoke()28 assert!(a.poll_lock().is_ready()); in smoke()31 let lock = match b.poll_lock() { in smoke()69 match a.poll_lock() { in concurrent()73 match b.poll_lock() { in concurrent()96 let mut a = match a.poll_lock() { in concurrent()
106 let mut inner = ready!(self.inner.poll_lock(cx)); in poll_read()117 let mut inner = ready!(self.inner.poll_lock(cx)); in poll_write()122 let mut inner = ready!(self.inner.poll_lock(cx)); in poll_flush()127 let mut inner = ready!(self.inner.poll_lock(cx)); in poll_shutdown()133 fn poll_lock(&self, cx: &mut Context<'_>) -> Poll<Guard<'_, T>> { in poll_lock() method
33 ready!(self.0.poll_lock(cx)).as_pin_mut().poll_next(cx) in poll_next()79 let mut inner = ready!(this.lock.poll_lock(cx)); in poll_lock_and_flush_slot()103 let mut inner = ready!(this.lock.poll_lock(cx)); in poll_flush()110 let mut inner = ready!(this.lock.poll_lock(cx)); in poll_close()
90 pub fn poll_lock(&self, cx: &mut Context<'_>) -> Poll<BiLockGuard<'_, T>> { in poll_lock() method281 self.bilock.poll_lock(cx) in poll()
28 let mut l = ready!(lock.poll_lock(cx)); in lock_and_then()