| /external/rust/android-crates-io/crates/mio/src/net/uds/ |
| D | listener.rs | 11 pub struct UnixListener { struct
12 inner: IoSource<net::UnixListener>, argument
15 impl UnixListener { impl
17 pub fn bind<P: AsRef<Path>>(path: P) -> io::Result<UnixListener> { in bind() argument
19 UnixListener::bind_addr(&addr) in bind()
23 pub fn bind_addr(address: &SocketAddr) -> io::Result<UnixListener> { in bind_addr() argument
24 sys::uds::listener::bind_addr(address).map(UnixListener::from_std) in bind_addr()
33 pub fn from_std(listener: net::UnixListener) -> UnixListener { in from_std() argument
34 UnixListener { in from_std()
58 impl event::Source for UnixListener { implementation
[all …]
|
| D | mod.rs | 5 pub use self::listener::UnixListener;
|
| /external/rust/android-crates-io/crates/tokio/src/net/unix/ |
| D | listener.rs | 53 pub struct UnixListener {
54 io: PollEvented<mio::net::UnixListener>,
58 impl UnixListener { impl
59 pub(crate) fn new(listener: mio::net::UnixListener) -> io::Result<UnixListener> { in new() argument
61 Ok(UnixListener { io }) in new()
75 pub fn bind<P>(path: P) -> io::Result<UnixListener> in bind()
92 let listener = mio::net::UnixListener::bind_addr(&addr)?; in bind()
94 Ok(UnixListener { io }) in bind()
135 pub fn from_std(listener: net::UnixListener) -> io::Result<UnixListener> { in from_std() argument
136 let listener = mio::net::UnixListener::from_std(listener); in from_std()
[all …]
|
| D | socket.rs | 6 use crate::net::{UnixDatagram, UnixListener, UnixStream};
171 pub fn listen(self, backlog: u32) -> io::Result<UnixListener> { in listen() argument
184 unsafe { mio::net::UnixListener::from_raw_fd(raw_fd) } in listen()
187 UnixListener::new(mio) in listen()
|
| /external/rust/android-crates-io/crates/tokio-stream/src/wrappers/ |
| D | unix_listener.rs | 5 use tokio::net::{UnixListener, UnixStream};
14 inner: UnixListener,
19 pub fn new(listener: UnixListener) -> Self { in new()
24 pub fn into_inner(self) -> UnixListener { in into_inner() argument
44 impl AsRef<UnixListener> for UnixListenerStream {
45 fn as_ref(&self) -> &UnixListener { in as_ref() argument
50 impl AsMut<UnixListener> for UnixListenerStream {
51 fn as_mut(&mut self) -> &mut UnixListener { in as_mut() argument
|
| /external/rust/android-crates-io/crates/tokio/tests/ |
| D | net_panic.rs | 81 use tokio::net::UnixListener; in unix_listener_bind_panic_caller()
89 let _ = UnixListener::bind(&sock_path); in unix_listener_bind_panic_caller()
103 use tokio::net::UnixListener; in unix_listener_from_std_panic_caller()
107 let std_listener = std::os::unix::net::UnixListener::bind(sock_path).unwrap(); in unix_listener_from_std_panic_caller()
112 let _ = UnixListener::from_std(std_listener); in unix_listener_from_std_panic_caller()
130 let _std_listener = std::os::unix::net::UnixListener::bind(&sock_path).unwrap(); in unix_stream_from_std_panic_caller()
|
| D | uds_stream.rs | 14 use tokio::net::{UnixListener, UnixStream};
27 let listener = UnixListener::bind(&sock_path)?; in accept_read_write()
54 let listener = UnixListener::bind(&sock_path)?; in shutdown()
77 let listener = UnixListener::bind(&bind_path)?; in try_read_write()
200 let listener = assert_ok!(UnixListener::bind(&bind_path)); in create_pair()
314 let listener = UnixListener::bind(&bind_path)?; in try_read_buf()
398 let listener = UnixListener::bind(&sock_path)?; in epollhup()
434 let listener = UnixListener::bind(socket_path).unwrap(); in abstract_socket_name()
|
| D | rt_handle_block_on.rs | 329 let err = net::UnixListener::bind(path).unwrap_err();
349 let listener = net::UnixListener::bind(path).unwrap();
371 let listener = net::UnixListener::bind(path).unwrap();
436 let listener = net::UnixListener::bind(path).unwrap();
|
| D | unwindsafe.rs | 28 is_unwind_safe::<tokio::net::UnixListener>(); in unix_net_types_are_unwind_safe()
|
| /external/rust/android-crates-io/crates/mio/src/sys/shell/ |
| D | uds.rs | 24 pub(crate) fn bind_addr(_: &SocketAddr) -> io::Result<net::UnixListener> { in bind_addr() argument
28 pub(crate) fn accept(_: &net::UnixListener) -> io::Result<(UnixStream, SocketAddr)> { in accept()
|
| /external/rust/android-crates-io/crates/mio/src/sys/unix/uds/ |
| D | listener.rs | 12 pub(crate) fn bind_addr(address: &SocketAddr) -> io::Result<net::UnixListener> { in bind_addr() argument
14 let socket = unsafe { net::UnixListener::from_raw_fd(fd) }; in bind_addr()
24 pub(crate) fn accept(listener: &net::UnixListener) -> io::Result<(UnixStream, SocketAddr)> { in accept()
|
| /external/crosvm/base/src/sys/linux/ |
| D | mod.rs | 53 use std::os::unix::net::UnixListener;
438 pub struct UnlinkUnixListener(pub UnixListener);
440 impl AsRef<UnixListener> for UnlinkUnixListener {
441 fn as_ref(&self) -> &UnixListener { in as_ref() argument
447 type Target = UnixListener;
449 fn deref(&self) -> &UnixListener { in deref() argument
|
| D | net.rs | 11 use std::os::unix::net::UnixListener;
180 ScmSocketTryFrom!(UnixListener);
|
| /external/rust/android-crates-io/crates/mio/src/net/ |
| D | mod.rs | 39 pub use self::uds::{UnixDatagram, UnixListener, UnixStream};
|
| /external/rust/android-crates-io/crates/tokio-util/src/net/unix/ |
| D | mod.rs | 7 impl Listener for tokio::net::UnixListener { implementation
|
| /external/crosvm/base/src/sys/unix/ |
| D | descriptor.rs | 20 use std::os::unix::net::UnixListener;
227 AsRawDescriptor!(UnixListener);
|
| /external/rust/android-crates-io/crates/tokio/src/net/ |
| D | mod.rs | 57 pub use unix::listener::UnixListener;
|
| /external/rust/android-crates-io/crates/gdbstub/examples/armv4t/ |
| D | main.rs | 16 use std::os::unix::net::UnixListener;
51 let sock = UnixListener::bind(path)?; in wait_for_uds()
|
| /external/crosvm/base/src/sys/macos/ |
| D | net.rs | 11 use std::os::unix::net::UnixListener;
78 ScmSocketTryFrom!(UnixListener);
|
| /external/rust/android-crates-io/crates/gdbstub/examples/armv4t_multicore/ |
| D | main.rs | 17 use std::os::unix::net::UnixListener;
52 let sock = UnixListener::bind(path)?; in wait_for_uds()
|
| /external/rust/android-crates-io/crates/tempfile/tests/ |
| D | namedtempfile.rs | 402 use std::os::unix::net::UnixListener; in test_make_uds()
408 .make(|path| UnixListener::bind(path)) in test_make_uds()
417 use std::os::unix::net::UnixListener; in test_make_uds_conflict()
443 UnixListener::bind(path) in test_make_uds_conflict()
|
| /external/crosvm/third_party/vmm_vhost/src/sys/ |
| D | unix.rs | 12 use std::os::unix::net::UnixListener;
34 pub type SystemListener = UnixListener;
|
| /external/rust/android-crates-io/crates/vhost-user-backend/src/ |
| D | lib.rs | 254 use std::os::unix::net::{UnixListener, UnixStream};
309 let listener = UnixListener::bind(&path).unwrap(); in test_new_daemon_client()
|
| /external/rust/android-crates-io/crates/vhost/src/vhost_user/ |
| D | connection.rs | 12 use std::os::unix::net::{UnixListener, UnixStream};
25 fd: UnixListener,
39 let fd = UnixListener::bind(&path).map_err(Error::SocketError)?; in new()
90 fd: UnixListener::from_raw_fd(fd), in from_raw_fd()
|
| /external/rust/crates/vhost-device-vsock/src/ |
| D | vhu_vsock_thread.rs | 12 net::{UnixListener, UnixStream},
65 host_listener: UnixListener,
97 let host_sock = UnixListener::bind(&uds_path) in new()
|