Home
last modified time | relevance | path

Searched refs:connect (Results 1 - 25 of 40) sorted by relevance

12

/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/
H A Dhappy_eyeballs.rs113 async fn connect(&mut self) -> Result<TcpStream, io::Error> {
116 match connect(addr, self.timeout).await {
176 pub(crate) async fn connect(mut self) -> io::Result<TcpStream> {
178 None => self.preferred_addr.connect().await,
180 let preferred_fut = self.preferred_addr.connect();
181 let second_fut = second_addrs.addrs.connect();
190 let preferred_fut = self.preferred_addr.connect();
193 let second_fut = second_addrs.addrs.connect();
197 let preferred_fut = self.preferred_addr.connect();
210 let preferred_fut = self.preferred_addr.connect();
234 fn connect( connect() functions
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dtcp_test.rs26 /// 2. `TcpStream` connect to listener and try to read buf.
35 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_ipv6_connect()
37 stream = TcpStream::connect(addr).await; in sdv_tcp_ipv6_connect()
77 /// 2. `TcpStream` connect to listener and try to read buf.
86 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_try()
88 stream = TcpStream::connect(addr).await; in sdv_tcp_stream_try()
110 /// 2. `TcpStream` connect to listener.
121 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_basic()
123 stream = TcpStream::connect(addr).await; in sdv_tcp_stream_basic()
158 /// 2. `TcpStream` connect t
[all...]
H A Dasync_buf_read.rs50 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_until()
52 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_until()
92 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_line()
94 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_line()
131 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_split()
133 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_split()
179 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_lines()
181 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_lines()
273 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read()
275 tcp = TcpStream::connect(add in sdv_buf_reader_read()
[all...]
H A Dudp_test.rs25 /// 1. Create UdpSocket and connect to the remote address.
38 .connect(receiver_addr) in sdv_udp_send_recv()
42 .connect(sender_addr) in sdv_udp_send_recv()
92 /// 1. Create sender and receiver threads, bind their new UdpSockets and connect
105 .connect(sender_addr) in sdv_udp_recv()
109 .connect(receiver_addr) in sdv_udp_recv()
193 /// 1. Create sender and receiver threads, bind their new UdpSockets and connect
208 .connect(sender_addr) in sdv_udp_try_recv()
212 .connect(receiver_addr) in sdv_udp_try_recv()
230 /// 1. Create sender and receiver threads, bind their new UdpSockets and connect
[all...]
H A Dasync_buf_write.rs43 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write()
45 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write()
82 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored()
84 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored()
178 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored_2()
180 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored_2()
H A Duds_cargo_test.rs50 /// 2. Create a client with `connect()`.
64 let mut stream = UnixStream::connect(PATH).await; in sdv_uds_listener_read_write_test()
66 stream = UnixStream::connect(PATH).await; in sdv_uds_listener_read_write_test()
127 if let Ok(mut stream) = UnixStream::connect(PATH).await { in sdv_uds_stream_test()
180 if socket.connect(PATH).is_ok() { in sdv_uds_datagram_test()
H A Dasync_read.rs76 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string()
78 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_udp.rs34 /// Benchmark test for ylong udp connect.
48 let _connected_sender = sender.connect(receiver_addr).await.unwrap(); in ylong_udp_connect()
54 /// Benchmark test for tokio udp connect.
68 sender.connect(receiver_addr).await.unwrap(); in tokio_udp_connect()
77 /// 1. Create sender and receiver, bind their new UdpSockets and connect to
102 let connected_sender = sender.connect(receiver_addr).await.unwrap(); in ylong_udp_send_recv()
103 let connected_receiver = receiver.connect(sender_addr).await.unwrap(); in ylong_udp_send_recv()
124 /// 1. Create sender and receiver, bind their new UdpSockets and connect to
143 sender.connect(receiver_addr).await.unwrap(); in tokio_udp_send_recv()
144 receiver.connect(sender_add in tokio_udp_send_recv()
[all...]
H A Dylong_tokio_tcp.rs39 let mut tcp = tokioTcpStream::connect(addr.clone()).await;
41 tcp = tokioTcpStream::connect(addr.clone()).await;
91 let mut tcp = TcpStream::connect(addr).await;
93 tcp = TcpStream::connect(addr).await;
H A Dylong_tokio_uds.rs40 let mut uds = tokioUnixStream::connect(addr.clone()).await;
42 uds = tokioUnixStream::connect(addr.clone()).await;
94 let mut uds = UnixStream::connect(addr.clone()).await;
96 uds = UnixStream::connect(addr.clone()).await;
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dsplit.rs128 /// 2. `TcpStream` connect to listener. in poll_flush()
139 let mut stream = TcpStream::connect(addr).await; in poll_flush()
141 stream = TcpStream::connect(addr).await; in poll_flush()
174 /// 2. `TcpStream` connect to listener. in poll_flush()
185 let mut stream = TcpStream::connect(addr).await; in poll_flush()
187 stream = TcpStream::connect(addr).await; in poll_flush()
221 /// 2. `TcpStream` connect to listener. in poll_flush()
232 let mut stream = TcpStream::connect(addr).await; in poll_flush()
234 stream = TcpStream::connect(addr).await; in poll_flush()
271 /// 2. `TcpStream` connect t in poll_flush()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Dudp_socket_test.rs21 /// 1. Create UdpSocket and connect to the remote address.
44 let connected_sender = match sender.connect(receiver_addr) { in sdv_send_recv()
50 let connected_receiver = match receiver.connect(sender_addr) { in sdv_send_recv()
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_tcp.rs38 let mut tcp = TcpStream::connect(addr).await;
40 tcp = TcpStream::connect(addr).await;
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/
H A Dsocket.rs91 /// System call to connect.
92 pub(crate) fn connect(self, addr: SocketAddr) -> io::Result<()> {
93 use crate::sys::winapi::connect;
97 connect(self.socket as _, socket_addr.as_ptr(), socket_addr_length),
H A Dstream.rs42 /// let stream = ylong_io::TcpStream::connect(addr).unwrap();
44 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect() functions
48 socket.connect(addr)?; in connect()
78 /// let stream = TcpStream::connect(addr).expect("Couldn't connect to the server...");
98 /// let stream = TcpStream::connect(addr).expect("Couldn't connect to the server...");
118 /// let stream = TcpStream::connect(addr).expect("Couldn't connect to the server...");
135 /// let stream = TcpStream::connect(add
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
H A Dudp.rs48 /// let connected_sender = match sender.connect(receiver_addr).await {
54 /// let connected_receiver = match receiver.connect(sender_addr).await {
94 /// connect them in sequence until one of the addrs returns success. If
137 /// connect them in sequence until one of the addrs returns success. If
155 /// let connected_sock = match sock.connect(remote_addr).await {
164 pub async fn connect<A: ToSocketAddrs>(self, addr: A) -> io::Result<ConnectedUdpSocket> {
174 match socket.connect(addr) {
781 /// let connected_sock = match sock.connect(remote_addr).await {
809 /// let connected_sock = match sock.connect(peer_addr).await {
838 /// let connected_sock = match socket.connect(peer_add
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
H A Dstream.rs31 /// Create a new TCP stream and issue a non-blocking connect to the
33 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect() functions
35 socket.connect(addr) in connect()
60 /// let stream = TcpStream::connect(addr).expect("Couldn't connect to the server...");
80 /// let stream = TcpStream::connect(addr).expect("Couldn't connect to the server...");
98 /// let stream = TcpStream::connect(addr).expect("Couldn't connect to the server...");
113 /// let stream = TcpStream::connect(add
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
H A Ddatagram.rs78 /// if let Ok(socket) = socket.connect("/socket/path") {
82 pub fn connect<P: AsRef<Path>>(&self, path: P) -> io::Result<()> { in connect() functions
83 self.inner.connect(path) in connect()
87 /// Returns two `UnixDatagrams`s, they connect to each other.
216 /// socket.connect("/some/sock").expect("connect fail");
H A Dstream.rs35 /// if let Ok(sock) = UnixStream::connect("/tmp/sock") {
39 pub fn connect<P: AsRef<Path>>(path: P) -> io::Result<UnixStream> { in connect() functions
40 super::socket::connect(path.as_ref()).map(UnixStream::from_std) in connect()
51 /// if let Ok(stream) = UnixStream::connect("/path/to/the/socket") {
84 /// let socket = UnixStream::connect("/tmp/sock")?;
100 /// let socket = UnixStream::connect("/tmp/sock")?;
116 /// let socket = UnixStream::connect("/tmp/sock")?;
132 /// let socket = UnixStream::connect("/tmp/sock")?;
152 /// let socket = UnixStream::connect("/tmp/sock")?;
H A Dsocket.rs40 pub(crate) fn connect(path: &Path) -> io::Result<net::UnixStream> {
46 match syscall!(connect(socket, sockaddr, addr_length)) {
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_runtime_async_benchmark.rs23 let mut client_stream = TcpStream::connect(addr).await;
25 client_stream = TcpStream::connect(addr).await
H A Dylong_runtime_tcp_client_perf.rs25 let mut stream = match TcpStream::connect(addr).await { in main()
29 println!("client connect Ok"); in main()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Dstream.rs50 /// let mut stream = UnixStream::connect("/tmp/sock").await?;
54 pub async fn connect<P: AsRef<Path>>(path: P) -> Result<UnixStream> {
55 let stream = UnixStream::new(ylong_io::UnixStream::connect(path)?)?;
83 /// let std_stream = StdUnixStream::connect("/socket/path")?;
130 /// let stream = UnixStream::connect("/socket/path").await?;
184 /// let stream = UnixStream::connect("/socket/path").await?;
220 /// let stream = UnixStream::connect("/socket/path").await?;
254 /// let stream = UnixStream::connect("/socket/path").await?;
289 /// let stream = UnixStream::connect("/socket/path").await?;
320 /// let socket = UnixStream::connect("/tm
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/examples/
H A Dylong_io_tcp_client.rs27 let mut stream = match TcpStream::connect(addr) { in main()
29 println!("TcpStream::connect err {err}"); in main()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/
H A Dc_ssl_stream.rs77 /// Like [`SslStream::connect`](ssl::SslStream::connect).
79 self.with_context(cx, |s| check_result_to_poll(s.connect())) in poll_connect()
83 pub(crate) async fn connect(mut self: Pin<&mut Self>) -> Result<(), ssl::SslError> { in poll_connect()

Completed in 9 milliseconds

12