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

修复打洞问题

Browse Source
This commit is contained in:
lbl8603
2024-08-01 23:23:23 +08:00
parent e8322adbcc
commit 64d68c8a84
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
vnt/src/handle/maintain/punch.rs
+4 -5
View File
@@ -251,7 +251,7 @@ fn punch0(
.collect(); .collect();
list.shuffle(&mut rand::thread_rng()); list.shuffle(&mut rand::thread_rng());
for info in list { for info in list {
if info.status.is_online() { if info.status.is_offline() {
// 客户端掉线了要重置打洞记录 // 客户端掉线了要重置打洞记录
punch_record.lock().remove(&info.virtual_ip); punch_record.lock().remove(&info.virtual_ip);
continue; continue;
@@ -266,12 +266,11 @@ fn punch0(
let p2p_num = context.route_table.p2p_num(&info.virtual_ip); let p2p_num = context.route_table.p2p_num(&info.virtual_ip);
let mut max_punch_interval = 50; let mut max_punch_interval = 50;
if p2p_num > 0 { if p2p_num > 0 {
if punch_count == 0 {
continue;
}
if p2p_num >= context.channel_num() { if p2p_num >= context.channel_num() {
//通道数满足要求，不再打洞 //通道数满足要求，不再打洞
punch_record.lock().remove(&info.virtual_ip); if punch_count != 0 {
punch_record.lock().remove(&info.virtual_ip);
}
continue; continue;
} }
//有p2p通道，但是通道数量不够，则继续打洞 //有p2p通道，但是通道数量不够，则继续打洞