yeyinlaoying/vnt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

[mio] 返回详细路由

Browse Source
This commit is contained in:
lubeilin
2024-03-10 14:10:49 +08:00
parent 996a80e710
commit 03529bc339
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
vnt/src/channel/idle.rs
+3 -3
View File
@@ -2,7 +2,7 @@ use std::net::Ipv4Addr;
use std::time::Duration; use std::time::Duration;
use crate::channel::context::Context; use crate::channel::context::Context;
use crate::channel::RouteKey; use crate::channel::Route;
pub struct Idle { pub struct Idle {
read_idle: Duration, read_idle: Duration,
@@ -16,7 +16,7 @@ impl Idle {
} }
pub enum IdleType { pub enum IdleType {
Timeout(Ipv4Addr, RouteKey), Timeout(Ipv4Addr, Route),
Sleep(Duration), Sleep(Duration),
None, None,
} }
@@ -33,7 +33,7 @@ impl Idle {
for (route, time) in routes { for (route, time) in routes {
let last_read = time.load().elapsed(); let last_read = time.load().elapsed();
if last_read >= self.read_idle { if last_read >= self.read_idle {
return IdleType::Timeout(*ip, route.route_key()); return IdleType::Timeout(*ip, *route);
} else if max < last_read { } else if max < last_read {
max = last_read; max = last_read;
} }