Home
last modified time | relevance | path

Searched refs:send_to (Results 1 – 25 of 32) sorted by relevance

12

/webrtc/util/src/conn/
H A Dconn_disconnected_packet.rs43 self.pconn.send_to(buf, addr).await in send()
46 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize> { in send_to() method
47 self.pconn.send_to(buf, target).await in send_to()
H A Dconn_udp.rs23 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize> { in send_to() method
24 Ok(self.send_to(buf, target).await?) in send_to()
H A Dconn_udp_listener.rs273 self.pconn.send_to(buf, self.raddr).await in send()
276 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize> { in send_to() method
277 self.pconn.send_to(buf, target).await in send_to()
H A Dmod.rs32 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize>; in send_to() method
H A Dconn_pipe.rs60 async fn send_to(&self, _buf: &[u8], _target: SocketAddr) -> Result<usize> { in send_to() method
H A Dconn_bridge.rs52 async fn send_to(&self, _buf: &[u8], _target: SocketAddr) -> Result<usize> { in send_to() method
/webrtc/ice/src/udp_mux/
H A Dudp_mux_conn.rs20 async fn send_to(&self, buf: &[u8], target: &SocketAddr) -> Result<usize, Error>; in send_to() method
194 async fn send_to(&self, buf: &[u8], target: &SocketAddr) -> ConnResult<usize> { in send_to() method
196 mux.send_to(buf, target).await in send_to()
282 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> ConnResult<usize> { in send_to() method
289 self.inner.send_to(buf, &normalized_target).await in send_to()
H A Dudp_mux_test.rs195 conn.send_to(&stun_msg, remote_connection_addr).await?; in test_mux_connection()
221 conn.send_to(&buffer[..n], remote_connection_addr) in test_mux_connection()
H A Dmod.rs331 async fn send_to(&self, buf: &[u8], target: &SocketAddr) -> Result<usize, Error> { in send_to() method
334 .send_to(buf, *target) in send_to()
/webrtc/turn/examples/
H A Dturn_client_udp.rs134 relay_conn.send_to("Hello".as_bytes(), mapped_addr).await?; in do_ping_test()
173 if relay_conn.send_to(&buf[..n], from).await.is_err() { in do_ping_test()
189 pinger_conn_tx.send_to(msg.as_bytes(), relay_addr).await?; in do_ping_test()
/webrtc/turn/src/allocation/allocation_manager/
H A Dallocation_manager_test.rs108 .send_to(target_text.as_bytes(), relay_addr_with_host) in test_packet_handler()
133 .send_to(target_text2.as_bytes(), relay_addr_with_host) in test_packet_handler()
474 user1.send_to(b"1", addr1).await?; in test_get_allocations_info()
475 user2.send_to(b"12", addr2).await?; in test_get_allocations_info()
476 user3.send_to(b"123", addr3).await?; in test_get_allocations_info()
524 conn.send_to(b"Hello", addr).await?; in test_get_allocations_info_bytes_count()
543 conn.send_to(b"Hello", addr).await?; in test_get_allocations_info_bytes_count()
594 conn.send_to(b"Hello", addr).await?; in test_alloc_close_notify()
/webrtc/util/src/vnet/
H A Dconn.rs105 self.send_to(buf, rem_addr).await in send()
113 async fn send_to(&self, buf: &[u8], target: SocketAddr) -> Result<usize> { in send_to() method
/webrtc/webrtc/src/mux/
H A Dendpoint.rs57 async fn send_to(&self, _buf: &[u8], _target: SocketAddr) -> Result<usize> { in send_to() method
H A Dmux_test.rs79 async fn send_to(&self, _buf: &[u8], _target: SocketAddr) -> Result<usize> { in send_to() method
/webrtc/util/src/vnet/net/
H A Dnet_test.rs100 let n = conn.send_to(msg.as_bytes(), laddr).await?; in test_net_native_loopback()
415 let n = conn.send_to(msg.as_bytes(), laddr).await?; in test_net_virtual_loopback1()
745 let n = conn2_tr.send_to(b"Good-bye!", addr).await?; in test_net_virtual_end2end()
761 let n = conn1.send_to(b"Hello!", conn2.local_addr()?).await?; in test_net_virtual_end2end()
877 let n = conn2_tr.send_to(b"Good-bye!", addr).await?; in test_net_virtual_two_ips_on_a_nic()
893 let n = conn1.send_to(b"Hello!", conn2.local_addr()?).await?; in test_net_virtual_two_ips_on_a_nic()
/webrtc/turn/src/server/
H A Dserver_test.rs312 let _ = echo_conn.send_to(&buf[..n], from).await; in test_server_vnet_echo_via_relay()
320 conn.send_to(b"Hello", echo_addr).await?; in test_server_vnet_echo_via_relay()
H A Drequest.rs688 let l = a.relay_socket.send_to(&data_attr.0, msg_dst).await?; in handle_send_indication()
787 let l = a.relay_socket.send_to(&c.data, peer).await?; in handle_channel_data()
842 let _ = conn.send_to(&msg.raw, dst).await?; in build_and_send()
/webrtc/mdns/src/conn/
H A Dmod.rs238 if let Err(err) = self.socket.send_to(&raw_query, self.dst_addr).await { in send_question()
420 socket.send_to(&raw_answer, dst_addr).await?; in send_answer()
/webrtc/turn/src/allocation/
H A Dmod.rs400 .send_to(&channel_data.raw, five_tuple.src_addr) in packet_handler()
448 turn_socket.send_to(&msg.raw, five_tuple.src_addr).await in packet_handler()
/webrtc/turn/src/client/
H A Dclient_test.rs182 .send_to(&[0x00], SocketAddr::from_str("127.0.0.1:8080")?) in test_client_nonce_expiration()
H A Drelay_conn.rs161 async fn send_to(&self, p: &[u8], addr: SocketAddr) -> Result<usize, util::Error> { in send_to() method
163 match relay_conn.send_to(p, addr).await { in send_to()
212 async fn send_to(&mut self, p: &[u8], addr: SocketAddr) -> Result<usize, Error> { in send_to() method
H A Dtransaction.rs61 if conn.send_to(&tr_raw, dst).await.is_err() { in on_rtx_timeout()
/webrtc/ice/src/util/
H A Dmod.rs69 conn.send_to(&request.raw, server_addr).await?; in stun_request()
/webrtc/util/src/vnet/conn/
H A Dconn_test.rs100 let n = conn.send_to(&data, dst_addr).await.unwrap(); in test_udp_conn_send_to_recv_from()
/webrtc/ice/src/agent/
H A Dagent_transport.rs222 async fn send_to( in send_to() method

12