mirror of
https://github.com/uutils/coreutils
synced 2024-12-13 06:42:42 +00:00
tests: add the ability to set resource limits
This commit is contained in:
parent
dfaaa8c787
commit
e5c4681e04
4 changed files with 44 additions and 0 deletions
|
@ -30,6 +30,7 @@ peekreader
|
||||||
quickcheck
|
quickcheck
|
||||||
rand_chacha
|
rand_chacha
|
||||||
ringbuffer
|
ringbuffer
|
||||||
|
rlimit
|
||||||
smallvec
|
smallvec
|
||||||
tempdir
|
tempdir
|
||||||
tempfile
|
tempfile
|
||||||
|
|
11
Cargo.lock
generated
11
Cargo.lock
generated
|
@ -233,6 +233,7 @@ dependencies = [
|
||||||
"pretty_assertions",
|
"pretty_assertions",
|
||||||
"rand 0.7.3",
|
"rand 0.7.3",
|
||||||
"regex",
|
"regex",
|
||||||
|
"rlimit",
|
||||||
"sha1",
|
"sha1",
|
||||||
"tempfile",
|
"tempfile",
|
||||||
"textwrap",
|
"textwrap",
|
||||||
|
@ -1410,6 +1411,16 @@ version = "0.1.3"
|
||||||
source = "registry+https://github.com/rust-lang/crates.io-index"
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
checksum = "e9c17925a9027d298a4603d286befe3f9dc0e8ed02523141914eb628798d6e5b"
|
checksum = "e9c17925a9027d298a4603d286befe3f9dc0e8ed02523141914eb628798d6e5b"
|
||||||
|
|
||||||
|
[[package]]
|
||||||
|
name = "rlimit"
|
||||||
|
version = "0.4.0"
|
||||||
|
source = "registry+https://github.com/rust-lang/crates.io-index"
|
||||||
|
checksum = "49b02d62c38353a6fce45c25ca19783e25dd5f495ca681c674a4ee15aa4c1536"
|
||||||
|
dependencies = [
|
||||||
|
"cfg-if 0.1.10",
|
||||||
|
"libc",
|
||||||
|
]
|
||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "rust-ini"
|
name = "rust-ini"
|
||||||
version = "0.13.0"
|
version = "0.13.0"
|
||||||
|
|
|
@ -354,6 +354,7 @@ walkdir = "2.2"
|
||||||
atty = "0.2.14"
|
atty = "0.2.14"
|
||||||
|
|
||||||
[target.'cfg(unix)'.dev-dependencies]
|
[target.'cfg(unix)'.dev-dependencies]
|
||||||
|
rlimit = "0.4.0"
|
||||||
rust-users = { version="0.10", package="users" }
|
rust-users = { version="0.10", package="users" }
|
||||||
unix_socket = "0.5.0"
|
unix_socket = "0.5.0"
|
||||||
|
|
||||||
|
|
|
@ -1,5 +1,10 @@
|
||||||
|
//spell-checker: ignore (linux) rlimit prlimit Rlim
|
||||||
|
|
||||||
#![allow(dead_code)]
|
#![allow(dead_code)]
|
||||||
|
|
||||||
use pretty_assertions::assert_eq;
|
use pretty_assertions::assert_eq;
|
||||||
|
#[cfg(target_os = "linux")]
|
||||||
|
use rlimit::{prlimit, rlim};
|
||||||
use std::env;
|
use std::env;
|
||||||
#[cfg(not(windows))]
|
#[cfg(not(windows))]
|
||||||
use std::ffi::CString;
|
use std::ffi::CString;
|
||||||
|
@ -724,6 +729,8 @@ pub struct UCommand {
|
||||||
stdout: Option<Stdio>,
|
stdout: Option<Stdio>,
|
||||||
stderr: Option<Stdio>,
|
stderr: Option<Stdio>,
|
||||||
bytes_into_stdin: Option<Vec<u8>>,
|
bytes_into_stdin: Option<Vec<u8>>,
|
||||||
|
#[cfg(target_os = "linux")]
|
||||||
|
limits: Vec<(rlimit::Resource, rlim, rlim)>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl UCommand {
|
impl UCommand {
|
||||||
|
@ -758,6 +765,8 @@ impl UCommand {
|
||||||
stdin: None,
|
stdin: None,
|
||||||
stdout: None,
|
stdout: None,
|
||||||
stderr: None,
|
stderr: None,
|
||||||
|
#[cfg(target_os = "linux")]
|
||||||
|
limits: vec![],
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -855,6 +864,17 @@ impl UCommand {
|
||||||
self
|
self
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[cfg(target_os = "linux")]
|
||||||
|
pub fn with_limit(
|
||||||
|
&mut self,
|
||||||
|
resource: rlimit::Resource,
|
||||||
|
soft_limit: rlim,
|
||||||
|
hard_limit: rlim,
|
||||||
|
) -> &mut Self {
|
||||||
|
self.limits.push((resource, soft_limit, hard_limit));
|
||||||
|
self
|
||||||
|
}
|
||||||
|
|
||||||
/// Spawns the command, feeds the stdin if any, and returns the
|
/// Spawns the command, feeds the stdin if any, and returns the
|
||||||
/// child process immediately.
|
/// child process immediately.
|
||||||
pub fn run_no_wait(&mut self) -> Child {
|
pub fn run_no_wait(&mut self) -> Child {
|
||||||
|
@ -871,6 +891,17 @@ impl UCommand {
|
||||||
.spawn()
|
.spawn()
|
||||||
.unwrap();
|
.unwrap();
|
||||||
|
|
||||||
|
#[cfg(target_os = "linux")]
|
||||||
|
for &(resource, soft_limit, hard_limit) in &self.limits {
|
||||||
|
prlimit(
|
||||||
|
child.id() as i32,
|
||||||
|
resource,
|
||||||
|
Some((soft_limit, hard_limit)),
|
||||||
|
None,
|
||||||
|
)
|
||||||
|
.unwrap();
|
||||||
|
}
|
||||||
|
|
||||||
if let Some(ref input) = self.bytes_into_stdin {
|
if let Some(ref input) = self.bytes_into_stdin {
|
||||||
let write_result = child
|
let write_result = child
|
||||||
.stdin
|
.stdin
|
||||||
|
|
Loading…
Reference in a new issue