Revision control
Copy as Markdown
Other Tools
use crate::process::Pid;
use crate::{backend, io};
use core::{fmt, hash};
/// `CpuSet` represents a bit-mask of CPUs.
///
/// `CpuSet`s are used by [`sched_setaffinity`] and [`sched_getaffinity`], for
/// example.
///
/// # References
/// - [Linux]
///
/// [`sched_setaffinity`]: crate::process::sched_setaffinity
/// [`sched_getaffinity`]: crate::process::sched_getaffinity
#[repr(C)]
#[derive(Clone, Copy)]
pub struct CpuSet {
cpu_set: backend::process::types::RawCpuSet,
}
impl CpuSet {
/// The maximum number of CPU in `CpuSet`.
pub const MAX_CPU: usize = backend::process::types::CPU_SETSIZE;
/// Create a new and empty `CpuSet`.
#[inline]
pub fn new() -> Self {
Self {
cpu_set: backend::process::types::raw_cpu_set_new(),
}
}
/// Test to see if a CPU is in the `CpuSet`.
///
/// `field` is the CPU id to test.
#[inline]
pub fn is_set(&self, field: usize) -> bool {
backend::process::cpu_set::CPU_ISSET(field, &self.cpu_set)
}
/// Add a CPU to `CpuSet`.
///
/// `field` is the CPU id to add.
#[inline]
pub fn set(&mut self, field: usize) {
backend::process::cpu_set::CPU_SET(field, &mut self.cpu_set)
}
/// Remove a CPU from `CpuSet`.
///
/// `field` is the CPU id to remove.
#[inline]
pub fn unset(&mut self, field: usize) {
backend::process::cpu_set::CPU_CLR(field, &mut self.cpu_set)
}
/// Count the number of CPUs set in the `CpuSet`.
#[cfg(linux_kernel)]
#[inline]
pub fn count(&self) -> u32 {
backend::process::cpu_set::CPU_COUNT(&self.cpu_set)
}
/// Zeroes the `CpuSet`.
#[inline]
pub fn clear(&mut self) {
backend::process::cpu_set::CPU_ZERO(&mut self.cpu_set)
}
}
impl Default for CpuSet {
#[inline]
fn default() -> Self {
Self::new()
}
}
impl fmt::Debug for CpuSet {
fn fmt(&self, fmt: &mut fmt::Formatter<'_>) -> fmt::Result {
write!(fmt, "CpuSet {{")?;
let mut first = true;
for i in 0..CpuSet::MAX_CPU {
if self.is_set(i) {
if first {
write!(fmt, " ")?;
first = false;
} else {
write!(fmt, ", ")?;
}
write!(fmt, "cpu{}", i)?;
}
}
write!(fmt, " }}")
}
}
impl hash::Hash for CpuSet {
fn hash<H: hash::Hasher>(&self, state: &mut H) {
for i in 0..CpuSet::MAX_CPU {
self.is_set(i).hash(state);
}
}
}
impl Eq for CpuSet {}
impl PartialEq for CpuSet {
fn eq(&self, other: &Self) -> bool {
backend::process::cpu_set::CPU_EQUAL(&self.cpu_set, &other.cpu_set)
}
}
/// `sched_setaffinity(pid, cpuset)`—Set a thread's CPU affinity mask.
///
/// `pid` is the thread ID to update. If pid is `None`, then the current thread
/// is updated.
///
/// The `CpuSet` argument specifies the set of CPUs on which the thread will be
/// eligible to run.
///
/// # References
/// - [Linux]
///
#[inline]
pub fn sched_setaffinity(pid: Option<Pid>, cpuset: &CpuSet) -> io::Result<()> {
backend::process::syscalls::sched_setaffinity(pid, &cpuset.cpu_set)
}
/// `sched_getaffinity(pid)`—Get a thread's CPU affinity mask.
///
/// `pid` is the thread ID to check. If pid is `None`, then the current thread
/// is checked.
///
/// Returns the set of CPUs on which the thread is eligible to run.
///
/// # References
/// - [Linux]
///
#[inline]
pub fn sched_getaffinity(pid: Option<Pid>) -> io::Result<CpuSet> {
let mut cpuset = CpuSet::new();
backend::process::syscalls::sched_getaffinity(pid, &mut cpuset.cpu_set).and(Ok(cpuset))
}
/// `sched_getcpu()`—Get the CPU that the current thread is currently on.
///
/// # References
/// - [Linux]
/// - [DragonFly BSD]
///
// FreeBSD added `sched_getcpu` in 13.0.
#[cfg(any(linux_kernel, target_os = "dragonfly"))]
#[inline]
pub fn sched_getcpu() -> usize {
backend::process::syscalls::sched_getcpu()
}