Replace getrusage with a 64-bit-time_t wrapper

Part of #10634
This commit is contained in:
Johannes Altmanninger 2024-08-07 11:26:08 +02:00
parent 46c8ba2c9f
commit 4992f88966
5 changed files with 66 additions and 36 deletions

View file

@ -41,6 +41,7 @@ use fish::{
fprintf, function, future_feature_flags as features, fprintf, function, future_feature_flags as features,
history::{self, start_private_mode}, history::{self, start_private_mode},
io::IoChain, io::IoChain,
libc::{getrusage64, timeval64},
nix::{getpid, isatty}, nix::{getpid, isatty},
panic::panic_handler, panic::panic_handler,
parse_constants::{ParseErrorList, ParseTreeFlags}, parse_constants::{ParseErrorList, ParseTreeFlags},
@ -55,14 +56,12 @@ use fish::{
}, },
reader::{reader_init, reader_read, term_copy_modes}, reader::{reader_init, reader_read, term_copy_modes},
signal::{signal_clear_cancel, signal_unblock_all}, signal::{signal_clear_cancel, signal_unblock_all},
threads::{self}, threads, topic_monitor,
topic_monitor,
wchar::prelude::*, wchar::prelude::*,
wutil::waccess, wutil::waccess,
}; };
use std::ffi::{CString, OsStr, OsString}; use std::ffi::{CString, OsStr, OsString};
use std::fs::File; use std::fs::File;
use std::mem::MaybeUninit;
use std::os::unix::prelude::*; use std::os::unix::prelude::*;
use std::path::{Path, PathBuf}; use std::path::{Path, PathBuf};
use std::rc::Rc; use std::rc::Rc;
@ -104,23 +103,20 @@ struct FishCmdOpts {
} }
/// Return a timeval converted to milliseconds. /// Return a timeval converted to milliseconds.
#[allow(clippy::unnecessary_cast)] fn tv_to_msec(tv: &timeval64) -> i64 {
fn tv_to_msec(tv: &libc::timeval) -> i64 {
// milliseconds per second // milliseconds per second
let mut msec = tv.tv_sec as i64 * 1000; let mut msec = tv.tv_sec * 1000;
// microseconds per millisecond // microseconds per millisecond
msec += tv.tv_usec as i64 / 1000; msec += tv.tv_usec / 1000;
msec msec
} }
fn print_rusage_self() { fn print_rusage_self() {
let mut rs = MaybeUninit::uninit(); let Some(rs) = getrusage64(libc::RUSAGE_SELF) else {
if unsafe { libc::getrusage(libc::RUSAGE_SELF, rs.as_mut_ptr()) } != 0 {
let s = CString::new("getrusage").unwrap(); let s = CString::new("getrusage").unwrap();
unsafe { libc::perror(s.as_ptr()) } unsafe { libc::perror(s.as_ptr()) }
return; return;
} };
let rs: libc::rusage = unsafe { rs.assume_init() };
let rss_kb = if cfg!(target_os = "macos") { let rss_kb = if cfg!(target_os = "macos") {
// mac use bytes. // mac use bytes.
rs.ru_maxrss / 1024 rs.ru_maxrss / 1024

View file

@ -249,3 +249,22 @@ int C_select64(int nfds, fd_set* readfds, fd_set* writefds, fd_set* errorfds,
} }
return result; return result;
} }
struct rusage64 {
struct timeval64 ru_utime;
struct timeval64 ru_stime;
int64_t ru_maxrss;
int64_t ru_nsignals;
};
int C_getrusage64(int resource, struct rusage64* usage) {
struct rusage tmp;
int result = getrusage(resource, &tmp);
usage->ru_utime.tv_sec = tmp.ru_utime.tv_sec;
usage->ru_utime.tv_usec = tmp.ru_utime.tv_usec;
usage->ru_stime.tv_sec = tmp.ru_stime.tv_sec;
usage->ru_stime.tv_usec = tmp.ru_stime.tv_usec;
usage->ru_maxrss = tmp.ru_maxrss;
usage->ru_nsignals = tmp.ru_nsignals;
return result;
}

View file

@ -126,7 +126,7 @@ extern "C" {
#[repr(C)] #[repr(C)]
#[derive(Clone, Copy)] #[derive(Clone, Copy)]
pub(crate) struct timeval64 { pub struct timeval64 {
pub tv_sec: i64, pub tv_sec: i64,
pub tv_usec: i64, pub tv_usec: i64,
} }
@ -149,3 +149,27 @@ extern "C" {
timeout: *mut timeval64, timeout: *mut timeval64,
) -> c_int; ) -> c_int;
} }
#[repr(C)]
pub struct rusage64 {
pub ru_utime: timeval64,
pub ru_stime: timeval64,
pub ru_maxrss: u64,
pub ru_nsignals: u64,
}
pub fn getrusage64(resource: c_int) -> Option<rusage64> {
let mut rusage = std::mem::MaybeUninit::uninit();
let result = unsafe { C_getrusage64(resource, rusage.as_mut_ptr()) };
// getrusage(2) says the syscall can only fail if the dest address is invalid (EFAULT) or if the
// requested resource type is invalid. Since we're in control of both, we can assume it won't
// fail. In case it does anyway (e.g. OS where the syscall isn't implemented), we can just
// return an empty value.
match result {
0 => unsafe { Some(rusage.assume_init()) },
_ => None,
}
}
extern "C" {
fn C_getrusage64(resource: c_int, usage: *mut rusage64) -> c_int;
}

