Home
last modified time | relevance | path

Searched refs:TcpStream (Results 1 - 25 of 32) sorted by relevance

12

/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
H A Dstream.rs25 pub struct TcpStream { structure names
27 pub inner: net::TcpStream,
30 impl TcpStream { impls
33 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect()
38 /// Creates a new `TcpStream` from a standard `net::TcpStream`.
39 pub fn from_std(stream: net::TcpStream) -> TcpStream { in from_std()
40 TcpStream { inner: stream } in from_std()
43 /// Clones the TcpStream
[all...]
H A Dlistener.rs21 use super::{TcpSocket, TcpStream};
48 /// Accepts connections and returns the `TcpStream` and the remote peer
56 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept()
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 Dsocket.rs26 use super::TcpStream;
78 pub(crate) fn connect(self, addr: SocketAddr) -> io::Result<TcpStream> {
79 let stream = TcpStream {
80 inner: unsafe { net::TcpStream::from_raw_fd(self.socket) },
H A Dmod.rs23 pub use stream::TcpStream;
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/
H A Dstream.rs28 pub struct TcpStream { structure names
30 pub(crate) inner: net::TcpStream,
35 impl TcpStream { impls
36 /// Connects address to form TcpStream
42 /// let stream = ylong_io::TcpStream::connect(addr).unwrap();
44 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect()
46 let stream = unsafe { TcpStream::from_raw_socket(socket.as_raw_socket() as _) }; in connect()
52 /// Creates `TcpStream` from raw TcpStream.
53 pub fn from_std(stream: net::TcpStream)
[all...]
H A Dlistener.rs22 use crate::{Interest, Selector, Source, TcpStream, Token};
60 /// Accepts connections and returns the `TcpStream` and the remote peer
72 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept()
75 .map(|(stream, addr)| (TcpStream::from_std(stream), addr)) in accept()
H A Dmod.rs21 pub use stream::TcpStream;
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dtcp_test.rs17 use ylong_runtime::net::{TcpListener, TcpStream};
21 /// SDV test cases for `TcpStream`.
26 /// 2. `TcpStream` connect to listener and try to read buf.
35 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_ipv6_connect()
37 stream = TcpStream::connect(addr).await; in sdv_tcp_ipv6_connect()
72 /// SDV test cases for `TcpStream`.
77 /// 2. `TcpStream` connect to listener and try to read buf.
86 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_try()
88 stream = TcpStream::connect(addr).await; in sdv_tcp_stream_try()
106 /// SDV test cases for `TcpStream`
[all...]
H A Dasync_buf_read.rs17 use ylong_runtime::net::{TcpListener, TcpStream};
25 /// 3. The server wraps the TcpStream inside a AsyncBufReader
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()
69 /// 3. The server wraps the TcpStream inside a AsyncBufReader
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()
111 /// 3. The server wraps the TcpStream inside a AsyncBufReader
131 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_split()
133 tcp = TcpStream in sdv_buf_reader_split()
[all...]
H A Dasync_buf_write.rs18 use ylong_runtime::net::{TcpListener, TcpStream};
24 /// 2. The client wraps the TcpStream inside a AsyncBufWriter and calls `write`
43 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write()
45 tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write()
63 /// 2. The client wraps the TcpStream inside a AsyncBufWriter and calls
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()
159 /// 2. The client wraps the TcpStream inside a AsyncBufWriter and calls
178 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored_2()
180 tcp = TcpStream in sdv_buf_writer_write_vectored_2()
[all...]
H A Dasync_read.rs19 use ylong_runtime::net::{TcpListener, TcpStream};
58 /// 3. The server wraps the TcpStream inside a AsyncBufReader
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()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dsplit.rs21 use crate::net::TcpStream;
23 /// Borrowed read half of a TcpStream
24 pub struct BorrowReadHalf<'a>(pub(crate) &'a TcpStream);
26 /// Borrowed write half of a TcpStream
27 pub struct BorrowWriteHalf<'a>(pub(crate) &'a TcpStream);
69 /// Read half of a TcpStream in poll_flush()
70 pub struct SplitReadHalf(pub(crate) Arc<TcpStream>); in poll_flush()
72 /// Write half of a TcpStream
73 pub struct SplitWriteHalf(pub(crate) Arc<TcpStream>);
120 use crate::net::{TcpListener, TcpStream}; in poll_flush()
[all...]
H A Dstream.rs31 /// An asynchronous version of [`std::net::TcpStream`]
33 /// After creating a `TcpStream` by either connecting to a remote host or
44 /// use ylong_runtime::net::TcpStream;
48 /// let mut stream = TcpStream::connect(addr).await?;
61 pub struct TcpStream { structure names
62 pub(crate) source: AsyncSource<ylong_io::TcpStream>,
65 impl Debug for TcpStream {
71 impl TcpStream { in fmt() impls
88 /// use ylong_runtime::net::TcpStream; in fmt()
92 /// let mut stream = TcpStream in fmt()
[all...]
H A Dlistener.rs20 use crate::net::{AsyncSource, TcpStream};
80 /// When connection gets established, the corresponding [`TcpStream`] and
99 pub async fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> {
104 let stream = TcpStream::new(stream)?;
H A Dmod.rs18 pub use stream::TcpStream;
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Dmix.rs21 use crate::runtime::{AsyncRead, AsyncWrite, ReadBuf, TcpStream};
26 Http(TcpStream),
28 Https(AsyncSslStream<TcpStream>),
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_tcp.rs18 use ylong_runtime::net::{TcpListener, TcpStream};
38 let mut tcp = TcpStream::connect(addr).await;
40 tcp = TcpStream::connect(addr).await;
/commonlibrary/rust/ylong_runtime/ylong_io/examples/
H A Dylong_io_tcp_client.rs22 use ylong_io::TcpStream;
27 let mut stream = match TcpStream::connect(addr) { in main()
29 println!("TcpStream::connect err {err}"); in main()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_runtime_tcp_client_perf.rs20 use ylong_runtime::net::TcpStream;
25 let mut stream = match TcpStream::connect(addr).await { in main()
H A Dylong_runtime_async_benchmark.rs20 use ylong_runtime::net::{TcpListener, TcpStream};
23 let mut client_stream = TcpStream::connect(addr).await;
25 client_stream = TcpStream::connect(addr).await
H A Dylong_tokio_tcp_perf.rs26 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()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/
H A Dhappy_eyeballs.rs24 use crate::runtime::{Sleep, TcpStream};
113 async fn connect(&mut self) -> Result<TcpStream, io::Error> {
176 pub(crate) async fn connect(mut self) -> io::Result<TcpStream> {
237 ) -> impl Future<Output = io::Result<TcpStream>> { in connect()
238 let stream_fut = TcpStream::connect(*addr); in connect()
346 let reachable = match std::net::TcpStream::connect_timeout( in ut_happy_eyeballs_connect()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_tcp.rs91 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};
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
H A Dmod.rs16 BorrowReadHalf, BorrowWriteHalf, SplitReadHalf, SplitWriteHalf, TcpListener, TcpStream,
/commonlibrary/rust/ylong_http/ylong_http_client/src/
H A Dlib.rs86 net::TcpStream,
93 net::TcpStream,

Completed in 7 milliseconds

12