| /external/rust/crates/mio/src/net/tcp/ |
| D | stream.rs | 45 pub struct TcpStream { struct
46 inner: IoSource<net::TcpStream>, argument
49 impl TcpStream { impl
52 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect() argument
69 pub fn from_std(stream: net::TcpStream) -> TcpStream { in from_std() argument
70 TcpStream { in from_std()
175 impl Read for TcpStream { implementation
185 impl<'a> Read for &'a TcpStream { implementation
195 impl Write for TcpStream { implementation
209 impl<'a> Write for &'a TcpStream { implementation
[all …]
|
| D | listener.rs | 8 use super::{TcpSocket, TcpStream};
89 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept() argument
91 sys::tcp::accept(inner).map(|(stream, addr)| (TcpStream::from_std(stream), addr)) in accept()
|
| /external/rust/crates/tokio/src/net/tcp/ |
| D | stream.rs | 67 pub struct TcpStream {
68 io: PollEvented<mio::net::TcpStream>,
72 impl TcpStream { impl
111 pub async fn connect<A: ToSocketAddrs>(addr: A) -> io::Result<TcpStream> { in connect() argument
117 match TcpStream::connect_addr(addr).await { in connect()
132 async fn connect_addr(addr: SocketAddr) -> io::Result<TcpStream> { in connect_addr() argument
133 let sys = mio::net::TcpStream::connect(addr)?; in connect_addr()
134 TcpStream::connect_mio(sys).await in connect_addr()
137 pub(crate) async fn connect_mio(sys: mio::net::TcpStream) -> io::Result<TcpStream> { in connect_mio() argument
138 let stream = TcpStream::new(sys)?; in connect_mio()
[all …]
|
| D | split_owned.rs | 13 use crate::net::TcpStream;
32 inner: Arc<TcpStream>,
51 inner: Arc<TcpStream>,
55 pub(crate) fn split_owned(stream: TcpStream) -> (OwnedReadHalf, OwnedWriteHalf) { in split_owned()
70 ) -> Result<TcpStream, ReuniteError> { in reunite() argument
103 pub fn reunite(self, other: OwnedWriteHalf) -> Result<TcpStream, ReuniteError> { in reunite() argument
210 pub fn reunite(self, other: OwnedReadHalf) -> Result<TcpStream, ReuniteError> { in reunite() argument
268 impl AsRef<TcpStream> for OwnedReadHalf {
269 fn as_ref(&self) -> &TcpStream { in as_ref() argument
274 impl AsRef<TcpStream> for OwnedWriteHalf {
[all …]
|
| D | split.rs | 13 use crate::net::TcpStream;
29 pub struct ReadHalf<'a>(&'a TcpStream);
45 pub struct WriteHalf<'a>(&'a TcpStream);
47 pub(crate) fn split(stream: &mut TcpStream) -> (ReadHalf<'_>, WriteHalf<'_>) { in split()
182 impl AsRef<TcpStream> for ReadHalf<'_> {
183 fn as_ref(&self) -> &TcpStream { in as_ref() argument
188 impl AsRef<TcpStream> for WriteHalf<'_> {
189 fn as_ref(&self) -> &TcpStream { in as_ref() argument
|
| D | listener.rs | 2 use crate::net::tcp::TcpStream;
149 pub async fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept() argument
156 let stream = TcpStream::new(mio)?; in accept()
166 pub fn poll_accept(&self, cx: &mut Context<'_>) -> Poll<io::Result<(TcpStream, SocketAddr)>> { in poll_accept() argument
172 let io = TcpStream::new(io)?; in poll_accept()
|
| D | socket.rs | 1 use crate::net::{TcpListener, TcpStream};
441 pub async fn connect(self, addr: SocketAddr) -> io::Result<TcpStream> { in connect() argument
443 TcpStream::connect_mio(mio).await in connect()
|
| /external/rust/crates/tokio/tests/ |
| D | tcp_connect.rs | 4 use tokio::net::{TcpListener, TcpStream};
24 let mine = assert_ok!(TcpStream::connect(&addr).await); in connect_v4()
51 let mine = assert_ok!(TcpStream::connect(&addr).await); in connect_v6()
75 assert_ok!(TcpStream::connect(addr).await); in connect_addr_ip_string()
92 assert_ok!(TcpStream::connect(&addr[..]).await); in connect_addr_ip_str_slice()
109 assert_ok!(TcpStream::connect(addr).await); in connect_addr_host_string()
126 assert_ok!(TcpStream::connect(&addr).await); in connect_addr_ip_port_tuple()
143 assert_ok!(TcpStream::connect(&addr).await); in connect_addr_ip_str_port_tuple()
160 assert_ok!(TcpStream::connect(&addr).await); in connect_addr_host_str_port_tuple()
|
| D | io_copy_bidirectional.rs | 6 use tokio::net::TcpStream;
9 async fn make_socketpair() -> (TcpStream, TcpStream) { in make_socketpair()
12 let connector = TcpStream::connect(addr); in make_socketpair()
20 async fn block_write(s: &mut TcpStream) -> usize { in block_write()
40 F: FnMut(JoinHandle<io::Result<(u64, u64)>>, TcpStream, TcpStream) -> Fut, in symmetric() argument
|
| D | tcp_stream.rs | 5 use tokio::net::{TcpListener, TcpStream};
20 let stream = TcpStream::connect(listener.local_addr().unwrap()) in set_linger()
39 let client = TcpStream::connect(listener.local_addr().unwrap()) in try_read_write()
116 let stream = TcpStream::connect("127.0.0.1:8080").await.unwrap(); in buffer_not_included_in_future()
205 async fn create_pair() -> (TcpStream, TcpStream) { in create_pair()
208 let (client, (server, _)) = assert_ok!(try_join!(TcpStream::connect(&addr), listener.accept())); in create_pair()
212 fn read_until_pending(stream: &mut TcpStream) { in read_until_pending() argument
225 fn write_until_pending(stream: &mut TcpStream) { in write_until_pending() argument
246 let client = TcpStream::connect(listener.local_addr().unwrap()) in try_read_buf()
|
| D | tcp_into_std.rs | 8 use tokio::net::TcpStream;
16 let stream: TcpStream = TcpStream::connect("127.0.0.1:34254").await.unwrap(); in tcp_into_std()
38 let mut tokio_tcp_stream = TcpStream::from_std(std_tcp_stream)?; in tcp_into_std()
|
| D | tcp_into_split.rs | 9 use tokio::net::{TcpListener, TcpStream};
20 TcpStream::connect(&addr), in split()
66 let stream1 = TcpStream::connect(&addr).await?; in reunite()
69 let stream2 = TcpStream::connect(&addr).await?; in reunite()
110 let stream = TcpStream::connect(&addr).await?; in drop_write()
|
| D | tcp_peek.rs | 5 use tokio::net::TcpStream;
18 let left = net::TcpStream::connect(&addr).unwrap(); in peek()
22 let mut left: TcpStream = left.try_into().unwrap(); in peek()
|
| D | tcp_accept.rs | 4 use tokio::net::{TcpListener, TcpStream};
26 let cli = assert_ok!(TcpStream::connect(&addr).await);
57 type Item = io::Result<(TcpStream, SocketAddr)>;
90 let _ = assert_ok!(TcpStream::connect(&addr).await); in no_extra_poll()
151 let _sock = TcpStream::connect(addr).await.unwrap(); in accept_many()
|
| D | buffered.rs | 8 use std::net::TcpStream;
21 let mut s = assert_ok!(TcpStream::connect(&addr)); in echo_server()
24 let mut s = assert_ok!(TcpStream::connect(&addr)); in echo_server()
|
| D | no_rt.rs | 1 use tokio::net::TcpStream;
24 block_on(TcpStream::connect(&addr)).unwrap(); in panics_when_no_reactor()
|
| D | tcp_shutdown.rs | 5 use tokio::net::{TcpListener, TcpStream};
14 let mut stream = assert_ok!(TcpStream::connect(&addr).await); in shutdown()
|
| D | tcp_echo.rs | 5 use tokio::net::{TcpListener, TcpStream};
20 let mut stream = assert_ok!(TcpStream::connect(&addr).await); in echo_server()
|
| D | tcp_split.rs | 9 use tokio::net::TcpStream;
27 let mut stream = TcpStream::connect(&addr).await?; in split()
|
| D | io_driver.rs | 10 use std::net::TcpStream;
82 let _s = TcpStream::connect(&addr).unwrap(); in test_drop_on_notify()
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | tcp_listener.rs | 5 use tokio::net::{TcpListener, TcpStream};
30 type Item = io::Result<TcpStream>;
35 ) -> Poll<Option<io::Result<TcpStream>>> { in poll_next() argument
|
| /external/rust/crates/tokio/docs/ |
| D | reactor-refactor.md | 12 * Implement `AsyncRead` / `AsyncWrite` for `&TcpStream` or other reference type.
30 implementation detail backing I/O resources such as `TcpStream`. The API of
234 ## Enabling reads and writes for `&TcpStream`
236 Instead of implementing `AsyncRead` and `AsyncWrite` for `&TcpStream`, a new
237 function is added to `TcpStream`.
240 impl TcpStream {
246 stream: &'a TcpStream,
259 With `TcpStream::by_ref()`, `TcpStream::split()` is no longer needed. Instead,
271 It is also possible to sotre a `TcpStream` in an `Arc`.
|
| /external/rust/crates/gdbstub/src/connection/impls/ |
| D | tcpstream.rs | 1 use std::net::TcpStream;
5 impl Connection for TcpStream { implementation
|
| /external/rust/crates/flate2/tests/ |
| D | tokio.rs | 22 use tokio_tcp::TcpStream;
58 let stream = TcpStream::connect(&addr); in tcp_stream_echo_pattern()
114 let stream = TcpStream::connect(&addr); in echo_random()
|
| /external/rust/crates/gdbstub/examples/armv4t/ |
| D | main.rs | 1 use std::net::{TcpListener, TcpStream};
16 fn wait_for_tcp(port: u16) -> DynResult<TcpStream> { in wait_for_tcp() argument
|