Home
last modified time | relevance | path

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

/external/rust/crates/tokio/src/net/unix/datagram/
Dsocket.rs611 .try_io(Interest::WRITABLE, || self.io.send_to(buf, target)) in try_send_to()
854 pub async fn send_to<P>(&self, buf: &[u8], target: P) -> io::Result<usize> in send_to() method
860 .async_io(Interest::WRITABLE, || self.io.send_to(buf, target.as_ref())) in send_to()
974 .poll_write_io(cx, || self.io.send_to(buf, target.as_ref())) in poll_send_to()
/external/rust/crates/mio/src/net/uds/
Ddatagram.rs84 pub fn send_to<P: AsRef<Path>>(&self, buf: &[u8], path: P) -> io::Result<usize> { in send_to() method
85 self.inner.do_io(|inner| inner.send_to(buf, path)) in send_to()
/external/rust/crates/tokio/src/net/
Dudp.rs901 pub async fn send_to<A: ToSocketAddrs>(&self, buf: &[u8], target: A) -> io::Result<usize> { in send_to() method
938 .poll_write_io(cx, || self.io.send_to(buf, target)) in poll_send_to()
991 .try_io(Interest::WRITABLE, || self.io.send_to(buf, target)) in try_send_to()
997 .async_io(Interest::WRITABLE, || self.io.send_to(buf, target)) in send_to_addr()
/external/rust/crates/tokio/tests/
Dudp.rs53 sender.send_to(MSG, &receiver_addr).await?; in send_to_recv_from()
144 s.send_to(MSG, &addr).await.unwrap(); in split()
163 s.send_to(&bytes, &addr).await.unwrap(); in split_chan()
177 sender.send_to(MSG, addr).await?; in split_chan()
Duds_datagram.rs18 socket.send_to(&recv_buf[..len], path).await?; in echo_server()
129 s.send_to(msg, path).await?; in split()
Dasync_send_sync.rs215 async_assert_fn!(tokio::net::UdpSocket::send_to(_, &[u8], SocketAddr): Send & Sync);
225 async_assert_fn!(tokio::net::UnixDatagram::send_to(_, &[u8], &str): Send & Sync);
Drt_common.rs833 send_half.send_to(&buf, &addr).await.unwrap();
/external/rust/crates/mio/examples/
Dudp_server.rs53 socket.send_to(&buf[..packet_size], source_address)?; in main()
/external/rust/crates/quiche/examples/
Dserver.rs192 if let Err(e) = socket.send_to(out, &src) { in main()
227 if let Err(e) = socket.send_to(out, &src) { in main()
347 if let Err(e) = socket.send_to(&out[..write], &peer) { in main()
Dhttp3-server.rs200 if let Err(e) = socket.send_to(out, &src) { in main()
235 if let Err(e) = socket.send_to(out, &src) { in main()
404 if let Err(e) = socket.send_to(&out[..write], &peer) { in main()
/external/rust/crates/mio/src/net/
Dudp.rs188 pub fn send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in send_to() method
189 self.inner.do_io(|inner| inner.send_to(buf, target)) in send_to()
/external/parameter-framework/asio-1.10.6/include/asio/detail/
Dreactive_socket_service.hpp196 size_t send_to(implementation_type& impl, const ConstBufferSequence& buffers, in send_to() function in asio::detail::reactive_socket_service
209 size_t send_to(implementation_type& impl, const null_buffers&, in send_to() function in asio::detail::reactive_socket_service
/external/tensorflow/tensorflow/core/common_runtime/
Dhierarchical_tree_broadcaster_test.cc71 std::vector<int> send_to; \
72 HierarchicalTreeBroadcaster::TreeSendTo(*cp, 0, &send_to); \
73 ASSERT_EQ(expected.size(), send_to.size()); \
75 EXPECT_EQ(expected[i], send_to[i]); \
/external/rust/crates/mio/
DCHANGELOG.md450 * The `UdpSocket::{send_to, recv_from}` methods are no longer generic over `Buf`