- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 875 for Millisecond (0.4 sec)
-
staging/src/k8s.io/apiextensions-apiserver/test/integration/fixtures/resources.go
// wait until all resources appears in discovery for _, version := range servedV1Versions(crd) { err := wait.PollImmediate(500*time.Millisecond, 30*time.Second, func() (bool, error) { return existsInDiscoveryV1(crd, apiExtensionsClient, version) }) if err != nil { return nil, err } } return crd, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 19 02:01:40 UTC 2021 - 21.4K bytes - Viewed (0) -
pilot/pkg/config/monitor/monitor_test.go
defer func() { close(stop) }() mon.Start(stop) go func() { for i := 0; i < 10; i++ { select { case <-stop: return case mon.updateCh <- struct{}{}: } time.Sleep(time.Millisecond * 100) } }() g.Eventually(func() error { c := store.List(gvk.Gateway, "") if len(c) != 1 { return errors.New("no configs") } if c[0].Meta.Name != "magic" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 4.8K bytes - Viewed (0) -
internal/grid/muxserver.go
var cancel context.CancelFunc ctx = setCaller(ctx, c.remote) if msg.DeadlineMS > 0 { ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond) } else { ctx, cancel = context.WithCancel(ctx) } m := muxServer{ ID: msg.MuxID, RecvSeq: msg.Seq + 1, SendSeq: msg.Seq, ctx: ctx, cancel: cancel, parent: c,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue6997_linux.go
import ( "testing" "time" ) func test6997(t *testing.T) { r := C.StartThread() if r != 0 { t.Error("pthread_create failed") } c := make(chan C.int) go func() { time.Sleep(500 * time.Millisecond) c <- C.CancelThread() }() select { case r = <-c: if r == 0 { t.Error("pthread finished but wasn't canceled??") } case <-time.After(30 * time.Second):
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 12:00:02 UTC 2023 - 879 bytes - Viewed (0) -
pkg/kubelet/config/file_linux_test.go
ch := make(chan interface{}, 1) lw := newSourceFile("/some/fake/file", "localhost", time.Millisecond, ch) err := lw.doWatch() if err == nil { t.Errorf("Expected error") } } func TestUpdateOnNonExistentFile(t *testing.T) { ch := make(chan interface{}) NewSourceFile("random_non_existent_path", "localhost", time.Millisecond, ch) select { case got := <-ch: update := got.(kubetypes.PodUpdate)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 14 09:38:23 UTC 2022 - 12.3K bytes - Viewed (0) -
cni/test/install_cni.go
// We should have waited for the delayed conf return fmt.Errorf("did not wait for valid config file") } return nil }, retry.Delay(time.Millisecond), retry.Timeout(time.Millisecond*250)) var destFilenm string if preConfFile != "" { destFilenm = preConfFile } else { destFilenm = delayedConfFile } cp(delayedConfFile, tempCNIConfDir+"/"+destFilenm, t)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 11.4K bytes - Viewed (0) -
src/cmd/cgo/internal/testcarchive/testdata/libgo/libgo.go
"time" _ "testcarchive/p" ) import "C" var initCh = make(chan int, 1) var ranMain bool func init() { // emulate an exceedingly slow package initialization function time.Sleep(100 * time.Millisecond) initCh <- 42 } func main() { ranMain = true } //export DidInitRun func DidInitRun() bool { select { case x := <-initCh: if x != 42 { // Just in case initCh was not correctly made.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 977 bytes - Viewed (0) -
cmd/kubeadm/app/discovery/token/token_test.go
} // Set arbitrary discovery timeout and retry interval timeout := time.Millisecond * 500 interval := time.Millisecond * 20 // Patch the JWS signature after a short delay if test.delayedJWSSignaturePatch { test.configMap.data[bootstrapapi.JWSSignatureKeyPrefix+test.tokenID] = sig go func() { time.Sleep(time.Millisecond * 60) if err := test.configMap.createOrUpdate(client); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 10.9K bytes - Viewed (0) -
src/runtime/norace_linux_test.go
// that require a valid G/M. func TestNewOSProc0(t *testing.T) { runtime.NewOSProc0(0x800000, unsafe.Pointer(abi.FuncPCABIInternal(newOSProcCreated))) check := time.NewTicker(100 * time.Millisecond) defer check.Stop() end := time.After(5 * time.Second) for { select { case <-check.C: if newOSProcDone { return } case <-end: t.Fatalf("couldn't create new OS process") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 05 17:54:15 UTC 2022 - 915 bytes - Viewed (0) -
test/fixedbugs/issue16016.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:39:06 UTC 2024 - 877 bytes - Viewed (0)