Commit bfc663da authored by nanamicat's avatar nanamicat

fix

parent f2b4f3d2
Pipeline #42430 passed with stages
in 2 minutes and 59 seconds
......@@ -7,8 +7,6 @@ use std::net::{IpAddr, Ipv4Addr, SocketAddr};
use std::time::SystemTime;
use tokio::time::Instant;
const WINDOW_SIZE: u32 = 64; // 用于计算丢包率的窗口大小(通常64或128)
pub struct Router {
pub link_address: SocketAddr,
seq: u32,
......@@ -47,10 +45,10 @@ impl Router {
pub fn on_message(&mut self, data: &Hello) {
let delay = (SystemTime::now().duration_since(SystemTime::UNIX_EPOCH).unwrap().as_millis() as u32).wrapping_sub(data.time) as i32;
self.delay += (delay - self.delay) / 16;
self.delay += (delay - self.delay) / 8;
let d = (delay - self.prev_delay).abs();
self.jitter += (d - self.jitter) / 16;
self.jitter += (d - self.jitter) / 8;
self.prev_delay = delay;
let delta = data.seq.wrapping_sub(self.seq) as i32;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment