diff --git a/vnt/src/channel/context.rs b/vnt/src/channel/context.rs index f462953..8f47f8b 100644 --- a/vnt/src/channel/context.rs +++ b/vnt/src/channel/context.rs @@ -199,10 +199,7 @@ impl ContextInner { self.send_main_udp(self.main_index.load(Ordering::Relaxed), buf, addr) } } - pub fn is_default_route(&self, route_key: RouteKey) -> bool { - self.is_tcp == route_key.is_tcp - && self.main_index.load(Ordering::Relaxed) == route_key.index - } + pub fn change_main_index(&self) { let index = (self.main_index.load(Ordering::Relaxed) + 1) % self.main_udp_socket.len(); self.main_index.store(index, Ordering::Relaxed); diff --git a/vnt/src/handle/recv_data/server.rs b/vnt/src/handle/recv_data/server.rs index 58c6408..1a6279a 100644 --- a/vnt/src/handle/recv_data/server.rs +++ b/vnt/src/handle/recv_data/server.rs @@ -394,11 +394,9 @@ impl ServerPacketHandler { self.set_device_info_list(response.device_info_list, response.epoch as _); } service_packet::Protocol::SecretHandshakeResponse => { - if context.is_default_route(route_key) { - log::info!("SecretHandshakeResponse"); - //加密握手结束,发送注册数据 - self.register(current_device, context)?; - } + log::info!("SecretHandshakeResponse"); + //加密握手结束,发送注册数据 + self.register(current_device, context)?; } _ => { log::warn!(