Commit 8d2e070a authored by nanamicat's avatar nanamicat

fix

parent a6800c1e
Pipeline #42085 passed with stages
in 1 minute and 21 seconds
...@@ -87,12 +87,12 @@ impl Router { ...@@ -87,12 +87,12 @@ impl Router {
pub(crate) fn update(&mut self, local_time: u32) -> PeerQuality { pub(crate) fn update(&mut self, local_time: u32) -> PeerQuality {
if self.quality.reliability > 0 { if self.quality.reliability > 0 {
let diff = (local_time.wrapping_sub(self.local_time) as i32 as f64 / INTERVAL.as_millis() as f64).round() as i32; let diff = local_time.wrapping_sub(self.local_time);
// 有几个包没到 // 有几个包没到
if diff > TIMEOUT.as_millis() as i32 { if diff > TIMEOUT.as_millis() as u32 {
self.reset(); self.reset();
} else if diff >= (INTERVAL.as_millis() * 2) as i32 { } else if diff >= (INTERVAL.as_millis() * 2) as u32 {
self.quality.reliability = self.quality.reliability.saturating_sub(255 / HISTORY); self.quality.reliability = self.quality.reliability.saturating_sub(255 / HISTORY);
} }
} }
......
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