diff --git a/crates/runc-shim/Cargo.toml b/crates/runc-shim/Cargo.toml index 2e31e3fe..996316b9 100644 --- a/crates/runc-shim/Cargo.toml +++ b/crates/runc-shim/Cargo.toml @@ -33,6 +33,7 @@ serde_json = "1.0.74" oci-spec = "0.6.0" crossbeam = "0.8.1" uuid = { version = "1.0.0", features = ["v4"] } +prctl = "1.0.0" # Async dependencies async-trait = { workspace = true } diff --git a/crates/runc-shim/src/service.rs b/crates/runc-shim/src/service.rs index 512a3d31..5d548e23 100644 --- a/crates/runc-shim/src/service.rs +++ b/crates/runc-shim/src/service.rs @@ -79,7 +79,17 @@ impl Shim for Service { None => {} } - let address = spawn(opts, &grouping, Vec::new()).await?; + let mut vars: Vec<(&str, &str)> = Vec::new(); + let thp_disabled = match prctl::get_thp_disable() { + Ok(x) => { + x.to_string() + } + _ => {"".to_string()} + }; + match prctl::set_thp_disable(true) { _=> {} } + vars.push(("THP_DISABLED", thp_disabled.as_str())); + + let address = spawn(opts, &grouping, vars).await?; write_str_to_file("address", &address).await?; Ok(address) } diff --git a/crates/runc/Cargo.toml b/crates/runc/Cargo.toml index a4c8b67a..e06276ce 100644 --- a/crates/runc/Cargo.toml +++ b/crates/runc/Cargo.toml @@ -28,6 +28,7 @@ thiserror = "1.0.30" time = { version = "0.3.7", features = ["serde", "std"] } uuid = { version = "1.0.0", features = ["v4"] } os_pipe = "1.0.0" +prctl = "1.0.0" # Async dependencies tokio = { workspace = true, features = ["full"], optional = true } diff --git a/crates/runc/src/lib.rs b/crates/runc/src/lib.rs index d222dc1b..d69e94c6 100644 --- a/crates/runc/src/lib.rs +++ b/crates/runc/src/lib.rs @@ -366,8 +366,23 @@ pub trait Spawner: Debug { /// and some other utilities. #[cfg(feature = "async")] impl Runc { - async fn launch(&self, cmd: Command, combined_output: bool) -> Result { + async fn launch(&self, mut cmd: Command, combined_output: bool) -> Result { debug!("Execute command {:?}", cmd); + if let Ok(thp) = std::env::var("THP_DISABLED") { + if let Ok(thp_disabled) = thp.parse::() { + unsafe { + cmd.pre_exec(move || { + match prctl::set_thp_disable(thp_disabled) { + Err(e) => { + log::debug!("set_thp_disable err: {}", e); + } + _ => {} + }; + Ok(()) + }); + } + } + } let (status, pid, stdout, stderr) = self.spawner.execute(cmd).await?; if status.success() { let output = if combined_output {