rustfmt.toml: init, format
Build and test / check (push) Has been cancelled
Build and test / docs (push) Has been cancelled
Build and test / build (push) Has been cancelled

This commit is contained in:
2026-01-02 22:44:34 +09:00
parent abf08b3013
commit 3559de58e2
4 changed files with 18 additions and 10 deletions
+4 -5
View File
@@ -19,21 +19,20 @@ fn important_thread() {
actual_priority.value(), actual_priority.value(),
), ),
Err(err) => { Err(err) => {
eprintln!("Failed to set priority: {}", err); eprintln!("Failed to set priority: {err}");
} }
} }
let requested_nice_level = -10; let requested_nice_level = -10;
let actual_nice_level = set_current_thread_nice_level(Some( let actual_nice_level =
requested_nice_level.try_into().unwrap(), set_current_thread_nice_level(Some(requested_nice_level.try_into().unwrap()));
));
match actual_nice_level { match actual_nice_level {
Ok(actual_nice_level) => println!( Ok(actual_nice_level) => println!(
"Requested nice level: {requested_nice_level}, Actual nice level: {}", "Requested nice level: {requested_nice_level}, Actual nice level: {}",
actual_nice_level.value(), actual_nice_level.value(),
), ),
Err(err) => { Err(err) => {
eprintln!("Failed to set nice level: {}", err); eprintln!("Failed to set nice level: {err}");
} }
} }
} }
+1
View File
@@ -0,0 +1 @@
style_edition = "2024"
+12 -4
View File
@@ -53,7 +53,9 @@ pub fn set_thread_priority(tid: u64, priority: Option<Priority>) -> Result<Prior
.map_err(|e| match e { .map_err(|e| match e {
zbus::fdo::Error::AccessDenied(err) => Error::PermissionDenied(err), zbus::fdo::Error::AccessDenied(err) => Error::PermissionDenied(err),
// NOTE: RTKit returns "No such file or directory" for invalid tids. // NOTE: RTKit returns "No such file or directory" for invalid tids.
zbus::fdo::Error::Failed(err) if err == "No such file or directory" => Error::InvalidPidOrTid, zbus::fdo::Error::Failed(err) if err == "No such file or directory" => {
Error::InvalidPidOrTid
}
err => Error::ZbusMethodError(err), err => Error::ZbusMethodError(err),
}) })
} }
@@ -85,7 +87,9 @@ pub fn set_process_thread_priority(
.map_err(|e| match e { .map_err(|e| match e {
zbus::fdo::Error::AccessDenied(err) => Error::PermissionDenied(err), zbus::fdo::Error::AccessDenied(err) => Error::PermissionDenied(err),
// NOTE: RTKit returns "No such file or directory" for invalid tids. // NOTE: RTKit returns "No such file or directory" for invalid tids.
zbus::fdo::Error::Failed(err) if err == "No such file or directory" => Error::InvalidPidOrTid, zbus::fdo::Error::Failed(err) if err == "No such file or directory" => {
Error::InvalidPidOrTid
}
err => Error::ZbusMethodError(err), err => Error::ZbusMethodError(err),
}) })
} }
@@ -121,7 +125,9 @@ pub fn set_thread_nice_level(tid: u64, nice_level: Option<NiceLevel>) -> Result<
.map_err(|e| match e { .map_err(|e| match e {
zbus::fdo::Error::AccessDenied(err) => Error::PermissionDenied(err), zbus::fdo::Error::AccessDenied(err) => Error::PermissionDenied(err),
// NOTE: RTKit returns "No such file or directory" for invalid tids. // NOTE: RTKit returns "No such file or directory" for invalid tids.
zbus::fdo::Error::Failed(err) if err == "No such file or directory" => Error::InvalidPidOrTid, zbus::fdo::Error::Failed(err) if err == "No such file or directory" => {
Error::InvalidPidOrTid
}
err => Error::ZbusMethodError(err), err => Error::ZbusMethodError(err),
}) })
} }
@@ -153,7 +159,9 @@ pub fn set_process_thread_nice_level(
.map_err(|e| match e { .map_err(|e| match e {
zbus::fdo::Error::AccessDenied(err) => Error::PermissionDenied(err), zbus::fdo::Error::AccessDenied(err) => Error::PermissionDenied(err),
// NOTE: RTKit returns "No such file or directory" for invalid tids. // NOTE: RTKit returns "No such file or directory" for invalid tids.
zbus::fdo::Error::Failed(err) if err == "No such file or directory" => Error::InvalidPidOrTid, zbus::fdo::Error::Failed(err) if err == "No such file or directory" => {
Error::InvalidPidOrTid
}
err => Error::ZbusMethodError(err), err => Error::ZbusMethodError(err),
}) })
} }
+1 -1
View File
@@ -12,7 +12,7 @@ use zbus::{fdo::Result, proxy};
pub trait RTKit { pub trait RTKit {
fn make_thread_realtime(&self, thread: u64, priority: u32) -> Result<()>; fn make_thread_realtime(&self, thread: u64, priority: u32) -> Result<()>;
fn make_thread_realtime_with_pid(&self, process: u64, thread: u64, priority: u32) fn make_thread_realtime_with_pid(&self, process: u64, thread: u64, priority: u32)
-> Result<()>; -> Result<()>;
// NOTE: despite being named "priority", the priority parameter here is actually a nice level. // NOTE: despite being named "priority", the priority parameter here is actually a nice level.
fn make_thread_high_priority(&self, thread: u64, priority: i32) -> Result<()>; fn make_thread_high_priority(&self, thread: u64, priority: i32) -> Result<()>;