summaryrefslogtreecommitdiffstats
path: root/crates/runner/src/util/unix.rs
diff options
context:
space:
mode:
authorMatthias Schiffer <mschiffer@universe-factory.net>2024-04-20 14:28:05 +0200
committerMatthias Schiffer <mschiffer@universe-factory.net>2024-04-20 14:38:17 +0200
commite9bf0fc40c0eb7e9d4228b804d62f31b0a136528 (patch)
tree7872f587782d5635eadbf82ae861d474d4da2efe /crates/runner/src/util/unix.rs
parent35e68444dd5e9d3d5fc39409c48be6eb3fa05e07 (diff)
downloadrebel-e9bf0fc40c0eb7e9d4228b804d62f31b0a136528.tar
rebel-e9bf0fc40c0eb7e9d4228b804d62f31b0a136528.zip
Rename directories to match crate names
Diffstat (limited to 'crates/runner/src/util/unix.rs')
-rw-r--r--crates/runner/src/util/unix.rs86
1 files changed, 0 insertions, 86 deletions
diff --git a/crates/runner/src/util/unix.rs b/crates/runner/src/util/unix.rs
deleted file mode 100644
index 08884ec..0000000
--- a/crates/runner/src/util/unix.rs
+++ /dev/null
@@ -1,86 +0,0 @@
-use std::{fs::File, os::unix::prelude::*, path::Path};
-
-use nix::{
- fcntl::{self, FcntlArg, FdFlag, Flock, OFlag},
- sched,
- unistd::Pid,
-};
-
-use common::error::*;
-
-use super::fs;
-
-pub fn set_blocking<Fd: AsFd>(fd: &Fd, blocking: bool) -> Result<()> {
- let raw_fd = fd.as_fd().as_raw_fd();
-
- let flags =
- OFlag::from_bits_retain(fcntl::fcntl(raw_fd, FcntlArg::F_GETFL).context("fcntl(F_GETFL)")?);
-
- let new_flags = if blocking {
- flags & !OFlag::O_NONBLOCK
- } else {
- flags | OFlag::O_NONBLOCK
- };
-
- if new_flags != flags {
- fcntl::fcntl(raw_fd, FcntlArg::F_SETFL(new_flags)).context("fcntl(F_SETFL)")?;
- }
-
- Ok(())
-}
-
-pub fn set_cloexec<Fd: AsFd>(fd: &Fd, cloexec: bool) -> Result<()> {
- let raw_fd = fd.as_fd().as_raw_fd();
-
- let flags = FdFlag::from_bits_retain(
- fcntl::fcntl(raw_fd, FcntlArg::F_GETFD).context("fcntl(F_GETFD)")?,
- );
-
- let new_flags = if cloexec {
- flags | FdFlag::FD_CLOEXEC
- } else {
- flags & !FdFlag::FD_CLOEXEC
- };
-
- if new_flags != flags {
- fcntl::fcntl(raw_fd, FcntlArg::F_SETFD(new_flags)).context("fcntl(F_SETFD)")?;
- }
-
- Ok(())
-}
-
-pub fn nproc() -> Result<usize> {
- const MAXCPU: usize = sched::CpuSet::count();
-
- let affinity = sched::sched_getaffinity(Pid::from_raw(0)).context("sched_getaffinity()")?;
-
- let mut count = 0;
-
- for cpu in 0..MAXCPU {
- if affinity.is_set(cpu).unwrap() {
- count += 1;
- }
- }
-
- Ok(count)
-}
-
-pub fn lock<P: AsRef<Path>>(path: P, exclusive: bool, blocking: bool) -> Result<Flock<File>> {
- use fcntl::FlockArg::*;
-
- if let Some(parent) = path.as_ref().parent() {
- fs::mkdir(parent)?;
- }
-
- let arg = match (exclusive, blocking) {
- (true, true) => LockExclusive,
- (true, false) => LockExclusiveNonblock,
- (false, true) => LockShared,
- (false, false) => LockSharedNonblock,
- };
-
- let file = fs::create(path.as_ref())?;
- fcntl::Flock::lock(file, arg)
- .map_err(|(_, errno)| errno)
- .with_context(|| format!("flock failed on {:?}", path.as_ref()))
-}