github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-29 14:37:00 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #113499 from kerthcet/cleanup/map-empty-judgement

Browse Source 
Fix: resourceToWeightMap will never be nil here
This commit is contained in:
Kubernetes Prow Robot 2022-12-12 00:15:33 -08:00 committed by GitHub
commit c80b03fee8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/scheduler/framework/plugins/noderesources/least_allocated_test.go
View File

@ -40,6 +40,7 @@ func TestLeastAllocatedScoringStrategy(t *testing.T) {
expectedScores framework.NodeScoreList
resources []config.ResourceSpec
wantErrs field.ErrorList
wantStatusCode framework.Code
}{
{
// Node1 scores (remaining resources) on 0-MaxNodeScore scale
@ -83,7 +84,7 @@ func TestLeastAllocatedScoringStrategy(t *testing.T) {
resources: defaultResources,
},
{
name: "Resources not set, nothing scheduled, resources requested, differently sized nodes",
name: "Resources not set, pods scheduled with error",
requestedPod: st.MakePod().
Req(map[v1.ResourceName]string{"cpu": "1000", "memory": "2000"}).
Req(map[v1.ResourceName]string{"cpu": "2000", "memory": "3000"}).
@ -95,6 +96,7 @@ func TestLeastAllocatedScoringStrategy(t *testing.T) {
existingPods: nil,
expectedScores: []framework.NodeScore{{Name: "node1", Score: framework.MinNodeScore}, {Name: "node2", Score: framework.MinNodeScore}},
resources: nil,
wantStatusCode: framework.Error,
},
{
// Node1 scores on 0-MaxNodeScore scale
@ -387,8 +389,8 @@ func TestLeastAllocatedScoringStrategy(t *testing.T) {
var gotScores framework.NodeScoreList
for _, n := range test.nodes {
score, status := p.(framework.ScorePlugin).Score(ctx, state, test.requestedPod, n.Name)
if !status.IsSuccess() {
t.Errorf("unexpected error: %v", status)
if status.Code() != test.wantStatusCode {
t.Errorf("unexpected status code, want: %v, got: %v", test.wantStatusCode, status)
}
gotScores = append(gotScores, framework.NodeScore{Name: n.Name, Score: score})
}

8
pkg/scheduler/framework/plugins/noderesources/most_allocated_test.go
View File

@ -40,6 +40,7 @@ func TestMostAllocatedScoringStrategy(t *testing.T) {
expectedScores framework.NodeScoreList
resources []config.ResourceSpec
wantErrs field.ErrorList
wantStatusCode framework.Code
}{
{
// Node1 scores (used resources) on 0-MaxNodeScore scale
@ -83,7 +84,7 @@ func TestMostAllocatedScoringStrategy(t *testing.T) {
resources: defaultResources,
},
{
name: "Resources not set, nothing scheduled, resources requested, differently sized nodes",
name: "Resources not set, pods scheduled with error",
requestedPod: st.MakePod().
Req(map[v1.ResourceName]string{"cpu": "1000", "memory": "2000"}).
Req(map[v1.ResourceName]string{"cpu": "2000", "memory": "3000"}).
@ -95,6 +96,7 @@ func TestMostAllocatedScoringStrategy(t *testing.T) {
existingPods: nil,
expectedScores: []framework.NodeScore{{Name: "node1", Score: framework.MinNodeScore}, {Name: "node2", Score: framework.MinNodeScore}},
resources: nil,
wantStatusCode: framework.Error,
},
{
// Node1 scores on 0-MaxNodeScore scale
@ -344,8 +346,8 @@ func TestMostAllocatedScoringStrategy(t *testing.T) {
var gotScores framework.NodeScoreList
for _, n := range test.nodes {
score, status := p.(framework.ScorePlugin).Score(ctx, state, test.requestedPod, n.Name)
if !status.IsSuccess() {
t.Errorf("unexpected error: %v", status)
if status.Code() != test.wantStatusCode {
t.Errorf("unexpected status code, want: %v, got: %v", test.wantStatusCode, status.Code())
}
gotScores = append(gotScores, framework.NodeScore{Name: n.Name, Score: score})
}

2
pkg/scheduler/framework/plugins/noderesources/resource_allocation.go
View File

@ -51,7 +51,7 @@ func (r *resourceAllocationScorer) score(
if node == nil {
return 0, framework.NewStatus(framework.Error, "node not found")
}
if r.resourceToWeightMap == nil {
if len(r.resourceToWeightMap) == 0 {
return 0, framework.NewStatus(framework.Error, "resources not found")
}