Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ReceiveError (0.1 sec)

  1. pkg/scheduler/framework/preemption/preemption.go

    	}
    
    	fh.Parallelizer().Until(ctx, len(c.Victims().Pods), preemptPod, ev.PluginName)
    	if err := errCh.ReceiveError(); err != nil {
    		return framework.AsStatus(err)
    	}
    
    	metrics.PreemptionVictims.Observe(float64(len(c.Victims().Pods)))
    
    	// Lower priority pods nominated to run on this node, may no longer fit on
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 25.1K bytes
    - Viewed (0)
  2. pkg/scheduler/schedule_one.go

    	for _, item := range result {
    		if item == nil {
    			continue
    		}
    		diagnosis.NodeToStatusMap[item.node] = item.status
    		diagnosis.AddPluginStatus(item.status)
    	}
    	if err := errCh.ReceiveError(); err != nil {
    		statusCode = framework.Error
    		return feasibleNodes, err
    	}
    	return feasibleNodes, nil
    }
    
    // numFeasibleNodesToFind returns the number of feasible nodes that once found, the scheduler stops
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
Back to top