Searched refs:should_notify (Results 1 – 9 of 9) sorted by relevance
964 fn notify(style: NotifyStyle, condition: &Condvar, should_notify: bool) { in notify()970 if should_notify { in notify()1055 let (should_notify, result) = { in consumer_thread()1066 let should_notify = queue.items.len() == max_queue_size; in consumer_thread() localVariable1069 (should_notify, result) in consumer_thread()1071 notify(notify_style, &*full_condition, should_notify); in consumer_thread()1090 let should_notify = { in producer_thread() localVariable1098 let should_notify = queue.items.is_empty(); in producer_thread() localVariable1101 should_notify in producer_thread()1103 notify(notify_style, &*empty_condition, should_notify); in producer_thread()
48 if event_queue.should_notify() { in new()88 if self.event_queue.should_notify() { in pop_pending_event()
155 if recv_queue.should_notify() { in new()231 if self.recv_queue.should_notify() { in recycle_rx_buffer()
191 if self.queue.should_notify() { in read_block_nb()272 if self.queue.should_notify() { in write_block_nb()
122 if self.receiveq.should_notify() { in poll_retrieve()
197 if rx.should_notify() {309 if self.rx.should_notify() { in poll_recv()
786 let should_notify = if is_yield || self.shared.config.disable_lifo_slot { in schedule_local() localVariable808 if should_notify && core.park.is_some() { in schedule_local()
197 if self.should_notify() { in add_notify_wait_pop()215 pub fn should_notify(&self) -> bool { in should_notify() method
70010 u8 should_notify: 1; member