| /external/rust/android-crates-io/crates/mio/src/net/uds/ |
| D | stream.rs | 12 pub struct UnixStream { struct
13 inner: IoSource<net::UnixStream>, argument
16 impl UnixStream { impl
21 pub fn connect<P: AsRef<Path>>(path: P) -> io::Result<UnixStream> { in connect()
30 pub fn connect_addr(address: &SocketAddr) -> io::Result<UnixStream> { in connect_addr()
46 pub fn from_std(stream: net::UnixStream) -> UnixStream { in from_std()
154 impl Read for UnixStream { implementation
164 impl<'a> Read for &'a UnixStream { implementation
174 impl Write for UnixStream { implementation
188 impl<'a> Write for &'a UnixStream { implementation
[all …]
|
| D | listener.rs | 43 pub fn accept(&self) -> io::Result<(UnixStream, SocketAddr)> { in accept()
|
| /external/rust/android-crates-io/crates/tokio/src/net/unix/ |
| D | stream.rs | 47 impl UnixStream { impl
48 pub(crate) async fn connect_mio(sys: mio::net::UnixStream) -> io::Result<UnixStream> { in connect_mio()
820 pub fn from_std(stream: net::UnixStream) -> io::Result<UnixStream> { in from_std()
865 pub fn into_std(self) -> io::Result<std::os::unix::net::UnixStream> { in into_std()
885 pub(crate) fn new(stream: mio::net::UnixStream) -> io::Result<UnixStream> { in new()
979 impl TryFrom<net::UnixStream> for UnixStream { implementation
991 impl AsyncRead for UnixStream { implementation
1001 impl AsyncWrite for UnixStream { implementation
1032 impl UnixStream { implementation
1065 impl fmt::Debug for UnixStream { implementation
[all …]
|
| D | split_owned.rs | 74 ) -> Result<UnixStream, ReuniteError> { in reunite()
107 pub fn reunite(self, other: OwnedWriteHalf) -> Result<UnixStream, ReuniteError> { in reunite()
261 pub fn reunite(self, other: OwnedReadHalf) -> Result<UnixStream, ReuniteError> { in reunite()
410 fn as_ref(&self) -> &UnixStream { in as_ref()
416 fn as_ref(&self) -> &UnixStream { in as_ref()
|
| D | listener.rs | 186 pub async fn accept(&self) -> io::Result<(UnixStream, SocketAddr)> { in accept()
204 pub fn poll_accept(&self, cx: &mut Context<'_>) -> Poll<io::Result<(UnixStream, SocketAddr)>> { in poll_accept()
|
| D | split.rs | 322 fn as_ref(&self) -> &UnixStream { in as_ref()
328 fn as_ref(&self) -> &UnixStream { in as_ref()
|
| D | socket.rs | 201 pub async fn connect(self, path: impl AsRef<Path>) -> io::Result<UnixStream> { in connect()
|
| /external/crosvm/base/src/sys/linux/ |
| D | notifiers.rs | 11 impl ReadNotifier for UnixStream { implementation
17 impl CloseNotifier for UnixStream { implementation
|
| /external/rust/android-crates-io/crates/mio/src/sys/shell/ |
| D | uds.rs | 28 pub(crate) fn accept(_: &net::UnixListener) -> io::Result<(UnixStream, SocketAddr)> { in accept()
37 pub(crate) fn connect_addr(_: &SocketAddr) -> io::Result<net::UnixStream> { in connect_addr()
|
| /external/rust/android-crates-io/crates/gdbstub/src/conn/impls/ |
| D | unixstream.rs | 11 impl PeekExt for UnixStream { implementation
57 impl Connection for UnixStream { implementation
79 impl ConnectionExt for UnixStream { implementation
|
| /external/rust/android-crates-io/crates/mio/src/sys/unix/uds/ |
| D | stream.rs | 8 pub(crate) fn connect_addr(address: &SocketAddr) -> io::Result<net::UnixStream> { in connect_addr()
|
| D | listener.rs | 24 pub(crate) fn accept(listener: &net::UnixListener) -> io::Result<(UnixStream, SocketAddr)> { in accept()
|
| /external/rust/android-crates-io/crates/tonic/src/transport/server/ |
| D | unix.rs | 22 impl Connected for tokio::net::UnixStream { implementation
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/io/driver/ |
| D | signal.rs | 8 receiver: &mut mio::net::UnixStream, in register_signal_receiver()
|
| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | uds_stream.rs | 280 fn read_until_pending(stream: &mut UnixStream) { in read_until_pending()
293 fn write_until_pending(stream: &mut UnixStream) { in write_until_pending()
|
| /external/rust/android-crates-io/crates/tokio-stream/src/wrappers/ |
| D | unix_listener.rs | 35 ) -> Poll<Option<io::Result<UnixStream>>> { in poll_next()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/connection/sys/linux/ |
| D | stream.rs | 74 stream: UnixStream, in stream_run_with_handler()
|
| /external/rust/android-crates-io/crates/gdbstub/examples/armv4t/ |
| D | main.rs | 40 fn wait_for_uds(path: &str) -> DynResult<UnixStream> { in wait_for_uds()
|
| /external/rust/android-crates-io/crates/gdbstub/examples/armv4t_multicore/ |
| D | main.rs | 41 fn wait_for_uds(path: &str) -> DynResult<UnixStream> { in wait_for_uds()
|
| /external/crosvm/devices/src/ |
| D | serial_device.rs | 74 impl SerialInput for UnixStream {} implementation
91 UnixStream, enumerator
|
| /external/crosvm/base/src/sys/unix/ |
| D | descriptor.rs | 155 impl From<SafeDescriptor> for UnixStream { implementation
|
| /external/crosvm/src/crosvm/sys/linux/ |
| D | device_helpers.rs | 210 fn into_unix_stream(self) -> Result<UnixStream>; in into_unix_stream()
214 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
227 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
232 impl IntoUnixStream for UnixStream { implementation
233 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
|
| /external/rust/crates/vhost-device-vsock/src/ |
| D | thread_backend.rs | 309 stream: UnixStream, in add_new_guest_conn()
|
| /external/rust/android-crates-io/crates/vmm-sys-util/src/linux/ |
| D | sock_ctrl_msg.rs | 426 impl ScmSocket for UnixStream { implementation
|
| /external/rust/android-crates-io/crates/vhost/src/vhost_user/ |
| D | connection.rs | 52 pub fn accept(&self) -> Result<Option<UnixStream>> { in accept()
|