Home
last modified time | relevance | path

Searched refs:clone (Results 1 – 25 of 294) sorted by relevance

12345678910>>...12

/webrtc/constraints/src/settings/
H A Dtrack.rs93 (DEVICE_ID.clone(), "device-id".into()), in into_inner()
94 (AUTO_GAIN_CONTROL.clone(), true.into()), in into_inner()
95 (CHANNEL_COUNT.clone(), 20.into()), in into_inner()
96 (LATENCY.clone(), 2.0.into()), in into_inner()
99 let subject = Subject::new(hash_map.clone()); in into_inner()
111 (DEVICE_ID.clone(), "device-id".into()), in into_iter()
112 (AUTO_GAIN_CONTROL.clone(), true.into()), in into_iter()
113 (CHANNEL_COUNT.clone(), 20.into()), in into_iter()
114 (LATENCY.clone(), 2.0.into()), in into_iter()
117 let subject = Subject::new(hash_map.clone()); in into_iter()
[all …]
/webrtc/constraints/src/capabilities/
H A Dtrack.rs91 (DEVICE_ID.clone(), "device-id".into()), in into_inner()
92 (AUTO_GAIN_CONTROL.clone(), true.into()), in into_inner()
93 (CHANNEL_COUNT.clone(), (12..=34).into()), in into_inner()
94 (LATENCY.clone(), (1.2..=3.4).into()), in into_inner()
97 let subject = Subject::new(hash_map.clone()); in into_inner()
109 (DEVICE_ID.clone(), "device-id".into()), in into_iter()
110 (AUTO_GAIN_CONTROL.clone(), true.into()), in into_iter()
111 (CHANNEL_COUNT.clone(), (12..=34).into()), in into_iter()
112 (LATENCY.clone(), (1.2..=3.4).into()), in into_iter()
115 let subject = Subject::new(hash_map.clone()); in into_iter()
[all …]
/webrtc/webrtc/src/peer_connection/
H A Dpeer_connection_internal.rs238 let pci = Arc::clone(self); in undeclared_media_processor()
374 Arc::clone(t), in start_rtp_receivers()
411 data_channels.clone() in start_sctp()
1044 Arc::clone(t), in handle_incoming_ssrc()
1271 id.clone(), in collect_inbound_stats()
1275 id: id.clone(), in collect_inbound_stats()
1298 id.clone(), in collect_inbound_stats()
1356 mid: mid.clone(), in collect_outbound_stats()
1411 id.clone(), in collect_outbound_stats()
1416 id: id.clone(), in collect_outbound_stats()
[all …]
/webrtc/util/src/vnet/conn_map/
H A Dconn_map_test.rs38 conn_map.insert(Arc::clone(&conn_in)).await?; in test_udp_conn_map_insert_remove()
142 Arc::clone(&obs), in test_udp_conn_map_insert_many_ips_with_same_port()
148 Arc::clone(&obs), in test_udp_conn_map_insert_many_ips_with_same_port()
189 Arc::clone(&obs), in test_udp_conn_map_already_inuse_when_insert_0()
194 Arc::clone(&obs), in test_udp_conn_map_already_inuse_when_insert_0()
214 Arc::clone(&obs), in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
219 Arc::clone(&obs), in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
239 Arc::clone(&obs), in test_udp_conn_map_already_inuse_when_insert_same_specified_ip()
244 Arc::clone(&obs), in test_udp_conn_map_already_inuse_when_insert_same_specified_ip()
308 Arc::clone(&obs), in test_udp_conn_map_insert_two_on_same_port_then_remove()
[all …]
/webrtc/webrtc/src/rtp_transceiver/
H A Drtp_transceiver_test.rs14 m.push_codecs(m.video_codecs.clone(), RTPCodecType::Video) in test_rtp_transceiver_set_codec_preferences()
16 m.push_codecs(m.audio_codecs.clone(), RTPCodecType::Audio) in test_rtp_transceiver_set_codec_preferences()
19 let media_video_codecs = m.video_codecs.clone(); in test_rtp_transceiver_set_codec_preferences()
26 Arc::clone(&transport), in test_rtp_transceiver_set_codec_preferences()
27 Arc::clone(&interceptor), in test_rtp_transceiver_set_codec_preferences()
31 api.new_rtp_sender(None, Arc::clone(&transport), Arc::clone(&interceptor)) in test_rtp_transceiver_set_codec_preferences()
40 media_video_codecs.clone(), in test_rtp_transceiver_set_codec_preferences()
41 Arc::clone(&api.media_engine), in test_rtp_transceiver_set_codec_preferences()
195 offer_pc.set_local_description(offer.clone()).await?; in test_rtp_transceiver_set_codec_preferences_payload_type()
263 let count = count.clone(); in test_rtp_transceiver_set_direction_causing_negotiation()
[all …]
/webrtc/constraints/src/
H A Dsupported_constraints.rs156 DEVICE_ID.clone(), in into_inner()
157 AUTO_GAIN_CONTROL.clone(), in into_inner()
158 CHANNEL_COUNT.clone(), in into_inner()
159 LATENCY.clone(), in into_inner()
162 let subject = Subject::new(hash_set.clone()); in into_inner()
174 DEVICE_ID.clone(), in into_iter()
175 AUTO_GAIN_CONTROL.clone(), in into_iter()
176 CHANNEL_COUNT.clone(), in into_iter()
177 LATENCY.clone(), in into_iter()
180 let subject = Subject::new(hash_set.clone()); in into_iter()
[all …]
/webrtc/ice/src/agent/
H A Dmod.rs153 config.candidate_types.clone() in new()
204 urls: config.urls.clone(), in new()
281 let ai = Arc::clone(&self.internal); in add_remote_candidate()
282 let host_candidate = Arc::clone(c); in add_remote_candidate()
295 let candidate = Arc::clone(c); in add_remote_candidate()
323 (ufrag_pwd.local_ufrag.clone(), ufrag_pwd.local_pwd.clone()) in get_local_user_credentials()
329 (ufrag_pwd.remote_ufrag.clone(), ufrag_pwd.remote_pwd.clone()) in get_remote_user_credentials()
450 urls: self.urls.clone(), in gather_candidates()
453 mdns_name: self.mdns_name.clone(), in gather_candidates()
454 net: Arc::clone(&self.net), in gather_candidates()
[all …]
H A Dagent_gather.rs119 urls: params.urls.clone(), in gather_candidates_internal()
152 let urls = params.urls.clone(); in gather_candidates_internal()
249 mdns_name.clone() in gather_candidates_local()
310 network: network.clone(), in gather_candidates_local()
388 let udp_mux = Arc::clone(&udp_mux); in gather_candidates_local_udp_mux()
426 ufrag_pwd.local_ufrag.clone() in gather_candidates_local_udp_mux()
470 let net2 = Arc::clone(&net); in gather_candidates_srflx_mapped()
528 network: network.clone(), in gather_candidates_srflx_mapped()
598 let url = url.clone(); in gather_candidates_srflx()
599 let net2 = Arc::clone(&net); in gather_candidates_srflx()
[all …]
/webrtc/webrtc/src/ice_transport/
H A Dice_gatherer.rs109 udp_network: self.setting_engine.udp_network.clone(), in create_agent()
111 urls: self.validated_servers.clone(), in create_agent()
124 net: self.setting_engine.vnet.clone(), in create_agent()
130 .clone(), in create_agent()
158 let state = Arc::clone(&self.state); in gather()
165 let state_clone = Arc::clone(&state); in gather()
169 Arc::clone(&on_gathering_complete_handler); in gather()
287 agent.clone() in get_agent()
301 stats.id.clone(), in collect_stats()
308 stats.id.clone(), in collect_stats()
[all …]
H A Dice_candidate.rs67 let candidate_id = self.stats_id.clone(); in to_ice()
74 address: self.address.clone(), in to_ice()
78 foundation: self.foundation.clone(), in to_ice()
91 address: self.address.clone(), in to_ice()
94 foundation: self.foundation.clone(), in to_ice()
98 rel_addr: self.related_address.clone(), in to_ice()
108 address: self.address.clone(), in to_ice()
111 foundation: self.foundation.clone(), in to_ice()
115 rel_addr: self.related_address.clone(), in to_ice()
125 address: self.address.clone(), in to_ice()
[all …]
/webrtc/turn/src/client/
H A Dmod.rs80 self.turn_serv_addr.clone() in turn_server_addr()
85 self.username.clone() in username()
90 self.realm.clone() in realm()
109 key: tr_key.clone(), in perform_transaction()
110 raw: msg.raw.clone(), in perform_transaction()
120 tm.insert(tr_key.clone(), tr); in perform_transaction()
211 self.stun_serv_addr.clone() in stun_server_addr()
514 self.username.text.clone(), in allocate()
515 self.realm.text.clone(), in allocate()
516 self.password.clone(), in allocate()
[all …]
/webrtc/turn/src/server/
H A Dmod.rs49 command_tx: Mutex::new(Some(command_tx.clone())), in new()
57 let nonces = Arc::clone(&s.nonces); in new()
58 let auth_handler = Arc::clone(&s.auth_handler); in new()
59 let realm = s.realm.clone(); in new()
65 alloc_close_notify: config.alloc_close_notify.clone(), in new()
86 command_tx.clone() in delete_allocations_by_username()
124 command_tx.clone() in get_allocations_info()
202 conn: Arc::clone(&conn), in read_loop()
206 nonces: Arc::clone(&nonces), in read_loop()
207 auth_handler: Arc::clone(&auth_handler), in read_loop()
[all …]
/webrtc/webrtc/src/data_channel/
H A Ddata_channel_test.rs171 let dc2 = Arc::clone(&dc); in test_data_channel_open()
206 let d2 = Arc::clone(&d); in test_data_channel_send_before_signaling()
222 let dc2 = Arc::clone(&dc); in test_data_channel_send_before_signaling()
224 let dc3 = Arc::clone(&dc2); in test_data_channel_send_before_signaling()
262 let d2 = Arc::clone(&d); in test_data_channel_send_after_connected()
286 let dc1 = Arc::clone(&dc); in test_data_channel_send_after_connected()
870 let dc2 = Arc::clone(&dc); in test_data_channel_buffered_amount_set_before_open()
961 let dc2 = Arc::clone(&dc); in test_data_channel_buffered_amount_set_after_open()
1027 let dc2 = Arc::clone(&dc); in test_eof_detach()
1163 let dca2 = Arc::clone(&dca); in test_eof_no_detach()
[all …]
/webrtc/dtls/src/conn/
H A Dconn_test.rs969 client_cas: ca_pool.clone(), in test_client_certificate()
985 client_cas: ca_pool.clone(), in test_client_certificate()
1016 client_cas: ca_pool.clone(), in test_client_certificate()
1352 roots_cas: ca_pool.clone(), in test_server_certificate()
1380 roots_cas: ca_pool.clone(), in test_server_certificate()
1396 roots_cas: ca_pool.clone(), in test_server_certificate()
1413 roots_cas: ca_pool.clone(), in test_server_certificate()
1428 roots_cas: ca_pool.clone(), in test_server_certificate()
1442 roots_cas: ca_pool.clone(), in test_server_certificate()
1875 let ca_tx = Arc::clone(&ca_rx); in test_server_timeout()
[all …]
/webrtc/webrtc/src/rtp_transceiver/rtp_sender/
H A Dmod.rs44 rtcp_interceptor.clone() in read()
237 Arc::clone(&self.transport) in transport()
285 track.clone() in track()
313 t.clone() in replace_track()
329 context.clone() in replace_track()
336 id: context.id.clone(), in replace_track()
342 paused: self.paused.clone(), in replace_track()
387 id: self.id.clone(), in send()
412 self.id.clone(), in send()
509 lock.clone() in initial_track_id()
[all …]
/webrtc/webrtc/src/sctp_transport/
H A Dmod.rs128 Arc::clone(&self.dtls_transport) in transport()
172 *sa = Some(Arc::clone(&sctp_association)); in start()
178 notify_rx: self.notify_tx.clone(), in start()
180 data_channels: Arc::clone(&self.data_channels), in start()
186 setting_engine: Arc::clone(&self.setting_engine), in start()
286 label: dc.config.label.clone(), in accept_data_channels()
287 protocol: dc.config.protocol.clone(), in accept_data_channels()
293 Arc::clone(&param.setting_engine), in accept_data_channels()
298 f(Arc::clone(&rtc_dc)).await; in accept_data_channels()
303 dcs.push(Arc::clone(&rtc_dc)); in accept_data_channels()
[all …]
/webrtc/webrtc/src/api/media_engine/
H A Dmod.rs177 rtcp_feedback: video_rtcp_feedback.clone(), in register_default_codecs()
431 video_codecs: self.video_codecs.clone(), in clone_to()
432 audio_codecs: self.audio_codecs.clone(), in clone_to()
653 negotiated_video_codecs.clone() in get_codecs_by_kind()
655 self.video_codecs.clone() in get_codecs_by_kind()
660 negotiated_audio_codecs.clone() in get_codecs_by_kind()
662 self.audio_codecs.clone() in get_codecs_by_kind()
687 uri: e.uri.clone(), in get_rtp_parameters_by_kind()
735 let id = VALID_EXT_IDS.clone().find(|id| { in get_rtp_parameters_by_kind()
753 uri: local_extension.uri.clone(), in get_rtp_parameters_by_kind()
[all …]
/webrtc/turn/src/client/relay_conn/
H A Drelay_conn_test.rs15 self.turn_server_addr.clone() in turn_server_addr()
19 self.username.clone() in username()
23 self.realm.clone() in realm()
71 let rc_obs = Arc::clone(&rci.obs); in test_relay_conn()
72 let nonce = rci.nonce.clone(); in test_relay_conn()
73 let integrity = rci.integrity.clone(); in test_relay_conn()
/webrtc/webrtc/src/peer_connection/sdp/
H A Dsdp_test.rs576 Arc::clone(&transport), in test_media_description_fingerprints()
577 Arc::clone(&interceptor), in test_media_description_fingerprints()
581 Arc::clone(&transport), in test_media_description_fingerprints()
586 api.new_rtp_sender(None, Arc::clone(&transport), Arc::clone(&interceptor)) in test_media_description_fingerprints()
591 api.new_rtp_sender(None, Arc::clone(&transport), Arc::clone(&interceptor)) in test_media_description_fingerprints()
687 api.new_rtp_sender(None, Arc::clone(&transport), Arc::clone(&interceptor)) in test_populate_sdp()
771 api.new_rtp_sender(None, Arc::clone(&transport), Arc::clone(&interceptor)) in test_populate_sdp()
873 Arc::clone(&transport), in test_populate_sdp_reject()
878 api.new_rtp_sender(None, Arc::clone(&transport), Arc::clone(&interceptor)) in test_populate_sdp_reject()
895 Arc::clone(&transport), in test_populate_sdp_reject()
[all …]
/webrtc/webrtc/src/api/
H A Dmod.rs67 Arc::clone(&self.setting_engine), in new_ice_gatherer()
102 Arc::clone(&self.setting_engine), in new_dtls_transport()
115 Arc::clone(&self.setting_engine), in new_sctp_transport()
132 let d = RTCDataChannel::new(params, Arc::clone(&self.setting_engine)); in new_data_channel()
149 Arc::clone(&self.media_engine), in new_rtp_receiver()
165 Arc::clone(&self.media_engine), in new_rtp_sender()
174 Arc::clone(&self.setting_engine) in setting_engine()
179 Arc::clone(&self.media_engine) in media_engine()
/webrtc/examples/examples/ortc/
H A Dortc.rs46 let matches = app.clone().get_matches(); in main()
90 let ice = Arc::new(api.new_ice_transport(Arc::clone(&gatherer))); in main()
93 let dtls = Arc::new(api.new_dtls_transport(Arc::clone(&ice), vec![])?); in main()
96 let sctp = Arc::new(api.new_sctp_transport(Arc::clone(&dtls))?); in main()
99 let done_answer = done.clone(); in main()
100 let done_offer = done.clone(); in main()
108 let done_answer1 = done_answer.clone(); in main()
112 let d2 = Arc::clone(&d); in main()
113 let done_answer2 = done_answer1.clone(); in main()
203 let d = Arc::new(api.new_data_channel(Arc::clone(&sctp), dc_params).await?); in main()
[all …]
/webrtc/examples/examples/data-channels-flow-control/
H A Ddata-channels-flow-control.rs74 let shared_dc = dc.clone(); in create_requester()
101 let more_can_be_sent = more_can_be_sent.clone(); in create_requester()
122 let shared_total_bytes_received = total_bytes_received.clone(); in create_responder()
151 let total_bytes_received = total_bytes_received.clone(); in create_responder()
172 let maybe_requester = maybe_requester.clone(); in main()
189 let maybe_responder = maybe_responder.clone(); in main()
206 let fault = fault.clone(); in main()
217 let fault = fault.clone(); in main()
228 requester.set_local_description(reqs.clone()).await?; in main()
233 responder.set_local_description(resp.clone()).await?; in main()
/webrtc/sctp/src/association/
H A Dmod.rs301 Arc::clone(&awake_write_loop_ch), in new()
306 let name = ai.name.clone(); in new()
307 let state = Arc::clone(&ai.state); in new()
322 let name1 = name.clone(); in new()
323 let name2 = name.clone(); in new()
328 let net_conn1 = Arc::clone(&net_conn); in new()
329 let net_conn2 = Arc::clone(&net_conn); in new()
514 let net_conn = Arc::clone(&net_conn); in write_loop()
516 let name2 = Arc::clone(&name); in write_loop()
517 let done2 = Arc::clone(&done); in write_loop()
[all …]
/webrtc/webrtc/src/mux/
H A Dmod.rs44 next_conn: Arc::clone(&config.conn), in new()
51 let next_conn = Arc::clone(&m.next_conn); in new()
52 let endpoints = Arc::clone(&m.endpoints); in new()
72 next_conn: Arc::clone(&self.next_conn), in new_endpoint()
73 endpoints: Arc::clone(&self.endpoints), in new_endpoint()
76 endpoints.insert(e.id, Arc::clone(&e)); in new_endpoint()
130 endpoint = Some(Arc::clone(ep)); in dispatch()
/webrtc/turn/src/allocation/
H A Dallocation_manager.rs64 alloc.username.text.clone(), in get_allocations_info()
78 allocations.get(five_tuple).map(Arc::clone) in get_allocation()
108 self.alloc_close_notify.clone(), in create_allocation()
110 a.allocations = Some(Arc::clone(&self.allocations)); in create_allocation()
119 allocations.insert(five_tuple, Arc::clone(&a)); in create_allocation()
148 to_delete.push(Arc::clone(allocation)); in delete_allocations_by_username()
167 let reservations = Arc::clone(&self.reservations); in create_reservation()
168 let reservation_token2 = reservation_token.clone(); in create_reservation()

12345678910>>...12