ntop 0.1.1

A real-time system resource monitor for Linux, focused on network and disk I/O
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77

// Quick test to verify data collection
use std::fs;

fn main() {
    println!("=== Testing Data Collection ===\n");
    
    // Test Network
    println!("1. Network Interfaces:");
    if let Ok(content) = fs::read_to_string("/proc/net/dev") {
        for line in content.lines().skip(2) {
            let parts: Vec<&str> = line.split_whitespace().collect();
            if !parts.is_empty() {
                let iface = parts[0].trim_end_matches(':');
                if !iface.is_empty() && iface != "lo" {
                    println!("   - {}", iface);
                }
            }
        }
    }
    
    // Test Disk I/O
    println!("\n2. Disk I/O Devices (from /proc/diskstats):");
    if let Ok(content) = fs::read_to_string("/proc/diskstats") {
        for line in content.lines() {
            let parts: Vec<&str> = line.split_whitespace().collect();
            if parts.len() >= 3 {
                let device = parts[2];
                // Skip partitions, only show main devices
                if !device.starts_with("loop") && 
                   !device.starts_with("ram") &&
                   !is_partition(device) {
                    println!("   - {}", device);
                }
            }
        }
    }
    
    // Test Disk Usage
    println!("\n3. Disk Usage (from /proc/mounts):");
    if let Ok(content) = fs::read_to_string("/proc/mounts") {
        for line in content.lines() {
            let parts: Vec<&str> = line.split_whitespace().collect();
            if parts.len() >= 2 {
                let fs = parts[0];
                let mount = parts[1];
                // Only show real filesystems
                if (fs.starts_with("/dev/") || fs.contains(":")) &&
                   !fs.starts_with("/dev/loop") &&
                   !mount.starts_with("/sys") &&
                   !mount.starts_with("/proc") &&
                   !mount.starts_with("/run") &&
                   mount != "/dev" {
                    println!("   - {} -> {}", fs, mount);
                }
            }
        }
    }
}

fn is_partition(device: &str) -> bool {
    // nvme partitions: nvme0n1p1
    if device.starts_with("nvme") {
        return device.contains('p') && 
               device.matches('p').count() == 1 &&
               device.split('p').nth(1).map(|s| s.chars().next().map(|c| c.is_ascii_digit()).unwrap_or(false)).unwrap_or(false);
    }
    // sdX, hdX partitions: sda1, sdb2
    let chars: Vec<char> = device.chars().collect();
    if chars.len() >= 2 {
        let last = chars[chars.len() - 1];
        if last.is_ascii_digit() && 
           (device.starts_with("sd") || device.starts_with("hd") || device.starts_with("vd")) {
            return true;
        }
    }
    false
}