Searched refs:is_closed (Results 1 – 11 of 11) sorted by relevance
203 pub fn is_closed(&self) -> bool { in is_closed() method204 self.inner.is_closed() in is_closed()319 pub fn is_closed(&self) -> bool { in is_closed() method320 self.inner.is_closed() in is_closed()363 assert!(!sem.is_closed()); in ut_sem_close_test()365 assert!(sem.is_closed()); in ut_sem_close_test()411 assert!(!sem.is_closed()); in ut_auto_release_sem_close_test()413 assert!(sem.is_closed()); in ut_auto_release_sem_close_test()
305 let (value_version, is_closed) = self.channel.state.load(); in is_notified()306 if is_closed { in is_notified()313 let (value_version, is_closed) = self.channel.state.load(); in try_notified()319 if is_closed { in try_notified()527 let is_closed = state & CLOSED == CLOSED; in load() localVariable528 (version, is_closed) in load()561 let (value_version, is_closed) = self.state.load(); in fmt()565 .field("is_closed", &is_closed) in fmt()
210 pub fn is_closed(&self) -> bool { in is_closed() method518 assert!(!tx.is_closed()); in close_rx()521 assert!(tx.is_closed()); in close_rx()
142 pub(crate) fn is_closed(&self) -> bool { in is_closed() method
193 assert!(!tx.is_closed()); in sdv_mpsc_is_closed()195 assert!(tx.is_closed()); in sdv_mpsc_is_closed()199 assert!(!tx.is_closed()); in sdv_mpsc_is_closed()201 assert!(tx.is_closed()); in sdv_mpsc_is_closed()
83 assert!(!sem.is_closed()); in sdv_auto_release_sem_close_test()85 assert!(sem.is_closed()); in sdv_auto_release_sem_close_test()
201 pub(crate) is_closed: bool,235 is_closed: false, in new()268 text_io.is_closed = true; in match_channel_message()294 text_io.is_closed = true; in end_read()352 if buf.remaining() == 0 || text_io.is_closed { in poll_read()
141 pub fn is_closed(&self) -> bool { in is_closed() method
246 pub fn is_closed(&self) -> bool { in is_closed() method
649 if self.controller.streams.is_closed() { in poll_deal_with_go_away()
285 pub(crate) fn is_closed(&self) -> bool { in is_closed() method