hcavarsan/kftray

            let original_value = std::env::var(&key).ok();
            unsafe { std::env::set_var(&key, value) };
            EnvVarGuard {
                key,

    // SAFETY: the descriptor is owned by `file` and outlives this call.
    if unsafe { libc::flock(file.as_raw_fd(), libc::LOCK_EX | libc::LOCK_NB) } == 0 {
        return Ok(true);
    }

        // process id.
        let result = unsafe { libc::kill(pid, 0) };
        result == 0 || std::io::Error::last_os_error().raw_os_error() == Some(libc::EPERM)
    }

        let output = Command::new("git")
            .arg("clone")
            .arg("--depth=1")

    fn dead_pid() -> u32 {
        let mut child = std::process::Command::new(if cfg!(windows) { "cmd" } else { "true" })
            .args(if cfg!(windows) {
                &["/C", "exit 0"][..]

    let mut target_triple = String::new();
    if let Ok(output) = Command::new("rustc").args(["-Vv"]).output() {
        let output_str = String::from_utf8_lossy(&output.stdout);
        if let Some(...

    #[tokio::test]
    async fn http_proxy_should_stop_accepting_when_shutdown_signaled() {
        let tunnel_server = Arc::new(WebSocketTunnelServer::new(0));
        let listener = tokio::net::TcpL...

    pub async fn drain_forwarding(&mut self) -> HashSet<i64> {
        // Signalled before draining: an in-flight startup observes cancellation
        // at its own safe points and runs its own rollb...