Superminaren
/
kvm
mirror of https://github.com/jetkvm/kvm.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix(ntp): make sure queryMultipleNTP finish if all servers failed

This commit is contained in:
Qishuai Liu 2025-05-08 11:31:40 +09:00
parent 77089ea497
commit c13e1e11c5
No known key found for this signature in database
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/timesync/ntp.go
View File

@ -62,6 +62,7 @@ func (t *TimeSync) queryMultipleNTP(servers []string, timeout time.Duration) (no
scopedLogger.Warn(). scopedLogger.Warn().
Str("error", err.Error()). Str("error", err.Error()).
Msg("failed to query NTP server") Msg("failed to query NTP server")
results <- nil
return return
} }
@ -101,8 +102,15 @@ func (t *TimeSync) queryMultipleNTP(servers []string, timeout time.Duration) (no
}(server) }(server)
} }
result := <-results for range servers {
return result.now, result.offset result := <-results
if result == nil {
continue
}
now, offset = result.now, result.offset
return
}
return
} }
func queryNtpServer(server string, timeout time.Duration) (now *time.Time, response *ntp.Response, err error) { func queryNtpServer(server string, timeout time.Duration) (now *time.Time, response *ntp.Response, err error) {