| /webrtc/ice/src/candidate/ |
| H A D | candidate_pair_test.rs | 64 CandidatePair::new( in test_candidate_pair_priority()
72 CandidatePair::new( in test_candidate_pair_priority()
80 CandidatePair::new( in test_candidate_pair_priority()
88 CandidatePair::new( in test_candidate_pair_priority()
96 CandidatePair::new( in test_candidate_pair_priority()
104 CandidatePair::new( in test_candidate_pair_priority()
112 CandidatePair::new( in test_candidate_pair_priority()
120 CandidatePair::new( in test_candidate_pair_priority()
142 let pair_a = CandidatePair::new( in test_candidate_pair_equality()
143 Arc::new(host_candidate()?), in test_candidate_pair_equality()
[all …]
|
| 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()
20 network_type: AtomicU8::new(NetworkType::Tcp4 as u8), 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()
[all …]
|
| /webrtc/util/src/vnet/conn_map/ |
| H A D | conn_map_test.rs | 32 let conn_in = Arc::new(UdpConn::new( in test_udp_conn_map_insert_remove()
71 let conn_in = Arc::new(UdpConn::new( in test_udp_conn_map_insert_0_remove()
110 let conn_in = Arc::new(UdpConn::new( in test_udp_conn_map_find_0()
139 let conn_in1 = Arc::new(UdpConn::new( in test_udp_conn_map_insert_many_ips_with_same_port()
145 let conn_in2 = Arc::new(UdpConn::new( in test_udp_conn_map_insert_many_ips_with_same_port()
186 let conn_in1 = Arc::new(UdpConn::new( in test_udp_conn_map_already_inuse_when_insert_0()
191 let conn_in2 = Arc::new(UdpConn::new( in test_udp_conn_map_already_inuse_when_insert_0()
211 let conn_in1 = Arc::new(UdpConn::new( in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
216 let conn_in2 = Arc::new(UdpConn::new( in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
261 let conn_in = Arc::new(UdpConn::new( in test_udp_conn_map_find_failure_1()
[all …]
|
| /webrtc/dtls/src/cipher_suite/ |
| H A D | mod.rs | 153 Ok(Box::new(CipherSuiteAes128GcmSha256::new(true))) in cipher_suite_for_id()
156 Ok(Box::new(CipherSuiteAes256CbcSha::new(true))) in cipher_suite_for_id()
159 Ok(Box::new(CipherSuiteAes256CbcSha::new(false))) in cipher_suite_for_id()
177 Box::new(CipherSuiteAes128GcmSha256::new(false)), in default_cipher_suites()
178 Box::new(CipherSuiteAes256CbcSha::new(false)), in default_cipher_suites()
179 Box::new(CipherSuiteAes128GcmSha256::new(true)), in default_cipher_suites()
180 Box::new(CipherSuiteAes256CbcSha::new(true)), in default_cipher_suites()
188 Box::new(CipherSuiteAes128GcmSha256::new(false)), in all_cipher_suites()
189 Box::new(CipherSuiteAes128GcmSha256::new(true)), in all_cipher_suites()
190 Box::new(CipherSuiteAes256CbcSha::new(false)), in all_cipher_suites()
[all …]
|
| /webrtc/stun/benches/ |
| H A D | bench.rs | 31 let mut m = Message::new(); in benchmark_addr()
81 let mut m = Message::new(); in benchmark_agent()
95 let m = Message::new(); in benchmark_attributes()
104 let mut m = Message::new(); in benchmark_attributes()
118 let mut m = Message::new(); in benchmark_error_code()
128 let mut m = Message::new(); in benchmark_error_code()
142 let mut m = Message::new(); in benchmark_error_code()
158 let mut m = Message::new(); in benchmark_fingerprint()
178 let mut m = Message::new(); in benchmark_fingerprint()
450 Box::new(Software::new(ATTR_SOFTWARE, "webrtc-rs/stun".to_owned())), in benchmark_message()
[all …]
|
| /webrtc/turn/src/allocation/ |
| H A D | allocation_test.rs | 13 let a = Allocation::new( in test_has_permission()
26 let p1 = Permission::new(addr1); in test_has_permission()
27 let p2 = Permission::new(addr2); in test_has_permission()
51 let a = Allocation::new( in test_add_permission()
75 let a = Allocation::new( in test_remove_permission()
108 let a = Allocation::new( in test_add_channel_bind()
142 let a = Allocation::new( in test_get_channel_by_number()
178 let a = Allocation::new( in test_get_channel_by_addr()
210 let a = Allocation::new( in test_remove_channel_bind()
247 let a = Allocation::new( in test_allocation_refresh()
[all …]
|
| /webrtc/interceptor/src/report/ |
| H A D | mod.rs | 48 streams: Mutex::new(HashMap::new()), in build_rr()
49 close_rx: Mutex::new(Some(close_rx)), in build_rr()
52 wg: Mutex::new(Some(WaitGroup::new())), in build_rr()
53 close_tx: Mutex::new(Some(close_tx)), in build_rr()
60 internal: Arc::new(SenderReportInternal { in build_sr()
67 streams: Mutex::new(HashMap::new()), in build_sr()
68 close_rx: Mutex::new(Some(close_rx)), in build_sr()
71 wg: Mutex::new(Some(WaitGroup::new())), in build_sr()
72 close_tx: Mutex::new(Some(close_tx)), in build_sr()
80 Ok(Arc::new(self.build_rr())) in build()
[all …]
|
| /webrtc/turn/src/server/ |
| H A D | server_test.rs | 20 fn new() -> Self { in new() method
55 net: Arc::new(net::Net::new(None)), in test_server_simple()
59 auth_handler: Arc::new(TestAuthHandler::new()), in test_server_simple()
77 realm: String::new(), in test_server_simple()
107 let wan = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in build_vnet()
112 let net0 = Arc::new(net::Net::new(Some(net::NetConfig { in build_vnet()
117 let net1 = Arc::new(net::Net::new(Some(net::NetConfig { in build_vnet()
140 let lan = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in build_vnet()
151 let netl0 = Arc::new(net::Net::new(Some(net::NetConfig::default()))); in build_vnet()
194 auth_handler: Arc::new(TestAuthHandler::new()), in build_vnet()
[all …]
|
| /webrtc/ice/src/agent/ |
| H A D | agent_gather_test.rs | 40 let r = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in test_vnet_gather_dynamic_ip_address()
74 let r = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in test_vnet_gather_listen_udp()
122 let wan = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in test_vnet_gather_with_nat_1to1_as_host_candidates()
127 let lan = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in test_vnet_gather_with_nat_1to1_as_host_candidates()
139 let nw = Arc::new(net::Net::new(Some(net::NetConfig { in test_vnet_gather_with_nat_1to1_as_host_candidates()
155 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_vnet_gather_with_nat_1to1_as_host_candidates()
238 let wan = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
243 let lan = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
272 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
323 let r = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in test_vnet_gather_with_interface_filter()
[all …]
|
| H A D | agent_test.rs | 228 let p = Arc::new(CandidatePair::new( in test_on_selected_candidate_pair_change()
273 Box::new(TransactionId::new()), in test_handle_peer_reflexive_udp_pflx_candidate()
275 Box::new(UseCandidateAttr::new()), in test_handle_peer_reflexive_udp_pflx_candidate()
404 let wan = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in test_connectivity_on_startup()
437 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_connectivity_on_startup()
450 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_connectivity_on_startup()
545 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_connectivity_lite()
621 Box::new(TransactionId::new()), in build_msg()
813 Box::new(TransactionId::new()), in test_inbound_validity()
1714 let wf = Arc::new(Mutex::new(Some(wf))); in test_connection_state_connecting_to_failed()
[all …]
|
| H A D | agent_vnet_test.rs | 73 let wan = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in build_simple_vnet()
86 let lan = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in build_simple_vnet()
122 let wan = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in build_vnet()
135 let lan0 = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in build_vnet()
155 let lan1 = Arc::new(Mutex::new(router::Router::new(router::RouterConfig { in build_vnet()
310 let a_agent = Arc::new(Agent::new(cfg0).await?); in pipe_with_vnet()
328 let b_agent = Arc::new(Agent::new(cfg1).await?); in pipe_with_vnet()
362 let w1 = Arc::new(Mutex::new(Some(wg.worker()))); in gather_and_exchange_candidates()
376 let w2 = Arc::new(Mutex::new(Some(wg.worker()))); in gather_and_exchange_candidates()
773 let wan = Arc::new(Mutex::new(wan)); in test_disconnected_to_connected()
[all …]
|
| /webrtc/turn/src/client/relay_conn/ |
| H A D | relay_conn_test.rs | 43 turn_server_addr: String::new(), in test_relay_conn()
44 username: Username::new(ATTR_USERNAME, "username".to_owned()), in test_relay_conn()
45 realm: Realm::new(ATTR_REALM, "realm".to_owned()), in test_relay_conn()
51 relayed_addr: SocketAddr::new(Ipv4Addr::new(0, 0, 0, 0).into(), 0), in test_relay_conn()
53 nonce: Nonce::new(ATTR_NONCE, "nonce".to_owned()), in test_relay_conn()
55 binding_mgr: Arc::new(Mutex::new(BindingManager::new())), in test_relay_conn()
56 read_ch_rx: Arc::new(Mutex::new(read_ch_rx)), in test_relay_conn()
59 let rc = RelayConn::new(Arc::new(Mutex::new(obs)), config).await; in test_relay_conn()
65 .create(SocketAddr::new(Ipv4Addr::new(127, 0, 0, 1).into(), 1234)) in test_relay_conn()
|
| /webrtc/turn/src/client/ |
| H A D | client_test.rs | 15 let c = Client::new(ClientConfig { in create_listening_test_client()
18 username: String::new(), in create_listening_test_client()
19 password: String::new(), in create_listening_test_client()
20 realm: String::new(), in create_listening_test_client()
23 conn: Arc::new(conn), in create_listening_test_client()
39 username: String::new(), in create_listening_test_client_with_stun_serv()
40 password: String::new(), in create_listening_test_client_with_stun_serv()
41 realm: String::new(), in create_listening_test_client_with_stun_serv()
44 conn: Arc::new(conn), in create_listening_test_client_with_stun_serv()
147 net: Arc::new(Net::new(None)), in test_client_nonce_expiration()
[all …]
|
| H A D | mod.rs | 162 Arc::new(Net::new(None)) in new()
197 tr_map: Arc::new(Mutex::new(TransactionMap::new())), in new()
198 binding_mgr: Arc::new(Mutex::new(BindingManager::new())), in new()
205 read_ch_tx: Arc::new(Mutex::new(None)), in new()
441 Box::new(TransactionId::new()), in send_binding_request_to()
446 vec![Box::new(TransactionId::new()), Box::new(BINDING_REQUEST)] in send_binding_request_to()
495 Box::new(TransactionId::new()), in allocate()
496 Box::new(MessageType::new(METHOD_ALLOCATE, CLASS_REQUEST)), in allocate()
521 Box::new(TransactionId::new()), in allocate()
571 read_ch_rx: Arc::new(Mutex::new(read_ch_rx)), in allocate()
[all …]
|
| H A D | relay_conn.rs | 92 relay_conn: Arc::new(Mutex::new(RelayConnInternal::new(obs, config))), in new()
144 Err(io::Error::new( in recv_from()
296 Box::new(TransactionId::new()), in send_to()
297 Box::new(MessageType::new(METHOD_SEND, CLASS_INDICATION)), in send_to()
395 Box::new(TransactionId::new()), in create_permissions()
396 Box::new(MessageType::new(METHOD_CREATE_PERMISSION, CLASS_REQUEST)), in create_permissions()
469 Box::new(TransactionId::new()), in refresh_allocation()
470 Box::new(MessageType::new(METHOD_REFRESH, CLASS_REQUEST)), in refresh_allocation()
546 Box::new(TransactionId::new()), in bind()
547 Box::new(MessageType::new(METHOD_CHANNEL_BIND, CLASS_REQUEST)), in bind()
[all …]
|
| /webrtc/ice/src/control/ |
| H A D | control_test.rs | 6 let mut m = Message::new(); in test_controlled_get_from()
15 m.build(&[Box::new(BINDING_REQUEST), Box::new(c)])?; in test_controlled_get_from()
17 let mut m1 = Message::new(); in test_controlled_get_from()
27 let mut m3 = Message::new(); in test_controlled_get_from()
43 let mut m = Message::new(); in test_controlling_get_from()
52 m.build(&[Box::new(BINDING_REQUEST), Box::new(c)])?; in test_controlling_get_from()
54 let mut m1 = Message::new(); in test_controlling_get_from()
82 let m = Message::new(); in test_control_get_from()
93 let mut m = Message::new(); in test_control_get_from()
105 m.build(&[Box::new(BINDING_REQUEST), Box::new(c)])?; in test_control_get_from()
[all …]
|
| /webrtc/media/src/io/ogg_reader/ |
| H A D | ogg_reader_test.rs | 19 let r = Cursor::new(&ogg); in test_ogg_reader_parse_valid_header()
20 let (_reader, header) = OggReader::new(r, true)?; in test_ogg_reader_parse_valid_header()
35 let r = Cursor::new(&ogg); in test_ogg_reader_parse_next_page()
36 let (mut reader, _header) = OggReader::new(r, true)?; in test_ogg_reader_parse_next_page()
54 let result = OggReader::new(Cursor::new(ogg), false); in test_ogg_reader_parse_errors()
66 let result = OggReader::new(Cursor::new(ogg), false); in test_ogg_reader_parse_errors()
78 let result = OggReader::new(Cursor::new(ogg), false); in test_ogg_reader_parse_errors()
90 let result = OggReader::new(Cursor::new(ogg), false); in test_ogg_reader_parse_errors()
102 let result = OggReader::new(Cursor::new(ogg), true); in test_ogg_reader_parse_errors()
|
| /webrtc/sctp/src/timer/ |
| H A D | timer_test.rs | 37 let ncbs = Arc::new(AtomicU32::new(0)); in test_ack_timer_start_and_stop()
184 ncbs: Arc::new(AtomicU32::new(0)), in default()
226 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_callback_interval()
227 let obs = Arc::new(Mutex::new(TestTimerObserver { in test_rtx_timer_callback_interval()
253 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_last_start_wins()
281 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_stop_right_after_start()
306 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_start_stop_then_start()
335 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_start_and_stop_in_atight_loop()
361 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_should_stop_after_rtx_failure()
411 let ncbs = Arc::new(AtomicU32::new(0)); in test_rtx_timer_should_not_stop_if_max_retrans_is_zero()
[all …]
|
| /webrtc/stun/src/message/ |
| H A D | message_test.rs | 11 let mut m = Message::new(); in test_message_buffer()
138 let mut m = Message::new(); in test_message_write_to()
547 let mut m = Message::new(); in test_message_grow()
556 let mut m = Message::new(); in test_message_grow_smaller()
567 let m = Message::new(); in test_message_string()
622 Box::new(TextAttribute::new(ATTR_SOFTWARE, "pion/stun".to_owned())), in test_message_full_size()
628 Box::new(FINGERPRINT), in test_message_full_size()
648 Box::new(TextAttribute::new(ATTR_SOFTWARE, "pion/stun".to_owned())), in test_message_clone_to()
654 Box::new(FINGERPRINT), in test_message_clone_to()
678 Box::new(FINGERPRINT), in test_message_add_to()
[all …]
|
| /webrtc/util/src/vnet/nat/ |
| H A D | nat_test.rs | 66 let iec = ChunkUdp::new( in test_nat_mapping_behavior_full_cone_nat()
81 let iec = ChunkUdp::new( in test_nat_mapping_behavior_full_cone_nat()
90 let iec = ChunkUdp::new( in test_nat_mapping_behavior_full_cone_nat()
127 let oic2 = ChunkUdp::new( in test_nat_mapping_behavior_addr_restricted_cone_nat()
136 let iec = ChunkUdp::new( in test_nat_mapping_behavior_addr_restricted_cone_nat()
151 let iec = ChunkUdp::new( in test_nat_mapping_behavior_addr_restricted_cone_nat()
160 let iec = ChunkUdp::new( in test_nat_mapping_behavior_addr_restricted_cone_nat()
169 let iec = ChunkUdp::new( in test_nat_mapping_behavior_addr_restricted_cone_nat()
215 let iec = ChunkUdp::new( in test_nat_mapping_behavior_port_restricted_cone_nat()
230 let iec = ChunkUdp::new( in test_nat_mapping_behavior_port_restricted_cone_nat()
[all …]
|
| /webrtc/turn/src/server/request/ |
| H A D | request_test.rs | 17 let mut m = Message::new(); in test_allocation_lifetime_parsing()
40 let mut m2 = Message::new(); in test_allocation_lifetime_overflow()
63 let l = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_allocation_lifetime_deletion_zero_lifetime()
65 let allocation_manager = Arc::new(Manager::new(ManagerConfig { in test_allocation_lifetime_deletion_zero_lifetime()
66 relay_addr_generator: Box::new(RelayAddressGeneratorNone { in test_allocation_lifetime_deletion_zero_lifetime()
68 net: Arc::new(Net::new(None)), in test_allocation_lifetime_deletion_zero_lifetime()
75 let mut r = Request::new(l, socket, allocation_manager, Arc::new(TestAuthHandler {})); in test_allocation_lifetime_deletion_zero_lifetime()
94 TextAttribute::new(ATTR_USERNAME, "user".into()), in test_allocation_lifetime_deletion_zero_lifetime()
103 let mut m = Message::new(); in test_allocation_lifetime_deletion_zero_lifetime()
106 Nonce::new(ATTR_NONCE, STATIC_KEY.to_owned()).add_to(&mut m)?; in test_allocation_lifetime_deletion_zero_lifetime()
[all …]
|
| /webrtc/media/src/io/h264_reader/ |
| H A D | h264_reader_test.rs | 7 let mut reader = H264Reader::new(Cursor::new(input), 1_048_576); in test_data_does_not_start_with_h264header()
27 let mut reader = H264Reader::new(Cursor::new(h264bytes), 1_048_576); in test_parse_header()
43 let mut reader = H264Reader::new(Cursor::new(input), 1_048_576); in test_eof()
65 let mut reader = H264Reader::new(Cursor::new(h264bytes), 1_048_576); in test_skip_sei()
84 let mut reader = H264Reader::new(Cursor::new(test), 1_048_576); in test_issue1734_next_nal()
98 let mut r = H264Reader::new(Cursor::new(test), 1_048_576); in test_trailing01after_start_code()
|
| /webrtc/util/src/vnet/router/ |
| H A D | router_test.rs | 22 done_ch_tx: Arc::new(Mutex::new(None)), in default()
160 let wan = Arc::new(Mutex::new(Router::new(RouterConfig { in test_router_standalone_add_net()
191 let wan = Arc::new(Mutex::new(Router::new(RouterConfig { in test_router_standalone_routing()
278 let wan = Arc::new(Mutex::new(Router::new(RouterConfig { in test_router_standalone_add_chunk_filter()
368 let wan = Arc::new(Mutex::new(Router::new(RouterConfig { in delay_sub_test()
526 let r = Arc::new(Mutex::new(Router::new(RouterConfig { in test_router_one_child()
692 let wan = Arc::new(Mutex::new(Router::new(RouterConfig { in test_router_static_ips_1to1_nat()
697 let lan = Arc::new(Mutex::new(Router::new(RouterConfig { in test_router_static_ips_1to1_nat()
765 let wan = Arc::new(Mutex::new(Router::new(RouterConfig { in test_router_failures_add_net()
789 let r1 = Arc::new(Mutex::new(Router::new(RouterConfig { in test_router_failures_add_router()
[all …]
|
| /webrtc/mdns/src/message/ |
| H A D | message_test.rs | 18 let name = Name::new("example.com.")?; in small_test_msg()
241 let name = Name::new(want)?; in test_name_string()
250 name: Name::new(".")?, in test_question_pack_unpack()
297 let name = Name::new(test)?; in test_name()
335 let want = Name::new(want)?; in test_name_pack_unpack()
466 let want = Box::new(SrvResource { in test_srv_pack_unpack()
753 let mut str255 = String::new(); in test_very_long_txt()
797 let mut str256 = String::new(); in test_too_long_txt()
835 Box::new(|| -> Builder { in test_start_error()
845 Box::new(|| -> Builder { in test_start_error()
[all …]
|
| /webrtc/srtp/src/ |
| H A D | option.rs | 10 Box::new(move || -> Box<dyn ReplayDetector + Send> { in srtp_replay_protection()
11 Box::new(WrappedSlidingWindowDetector::new( in srtp_replay_protection()
20 Box::new(move || -> Box<dyn ReplayDetector + Send> { in srtcp_replay_protection()
21 Box::new(WrappedSlidingWindowDetector::new( in srtcp_replay_protection()
30 Box::new(|| -> Box<dyn ReplayDetector + Send> { Box::<NoOpReplayDetector>::default() }) in srtp_no_replay_protection()
35 Box::new(|| -> Box<dyn ReplayDetector + Send> { Box::<NoOpReplayDetector>::default() }) in srtcp_no_replay_protection()
|