Add support for input device passthrough

Signed-off-by: Sasha Finkelstein <[email protected]>

Author: WhatAmISupposedToPutHere

crates/krun-guest/src/bin/krun-guest.rs

@@ -13,6 +13,7 @@ use krun_guest::user::setup_user;
 use krun_guest::x11::setup_x11_forwarding;
 use log::debug;
 use rustix::process::{getrlimit, setrlimit, Resource};
+use utils::env::find_in_path;
 
 fn main() -> Result<()> {
     env_logger::init();
@@ -37,11 +38,16 @@ fn main() -> Result<()> {
     if let Err(err) = mount_filesystems() {
         return Err(err).context("Failed to mount filesystems, bailing out");
     }
+    Command::new("/usr/lib/systemd/systemd-udevd").spawn()?;
 
     setup_fex()?;
 
     configure_network()?;
 
+    if let Some(hidpipe_client_path) = find_in_path("hidpipe-client")? {
+        Command::new(hidpipe_client_path).arg(format!("{}", options.uid)).spawn()?;
+    }
+
     let run_path = match setup_user(options.username, options.uid, options.gid) {
         Ok(p) => p,
         Err(err) => return Err(err).context("Failed to set up user, bailing out"),

crates/krun/src/bin/krun.rs

@@ -179,6 +179,21 @@ fn main() -> Result<()> {
                 return Err(err).context("Failed to configure vsock for pulse socket");
             }
         }
+        let hidpipe_path = Path::new(&run_path).join("hidpipe");
+        if hidpipe_path.exists() {
+            let hidpipe_path = CString::new(
+                hidpipe_path
+                    .to_str()
+                    .expect("hidpipe_path should not contain invalid UTF-8"),
+            )
+            .context("Failed to process `hidpipe` path as it contains NUL character")?;
+            // SAFETY: `hidpipe_path` is a pointer to a `CString` with long enough lifetime.
+            let err = unsafe { krun_add_vsock_port(ctx_id, 3334, hidpipe_path.as_ptr()) };
+            if err < 0 {
+                let err = Errno::from_raw_os_error(-err);
+                return Err(err).context("Failed to configure vsock for hidpipe socket");
+            }
+        }
     }
 
     // Forward the native X11 display into the guest as a socket