robin/palantir
1
0
Fork 0
mirror of https://codeberg.org/icewind/palantir.git synced 2026-06-03 18:24:08 +02:00
Code Issues Projects Releases Wiki Activity

more disk logging

Browse source
This commit is contained in:
Robin Appelman 2024-05-19 14:25:49 +02:00
commit 2b7368fa78
1 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

10
src/linux/disk/mod.rs
View file

@ -7,7 +7,7 @@ use std::fs::File;
use std::hash::{Hash, Hasher}; use std::hash::{Hash, Hasher};
use std::io::{Read, Seek}; use std::io::{Read, Seek};
use std::mem::MaybeUninit; use std::mem::MaybeUninit;
use tracing::debug; use tracing::{debug, error};
pub mod zfs; pub mod zfs;
@ -118,18 +118,24 @@ impl Iterator for DiskUsageParser<'_> {
let line = self.lines.next()?; let line = self.lines.next()?;
if line.starts_with('/') && !line.contains("/dev/loop") && !line.contains("fuse") { if line.starts_with('/') && !line.contains("/dev/loop") && !line.contains("fuse") {
break line; break line;
} else {
debug!(line, "skipping mount");
} }
}; };
let mut parts = line.split_ascii_whitespace(); let mut parts = line.split_ascii_whitespace();
let disk = parts.next()?; let disk = parts.next()?;
if !self.found_disks.insert(hash_str(disk)) { if !self.found_disks.insert(hash_str(disk)) {
debug!(line, "skipping already processed disk");
return None; return None;
} }
let mount_point = parts.next()?; let mount_point = parts.next()?;
let stat = match statvfs(mount_point) { let stat = match statvfs(mount_point) {
Ok(stat) => stat, Ok(stat) => stat,
Err(e) => return Some(Err(e)), Err(e) => {
error!(error = ?e, "error while getting disk statistics");
return Some(Err(e));
}
}; };
// cast is needed on 32bit platforms // cast is needed on 32bit platforms
#[allow(clippy::unnecessary_cast)] #[allow(clippy::unnecessary_cast)]