| /external/rust/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()
37 pub fn from_std(stream: net::UnixStream) -> UnixStream { in from_std()
145 impl Read for UnixStream { implementation
155 impl<'a> Read for &'a UnixStream { implementation
165 impl Write for UnixStream { implementation
179 impl<'a> Write for &'a UnixStream { implementation
193 impl event::Source for UnixStream { implementation
[all …]
|
| D | listener.rs | 37 pub fn accept(&self) -> io::Result<(UnixStream, SocketAddr)> { in accept()
|
| /external/rust/crates/tokio/src/net/unix/ |
| D | stream.rs | 41 impl UnixStream { implementation
783 pub fn from_std(stream: net::UnixStream) -> io::Result<UnixStream> { in from_std()
828 pub fn into_std(self) -> io::Result<std::os::unix::net::UnixStream> { in into_std()
848 pub(crate) fn new(stream: mio::net::UnixStream) -> io::Result<UnixStream> { in new()
942 impl TryFrom<net::UnixStream> for UnixStream { implementation
954 impl AsyncRead for UnixStream { implementation
964 impl AsyncWrite for UnixStream { implementation
995 impl UnixStream { impl
1028 impl fmt::Debug for UnixStream { implementation
1034 impl AsRawFd 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 | 162 pub async fn accept(&self) -> io::Result<(UnixStream, SocketAddr)> { in accept()
180 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()
|
| /external/crosvm/base/src/sys/linux/ |
| D | notifiers.rs | 11 impl ReadNotifier for UnixStream { implementation
17 impl CloseNotifier for UnixStream { implementation
|
| /external/rust/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/crates/mio/src/sys/shell/ |
| D | uds.rs | 45 pub(crate) fn accept(_: &net::UnixListener) -> io::Result<(UnixStream, SocketAddr)> { in accept()
60 pub(crate) fn connect(_: &Path) -> io::Result<net::UnixStream> { in connect()
|
| /external/rust/crates/tonic/src/transport/server/ |
| D | unix.rs | 22 impl Connected for tokio::net::UnixStream { implementation
|
| /external/rust/crates/tokio/src/runtime/io/driver/ |
| D | signal.rs | 8 receiver: &mut mio::net::UnixStream, in register_signal_receiver()
|
| /external/rust/crates/mio/src/sys/unix/uds/ |
| D | stream.rs | 9 pub(crate) fn connect(path: &Path) -> io::Result<net::UnixStream> { in connect()
|
| D | listener.rs | 21 pub(crate) fn accept(listener: &net::UnixListener) -> io::Result<(UnixStream, SocketAddr)> { in accept()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/handler/sys/ |
| D | linux.rs | 75 pub(crate) fn connect(dir: tempfile::TempDir) -> UnixStream { in connect()
|
| /external/rust/crates/tokio/tests/ |
| D | uds_stream.rs | 275 fn read_until_pending(stream: &mut UnixStream) { in read_until_pending()
288 fn write_until_pending(stream: &mut UnixStream) { in write_until_pending()
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | unix_listener.rs | 35 ) -> Poll<Option<io::Result<UnixStream>>> { in poll_next()
|
| /external/rust/crates/gdbstub/examples/armv4t/ |
| D | main.rs | 40 fn wait_for_uds(path: &str) -> DynResult<UnixStream> { in wait_for_uds()
|
| /external/rust/crates/gdbstub/examples/armv4t_multicore/ |
| D | main.rs | 41 fn wait_for_uds(path: &str) -> DynResult<UnixStream> { in wait_for_uds()
|
| /external/crosvm/src/crosvm/sys/linux/ |
| D | device_helpers.rs | 145 fn into_unix_stream(self) -> Result<UnixStream>; in into_unix_stream()
149 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
162 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
167 impl IntoUnixStream for UnixStream { implementation
168 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
326 fn vhost_user_connection(path: &Path) -> Result<UnixStream> { in vhost_user_connection()
|
| /external/crosvm/base/src/sys/unix/ |
| D | descriptor.rs | 155 impl From<SafeDescriptor> for UnixStream { implementation
|
| /external/rust/crates/vhost-device-vsock/src/ |
| D | thread_backend.rs | 309 stream: UnixStream, in add_new_guest_conn()
|
| /external/rust/crates/vmm-sys-util/src/linux/ |
| D | sock_ctrl_msg.rs | 426 impl ScmSocket for UnixStream { implementation
|
| /external/rust/crates/vhost-user-backend/src/vhost_user/ |
| D | connection.rs | 52 pub fn accept(&self) -> Result<Option<UnixStream>> { in accept()
|
| D | master.rs | 110 pub fn from_stream(sock: UnixStream, max_queue_num: u64) -> Self { in from_stream()
|
| /external/rust/crates/vhost/src/vhost_user/ |
| D | connection.rs | 52 pub fn accept(&self) -> Result<Option<UnixStream>> { in accept()
|