pangolin_mirror/olm
1
0
Fork 0
mirror of https://github.com/fosrl/olm.git synced 2026-02-08 05:56:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add timeouts to hp

Browse Source 
Former-commit-id: fa1d2b1f55
This commit is contained in:
Owen
2025-09-29 14:55:19 -07:00
parent 2be0933246
commit dc9a547950
1 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
common.go
View File

@@ -402,11 +402,17 @@ func keepSendingUDPHolePunchToMultipleExitNodes(exitNodes []ExitNode, olmID stri
ticker := time.NewTicker(250 * time.Millisecond) ticker := time.NewTicker(250 * time.Millisecond)
defer ticker.Stop() defer ticker.Stop()
timeout := time.NewTimer(15 * time.Second)
defer timeout.Stop()
for { for {
select { select {
case <-stopHolepunch: case <-stopHolepunch:
logger.Info("Stopping UDP holepunch for all exit nodes") logger.Info("Stopping UDP holepunch for all exit nodes")
return return
case <-timeout.C:
logger.Info("UDP holepunch routine timed out after 15 seconds for all exit nodes")
return
case <-ticker.C: case <-ticker.C:
// Send hole punch to all exit nodes // Send hole punch to all exit nodes
for _, node := range resolvedNodes { for _, node := range resolvedNodes {
@@ -471,11 +477,17 @@ func keepSendingUDPHolePunch(endpoint string, olmID string, sourcePort uint16, s
ticker := time.NewTicker(250 * time.Millisecond) ticker := time.NewTicker(250 * time.Millisecond)
defer ticker.Stop() defer ticker.Stop()
timeout := time.NewTimer(15 * time.Second)
defer timeout.Stop()
for { for {
select { select {
case <-stopHolepunch: case <-stopHolepunch:
logger.Info("Stopping UDP holepunch") logger.Info("Stopping UDP holepunch")
return return
case <-timeout.C:
logger.Info("UDP holepunch routine timed out after 15 seconds")
return
case <-ticker.C: case <-ticker.C:
if err := sendUDPHolePunchWithConn(conn, remoteAddr, olmID, serverPubKey); err != nil { if err := sendUDPHolePunchWithConn(conn, remoteAddr, olmID, serverPubKey); err != nil {
logger.Error("Failed to send UDP hole punch: %v", err) logger.Error("Failed to send UDP hole punch: %v", err)