View file

@ -2,9 +2,10 @@
use std::time::Duration; use std::time::Duration;
#[allow(clippy::unnecessary_cast)] use crate::libc::timeval64;
pub const fn timeval_to_duration(val: &libc::timeval) -> Duration {
let micros = val.tv_sec as i64 * (1E6 as i64) + val.tv_usec as i64; pub(crate) const fn timeval_to_duration(val: &timeval64) -> Duration {
let micros = val.tv_sec * (1E6 as i64) + val.tv_usec;
Duration::from_micros(micros as u64) Duration::from_micros(micros as u64)
} }
@ -13,7 +14,7 @@ pub trait TimevalExt {
fn as_duration(&self) -> Duration; fn as_duration(&self) -> Duration;
} }
impl TimevalExt for libc::timeval { impl TimevalExt for timeval64 {
fn as_micros(&self) -> i64 { fn as_micros(&self) -> i64 {
timeval_to_duration(self).as_micros() as i64 timeval_to_duration(self).as_micros() as i64
} }

View file

@ -17,6 +17,8 @@
use std::io::Write; use std::io::Write;
use std::time::{Duration, Instant}; use std::time::{Duration, Instant};
use crate::libc::{getrusage64, rusage64};
enum Unit { enum Unit {
Minutes, Minutes,
Seconds, Seconds,
@ -26,8 +28,8 @@ enum Unit {
struct TimerSnapshot { struct TimerSnapshot {
wall_time: Instant, wall_time: Instant,
cpu_fish: libc::rusage, cpu_fish: rusage64,
cpu_children: libc::rusage, cpu_children: rusage64,
} }
/// Create a `TimerSnapshot` and return a `PrintElapsedOnDrop` object that will print upon /// Create a `TimerSnapshot` and return a `PrintElapsedOnDrop` object that will print upon
@ -45,24 +47,12 @@ enum RUsage {
RChildren, RChildren,
} }
/// A safe wrapper around `libc::getrusage()` fn getrusage(resource: RUsage) -> rusage64 {
fn getrusage(resource: RUsage) -> libc::rusage { getrusage64(match resource {
let mut rusage = std::mem::MaybeUninit::uninit(); RUsage::RSelf => libc::RUSAGE_SELF,
let result = unsafe { RUsage::RChildren => libc::RUSAGE_CHILDREN,
match resource { })
RUsage::RSelf => libc::getrusage(libc::RUSAGE_SELF, rusage.as_mut_ptr()), .unwrap_or(unsafe { std::mem::zeroed() })
RUsage::RChildren => libc::getrusage(libc::RUSAGE_CHILDREN, rusage.as_mut_ptr()),
}
};
// getrusage(2) says the syscall can only fail if the dest address is invalid (EFAULT) or if the
// requested resource type is invalid. Since we're in control of both, we can assume it won't
// fail. In case it does anyway (e.g. OS where the syscall isn't implemented), we can just
// return an empty value.
match result {
0 => unsafe { rusage.assume_init() },
_ => unsafe { std::mem::zeroed() },
}
} }
impl TimerSnapshot { impl TimerSnapshot {