Home
last modified time | relevance | path

Searched defs:a (Results 1 – 25 of 62) sorted by relevance

123

/webrtc/sdp/src/description/
H A Dsession.rs582 fn s1<'a, R: io::BufRead + io::Seek>(lexer: &mut Lexer<'a, R>) -> Result<Option<StateFn<'a, R>>> { in s1() argument
593 fn s2<'a, R: io::BufRead + io::Seek>(lexer: &mut Lexer<'a, R>) -> Result<Option<StateFn<'a, R>>> { in s2() argument
604 fn s3<'a, R: io::BufRead + io::Seek>(lexer: &mut Lexer<'a, R>) -> Result<Option<StateFn<'a, R>>> { in s3() argument
615 fn s4<'a, R: io::BufRead + io::Seek>(lexer: &mut Lexer<'a, R>) -> Result<Option<StateFn<'a, R>>> { in s4() argument
637 fn s5<'a, R: io::BufRead + io::Seek>(lexer: &mut Lexer<'a, R>) -> Result<Option<StateFn<'a, R>>> { in s5() argument
650 fn s6<'a, R: io::BufRead + io::Seek>(lexer: &mut Lexer<'a, R>) -> Result<Option<StateFn<'a, R>>> { in s6() argument
924 fn unmarshal_origin<'a, R: io::BufRead + io::Seek>( in unmarshal_origin()
981 fn unmarshal_uri<'a, R: io::BufRead + io::Seek>( in unmarshal_uri()
989 fn unmarshal_email<'a, R: io::BufRead + io::Seek>( in unmarshal_email()
997 fn unmarshal_phone<'a, R: io::BufRead + io::Seek>( in unmarshal_phone()
[all …]
/webrtc/turn/src/allocation/channel_bind/
H A Dchannel_bind_test.rs14 let a = Allocation::new( in create_channel_bind() localVariable
33 let a = create_channel_bind(Duration::from_millis(20)).await?; in test_channel_bind() localVariable
46 let a = create_channel_bind(Duration::from_millis(20)).await?; in test_channel_bind_start() localVariable
58 let a = create_channel_bind(Duration::from_millis(30)).await?; in test_channel_bind_reset() localVariable
/webrtc/stun/src/fingerprint/
H A Dfingerprint_test.rs10 let a = TextAttribute { in fingerprint_uses_crc_32_iso_hdlc() localVariable
30 let a = TextAttribute { in test_fingerprint_check() localVariable
51 let a = TextAttribute { in test_fingerprint_check_bad() localVariable
/webrtc/stun/src/agent/
H A Dagent_test.rs11 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_process_in_transaction() localVariable
37 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_process() localVariable
73 let mut a = Agent::new(noop_handler()); in test_agent_start() localVariable
125 let mut a = Agent::new(Some(Arc::new(handler_tx))); in test_agent_stop() localVariable
/webrtc/sctp/src/association/association_internal/
H A Dassociation_internal_test.rs66 let mut a = AssociationInternal { in test_create_forward_tsn_forward_one_abandoned() localVariable
96 let mut a = AssociationInternal { in test_create_forward_tsn_forward_two_abandoned_with_the_same_si() localVariable
164 let mut a = AssociationInternal { in test_handle_forward_tsn_forward_3unreceived_chunks() localVariable
200 let mut a = AssociationInternal { in test_handle_forward_tsn_forward_1for1_missing() localVariable
250 let mut a = AssociationInternal { in test_handle_forward_tsn_forward_1for2_missing() localVariable
298 let mut a = AssociationInternal { in test_handle_forward_tsn_dup_forward_tsn_chunk_should_generate_sack() localVariable
325 let mut a = AssociationInternal { in test_assoc_create_new_stream() localVariable
362 let mut a = create_association_internal(Config { in handle_init_test() localVariable
452 let mut a = create_association_internal(Config { in test_assoc_max_message_size_default() localVariable
497 let mut a = create_association_internal(Config { in test_assoc_max_message_size_explicit() localVariable
/webrtc/turn/src/allocation/
H A Dallocation_test.rs13 let a = Allocation::new( in test_has_permission() localVariable
51 let a = Allocation::new( in test_add_permission() localVariable
75 let a = Allocation::new( in test_remove_permission() localVariable
108 let a = Allocation::new( in test_add_channel_bind() localVariable
142 let a = Allocation::new( in test_get_channel_by_number() localVariable
178 let a = Allocation::new( in test_get_channel_by_addr() localVariable
210 let a = Allocation::new( in test_remove_channel_bind() localVariable
247 let a = Allocation::new( in test_allocation_refresh() localVariable
269 let a = Allocation::new( in test_allocation_close() localVariable
/webrtc/ice/src/agent/
H A Dagent_gather_test.rs15 let a = Agent::new(AgentConfig { in test_vnet_gather_no_local_ip_address() localVariable
47 let a = Agent::new(AgentConfig { in test_vnet_gather_dynamic_ip_address() localVariable
81 let a = Agent::new(AgentConfig { in test_vnet_gather_listen_udp() localVariable
146 let a = Agent::new(AgentConfig { in test_vnet_gather_with_nat_1to1_as_host_candidates() localVariable
262 let a = Agent::new(AgentConfig { in test_vnet_gather_with_nat_1to1_as_srflx_candidates() localVariable
332 let a = Agent::new(AgentConfig { in test_vnet_gather_with_interface_filter() localVariable
354 let a = Agent::new(AgentConfig { in test_vnet_gather_with_interface_filter() localVariable
446 let a = Agent::new(AgentConfig { in test_vnet_gather_muxed_udp() localVariable
H A Dagent_test.rs25 let a = Agent::new(config).await?; in test_pair_search() localVariable
51 let a = Agent::new(AgentConfig::default()).await?; in test_pair_priority() localVariable
189 let a = Agent::new(AgentConfig::default()).await?; in test_on_selected_candidate_pair_change() localVariable
244 let a = Agent::new(AgentConfig::default()).await?; in test_handle_peer_reflexive_udp_pflx_candidate() localVariable
326 let a = Agent::new(AgentConfig::default()).await?; in test_handle_peer_reflexive_unknown_remote() localVariable
873 let a = Agent::new(AgentConfig::default()).await?; in test_invalid_agent_starts() localVariable
1031 let a = Agent::new(AgentConfig::default()).await?; in test_invalid_gather() localVariable
1048 let a = Agent::new(AgentConfig::default()).await?; in test_candidate_pair_stats() localVariable
1210 let a = Agent::new(AgentConfig::default()).await?; in test_local_candidate_stats() localVariable
1301 let a = Agent::new(AgentConfig::default()).await?; in test_remote_candidate_stats() localVariable
[all …]
/webrtc/turn/src/proto/addr/
H A Daddr_test.rs10 let a = Addr::from_socket_addr(&u); in test_addr_from_socket_addr() localVariable
22 let a = Addr { in test_addr_equal_ip() localVariable
/webrtc/sctp/src/association/
H A Dassociation_test.rs255 let a = a0.association_internal.lock().await; in test_assoc_reliable_simple() localVariable
264 let a = a0.association_internal.lock().await; in test_assoc_reliable_simple() localVariable
281 let a = a0.association_internal.lock().await; in test_assoc_reliable_simple() localVariable
330 let a = a0.association_internal.lock().await; in test_assoc_reliable_ordered_reordered() localVariable
726 let a = a0.association_internal.lock().await; in test_assoc_reliable_short_buffer() localVariable
735 let a = a0.association_internal.lock().await; in test_assoc_reliable_short_buffer() localVariable
758 let a = a0.association_internal.lock().await; in test_assoc_reliable_short_buffer() localVariable
1387 let a = a0.association_internal.lock().await; in test_assoc_congestion_control_fast_retransmission() localVariable
2210 let a = Association::client(Config { in test_stats() localVariable
2245 let a = Association::client(Config { in create_assocs() localVariable
[all …]
/webrtc/stun/benches/
H A Dbench.rs61 let mut a = Agent::new(noop_handler()); in benchmark_agent() localVariable
76 let mut a = Agent::new(noop_handler()); in benchmark_agent() localVariable
129 let a = ErrorCodeAttribute { in benchmark_error_code() localVariable
143 let mut a = ErrorCodeAttribute { in benchmark_error_code() localVariable
459 let mut a = Message::new(); in benchmark_message() localVariable
476 let mut a = Message::new(); in benchmark_message() localVariable
569 let a = UnknownAttributes(vec![ in benchmark_unknown_attributes() localVariable
599 let mut a = [0u8; 1024]; in benchmark_xor() localVariable
/webrtc/stun/src/integrity/
H A Dintegrity_test.rs25 let a = TextAttribute { in test_message_integrity_add_to_simple() localVariable
51 let a = TextAttribute { in test_message_integrity_with_fingerprint() localVariable
/webrtc/sctp/examples/
H A Dthroughput.rs70 let a = Association::server(config).await?; in main() localVariable
116 let a = Association::client(config).await.unwrap(); in main() localVariable
H A Dpong.rs70 let a = Association::server(config).await?; in main() localVariable
H A Dping.rs71 let a = Association::client(config).await?; in main() localVariable
/webrtc/stun/src/message/
H A Dmessage_test.rs345 let a = RawAttribute { in test_attribute_equal() localVariable
402 let a = Message { in test_message_equal() localVariable
476 let a = Message { in test_message_equal() localVariable
504 let a = Message { in test_message_equal() localVariable
529 let a = Message { in test_message_equal() localVariable
576 let a = TextAttribute { in test_is_message() localVariable
/webrtc/turn/src/proto/peeraddr/
H A Dpeeraddr_test.rs8 let a = PeerAddress { in test_peer_address() localVariable
/webrtc/turn/src/proto/relayaddr/
H A Drelayaddr_test.rs8 let a = RelayedAddress { in test_relayed_address() localVariable
/webrtc/turn/src/proto/
H A Dpeeraddr.rs44 let a = XorMappedAddress { in add_to() localVariable
55 let mut a = XorMappedAddress::default(); in get_from() localVariable
H A Drelayaddr.rs43 let a = XorMappedAddress { in add_to() localVariable
54 let mut a = XorMappedAddress::default(); in get_from() localVariable
/webrtc/stun/src/uattrs/
H A Duattrs_test.rs6 let a = UnknownAttributes(vec![ATTR_DONT_FRAGMENT, ATTR_CHANNEL_NUMBER]); in test_unknown_attributes() localVariable
/webrtc/turn/src/server/
H A Drequest.rs472 let a = match self in handle_allocate_request() localVariable
573 let a = self.allocation_manager.get_allocation(&five_tuple).await; in handle_refresh_request() localVariable
598 let a = self in handle_create_permission_request() localVariable
665 let a = self in handle_send_indication() localVariable
706 let a = self in handle_channel_bind_request() localVariable
775 let a = self in handle_channel_data() localVariable
/webrtc/media/src/io/sample_builder/
H A Dsample_sequence_location.rs74 pub(crate) fn range<'a, T>(&self, data: &'a [Option<T>]) -> Iterator<'a, T> { in range()
/webrtc/webrtc/src/api/interceptor_registry/
H A Dinterceptor_registry_test.rs46 let a = attributes.clone(); localVariable
/webrtc/webrtc/src/rtp_transceiver/fmtp/generic/
H A Dgeneric_test.rs153 let a = parse("video/vp8", ""); in test_generic_fmtp_compare_mime_type_case_mismatch() localVariable

123