Searched refs:dc (Results 1 – 4 of 4) sorted by relevance
| /webrtc/webrtc/src/data_channel/ |
| H A D | data_channel_test.rs | 48 let dc = offer_pc in set_up_data_channel_parameters_test() localVariable
275 let dc = offer_pc in test_data_channel_send_after_connected() localVariable
340 dc.close().await?; in test_data_channel_close()
375 dc.ordered(), in test_data_channel_parameters_max_packet_life_time_exchange()
475 dc.protocol(), in test_data_channel_parameters_protocol_exchange()
605 dc.do_open(); in test_data_channel_event_handlers()
626 dc.do_open(); in test_data_channel_event_handlers()
789 assert_eq!(dc.id.load(Ordering::SeqCst), dc.id(), "should match"); in test_data_channel_parameters_go()
790 assert_eq!(dc.label, dc.label(), "should match"); in test_data_channel_parameters_go()
791 assert_eq!(dc.protocol, dc.protocol(), "should match"); in test_data_channel_parameters_go()
[all …]
|
| H A D | mod.rs | 282 dc, in handle_open()
371 if let Some(dc) = &*data_channel { in send()
383 if let Some(dc) = &*data_channel { in send_text()
412 if let Some(dc) = &*data_channel { in detach()
415 Ok(Arc::clone(dc)) in detach()
432 if let Some(dc) = &*data_channel { in close()
433 Ok(dc.close().await?) in close()
503 if let Some(dc) = &*data_channel { in buffered_amount()
504 dc.buffered_amount() in buffered_amount()
518 if let Some(dc) = &*data_channel { in buffered_amount_low_threshold()
[all …]
|
| /webrtc/webrtc/src/sctp_transport/ |
| H A D | mod.rs | 218 for dc in dcs.iter() { in accept_data_channels()
219 if let Some(dc) = dc.data_channel.lock().await.clone() { in accept_data_channels()
220 existing_data_channels.push(dc); in accept_data_channels()
226 let dc = tokio::select! { in accept_data_channels() localVariable
234 Ok(dc) => dc, in accept_data_channels()
254 match dc.config.channel_type { in accept_data_channels()
280 Some(dc.stream_identifier()) in accept_data_channels()
286 label: dc.config.label.clone(), in accept_data_channels()
306 rtc_dc.handle_open(Arc::new(dc)).await; in accept_data_channels()
411 for dc in &*data_channels { in generate_and_set_data_channel_id()
[all …]
|
| /webrtc/examples/examples/data-channels-flow-control/ |
| H A D | data-channels-flow-control.rs | 68 let dc = pc.create_data_channel("data", options).await?; in create_requester() localVariable
74 let shared_dc = dc.clone(); in create_requester()
75 dc.on_open(Box::new(|| { in create_requester()
97 dc.set_buffered_amount_low_threshold(BUFFERED_AMOUNT_LOW_THRESHOLD) in create_requester()
100 dc.on_buffered_amount_low(Box::new(move || { in create_requester()
118 pc.on_data_channel(Box::new(move |dc| { in create_responder()
123 dc.on_open(Box::new(move || { in create_responder()
150 dc.on_message(Box::new(move |msg| { in create_responder()
|