- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for waitingFor (0.23 sec)
-
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) -
pkg/scheduler/framework/runtime/framework.go
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 } return nil // Returning nil instead of *waitingPod(nil). }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
victim := c.Victims().Pods[index] // If the victim is a WaitingPod, send a reject message to the PermitPlugin. // Otherwise we should delete the victim. if waitingPod := fh.GetWaitingPod(victim.UID); waitingPod != nil { waitingPod.Reject(pluginName, "preempted") logger.V(2).Info("Preemptor pod rejected a waiting pod", "preemptor", klog.KObj(pod), "waitingPod", klog.KObj(victim), "node", c.Name()) } else {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
func AsStatus(err error) *Status { if err == nil { return nil } return &Status{ code: Error, err: err, } } // WaitingPod represents a pod currently waiting in the permit phase. type WaitingPod interface { // GetPod returns a reference to the waiting pod. GetPod() *v1.Pod // GetPendingPlugins returns a list of pending Permit plugin's name. GetPendingPlugins() []string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
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)