| /webrtc/webrtc/src/peer_connection/ |
| H A D | mod.rs | 252 internal, in new()
291 self.internal in on_signaling_state_change()
307 self.internal in on_data_channel()
315 self.internal in on_negotiation_needed()
576 self.internal in on_track()
602 self.internal in on_ice_connection_state_change()
624 self.internal in on_peer_connection_state_change()
923 .internal in create_answer()
933 .internal in create_answer()
1626 self.internal in add_ice_candidate()
[all …]
|
| /webrtc/webrtc/src/track/track_local/ |
| H A D | track_local_static_sample.rs | 23 internal: Mutex<TrackLocalStaticSampleInternal>, field
33 internal: Mutex::new(TrackLocalStaticSampleInternal { in new()
65 let mut internal = self.internal.lock().await; in write_sample_with_extensions() localVariable
67 if internal.packetizer.is_none() || internal.sequencer.is_none() { in write_sample_with_extensions()
101 if !internal.did_warn_about_wonky_pause { in write_sample_with_extensions()
102 internal.did_warn_about_wonky_pause = true; in write_sample_with_extensions()
108 if let Some(sequencer) = &internal.sequencer { in write_sample_with_extensions()
114 let clock_rate = internal.clock_rate; in write_sample_with_extensions()
187 let mut internal = self.internal.lock().await; in bind() localVariable
190 if internal.packetizer.is_some() { in bind()
[all …]
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | mod.rs | 23 pub(crate) internal: Arc<ReceiverReportInternal>, field
35 let now = if let Some(f) = &self.internal.now { in read()
47 let m = self.internal.streams.lock().await; in read()
62 pub(crate) internal: Arc<ReceiverReportInternal>, field
84 internal: Arc<ReceiverReportInternal>, in run()
88 let mut close_rx = internal.close_rx.lock().await; in run()
101 let now = if let Some(f) = &internal.now { in run()
107 let m = internal.streams.lock().await; in run()
136 internal: Arc::clone(&self.internal), in bind_rtcp_reader()
156 let internal = Arc::clone(&self.internal); in bind_rtcp_writer() localVariable
[all …]
|
| H A D | receiver_stream.rs | 152 internal: Mutex<ReceiverStreamInternal>, field
167 internal: Mutex::new(ReceiverStreamInternal { in new()
188 let mut internal = self.internal.lock(); in process_rtp() localVariable
189 internal.process_rtp(now, pkt); in process_rtp()
197 let mut internal = self.internal.lock(); in process_sender_report() localVariable
198 internal.process_sender_report(now, sr); in process_sender_report()
202 let mut internal = self.internal.lock(); in generate_report() localVariable
203 internal.generate_report(now) in generate_report()
|
| /webrtc/ice/src/agent/ |
| H A D | mod.rs | 96 pub(crate) internal: Arc<AgentInternal>, field
194 internal: Arc::new(ai), in new()
231 self.internal.agent_conn.bytes_sent() in get_bytes_sent()
236 self.internal in on_connection_state_change()
243 self.internal in on_selected_candidate_pair_change()
251 self.internal in on_candidate()
281 let ai = Arc::clone(&self.internal); in add_remote_candidate()
344 self.internal.close().await in close()
358 self.internal in set_remote_credentials()
418 self.internal.start().await; in restart()
[all …]
|
| H A D | agent_test.rs | 37 .internal in test_pair_search()
130 a.internal in test_pair_priority()
141 .internal in test_pair_priority()
233 a.internal.set_selected_pair(Some(p)).await; in test_on_selected_candidate_pair_change()
262 let ufrag_pwd = a.internal.ufrag_pwd.lock().await; in test_handle_peer_reflexive_udp_pflx_candidate()
671 a.internal in test_inbound_validity()
691 a.internal in test_inbound_validity()
720 a.internal in test_inbound_validity()
749 a.internal in test_inbound_validity()
779 a.internal in test_inbound_validity()
[all …]
|
| H A D | agent_transport.rs | 23 self.internal in dial()
27 let mut on_connected_rx = self.internal.on_connected_rx.lock().await; in dial()
30 Arc::clone(&self.internal.agent_conn), in dial()
58 self.internal in accept()
62 let mut on_connected_rx = self.internal.on_connected_rx.lock().await; in accept()
65 Arc::clone(&self.internal.agent_conn), in accept()
|
| H A D | agent_vnet_test.rs | 969 .internal in test_write_use_valid_pair()
972 Arc::clone(&controlling_agent_tx.internal.agent_conn) as Arc<dyn Conn + Send + Sync> in test_write_use_valid_pair()
990 .internal in test_write_use_valid_pair()
993 Arc::clone(&controlled_agent.internal.agent_conn) as Arc<dyn Conn + Send + Sync> in test_write_use_valid_pair()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | mod.rs | 24 pub(crate) internal: Arc<SenderReportInternal>, field
46 internal: Arc<SenderReportInternal>, in run()
48 let mut ticker = tokio::time::interval(internal.interval); in run()
50 let mut close_rx = internal.close_rx.lock().await; in run()
62 let now = if let Some(f) = &internal.now { in run()
68 let m = internal.streams.lock().await; in run()
114 let internal = Arc::clone(&self.internal); in bind_rtcp_writer() localVariable
117 if let Err(err) = SenderReport::run(writer2, internal).await { in bind_rtcp_writer()
136 self.internal.now.clone(), in bind_local_stream()
139 let mut streams = self.internal.streams.lock().await; in bind_local_stream()
[all …]
|
| H A D | sender_stream.rs | 52 internal: Mutex<SenderStreamInternal>, field
66 internal: Mutex::new(SenderStreamInternal { in new()
77 let mut internal = self.internal.lock().await; in process_rtp() localVariable
78 internal.process_rtp(now, pkt); in process_rtp()
85 let mut internal = self.internal.lock().await; in generate_report() localVariable
86 internal.generate_report(now) in generate_report()
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | mod.rs | 73 internal: Mutex<ICETransportInternal>, field
153 let mut internal = self.internal.lock().await; in start() localVariable
154 internal.role = role; in start()
188 let mut internal = self.internal.lock().await; in start() localVariable
189 internal.conn = Some(conn); in start()
225 let mut internal = self.internal.lock().await; in stop() localVariable
226 internal.cancel_tx.take(); in stop()
260 let internal = self.internal.lock().await; in role() localVariable
261 internal.role in role()
308 let internal = self.internal.lock().await; in new_endpoint() localVariable
[all …]
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 36 internal: Arc::new(ReceiverInternal { in build()
73 internal: Arc<ReceiverInternal>, field
96 internal: Arc<ReceiverInternal>, in run()
99 let mut close_rx = internal.close_rx.lock().await; in run()
107 let mut packet_chan_rx = internal.packet_chan_rx.lock().await; in run()
116 let mut ticker = tokio::time::interval(internal.interval); in run()
171 let mut recorder = self.internal.recorder.lock().await; in bind_rtcp_writer()
180 let internal = Arc::clone(&self.internal); in bind_rtcp_writer() localVariable
183 if let Err(err) = Receiver::run(writer2, internal).await { in bind_rtcp_writer()
232 let mut streams = self.internal.streams.lock().await; in bind_remote_stream()
[all …]
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | mod.rs | 58 internal: Arc::new(GeneratorInternal { in build()
96 internal: Arc<GeneratorInternal>, field
115 internal: Arc<GeneratorInternal>, in run()
117 let mut ticker = tokio::time::interval(internal.interval); in run()
119 let mut close_rx = internal.close_rx.lock().await; in run()
133 let streams = internal.streams.lock().await; in run()
190 let internal = Arc::clone(&self.internal); in bind_rtcp_writer() localVariable
193 if let Err(err) = Generator::run(writer2, internal).await { in bind_rtcp_writer()
226 self.internal.log2_size_minus_6, in bind_remote_stream()
230 let mut streams = self.internal.streams.lock().await; in bind_remote_stream()
[all …]
|
| H A D | generator_stream.rs | 129 internal: Mutex<GeneratorStreamInternal>, field
136 internal: Mutex::new(GeneratorStreamInternal::new(log2_size_minus_6)), in new()
141 let internal = self.internal.lock(); in missing_seq_numbers() localVariable
142 internal.missing_seq_numbers(skip_last_n) in missing_seq_numbers()
146 let mut internal = self.internal.lock(); in add() localVariable
147 internal.add(seq); in add()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 393 pub internal: Arc<RTPReceiverInternal>, field
455 self.internal.get_parameters().await in get_parameters()
509 self.internal.start()?; in receive()
617 self.internal.read(b).await in read()
638 self.internal in read_simulcast_rtcp()
686 self.internal.close()?; in stop()
718 self.internal in stop()
725 self.internal in stop()
806 self.internal.current_state() in current_state()
810 self.internal.pause()?; in pause()
[all …]
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | responder_stream.rs | 65 internal: Mutex<ResponderStreamInternal>, field
72 internal: Mutex::new(ResponderStreamInternal::new(log2_size)), in new()
78 let mut internal = self.internal.lock().await; in add() localVariable
79 internal.add(pkt); in add()
83 let internal = self.internal.lock().await; in get() localVariable
84 internal.get(seq).cloned() in get()
|
| H A D | mod.rs | 40 internal: Arc::new(ResponderInternal { in build()
100 internal: Arc<ResponderInternal>, field
113 let streams = Arc::clone(&self.internal.streams); in read()
126 internal: Arc<ResponderInternal>, field
145 internal: Arc::clone(&self.internal), in bind_rtcp_reader()
170 let stream = Arc::new(ResponderStream::new(self.internal.log2_size, writer)); in bind_local_stream()
172 let mut streams = self.internal.streams.lock().await; in bind_local_stream()
181 let mut streams = self.internal.streams.lock().await; in unbind_local_stream()
|
| /webrtc/webrtc/src/api/setting_engine/ |
| H A D | setting_engine_test.rs | 178 .internal in test_setting_engine_set_disable_media_engine_copy()
184 offerer.internal.media_engine.negotiated_video_codecs.lock(); in test_setting_engine_set_disable_media_engine_copy()
194 .internal in test_setting_engine_set_disable_media_engine_copy()
200 offerer.internal.media_engine.negotiated_video_codecs.lock(); in test_setting_engine_set_disable_media_engine_copy()
206 .internal in test_setting_engine_set_disable_media_engine_copy()
212 .internal in test_setting_engine_set_disable_media_engine_copy()
256 .internal in test_setting_engine_set_disable_media_engine_copy()
262 offerer.internal.media_engine.negotiated_video_codecs.lock(); in test_setting_engine_set_disable_media_engine_copy()
|
| /webrtc/webrtc/src/track/track_remote/ |
| H A D | mod.rs | 61 internal: Mutex<TrackRemoteInternal>, field
105 internal: Default::default(), in new()
222 let mut internal = self.internal.lock().await; in read() localVariable
223 if let Some((data, attributes)) = internal.peeked.pop_front() { in read()
300 let mut internal = self.internal.lock().await; in peek() localVariable
301 internal.peeked.push_back((data.freeze(), a.clone())); in peek()
312 let mut internal = self.internal.lock().await; in prepopulate_peeked_data() localVariable
313 internal.peeked = data; in prepopulate_peeked_data()
|
| /webrtc/interceptor/src/report/ |
| H A D | mod.rs | 41 internal: Arc::new(ReceiverReportInternal { in build_rr()
60 internal: Arc::new(SenderReportInternal { in build_sr()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 120 internal: Arc<RTPSenderInternal>, field
150 let internal = Arc::new(RTPSenderInternal { in new() localVariable
161 rtp_sender: Arc::downgrade(&internal), in new()
171 let mut internal_rtcp_interceptor = internal.rtcp_interceptor.lock().await; in new()
210 internal, in new()
473 self.internal.read(b).await in read()
480 self.internal.read_rtcp(self.receive_mtu).await in read_rtcp()
|
| /webrtc/webrtc/src/stats/ |
| H A D | mod.rs | 381 if let Some(internal) = &*lock { in from()
382 bytes_received = internal.bytes_received(); in from()
383 bytes_sent = internal.bytes_sent(); in from()
384 messages_received = internal.messages_received(); in from()
385 messages_sent = internal.messages_sent(); in from()
|
| /webrtc/dtls/examples/hub/src/ |
| H A D | utilities.rs | 5 use rustls::internal::pemfile::certs;
|
| /webrtc/sctp/ |
| H A D | CHANGELOG.md | 11 * The lock for the internal association was contended badly because marshaling was done while still…
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | rtp_transceiver_test.rs | 305 offer_pc.internal.ops.done().await; in test_rtp_transceiver_set_direction_causing_negotiation()
|