Lines Matching refs:Ordering
6 sync::atomic::{AtomicBool, AtomicUsize, Ordering},
85 self.n_bytes.fetch_add(user_data_len, Ordering::SeqCst); in push()
86 self.queue_len.fetch_add(1, Ordering::SeqCst); in push()
133 self.n_bytes.fetch_add(user_data_len, Ordering::SeqCst); in append_large()
134 self.queue_len.fetch_add(1, Ordering::SeqCst); in append_large()
162 .fetch_add(total_user_data_len, Ordering::SeqCst); in append_unlimited()
163 self.queue_len.fetch_add(chunks_len, Ordering::SeqCst); in append_unlimited()
167 if self.selected.load(Ordering::SeqCst) { in peek()
168 if self.unordered_is_selected.load(Ordering::SeqCst) { in peek()
195 let popped = if self.selected.load(Ordering::SeqCst) { in pop()
196 let popped = if self.unordered_is_selected.load(Ordering::SeqCst) { in pop()
205 self.selected.store(false, Ordering::SeqCst); in pop()
220 self.selected.store(true, Ordering::SeqCst); in pop()
221 self.unordered_is_selected.store(true, Ordering::SeqCst); in pop()
232 self.selected.store(true, Ordering::SeqCst); in pop()
233 self.unordered_is_selected.store(false, Ordering::SeqCst); in pop()
242 self.n_bytes.fetch_sub(user_data_len, Ordering::SeqCst); in pop()
243 self.queue_len.fetch_sub(1, Ordering::SeqCst); in pop()
251 self.n_bytes.load(Ordering::SeqCst) in get_num_bytes()
255 self.queue_len.load(Ordering::SeqCst) in len()