| /webrtc/util/src/conn/ |
| H A D | conn_bridge_test.rs | 23 let n = conn1.recv(&mut buf).await?; in test_bridge_normal()
30 let n = rx.recv().await.unwrap(); in test_bridge_normal()
49 let n = conn1.recv(&mut buf).await?; in test_bridge_drop_1st_packet_from_conn0()
57 let n = rx.recv().await.unwrap(); in test_bridge_drop_1st_packet_from_conn0()
76 let n = conn1.recv(&mut buf).await?; in test_bridge_drop_2nd_packet_from_conn0()
84 let n = rx.recv().await.unwrap(); in test_bridge_drop_2nd_packet_from_conn0()
103 let n = conn0.recv(&mut buf).await?; in test_bridge_drop_1st_packet_from_conn1()
111 let n = rx.recv().await.unwrap(); in test_bridge_drop_1st_packet_from_conn1()
138 let n = rx.recv().await.unwrap(); in test_bridge_drop_2nd_packet_from_conn1()
162 let _ = rx.recv().await; in test_bridge_reorder_packets_from_conn0()
[all …]
|
| H A D | conn_pipe_test.rs | 12 let n = c2.recv(&mut b2).await?; in test_pipe()
21 let n = c1.recv(&mut b1).await?; in test_pipe()
23 let n = c1.recv(&mut b1).await?; in test_pipe()
|
| H A D | conn_udp.rs | 11 async fn recv(&self, buf: &mut [u8]) -> Result<usize> { in recv() method
12 Ok(self.recv(buf).await?) in recv()
|
| H A D | conn_pipe.rs | 35 async fn recv(&self, b: &mut [u8]) -> Result<usize> { in recv() method
37 let v = match rd_rx.recv().await { in recv()
47 let n = self.recv(buf).await?; in recv_from()
|
| H A D | conn_udp_listener_test.rs | 40 let n = l_conn.recv(&mut buf).await?; in pipe()
139 _= ch_accepted_rx.recv()=>{ in test_listener_accept_filter()
182 let n = conn.recv(&mut b).await?; in test_listener_concurrent()
216 let _ = done_rx.recv().await; in test_listener_concurrent()
|
| /webrtc/ice/src/mdns/ |
| H A D | mdns_test.rs | 40 let _ = a_connected.recv().await; in test_multicast_dns_only_connection()
41 let _ = b_connected.recv().await; in test_multicast_dns_only_connection()
74 let _ = a_connected.recv().await; in test_multicast_dns_mixed_connection()
75 let _ = b_connected.recv().await; in test_multicast_dns_mixed_connection()
125 let _ = done_rx.recv().await; in test_multicast_dns_static_host_name()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_transport.rs | 37 _ = on_connected_rx.recv() => {}, in dial()
38 _ = cancel_rx.recv() => { in dial()
72 _ = on_connected_rx.recv() => {}, in accept()
73 _ = cancel_rx.recv() => { in accept()
170 async fn recv(&self, buf: &mut [u8]) -> std::result::Result<usize, util::Error> { in recv() method
189 let n = self.recv(buf).await?; in recv_from()
|
| H A D | agent_transport_test.rs | 41 let _ = a_connected.recv().await; in pipe()
42 let _ = b_connected.recv().await; in pipe()
121 let nb = cb.recv(&mut buf).await?; in test_conn_stats()
|
| H A D | agent_test.rs | 481 let _ = accepting_rx.recv().await; in test_connectivity_on_startup()
486 let _ = accepted_rx.recv().await; in test_connectivity_on_startup()
490 let _ = a_connected.recv().await; in test_connectivity_on_startup()
491 let _ = b_connected.recv().await; in test_connectivity_on_startup()
565 let _ = a_connected.recv().await; in test_connectivity_lite()
566 let _ = b_connected.recv().await; in test_connectivity_lite()
1017 let _ = is_failed_rx.recv().await; in test_connection_state_callback()
1837 let _ = cancel_rx.recv().await; in test_agent_restart_one_side()
1906 let _ = a_connected.recv().await; in test_agent_restart_both_side()
1907 let _ = b_connected.recv().await; in test_agent_restart_both_side()
[all …]
|
| /webrtc/util/src/vnet/conn/ |
| H A D | conn_test.rs | 105 result = rcvd_ch_rx.recv() =>{ in test_udp_conn_send_to_recv_from()
111 _ = done_ch_rx.recv() => { in test_udp_conn_send_to_recv_from()
168 let n = match conn_rx.recv(&mut buf).await { in test_udp_conn_send_recv()
190 result = rcvd_ch_rx.recv() =>{ in test_udp_conn_send_recv()
196 _ = done_ch_rx.recv() => { in test_udp_conn_send_recv()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | rtp_transceiver_direction.rs | 91 pub fn from_send_recv(send: bool, recv: bool) -> RTCRtpTransceiverDirection { in from_send_recv()
92 match (send, recv) { in from_send_recv()
182 for (expected_value, (send, recv)) in tests { in test_rtp_transceiver_from_send_recv()
184 RTCRtpTransceiverDirection::from_send_recv(send, recv), in test_rtp_transceiver_from_send_recv()
|
| /webrtc/webrtc/src/mux/ |
| H A D | mux_test.rs | 56 async fn recv(&self, buf: &mut [u8]) -> Result<usize> { in recv() method
117 let n = e.recv(&mut buff).await?; in test_non_fatal_read()
120 let n = e.recv(&mut buff).await?; in test_non_fatal_read()
123 let n = e.recv(&mut buff).await?; in test_non_fatal_read()
|
| /webrtc/examples/examples/broadcast/ |
| H A D | broadcast.rs | 77 let line = sdp_chan_rx.recv().await.unwrap(); in main()
202 let _ = gather_complete.recv().await; in main()
213 if let Some(local_track) = local_track_chan_rx.recv().await { in main()
217 let line = sdp_chan_rx.recv().await.unwrap(); in main()
292 let _ = gather_complete.recv().await; in main()
|
| /webrtc/examples/examples/swap-tracks/ |
| H A D | swap-tracks.rs | 236 let _ = gather_complete.recv().await; in main()
252 while let Some(mut packet) = packets_rx.recv().await { in main()
274 _ = connected_rx.recv() =>{ in main()
297 _ = done_rx.recv() => { in main()
308 _ = done_rx.recv() => {} in main()
|
| /webrtc/sctp/examples/ |
| H A D | throughput.rs | 80 let mut recv = 0; in main() localVariable
85 recv += n; in main()
93 recv = 0; in main()
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_server_reflexive_test.rs | 81 let _ = a_connected.recv().await; in test_server_reflexive_only_connection()
82 let _ = b_connected.recv().await; in test_server_reflexive_only_connection()
|
| H A D | candidate_relay_test.rs | 106 let _ = a_connected.recv().await; in test_relay_only_connection()
107 let _ = b_connected.recv().await; in test_relay_only_connection()
|
| /webrtc/stun/src/agent/ |
| H A D | agent_test.rs | 17 while let Some(e) = handler_rx.recv().await { in test_agent_process_in_transaction()
42 while let Some(e) = handler_rx.recv().await { in test_agent_process()
149 evt = handler_rx.recv() => { in test_agent_stop()
|
| /webrtc/sctp/src/association/ |
| H A D | mod.rs | 220 if let Some(err_opt) = handshake_completed_ch_rx.recv().await { in server()
235 if let Some(err_opt) = handshake_completed_ch_rx.recv().await { in client()
269 let _ = close_loop_ch_rx.recv().await; in shutdown()
437 _ = close_loop_ch.recv() => break, in read_loop()
438 result = net_conn.recv(&mut buffer) => { in read_loop()
546 _ = awake_write_loop_ch.recv() =>{} in write_loop()
547 _ = close_loop_ch.recv() => { in write_loop()
587 accept_ch_rx.recv().await in accept_stream()
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 548 let _ = done_rx.recv().await; in test_net_virtual_resolver()
595 _ = close_ch_rx.recv() => { in test_net_virtual_loopback2()
611 let _ = recv_ch_rx.recv().await; in test_net_virtual_loopback2()
614 let _ = done_ch_rx.recv().await; in test_net_virtual_loopback2()
717 _ = close_ch_rx1.recv() => { in test_net_virtual_end2end()
748 _ = close_ch_rx2.recv() => { in test_net_virtual_end2end()
764 let _ = conn1_recv_ch_rx.recv().await; in test_net_virtual_end2end()
768 let _ = done_ch_rx.recv().await; in test_net_virtual_end2end()
849 _ = close_ch_rx1.recv() => { in test_net_virtual_two_ips_on_a_nic()
896 let _ = conn1_recv_ch_rx.recv().await; in test_net_virtual_two_ips_on_a_nic()
[all …]
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_stream.rs | 194 rtcp_out_modified_rx.recv().await in written_rtcp()
216 rtp_out_modified_rx.recv().await in written_rtp()
224 rtcp_in_modified_rx.recv().await in read_rtcp()
230 rtp_in_modified_rx.recv().await in read_rtp()
265 rtcp_in.recv().await.ok_or(Error::ErrIoEOF)? in read()
292 rtp_in.recv().await.ok_or(Error::ErrIoEOF)? in read()
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 97 let close_stream = close_stream_rx.recv(); in new()
98 let close_session = close_session_rx.recv(); in new()
138 let n = udp_rx.recv(buf).await?; in incoming()
218 let result = new_stream_rx.recv().await; in accept()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_test.rs | 128 let _ = offer_gathering_complete.recv().await; in signal_pair()
144 let _ = answer_gathering_complete.recv().await; in signal_pair()
182 _ = done_rx.recv() =>{ in close_pair()
219 _ = done_rx.recv() =>{ in send_video_until_done()
326 let _ = ice_complete_rx.recv().await; in test_get_stats()
|
| /webrtc/webrtc/src/peer_connection/operation/ |
| H A D | mod.rs | 116 _ = close_rx.recv() => { in start()
119 result = ops_rx.recv() => { in start()
|
| /webrtc/examples/examples/data-channels-close/ |
| H A D | data-channels-close.rs | 166 _ = done_rx.recv() => { in main()
215 let _ = gather_complete.recv().await; in main()
228 _ = done_rx.recv() => { in main()
|