1 use std::io;
2 use std::os::fd::FromRawFd;
3 use std::os::unix::net::{self, SocketAddr};
4 
5 use crate::sys::unix::net::new_socket;
6 use crate::sys::unix::uds::unix_addr;
7 
connect_addr(address: &SocketAddr) -> io::Result<net::UnixStream>8 pub(crate) fn connect_addr(address: &SocketAddr) -> io::Result<net::UnixStream> {
9     let fd = new_socket(libc::AF_UNIX, libc::SOCK_STREAM)?;
10     let socket = unsafe { net::UnixStream::from_raw_fd(fd) };
11 
12     let (unix_address, addrlen) = unix_addr(address);
13     let 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) if err.raw_os_error() == Some(libc::EINPROGRESS) => {}
17         Err(e) => return Err(e),
18     }
19 
20     Ok(socket)
21 }
22 
pair() -> io::Result<(net::UnixStream, net::UnixStream)>23 pub(crate) fn pair() -> io::Result<(net::UnixStream, net::UnixStream)> {
24     super::pair(libc::SOCK_STREAM)
25 }
26