- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 875 for Millisecond (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
}) namespacedObject2.SetGroupVersionKind(fakeGVK) require.NoError(t, tracker.Add(object1)) require.NoError(t, tracker.Add(object2)) require.NoError(t, wait.PollWithContext(testContext, 100*time.Millisecond, 500*time.Millisecond, func(ctx context.Context) (done bool, err error) { return myController.Informer().LastSyncResourceVersion() == object2.GetResourceVersion(), nil }))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stacks.go
defer wp.Close() pipeReadDone := make(chan bool) go func() { // func11 var data [1]byte rp.Read(data[:]) pipeReadDone <- true }() time.Sleep(100 * time.Millisecond) runtime.GC() runtime.Gosched() time.Sleep(100 * time.Millisecond) // the last chance for the goroutines above to block done1 <- true <-done2 select { case c1 <- 0: case c2 <- 0: } mu.Unlock() wg.Done()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.4K bytes - Viewed (0) -
src/net/tcpsock_unix_test.go
for i := 0; i < attempts; i++ { throttle <- struct{}{} go func(i int) { defer func() { <-throttle wg.Done() }() d := Dialer{Timeout: 50 * time.Millisecond} c, err := d.Dial(ln.Addr().Network(), ln.Addr().String()) if err != nil { if perr := parseDialError(err); perr != nil { t.Errorf("#%d: %v (original error: %v)", i, perr, err) } return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 2.3K bytes - Viewed (0) -
src/runtime/race/testdata/sync_test.go
done := make(chan bool) var mu sync.Mutex cond := sync.NewCond(&mu) x := 0 _ = x condition := 0 go func() { time.Sleep(10 * time.Millisecond) // Enter cond.Wait loop x = 1 mu.Lock() condition = 1 cond.Signal() mu.Unlock() time.Sleep(10 * time.Millisecond) // Exit cond.Wait loop mu.Lock() x = 3 mu.Unlock() done <- true }() mu.Lock() for condition != 1 { cond.Wait() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 10 15:05:17 UTC 2020 - 3K bytes - Viewed (0) -
cmd/kubeadm/app/util/initsystem/initsystem_windows.go
timeout := time.Now().Add(10 * time.Second) for status.State != svc.Stopped { if timeout.Before(time.Now()) { return errors.Errorf("timeout waiting for %s service to stop", service) } time.Sleep(300 * time.Millisecond) status, err = s.Query() if err != nil { return errors.Wrapf(err, "could not retrieve %s service status", service) } } // Start the service err = s.Start("is", "manual-started") if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 08:56:16 UTC 2022 - 6.4K bytes - Viewed (0) -
pkg/test/loadbalancersim/lb_test.go
2: 1, } networkLatencies := map[mesh.RouteKey]time.Duration{ { Src: sameZone, Dest: sameZone, }: 1 * time.Millisecond, { Src: sameZone, Dest: sameRegion, }: 10 * time.Millisecond, { Src: sameZone, Dest: otherRegion, }: 100 * time.Millisecond, } networkLatencyCases := []struct { enable bool latencies map[mesh.RouteKey]time.Duration }{ {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 19 23:29:30 UTC 2022 - 11K bytes - Viewed (0) -
security/pkg/pki/ca/selfsignedcarootcertrotator_test.go
rotator.config.CheckInterval = 500 * time.Millisecond rootCertRotatorChan := make(chan struct{}) go rotator.Run(rootCertRotatorChan) defer close(rootCertRotatorChan) // Wait until root cert rotation is done. time.Sleep(600 * time.Millisecond) certItem1 := loadCert(rotator) verifyRootCertAndPrivateKey(t, false, certItem0, certItem1) time.Sleep(600 * time.Millisecond) certItem2 := loadCert(rotator)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 11 23:33:41 UTC 2023 - 14.1K bytes - Viewed (0) -
pkg/kubelet/winstats/perfcounters_test.go
// networking-related counters. if tc.skipCheck { return } // Wait until we get a non-zero perf counter data. if pollErr := wait.Poll(100*time.Millisecond, 5*perfCounterUpdatePeriod, func() (bool, error) { data, err := counter.getData() if err != nil { return false, err } if data != 0 { return true, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 3.5K bytes - Viewed (0) -
src/net/tcpconn_keepalive_illumos_test.go
} tcpKeepAliveThreshold, err := syscall.GetsockoptInt(fd, syscall.IPPROTO_TCP, syscall.TCP_KEEPALIVE_THRESHOLD) if err != nil { t.Fatal(err) } if time.Duration(tcpKeepAliveThreshold)*time.Millisecond != cfg.Idle { t.Fatalf("TCP_KEEPALIVE_THRESHOLD: got %dms; want %v", tcpKeepAliveThreshold, cfg.Idle) } tcpKeepAliveInterval, err := syscall.GetsockoptInt(fd, syscall.IPPROTO_TCP, syscall_TCP_KEEPINTVL)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sun Apr 14 18:17:21 UTC 2024 - 4K bytes - Viewed (0) -
src/os/exec_plan9.go
return p.status } func (p *ProcessState) userTime() time.Duration { return time.Duration(p.status.Time[0]) * time.Millisecond } func (p *ProcessState) systemTime() time.Duration { return time.Duration(p.status.Time[1]) * time.Millisecond } func (p *ProcessState) String() string { if p == nil { return "<nil>" } return "exit status: " + p.status.Msg }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 3.4K bytes - Viewed (0)