| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | async_buf_read.rs | 32 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_read_until() localVariable
76 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_read_line() localVariable
117 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_split() localVariable
156 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_lines() localVariable
259 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_read() localVariable
|
| D | async_buf_write.rs | 30 let server = ylong_runtime::spawn(async move { in sdv_buf_writer_write() localVariable
69 let server = ylong_runtime::spawn(async move { in sdv_buf_writer_write_vectored() localVariable
165 let server = ylong_runtime::spawn(async move { in sdv_buf_writer_write_vectored_2() localVariable
|
| D | uds_cargo_test.rs | 110 async fn server() { in sdv_uds_stream_test() function
166 async fn server() { in sdv_uds_datagram_test() function
|
| D | async_read.rs | 63 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_read_to_string() localVariable
|
| D | tcp_test.rs | 64 let server = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_listener_interface() localVariable
448 let server = ylong_runtime::block_on(handle).unwrap(); in sdv_tcp_drop_out_context() localVariable
469 let server = ylong_runtime::spawn(async { in sdv_tcp_cancel() localVariable
514 let server = ylong_runtime::spawn(async move { in sdv_tcp_cancel() localVariable
|
| D | join_set.rs | 100 let mut server = listener.accept().await.unwrap().0; in sdv_join_set_spawn_io() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| D | tcp_test.rs | 29 let server = TcpListener::bind(addr).unwrap(); in sdv_tcp_server() localVariable
99 let server = TcpListener::bind(addr).unwrap(); in sdv_tcp_server_vectored() localVariable
|
| D | uds_test.rs | 69 fn server() -> io::Result<()> { in server() function
71 let mut server = UnixListener::bind(PATH)?; in server() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/ |
| D | mod.rs | 76 …let server = TcpListener::bind("127.0.0.1:0").await.expect("server is failed to bind a address !"); localVariable
179 … let server = TcpListener::bind("127.0.0.1:0").expect("server is failed to bind a address !"); localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_runtime_tcp_server_perf.rs | 27 let server = match TcpListener::bind(addr).await { in main() localVariable
|
| D | ylong_runtime_async_benchmark.rs | 40 let mut server = socket.accept().await.unwrap().0; in run_server() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| D | mod.rs | 170 …let server = hyper::Server::from_tcp(tcp_listener).expect("build hyper server from tcp listener fa… localVariable
218 …let server = hyper::Server::from_tcp(tcp_listener).expect("build hyper server from tcp listener fa… localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/examples/ |
| D | ylong_io_tcp_server.rs | 30 let mut server = TcpListener::bind(addr)?; in main() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | test_utils.rs | 82 …let server = TcpListener::bind("127.0.0.1:0").await.expect("server is failed to bind a address !"); localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | listener.rs | 269 let server = TcpListener::bind(ADDR).await.unwrap(); in ut_tcp_listener_basic() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| D | sdv_async_http2.rs | 109 let server = hyper::Server::from_tcp(tcp_listener) localVariable
|