Home
last modified time | relevance | path

Searched refs:server (Results 1 - 20 of 20) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_runtime_tcp_server_perf.rs14 //! Tcp server usage in ylong_runtime.
27 let server = match TcpListener::bind(addr).await { in main()
28 Ok(server) => server, in main()
33 let (mut stream, _) = match server.accept().await { in main()
H A Dylong_runtime_async_benchmark.rs40 let mut server = socket.accept().await.unwrap().0; variables
44 let n = server.read(&mut buf).await.unwrap();
48 let n = server.write(&buf).await.unwrap();
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Duds_test.rs27 /// 1. Creates a server and a client with `pair()`.
34 let (server, client) = UnixStream::pair().unwrap(); in sdv_uds_stream_try_test()
36 server.writable().await.unwrap(); in sdv_uds_stream_try_test()
37 match server.try_write(b"hello") { in sdv_uds_stream_try_test()
69 /// 1. Creates a server and a client with `pair()`.
76 let (server, client) = UnixDatagram::pair().unwrap(); in sdv_uds_datagram_try_test()
78 server.writable().await.unwrap(); in sdv_uds_datagram_try_test()
79 match server.try_send(b"hello") { in sdv_uds_datagram_try_test()
H A Dasync_buf_read.rs23 /// 2. The client sends some data to the server. The message contains a `:`
25 /// 3. The server wraps the TcpStream inside a AsyncBufReader
26 /// 4. The server calls `read_until` with a delimiter ':'.
28 /// 6. The server calls `read`.
32 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_read_until()
59 ylong_runtime::block_on(server).unwrap(); in sdv_buf_reader_read_until()
67 /// 2. The client sends some data to the server. The message contains the `\n`
69 /// 3. The server wraps the TcpStream inside a AsyncBufReader
70 /// 4. The server calls `read_line` with a delimiter '\n'.
72 /// 6. The server call
[all...]
H A Dasync_buf_write.rs26 /// 3. The server receives data.
30 let server = ylong_runtime::spawn(async move { in sdv_buf_writer_write()
55 ylong_runtime::block_on(server).unwrap(); in sdv_buf_writer_write()
65 /// 3. The server receives data.
69 let server = ylong_runtime::spawn(async move { in sdv_buf_writer_write_vectored()
97 ylong_runtime::block_on(server).unwrap(); in sdv_buf_writer_write_vectored()
161 /// 3. The server receives data.
165 let server = ylong_runtime::spawn(async move { in sdv_buf_writer_write_vectored_2()
193 ylong_runtime::block_on(server).unwrap(); in sdv_buf_writer_write_vectored_2()
H A Duds_cargo_test.rs49 /// 1. Create a server with `bind()` and `accept()`.
57 let server_msg = "hello server"; in sdv_uds_listener_read_write_test()
99 /// 1. Creates a server and a client.
110 async fn server() { in sdv_uds_stream_test()
117 assert_eq!(n, "hello server".len()); in sdv_uds_stream_test()
120 "hello server".to_string() in sdv_uds_stream_test()
129 assert_eq!(n, "hello server".len()); in sdv_uds_stream_test()
135 let n = stream.write(b"hello server").await.unwrap(); in sdv_uds_stream_test()
143 ylong_runtime::block_on(server()); in sdv_uds_stream_test()
155 /// 1. Creates a server an
[all...]
H A Dtcp_test.rs62 let server = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_listener_interface()
64 server.set_ttl(101).unwrap(); in sdv_tcp_listener_interface()
65 assert_eq!(server.ttl().unwrap(), 101); in sdv_tcp_listener_interface()
67 assert!(server.take_error().unwrap().is_none()); in sdv_tcp_listener_interface()
204 .write(b"hello server") in sdv_tcp_global_runtime()
207 assert_eq!(n, "hello server".len()); in sdv_tcp_global_runtime()
229 "hello server".to_string() in sdv_tcp_global_runtime()
231 assert_eq!(n, "hello server".len()); in sdv_tcp_global_runtime()
308 let n = read_half.read(&mut buf).await.expect("server read err"); in sdv_tcp_split_borrow_half()
316 let n = read_half.read(&mut buf).await.expect("server rea in sdv_tcp_split_borrow_half()
[all...]
H A Dasync_read.rs57 /// 2. The client sends some data to the server. The message is valid UTF-8.
58 /// 3. The server wraps the TcpStream inside a AsyncBufReader
59 /// 4. The server calls `read_to_string` on the string "Hello".
63 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_read_to_string()
85 ylong_runtime::block_on(server).unwrap(); in sdv_buf_reader_read_to_string()
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Dtcp_test.rs23 /// 1. Create a Tcp server
29 let server = TcpListener::bind(addr).unwrap(); in sdv_tcp_server()
30 let addr = server.local_addr().unwrap(); in sdv_tcp_server()
34 let stream = server.accept(); in sdv_tcp_server()
93 /// 1. Create a Tcp server
99 let server = TcpListener::bind(addr).unwrap(); in sdv_tcp_server_vectored()
100 let addr = server.local_addr().unwrap(); in sdv_tcp_server_vectored()
104 let stream = server.accept(); in sdv_tcp_server_vectored()
H A Duds_test.rs33 /// 3. Client reads the message and sends "Hello server".
39 let handle = std::thread::spawn(server); in sdv_uds_stream_test()
59 let buf = b"Hello server"; in sdv_uds_stream_test()
69 fn server() -> io::Result<()> { in server() functions
71 let mut server = UnixListener::bind(PATH)?; in server() variables
73 poll.register(&mut server, SERVER, Interest::READABLE)?; in server()
83 let (mut stream, _) = server.accept()?; in server()
110 assert_eq!(str_buf, "Hello server"); in server()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_tcp.rs24 ($runtime: expr, $bench: ident, $server: ident, $client: ident, $port: literal, $task_num: literal, $loop_num: literal, $buf_size: literal) => {
25 pub async fn $server(addr: String) {
63 handlers.push(runtime.spawn($server(addr.clone())));
76 ($bench: ident, $server: ident, $client: ident, $port: literal, $task_num: literal, $loop_num: literal, $buf_size: literal) => {
77 pub async fn $server(addr: SocketAddr) {
117 handlers.push(ylong_runtime::spawn($server(addr)));
H A Dylong_tokio_uds.rs25 ($runtime: expr, $bench: ident, $server: ident, $client: ident, $path: literal, $task_num: literal, $loop_num: literal, $buf_size: literal) => {
26 pub async fn $server(addr: String) {
62 handlers.push(runtime.spawn($server(addr.clone())));
79 ($bench: ident, $server: ident, $client: ident, $path: literal, $task_num: literal, $loop_num: literal, $buf_size: literal) => {
80 pub async fn $server(addr: String) {
116 handlers.push(ylong_runtime::spawn($server(addr.clone())));
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dlistener.rs33 /// let server = TcpListener::bind(addr).await?;
34 /// let (stream, address) = server.accept().await?;
43 /// A TCP socket server, asynchronously listening for connections.
67 /// let server = TcpListener::bind(addr).await?;
94 /// let server = TcpListener::bind(addr).await?;
95 /// let (stream, address) = server.accept().await?;
119 /// let mut server = TcpListener::bind(addr).await.unwrap();
120 /// let ret = server.local_addr().unwrap();
139 /// let mut server = TcpListener::bind(addr).await.unwrap();
140 /// let ret = server
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/examples/
H A Dylong_io_tcp_server.rs30 let mut server = TcpListener::bind(addr)?; in main() variables
31 println!("server socket {server:?}\n"); in main()
33 poll.register(&mut server, SERVER, Interest::READABLE)?; in main()
43 let ret = server.accept()?; in main()
54 // println!("server writable\n"); in main()
70 println!("server readable\n"); in main()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Ddatagram.rs488 /// 1. Creates a server and a client.
489 /// 2. Client Sends message and server recv it.
497 let (server, client) = UnixDatagram::pair().unwrap(); in ut_uds_datagram_read_write_test()
504 server.recv(buf.as_mut_slice()).await.expect("recv failed"); in ut_uds_datagram_read_write_test()
521 /// 1. Creates a server and a client with `pair()`.
528 let (server, client) = UnixDatagram::pair().unwrap(); in ut_uds_datagram_try_test()
530 server.writable().await.unwrap(); in ut_uds_datagram_try_test()
531 match server.try_send(b"hello") { in ut_uds_datagram_try_test()
/commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/
H A Dmod.rs25 // This channel allows the server to notify the client when it has shut down.
76 let server = TcpListener::bind("127.0.0.1:0").await.expect("server is failed to bind a address !");
77 let addr = server.local_addr().expect("failed to get server address !");
84 let (mut stream, _client) = server.accept().await.expect("failed to build a tcp stream");
133 stream.write_all(resp_str.as_bytes()).await.expect("server write response failed");
139 stream.shutdown($shutdown).expect("server shutdown failed");
141 rx.send(()).expect("server send order failed !");
145 let handle = tx2.recv().expect("recv server handl
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Dtest_utils.rs14 //! Construct the http server using TcpStream.
21 // This channel allows the server to notify the client when it has shut down.
82 let server = TcpListener::bind("127.0.0.1:0").await.expect("server is failed to bind a address !");
83 let addr = server.local_addr().expect("failed to get server address !");
90 let (mut stream, _client) = server.accept().await.expect("failed to build a tcp stream");
113 stream.write_all(resp_str.as_bytes()).await.expect("server write response failed");
117 stream.shutdown($shutdown).expect("server shutdown failed");
120 tx.send(()).expect("server sen
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/tests/
H A Dsdv_async_http2.rs33 // This channel allows the server to notify the client when it is up and running.
36 // This channel allows the client to notify the server when it is ready to shut down.
39 // This channel allows the server to notify the client when it has shut down.
68 panic!("server read request body data occurs error");
103 std::net::TcpListener::bind("127.0.0.1:0").expect("server bind port failed !");
106 .expect("get server local address failed!");
109 let server = hyper::Server::from_tcp(tcp_listener)
110 .expect("build hyper server from tcp listener failed !");
115 server
128 .expect("Start server faile
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/tests/common/
H A Dmod.rs31 // This channel allows the server to notify the client when it is up and running.
34 // This channel allows the client to notify the server when it is ready to shut down.
37 // This channel allows the server to notify the client when it has shut down.
71 .expect("Runtime start server coroutine failed");
102 .expect("Runtime start server coroutine failed");
125 let tcp_listener = std::net::TcpListener::bind("127.0.0.1:0").expect("server bind port failed !");
126 let addr = tcp_listener.local_addr().expect("get server local address failed!");
128 let server = hyper::Server::from_tcp(tcp_listener).expect("build hyper server from tcp listener failed !");
133 server
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/
H A Dctx.rs217 /// the subject's certificate (actual client or server certificate),
244 /// Sets the protocols to sent to the server for Application Layer Protocol

Completed in 6 milliseconds