tyler/proxmox-backup
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

src/bin/proxmox-backup-proxy.rs: use block_in_place for rrd update

Browse Source
This commit is contained in:
Dietmar Maurer 2020-05-25 08:30:59 +02:00
parent 736edc7a7e
commit 4f9513996c
1 changed files with 42 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

82
src/bin/proxmox-backup-proxy.rs
View File

@ -605,50 +605,52 @@ async fn generate_host_stats() {
read_meminfo, read_proc_stat, read_proc_net_dev}; read_meminfo, read_proc_stat, read_proc_net_dev};
use proxmox_backup::rrd; use proxmox_backup::rrd;
match read_proc_stat() { proxmox_backup::tools::runtime::block_in_place(move || {
Ok(stat) => {
if let Err(err) = rrd::update_value("host/cpu", stat.cpu, rrd::DST::Gauge) {
eprintln!("rrd::update_value 'host/cpu' failed - {}", err);
}
}
Err(err) => {
eprintln!("read_proc_stat failed - {}", err);
}
}
match read_meminfo() {
Ok(meminfo) => {
if let Err(err) = rrd::update_value("host/memtotal", meminfo.memtotal as f64, rrd::DST::Gauge) {
eprintln!("rrd::update_value 'host/memtotal' failed - {}", err);
}
if let Err(err) = rrd::update_value("host/memused", meminfo.memused as f64, rrd::DST::Gauge) {
eprintln!("rrd::update_value 'host/memused' failed - {}", err);
}
}
Err(err) => {
eprintln!("read_meminfo failed - {}", err);
}
}
match read_proc_net_dev() { match read_proc_stat() {
Ok(netdev) => { Ok(stat) => {
use proxmox_backup::config::network::is_physical_nic; if let Err(err) = rrd::update_value("host/cpu", stat.cpu, rrd::DST::Gauge) {
let mut netin = 0; eprintln!("rrd::update_value 'host/cpu' failed - {}", err);
let mut netout = 0; }
for item in netdev {
if !is_physical_nic(&item.device) { continue; }
netin += item.receive;
netout += item.send;
} }
if let Err(err) = rrd::update_value("host/netin", netin as f64, rrd::DST::Derive) { Err(err) => {
eprintln!("rrd::update_value 'host/netin' failed - {}", err); eprintln!("read_proc_stat failed - {}", err);
}
if let Err(err) = rrd::update_value("host/netout", netout as f64, rrd::DST::Derive) {
eprintln!("rrd::update_value 'host/netout' failed - {}", err);
} }
} }
Err(err) => { match read_meminfo() {
eprintln!("read_prox_net_dev failed - {}", err); Ok(meminfo) => {
if let Err(err) = rrd::update_value("host/memtotal", meminfo.memtotal as f64, rrd::DST::Gauge) {
eprintln!("rrd::update_value 'host/memtotal' failed - {}", err);
}
if let Err(err) = rrd::update_value("host/memused", meminfo.memused as f64, rrd::DST::Gauge) {
eprintln!("rrd::update_value 'host/memused' failed - {}", err);
}
}
Err(err) => {
eprintln!("read_meminfo failed - {}", err);
}
} }
}
match read_proc_net_dev() {
Ok(netdev) => {
use proxmox_backup::config::network::is_physical_nic;
let mut netin = 0;
let mut netout = 0;
for item in netdev {
if !is_physical_nic(&item.device) { continue; }
netin += item.receive;
netout += item.send;
}
if let Err(err) = rrd::update_value("host/netin", netin as f64, rrd::DST::Derive) {
eprintln!("rrd::update_value 'host/netin' failed - {}", err);
}
if let Err(err) = rrd::update_value("host/netout", netout as f64, rrd::DST::Derive) {
eprintln!("rrd::update_value 'host/netout' failed - {}", err);
}
}
Err(err) => {
eprintln!("read_prox_net_dev failed - {}", err);
}
}
});
} }