| /webrtc/rtp/src/ |
| H A D | sequence.rs | 2 use std::sync::atomic::{AtomicU16, AtomicU64, Ordering};
22 sequence_number: Arc::new(AtomicU16::new(rand::random::<u16>())), in new_random_sequencer()
34 sequence_number: Arc::new(AtomicU16::new(sequence_number)), in new_fixed_sequencer()
46 sequence_number: Arc<AtomicU16>,
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_test.rs | 11 component: AtomicU16::new(COMPONENT_RTP), in test_candidate_priority()
19 component: AtomicU16::new(COMPONENT_RTP), in test_candidate_priority()
29 component: AtomicU16::new(COMPONENT_RTP), in test_candidate_priority()
39 component: AtomicU16::new(COMPONENT_RTP), in test_candidate_priority()
49 component: AtomicU16::new(COMPONENT_RTP), in test_candidate_priority()
57 component: AtomicU16::new(COMPONENT_RTP), in test_candidate_priority()
67 component: AtomicU16::new(COMPONENT_RTP), in test_candidate_priority()
77 component: AtomicU16::new(COMPONENT_RTP), in test_candidate_priority()
87 component: AtomicU16::new(COMPONENT_RTP), in test_candidate_priority()
95 component: AtomicU16::new(COMPONENT_RTP), in test_candidate_priority()
|
| H A D | candidate_host.rs | 5 use std::sync::atomic::{AtomicU16, AtomicU8};
27 component: AtomicU16::new(self.base_config.component), in new_candidate_host()
|
| H A D | candidate_peer_reflexive.rs | 6 use std::sync::atomic::{AtomicU16, AtomicU8};
40 component: AtomicU16::new(self.base_config.component), in new_candidate_peer_reflexive()
|
| H A D | candidate_server_reflexive.rs | 6 use std::sync::atomic::{AtomicU16, AtomicU8};
39 component: AtomicU16::new(self.base_config.component), in new_candidate_server_reflexive()
|
| H A D | candidate_relay.rs | 7 atomic::{AtomicU16, AtomicU8},
43 component: AtomicU16::new(self.base_config.component), in new_candidate_relay()
|
| H A D | mod.rs | 25 use std::sync::atomic::{AtomicBool, AtomicU16, AtomicU8, Ordering};
232 pub(crate) binding_request_count: AtomicU16,
244 binding_request_count: AtomicU16::new(0), in default()
296 binding_request_count: AtomicU16::new(0), in new()
|
| H A D | candidate_base.rs | 15 atomic::{AtomicU16, AtomicU64, AtomicU8, Ordering},
41 pub(crate) component: AtomicU16,
71 component: AtomicU16::new(0), in default()
|
| /webrtc/turn/src/client/ |
| H A D | transaction.rs | 8 use std::sync::atomic::{AtomicU16, Ordering};
119 pub n_rtx: Arc<AtomicU16>,
120 pub interval: Arc<AtomicU16>,
132 n_rtx: Arc::new(AtomicU16::new(0)), in default()
133 interval: Arc::new(AtomicU16::new(0)), in default()
156 interval: Arc::new(AtomicU16::new(config.interval)), in new()
|
| /webrtc/webrtc/src/sctp_transport/ |
| H A D | sctp_transport_test.rs | 2 use std::sync::atomic::AtomicU16;
10 id: AtomicU16::new(*id), in test_generate_data_channel_id()
|
| /webrtc/dtls/src/ |
| H A D | state.rs | 13 use std::sync::atomic::{AtomicU16, Ordering};
21 pub(crate) local_epoch: Arc<AtomicU16>,
22 pub(crate) remote_epoch: Arc<AtomicU16>,
70 local_epoch: Arc::new(AtomicU16::new(0)), in default()
71 remote_epoch: Arc::new(AtomicU16::new(0)), in default()
|
| /webrtc/util/src/vnet/ |
| H A D | nat.rs | 11 use std::sync::atomic::{AtomicU16, Ordering};
99 pub(crate) udp_port_counter: Arc<AtomicU16>,
134 udp_port_counter: Arc::new(AtomicU16::new(0)), in new()
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | mod.rs | 18 atomic::{AtomicBool, AtomicU16, AtomicU8, AtomicUsize, Ordering},
64 pub(crate) id: AtomicU16,
108 id: AtomicU16::new(id), in new()
|
| H A D | data_channel_test.rs | 782 id: AtomicU16::new(id), in test_data_channel_parameters_go()
829 let n_cbs = Arc::new(AtomicU16::new(0)); in test_data_channel_buffered_amount_set_before_open()
837 let n_packets_received = Arc::new(AtomicU16::new(0)); in test_data_channel_buffered_amount_set_before_open()
920 let n_cbs = Arc::new(AtomicU16::new(0)); in test_data_channel_buffered_amount_set_after_open()
928 let n_packets_received = Arc::new(AtomicU16::new(0)); in test_data_channel_buffered_amount_set_after_open()
|
| /webrtc/sctp/src/stream/ |
| H A D | mod.rs | 18 sync::atomic::{AtomicBool, AtomicU16, AtomicU32, AtomicU8, AtomicUsize, Ordering},
77 pub(crate) sequence_number: AtomicU16,
133 sequence_number: AtomicU16::new(0), in new()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 34 use std::sync::atomic::{AtomicBool, AtomicU16, Ordering};
64 remote_epoch: Arc<AtomicU16>,
751 local_epoch: &Arc<AtomicU16>, in read_and_buffer() argument
834 local_epoch: &Arc<AtomicU16>, in handle_queued_packets() argument
|