| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | async_buf_read.rs | 22 /// 1. Establish an asynchronous tcp connection.
34 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_until()
35 let (stream, _) = tcp.accept().await.unwrap(); in sdv_buf_reader_read_until()
50 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_until() variables
51 while tcp.is_err() { in sdv_buf_reader_read_until()
52 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_until()
54 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_until() variables
56 tcp.write_all(&buf).await.unwrap(); in sdv_buf_reader_read_until()
66 /// 1. Establish an asynchronous tcp connectio
92 let mut tcp = TcpStream::connect(addr).await; sdv_buf_reader_read_line() variables
96 let mut tcp = tcp.unwrap(); sdv_buf_reader_read_line() variables
131 let mut tcp = TcpStream::connect(addr).await; sdv_buf_reader_split() variables
135 let mut tcp = tcp.unwrap(); sdv_buf_reader_split() variables
179 let mut tcp = TcpStream::connect(addr).await; sdv_buf_reader_lines() variables
183 let mut tcp = tcp.unwrap(); sdv_buf_reader_lines() variables
273 let mut tcp = TcpStream::connect(addr).await; sdv_buf_reader_read() variables
277 let mut tcp = tcp.unwrap(); sdv_buf_reader_read() variables
[all...] |
| H A D | async_buf_write.rs | 23 /// 1. Establish an asynchronous tcp connection.
32 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write()
33 let (mut stream, _) = tcp.accept().await.unwrap(); in sdv_buf_writer_write()
43 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write() variables
44 while tcp.is_err() { in sdv_buf_writer_write()
45 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write()
47 let tcp = tcp.unwrap(); in sdv_buf_writer_write()
50 let mut buf_writer = AsyncBufWriter::with_capacity(10, tcp); in sdv_buf_writer_write()
62 /// 1. Establish an asynchronous tcp connectio
82 let mut tcp = TcpStream::connect(addr).await; sdv_buf_writer_write_vectored() variables
178 let mut tcp = TcpStream::connect(addr).await; sdv_buf_writer_write_vectored_2() variables
[all...] |
| H A D | tcp_test.rs | 252 let tcp = TcpListener::bind(ADDR).await.unwrap(); in sdv_tcp_multi_runtime()
253 let addr = tcp.local_addr().unwrap(); in sdv_tcp_multi_runtime()
256 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_multi_runtime() variables
257 while tcp.is_err() { in sdv_tcp_multi_runtime()
258 tcp = TcpStream::connect(addr).await; in sdv_tcp_multi_runtime()
260 let mut tcp = tcp.unwrap(); in sdv_tcp_multi_runtime() variables
262 tcp.write_all(&buf).await.unwrap(); in sdv_tcp_multi_runtime()
265 tcp.read_exact(&mut buf).await.unwrap(); in sdv_tcp_multi_runtime()
269 let (mut stream, _) = tcp in sdv_tcp_multi_runtime()
432 let mut tcp = TcpStream::connect(addr).await; sdv_tcp_drop_out_context() variables
436 let mut tcp = tcp.unwrap(); sdv_tcp_drop_out_context() variables
490 let mut tcp = TcpStream::connect(addr).await; sdv_tcp_cancel() variables
495 let mut tcp = tcp.unwrap(); sdv_tcp_cancel() variables
528 let mut tcp = TcpStream::connect(addr).await; sdv_tcp_cancel() variables
532 let mut tcp = tcp.unwrap(); sdv_tcp_cancel() variables
572 let mut tcp = TcpStream::connect(addr).await; sdv_tcp_unexpected_eof() variables
576 let mut tcp = tcp.unwrap(); sdv_tcp_unexpected_eof() variables
[all...] |
| H A D | async_read.rs | 56 /// 1. Establish an asynchronous tcp connection.
65 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_to_string()
66 let (stream, _) = tcp.accept().await.unwrap(); in sdv_buf_reader_read_to_string()
76 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string() variables
77 while tcp.is_err() { in sdv_buf_reader_read_to_string()
78 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string()
80 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_to_string() variables
82 tcp.write_all(&buf).await.unwrap(); in sdv_buf_reader_read_to_string()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_tcp.rs | 14 //! Benchmarks for the tcp.
26 let tcp = tokioTcpListener::bind(addr).await.unwrap();
27 let (mut stream, _) = tcp.accept().await.unwrap();
39 let mut tcp = tokioTcpStream::connect(addr.clone()).await; variables
40 while tcp.is_err() {
41 tcp = tokioTcpStream::connect(addr.clone()).await;
43 let mut tcp = tcp.unwrap(); variables
46 tcp.write_all(&buf).await.unwrap();
49 tcp
91 let mut tcp = TcpStream::connect(addr).await; global() variables
95 let mut tcp = tcp.unwrap(); global() variables
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_tcp.rs | 14 //! An example for `tcp`
25 let tcp = TcpListener::bind(addr).await.unwrap();
26 let (mut stream, _) = tcp.accept().await.unwrap();
38 let mut tcp = TcpStream::connect(addr).await; variables
39 while tcp.is_err() {
40 tcp = TcpStream::connect(addr).await;
42 let mut tcp = tcp.unwrap(); variables
45 tcp.write_all(&buf).await.unwrap();
48 tcp
[all...] |
| H A D | ylong_runtime_tcp_fd_limit.rs | 22 let tcp = TcpListener::bind("127.0.0.1:0").await; in main()
23 match tcp { in main()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | mod.rs | 14 mod tcp; modules
15 pub use tcp::{
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | mod.rs | 28 mod tcp; modules
29 pub use self::tcp::{TcpListener, TcpStream};
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | mod.rs | 67 mod tcp; modules
68 pub use self::tcp::{TcpListener, TcpStream};
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 365 let mut tcp = tcp_stream; variables
368 let _ = tcp.fchown(fchown.uid, fchown.gid);
370 let local = tcp
373 let peer = tcp
377 tcp = tunnel(tcp, &host, port, auth)
385 .and_then(|ssl| AsyncSslStream::new(ssl.into_inner(), tcp, pinned_key))
543 /// 1. Creates a `tcp stream` by calling `tcp_stream`.
562 let tcp = tcp_stream(eyeballs).await.unwrap(); in ut_ssl_tunnel_error()
564 tcp, in ut_ssl_tunnel_error()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | current_thread.rs | 363 let tcp = TcpListener::bind(ADDR).await.unwrap();
364 let addr = tcp.local_addr().unwrap();
366 let (mut stream, _) = tcp.accept().await.unwrap();
379 let mut tcp = TcpStream::connect(addr).await; variables
380 while tcp.is_err() {
381 tcp = TcpStream::connect(addr).await;
383 let mut tcp = tcp.unwrap(); variables
386 tcp.write_all(&buf).await.unwrap();
389 tcp
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | tcp_test.rs | 38 Err(e) => panic!("tcp accept failed: {e:?}"), in sdv_tcp_server()
51 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server()
67 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server()
73 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server()
74 match tcp { in sdv_tcp_server()
108 Err(e) => panic!("tcp accept failed: {e:?}"), in sdv_tcp_server_vectored()
124 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server_vectored()
141 Err(e) => panic!("tcp write failed: {e:?}"), in sdv_tcp_server_vectored()
147 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server_vectored()
148 match tcp { in sdv_tcp_server_vectored()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| H A D | stream.rs | 22 use crate::sys::windows::tcp::socket::{get_sock_linger, set_sock_linger};
23 use crate::sys::windows::tcp::TcpSocket;
|
| H A D | listener.rs | 20 use crate::sys::windows::tcp::TcpSocket;
32 /// Binds a new tcp Listener to the specific address to receive connection
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | socket.rs | 157 use crate::sys::unix::tcp::socket::into_linger;
158 use crate::sys::unix::tcp::TcpSocket;
|
| H A D | stream.rs | 21 use crate::sys::unix::tcp::socket::{get_sock_linger, set_sock_linger};
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | stream.rs | 27 use crate::net::sys::tcp::split::{BorrowReadHalf, BorrowWriteHalf};
|