Lines Matching refs:load
416 let state = decode_state(self.inner.state.load(SeqCst)); in poll_ready_nb()
436 let mut curr = self.inner.state.load(SeqCst); in inc_num_messages()
484 !decode_state(self.inner.state.load(SeqCst)).is_open in is_closed()
567 let mut curr = self.inner.state.load(SeqCst); in inc_num_messages()
609 let state = decode_state(self.inner.state.load(SeqCst)); in park()
626 let state = decode_state(self.inner.state.load(SeqCst)); in poll_ready()
653 !decode_state(self.inner.state.load(SeqCst)).is_open in is_closed()
873 let mut curr = self.inner.num_senders.load(SeqCst); in clone()
901 let mut curr = self.inner.num_senders.load(SeqCst); in clone()
1008 let state = decode_state(inner.state.load(SeqCst)); in next_message()
1090 let state = decode_state(self.inner.as_ref().unwrap().state.load(SeqCst)); in drop()
1152 let state = decode_state(inner.state.load(SeqCst)); in next_message()
1222 let state = decode_state(self.inner.as_ref().unwrap().state.load(SeqCst)); in drop()
1251 let curr = self.state.load(SeqCst); in set_closed()
1269 let curr = self.state.load(SeqCst); in set_closed()