.into());
// handle renaming
- match iface_name {
- Some(iface_name) => {
- let iface_renamed = iface.borrow().name != iface_name;
- if iface_renamed {
- log::trace!("name change: {iface:?} now named '{iface_name}'");
- iface.borrow_mut().name = iface_name;
- }
- },
- None => {},
+ if let Some(iface_name) = iface_name {
+ let iface_renamed = iface.borrow().name != iface_name;
+ if iface_renamed {
+ log::trace!("name change: {iface:?} now named '{iface_name}'");
+ iface.borrow_mut().name = iface_name;
+ }
};
Ok((iface.clone(), mac_address))
use clap::Parser;
-use crate::datastructs::{KernelInfo, NetInterfaceCache};
+use crate::datastructs::KernelInfo;
use crate::publisher::Publisher;
use crate::collector_net::NetworkSource;
use crate::collector_memory::MemorySource;
let mut timer_stream = tokio::time::interval(Duration::from_secs(MEM_PERIOD_SECONDS));
// network events
- let network_cache = Box::leak(Box::new(NetInterfaceCache::new()));
+ let network_cache = Box::leak(Box::default());
let mut collector_net = NetworkSource::new(network_cache)?;
for event in collector_net.collect_current().await? {
if REPORT_INTERNAL_NICS || ! event.iface.borrow().toolstack_iface.is_none() {
return ToolstackNetInterface::None;
}
let vif_id = nodename[PREFIX.len()..].parse().unwrap();
- return ToolstackNetInterface::Vif(vif_id);
+
+ ToolstackNetInterface::Vif(vif_id)
},
Err(e) => {
log::error!("reading {device_path}/nodename: {e}");
- return ToolstackNetInterface::None;
+
+ ToolstackNetInterface::None
},
}
},
Err(e) => {
log::debug!("reading {device_path}/devtype: {e}");
- return ToolstackNetInterface::None;
+
+ ToolstackNetInterface::None
},
}
}
let xs_iface_prefix = format!("attr/vif/{iface_id}");
match &event.op {
NetEventOp::AddIface => {
- xs_publish(&self.xs, &format!("{xs_iface_prefix}"), "")?;
+ xs_publish(&self.xs, &xs_iface_prefix, "")?;
},
NetEventOp::RmIface => {
- xs_unpublish(&self.xs, &format!("{xs_iface_prefix}"))?;
+ xs_unpublish(&self.xs, &xs_iface_prefix)?;
},
NetEventOp::AddIp(address) => {
let key_suffix = self.munged_address(address, &event.iface.borrow())?;