| /webrtc/util/src/conn/ |
| H A D | conn_disconnected_packet.rs | 32 let (n, addr) = self.pconn.recv_from(buf).await?; in recv()
37 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() method
38 self.pconn.recv_from(buf).await in recv_from()
|
| H A D | conn_udp.rs | 15 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() method
16 Ok(self.recv_from(buf).await?) in recv_from()
|
| H A D | mod.rs | 30 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)>; in recv_from() method
|
| H A D | conn_pipe.rs | 46 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() method
|
| H A D | conn_udp_listener.rs | 155 result = pconn.recv_from(&mut buf) => { in read_loop()
267 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() method
|
| H A D | conn_bridge.rs | 39 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() method
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_conn.rs | 152 async fn recv_from(&self, buf: &mut [u8]) -> ConnResult<(usize, SocketAddr)> { in recv_from() method
274 async fn recv_from(&self, buf: &mut [u8]) -> ConnResult<(usize, SocketAddr)> { in recv_from() method
275 self.inner.recv_from(buf).await in recv_from()
|
| H A D | udp_mux_test.rs | 214 .recv_from(&mut buffer) in test_mux_connection()
|
| H A D | mod.rs | 172 res = conn.recv_from(&mut buffer) => { in start_conn_worker()
|
| /webrtc/turn/examples/ |
| H A D | turn_client_udp.rs | 143 let (n, from) = match pinger_conn_rx.recv_from(&mut buf).await { in do_ping_test()
165 let (n, from) = match relay_conn.recv_from(&mut buf).await { in do_ping_test()
|
| /webrtc/util/src/vnet/ |
| H A D | conn.rs | 70 let (n, _) = self.recv_from(buf).await?; in recv()
81 async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() method
|
| /webrtc/ice/src/util/ |
| H A D | mod.rs | 72 match tokio::time::timeout(deadline, conn.recv_from(&mut bs)).await { in stun_request()
80 conn.recv_from(&mut bs).await? in stun_request()
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 104 let (n, raddr) = conn.recv_from(&mut buf).await?; in test_net_native_loopback()
419 let (n, raddr) = conn.recv_from(&mut buf).await?; in test_net_virtual_loopback1()
580 result = conn_rx.recv_from(&mut buf) => { in test_net_virtual_loopback2()
705 result = conn1_rx.recv_from(&mut buf) =>{ in test_net_virtual_end2end()
733 result = conn2_tr.recv_from(&mut buf) =>{ in test_net_virtual_end2end()
837 result = conn1_rx.recv_from(&mut buf) =>{ in test_net_virtual_two_ips_on_a_nic()
865 result = conn2_tr.recv_from(&mut buf) =>{ in test_net_virtual_two_ips_on_a_nic()
|
| /webrtc/webrtc/src/mux/ |
| H A D | endpoint.rs | 48 async fn recv_from(&self, _buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() method
|
| H A D | mux_test.rs | 71 async fn recv_from(&self, _buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() method
|
| /webrtc/turn/src/server/ |
| H A D | server_test.rs | 296 result = echo_conn.recv_from(&mut buf) => { in test_server_vnet_echo_via_relay()
322 let (_, from) = conn.recv_from(&mut buf).await?; in test_server_vnet_echo_via_relay()
|
| H A D | mod.rs | 189 v = conn.recv_from(&mut buf) => { in read_loop()
|
| /webrtc/examples/examples/rtp-to-webrtc/ |
| H A D | rtp-to-webrtc.rs | 193 while let Ok((n, _)) = listener.recv_from(&mut inbound_rtp_packet).await { in main()
|
| /webrtc/util/src/vnet/conn/ |
| H A D | conn_test.rs | 81 let (n, addr) = match conn_rx.recv_from(&mut buf).await { in test_udp_conn_send_to_recv_from()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_transport.rs | 184 async fn recv_from( in recv_from() method
|
| /webrtc/mdns/src/conn/ |
| H A D | mod.rs | 265 result = socket.recv_from(&mut b) => { in start()
|
| /webrtc/turn/src/allocation/ |
| H A D | mod.rs | 354 result = relay_socket.recv_from(&mut buffer) => { in packet_handler()
|
| /webrtc/sctp/src/association/association_internal/ |
| H A D | association_internal_test.rs | 25 async fn recv_from(&self, _buf: &mut [u8]) -> Result<(usize, SocketAddr)> { in recv_from() method
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 59 let n = match client_listener.recv_from(&mut buffer).await { in test_packet_handler()
|
| /webrtc/turn/src/client/ |
| H A D | mod.rs | 228 let (n, from) = match conn.recv_from(&mut buf).await { in listen()
|