Merge 77089ea497 into d79f359c43

internal/timesync/ntp.go

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