Home
last modified time | relevance | path

Searched refs:AtomicU32 (Results 1 – 11 of 11) sorted by relevance

/webrtc/sctp/src/timer/
H A Dtimer_test.rs10 use std::sync::atomic::{AtomicU32, Ordering};
24 ncbs: Arc<AtomicU32>,
37 let ncbs = Arc::new(AtomicU32::new(0)); in test_ack_timer_start_and_stop()
175 ncbs: Arc<AtomicU32>,
226 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_callback_interval()
253 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_last_start_wins()
281 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_stop_right_after_start()
306 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_start_stop_then_start()
335 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_start_and_stop_in_atight_loop()
361 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_should_stop_after_rtx_failure()
[all …]
/webrtc/interceptor/src/twcc/sender/
H A Dsender_stream.rs5 next_sequence_nr: Arc<AtomicU32>,
12 next_sequence_nr: Arc<AtomicU32>, in new() argument
H A Dmod.rs10 use std::sync::atomic::{AtomicU32, Ordering};
36 next_sequence_nr: Arc::new(AtomicU32::new(self.init_sequence_nr)), in build()
44 next_sequence_nr: Arc<AtomicU32>,
/webrtc/webrtc/src/sctp_transport/
H A Dmod.rs31 use std::sync::atomic::{AtomicBool, AtomicU32, AtomicU8, Ordering};
57 data_channels_opened: Arc<AtomicU32>,
58 data_channels_accepted: Arc<AtomicU32>,
90 pub(crate) data_channels_opened: Arc<AtomicU32>,
91 pub(crate) data_channels_requested: Arc<AtomicU32>,
92 data_channels_accepted: Arc<AtomicU32>,
116 data_channels_opened: Arc::new(AtomicU32::new(0)), in new()
117 data_channels_requested: Arc::new(AtomicU32::new(0)), in new()
118 data_channels_accepted: Arc::new(AtomicU32::new(0)), in new()
/webrtc/sctp/src/stream/
H A Dstream_test.rs2 use std::sync::atomic::{AtomicU32, Ordering};
33 let n_cbs = Arc::new(AtomicU32::new(0)); in test_stream_amount_on_buffered_amount_low()
80 Arc::new(AtomicU32::new(4096)), in test_stream()
154 Arc::new(AtomicU32::new(4096)), in test_poll_stream()
H A Dmod.rs18 sync::atomic::{AtomicBool, AtomicU16, AtomicU32, AtomicU8, AtomicUsize, Ordering},
69 pub(crate) max_message_size: Arc<AtomicU32>, // clone from association
75 pub(crate) default_payload_type: AtomicU32, //PayloadProtocolIdentifier,
83 pub(crate) reliability_value: AtomicU32,
118 max_message_size: Arc<AtomicU32>, in new() argument
131 default_payload_type: AtomicU32::new(0), //PayloadProtocolIdentifier::Unknown, in new()
139 reliability_value: AtomicU32::new(0), in new()
/webrtc/webrtc/src/ice_transport/
H A Dice_transport_test.rs10 use std::sync::atomic::AtomicU32;
35 let sender_called_candidate_change = Arc::new(AtomicU32::new(0)); in test_ice_transport_on_selected_candidate_pair_change()
/webrtc/webrtc/src/track/track_remote/
H A Dmod.rs15 use std::sync::atomic::{AtomicU32, AtomicU8, AtomicUsize, Ordering};
50 ssrc: AtomicU32, //SSRC,
96 ssrc: AtomicU32::new(ssrc), in new()
/webrtc/webrtc/src/peer_connection/
H A Dpeer_connection_test.rs11 use std::sync::atomic::AtomicU32;
283 let sender_called_candidate_change = Arc::new(AtomicU32::new(0)); in test_get_stats()
/webrtc/sctp/src/association/
H A Dmod.rs47 use std::sync::atomic::{AtomicBool, AtomicU32, AtomicU8, AtomicUsize, Ordering};
202 max_message_size: Arc<AtomicU32>,
H A Dassociation_internal.rs15 pub(crate) max_message_size: Arc<AtomicU32>,
123 max_message_size: Arc::new(AtomicU32::new(max_message_size)), in new()