|
@@ -715,7 +715,12 @@ func makeTunneledNTPRequestAttempt(
|
|
|
|
|
|
|
|
// Tunneled NTP request
|
|
// Tunneled NTP request
|
|
|
|
|
|
|
|
- go localUDPProxy(addrs[0][len(addrs[0])-4:], 123, nil)
|
|
|
|
|
|
|
+ waitGroup = new(sync.WaitGroup)
|
|
|
|
|
+ waitGroup.Add(1)
|
|
|
|
|
+ go localUDPProxy(
|
|
|
|
|
+ addrs[0][len(addrs[0])-4:],
|
|
|
|
|
+ 123,
|
|
|
|
|
+ waitGroup)
|
|
|
// TODO: properly synchronize with local UDP proxy startup
|
|
// TODO: properly synchronize with local UDP proxy startup
|
|
|
time.Sleep(1 * time.Second)
|
|
time.Sleep(1 * time.Second)
|
|
|
|
|
|
|
@@ -766,6 +771,8 @@ func makeTunneledNTPRequestAttempt(
|
|
|
return fmt.Errorf("Unexpected NTP time: %s; local time: %s", ntpNow, now)
|
|
return fmt.Errorf("Unexpected NTP time: %s; local time: %s", ntpNow, now)
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ waitGroup.Wait()
|
|
|
|
|
+
|
|
|
return nil
|
|
return nil
|
|
|
}
|
|
}
|
|
|
|
|
|