Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for waitingFor (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to top