Home
last modified time | relevance | path

Searched refs:Ordering (Results 1 – 25 of 78) sorted by relevance

1234

/webrtc/sctp/src/association/
H A Dassociation_stats.rs1 use std::sync::atomic::{AtomicU64, Ordering};
14 self.n_datas.fetch_add(1, Ordering::SeqCst); in inc_datas()
18 self.n_datas.load(Ordering::SeqCst) in get_num_datas()
22 self.n_sacks.fetch_add(1, Ordering::SeqCst); in inc_sacks()
26 self.n_sacks.load(Ordering::SeqCst) in get_num_sacks()
34 self.n_t3timeouts.load(Ordering::SeqCst) in get_num_t3timeouts()
42 self.n_ack_timeouts.load(Ordering::SeqCst) in get_num_ack_timeouts()
50 self.n_fast_retrans.load(Ordering::SeqCst) in get_num_fast_retrans()
54 self.n_datas.store(0, Ordering::SeqCst); in reset()
55 self.n_sacks.store(0, Ordering::SeqCst); in reset()
[all …]
H A Dmod.rs260 if self.inflight_queue_length.load(Ordering::SeqCst) == 0 { in shutdown()
262 self.will_send_shutdown.store(true, Ordering::SeqCst); in shutdown()
457 bytes_received.fetch_add(n, Ordering::SeqCst); in read_loop()
502 while !done.load(Ordering::Relaxed) { in write_loop()
530 done2.store(true, Ordering::Relaxed) in write_loop()
548 done.store(true, Ordering::Relaxed); in write_loop()
566 self.bytes_sent.load(Ordering::SeqCst) in bytes_sent()
571 self.bytes_received.load(Ordering::SeqCst) in bytes_received()
592 self.max_message_size.load(Ordering::SeqCst) in max_message_size()
598 .store(max_message_size, Ordering::SeqCst); in set_max_message_size()
[all …]
/webrtc/sctp/src/queue/
H A Dpending_queue.rs6 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()
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()
195 let popped = if self.selected.load(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()
[all …]
H A Dpayload_queue.rs6 use std::sync::atomic::{AtomicUsize, Ordering};
20 length.store(0, Ordering::SeqCst); in new()
35 self.length.fetch_add(1, Ordering::SeqCst); in push_no_check()
42 fn compare_tsn(a: u32, b: u32) -> std::cmp::Ordering { in push_no_check() argument
44 std::cmp::Ordering::Less in push_no_check()
46 std::cmp::Ordering::Greater in push_no_check()
80 self.length.fetch_sub(1, Ordering::SeqCst); in pop()
175 assert_eq!(self.chunk_map.len(), self.length.load(Ordering::SeqCst)); in len()
/webrtc/constraints/src/algorithms/
H A Dfitness_distance.rs28 use std::cmp::Ordering;
35 fn nearly_cmp(lhs: f64, rhs: f64) -> Ordering { in nearly_cmp() argument
44 return Ordering::Equal; in nearly_cmp()
51 Ordering::Equal in nearly_cmp()
53 Ordering::Less in nearly_cmp()
55 Ordering::Greater in nearly_cmp()
60 nearly_cmp(actual, min) != Ordering::Less in is_nearly_greater_than_or_equal_to()
64 nearly_cmp(actual, max) != Ordering::Greater in is_nearly_less_than_or_equal_to()
68 nearly_cmp(actual, exact) == Ordering::Equal in is_nearly_equal_to()
/webrtc/rtp/src/
H A Dsequence.rs2 use std::sync::atomic::{AtomicU16, AtomicU64, Ordering};
54 if self.0.sequence_number.load(Ordering::SeqCst) == u16::MAX { in next_sequence_number()
55 self.0.roll_over_count.fetch_add(1, Ordering::SeqCst); in next_sequence_number()
56 self.0.sequence_number.store(0, Ordering::SeqCst); in next_sequence_number()
59 self.0.sequence_number.fetch_add(1, Ordering::SeqCst) + 1 in next_sequence_number()
66 self.0.roll_over_count.load(Ordering::SeqCst) in roll_over_count()
/webrtc/sctp/src/stream/
H A Dmod.rs167 self.unordered.store(unordered, Ordering::SeqCst); in set_reliability_params()
169 .store(rel_type as u8, 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()
288 if self.write_shutdown.load(Ordering::SeqCst) { in prepare_write()
378 if self.read_shutdown.load(Ordering::SeqCst) && self.write_shutdown.load(Ordering::SeqCst) { in shutdown()
393 || (self.read_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()
[all …]
H A Dstream_test.rs2 use std::sync::atomic::{AtomicU32, Ordering};
14 s.buffered_amount.store(8192, Ordering::SeqCst); in test_stream_buffered_amount()
30 s.buffered_amount.store(4096, Ordering::SeqCst); in test_stream_amount_on_buffered_amount_low()
37 n_cbs2.fetch_add(1, Ordering::SeqCst); in test_stream_amount_on_buffered_amount_low()
44 assert_eq!(n_cbs.load(Ordering::SeqCst), 0, "callback count mismatch"); in test_stream_amount_on_buffered_amount_low()
49 assert_eq!(n_cbs.load(Ordering::SeqCst), 0, "callback count mismatch"); in test_stream_amount_on_buffered_amount_low()
54 assert_eq!(n_cbs.load(Ordering::SeqCst), 1, "callback count mismatch"); in test_stream_amount_on_buffered_amount_low()
59 assert_eq!(n_cbs.load(Ordering::SeqCst), 1, "callback count mismatch"); in test_stream_amount_on_buffered_amount_low()
64 assert_eq!(n_cbs.load(Ordering::SeqCst), 1, "callback count mismatch"); in test_stream_amount_on_buffered_amount_low()
69 assert_eq!(n_cbs.load(Ordering::SeqCst), 1, "callback count mismatch"); in test_stream_amount_on_buffered_amount_low()
/webrtc/webrtc/src/api/media_engine/
H A Dmedia_engine_test.rs71 assert!(!m.negotiated_video.load(Ordering::SeqCst)); in test_media_engine_remote_description()
72 assert!(!m.negotiated_audio.load(Ordering::SeqCst)); in test_media_engine_remote_description()
91 assert!(!m.negotiated_video.load(Ordering::SeqCst)); in test_media_engine_remote_description()
92 assert!(m.negotiated_audio.load(Ordering::SeqCst)); in test_media_engine_remote_description()
114 assert!(!m.negotiated_video.load(Ordering::SeqCst)); in test_media_engine_remote_description()
115 assert!(m.negotiated_audio.load(Ordering::SeqCst)); in test_media_engine_remote_description()
141 assert!(m.negotiated_audio.load(Ordering::SeqCst)); in test_media_engine_remote_description()
163 assert!(m.negotiated_audio.load(Ordering::SeqCst)); in test_media_engine_remote_description()
200 assert!(m.negotiated_audio.load(Ordering::SeqCst)); in test_media_engine_remote_description()
734 assert!(!m.negotiated_video.load(Ordering::SeqCst)); in test_extension_id_collision()
[all …]
/webrtc/ice/src/agent/
H A Dagent_selector.rs11 use std::sync::atomic::Ordering;
158 if self.is_controlling.load(Ordering::SeqCst) { in start()
166 if self.is_controlling.load(Ordering::SeqCst) { in contact_candidates()
178 if self.is_controlling.load(Ordering::SeqCst) { in ping_candidate()
192 if self.is_controlling.load(Ordering::SeqCst) { in handle_success_response()
205 if self.is_controlling.load(Ordering::SeqCst) { in handle_binding_request()
225 if self.lite.load(Ordering::SeqCst) { in contact_candidates()
257 p.nominated.store(true, Ordering::SeqCst); in contact_candidates()
331 p.state.load(Ordering::SeqCst), in handle_success_response()
369 p.state.load(Ordering::SeqCst), in handle_binding_request()
[all …]
H A Dagent_transport.rs7 use std::sync::atomic::{AtomicBool, Ordering};
116 if p.state.load(Ordering::SeqCst) == CandidatePairState::Failed as u8 { in get_best_available_candidate_pair()
137 if p.state.load(Ordering::SeqCst) != CandidatePairState::Succeeded as u8 { in get_best_valid_candidate_pair()
155 self.bytes_sent.load(Ordering::SeqCst) in bytes_sent()
160 self.bytes_received.load(Ordering::SeqCst) in bytes_received()
171 if self.done.load(Ordering::SeqCst) { in recv()
179 self.bytes_received.fetch_add(n, Ordering::SeqCst); in recv()
197 if self.done.load(Ordering::SeqCst) { in send()
215 self.bytes_sent.fetch_add(buf.len(), Ordering::SeqCst); in send()
/webrtc/examples/examples/swap-tracks/
H A Dswap-tracks.rs4 use std::sync::atomic::{AtomicUsize, Ordering};
147 let track_num = track_count1.fetch_add(1, Ordering::SeqCst); in main()
172 if curr_track2.load(Ordering::SeqCst) == track_num { in main()
283 if track_count.load(Ordering::SeqCst) == 0 { in main()
287 … if curr_track.load(Ordering::SeqCst) == track_count.load(Ordering::SeqCst) - 1 { in main()
288 curr_track.store(0, Ordering::SeqCst); in main()
290 curr_track.fetch_add(1, Ordering::SeqCst); in main()
294 curr_track.load(Ordering::SeqCst) + 1, in main()
/webrtc/webrtc/src/api/setting_engine/
H A Dsetting_engine_test.rs6 use std::sync::atomic::Ordering;
170 assert!(!api.media_engine.negotiated_video.load(Ordering::SeqCst)); in test_setting_engine_set_disable_media_engine_copy()
181 .load(Ordering::SeqCst)); in test_setting_engine_set_disable_media_engine_copy()
197 .load(Ordering::SeqCst)); in test_setting_engine_set_disable_media_engine_copy()
209 .load(Ordering::SeqCst)); in test_setting_engine_set_disable_media_engine_copy()
244 assert!(api.media_engine.negotiated_video.load(Ordering::SeqCst)); in test_setting_engine_set_disable_media_engine_copy()
259 .load(Ordering::SeqCst)); in test_setting_engine_set_disable_media_engine_copy()
/webrtc/webrtc/src/track/track_remote/
H A Dmod.rs15 use std::sync::atomic::{AtomicU32, AtomicU8, AtomicUsize, Ordering};
90 tid: TRACK_REMOTE_UNIQUE_ID.fetch_add(1, Ordering::SeqCst), in new()
146 self.payload_type.load(Ordering::SeqCst) in payload_type()
150 self.payload_type.store(payload_type, Ordering::SeqCst); in set_payload_type()
155 self.kind.load(Ordering::SeqCst).into() in kind()
159 self.kind.store(kind as u8, Ordering::SeqCst); in set_kind()
164 self.ssrc.load(Ordering::SeqCst) in ssrc()
168 self.ssrc.store(ssrc, Ordering::SeqCst); in set_ssrc()
259 self.kind.store(receiver.kind as u8, Ordering::SeqCst); in check_and_update_track()
262 self.payload_type.store(payload_type, Ordering::SeqCst); in check_and_update_track()
/webrtc/webrtc/src/sctp_transport/
H A Dmod.rs31 use std::sync::atomic::{AtomicBool, AtomicU32, AtomicU8, Ordering};
142 if self.is_started.load(Ordering::SeqCst) { in start()
145 self.is_started.store(true, Ordering::SeqCst); in start()
175 .store(RTCSctpTransportState::Connected as u8, Ordering::SeqCst); in start()
208 .store(RTCSctpTransportState::Closed as u8, Ordering::SeqCst); in stop()
300 param.data_channels_accepted.fetch_add(1, Ordering::SeqCst); in accept_data_channels()
311 param.data_channels_opened.fetch_add(1, Ordering::SeqCst); in accept_data_channels()
359 self.state.load(Ordering::SeqCst).into() in state()
434 self.data_channels_accepted.load(Ordering::SeqCst) in data_channels_accepted()
438 self.data_channels_opened.load(Ordering::SeqCst) in data_channels_opened()
[all …]
/webrtc/webrtc/src/peer_connection/
H A Dmod.rs325 .load(Ordering::SeqCst) in do_negotiation_needed_inner()
384 if params.is_closed.load(Ordering::SeqCst) { in negotiation_needed_op()
459 if !t.stopped.load(Ordering::SeqCst) { in check_negotiation_needed()
540 if t.stopped.load(Ordering::SeqCst) { in check_negotiation_needed()
869 if is_closed.load(Ordering::SeqCst) { in update_connection_state()
967 if self.internal.is_closed.load(Ordering::SeqCst) { in set_description()
1181 .store(false, Ordering::SeqCst); in set_description()
1193 if self.internal.is_closed.load(Ordering::SeqCst) { in set_local_description()
1637 .load(Ordering::SeqCst) in ice_connection_state()
1853 .fetch_add(1, Ordering::SeqCst); in create_data_channel()
[all …]
/webrtc/turn/src/client/
H A Dpermission.rs3 use std::sync::atomic::{AtomicU8, Ordering};
29 self.st.store(state as u8, Ordering::SeqCst); in set_state()
33 self.st.load(Ordering::SeqCst).into() in state()
/webrtc/util/src/conn/
H A Dconn_bridge.rs7 use std::sync::atomic::{AtomicUsize, Ordering};
127 if self.drop_nwrites[id].load(Ordering::SeqCst) > 0 { in push()
128 self.drop_nwrites[id].fetch_sub(1, Ordering::SeqCst); in push()
129 } else if self.reorder_nwrites[id].load(Ordering::SeqCst) > 0 { in push()
132 if self.reorder_nwrites[id].fetch_sub(1, Ordering::SeqCst) == 1 { in push()
170 self.drop_nwrites[id].store(n, Ordering::SeqCst); in drop_next_nwrites()
176 self.reorder_nwrites[id].store(n, Ordering::SeqCst); in reorder_next_nwrites()
/webrtc/sctp/src/timer/
H A Dtimer_test.rs10 use std::sync::atomic::{AtomicU32, Ordering};
31 self.ncbs.fetch_add(1, Ordering::SeqCst); in on_ack_timeout()
55 ncbs.load(Ordering::SeqCst), in test_ack_timer_start_and_stop()
58 ncbs.load(Ordering::SeqCst) in test_ack_timer_start_and_stop()
195 self.ncbs.fetch_add(1, Ordering::SeqCst); in on_retransmission_timeout()
245 assert_eq!(ncbs.load(Ordering::SeqCst), 4, "should be called 4 times"); in test_rtx_timer_callback_interval()
273 assert_eq!(ncbs.load(Ordering::SeqCst), 1, "must be called once"); in test_rtx_timer_last_start_wins()
327 assert_eq!(ncbs.load(Ordering::SeqCst), 1, "must be called once"); in test_rtx_timer_start_stop_then_start()
388 assert_eq!(ncbs.load(Ordering::SeqCst), 5, "should be called 5 times"); in test_rtx_timer_should_stop_after_rtx_failure()
439 assert_eq!(ncbs.load(Ordering::SeqCst), 6, "should be called 6 times"); in test_rtx_timer_should_not_stop_if_max_retrans_is_zero()
[all …]
/webrtc/webrtc/src/data_channel/
H A Dmod.rs18 atomic::{AtomicBool, AtomicU16, AtomicU8, AtomicUsize, Ordering},
176 Ordering::SeqCst, in open()
184 self.buffered_amount_low_threshold.load(Ordering::SeqCst), in open()
232 if detach_data_channels && !detach_called.load(Ordering::SeqCst) { in do_open()
317 ready_state.store(RTCDataChannelState::Closed as u8, Ordering::SeqCst); in read_loop()
413 self.detach_called.store(true, Ordering::SeqCst); in detach()
483 self.id.load(Ordering::SeqCst) in id()
488 self.ready_state.load(Ordering::SeqCst).into() in ready_state()
521 self.buffered_amount_low_threshold.load(Ordering::SeqCst) in buffered_amount_low_threshold()
529 .store(th, Ordering::SeqCst); in set_buffered_amount_low_threshold()
[all …]
/webrtc/turn/src/allocation/
H A Dpermission.rs3 use std::sync::{atomic::AtomicBool, atomic::Ordering, Arc};
62 timer_expired.store(true, Ordering::SeqCst); in start()
67 let expired = self.reset_tx.is_none() || self.timer_expired.load(Ordering::SeqCst); in stop()
H A Dchannel_bind.rs7 use std::sync::{atomic::AtomicBool, atomic::Ordering, Arc};
68 timer_expired.store(true, Ordering::SeqCst); in start()
73 let expired = self.reset_tx.is_none() || self.timer_expired.load(Ordering::SeqCst); in stop()
/webrtc/webrtc/src/peer_connection/operation/
H A Dmod.rs7 use std::sync::atomic::{AtomicUsize, Ordering};
80 length.fetch_add(1, Ordering::SeqCst); in enqueue_inner()
88 self.length.load(Ordering::SeqCst) == 0 in is_empty()
121 length.fetch_sub(1, Ordering::SeqCst); in start()
/webrtc/ice/src/candidate/
H A Dcandidate_base.rs15 atomic::{AtomicU16, AtomicU64, AtomicU8, Ordering},
143 self.component.load(Ordering::SeqCst) in component()
147 self.component.store(component, Ordering::SeqCst); in set_component()
153 self.last_received.load(Ordering::SeqCst), in last_received()
159 UNIX_EPOCH.add(Duration::from_nanos(self.last_sent.load(Ordering::SeqCst))) in last_sent()
164 NetworkType::from(self.network_type.load(Ordering::SeqCst)) in network_type()
298 .store(network_type as u8, Ordering::SeqCst); in set_ip()
319 .store(d.as_nanos() as u64, Ordering::SeqCst); in set_last_received()
324 self.last_sent.store(d.as_nanos() as u64, Ordering::SeqCst); in set_last_sent()
/webrtc/constraints/src/algorithms/select_settings/
H A Dselect_optimal.rs11 use std::cmp::Ordering; in select_optimal_candidates()
30 if ordering == Ordering::Less { in select_optimal_candidates()
36 if ordering != Ordering::Greater { in select_optimal_candidates()

1234