From 1eb2a0f5cfb46acd52e102eb3b1a4cdfc574d2dc Mon Sep 17 00:00:00 2001 From: lubeilin <1791778603@qq.com> Date: Sun, 3 Mar 2024 00:35:02 +0800 Subject: [PATCH] =?UTF-8?q?[mio]=20=E5=87=8F=E5=B0=91=E8=AF=BB=E6=9B=B4?= =?UTF-8?q?=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- vnt/src/handle/recv_data/client.rs | 1 + vnt/src/handle/recv_data/mod.rs | 2 -- vnt/src/handle/recv_data/server.rs | 3 ++- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/vnt/src/handle/recv_data/client.rs b/vnt/src/handle/recv_data/client.rs index 8441d81..332780b 100644 --- a/vnt/src/handle/recv_data/client.rs +++ b/vnt/src/handle/recv_data/client.rs @@ -165,6 +165,7 @@ impl ClientPacketHandler { ) -> io::Result<()> { let metric = net_packet.source_ttl() - net_packet.ttl() + 1; let source = net_packet.source(); + context.route_table.update_read_time(&source, &route_key); match ControlPacket::new(net_packet.transport_protocol(), net_packet.payload())? { ControlPacket::PingPacket(_) => { net_packet.set_transport_protocol(control_packet::Protocol::Pong.into()); diff --git a/vnt/src/handle/recv_data/mod.rs b/vnt/src/handle/recv_data/mod.rs index 0b91168..408c1fd 100644 --- a/vnt/src/handle/recv_data/mod.rs +++ b/vnt/src/handle/recv_data/mod.rs @@ -112,8 +112,6 @@ impl RecvDataHandler { } let current_device = self.current_device.load(); let dest = net_packet.destination(); - let source = net_packet.source(); - context.route_table.update_read_time(&source, &route_key); if dest == current_device.virtual_ip || dest.is_broadcast() || dest.is_multicast() diff --git a/vnt/src/handle/recv_data/server.rs b/vnt/src/handle/recv_data/server.rs index d75cc26..58bd975 100644 --- a/vnt/src/handle/recv_data/server.rs +++ b/vnt/src/handle/recv_data/server.rs @@ -89,11 +89,12 @@ impl PacketHandler for ServerPacketHandler { context: &Context, current_device: &CurrentDeviceInfo, ) -> io::Result<()> { + context.route_table.update_read_time(&net_packet.source(), &route_key); if net_packet.protocol() == Protocol::Error && net_packet.transport_protocol() == crate::protocol::error_packet::Protocol::NoKey.into() { - //开启服务端加密的情况下,只有这个回应是不加密的,是服务端通知客户端上传密钥 + //服务端通知客户端上传密钥 #[cfg(feature = "server_encrypt")] { let mutex_guard = self.rsa_cipher.lock();