use crate::{RunContext, Runnable, util::open_path};
use anyhow::{Context, Result};
use btrfs_uapi::{filesystem::filesystem_info, sysfs::SysfsBtrfs};
use clap::Parser;
use std::{os::unix::io::AsFd, path::PathBuf};
#[derive(Parser, Debug)]
#[allow(clippy::doc_markdown)]
pub struct FilesystemCommitStatsCommand {
#[clap(long, short = 'z')]
pub reset: bool,
pub path: PathBuf,
}
impl Runnable for FilesystemCommitStatsCommand {
fn run(&self, _ctx: &RunContext) -> Result<()> {
let file = open_path(&self.path)?;
let info = filesystem_info(file.as_fd()).with_context(|| {
format!(
"failed to get filesystem info for '{}'",
self.path.display()
)
})?;
let sysfs = SysfsBtrfs::new(&info.uuid);
let stats = sysfs
.commit_stats()
.context("failed to read commit_stats from sysfs")?;
println!("UUID: {}", info.uuid.as_hyphenated());
println!("Commit stats since mount:");
println!(" {:<28}{:>8}", "Total commits:", stats.commits);
println!(
" {:<28}{:>8}ms",
"Last commit duration:", stats.last_commit_ms
);
println!(
" {:<28}{:>8}ms",
"Max commit duration:", stats.max_commit_ms
);
println!(
" {:<28}{:>8}ms",
"Total time spent in commit:", stats.total_commit_ms
);
if self.reset {
sysfs
.reset_commit_stats()
.context("failed to reset commit_stats (requires root)")?;
println!("NOTE: Max commit duration has been reset");
}
Ok(())
}
}