| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | async_buf_read.rs | 34 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_until() localVariable
50 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_until() localVariable
54 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_until() localVariable
78 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_line() localVariable
92 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_line() localVariable
96 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_line() localVariable
119 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_split() localVariable
131 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_split() localVariable
135 let mut tcp = tcp.unwrap(); in sdv_buf_reader_split() localVariable
158 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_lines() localVariable
[all …]
|
| D | async_buf_write.rs | 32 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write() localVariable
43 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write() localVariable
47 let tcp = tcp.unwrap(); in sdv_buf_writer_write() localVariable
71 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write_vectored() localVariable
82 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored() localVariable
86 let tcp = tcp.unwrap(); in sdv_buf_writer_write_vectored() localVariable
167 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write_vectored_2() localVariable
178 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored_2() localVariable
182 let tcp = tcp.unwrap(); in sdv_buf_writer_write_vectored_2() localVariable
|
| D | tcp_test.rs | 254 let tcp = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_multi_runtime() localVariable
258 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_multi_runtime() localVariable
262 let mut tcp = tcp.unwrap(); in sdv_tcp_multi_runtime() localVariable
345 let tcp = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_address_in_use() localVariable
419 let tcp = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_drop_out_context() localVariable
434 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_drop_out_context() localVariable
438 let mut tcp = tcp.unwrap(); in sdv_tcp_drop_out_context() localVariable
470 let tcp = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_cancel() localVariable
492 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_cancel() localVariable
497 let mut tcp = tcp.unwrap(); in sdv_tcp_cancel() localVariable
[all …]
|
| D | async_read.rs | 65 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_to_string() localVariable
76 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string() localVariable
80 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_to_string() localVariable
|
| D | join_set.rs | 110 let mut tcp = TcpStream::connect(addr).await; in sdv_join_set_spawn_io() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_tcp.rs | 26 let tcp = tokioTcpListener::bind(addr).await.unwrap(); localVariable
39 let mut tcp = tokioTcpStream::connect(addr.clone()).await; localVariable
43 let mut tcp = tcp.unwrap(); localVariable
78 let tcp = TcpListener::bind(addr).await.unwrap(); localVariable
91 let mut tcp = TcpStream::connect(addr).await; localVariable
95 let mut tcp = tcp.unwrap(); localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| D | ylong_runtime_tcp.rs | 25 let tcp = TcpListener::bind(addr).await.unwrap(); in ylong_tcp_server() localVariable
38 let mut tcp = TcpStream::connect(addr).await; in ylong_tcp_client() localVariable
42 let mut tcp = tcp.unwrap(); in ylong_tcp_client() localVariable
|
| D | ylong_runtime_tcp_fd_limit.rs | 22 let tcp = TcpListener::bind("127.0.0.1:0").await; in main() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| D | mod.rs | 14 mod tcp; module
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| D | tcp_test.rs | 73 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server() localVariable
147 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server_vectored() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 419 let mut tcp = tcp_stream; in https_connect() localVariable
630 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_error() localVariable
667 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_error() localVariable
707 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_error() localVariable
754 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_connect() localVariable
801 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_resp_beyond_size() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | current_thread.rs | 363 let tcp = TcpListener::bind(ADDR).await.unwrap(); localVariable
379 let mut tcp = TcpStream::connect(addr).await; localVariable
383 let mut tcp = tcp.unwrap(); localVariable
|