punchnet/sdlan-lib-rs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

statics for rx_sup, rx_p2p, and rx_broadcast

Browse Source
This commit is contained in:
asxalex 2024-07-10 16:59:36 +08:00
parent a81909c2ac
commit d26f9d6d43
1 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/network/packet.rs
View File

@ -631,16 +631,6 @@ async fn handle_tun_packet(
pkt: SdlData, //orig_sender: &SdlanSock
) {
let now = get_current_timestamp();
if from_sn {
if is_multi_broadcast(pkt.dst_ip) {
eee.stats.rx_broadcast.fetch_add(1, Ordering::Relaxed);
}
eee.stats.rx_sup.fetch_add(1, Ordering::Relaxed);
eee.stats.last_sup.store(now, Ordering::Relaxed);
} else {
eee.stats.rx_p2p.fetch_add(1, Ordering::Relaxed);
eee.stats.last_p2p.store(now, Ordering::Relaxed);
}
let payload = pkt.data;
let key = eee.get_encrypt_key();
@ -656,6 +646,20 @@ async fn handle_tun_packet(
return;
}
let data = origin.unwrap();
let msg_size = data.len() as u64;
if from_sn {
if is_multi_broadcast(pkt.dst_ip) {
eee.stats
.rx_broadcast
.fetch_add(msg_size, Ordering::Relaxed);
}
eee.stats.rx_sup.fetch_add(msg_size, Ordering::Relaxed);
eee.stats.last_sup.store(now, Ordering::Relaxed);
} else {
eee.stats.rx_p2p.fetch_add(msg_size, Ordering::Relaxed);
eee.stats.last_p2p.store(now, Ordering::Relaxed);
}
debug!("got packet from sock, will send to tun");
match IpHeaders::from_slice(&data) {