| /external/crosvm/base/tests/linux/ |
| D | net.rs | 9 use base::UnixSeqpacket;
16 let res = UnixSeqpacket::connect("/path/not/exists"); in unix_seqpacket_path_not_exists()
49 let s1 = UnixSeqpacket::connect(socket_path.as_path()).expect("UnixSeqpacket::connect failed"); in unix_seqpacket_listener_from_fd()
65 UnixSeqpacket::connect(socket_path.as_path()).expect("UnixSeqpacket::connect failed"); in unix_seqpacket_path_exists_pass()
82 let s1 = UnixSeqpacket::connect(socket_path.as_path()) in unix_seqpacket_path_listener_accept_with_timeout()
108 let s1 = UnixSeqpacket::connect(socket_path.as_path()).expect("UnixSeqpacket::connect failed"); in unix_seqpacket_path_listener_accept()
125 let (s1, _s2) = UnixSeqpacket::pair().expect("failed to create socket pair"); in unix_seqpacket_zero_timeout()
133 let (s1, _s2) = UnixSeqpacket::pair().expect("failed to create socket pair"); in unix_seqpacket_read_timeout()
141 let (s1, _s2) = UnixSeqpacket::pair().expect("failed to create socket pair"); in unix_seqpacket_write_timeout()
148 let (s1, s2) = UnixSeqpacket::pair().expect("failed to create socket pair"); in unix_seqpacket_send_recv()
[all …]
|
| D | tube.rs | 15 use base::UnixSeqpacket;
60 let (sock_send, sock_recv) = UnixSeqpacket::pair().unwrap(); in test_send_recv_from_seqpacket()
|
| /external/crosvm/base/src/sys/linux/ |
| D | net.rs | 40 use crate::UnixSeqpacket;
129 impl UnixSeqpacket { implementation
133 pub fn pair() -> io::Result<(UnixSeqpacket, UnixSeqpacket)> { in pair()
135 .map(|(s0, s1)| (UnixSeqpacket::from(s0), UnixSeqpacket::from(s1))) in pair()
144 pub fn accept(&self) -> io::Result<UnixSeqpacket> { in accept() argument
157 Ok(UnixSeqpacket::from( in accept()
181 ScmSocketTryFrom!(UnixSeqpacket);
|
| /external/crosvm/base/src/sys/macos/ |
| D | net.rs | 44 use crate::UnixSeqpacket;
79 ScmSocketTryFrom!(UnixSeqpacket);
177 impl UnixSeqpacket { implementation
181 pub fn pair() -> io::Result<(UnixSeqpacket, UnixSeqpacket)> { in pair()
183 let (s0, s1) = (UnixSeqpacket::from(fd0), UnixSeqpacket::from(fd1)); in pair()
193 pub fn accept(&self) -> io::Result<UnixSeqpacket> { in accept() argument
202 Ok(UnixSeqpacket::from(cloexec_or_close(safe_desc)?)) in accept()
|
| /external/crosvm/devices/src/virtio/snd/vios_backend/ |
| D | shm_vios.rs | 33 use base::UnixSeqpacket;
141 control_socket: Mutex<UnixSeqpacket>,
142 event_socket: UnixSeqpacket,
172 UnixSeqpacket::connect(server.as_ref()) in try_new()
218 let rx_socket = pop::<UnixSeqpacket>(&mut safe_fds, NUM_FDS, fd_count)?; in try_new()
219 let tx_socket = pop::<UnixSeqpacket>(&mut safe_fds, NUM_FDS, fd_count)?; in try_new()
220 let event_socket = pop::<UnixSeqpacket>(&mut safe_fds, NUM_FDS, fd_count)?; in try_new()
629 socket: &UnixSeqpacket, in recv_buffer_status_msg() argument
669 fn recv_event(socket: &UnixSeqpacket) -> Result<virtio_snd_event> { in recv_event()
688 tx_socket: UnixSeqpacket, in spawn_recv_thread() argument
[all …]
|
| /external/crosvm/base/src/sys/unix/ |
| D | net.rs | 298 pub struct UnixSeqpacket(SafeDescriptor); struct
300 impl UnixSeqpacket { impl
327 Ok(UnixSeqpacket(descriptor)) in connect()
529 impl From<UnixSeqpacket> for SafeDescriptor {
530 fn from(s: UnixSeqpacket) -> Self { in from()
535 impl From<SafeDescriptor> for UnixSeqpacket { implementation
541 impl FromRawDescriptor for UnixSeqpacket { implementation
547 impl AsRawDescriptor for UnixSeqpacket { implementation
553 impl IntoRawDescriptor for UnixSeqpacket { implementation
559 impl io::Read for UnixSeqpacket { implementation
[all …]
|
| D | tube.rs | 24 use crate::UnixSeqpacket;
33 socket: ScmSocket<UnixSeqpacket>,
40 let (socket1, socket2) = UnixSeqpacket::pair().map_err(Error::Pair)?; in pair()
164 impl TryFrom<UnixSeqpacket> for Tube {
167 fn try_from(socket: UnixSeqpacket) -> Result<Self> { in try_from()
|
| D | stream_channel.rs | 16 use super::super::net::UnixSeqpacket;
55 Message(UnixSeqpacket),
149 let (pipe_a, pipe_b) = UnixSeqpacket::pair()?; in pair()
|
| /external/crosvm/cros_async/src/ |
| D | io_ext.rs | 13 use base::UnixSeqpacket;
50 impl IntoAsync for UnixSeqpacket {} implementation
|
| /external/crosvm/vm_control/src/sys/ |
| D | linux.rs | 20 use base::UnixSeqpacket;
50 match UnixSeqpacket::connect(&socket_path) { in handle_request_with_timeout()
|
| /external/crosvm/devices/src/virtio/vhost/user/device/ |
| D | wl.rs | 23 use base::UnixSeqpacket;
363 match UnixSeqpacket::connect(&p) { in run_wl_device()
|
| /external/crosvm/base/src/ |
| D | lib.rs | 160 pub use unix::net::UnixSeqpacket;
|
| /external/crosvm/src/crosvm/sys/linux/ |
| D | gpu.rs | 292 UnixSeqpacket::pair().context("failed to create render server socket")?; in start_gpu_render_server()
|
| /external/crosvm/src/crosvm/sys/ |
| D | linux.rs | 76 use base::UnixSeqpacket;
683 Tube::try_from(UnixSeqpacket::connect(path).with_context(|| { in create_virtio_devices()
3496 let sock = UnixSeqpacket::connect(addr.clone()).with_context(|| { in make_addr_tube_from_maybe_existing()
|