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

fix not listing all storages

Browse source
This commit is contained in:
Robin Appelman 2024-05-19 15:20:03 +02:00
commit effc4641ad
1 changed files with 12 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -114,22 +114,25 @@ impl Iterator for DiskUsageParser<'_> {
type Item = Result<DiskUsage>; type Item = Result<DiskUsage>;
fn next(&mut self) -> Option<Self::Item> { fn next(&mut self) -> Option<Self::Item> {
let line = loop { let mount_point = loop {
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; debug!(line, "picking mount");
let mut parts = line.split_ascii_whitespace();
let disk = parts.next()?;
if self.found_disks.insert(hash_str(disk)) {
let mount_point = parts.next()?;
break mount_point;
} else {
debug!(line, "skipping already processed disk");
}
} else { } else {
debug!(line, "skipping mount"); debug!(line, "skipping mount");
} }
}; };
let mut parts = line.split_ascii_whitespace();
let disk = parts.next()?;
if !self.found_disks.insert(hash_str(disk)) {
debug!(line, "skipping already processed disk");
return None;
}
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) => { Err(e) => {