- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 875 for Millisecond (0.15 sec)
-
staging/src/k8s.io/apimachinery/pkg/watch/streamwatcher_test.go
} } func TestStreamWatcherRace(t *testing.T) { fd := fakeDecoder{err: fmt.Errorf("test error")} fr := &fakeReporter{} sw := NewStreamWatcher(fd, fr) time.Sleep(10 * time.Millisecond) sw.Stop() time.Sleep(10 * time.Millisecond) _, ok := <-sw.ResultChan() if ok { t.Fatalf("unexpected pending send") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 06 13:42:59 UTC 2021 - 2.5K bytes - Viewed (0) -
src/crypto/cipher/fuzz_test.go
c, _ := aes.NewCipher(ft.key) cbcAsm := cipher.NewCBCEncrypter(c, commonIV) cbcGeneric := cipher.NewCBCGenericEncrypter(c, commonIV) if testing.Short() { timeout = time.NewTimer(10 * time.Millisecond) } else { timeout = time.NewTimer(2 * time.Second) } indata := make([]byte, datalen) outgeneric := make([]byte, datalen) outdata := make([]byte, datalen) fuzzencrypt: for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 03 13:39:12 UTC 2022 - 2K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/time_budget.go
limitations under the License. */ package cacher import ( "sync" "time" "k8s.io/utils/clock" ) const ( refreshPerSecond = 50 * time.Millisecond maxBudget = 100 * time.Millisecond ) // timeBudget implements a budget of time that you can use and is // periodically being refreshed. The pattern to use it is: // // budget := newTimeBudget(...) // ...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2.6K bytes - Viewed (0) -
src/net/http/pprof/pprof_test.go
} // causes mutexHog2 call stacks to appear in the mutex profile. done := make(chan bool) go func() { for { mutexHog(20*time.Millisecond, mutexHog2) select { case <-done: done <- true return default: time.Sleep(10 * time.Millisecond) } } }() defer func() { // cleanup the above goroutine. done <- true <-done // wait for the goroutine to exit. }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Dec 07 19:52:28 UTC 2023 - 9.7K bytes - Viewed (0) -
pkg/hbone/dialer_test.go
c.Write([]byte(data)) c.Close() } }() t.Cleanup(func() { n.Close() }) return n.Addr().String() } func TestDialerError(t *testing.T) { timeout := 500 * time.Millisecond d := NewDialer(Config{ ProxyAddress: "127.0.0.10:1", // Random address that should fail to dial Headers: map[string][]string{ "some-addition-metadata": {"test-value"}, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 26 23:44:52 UTC 2023 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/time_budget_test.go
func TestTimeBudget(t *testing.T) { fakeClock := testingclock.NewFakeClock(time.Now()) budget := &timeBudgetImpl{ clock: fakeClock, budget: time.Duration(0), maxBudget: 200 * time.Millisecond, refresh: 50 * time.Millisecond, last: fakeClock.Now(), } if res := budget.takeAvailable(); res != time.Duration(0) { t.Errorf("Expected: %v, got: %v", time.Duration(0), res) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 15 09:52:18 UTC 2021 - 2.8K bytes - Viewed (0) -
src/cmd/go/testdata/script/cpu_profile_twice.txt
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 19 19:57:03 UTC 2019 - 391 bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager_test.go
if secret == nil || secret.Name != "name" || secret.Namespace != "ns" { return false, fmt.Errorf("unexpected secret: %v", secret) } return true, nil } if err := wait.PollImmediate(10*time.Millisecond, time.Second, getFn); err != nil { t.Errorf("unexpected error: %v", err) } // Eventually we should observer secret deletion. fakeWatch.Delete(secret) getFn = func() (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 09 10:05:43 UTC 2023 - 17.2K bytes - Viewed (0) -
pkg/controller/cronjob/cronjob_controllerv2_test.go
stillActive: true, jobCreationTime: topOfTheHour().Add(time.Millisecond * 100), now: justAfterTheHour().Add(time.Millisecond * 100), expectActive: 1, expectRequeueAfter: true, expectedRequeueDuration: 1*time.Hour - 1*time.Minute - time.Millisecond*100 + nextScheduleDelta, jobStillNotFoundInLister: true, jobPresentInCJActiveStatus: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 70.8K bytes - Viewed (0)