| /webrtc/media/src/audio/buffer/ |
| H A D | layout.rs | 5 fn index_of(info: &BufferInfo<Self>, channel: usize, frame: usize) -> usize; in index_of()
15 fn index_of(info: &BufferInfo<Self>, channel: usize, frame: usize) -> usize { in index_of()
16 (channel * info.frames()) + frame in index_of()
27 fn index_of(info: &BufferInfo<Self>, channel: usize, frame: usize) -> usize { in index_of()
28 (frame * info.channels()) + channel in index_of()
82 for channel in 0..channels { in interleaved_by()
83 let mut interleaved_index = channel; in interleaved_by()
|
| /webrtc/util/src/conn/ |
| H A D | conn_bridge_test.rs | 19 let (tx, mut rx) = mpsc::channel(1); in test_bridge_normal()
45 let (tx, mut rx) = mpsc::channel(1); in test_bridge_drop_1st_packet_from_conn0()
72 let (tx, mut rx) = mpsc::channel(1); in test_bridge_drop_2nd_packet_from_conn0()
99 let (tx, mut rx) = mpsc::channel(1); in test_bridge_drop_1st_packet_from_conn1()
126 let (tx, mut rx) = mpsc::channel(1); in test_bridge_drop_2nd_packet_from_conn1()
153 let (tx, mut rx) = mpsc::channel(1); in test_bridge_reorder_packets_from_conn0()
184 let (tx, mut rx) = mpsc::channel(1); in test_bridge_reorder_packets_from_conn1()
223 let (tx, mut rx) = mpsc::channel(5); in test_bridge_drop_next_n_packets()
|
| H A D | conn_pipe.rs | 13 let (cb1_tx, cb1_rx) = mpsc::channel(16); in pipe()
14 let (cb2_tx, cb2_rx) = mpsc::channel(16); in pipe()
|
| H A D | conn_udp_listener_test.rs | 116 let (ch_accepted_tx, mut ch_accepted_rx) = mpsc::channel::<()>(1); in test_listener_accept_filter()
194 let (done_tx, mut done_rx) = mpsc::channel::<()>(1); in test_listener_concurrent()
|
| /webrtc/examples/examples/data-channels-flow-control/ |
| H A D | README.md | 23 The rate you wish to send data might be much higher than the rate the data channel can
25 application to pace the amount of data to be pushed into the data channel.
44 connection, and data channel (label: "data").
46 Once the data channel is successfully opened, requester will start sending a series of
|
| H A D | data-channels-flow-control.rs | 71 let (more_can_be_sent, mut maybe_more_can_be_sent) = tokio::sync::mpsc::channel(1); in create_requester()
204 let (fault, mut reqs_fault) = tokio::sync::mpsc::channel(1); in main()
215 let (fault, mut resp_fault) = tokio::sync::mpsc::channel(1); in main()
|
| /webrtc/mdns/examples/ |
| H A D | mdns_server_query.rs | 31 let (a, b) = mpsc::channel(1); in main()
41 let (a, b) = mpsc::channel(1); in main()
|
| /webrtc/turn/src/server/ |
| H A D | mod.rs | 43 let (command_tx, _) = broadcast::channel(16); in new()
89 let (closed_tx, closed_rx) = mpsc::channel(1); in delete_allocations_by_username()
127 let (infos_tx, mut infos_rx) = mpsc::channel(1); in get_allocations_info()
154 let (mut close_tx, mut close_rx) = oneshot::channel::<()>(); in read_loop()
233 let (closed_tx, closed_rx) = mpsc::channel(1); in close()
|
| /webrtc/util/src/vnet/conn/ |
| H A D | conn_test.rs | 74 let (rcvd_ch_tx, mut rcvd_ch_rx) = mpsc::channel(1); in test_udp_conn_send_to_recv_from()
75 let (done_ch_tx, mut done_ch_rx) = mpsc::channel::<()>(1); in test_udp_conn_send_to_recv_from()
161 let (rcvd_ch_tx, mut rcvd_ch_rx) = mpsc::channel(1); in test_udp_conn_send_recv()
162 let (done_ch_tx, mut done_ch_rx) = mpsc::channel::<()>(1); in test_udp_conn_send_recv()
|
| /webrtc/interceptor/src/report/ |
| H A D | mod.rs | 39 let (close_tx, close_rx) = mpsc::channel(1); in build_rr()
58 let (close_tx, close_rx) = mpsc::channel(1); in build_sr()
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | data_channel_test.rs | 46 let (done_tx, done_rx) = mpsc::channel(1); in set_up_data_channel_parameters_test()
139 let (done_tx, done_rx) = mpsc::channel(1); in test_data_channel_open()
140 let (open_calls_tx, mut open_calls_rx) = mpsc::channel(2); in test_data_channel_open()
231 let (done_tx, done_rx) = mpsc::channel::<()>(1); in test_data_channel_send_before_signaling()
280 let (done_tx, done_rx) = mpsc::channel::<()>(1); in test_data_channel_send_after_connected()
834 let (done_tx, done_rx) = mpsc::channel::<()>(1); in test_data_channel_buffered_amount_set_before_open()
925 let (done_tx, done_rx) = mpsc::channel::<()>(1); in test_data_channel_buffered_amount_set_after_open()
1019 let (dc_chan_tx, mut dc_chan_rx) = mpsc::channel(1); in test_eof_detach()
1074 let (open_tx, mut open_rx) = mpsc::channel::<()>(1); in test_eof_detach()
1386 let (a_tx, mut a_rx) = mpsc::channel(1); in signal_ortc_pair()
[all …]
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_stream.rs | 39 let (rtcp_in_tx, rtcp_in_rx) = mpsc::channel(1000); in new()
40 let (rtp_in_tx, rtp_in_rx) = mpsc::channel(1000); in new()
41 let (rtcp_out_modified_tx, rtcp_out_modified_rx) = mpsc::channel(1000); in new()
42 let (rtp_out_modified_tx, rtp_out_modified_rx) = mpsc::channel(1000); in new()
43 let (rtcp_in_modified_tx, rtcp_in_modified_rx) = mpsc::channel(1000); in new()
44 let (rtp_in_modified_tx, rtp_in_modified_rx) = mpsc::channel(1000); in new()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_test.rs | 459 let (accepted_tx, mut accepted_rx) = mpsc::channel::<()>(1); in test_connectivity_on_startup()
460 let (accepting_tx, mut accepting_rx) = mpsc::channel::<()>(1); in test_connectivity_on_startup()
461 let (_a_cancel_tx, a_cancel_rx) = mpsc::channel(1); in test_connectivity_on_startup()
462 let (_b_cancel_tx, b_cancel_rx) = mpsc::channel(1); in test_connectivity_on_startup()
875 let (_cancel_tx1, cancel_rx1) = mpsc::channel(1); in test_invalid_agent_starts()
882 let (_cancel_tx2, cancel_rx2) = mpsc::channel(1); in test_invalid_agent_starts()
889 let (cancel_tx3, cancel_rx3) = mpsc::channel(1); in test_invalid_agent_starts()
901 let (_cancel_tx4, cancel_rx4) = mpsc::channel(1); in test_invalid_agent_starts()
1742 let (_cancel_tx, cancel_rx) = mpsc::channel(1); in test_connection_state_connecting_to_failed()
1751 let (_cancel_tx, cancel_rx) = mpsc::channel(1); in test_connection_state_connecting_to_failed()
[all …]
|
| /webrtc/ice/examples/ |
| H A D | ping_pong.rs | 30 let (tx, rx) = mpsc::channel::<String>(3);
35 let (tx, rx) = mpsc::channel::<String>(10);
147 let (done_tx, done_rx) = watch::channel(()); in main()
237 let (ice_done_tx, mut ice_done_rx) = mpsc::channel::<()>(1); in main()
309 let (_cancel_tx, cancel_rx) = mpsc::channel(1); in main()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | rtp_sender_test.rs | 55 let (seen_packet_a_tx, seen_packet_a_rx) = mpsc::channel::<()>(1); in test_rtp_sender_replace_track()
56 let (seen_packet_b_tx, seen_packet_b_rx) = mpsc::channel::<()>(1); in test_rtp_sender_replace_track()
225 let (seen_packet_tx, seen_packet_rx) = mpsc::channel::<()>(1); in test_rtp_sender_replace_track_invalid_track_kind_change()
307 let (seen_packet_tx, seen_packet_rx) = mpsc::channel::<()>(1); in test_rtp_sender_replace_track_invalid_codec_change()
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 522 let (done_tx, mut done_rx) = mpsc::channel::<()>(1); in test_net_virtual_resolver()
571 let (recv_ch_tx, mut recv_ch_rx) = mpsc::channel(1); in test_net_virtual_loopback2()
572 let (done_ch_tx, mut done_ch_rx) = mpsc::channel::<bool>(1); in test_net_virtual_loopback2()
573 let (close_ch_tx, mut close_ch_rx) = mpsc::channel::<bool>(1); in test_net_virtual_loopback2()
692 let (close_ch_tx, mut close_ch_rx1) = broadcast::channel::<bool>(1); in test_net_virtual_end2end()
693 let (done_ch_tx, mut done_ch_rx) = mpsc::channel::<bool>(1); in test_net_virtual_end2end()
694 let (conn1_recv_ch_tx, mut conn1_recv_ch_rx) = mpsc::channel(1); in test_net_virtual_end2end()
824 let (close_ch_tx, mut close_ch_rx1) = broadcast::channel::<bool>(1); in test_net_virtual_two_ips_on_a_nic()
825 let (done_ch_tx, mut done_ch_rx) = mpsc::channel::<bool>(1); in test_net_virtual_two_ips_on_a_nic()
826 let (conn1_recv_ch_tx, mut conn1_recv_ch_rx) = mpsc::channel(1); in test_net_virtual_two_ips_on_a_nic()
|
| /webrtc/sctp/src/association/association_internal/ |
| H A D | association_internal_test.rs | 51 let (close_loop_ch_tx, _close_loop_ch_rx) = broadcast::channel(1); in create_association_internal()
52 let (accept_ch_tx, _accept_ch_rx) = mpsc::channel(1); in create_association_internal()
53 let (handshake_completed_ch_tx, _handshake_completed_ch_rx) = mpsc::channel(1); in create_association_internal()
54 let (awake_write_loop_ch_tx, _awake_write_loop_ch_rx) = mpsc::channel(1); in create_association_internal()
324 let (accept_ch_tx, _accept_ch_rx) = mpsc::channel(ACCEPT_CH_SIZE); in test_assoc_create_new_stream()
|
| /webrtc/examples/examples/data-channels-detach-create/ |
| H A D | README.md | 3 data-channels-detach-create is an example that shows how you can detach a data channel.
|
| /webrtc/mdns/src/conn/ |
| H A D | conn_test.rs | 31 let (a, b) = mpsc::channel(1); in test_query_respect_timeout()
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 76 let (mut new_stream_tx, new_stream_rx) = mpsc::channel(8); in new()
77 let (close_stream_tx, mut close_stream_rx) = mpsc::channel(8); in new()
78 let (close_session_tx, mut close_session_rx) = mpsc::channel(8); in new()
|
| /webrtc/examples/examples/swap-tracks/ |
| H A D | swap-tracks.rs | 138 tokio::sync::mpsc::channel::<webrtc::rtp::packet::Packet>(60); in main()
206 let (connected_tx, mut connected_rx) = tokio::sync::mpsc::channel(1); in main()
207 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel(1); in main()
|
| /webrtc/turn/src/client/ |
| H A D | client_test.rs | 80 let (stared_tx, mut started_rx) = mpsc::channel::<()>(1); in test_client_with_stun_send_binding_request_to_parallel()
81 let (finished_tx, mut finished_rx) = mpsc::channel::<()>(1); in test_client_with_stun_send_binding_request_to_parallel()
|
| H A D | periodic_timer.rs | 55 let (close_tx, mut close_rx) = mpsc::channel(1); in start()
|
| /webrtc/sctp/src/timer/ |
| H A D | ack_timer.rs | 39 let (close_tx, mut close_rx) = mpsc::channel(1); in start()
|
| /webrtc/dtls/src/conn/ |
| H A D | conn_test.rs | 43 let (c_tx, mut c_rx) = mpsc::channel(1); in pipe_conn()
353 let (client_err_tx, mut client_err_rx) = mpsc::channel(1); in test_handshake_with_alert()
395 let (_decrypted_tx, decrypted_rx) = mpsc::channel(1); in test_export_keying_material()
396 let (_handshake_tx, handshake_rx) = mpsc::channel(1); in test_export_keying_material()
397 let (packet_tx, _packet_rx) = mpsc::channel(1); in test_export_keying_material()
398 let (handle_queue_tx, _handle_queue_rx) = mpsc::channel(1); in test_export_keying_material()
530 let (client_res_tx, mut client_res_rx) = mpsc::channel(1); in test_psk()
591 let (client_res_tx, mut client_res_rx) = mpsc::channel(1); in test_psk_hint_fail()
657 let (client_res_tx, mut client_res_rx) = mpsc::channel(1); in test_client_timeout()
772 let (client_res_tx, mut client_res_rx) = mpsc::channel(1); in test_srtp_configuration()
[all …]
|