Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for waitingPods (0.26 sec)

  1. pkg/scheduler/internal/cache/debugger/comparer.go

    		cached = append(cached, nodeName)
    	}
    
    	return compareStrings(actual, cached)
    }
    
    // ComparePods compares actual pods with cached pods.
    func (c *CacheComparer) ComparePods(pods, waitingPods []*v1.Pod, nodeinfos map[string]*framework.NodeInfo) (missed, redundant []string) {
    	actual := []string{}
    	for _, pod := range pods {
    		actual = append(actual, string(pod.UID))
    	}
    
    	cached := []string{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 29 05:26:32 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/runtime/framework.go

    // IterateOverWaitingPods acquires a read lock and iterates over the WaitingPods map.
    func (f *frameworkImpl) IterateOverWaitingPods(callback func(framework.WaitingPod)) {
    	f.waitingPods.iterate(callback)
    }
    
    // GetWaitingPod returns a reference to a WaitingPod given its UID.
    func (f *frameworkImpl) GetWaitingPod(uid types.UID) framework.WaitingPod {
    	if wp := f.waitingPods.get(uid); wp != nil {
    		return wp
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  3. pkg/scheduler/scheduler_test.go

    			wg.Wait()
    
    			// Ensure that all waitingPods in scheduler can be obtained from any profiles.
    			for _, fwk := range scheduler.Profiles {
    				actualPodNamesInWaitingPods := sets.NewString()
    				fwk.IterateOverWaitingPods(func(pod framework.WaitingPod) {
    					actualPodNamesInWaitingPods.Insert(pod.GetPod().Name)
    				})
    				// Validate the name of pods in waitingPods matches expectations.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 42K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/runtime/waiting_pods_map.go

    	for _, v := range m.pods {
    		callback(v)
    	}
    }
    
    // waitingPod represents a pod waiting in the permit phase.
    type waitingPod struct {
    	pod            *v1.Pod
    	pendingPlugins map[string]*time.Timer
    	s              chan *framework.Status
    	mu             sync.RWMutex
    }
    
    var _ framework.WaitingPod = &waitingPod{}
    
    // newWaitingPod returns a new waitingPod instance.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  5. pkg/scheduler/scheduler.go

    	snapshot := internalcache.NewEmptySnapshot()
    	metricsRecorder := metrics.NewMetricsAsyncRecorder(1000, time.Second, stopEverything)
    	// waitingPods holds all the pods that are in the scheduler and waiting in the permit stage
    	waitingPods := frameworkruntime.NewWaitingPodsMap()
    
    	profiles, err := profile.NewMap(ctx, options.profiles, registry, recorderFactory,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  6. pkg/kubelet/pod_workers.go

    		if waitingUID != uid {
    			p.waitingToStartStaticPodsByFullname[fullname] = waitingPods[i:]
    			return false
    		}
    		// we are up next, remove ourselves
    		waitingPods = waitingPods[i+1:]
    		break
    	}
    	if len(waitingPods) != 0 {
    		p.waitingToStartStaticPodsByFullname[fullname] = waitingPods
    	} else {
    		delete(p.waitingToStartStaticPodsByFullname, fullname)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 02 13:22:37 UTC 2024
    - 74.8K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/interface.go

    	SnapshotSharedLister() SharedLister
    
    	// IterateOverWaitingPods acquires a read lock and iterates over the WaitingPods map.
    	IterateOverWaitingPods(callback func(WaitingPod))
    
    	// GetWaitingPod returns a waiting pod given its UID.
    	GetWaitingPod(uid types.UID) WaitingPod
    
    	// RejectWaitingPod rejects a waiting pod given its UID.
    	// The return value indicates if the pod is waiting or not.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.31.md

    - Users can traverse all the pods that are in the scheduler and waiting in the permit stage through method `IterateOverWaitingPods`. In other words,  all waitingPods in scheduler can be obtained from any profiles. Before this commit, each profile could only obtain waitingPods within that profile. ([#124926](https://github.com/kubernetes/kubernetes/pull/124926), [@kerthcet](https://github.com/kerthcet)) [SIG Scheduling]
    
    ### Failing Test
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 20:34:14 UTC 2024
    - 60.3K bytes
    - Viewed (0)
  9. CHANGELOG/CHANGELOG-1.30.md

    - Users can now traverse all the pods that are in the scheduler and waiting in the permit stage through method `IterateOverWaitingPods`. In other words,  all waitingPods in scheduler can be obtained from any profiles. Before this commit, each profile could only obtain `waitingPods` within that profile ([#122946](https://github.com/kubernetes/kubernetes/pull/122946), [@NoicFank](https://github.com/NoicFank))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 04:05:28 UTC 2024
    - 253.2K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    				return true, nil, nil
    			})
    
    			logger, ctx := ktesting.NewTestContext(t)
    			ctx, cancel := context.WithCancel(ctx)
    			defer cancel()
    
    			waitingPods := frameworkruntime.NewWaitingPodsMap()
    
    			cache := internalcache.New(ctx, time.Duration(0))
    			for _, pod := range test.pods {
    				cache.AddPod(logger, pod)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
Back to top