1use std::io;
2use std::os::fd::FromRawFd;
3use std::os::unix::net::{self, SocketAddr};
4
5use crate::sys::unix::net::new_socket;
6use crate::sys::unix::uds::unix_addr;
7
8pub(crate) fn connect_addr(address: &SocketAddr) -> io::Result<net::UnixStream> {
9 let fd: i32 = new_socket(domain:libc::AF_UNIX, socket_type:libc::SOCK_STREAM)?;
10 let socket: UnixStream = unsafe { net::UnixStream::from_raw_fd(fd) };
11
12 let (unix_address: sockaddr_un, addrlen: u32) = unix_addr(address);
13 let sockaddr: *const sockaddr = &unix_address as *const libc::sockaddr_un as *const libc::sockaddr;
14 match syscall!(connect(fd, sockaddr, addrlen)) {
15 Ok(_) => {}
16 Err(ref err: &Error) if err.raw_os_error() == Some(libc::EINPROGRESS) => {}
17 Err(e: Error) => return Err(e),
18 }
19
20 Ok(socket)
21}
22
23pub(crate) fn pair() -> io::Result<(net::UnixStream, net::UnixStream)> {
24 super::pair(flags:libc::SOCK_STREAM)
25}
26