-
Notifications
You must be signed in to change notification settings - Fork 202
/
poll_sysfs.rs
54 lines (48 loc) 路 1.51 KB
/
poll_sysfs.rs
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
use notify::poll::PollWatcherConfig;
use notify::{PollWatcher, RecursiveMode, Watcher};
use std::path::Path;
use std::time::Duration;
#[cfg(not(target_os = "windows"))]
fn not_windows_main() -> notify::Result<()> {
let mut paths: Vec<_> = std::env::args()
.skip(1)
.map(|arg| Path::new(&arg).to_path_buf())
.collect();
if paths.is_empty() {
let lo_stats = Path::new("/sys/class/net/lo/statistics/tx_bytes").to_path_buf();
if !lo_stats.exists() {
eprintln!("Must provide path to watch, default system path was not found (probably you're not running on Linux?)");
std::process::exit(1);
}
println!(
"Trying {:?}, use `ping localhost` to see changes!",
lo_stats
);
paths.push(lo_stats);
}
println!("watching {:?}...", paths);
let config = PollWatcherConfig {
compare_contents: true,
poll_interval: Duration::from_secs(2),
};
let (tx, rx) = std::sync::mpsc::channel();
let mut watcher = PollWatcher::with_config(tx, config)?;
for path in paths {
watcher.watch(&path, RecursiveMode::Recursive)?;
}
for res in rx {
match res {
Ok(event) => println!("changed: {:?}", event),
Err(e) => println!("watch error: {:?}", e),
}
}
Ok(())
}
fn main() -> notify::Result<()> {
#[cfg(not(target_os = "windows"))]
{
not_windows_main()
}
#[cfg(target_os = "windows")]
notify::Result::Ok(())
}