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

处理tcp加密注册失败的问题

Browse Source
This commit is contained in:
lbl8603
2024-04-21 18:48:18 +08:00
parent 5bdc514606
commit 0b570130e8
2 changed files with 4 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
vnt/src/channel/context.rs
+1 -4
View File
@@ -199,10 +199,7 @@ impl ContextInner {
self.send_main_udp(self.main_index.load(Ordering::Relaxed), buf, addr) 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) { pub fn change_main_index(&self) {
let index = (self.main_index.load(Ordering::Relaxed) + 1) % self.main_udp_socket.len(); let index = (self.main_index.load(Ordering::Relaxed) + 1) % self.main_udp_socket.len();
self.main_index.store(index, Ordering::Relaxed); self.main_index.store(index, Ordering::Relaxed);
vnt/src/handle/recv_data/server.rs
+3 -5
View File
@@ -394,11 +394,9 @@ impl<Call: VntCallback> ServerPacketHandler<Call> {
self.set_device_info_list(response.device_info_list, response.epoch as _); self.set_device_info_list(response.device_info_list, response.epoch as _);
} }
service_packet::Protocol::SecretHandshakeResponse => { service_packet::Protocol::SecretHandshakeResponse => {
if context.is_default_route(route_key) { log::info!("SecretHandshakeResponse");
log::info!("SecretHandshakeResponse"); //加密握手结束，发送注册数据
//加密握手结束，发送注册数据 self.register(current_device, context)?;
self.register(current_device, context)?;
}
} }
_ => { _ => {
log::warn!( log::warn!(