| /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
18 pub fn connect<P: AsRef<Path>>(path: P) -> io::Result<UnixStream> { in connect()
34 pub fn from_std(stream: net::UnixStream) -> UnixStream { in from_std()
74 impl Read for UnixStream { implementation
84 impl<'a> Read for &'a UnixStream { implementation
94 impl Write for UnixStream { implementation
108 impl<'a> Write for &'a UnixStream { implementation
122 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 | 40 impl UnixStream { impl
504 pub fn from_std(stream: net::UnixStream) -> io::Result<UnixStream> { in from_std()
549 pub fn into_std(self) -> io::Result<std::os::unix::net::UnixStream> { in into_std()
569 pub(crate) fn new(stream: mio::net::UnixStream) -> io::Result<UnixStream> { in new()
633 impl TryFrom<net::UnixStream> for UnixStream { implementation
645 impl AsyncRead for UnixStream { implementation
655 impl AsyncWrite for UnixStream { implementation
686 impl UnixStream { implementation
724 impl fmt::Debug for UnixStream { implementation
730 impl AsRawFd for UnixStream { implementation
|
| D | split_owned.rs | 69 ) -> Result<UnixStream, ReuniteError> { in reunite()
102 pub fn reunite(self, other: OwnedWriteHalf) -> Result<UnixStream, ReuniteError> { in reunite()
123 pub fn reunite(self, other: OwnedReadHalf) -> Result<UnixStream, ReuniteError> { in reunite()
182 fn as_ref(&self) -> &UnixStream { in as_ref()
188 fn as_ref(&self) -> &UnixStream { in as_ref()
|
| D | listener.rs | 131 pub async fn accept(&self) -> io::Result<(UnixStream, SocketAddr)> { in accept()
149 pub fn poll_accept(&self, cx: &mut Context<'_>) -> Poll<io::Result<(UnixStream, SocketAddr)>> { in poll_accept()
|
| D | split.rs | 91 fn as_ref(&self) -> &UnixStream { in as_ref()
97 fn as_ref(&self) -> &UnixStream { in as_ref()
|
| /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/gdbstub/src/connection/impls/ |
| D | unixstream.rs | 13 impl PeekExt for UnixStream { implementation
49 impl Connection for UnixStream { implementation
|
| /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 | 25 pub(crate) fn accept(listener: &net::UnixListener) -> io::Result<(UnixStream, SocketAddr)> { in accept()
|
| /external/rust/crates/tokio/tests/ |
| D | uds_stream.rs | 230 fn read_until_pending(stream: &mut UnixStream) { in read_until_pending()
243 fn write_until_pending(stream: &mut UnixStream) { in write_until_pending()
|
| /external/rust/crates/gdbstub/examples/armv4t/ |
| D | main.rs | 28 fn wait_for_uds(path: &str) -> DynResult<UnixStream> { in wait_for_uds()
|
| /external/rust/crates/gdbstub/examples/armv4t_multicore/ |
| D | main.rs | 28 fn wait_for_uds(path: &str) -> DynResult<UnixStream> { in wait_for_uds()
|
| /external/rust/crates/tokio-stream/src/wrappers/ |
| D | unix_listener.rs | 35 ) -> Poll<Option<io::Result<UnixStream>>> { in poll_next()
|
| /external/crosvm/src/ |
| D | linux.rs | 1770 fn into_unix_stream(self) -> Result<UnixStream>; in into_unix_stream()
1774 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
1784 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
1789 impl IntoUnixStream for UnixStream { implementation
1790 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
|
| /external/crosvm/sys_util/src/ |
| D | descriptor.rs | 236 impl AsRawDescriptor for UnixStream { implementation
|
| D | sock_ctrl_msg.rs | 348 impl ScmSocket for UnixStream { implementation
|
| /external/rust/crates/vmm_vhost/src/vhost_user/ |
| D | connection.rs | 50 pub fn accept(&self) -> Result<Option<UnixStream>> { in accept()
|
| D | master.rs | 96 pub fn from_stream(sock: UnixStream, max_queue_num: u64) -> Self { in from_stream()
|