| /external/rust/crates/mio/src/net/tcp/ |
| D | stream.rs | 45 pub struct TcpStream { struct
46 inner: IoSource<net::TcpStream>, argument
49 impl TcpStream { implementation
52 pub fn connect(addr: SocketAddr) -> io::Result<TcpStream> { in connect()
69 pub fn from_std(stream: net::TcpStream) -> 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
223 impl event::Source for TcpStream { implementation
[all …]
|
| D | listener.rs | 89 pub fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept()
|
| D | socket.rs | 81 pub fn connect(self, addr: SocketAddr) -> io::Result<TcpStream> { in connect()
|
| /external/rust/crates/tokio/src/net/tcp/ |
| D | stream.rs | 72 impl TcpStream { impl
111 pub async fn connect<A: ToSocketAddrs>(addr: A) -> io::Result<TcpStream> { in connect()
132 async fn connect_addr(addr: SocketAddr) -> io::Result<TcpStream> { in connect_addr()
137 pub(crate) async fn connect_mio(sys: mio::net::TcpStream) -> io::Result<TcpStream> { in connect_mio()
155 pub(crate) fn new(connected: mio::net::TcpStream) -> io::Result<TcpStream> { in new()
189 pub fn from_std(stream: std::net::TcpStream) -> io::Result<TcpStream> { in from_std()
229 pub fn into_std(self) -> io::Result<std::net::TcpStream> { in into_std()
1041 impl TryFrom<std::net::TcpStream> for TcpStream { implementation
1055 impl AsyncRead for TcpStream { implementation
1065 impl AsyncWrite for TcpStream { implementation
[all …]
|
| D | split_owned.rs | 70 ) -> Result<TcpStream, ReuniteError> { in reunite()
103 pub fn reunite(self, other: OwnedWriteHalf) -> Result<TcpStream, ReuniteError> { in reunite()
210 pub fn reunite(self, other: OwnedReadHalf) -> Result<TcpStream, ReuniteError> { in reunite()
269 fn as_ref(&self) -> &TcpStream { in as_ref()
275 fn as_ref(&self) -> &TcpStream { in as_ref()
|
| D | split.rs | 183 fn as_ref(&self) -> &TcpStream { in as_ref()
189 fn as_ref(&self) -> &TcpStream { in as_ref()
|
| D | listener.rs | 149 pub async fn accept(&self) -> io::Result<(TcpStream, SocketAddr)> { in accept()
166 pub fn poll_accept(&self, cx: &mut Context<'_>) -> Poll<io::Result<(TcpStream, SocketAddr)>> { in poll_accept()
|
| D | socket.rs | 441 pub async fn connect(self, addr: SocketAddr) -> io::Result<TcpStream> { in connect()
|
| /external/rust/crates/tokio/tests/ |
| D | tcp_stream.rs | 212 fn read_until_pending(stream: &mut TcpStream) { in read_until_pending()
225 fn write_until_pending(stream: &mut TcpStream) { in write_until_pending()
|
| D | io_copy_bidirectional.rs | 40 F: FnMut(JoinHandle<io::Result<(u64, u64)>>, TcpStream, TcpStream) -> Fut, in symmetric() argument
|
| /external/rust/crates/mio/src/sys/shell/ |
| D | tcp.rs | 20 pub(crate) fn connect(_: TcpSocket, _addr: SocketAddr) -> io::Result<net::TcpStream> { in connect()
121 pub fn accept(_: &net::TcpListener) -> io::Result<(net::TcpStream, SocketAddr)> { in accept()
|
| /external/rust/crates/tokio/docs/ |
| D | reactor-refactor.md | 257 ### Removing all the `split()` functions
|
| /external/rust/crates/gdbstub/examples/armv4t/ |
| D | main.rs | 16 fn wait_for_tcp(port: u16) -> DynResult<TcpStream> { in wait_for_tcp()
|
| /external/rust/crates/gdbstub/examples/armv4t_multicore/ |
| D | main.rs | 16 fn wait_for_tcp(port: u16) -> DynResult<TcpStream> { in wait_for_tcp()
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | tcp_listener.rs | 35 ) -> Poll<Option<io::Result<TcpStream>>> { in poll_next()
|
| /external/rust/crates/gdbstub/src/connection/impls/ |
| D | tcpstream.rs | 5 impl Connection for TcpStream { implementation
|
| /external/rust/crates/mio/examples/ |
| D | tcp_server.rs | 102 connection: &mut TcpStream, in handle_connection_event()
|
| /external/rust/crates/mio/src/sys/windows/ |
| D | tcp.rs | 48 pub(crate) fn connect(socket: TcpSocket, addr: SocketAddr) -> io::Result<net::TcpStream> { in connect()
321 pub(crate) fn accept(listener: &net::TcpListener) -> io::Result<(net::TcpStream, SocketAddr)> { in accept()
|
| /external/rust/crates/mio/src/sys/unix/ |
| D | tcp.rs | 40 pub(crate) fn connect(socket: TcpSocket, addr: SocketAddr) -> io::Result<net::TcpStream> { in connect()
425 pub fn accept(listener: &net::TcpListener) -> io::Result<(net::TcpStream, SocketAddr)> { in accept()
|
| /external/libchromeos-rs/src/ |
| D | net.rs | 130 pub fn connect<A: ToSocketAddrs>(self, addr: A) -> io::Result<TcpStream> { in connect()
|
| /external/crosvm/sys_util/src/ |
| D | net.rs | 143 pub fn connect<A: ToSocketAddrs>(self, addr: A) -> io::Result<TcpStream> { in connect()
|
| /external/perfetto/src/base/ |
| D | unix_socket_unittest.cc | 423 TEST_F(UnixSocketTest, TcpStream) { in TEST_F() argument
|