| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | stream.rs | 24 pub struct UnixStream { struct
28 impl UnixStream { implementation
56 pub fn from_std(stream: net::UnixStream) -> UnixStream { in from_std() argument
71 pub fn pair() -> io::Result<(UnixStream, UnixStream)> { in pair()
73 (UnixStream::from_std(stream1), UnixStream::from_std(stream2)) in pair()
162 impl Read for UnixStream { implementation
172 impl Write for UnixStream { implementation
185 impl Read for &UnixStream { implementation
197 impl Write for &UnixStream { implementation
214 impl Debug for UnixStream { implementation
[all …]
|
| H A D | listener.rs | 24 use crate::{Interest, Selector, Source, Token, UnixStream};
61 pub fn accept(&self) -> io::Result<(UnixStream, SocketAddr)> { in accept() argument
75 .map(|socket| unsafe { net::UnixStream::from_raw_fd(socket) })? in accept()
86 let socket = unsafe { net::UnixStream::from_raw_fd(socket) }; in accept()
87 Ok::<net::UnixStream, io::Error>(socket) in accept()
92 UnixStream::from_std(socket), in accept()
|
| H A D | socket.rs | 40 pub(crate) fn connect(path: &Path) -> io::Result<net::UnixStream> { in connect() argument
45 let net = unsafe { net::UnixStream::from_raw_fd(socket) }; in connect()
69 pub(crate) fn stream_pair() -> io::Result<(net::UnixStream, net::UnixStream)> { in stream_pair()
|
| H A D | mod.rs | 20 pub use stream::UnixStream;
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | stream.rs | 29 pub struct UnixStream { struct
33 impl UnixStream { implementation
36 Ok(UnixStream { in new()
55 let stream = UnixStream::new(ylong_io::UnixStream::connect(path)?)?; in connect()
89 pub fn from_std(listener: net::UnixStream) -> Result<UnixStream> { in from_std() argument
91 Ok(UnixStream { in from_std()
111 pub fn pair() -> Result<(UnixStream, UnixStream)> { in pair()
337 impl AsyncRead for UnixStream { implementation
380 impl AsRawFd for UnixStream { implementation
386 impl AsFd for UnixStream { implementation
[all …]
|
| H A D | listener.rs | 22 use crate::net::{AsyncSource, UnixStream};
66 pub async fn accept(&self) -> Result<(UnixStream, SocketAddr)> { in accept() argument
72 let stream = UnixStream::new(stream)?; in accept()
134 use crate::net::{UnixListener, UnixStream};
183 let mut stream = UnixStream::connect(PATH).await; in ut_uds_listener_read_write_test()
185 stream = UnixStream::connect(PATH).await; in ut_uds_listener_read_write_test()
|
| H A D | mod.rs | 21 pub use stream::UnixStream;
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | registry.rs | 22 use ylong_io::UnixStream;
69 sender: UnixStream,
70 receiver: UnixStream,
75 let (sender, receiver) = UnixStream::pair() in default()
146 pub(crate) fn try_clone_stream(&self) -> io::Result<UnixStream> { in try_clone_stream() argument
|
| H A D | driver.rs | 16 use ylong_io::{Interest, UnixStream};
24 receiver: UnixStream,
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | uds_test.rs | 20 use ylong_runtime::net::{UnixDatagram, UnixListener, UnixStream};
56 if let Ok(mut stream) = UnixStream::connect(PATH).await { in sdv_uds_stream_test()
136 let (server, client) = UnixStream::pair().unwrap(); in sdv_uds_stream_try_test()
243 let (stream, _) = std::os::unix::net::UnixStream::pair().unwrap(); in sdv_uds_stream_baisc_test()
245 let res = UnixStream::from_std(stream); in sdv_uds_stream_baisc_test()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_uds.rs | 94 let mut uds = UnixStream::connect(addr.clone()).await;
96 uds = UnixStream::connect(addr.clone()).await;
139 use tokio::net::{UnixListener as tokioUnixListener, UnixStream as tokioUnixStream};
141 use ylong_runtime::net::{UnixListener, UnixStream};
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | mod.rs | 25 pub use unix::{UnixDatagram, UnixListener, UnixStream};
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | uds_test.rs | 23 use ylong_io::{EventTrait, Events, Interest, Poll, Token, UnixDatagram, UnixListener, UnixStream};
42 if let Ok(stream) = UnixStream::connect(PATH) { in sdv_uds_stream_test()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | mod.rs | 35 pub use sys::{UnixDatagram, UnixListener, UnixStream};
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| H A D | lib.rs | 27 pub use sys::{SocketAddr, UnixDatagram, UnixListener, UnixStream};
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| H A D | mod.rs | 38 pub use uds::{SocketAddr, UnixDatagram, UnixListener, UnixStream};
|