| /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
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() localVariable
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() localVariable
56 tcp.write_all(&buf).await.unwrap(); in sdv_buf_reader_read_until()
78 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_line() localVariable
79 let (stream, _) = tcp.accept().await.unwrap(); in sdv_buf_reader_read_line()
92 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_line() localVariable
[all …]
|
| D | tcp_test.rs | 109 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_tcp_multi_runtime() localVariable
110 let (mut stream, _) = tcp.accept().await.unwrap(); in sdv_tcp_multi_runtime()
121 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_multi_runtime() localVariable
122 while tcp.is_err() { in sdv_tcp_multi_runtime()
123 tcp = TcpStream::connect(addr).await; in sdv_tcp_multi_runtime()
125 let mut tcp = tcp.unwrap(); in sdv_tcp_multi_runtime() localVariable
127 tcp.write_all(&buf).await.unwrap(); in sdv_tcp_multi_runtime()
130 tcp.read_exact(&mut buf).await.unwrap(); in sdv_tcp_multi_runtime()
149 let tcp = TcpListener::bind("127.0.0.1:8200").await.unwrap(); in sdv_tcp_drop_out_context() localVariable
150 let (mut stream, _) = tcp.accept().await.unwrap(); in sdv_tcp_drop_out_context()
[all …]
|
| D | async_buf_write.rs | 32 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write() localVariable
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() localVariable
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() localVariable
50 let mut buf_writer = AsyncBufWriter::with_capacity(10, tcp); in sdv_buf_writer_write()
71 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write_vectored() localVariable
72 let (mut stream, _) = tcp.accept().await.unwrap(); in sdv_buf_writer_write_vectored()
82 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored() localVariable
[all …]
|
| D | async_read.rs | 65 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_to_string() localVariable
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() localVariable
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() localVariable
82 tcp.write_all(&buf).await.unwrap(); in sdv_buf_reader_read_to_string()
|
| D | join_set.rs | 110 let mut tcp = TcpStream::connect(addr).await; in sdv_join_set_spawn_io() localVariable
111 while tcp.is_err() { in sdv_join_set_spawn_io()
112 tcp = TcpStream::connect(addr).await; in sdv_join_set_spawn_io()
114 let mut client = tcp.unwrap(); in sdv_join_set_spawn_io()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_tcp.rs | 26 let tcp = tokioTcpListener::bind(addr).await.unwrap(); localVariable
27 let (mut stream, _) = tcp.accept().await.unwrap();
39 let mut tcp = tokioTcpStream::connect(addr.clone()).await; localVariable
40 while tcp.is_err() {
41 tcp = tokioTcpStream::connect(addr.clone()).await;
43 let mut tcp = tcp.unwrap(); localVariable
46 tcp.write_all(&buf).await.unwrap();
49 tcp.read_exact(&mut buf).await.unwrap();
78 let tcp = TcpListener::bind(addr).await.unwrap(); localVariable
79 let (mut stream, _) = tcp.accept().await.unwrap();
[all …]
|
| /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
26 let (mut stream, _) = tcp.accept().await.unwrap(); in ylong_tcp_server()
38 let mut tcp = TcpStream::connect(addr).await; in ylong_tcp_client() localVariable
39 while tcp.is_err() { in ylong_tcp_client()
40 tcp = TcpStream::connect(addr).await; in ylong_tcp_client()
42 let mut tcp = tcp.unwrap(); in ylong_tcp_client() localVariable
45 tcp.write_all(&buf).await.unwrap(); in ylong_tcp_client()
48 tcp.read_exact(&mut buf).await.unwrap(); in ylong_tcp_client()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/ |
| D | Cargo.toml | 11 default = ["tcp", "udp"]
13 tcp = []
32 required-features = ["tcp"]
37 required-features = ["tcp"]
|
| D | BUILD.gn | 24 "tcp",
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| D | mod.rs | 14 mod tcp; module
15 pub use tcp::{
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/ |
| D | mod.rs | 28 mod tcp;
29 pub use self::tcp::{TcpListener, TcpStream};
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| D | mod.rs | 63 mod tcp;
64 pub use self::tcp::{TcpListener, TcpStream};
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | current_thread.rs | 237 let tcp = TcpListener::bind(addr).await.unwrap(); localVariable
238 let (mut stream, _) = tcp.accept().await.unwrap();
250 let mut tcp = TcpStream::connect(addr).await; localVariable
251 while tcp.is_err() {
252 tcp = TcpStream::connect(addr).await;
254 let mut tcp = tcp.unwrap(); localVariable
257 tcp.write_all(&buf).await.unwrap();
260 tcp.read_exact(&mut buf).await.unwrap();
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | connector.rs | 150 let mut tcp = tcp_stream(&addr).await?; in connect() localVariable
153 tcp = tunnel(tcp, host, port, auth).await?; in connect()
158 .and_then(|ssl| AsyncSslStream::new(ssl.into_inner(), tcp)) in connect()
|
| /commonlibrary/rust/ylong_runtime/ |
| D | RELEASE_NOTES.md | 4 - async net: tcp / udp
|
| D | README_zh.md | 75 | | | └── tcp # 异步TCP实现
|
| D | README.md | 99 | | | └── tcp # Async Tcp
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| D | listener.rs | 20 use crate::sys::windows::tcp::TcpSocket;
|
| D | stream.rs | 21 use crate::sys::windows::tcp::TcpSocket;
|
| /commonlibrary/rust/ylong_http/ylong_http_client/ |
| D | Cargo.toml | 19 hyper = { version = "0.14.23", features = ["http1", "tcp", "server"] }
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/ |
| D | Cargo.toml | 54 net = ["ylong_io/tcp", "ylong_io/udp"]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | stream.rs | 26 use crate::net::sys::tcp::split::{BorrowReadHalf, BorrowWriteHalf};
|