Home
last modified time | relevance | path

Searched defs:p (Results 1 – 25 of 36) sorted by relevance

12

/webrtc/rtp/src/packet/
H A Dpacket_test.rs182 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
599 let mut p = Packet { in test_rfc8285_del_extension() 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
707 let mut p = Packet { in test_rfc8285_del_extension_returns_error_when_extenstions_disabled() localVariable
[all …]
/webrtc/turn/src/proto/evenport/
H A Devenport_test.rs5 let mut p = EvenPort::default(); in test_even_port_string() localVariable
25 let p = EvenPort { in test_even_port_false() localVariable
43 let p = EvenPort { reserve_port: true }; in test_even_port_add_to() localVariable
/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
229 let p = a.handle_forward_tsn(&fwdtsn).await?; in test_handle_forward_tsn_forward_1for1_missing() localVariable
279 let p = a.handle_forward_tsn(&fwdtsn).await?; in test_handle_forward_tsn_forward_1for2_missing() localVariable
313 let p = a.handle_forward_tsn(&fwdtsn).await?; in test_handle_forward_tsn_dup_forward_tsn_chunk_should_generate_sack() localVariable
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
514 let p = Bytes::from(vec![0u8; 30001]); in test_assoc_max_message_size_explicit() localVariable
/webrtc/rtp/src/codecs/vp9/
H A Dvp9_test.rs214 let mut p = Vp9Packet::default(); in test_vp9_packet_unmarshal() localVariable
318 let mut p = Vp9Packet::default(); in test_vp9_payloader_payload() localVariable
/webrtc/mdns/src/message/
H A Dmessage_test.rs255 let mut p = Parser { in test_question_pack_unpack() localVariable
406 let mut p = Parser::default(); in test_parser_start() localVariable
455 let mut p = Parser::default(); in test_resource_not_started() localVariable
540 let mut p = Parser::default(); in test_skip_all() localVariable
563 let mut p = Parser::default(); in test_skip_each() localVariable
606 let mut p = Parser::default(); in test_skip_after_read() localVariable
669 let mut p = Parser::default(); in test_skip_not_started() localVariable
/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
/webrtc/ice/src/priority/
H A Dpriority_test.rs7 let mut p = PriorityAttr::default(); in test_priority_get_from() localVariable
H A Dmod.rs31 let p = u32::from_be_bytes([v[0], v[1], v[2], v[3]]); in get_from() localVariable
/webrtc/rtp/benches/
H A Dpacket_bench.rs32 let p = Packet::unmarshal(buf).unwrap(); in benchmark_packet() localVariable
/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
87 let p: Box<dyn rtcp::packet::Packet + Send + Sync> = Box::new(feedback.get_rtcp()); in build_feedback_packet() localVariable
223 let p = PacketStatusChunk::RunLengthChunk(RunLengthChunk { in encode() localVariable
232 let p = PacketStatusChunk::StatusVectorChunk(StatusVectorChunk { in encode() localVariable
/webrtc/rtcp/src/
H A Dpacket.rs64 let p = unmarshaller(raw_data)?; in unmarshal() localVariable
92 let p: Box<dyn Packet + Send + Sync> = match h.packet_type { in unmarshaller() localVariable
/webrtc/util/src/vnet/
H A Dresolver.rs60 let p = parent2.lock().await; in lookup() localVariable
/webrtc/sctp/src/chunk/
H A Dchunk_heartbeat.rs65 let p = in unmarshal() localVariable
H A Dchunk_heartbeat_ack.rs67 let p = in unmarshal() localVariable
H A Dchunk_init.rs173 let p = build_param(&raw.slice(offset..CHUNK_HEADER_SIZE + header.value_length()))?; in unmarshal() localVariable
/webrtc/rtcp/src/compound_packet/
H A Dcompound_packet_test.rs51 let p = unmarshal(&mut bad_compound).expect("Error unmarshalling packet"); in test_bad_compound() localVariable
H A Dmod.rs107 let p = unmarshaller(raw_packet)?; in unmarshal() localVariable
/webrtc/turn/src/allocation/
H A Dpermission.rs47 let mut p = perms.lock().await; in start() localVariable
H A Dallocation_test.rs61 let p = Permission::new(addr); in test_add_permission() localVariable
86 let p = Permission::new(addr); in test_remove_permission() localVariable
/webrtc/sctp/src/association/
H A Dassociation_internal.rs313 let p = match Packet::unmarshal(raw) { in handle_inbound() localVariable
371 let p = self.create_packet(vec![Box::new(c.clone())]); in gather_outbound_data_and_reconfig_packets() localVariable
398 let p = self.create_packet(vec![Box::new(c)]); in gather_outbound_data_and_reconfig_packets() localVariable
468 let p = self.create_packet(to_fast_retrans); in gather_outbound_fast_retransmission_packets() localVariable
481 let p = self.create_packet(vec![Box::new(sack)]); in gather_outbound_sack_packets() localVariable
501 let p = self.create_packet(vec![Box::new(fwd_tsn)]); in gather_outbound_forward_tsn_packets() localVariable
522 let p = self.create_packet(vec![Box::new(shutdown)]); in gather_outbound_shutdown_packets() localVariable
532 let p = self.create_packet(vec![Box::new(shutdown_ack)]); in gather_outbound_shutdown_packets() localVariable
542 let p = self.create_packet(vec![Box::new(shutdown_complete)]); in gather_outbound_shutdown_packets() localVariable
/webrtc/interceptor/src/twcc/receiver/
H A Dreceiver_stream.rs37 let p = rtp::packet::Packet::unmarshal(&mut b)?; in read() localVariable
/webrtc/webrtc/src/track/track_remote/
H A Dmod.rs188 let p = self.params.lock(); in params() localVariable
193 let mut p = self.params.lock(); in set_params() localVariable
252 let p = self in check_and_update_track() localVariable
/webrtc/sctp/src/param/
H A Dparam_test.rs249 let p = build_param(&binary)?; in test_build_param_success() localVariable
/webrtc/media/src/io/sample_builder/
H A Dsample_builder_test.rs1479 let p = Packet { in test_sample_builder_data() localVariable
/webrtc/dtls/src/flight/
H A Dflight5.rs436 let mut p = Packet { in generate() localVariable

12