Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PollUntilContextCancel (0.77 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    	// Since we cannot send a bookmark when the lastProcessedResourceVersion is 0,
    	// we poll aggressively for the first list RV before entering the dispatch loop.
    	lastProcessedResourceVersion := uint64(0)
    	if err := wait.PollUntilContextCancel(wait.ContextForChannel(c.stopCh), 10*time.Millisecond, true, func(_ context.Context) (bool, error) {
    		if rv := c.watchCache.getListResourceVersion(); rv != 0 {
    			lastProcessedResourceVersion = rv
    			return true, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  2. pkg/kubelet/kubelet.go

    	// This waiting loop relies on the background cleanup which starts after pod workers respond
    	// true for ShouldPodRuntimeBeRemoved, which happens after `SyncTerminatingPod` is completed.
    	if err := wait.PollUntilContextCancel(ctx, 100*time.Millisecond, true, func(ctx context.Context) (bool, error) {
    		volumesExist := kl.podVolumesExist(pod.UID)
    		if volumesExist {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  3. CHANGELOG/CHANGELOG-1.27.md

    - The `wait.Poll*` and `wait.ExponentialBackoff*` functions have been deprecated and will be removed in a future release.  Callers should switch to using `wait.PollUntilContextCancel`, `wait.PollUntilContextTimeout`, or `wait.ExponentialBackoffWithContext` as appropriate.
      
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 23:01:06 UTC 2024
    - 455.3K bytes
    - Viewed (0)
Back to top