oxidux 0.4.0

Reverse proxy and process manager for web app development.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

// Socket activation integration with launchd
// Copied from https://github.com/LinkTed/doh-client/blob/3920321902ab270a0c68f67717036d405fbdcd87/src/dns.rs

use libc::{c_void, free, size_t};
use std::{
    ffi::CString,
    io::{Error, ErrorKind::Other},
    net::TcpListener,
    os::{
        raw::{c_char, c_int},
        unix::io::{FromRawFd, RawFd},
    },
    ptr::null_mut,
};

type FdType = RawFd;

extern "C" {
    fn launch_activate_socket(name: *const c_char, fds: *mut *mut c_int, cnt: *mut size_t)
        -> c_int;
}

pub fn get_activation_socket(name: &str) -> Result<TcpListener, Error> {
    let fds = get_fds(name).unwrap_or_default();

    match fds.get(0) {
        Some(fd) => {
            let listener = unsafe { TcpListener::from_raw_fd(*fd) };

            Ok(listener)
        }
        None => Err(Error::new(
            Other,
            "Couln't find file descriptor from socket activation",
        )),
    }
}

/// Get raw file descriptors for lanchd socket of a given name
fn get_fds(name: &str) -> Option<Vec<FdType>> {
    // Launchd takes a name, array pointer, and count pointer and fills the array with file
    // descriptors for the named socket.  We are responsible for freeing the memory, so copy the
    // array into a new vector and free it immediately so we don't need to set up a custom
    // desctructor.
    unsafe {
        let mut fds: *mut c_int = null_mut();
        let mut cnt: size_t = 0;

        let name = CString::new(name).expect("CString::new failed");

        if launch_activate_socket(name.as_ptr(), &mut fds, &mut cnt) == 0 {
            assert!(!fds.is_null());
            let result = std::slice::from_raw_parts(fds, cnt).to_vec();
            free(fds as *mut c_void);

            Some(result)
        } else {
            None
        }
    }
}