mirrors/electrs
1
0
Fork 0
mirror of https://github.com/romanz/electrs.git synced 2024-11-19 09:54:09 +01:00
Code Issues Projects Releases Wiki Activity

Stop process stats exporting on error

Browse Source 
Also, improve error messages a bit.
This commit is contained in:
Roman Zeyde 2019-04-11 15:04:51 +03:00
parent 963037607b
commit 2597eee006
No known key found for this signature in database
GPG Key ID: 87CAE5FA46917CBB
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/metrics.rs
View File

@ -102,7 +102,8 @@ struct Stats {
} }
fn parse_stats() -> Result<Stats> { fn parse_stats() -> Result<Stats> {
let value = fs::read_to_string("/proc/self/stat").chain_err(|| "failed to read stats")?; let value =
fs::read_to_string("/proc/self/stat").chain_err(|| "failed to read /proc/self/stat")?;
let parts: Vec<&str> = value.split_whitespace().collect(); let parts: Vec<&str> = value.split_whitespace().collect();
let page_size = page_size::get() as u64; let page_size = page_size::get() as u64;
let ticks_per_second = sysconf::raw::sysconf(sysconf::raw::SysconfVariable::ScClkTck) let ticks_per_second = sysconf::raw::sysconf(sysconf::raw::SysconfVariable::ScClkTck)
@ -120,7 +121,7 @@ fn parse_stats() -> Result<Stats> {
let utime = parse_part(13, "utime")? as f64 / ticks_per_second; let utime = parse_part(13, "utime")? as f64 / ticks_per_second;
let rss = parse_part(23, "rss")? * page_size; let rss = parse_part(23, "rss")? * page_size;
let fds = fs::read_dir("/proc/self/fd") let fds = fs::read_dir("/proc/self/fd")
.chain_err(|| "failed to read fd directory")? .chain_err(|| "failed to read /proc/self/fd directory")?
.count(); .count();
Ok(Stats { utime, rss, fds }) Ok(Stats { utime, rss, fds })
} }
@ -148,7 +149,10 @@ fn start_process_exporter(metrics: &Metrics) {
rss.set(stats.rss as i64); rss.set(stats.rss as i64);
fds.set(stats.fds as i64); fds.set(stats.fds as i64);
} }
Err(e) => warn!("failed to export stats: {}", e), Err(e) => {
warn!("failed to export process stats: {}", e);
return;
}
} }
thread::sleep(Duration::from_secs(5)); thread::sleep(Duration::from_secs(5));
}); });