| /webrtc/dtls/src/ |
| H A D | content.rs | 43 Content::ChangeCipherSpec(c) => c.content_type(), in content_type()
44 Content::Alert(c) => c.content_type(), in content_type()
45 Content::Handshake(c) => c.content_type(), in content_type()
46 Content::ApplicationData(c) => c.content_type(), in content_type()
52 Content::ChangeCipherSpec(c) => c.size(), in size()
53 Content::Alert(c) => c.size(), in size()
54 Content::Handshake(c) => c.size(), in size()
55 Content::ApplicationData(c) => c.size(), in size()
62 Content::Alert(c) => c.marshal(writer), in marshal()
63 Content::Handshake(c) => c.marshal(writer), in marshal()
[all …]
|
| /webrtc/interceptor/src/twcc/ |
| H A D | twcc_test.rs | 10 let mut c = Chunk::default(); in test_chunk_add() localVariable
17 assert!(!c.has_different_types); in test_chunk_add()
23 let status_chunk = c.encode(); in test_chunk_add()
35 let mut c = Chunk::default(); in test_chunk_add() localVariable
47 assert!(!c.has_different_types); in test_chunk_add()
52 let status_chunk = c.encode(); in test_chunk_add()
64 let mut c = Chunk::default(); in test_chunk_add() localVariable
76 assert!(c.has_large_delta); in test_chunk_add()
82 let status_chunk = c.encode(); in test_chunk_add()
94 let mut c = Chunk::default(); in test_chunk_add() localVariable
[all …]
|
| /webrtc/sctp/src/queue/ |
| H A D | queue_test.rs | 42 if let Some(c) = c { in test_payload_queue_push_no_check()
60 if let Some(c) = c { in test_payload_queue_push_no_check()
288 let c = c.unwrap(); in test_pending_queue_push_and_pop() localVariable
306 let c = c.unwrap(); in test_pending_queue_push_and_pop() localVariable
334 let c = c.unwrap(); in test_pending_queue_unordered_wins() localVariable
342 let c = c.unwrap(); in test_pending_queue_unordered_wins() localVariable
350 let c = c.unwrap(); in test_pending_queue_unordered_wins() localVariable
358 let c = c.unwrap(); in test_pending_queue_unordered_wins() localVariable
384 let c = c.unwrap(); in test_pending_queue_fragments() localVariable
403 let c = c.unwrap(); in test_pending_queue_selection_persistence() localVariable
[all …]
|
| H A D | reassembly_queue.rs | 9 c.sort_by(|a, b| { in sort_chunks_by_tsn()
18 fn sort_chunks_by_ssn(c: &mut [ChunkSet]) { in sort_chunks_by_ssn()
19 c.sort_by(|a, b| { in sort_chunks_by_ssn()
48 for c in &self.chunks { in push()
49 if c.tsn == chunk.tsn { in push()
101 last_tsn = c.tsn; in is_complete()
195 last_tsn = c.tsn; in find_complete_unordered_chunk_set()
214 last_tsn = c.tsn; in find_complete_unordered_chunk_set()
217 if c.ending_fragment { in find_complete_unordered_chunk_set()
281 for c in &cset.chunks { in read()
[all …]
|
| H A D | payload_queue.rs | 79 if let Some(c) = self.chunk_map.remove(&tsn) { in pop()
81 self.n_bytes -= c.user_data.len(); in pop()
82 return Some(c); in pop()
143 let n_bytes_acked = if let Some(c) = self.chunk_map.get_mut(&tsn) { in mark_as_acked()
144 c.acked = true; in mark_as_acked()
145 c.retransmit = false; in mark_as_acked()
146 let n = c.user_data.len(); in mark_as_acked()
148 c.user_data.clear(); in mark_as_acked()
162 for c in self.chunk_map.values_mut() { in mark_all_to_retrasmit()
163 if c.acked || c.abandoned() { in mark_all_to_retrasmit()
[all …]
|
| H A D | pending_queue.rs | 67 pub(crate) async fn push(&self, c: ChunkPayloadData) { in push()
68 let user_data_len = c.user_data.len(); in push()
76 if c.unordered { in push()
78 unordered_queue.push_back(c); in push()
81 ordered_queue.push_back(c); in push()
99 let total_user_data_len = chunks.iter().fold(0, |acc, c| acc + c.user_data.len()); in append()
148 chunks.iter().all(|c| c.unordered), in append_unlimited()
155 chunks.iter().all(|c| !c.unordered), in append_unlimited()
177 let c = { in peek() localVariable
182 if c.is_some() { in peek()
[all …]
|
| /webrtc/ice/src/control/ |
| H A D | control_test.rs | 7 let mut c = AttrControlled(4321); in test_controlled_get_from() localVariable
8 let result = c.get_from(&m); in test_controlled_get_from()
23 assert_eq!(c1, c, "not equal"); in test_controlled_get_from()
44 let mut c = AttrControlling(4321); in test_controlling_get_from() localVariable
45 let result = c.get_from(&m); in test_controlling_get_from()
60 assert_eq!(c1, c, "not equal"); in test_controlling_get_from()
84 let result = c.get_from(&m); in test_control_get_from()
95 let result = c.get_from(&m); in test_control_get_from()
102 c.role = Role::Controlling; in test_control_get_from()
133 let result = c.get_from(&m); in test_control_get_from()
[all …]
|
| /webrtc/util/src/vnet/chunk/ |
| H A D | chunk_test.rs | 28 let mut c = ChunkUdp::new(src, dst); in test_chunk_udp() localVariable
29 let s = c.to_string(); in test_chunk_udp()
31 assert_eq!(c.network(), UDP_STR, "should match"); in test_chunk_udp()
34 assert_eq!(c.get_source_ip(), src.ip(), "ip should match"); in test_chunk_udp()
38 let ts = c.set_timestamp(); in test_chunk_udp()
41 c.user_data = "Hello".as_bytes().to_vec(); in test_chunk_udp()
43 let cloned = c.clone_to(); in test_chunk_udp()
46 c.set_source_addr("2.3.4.5:4000")?; in test_chunk_udp()
47 assert_eq!(c.source_addr().to_string(), "2.3.4.5:4000"); in test_chunk_udp()
50 assert!(!c.tag().is_empty(), "should not be empty"); in test_chunk_udp()
[all …]
|
| /webrtc/stun/benches/ |
| H A D | bench.rs | 30 fn benchmark_addr(c: &mut Criterion) { in benchmark_addr()
56 fn benchmark_agent(c: &mut Criterion) { in benchmark_agent()
66 c.bench_function("BenchmarkAgent_GC", |b| { in benchmark_agent()
93 fn benchmark_attributes(c: &mut Criterion) { in benchmark_attributes()
116 fn benchmark_error_code(c: &mut Criterion) { in benchmark_error_code()
156 fn benchmark_fingerprint(c: &mut Criterion) { in benchmark_fingerprint()
264 fn benchmark_message(c: &mut Criterion) { in benchmark_message()
498 c.bench_function("BenchmarkDecode", |b| { in benchmark_message()
597 fn benchmark_xor(c: &mut Criterion) { in benchmark_xor()
604 c.bench_function("BenchmarkXOR", |b| { in benchmark_xor()
[all …]
|
| /webrtc/sctp/src/association/ |
| H A D | association_internal.rs | 328 for c in &p.chunks { in handle_inbound()
426 if c.acked || c.abandoned() || c.nsent > 1 || c.miss_indicator < 3 { in gather_outbound_fast_retransmission_packets()
1123 if c.nsent == 1 && sna32gte(c.tsn, self.min_tsn2measure_rtt) { in process_selective_ack()
1318 if !c.acked && !c.abandoned() && c.miss_indicator < 3 { in process_fast_retransmission()
1824 c.tsn, in move_pending_data_chunk_to_inflight_queue()
1826 c.nsent, in move_pending_data_chunk_to_inflight_queue()
1834 Some(c) in move_pending_data_chunk_to_inflight_queue()
1922 for c in chunks { in bundle_data_chunks_into_packets()
2034 c.tsn, in get_data_packets_to_retransmit()
2036 c.nsent in get_data_packets_to_retransmit()
[all …]
|
| /webrtc/turn/benches/ |
| H A D | bench.rs | 10 fn benchmark_chan_data(c: &mut Criterion) { in benchmark_chan_data()
13 c.bench_function("BenchmarkIsChannelData", |b| { in benchmark_chan_data()
26 c.bench_function("BenchmarkChannelData_Encode", |b| { in benchmark_chan_data()
43 c.bench_function("BenchmarkChannelData_Decode", |b| { in benchmark_chan_data()
53 fn benchmark_chan(c: &mut Criterion) { in benchmark_chan()
79 fn benchmark_data(c: &mut Criterion) { in benchmark_data()
83 c.bench_function("BenchmarkData/AddTo", |b| { in benchmark_data()
94 c.bench_function("BenchmarkData/AddToRaw", |b| { in benchmark_data()
103 fn benchmark_lifetime(c: &mut Criterion) { in benchmark_lifetime()
107 c.bench_function("BenchmarkLifetime/AddTo", |b| { in benchmark_lifetime()
[all …]
|
| /webrtc/dtls/src/handshake/ |
| H A D | handshake_cache.rs | 79 for c in &*cache { in pull()
80 if c.typ == r.typ && c.is_client == r.is_client && c.epoch == r.epoch { in pull()
83 item = Some(c.clone()); in pull()
86 item = Some(c.clone()); in pull()
91 if let Some(c) = item { in pull()
92 out.push(c); in pull()
110 for c in &*cache { in full_pull_map()
111 if c.typ == r.typ && c.is_client == r.is_client && c.epoch == r.epoch { in full_pull_map()
117 item = Some(c.clone()); in full_pull_map()
126 if let Some(c) = item { in full_pull_map()
[all …]
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_test.rs | 131 let ec = &c.error_causes[0]; in test_chunk_error_unrecognized_chunk_type_unmarshal()
488 1438213285, c.initiate_tag in test_init_chunk()
611 c.initiate_tag, 123, in test_init_marshal_unmarshal()
613 123, c.initiate_tag in test_init_marshal_unmarshal()
618 c.num_inbound_streams, 1, in test_init_marshal_unmarshal()
620 1, c.num_inbound_streams in test_init_marshal_unmarshal()
623 c.initial_tsn, 123, in test_init_marshal_unmarshal()
625 123, c.initial_tsn in test_init_marshal_unmarshal()
684 c.param_a in test_reconfig_chunk()
713 c.new_cumulative_tsn, 3, in test_forward_tsn_chunk()
[all …]
|
| /webrtc/constraints/src/ |
| H A D | macros.rs | 7 $($p:expr => $c:expr),* $(,)?
10 $(($p, $c.into())),*
24 $($p: Some($c)),+,
29 ($c:expr) => {
42 $($p: Some($c)),+,
47 ($c:expr) => {
60 $($p: Some($c)),*,
65 ($c:expr) => {
79 $(($p, $c.into())),*
94 $($p => $c),*
[all …]
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | ice_candidate.rs | 36 ice_candidates.iter().map(|c| c.into()).collect() in rtc_ice_candidates_from_ice_candidates()
40 fn from(c: &Arc<dyn Candidate + Send + Sync>) -> Self { in from()
50 stats_id: c.id(), in from()
51 foundation: c.foundation(), in from()
52 priority: c.priority(), in from()
53 address: c.address(), in from()
55 port: c.port(), in from()
56 component: c.component(), in from()
58 tcp_type: c.tcp_type().to_string(), in from()
68 let c = match self.typ { in to_ice() localVariable
[all …]
|
| /webrtc/turn/src/client/ |
| H A D | client_test.rs | 15 let c = Client::new(ClientConfig { in create_listening_test_client() localVariable
28 c.listen().await?; in create_listening_test_client()
30 Ok(c) in create_listening_test_client()
36 let c = Client::new(ClientConfig { in create_listening_test_client_with_stun_serv() localVariable
49 c.listen().await?; in create_listening_test_client_with_stun_serv()
51 Ok(c) in create_listening_test_client_with_stun_serv()
60 let resp = c.send_binding_request().await?; in test_client_with_stun_send_binding_request()
63 let ci = c.client_internal.lock().await; in test_client_with_stun_send_binding_request()
68 c.close().await?; in test_client_with_stun_send_binding_request()
109 let c = create_listening_test_client(10).await?; in test_client_with_stun_send_binding_request_to_timeout() localVariable
[all …]
|
| /webrtc/util/src/vnet/ |
| H A D | conn_map.rs | 36 for c in conns { in insert()
37 let laddr = c.local_addr()?; in insert()
57 if let Some(c) = conns.first() { in find()
58 return Some(Arc::clone(c)); in find()
64 for c in conns { in find()
66 match c.local_addr() { in find()
72 return Some(Arc::clone(c)); in find()
85 for c in conns { in delete()
86 let laddr = c.local_addr()?; in delete()
95 new_conns.push(Arc::clone(c)); in delete()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_stats.rs | 238 for c in local_candidates { in get_local_candidates_stats()
241 id: c.id(), in get_local_candidates_stats()
243 ip: c.address(), in get_local_candidates_stats()
244 port: c.port(), in get_local_candidates_stats()
245 candidate_type: c.candidate_type(), in get_local_candidates_stats()
246 priority: c.priority(), in get_local_candidates_stats()
263 for c in remote_candidates { in get_remote_candidates_stats()
266 id: c.id(), in get_remote_candidates_stats()
268 ip: c.address(), in get_remote_candidates_stats()
269 port: c.port(), in get_remote_candidates_stats()
[all …]
|
| /webrtc/util/src/vnet/chunk_queue/ |
| H A D | chunk_queue_test.rs | 12 let c: Box<dyn Chunk> = Box::new(ChunkUdp::new( in test_chunk_queue() localVariable
22 let ok = q.push(c.clone_to()).await; in test_chunk_queue()
28 assert_eq!(c.to_string(), d.to_string(), "should be the same"); in test_chunk_queue()
35 let ok = q.push(c.clone_to()).await; in test_chunk_queue()
38 let ok = q.push(c.clone_to()).await; in test_chunk_queue()
44 assert_eq!(c.to_string(), d.to_string(), "should be the same"); in test_chunk_queue()
|
| /webrtc/webrtc/src/rtp_transceiver/fmtp/h264/ |
| H A D | h264_test.rs | 135 let c = aa.match_fmtp(&*bb); in test_h264_fmtp_compare() localVariable
137 c, in test_h264_fmtp_compare()
144 consist_string.get(&c), in test_h264_fmtp_compare()
148 let c = bb.match_fmtp(&*aa); in test_h264_fmtp_compare() localVariable
150 c, in test_h264_fmtp_compare()
157 consist_string.get(&c), in test_h264_fmtp_compare()
|
| /webrtc/webrtc/src/rtp_transceiver/fmtp/generic/ |
| H A D | generic_test.rs | 121 let c = aa.match_fmtp(&*bb); in test_generic_fmtp_compare() localVariable
123 c, in test_generic_fmtp_compare()
130 consist_string.get(&c), in test_generic_fmtp_compare()
134 let c = bb.match_fmtp(&*aa); in test_generic_fmtp_compare() localVariable
136 c, in test_generic_fmtp_compare()
143 consist_string.get(&c), in test_generic_fmtp_compare()
|
| /webrtc/dtls/src/handshake/handshake_message_certificate/ |
| H A D | handshake_message_certificate_test.rs | 38 let c = HandshakeMessageCertificate::unmarshal(&mut reader)?; in test_handshake_message_certificate() localVariable
52 c.marshal(&mut writer)?; in test_handshake_message_certificate()
71 let c = HandshakeMessageCertificate::unmarshal(&mut reader)?; in test_empty_handshake_message_certificate() localVariable
74 c, expected_certificate, in test_empty_handshake_message_certificate()
|
| /webrtc/util/benches/ |
| H A D | bench.rs | 15 fn benchmark_buffer(c: &mut Criterion) { in benchmark_buffer()
17 c.bench_function("Benchmark Buffer WriteThenRead 1", |b| { in benchmark_buffer()
22 c.bench_function("Benchmark Buffer WriteThenRead 10", |b| { in benchmark_buffer()
27 c.bench_function("Benchmark Buffer WriteThenRead 100", |b| { in benchmark_buffer()
|
| /webrtc/mdns/src/message/ |
| H A D | name.rs | 139 let c = msg[curr_off]; in unpack_compressed() localVariable
141 match c & 0xC0 { in unpack_compressed()
144 if c == 0x00 { in unpack_compressed()
148 let end_off = curr_off + c as usize; in unpack_compressed()
174 curr_off = ((c ^ 0xC0) as usize) << 8 | (c1 as usize); in unpack_compressed()
205 let c = msg[new_off]; in skip() localVariable
207 match c & 0xC0 { in skip()
209 if c == 0x00 { in skip()
214 new_off += c as usize; in skip()
|
| /webrtc/dtls/src/handshake/handshake_message_server_hello_done/ |
| H A D | handshake_message_server_hello_done_test.rs | 11 let c = HandshakeMessageServerHelloDone::unmarshal(&mut reader)?; in test_handshake_message_server_hello_done() localVariable
13 c, parsed_server_hello_done, in test_handshake_message_server_hello_done()
20 c.marshal(&mut writer)?; in test_handshake_message_server_hello_done()
|