- Sort Score
- Result 10 results
- Languages All
Results 1 - 1 of 1 for wgDoneOrTimeout (0.83 sec)
-
pilot/pkg/xds/discovery_test.go
for p := 0; p < n; p++ { conn := newConnection("", &fakeStream{}) conn.SetID(fmt.Sprintf("proxy-%v", p)) proxies = append(proxies, conn) } return proxies } func wgDoneOrTimeout(wg *sync.WaitGroup, timeout time.Duration) bool { c := make(chan struct{}) go func() { wg.Wait() c <- struct{}{} }() select { case <-c: return true case <-time.After(timeout):
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0)