Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for IsWait (0.09 sec)

  1. pkg/scheduler/framework/interface.go

    }
    
    // IsSuccess returns true if and only if "Status" is nil or Code is "Success".
    func (s *Status) IsSuccess() bool {
    	return s.Code() == Success
    }
    
    // IsWait returns true if and only if "Status" is non-nil and its Code is "Wait".
    func (s *Status) IsWait() bool {
    	return s.Code() == Wait
    }
    
    // IsSkip returns true if and only if "Status" is non-nil and its Code is "Skip".
    func (s *Status) IsSkip() bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  2. pkg/scheduler/schedule_one.go

    	}
    
    	// Run "permit" plugins.
    	runPermitStatus := fwk.RunPermitPlugins(ctx, state, assumedPod, scheduleResult.SuggestedHost)
    	if !runPermitStatus.IsWait() && !runPermitStatus.IsSuccess() {
    		// trigger un-reserve to clean up state associated with the reserved Pod
    		fwk.RunReservePluginsUnreserve(ctx, state, assumedPod, scheduleResult.SuggestedHost)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/runtime/framework.go

    			if status.IsRejected() {
    				logger.V(4).Info("Pod rejected by plugin", "pod", klog.KObj(pod), "plugin", pl.Name(), "status", status.Message())
    				return status.WithPlugin(pl.Name())
    			}
    			if status.IsWait() {
    				// Not allowed to be greater than maxTimeout.
    				if timeout > maxTimeout {
    					timeout = maxTimeout
    				}
    				pluginsWaitTime[pl.Name()] = timeout
    				statusCode = framework.Wait
    			} else {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
Back to top