Home
last modified time | relevance | path

Searched refs:p (Results 1 – 25 of 90) sorted by relevance

1234

/webrtc/rtp/src/packet/
H A Dpacket_test.rs168 assert_eq!(pkt, p); in test_packet_marshal_unmarshal()
182 let p = Packet { in test_rfc_8285_one_byte_extension() localVariable
242 let p = Packet { in test_rfc_8285_one_byte_two_extension_of_two_bytes() localVariable
373 let p = Packet { in test_rfc_8285_one_byte_multiple_extension() localVariable
422 let p = Packet { in test_rfc_8285_two_byte_extension() localVariable
523 let p = Packet { in test_rfc8285_two_byte_multiple_extension_with_large_extension() localVariable
571 let p = Packet { in test_rfc8285_get_extension_returns_nil_when_extension_disabled() localVariable
639 let p = Packet { in test_rfc8285_get_extension_ids() localVariable
685 let p = Packet { in test_rfc8285_get_extension_ids_return_empty_when_extension_disabled() localVariable
865 p.header in test_rfc8285_one_byte_set_extension_should_error_when_invalid_id_provided()
[all …]
/webrtc/turn/src/proto/evenport/
H A Devenport_test.rs5 let mut p = EvenPort::default(); in test_even_port_string() localVariable
7 p.to_string(), in test_even_port_string()
12 p.reserve_port = true; in test_even_port_string()
14 p.to_string(), in test_even_port_string()
25 let p = EvenPort { in test_even_port_false() localVariable
28 p.add_to(&mut m)?; in test_even_port_false()
35 assert_eq!(port, p); in test_even_port_false()
43 let p = EvenPort { reserve_port: true }; in test_even_port_add_to() localVariable
44 p.add_to(&mut m)?; in test_even_port_add_to()
52 assert_eq!(port, p, "Decoded {port}, expected {p}"); in test_even_port_add_to()
/webrtc/mdns/src/message/
H A Dmessage_test.rs255 let mut p = Parser { in test_question_pack_unpack() localVariable
268 p.off, in test_question_pack_unpack()
271 p.off, in test_question_pack_unpack()
541 p.start(&buf)?; in test_skip_all()
564 p.start(&buf)?; in test_skip_each()
571 p.skip_question()?; in test_skip_each()
578 p.skip_answer()?; in test_skip_each()
585 p.skip_authority()?; in test_skip_each()
592 p.skip_additional()?; in test_skip_each()
607 p.start(&buf)?; in test_skip_after_read()
[all …]
/webrtc/sctp/src/chunk/
H A Dchunk_heartbeat.rs65 let p = in unmarshal() localVariable
67 if p.header().typ != ParamType::HeartbeatInfo { in unmarshal()
70 let params = vec![p]; in unmarshal()
77 for p in &self.params { in marshal_to()
78 buf.extend(p.marshal()?); in marshal_to()
88 self.params.iter().fold(0, |length, p| { in value_length()
89 length + PARAM_HEADER_LENGTH + p.value_length() in value_length()
H A Dchunk_heartbeat_ack.rs67 let p = in unmarshal() localVariable
69 if p.header().typ != ParamType::HeartbeatInfo { in unmarshal()
72 let params = vec![p]; in unmarshal()
86 for (idx, p) in self.params.iter().enumerate() { in marshal_to()
87 let pp = p.marshal()?; in marshal_to()
112 for (idx, p) in self.params.iter().enumerate() { in value_length()
113 let p_len = PARAM_HEADER_LENGTH + p.value_length(); in value_length()
H A Dchunk_init.rs173 let p = build_param(&raw.slice(offset..CHUNK_HEADER_SIZE + header.value_length()))?; in unmarshal() localVariable
174 let p_len = PARAM_HEADER_LENGTH + p.value_length(); in unmarshal()
176 params.push(p); in unmarshal()
200 for (idx, p) in self.params.iter().enumerate() { in marshal_to()
201 let pp = p.marshal()?; in marshal_to()
275 for (idx, p) in self.params.iter().enumerate() { in value_length()
276 let p_len = PARAM_HEADER_LENGTH + p.value_length(); in value_length()
/webrtc/sctp/src/queue/
H A Dpayload_queue.rs27 pub(crate) fn can_push(&self, p: &ChunkPayloadData, cumulative_tsn: u32) -> bool { in can_push()
28 !(self.chunk_map.contains_key(&p.tsn) || sna32lte(p.tsn, cumulative_tsn)) in can_push()
31 pub(crate) fn push_no_check(&mut self, p: ChunkPayloadData) { in push_no_check()
32 let tsn = p.tsn; in push_no_check()
33 self.n_bytes += p.user_data.len(); in push_no_check()
34 self.chunk_map.insert(tsn, p); in push_no_check()
63 pub(crate) fn push(&mut self, p: ChunkPayloadData, cumulative_tsn: u32) -> bool { in push()
64 let ok = self.chunk_map.contains_key(&p.tsn); in push()
65 if ok || sna32lte(p.tsn, cumulative_tsn) { in push()
67 self.dup_tsn.push(p.tsn); in push()
[all …]
H A Dpending_queue.rs203 if let Some(p) = &popped { in pop()
204 if p.ending_fragment { in pop()
218 if let Some(p) = &popped { in pop()
219 if !p.ending_fragment { in pop()
230 if let Some(p) = &popped { in pop()
231 if !p.ending_fragment { in pop()
240 if let Some(p) = &popped { in pop()
241 let user_data_len = p.user_data.len(); in pop()
/webrtc/interceptor/src/twcc/sender/
H A Dsender_test.rs56 p = stream.written_rtp() =>{ in test_twcc_sender_interceptor()
57 if let Some(p) = p { in test_twcc_sender_interceptor()
58 assert_eq!(p.header.sequence_number, seq_num); in test_twcc_sender_interceptor()
59 let _ = p_chan_tx2.send(p).await; in test_twcc_sender_interceptor()
76 while let Some(p) = p_chan_rx.recv().await { in test_twcc_sender_interceptor()
79 let mut extension_header = p.header.get_extension(1).unwrap(); in test_twcc_sender_interceptor()
/webrtc/ice/src/agent/
H A Dagent_selector.rs245 self.is_nominatable(&p.local) && self.is_nominatable(&p.remote) in contact_candidates()
254 p.local.to_string(), in contact_candidates()
255 p.remote.to_string() in contact_candidates()
260 *nominated_pair = Some(p); in contact_candidates()
326 p.state in handle_success_response()
330 p, in handle_success_response()
368 p, in handle_binding_request()
369 p.state.load(Ordering::SeqCst), in handle_binding_request()
382 if best_pair == p in handle_binding_request()
387 p.local, p.remote); in handle_binding_request()
[all …]
H A Dagent_transport.rs115 for p in &*checklist { in get_best_available_candidate_pair()
116 if p.state.load(Ordering::SeqCst) == CandidatePairState::Failed as u8 { in get_best_available_candidate_pair()
121 if b.priority() < p.priority() { in get_best_available_candidate_pair()
122 *b = p; in get_best_available_candidate_pair()
125 best = Some(p); in get_best_available_candidate_pair()
136 for p in &*checklist { in get_best_valid_candidate_pair()
137 if p.state.load(Ordering::SeqCst) != CandidatePairState::Succeeded as u8 { in get_best_valid_candidate_pair()
142 if b.priority() < p.priority() { in get_best_valid_candidate_pair()
143 *b = p; in get_best_valid_candidate_pair()
146 best = Some(p); in get_best_valid_candidate_pair()
/webrtc/rtp/src/codecs/vp9/
H A Dvp9_test.rs107 p: true, in test_vp9_packet_unmarshal()
128 p: true, in test_vp9_packet_unmarshal()
214 let mut p = Vp9Packet::default(); in test_vp9_packet_unmarshal() localVariable
217 if let Err(actual) = p.depacketize(&b) { in test_vp9_packet_unmarshal()
226 let payload = p.depacketize(&b)?; in test_vp9_packet_unmarshal()
318 let mut p = Vp9Packet::default(); in test_vp9_payloader_payload() localVariable
319 p.depacketize(&res[0])?; in test_vp9_payloader_payload()
324 p.picture_id, 0, in test_vp9_payloader_payload()
326 p.picture_id in test_vp9_payloader_payload()
331 p_prev.picture_id, p.picture_id, in test_vp9_payloader_payload()
[all …]
/webrtc/sdp/src/
H A Derror.rs37 …#[error("{} --> {} <-- {}", .s.substring(0,*.p), .s.substring(*.p, *.p+1), .s.substring(*.p+1, .s.…
38 SyntaxError { s: String, p: usize },
/webrtc/ice/src/priority/
H A Dpriority_test.rs7 let mut p = PriorityAttr::default(); in test_priority_get_from() localVariable
8 let result = p.get_from(&m); in test_priority_get_from()
15 m.build(&[Box::new(BINDING_REQUEST), Box::new(p)])?; in test_priority_get_from()
23 assert_eq!(p1, p, "not equal"); in test_priority_get_from()
/webrtc/constraints/src/
H A Dmacros.rs7 $($p:expr => $c:expr),* $(,)?
10 $(($p, $c.into())),*
20 ($($p:ident: $c:expr),+ $(,)?) => {
24 $($p: Some($c)),+,
39 {$($p:ident: $c:expr),+ $(,)?} => {
42 $($p: Some($c)),+,
60 $($p: Some($c)),*,
76 $($p:expr => $c:expr),* $(,)?
79 $(($p, $c.into())),*
94 $($p => $c),*
[all …]
/webrtc/media/src/io/sample_builder/
H A Dmod.rs200 pub fn push(&mut self, p: Packet) { in push()
201 let sequence_number = p.header.sequence_number; in push()
202 self.buffer[sequence_number as usize] = Some(p); in push()
301 .map(|p| &p.payload) in build_sample()
306 let is_padding = consume.range(&self.buffer).all(|p| { in build_sample()
307 p.map(|p| { in build_sample()
308 self.last_sample_timestamp == Some(p.header.timestamp) && p.payload.is_empty() in build_sample()
333 .map(|p| &p.payload) in build_sample()
336 let p = self in build_sample() localVariable
341 data.extend_from_slice(&p); in build_sample()
/webrtc/sctp/src/association/association_internal/
H A Dassociation_internal_test.rs179 let p = a.handle_forward_tsn(&fwdtsn).await?; in test_handle_forward_tsn_forward_3unreceived_chunks() localVariable
193 assert!(p.is_empty(), "should return empty"); in test_handle_forward_tsn_forward_3unreceived_chunks()
229 let p = a.handle_forward_tsn(&fwdtsn).await?; in test_handle_forward_tsn_forward_1for1_missing() localVariable
243 assert!(p.is_empty(), "should return empty"); in test_handle_forward_tsn_forward_1for1_missing()
279 let p = a.handle_forward_tsn(&fwdtsn).await?; in test_handle_forward_tsn_forward_1for2_missing() localVariable
291 assert!(p.is_empty(), "should return empty"); in test_handle_forward_tsn_forward_1for2_missing()
313 let p = a.handle_forward_tsn(&fwdtsn).await?; in test_handle_forward_tsn_dup_forward_tsn_chunk_should_generate_sack() localVariable
317 assert!(p.is_empty(), "should return empty"); in test_handle_forward_tsn_dup_forward_tsn_chunk_should_generate_sack()
355 let p = a.handle_data(&to_be_ignored).await?; in test_assoc_create_new_stream() localVariable
468 let p = Bytes::from(vec![0u8; 65537]); in test_assoc_max_message_size_default() localVariable
[all …]
/webrtc/interceptor/src/nack/responder/
H A Dresponder_test.rs38 let p = timeout_or_fail(Duration::from_millis(10), stream.written_rtp()) in test_responder_interceptor() localVariable
41 assert_eq!(p.header.sequence_number, seq_num); in test_responder_interceptor()
60 if let Some(p) = r { in test_responder_interceptor()
61 assert_eq!(p.header.sequence_number, seq_num); in test_responder_interceptor()
/webrtc/util/src/vnet/
H A Dresolver.rs33 pub(crate) fn set_parent(&mut self, p: Arc<Mutex<Resolver>>) { in set_parent()
34 self.parent = Some(p); in set_parent()
60 let p = parent2.lock().await; in lookup() localVariable
61 p.lookup(host_name).await in lookup()
/webrtc/sctp/src/association/
H A Dassociation_internal.rs314 Ok(p) => p, in handle_inbound()
328 for c in &p.chunks { in handle_inbound()
338 raw_packets.push(p); in gather_data_packets_to_retransmit()
482 raw_packets.push(p); in gather_outbound_sack_packets()
526 raw_packets.push(p); in gather_outbound_shutdown_packets()
536 raw_packets.push(p); in gather_outbound_shutdown_packets()
1626 pp.push(p); in handle_reconfig()
1632 pp.push(p); in handle_reconfig()
1749 .insert(p.reconfig_request_sequence_number, p.clone()); in handle_reconfig_param()
2071 vec![p] in pack()
[all …]
/webrtc/interceptor/src/twcc/receiver/
H A Dreceiver_stream.rs37 let p = rtp::packet::Packet::unmarshal(&mut b)?; in read() localVariable
39 if let Some(mut ext) = p.header.get_extension(self.hdr_ext_id) { in read()
45 hdr: p.header, in read()
/webrtc/interceptor/src/twcc/
H A Dmod.rs79 let p: Box<dyn rtcp::packet::Packet + Send + Sync> = Box::new(feedback.get_rtcp()); in build_feedback_packet() localVariable
80 pkts.push(p); in build_feedback_packet()
87 let p: Box<dyn rtcp::packet::Packet + Send + Sync> = Box::new(feedback.get_rtcp()); in build_feedback_packet() localVariable
88 pkts.push(p); in build_feedback_packet()
223 let p = PacketStatusChunk::RunLengthChunk(RunLengthChunk { in encode() localVariable
229 return p; in encode()
232 let p = PacketStatusChunk::StatusVectorChunk(StatusVectorChunk { in encode() localVariable
242 return p; in encode()
/webrtc/examples/
H A DREADME.md5 <p align="center">
27 </p>
28 <p align="center">
30 </p>
/webrtc/interceptor/src/nack/generator/
H A Dgenerator_test.rs56 if let Some(p) = r[0].as_any().downcast_ref::<TransportLayerNack>() { in test_generator_interceptor()
57 assert_eq!(p.nacks[0].packet_id, 13); in test_generator_interceptor()
58 …assert_eq!(p.nacks[0].lost_packets, 0b10); // we want packets: 13, 15 (not packet 17, because skip… in test_generator_interceptor()
/webrtc/stun/src/
H A Duri.rs47 if let Some(p) = pos { in parse_uri()
48 s.replace_range(p..p + 1, "://"); in parse_uri()

1234