Home
last modified time | relevance | path

Searched refs:UnixStream (Results 1 - 16 of 16) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Dstream.rs29 pub struct UnixStream { structure names
30 source: AsyncSource<ylong_io::UnixStream>,
33 impl UnixStream { impls
34 /// Creates a new `UnixStream` from `ylong_io::UnixStream`
35 pub(crate) fn new(stream: ylong_io::UnixStream) -> Result<Self> {
36 Ok(UnixStream {
47 /// use ylong_runtime::net::UnixStream;
50 /// let mut stream = UnixStream::connect("/tmp/sock").await?;
54 pub async fn connect<P: AsRef<Path>>(path: P) -> Result<UnixStream> {
[all...]
H A Dlistener.rs22 use crate::net::{AsyncSource, UnixStream};
66 pub async fn accept(&self) -> Result<(UnixStream, SocketAddr)> {
72 let stream = UnixStream::new(stream)?;
H A Dmod.rs21 pub use stream::UnixStream;
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
H A Dstream.rs24 pub struct UnixStream { structure names
25 pub(crate) inner: net::UnixStream,
28 impl UnixStream { impls
33 /// use ylong_io::UnixStream;
35 /// if let Ok(sock) = UnixStream::connect("/tmp/sock") {
39 pub fn connect<P: AsRef<Path>>(path: P) -> io::Result<UnixStream> { in connect()
40 super::socket::connect(path.as_ref()).map(UnixStream::from_std) in connect()
43 /// Creates a new `UnixStream` from a standard `net::UnixStream`
47 /// use std::os::unix::net::UnixStream;
[all...]
H A Dlistener.rs24 use crate::{Interest, Selector, Source, Token, UnixStream};
61 pub fn accept(&self) -> io::Result<(UnixStream, SocketAddr)> { in accept()
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 Dsocket.rs40 pub(crate) fn connect(path: &Path) -> io::Result<net::UnixStream> {
45 let net = unsafe { net::UnixStream::from_raw_fd(socket) };
69 pub(crate) fn stream_pair() -> io::Result<(net::UnixStream, net::UnixStream)> {
H A Dmod.rs20 pub use stream::UnixStream;
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Duds_test.rs19 use ylong_runtime::net::{UnixDatagram, UnixStream};
21 /// Uds UnixStream try_xxx() test case.
34 let (server, client) = UnixStream::pair().unwrap(); in sdv_uds_stream_try_test()
105 /// Uds UnixStream test case.
111 /// 1. Create a std UnixStream with `pair()`.
112 /// 2. Convert std UnixStream to Ylong_runtime UnixStream.
116 let (stream, _) = std::os::unix::net::UnixStream::pair().unwrap(); in sdv_uds_stream_baisc_test()
118 let res = UnixStream::from_std(stream); in sdv_uds_stream_baisc_test()
H A Duds_cargo_test.rs21 use ylong_runtime::net::{UnixDatagram, UnixListener, UnixStream};
64 let mut stream = UnixStream::connect(PATH).await; in sdv_uds_listener_read_write_test()
66 stream = UnixStream::connect(PATH).await; in sdv_uds_listener_read_write_test()
93 /// uds UnixListener/UnixStream test case.
127 if let Ok(mut stream) = UnixStream::connect(PATH).await { in sdv_uds_stream_test()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/
H A Ddriver.rs16 use ylong_io::{Interest, UnixStream};
24 receiver: UnixStream,
55 .unwrap_or_else(|e| panic!("Signal failed to clone UnixStream, {e}"));
77 .unwrap_or_else(|e| panic!("Signal failed to clone UnixStream, {e}"));
H A Dregistry.rs22 use ylong_io::UnixStream;
69 sender: UnixStream,
70 receiver: UnixStream,
75 let (sender, receiver) = UnixStream::pair() in default()
76 .unwrap_or_else(|e| panic!("failed to create a pair of UnixStream, error: {e}")); in default()
146 pub(crate) fn try_clone_stream(&self) -> io::Result<UnixStream> {
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_uds.rs94 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};
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
H A Dmod.rs25 pub use unix::{UnixDatagram, UnixListener, UnixStream};
/commonlibrary/rust/ylong_runtime/ylong_io/src/
H A Dlib.rs27 pub use sys::{SocketAddr, UnixDatagram, UnixListener, UnixStream};
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/
H A Dmod.rs38 pub use uds::{SocketAddr, UnixDatagram, UnixListener, UnixStream};
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Duds_test.rs23 use ylong_io::{EventTrait, Events, Interest, Poll, Token, UnixDatagram, UnixListener, UnixStream};
28 /// SDV test for UnixStream.
31 /// 1. Create a pair of UnixStream.
42 if let Ok(stream) = UnixStream::connect(PATH) { in sdv_uds_stream_test()

Completed in 5 milliseconds