| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| H A D | stream.rs | 28 pub struct TcpStream { struct
30 pub(crate) inner: net::TcpStream,
35 impl TcpStream { impl
53 pub fn from_std(stream: net::TcpStream) -> TcpStream { in from_std() argument
54 TcpStream { in from_std()
62 Ok(TcpStream { in try_clone()
262 impl fmt::Debug for TcpStream { implementation
296 read_write!(TcpStream);
298 read_write!(&TcpStream);
306 impl AsRawSocket for TcpStream { implementation
[all …]
|
| H A D | listener.rs | 22 use crate::{Interest, Selector, Source, TcpStream, Token};
72 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept() argument
75 .map(|(stream, addr)| (TcpStream::from_std(stream), addr)) in accept()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | stream.rs | 25 pub struct TcpStream { struct
27 pub inner: net::TcpStream, argument
30 impl TcpStream { impl
39 pub fn from_std(stream: net::TcpStream) -> TcpStream { in from_std() argument
40 TcpStream { inner: stream } in from_std()
45 Ok(TcpStream { in try_clone()
220 impl Read for TcpStream { implementation
230 impl Write for TcpStream { implementation
244 impl Read for &TcpStream { implementation
256 impl Write for &TcpStream { implementation
[all …]
|
| H A D | listener.rs | 21 use super::{TcpSocket, TcpStream};
56 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept() argument
67 Ok(socket) => unsafe { net::TcpStream::from_raw_fd(socket) }, in accept()
81 unsafe { net::TcpStream::from_raw_fd(socket) } in accept()
89 Ok(sockaddr) => Ok((TcpStream::from_std(stream), sockaddr)), in accept()
|
| H A D | socket.rs | 26 use super::TcpStream;
78 pub(crate) fn connect(self, addr: SocketAddr) -> io::Result<TcpStream> { in connect() argument
79 let stream = TcpStream { in connect()
80 inner: unsafe { net::TcpStream::from_raw_fd(self.socket) }, in connect()
|
| H A D | mod.rs | 23 pub use stream::TcpStream;
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | stream.rs | 61 pub struct TcpStream { struct
62 pub(crate) source: AsyncSource<ylong_io::TcpStream>,
65 impl Debug for TcpStream { implementation
71 impl TcpStream { impl
102 let stream = TcpStream::new(stream)?; in connect_inner()
122 Ok(TcpStream { source }) in new()
598 impl AsyncRead for TcpStream { implementation
608 impl AsyncWrite for TcpStream { implementation
643 impl AsRawSocket for TcpStream { implementation
658 impl AsRawFd for TcpStream { implementation
[all …]
|
| H A D | split.rs | 21 use crate::net::TcpStream;
24 pub struct BorrowReadHalf<'a>(pub(crate) &'a TcpStream);
27 pub struct BorrowWriteHalf<'a>(pub(crate) &'a TcpStream);
70 pub struct SplitReadHalf(pub(crate) Arc<TcpStream>);
73 pub struct SplitWriteHalf(pub(crate) Arc<TcpStream>);
120 use crate::net::{TcpListener, TcpStream};
139 let mut stream = TcpStream::connect(addr).await; in ut_test_borrow_half()
141 stream = TcpStream::connect(addr).await; in ut_test_borrow_half()
187 stream = TcpStream::connect(addr).await; in ut_test_owned_half()
234 stream = TcpStream::connect(addr).await; in ut_test_borrow_half_vector()
[all …]
|
| H A D | listener.rs | 20 use crate::net::{AsyncSource, TcpStream};
99 pub async fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept() argument
104 let stream = TcpStream::new(stream)?; in accept()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | tcp_test.rs | 17 use ylong_runtime::net::{TcpListener, TcpStream};
37 stream = TcpStream::connect(addr).await; in sdv_tcp_ipv6_connect()
88 stream = TcpStream::connect(addr).await; in sdv_tcp_stream_try()
258 tcp = TcpStream::connect(addr).await; in sdv_tcp_multi_runtime()
432 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_drop_out_context()
434 tcp = TcpStream::connect(addr).await; in sdv_tcp_drop_out_context()
490 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_cancel()
492 tcp = TcpStream::connect(addr).await; in sdv_tcp_cancel()
528 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_cancel()
530 tcp = TcpStream::connect(addr).await; in sdv_tcp_cancel()
[all …]
|
| H A D | async_buf_read.rs | 17 use ylong_runtime::net::{TcpListener, TcpStream};
50 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_until()
52 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_until()
92 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_line()
94 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_line()
131 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_split()
133 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_split()
179 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_lines()
181 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_lines()
273 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read()
[all …]
|
| H A D | async_buf_write.rs | 18 use ylong_runtime::net::{TcpListener, TcpStream};
43 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write()
45 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write()
82 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored()
84 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored()
178 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored_2()
180 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored_2()
|
| H A D | async_read.rs | 19 use ylong_runtime::net::{TcpListener, TcpStream};
76 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string()
78 tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string()
|
| H A D | join_set.rs | 93 use ylong_runtime::net::{TcpListener, TcpStream}; in sdv_join_set_spawn_io()
110 let mut tcp = TcpStream::connect(addr).await; in sdv_join_set_spawn_io()
112 tcp = TcpStream::connect(addr).await; in sdv_join_set_spawn_io()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | connector.rs | 55 use std::net::TcpStream;
62 type Stream = TcpStream;
71 TcpStream::connect(addr) in connect()
79 use std::net::TcpStream;
87 type Stream = MixStream<TcpStream>;
116 Ok(MixStream::Http(TcpStream::connect(addr).map_err(|e| { in connect()
121 let tcp_stream = TcpStream::connect(addr) in connect()
147 mut conn: TcpStream, in tunnel() argument
151 ) -> Result<TcpStream, HttpClientError> { in tunnel() argument
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_tcp.rs | 18 use ylong_runtime::net::{TcpListener, TcpStream};
38 let mut tcp = TcpStream::connect(addr).await; in ylong_tcp_client()
40 tcp = TcpStream::connect(addr).await; in ylong_tcp_client()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
| H A D | happy_eyeballs.rs | 24 use crate::runtime::{Sleep, TcpStream};
113 async fn connect(&mut self) -> Result<TcpStream, io::Error> { in connect() argument
176 pub(crate) async fn connect(mut self) -> io::Result<TcpStream> { in connect() argument
237 ) -> impl Future<Output = io::Result<TcpStream>> { in connect()
238 let stream_fut = TcpStream::connect(*addr); in connect()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 27 use crate::runtime::{AsyncRead, AsyncWrite, TcpStream};
84 async fn tcp_stream(eyeballs: HappyEyeballs) -> Result<TcpStream, HttpClientError> { in tcp_stream() argument
111 ) -> Result<TcpStream, HttpClientError> { in eyeballs_connect() argument
136 use crate::runtime::TcpStream;
140 type Stream = HttpStream<TcpStream>;
192 use crate::runtime::{AsyncReadExt, AsyncWriteExt, TcpStream};
196 type Stream = HttpStream<MixStream<TcpStream>>;
282 tcp_stream: TcpStream, in https_connect() argument
289 ) -> Result<HttpStream<MixStream<TcpStream>>, HttpClientError> { in https_connect() argument
339 mut conn: TcpStream, in tunnel() argument
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_tcp.rs | 91 let mut tcp = TcpStream::connect(addr).await;
93 tcp = TcpStream::connect(addr).await;
137 use tokio::net::{TcpListener as tokioTcpListener, TcpStream as tokioTcpStream};
139 use ylong_runtime::net::{TcpListener, TcpStream};
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| H A D | ylong_runtime_async_benchmark.rs | 20 use ylong_runtime::net::{TcpListener, TcpStream};
23 let mut client_stream = TcpStream::connect(addr).await; in run_client()
25 client_stream = TcpStream::connect(addr).await in run_client()
|
| H A D | ylong_runtime_tcp_client_perf.rs | 20 use ylong_runtime::net::TcpStream;
25 let mut stream = match TcpStream::connect(addr).await { in main()
|
| H A D | ylong_tokio_tcp_perf.rs | 26 use tokio::net::{TcpListener as tokioTcpListener, TcpStream as tokioTcpStream};
29 use ylong_runtime::net::{TcpListener, TcpStream};
39 if let Ok(mut client) = TcpStream::connect(addr).await { in ylong_create_client()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/examples/ |
| H A D | ylong_io_tcp_client.rs | 22 use ylong_io::TcpStream;
27 let mut stream = match TcpStream::connect(addr) { in main()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| H A D | lib.rs | 86 net::TcpStream,
93 net::TcpStream,
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | tcp_test.rs | 73 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server()
147 let tcp = net::TcpStream::connect(addr); in sdv_tcp_server_vectored()
|