Home
last modified time | relevance | path

Searched defs:UnixStream (Results 1 – 18 of 18) sorted by relevance

/external/rust/crates/mio/src/net/uds/
Dstream.rs12 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 …]
Dlistener.rs37 pub fn accept(&self) -> io::Result<(UnixStream, SocketAddr)> { in accept()
/external/rust/crates/tokio/src/net/unix/
Dstream.rs41 impl UnixStream { implementation
747 pub fn from_std(stream: net::UnixStream) -> io::Result<UnixStream> { in from_std()
792 pub fn into_std(self) -> io::Result<std::os::unix::net::UnixStream> { in into_std()
812 pub(crate) fn new(stream: mio::net::UnixStream) -> io::Result<UnixStream> { in new()
906 impl TryFrom<net::UnixStream> for UnixStream { implementation
918 impl AsyncRead for UnixStream { implementation
928 impl AsyncWrite for UnixStream { implementation
959 impl UnixStream { implementation
992 impl fmt::Debug for UnixStream { implementation
998 impl AsRawFd for UnixStream { implementation
Dsplit_owned.rs74 ) -> Result<UnixStream, ReuniteError> { in reunite()
107 pub fn reunite(self, other: OwnedWriteHalf) -> Result<UnixStream, ReuniteError> { in reunite()
256 pub fn reunite(self, other: OwnedReadHalf) -> Result<UnixStream, ReuniteError> { in reunite()
400 fn as_ref(&self) -> &UnixStream { in as_ref()
406 fn as_ref(&self) -> &UnixStream { in as_ref()
Dlistener.rs162 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()
Dsplit.rs306 fn as_ref(&self) -> &UnixStream { in as_ref()
312 fn as_ref(&self) -> &UnixStream { in as_ref()
/external/crosvm/base/src/sys/unix/
Dnotifiers.rs11 impl ReadNotifier for UnixStream { implementation
17 impl CloseNotifier for UnixStream { implementation
Ddescriptor.rs161 impl From<SafeDescriptor> for UnixStream { implementation
Dsock_ctrl_msg.rs357 impl ScmSocket for UnixStream { implementation
/external/rust/crates/gdbstub/src/conn/impls/
Dunixstream.rs12 impl PeekExt for UnixStream { implementation
58 impl Connection for UnixStream { implementation
80 impl ConnectionExt for UnixStream { implementation
/external/rust/crates/mio/src/sys/shell/
Duds.rs45 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/mio/src/sys/unix/uds/
Dstream.rs9 pub(crate) fn connect(path: &Path) -> io::Result<net::UnixStream> { in connect()
Dlistener.rs21 pub(crate) fn accept(listener: &net::UnixListener) -> io::Result<(UnixStream, SocketAddr)> { in accept()
/external/rust/crates/tokio/tests/
Duds_stream.rs275 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/
Dunix_listener.rs35 ) -> Poll<Option<io::Result<UnixStream>>> { in poll_next()
/external/rust/crates/gdbstub/examples/armv4t/
Dmain.rs36 fn wait_for_uds(path: &str) -> DynResult<UnixStream> { in wait_for_uds()
/external/rust/crates/gdbstub/examples/armv4t_multicore/
Dmain.rs36 fn wait_for_uds(path: &str) -> DynResult<UnixStream> { in wait_for_uds()
/external/crosvm/src/crosvm/sys/unix/
Ddevice_helpers.rs116 fn into_unix_stream(self) -> Result<UnixStream>; in into_unix_stream()
120 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
130 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
135 impl IntoUnixStream for UnixStream { implementation
136 fn into_unix_stream(self) -> Result<UnixStream> { in into_unix_stream()
273 fn vhost_user_connection(path: &Path) -> Result<UnixStream> { in vhost_user_connection()