Home
last modified time | relevance | path

Searched refs:data_channels (Results 1 – 8 of 8) sorted by relevance

/webrtc/webrtc/src/sctp_transport/
H A Dsctp_transport_test.rs7 let mut data_channels = vec![]; in test_generate_data_channel_id() localVariable
9 data_channels.push(Arc::new(RTCDataChannel { in test_generate_data_channel_id()
16 data_channels: Arc::new(Mutex::new(data_channels)), in test_generate_data_channel_id()
H A Dmod.rs53 data_channels: Arc<Mutex<Vec<Arc<RTCDataChannel>>>>, field
89 pub(crate) data_channels: Arc<Mutex<Vec<Arc<RTCDataChannel>>>>, field
115 data_channels: Arc::new(Mutex::new(vec![])), in new()
180 data_channels: Arc::clone(&self.data_channels), in start()
216 let dcs = param.data_channels.lock().await; in accept_data_channels()
302 let mut dcs = param.data_channels.lock().await; in accept_data_channels()
374 let data_channels = self.data_channels.lock().await; in collect_stats() localVariable
375 for data_channel in &*data_channels { in collect_stats()
410 let data_channels = self.data_channels.lock().await; in generate_and_set_data_channel_id() localVariable
411 for dc in &*data_channels { in generate_and_set_data_channel_id()
/webrtc/webrtc/src/api/
H A Dapi_test.rs16 api.setting_engine.detach.data_channels, in test_new_api()
/webrtc/webrtc/src/api/setting_engine/
H A Dsetting_engine_test.rs39 !s.detach.data_channels, in test_detach_data_channels()
46 s.detach.data_channels, in test_detach_data_channels()
H A Dmod.rs21 pub data_channels: bool, field
95 self.detach.data_channels = true; in detach_data_channels()
/webrtc/webrtc/src/peer_connection/
H A Dmod.rs441 let data_channels = params.sctp_transport.data_channels.lock().await; in check_negotiation_needed() localVariable
442 data_channels.len() in check_negotiation_needed()
1847 let mut data_channels = self.internal.sctp_transport.data_channels.lock().await; in create_data_channel() localVariable
1848 data_channels.push(Arc::clone(&d)); in create_data_channel()
1920 let mut data_channels = self.internal.sctp_transport.data_channels.lock().await; in close() localVariable
1921 for d in &*data_channels { in close()
1926 data_channels.clear(); in close()
H A Dpeer_connection_internal.rs409 let data_channels = { in start_sctp() localVariable
410 let data_channels = self.sctp_transport.data_channels.lock().await; in start_sctp() localVariable
411 data_channels.clone() in start_sctp()
415 for d in data_channels { in start_sctp()
/webrtc/webrtc/src/data_channel/
H A Dmod.rs223 let detach_data_channels = self.setting_engine.detach.data_channels; in do_open()
273 if !self.setting_engine.detach.data_channels { in handle_open()
407 if !self.setting_engine.detach.data_channels { in detach()