Lines Matching refs:Ordering
18 sync::atomic::{AtomicBool, AtomicU16, AtomicU32, AtomicU8, AtomicUsize, Ordering},
155 .store(default_payload_type as u32, Ordering::SeqCst); in set_default_payload_type()
167 self.unordered.store(unordered, Ordering::SeqCst); in set_reliability_params()
169 .store(rel_type as u8, Ordering::SeqCst); in set_reliability_params()
170 self.reliability_value.store(rel_val, Ordering::SeqCst); in set_reliability_params()
188 if self.read_shutdown.load(Ordering::SeqCst) { in read_sctp()
227 if self.unordered.load(Ordering::SeqCst) { in handle_forward_tsn_for_ordered()
246 if !self.unordered.load(Ordering::SeqCst) { in handle_forward_tsn_for_unordered()
268 self.write_sctp(p, self.default_payload_type.load(Ordering::SeqCst).into()) in write()
288 if self.write_shutdown.load(Ordering::SeqCst) { in prepare_write()
292 if p.len() > self.max_message_size.load(Ordering::SeqCst) as usize { in prepare_write()
296 let state: AssociationState = self.state.load(Ordering::SeqCst).into(); in prepare_write()
316 ppi != PayloadProtocolIdentifier::Dcep && self.unordered.load(Ordering::SeqCst); in packetize()
337 stream_sequence_number: self.sequence_number.load(Ordering::SeqCst), in packetize()
354 self.sequence_number.fetch_add(1, Ordering::SeqCst); in packetize()
357 let old_value = self.buffered_amount.fetch_add(raw.len(), Ordering::SeqCst); in packetize()
378 if self.read_shutdown.load(Ordering::SeqCst) && self.write_shutdown.load(Ordering::SeqCst) { in shutdown()
383 self.write_shutdown.store(true, Ordering::SeqCst); in shutdown()
387 && !self.read_shutdown.swap(true, Ordering::SeqCst) in shutdown()
393 || (self.read_shutdown.load(Ordering::SeqCst) in shutdown()
394 && self.write_shutdown.load(Ordering::SeqCst)) in shutdown()
406 self.buffered_amount.load(Ordering::SeqCst) in buffered_amount()
412 self.buffered_amount_low.load(Ordering::SeqCst) in buffered_amount_low_threshold()
418 self.buffered_amount_low.store(th, Ordering::SeqCst); in set_buffered_amount_low_threshold()
435 let from_amount = self.buffered_amount.load(Ordering::SeqCst); in on_buffer_released()
437 self.buffered_amount.store(0, Ordering::SeqCst); in on_buffer_released()
447 .fetch_sub(n_bytes_released as usize, Ordering::SeqCst); in on_buffer_released()
452 let buffered_amount_low = self.buffered_amount_low.load(Ordering::SeqCst); in on_buffer_released()
480 self.state.load(Ordering::SeqCst).into() in get_state()
635 self.stream.buffered_amount.load(Ordering::SeqCst) in buffered_amount()
641 self.stream.buffered_amount_low.load(Ordering::SeqCst) in buffered_amount_low_threshold()