- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 702 for waits (0.11 sec)
-
src/net/http/main_test.go
// shutting down, so give it some time. time.Sleep(1 * time.Millisecond) } t.Errorf("Test appears to have leaked %s:\n%s", bad, stacks) } // waitCondition waits for fn to return true, // checking immediately and then at exponentially increasing intervals. func waitCondition(t testing.TB, delay time.Duration, fn func(time.Duration) bool) { t.Helper() start := time.Now()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 22:49:46 UTC 2024 - 4.9K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
Context string // DryRun performs all steps except actually applying the manifests or creating output dirs/files. DryRun bool // Maximum amount of time to wait for resources to be ready after install when Wait=true. WaitTimeout time.Duration } func applyManifest(kubeClient kube.Client, client client.Client, manifestStr string,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/workload_manager.go
// Run the pod controller. go m.podController.Run(m.stopCh) // Wait for the cache to sync. if !m.podController.WaitForSync(m.stopCh) { return fmt.Errorf( "failed syncing cache for echo %s/%s: controller stopping", m.cfg.Namespace.Name(), m.cfg.Service) } // Wait until all pods are ready. _, err := m.WaitForReadyWorkloads() return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/kubelet/eviction/threshold_notifier_linux.go
return } eventCh <- struct{}{} } } // wait waits up to notifierRefreshInterval for an event on the Epoll FD for the // eventfd we are concerned about. It returns an error if one occurs, and true // if the consumer should read from the eventfd. func wait(epfd, eventfd int, timeout time.Duration) (bool, error) { events := make([]unix.EpollEvent, numFdEvents+1)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 01 21:59:54 UTC 2022 - 5.8K 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) -
src/cmd/go/internal/vcweb/svn.go
if stderr.Len() > 0 { stderrFrag = "\n" + stderr.String() } h.logger.Printf("%v: %s%s", cmd, errFrag, stderrFrag) } // Close stops accepting new svn:// connections and terminates the existing // ones, then waits for the 'svnserve' subprocesses to complete. func (h *svnHandler) Close() error { h.listenOnce.Do(func() {}) if h.s == nil { return nil } var err error s := <-h.s s.closing = true
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 25 13:44:48 UTC 2022 - 5K bytes - Viewed (0) -
pkg/kube/kclient/crdwatcher.go
c.mutex.Unlock() kube.WaitForCacheSync("crd watcher", stop, c.crds.HasSynced) c.queue.Run(stop) c.crds.ShutdownHandlers() } // WaitForCRD waits until the request CRD exists, and returns true on success. A false return value // indicates the CRD does not exist but the wait failed or was canceled. // This is useful to conditionally enable controllers based on CRDs being created.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/kubelet/runonce.go
} if len(failedPods) > 0 { return results, fmt.Errorf("error running pods: %v", failedPods) } klog.InfoS("Pods started", "numPods", len(pods)) return results, err } // runPod runs a single pod and waits until all containers are running. func (kl *Kubelet) runPod(ctx context.Context, pod *v1.Pod, retryDelay time.Duration) error { var isTerminal bool delay := retryDelay retry := 0 for !isTerminal {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/kube/informerfactory/factory.go
if !cache.WaitForCacheSync(stopCh, informer.HasSynced) { return false } } return true } func (f *informerFactory) Shutdown() { // Will return immediately if there is nothing to wait for. defer f.wg.Wait() f.lock.Lock() defer f.lock.Unlock() f.shuttingDown = true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.9K bytes - Viewed (0) -
pkg/kube/kubetypes/types.go
KnownOrCallback(s schema.GroupVersionResource, f func(stop <-chan struct{})) bool // WaitForCRD waits until the request CRD exists, and returns true on success. A false return value // indicates the CRD does not exist but the wait failed or was canceled. // This is useful to conditionally enable controllers based on CRDs being created.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 6.1K bytes - Viewed (0)