| /external/rust/crates/mio/src/net/tcp/ |
| D | stream.rs | 48 pub struct TcpStream { struct
49 inner: IoSource<net::TcpStream>, argument
52 impl TcpStream { implementation
84 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect()
106 pub fn from_std(stream: net::TcpStream) -> TcpStream { in from_std()
270 impl Read for TcpStream { implementation
280 impl<'a> Read for &'a TcpStream { implementation
290 impl Write for TcpStream { implementation
304 impl<'a> Write for &'a TcpStream { implementation
318 impl event::Source for TcpStream { implementation
[all …]
|
| D | listener.rs | 101 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept()
|
| /external/rust/crates/tokio/src/net/tcp/ |
| D | stream.rs | 75 impl TcpStream { implementation
160 pub(crate) fn new(connected: mio::net::TcpStream) -> io::Result<TcpStream> { in new()
203 pub fn from_std(stream: std::net::TcpStream) -> io::Result<TcpStream> { in from_std()
243 pub fn into_std(self) -> io::Result<std::net::TcpStream> { in into_std()
1272 impl TryFrom<std::net::TcpStream> for TcpStream { implementation
1286 impl AsyncRead for TcpStream { implementation
1296 impl AsyncWrite for TcpStream { implementation
1329 impl fmt::Debug for TcpStream { implementation
1340 impl AsRawFd for TcpStream { implementation
1352 impl AsRawSocket for TcpStream { implementation
[all …]
|
| D | split_owned.rs | 74 ) -> Result<TcpStream, ReuniteError> { in reunite()
107 pub fn reunite(self, other: OwnedWriteHalf) -> Result<TcpStream, ReuniteError> { in reunite()
346 pub fn reunite(self, other: OwnedReadHalf) -> Result<TcpStream, ReuniteError> { in reunite()
492 fn as_ref(&self) -> &TcpStream { in as_ref()
498 fn as_ref(&self) -> &TcpStream { in as_ref()
|
| D | listener.rs | 161 pub async fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept()
178 pub fn poll_accept(&self, cx: &mut Context<'_>) -> Poll<io::Result<(TcpStream, SocketAddr)>> { in poll_accept()
|
| D | split.rs | 408 fn as_ref(&self) -> &TcpStream { in as_ref()
414 fn as_ref(&self) -> &TcpStream { in as_ref()
|
| D | socket.rs | 579 pub async fn connect(self, addr: SocketAddr) -> io::Result<TcpStream> { in connect()
|
| /external/rust/crates/mio/src/sys/windows/ |
| D | tcp.rs | 29 pub(crate) fn connect(socket: &net::TcpStream, addr: SocketAddr) -> io::Result<()> { in connect()
62 pub(crate) fn accept(listener: &net::TcpListener) -> io::Result<(net::TcpStream, SocketAddr)> { in accept()
|
| /external/rust/crates/mio/src/sys/shell/ |
| D | tcp.rs | 15 pub(crate) fn connect(_: &net::TcpStream, _: SocketAddr) -> io::Result<()> { in connect()
29 pub(crate) fn accept(_: &net::TcpListener) -> io::Result<(net::TcpStream, SocketAddr)> { in accept()
|
| /external/rust/crates/mio/src/sys/unix/ |
| D | tcp.rs | 23 pub(crate) fn connect(socket: &net::TcpStream, addr: SocketAddr) -> io::Result<()> { in connect()
54 pub(crate) fn accept(listener: &net::TcpListener) -> io::Result<(net::TcpStream, SocketAddr)> { in accept()
|
| /external/rust/crates/gdbstub/src/conn/impls/ |
| D | tcpstream.rs | 6 impl Connection for TcpStream { implementation
33 impl ConnectionExt for TcpStream { implementation
|
| /external/rust/crates/openssl/src/ssl/test/ |
| D | server.rs | 42 pub fn connect_tcp(&self) -> TcpStream { in connect_tcp()
123 pub fn connect(self) -> SslStream<TcpStream> { in connect()
156 pub fn connect(self) -> SslStream<TcpStream> { in connect()
|
| /external/rust/crates/tokio/docs/ |
| D | reactor-refactor.md | 257 ### Removing all the `split()` functions
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | tcp_listener.rs | 35 ) -> Poll<Option<io::Result<TcpStream>>> { in poll_next()
|
| /external/rust/crates/mio/examples/ |
| D | tcp_server.rs | 105 connection: &mut TcpStream, in handle_connection_event()
|
| D | tcp_listenfd_server.rs | 130 connection: &mut TcpStream, in handle_connection_event()
|
| /external/rust/crates/tokio/tests/ |
| D | io_copy_bidirectional.rs | 40 F: FnMut(JoinHandle<io::Result<(u64, u64)>>, TcpStream, TcpStream) -> Fut, in symmetric() argument
|
| /external/rust/crates/gdbstub/examples/armv4t/ |
| D | main.rs | 24 fn wait_for_tcp(port: u16) -> DynResult<TcpStream> { in wait_for_tcp()
|
| /external/rust/crates/gdbstub/examples/armv4t_multicore/ |
| D | main.rs | 24 fn wait_for_tcp(port: u16) -> DynResult<TcpStream> { in wait_for_tcp()
|
| /external/crosvm/base/src/sys/unix/ |
| D | descriptor.rs | 154 impl From<SafeDescriptor> for TcpStream { implementation
|
| D | net.rs | 193 pub fn connect<A: ToSocketAddrs>(self, addr: A) -> io::Result<TcpStream> { in connect()
|
| /external/rust/pica/src/ |
| D | lib.rs | 58 fn new(socket: TcpStream, pcapng_file: Option<pcapng::File>) -> Self { in new()
303 async fn connect(&mut self, stream: TcpStream) { in connect()
|
| /external/libchromeos-rs/src/ |
| D | net.rs | 130 pub fn connect<A: ToSocketAddrs>(self, addr: A) -> io::Result<TcpStream> { in connect()
|
| /external/perfetto/src/base/ |
| D | unix_socket_unittest.cc | 425 TEST_F(UnixSocketTest, TcpStream) { in TEST_F() argument
|