- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 81 for wait4 (0.38 sec)
-
staging/src/k8s.io/apiserver/plugin/pkg/authenticator/token/oidc/oidc_test.go
if err != nil { t.Fatalf("sign claims: %v", err) } token, err := jws.CompactSerialize() if err != nil { t.Fatalf("serialize token: %v", err) } // wait for the authenticator to be healthy err = wait.PollUntilContextCancel(ctx, time.Millisecond, true, func(context.Context) (bool, error) { return a.HealthCheck() == nil, nil }) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 97.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
// Once the backing futures are done there's a (brief) moment where we know nothing assertThat(futureResult.toString()).matches("CombinedFuture@\\w+\\[status=PENDING]"); callableBlocking.countDown(); // Need to wait for resultFuture to be returned. assertTrue(executor.awaitTermination(10, SECONDS)); // But once the async function has returned a future we can include that in the toString assertThat(futureResult.toString())
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
// Once the backing futures are done there's a (brief) moment where we know nothing assertThat(futureResult.toString()).matches("CombinedFuture@\\w+\\[status=PENDING]"); callableBlocking.countDown(); // Need to wait for resultFuture to be returned. assertTrue(executor.awaitTermination(10, SECONDS)); // But once the async function has returned a future we can include that in the toString assertThat(futureResult.toString())
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
cmd/bucket-replication.go
defer wg.Done() tgtInfo := replicateDeleteToTarget(ctx, dobj, tgt) mu.Lock() rinfos.Targets = append(rinfos.Targets, tgtInfo) mu.Unlock() }(tgtClnt) } wg.Wait() replicationStatus = rinfos.ReplicationStatus() prevStatus := dobj.DeleteMarkerReplicationStatus() if dobj.VersionID != "" { prevStatus = replication.StatusType(dobj.VersionPurgeStatus())
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
} // If the pod originates from the kube-api, when we know that the kube-apiserver is responding and the kubelet's credentials are valid. // Knowing this, it is reasonable to wait until the service lister has synchronized at least once before attempting to build // a service env var map. This doesn't present the race below from happening entirely, but it does prevent the "obvious"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/volume/util/operationexecutor/operation_generator.go
} if podSc.FSGroupChangePolicy != nil { fsGroupChangePolicy = podSc.FSGroupChangePolicy } } devicePath := volumeToMount.DevicePath if volumeAttacher != nil { // Wait for attachable volumes to finish attaching klog.InfoS(volumeToMount.GenerateMsgDetailed("MountVolume.WaitForAttach entering", fmt.Sprintf("DevicePath %q", volumeToMount.DevicePath)), "pod", klog.KObj(volumeToMount.Pod))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/apiserver_test.go
t.Errorf("unexpected error: %v", err) } wg := sync.WaitGroup{} wg.Add(1) var response *http.Response go func() { response, err = client.Do(request) wg.Done() }() wg.Wait() if err != nil { t.Errorf("unexpected error: %v", err) } // empty name is not allowed for NamedCreater if response.StatusCode != http.StatusBadRequest { t.Errorf("Unexpected response %#v", response)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 20:15:22 UTC 2023 - 158.7K bytes - Viewed (0) -
cmd/admin-handlers.go
if ok { continue } client := client ng.Go(ctx, func() error { return client.CommitBinary(ctx) }, idx, *client.host) } for _, nerr := range ng.Wait() { if nerr.Err != nil { prs, ok := peerResults[nerr.Host.String()] if ok { prs.Err = nerr.Err.Error() peerResults[nerr.Host.String()] = prs } else {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
src/cmd/trace/testdata/go122.test
String id=9 data="sync.(*Cond).Wait" String id=10 data="sync" String id=11 data="chan send" String id=12 data="chan receive" String id=13 data="GC mark assist wait for work" String id=14 data="GC background sweeper wait" String id=15 data="system goroutine wait" String id=16 data="preempted" String id=17 data="wait for debug call" String id=18
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 17:15:58 UTC 2024 - 166K bytes - Viewed (0) -
pkg/controller/daemon/daemon_controller_test.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/util/intstr" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/uuid" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apiserver/pkg/storage/names" "k8s.io/client-go/informers" "k8s.io/client-go/kubernetes/fake" core "k8s.io/client-go/testing" "k8s.io/client-go/tools/cache" "k8s.io/client-go/tools/record"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0)