- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 667 for wait4 (0.05 sec)
-
pkg/kube/client.go
ObjectFilter() kubetypes.DynamicObjectFilter // RunAndWait starts all informers and waits for their caches to sync. // Warning: this must be called AFTER .Informer() is called, which will register the informer. // "false" is returned if this prematurely exited without syncing. RunAndWait(stop <-chan struct{}) bool // WaitForCacheSync waits for all cache functions to sync, as well as all informers started by the *fake* client.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
} return this; } /** * Waits for the all the services to reach a terminal state. After this method returns all * services will either be {@linkplain Service.State#TERMINATED terminated} or {@linkplain * Service.State#FAILED failed}. */ public void awaitStopped() { state.awaitStopped(); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:41:16 UTC 2024 - 33K bytes - Viewed (0) -
pkg/controller/podgc/gc_controller.go
// sort only when necessary sort.Sort(byEvictionAndCreationTimestamp(terminatingPods)) var wait sync.WaitGroup for i := 0; i < deleteCount; i++ { wait.Add(1) go func(pod *v1.Pod) { defer wait.Done() metrics.DeletingPodsTotal.WithLabelValues(pod.Namespace, metrics.PodGCReasonTerminatingOutOfService).Inc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/start.go
// A StartResult is a handle to the result of a call to [Start]. Call // [StartResult.Wait] to wait for the completion of all work done on behalf of // Start. type StartResult struct { wg sync.WaitGroup } // Wait waits for the completion of all work initiated by [Start]. func (res *StartResult) Wait() { if res == nil { return } res.wg.Wait() } var daemonize = func(cmd *exec.Cmd) {}
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 14:52:56 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
} synced := []cache.InformerSynced{kvh.csiDriversSynced} if !cache.WaitForCacheSync(wait.NeverStop, synced...) { klog.InfoS("Failed to wait for cache sync for CSIDriverLister") return fmt.Errorf("failed to wait for cache sync for CSIDriverLister") } return nil } func (kvh *kubeletVolumeHost) NewWrapperMounter( volName string, spec volume.Spec, pod *v1.Pod,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
src/runtime/sema.go
// more costly than contention holding up a single goroutine. // It would take O(N) time to calculate how long each goroutine // has been waiting, so instead we charge avg(head-wait, tail-wait)*N. // head-wait is the longest wait and tail-wait is the shortest. // (When we do a lifo insertion, we preserve this property by // copying the old head's acquiretime into the inserted new head.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 19K bytes - Viewed (0) -
src/net/http/transport_dial_test.go
<-rt.done if rt.err != nil { return } rt.reqBody.Close() io.ReadAll(rt.res.Body) rt.res.Body.Close() rt.t.Logf("RoundTrip %v: closed request body", rt.roundTripID) } // wantDial waits for the Transport to start a Dial. func (dt *transportDialTester) wantDial() *transportDialTesterConn { c := <-dt.dials c.connID = dt.dialCount dt.dialCount++ dt.t.Logf("Dial %v: started", c.connID) return c
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 6.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
/** * Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application * is complete. It does so by using daemon threads and adding a shutdown hook to wait for their * completion. * * <p>This method waits 120 seconds before continuing with JVM termination, even if the executor * has not finished its work. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 43.7K bytes - Viewed (0) -
pkg/controller/volume/pvcprotection/pvc_protection_controller.go
// b) was force-deleted. // // It's now just waiting for garbage collection. We could wait // for it to actually get removed, but that may be blocked by // finalizers for the pod and thus get delayed. // // Worse, it is possible that there is a cyclic dependency // (pod finalizer waits for PVC to get removed, PVC protection // controller waits for pod to get removed). By considering
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 14K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
} installLog.Infof("Created CNI config %s", cniConfigFilepath) installLog.Debugf("CNI config: %s", pluginConfig) return cniConfigFilepath, nil } // If configured as chained CNI plugin, waits indefinitely for a main CNI config file to exist before returning // Or until cancelled by parent context func getCNIConfigFilepath(ctx context.Context, cniConfName, mountedCNINetDir string, chained bool) (string, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 8.3K bytes - Viewed (0)