| /external/crosvm/base/tests/unix/ |
| D | net.rs | 9 use base::UnixSeqpacket;
16 let res = UnixSeqpacket::connect("/path/not/exists"); in unix_seqpacket_path_not_exists()
48 let s1 = UnixSeqpacket::connect(socket_path.as_path()).expect("UnixSeqpacket::connect failed"); in unix_seqpacket_listener_from_fd()
63 UnixSeqpacket::connect(socket_path.as_path()).expect("UnixSeqpacket::connect failed"); in unix_seqpacket_path_exists_pass()
80 let s1 = UnixSeqpacket::connect(socket_path.as_path()) in unix_seqpacket_path_listener_accept_with_timeout()
106 let s1 = UnixSeqpacket::connect(socket_path.as_path()).expect("UnixSeqpacket::connect failed"); in unix_seqpacket_path_listener_accept()
123 let (s1, _s2) = UnixSeqpacket::pair().expect("failed to create socket pair"); in unix_seqpacket_zero_timeout()
131 let (s1, _s2) = UnixSeqpacket::pair().expect("failed to create socket pair"); in unix_seqpacket_read_timeout()
139 let (s1, _s2) = UnixSeqpacket::pair().expect("failed to create socket pair"); in unix_seqpacket_write_timeout()
146 let (s1, s2) = UnixSeqpacket::pair().expect("failed to create socket pair"); in unix_seqpacket_send_recv()
[all …]
|
| D | tube.rs | 18 use base::UnixSeqpacket;
69 let (sock_send, sock_recv) = UnixSeqpacket::pair().unwrap(); in test_send_recv_new_from_seqpacket()
|
| /external/crosvm/base/src/sys/unix/ |
| D | net.rs | 366 pub struct UnixSeqpacket(SafeDescriptor); struct
370 unsafe impl Send for UnixSeqpacket {} implementation
372 impl UnixSeqpacket { impl
398 Ok(UnixSeqpacket(descriptor)) in connect()
404 pub fn pair() -> io::Result<(UnixSeqpacket, UnixSeqpacket)> { in pair()
406 .map(|(s0, s1)| (UnixSeqpacket::from(s0), UnixSeqpacket::from(s1))) in pair()
620 impl From<UnixSeqpacket> for SafeDescriptor {
621 fn from(s: UnixSeqpacket) -> Self { in from()
626 impl From<SafeDescriptor> for UnixSeqpacket { implementation
632 impl FromRawDescriptor for UnixSeqpacket { implementation
[all …]
|
| D | stream_channel.rs | 16 use super::super::net::UnixSeqpacket;
54 Message(UnixSeqpacket),
138 let (pipe_a, pipe_b) = UnixSeqpacket::pair()?; in pair()
150 pub fn from_unix_seqpacket(sock: UnixSeqpacket) -> StreamChannel { in from_unix_seqpacket()
380 let (sock_sender, sock_receiver) = UnixSeqpacket::pair().unwrap(); in test_from_unix_seqpacket()
|
| D | tube.rs | 30 use crate::UnixSeqpacket;
64 pub fn new_from_unix_seqpacket(sock: UnixSeqpacket) -> Tube { in new_from_unix_seqpacket()
|
| D | sock_ctrl_msg.rs | 36 use super::net::UnixSeqpacket;
363 impl ScmSocket for UnixSeqpacket { implementation
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | shm_vios.rs | 35 use base::UnixSeqpacket;
136 control_socket: Mutex<UnixSeqpacket>,
137 event_socket: UnixSeqpacket,
154 let client_socket = UnixSeqpacket::connect(server.as_ref()) in try_new()
209 let rx_socket = pop::<UnixSeqpacket>(&mut safe_fds, NUM_FDS, fd_count)?; in try_new()
210 let tx_socket = pop::<UnixSeqpacket>(&mut safe_fds, NUM_FDS, fd_count)?; in try_new()
211 let event_socket = pop::<UnixSeqpacket>(&mut safe_fds, NUM_FDS, fd_count)?; in try_new()
562 socket: &UnixSeqpacket, in recv_buffer_status_msg() argument
602 fn recv_event(socket: &UnixSeqpacket) -> Result<virtio_snd_event> { in recv_event()
621 tx_socket: UnixSeqpacket, in spawn_recv_thread() argument
[all …]
|
| /external/crosvm/cros_async/src/ |
| D | io_ext.rs | 13 use base::UnixSeqpacket;
111 impl IntoAsync for UnixSeqpacket {} implementation
|
| /external/crosvm/vm_control/src/sys/ |
| D | unix.rs | 19 use base::UnixSeqpacket;
38 match UnixSeqpacket::connect(&socket_path) { in handle_request()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/ |
| D | wl.rs | 24 use base::UnixSeqpacket;
381 match UnixSeqpacket::connect(&p) { in run_wl_device()
|
| /external/crosvm/base/src/ |
| D | lib.rs | 109 net::{UnixSeqpacket, UnixSeqpacketListener, UnlinkUnixSeqpacketListener},
|
| /external/crosvm/src/crosvm/sys/unix/ |
| D | gpu.rs | 221 UnixSeqpacket::pair().context("failed to create render server socket")?; in start_gpu_render_server()
|
| /external/crosvm/src/crosvm/sys/ |
| D | unix.rs | 56 use base::UnixSeqpacket;
1625 UnixSeqpacket::connect(path).with_context(|| { in run_vm()
2599 let sock = UnixSeqpacket::connect(addr.clone()).with_context(|| { in run_control()
|