Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for canAdmitPodResult (0.33 sec)

  1. pkg/kubelet/cm/topologymanager/policy_best_effort.go

    }
    
    func (p *bestEffortPolicy) canAdmitPodResult(hint *TopologyHint) bool {
    	return true
    }
    
    func (p *bestEffortPolicy) Merge(providersHints []map[string][]TopologyHint) (TopologyHint, bool) {
    	filteredHints := filterProvidersHints(providersHints)
    	merger := NewHintMerger(p.numaInfo, filteredHints, p.Name(), p.opts)
    	bestHint := merger.Merge()
    	admit := p.canAdmitPodResult(&bestHint)
    	return bestHint, admit
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 16:52:08 UTC 2022
    - 1.5K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/topologymanager/policy_restricted.go

    }
    
    func (p *restrictedPolicy) canAdmitPodResult(hint *TopologyHint) bool {
    	return hint.Preferred
    }
    
    func (p *restrictedPolicy) Merge(providersHints []map[string][]TopologyHint) (TopologyHint, bool) {
    	filteredHints := filterProvidersHints(providersHints)
    	merger := NewHintMerger(p.numaInfo, filteredHints, p.Name(), p.opts)
    	bestHint := merger.Merge()
    	admit := p.canAdmitPodResult(&bestHint)
    	return bestHint, admit
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 16:52:08 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/topologymanager/policy_single_numa_node.go

    	return &singleNumaNodePolicy{numaInfo: numaInfo, opts: opts}
    }
    
    func (p *singleNumaNodePolicy) Name() string {
    	return PolicySingleNumaNode
    }
    
    func (p *singleNumaNodePolicy) canAdmitPodResult(hint *TopologyHint) bool {
    	return hint.Preferred
    }
    
    // Return hints that have valid bitmasks with exactly one bit set.
    func filterSingleNumaHints(allResourcesHints [][]TopologyHint) [][]TopologyHint {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 16:52:08 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/topologymanager/policy_none.go

    	return &nonePolicy{}
    }
    
    func (p *nonePolicy) Name() string {
    	return PolicyNone
    }
    
    func (p *nonePolicy) canAdmitPodResult(hint *TopologyHint) bool {
    	return true
    }
    
    func (p *nonePolicy) Merge(providersHints []map[string][]TopologyHint) (TopologyHint, bool) {
    	return TopologyHint{}, p.canAdmitPodResult(nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 03 17:13:28 UTC 2020
    - 1.1K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/topologymanager/policy_restricted_test.go

    			expected: true,
    		},
    	}
    
    	for _, tc := range tcases {
    		numaInfo := commonNUMAInfoTwoNodes()
    		policy := &restrictedPolicy{bestEffortPolicy{numaInfo: numaInfo}}
    		result := policy.canAdmitPodResult(&tc.hint)
    
    		if result != tc.expected {
    			t.Errorf("Expected result to be %t, got %t", tc.expected, result)
    		}
    	}
    }
    
    func TestPolicyRestrictedMerge(t *testing.T) {
    	numaInfo := commonNUMAInfoFourNodes()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 03 09:45:25 UTC 2022
    - 2.6K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/topologymanager/policy_best_effort_test.go

    			hint:     TopologyHint{nil, true},
    			expected: true,
    		},
    	}
    
    	for _, tc := range tcases {
    		numaInfo := commonNUMAInfoTwoNodes()
    		policy := &bestEffortPolicy{numaInfo: numaInfo}
    		result := policy.canAdmitPodResult(&tc.hint)
    
    		if result != tc.expected {
    			t.Errorf("Expected result to be %t, got %t", tc.expected, result)
    		}
    	}
    }
    
    func TestPolicyBestEffortMerge(t *testing.T) {
    	numaInfo := commonNUMAInfoFourNodes()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 03 09:45:25 UTC 2022
    - 2.1K bytes
    - Viewed (0)
  7. pkg/kubelet/cm/topologymanager/policy_none_test.go

    			hint:     TopologyHint{nil, true},
    			expected: true,
    		},
    	}
    
    	for _, tc := range tcases {
    		policy := NewNonePolicy()
    		result := policy.(*nonePolicy).canAdmitPodResult(&tc.hint)
    
    		if result != tc.expected {
    			t.Errorf("Expected result to be %t, got %t", tc.expected, result)
    		}
    	}
    }
    
    func TestPolicyNoneMerge(t *testing.T) {
    	tcases := []struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 03 17:13:28 UTC 2020
    - 2.8K bytes
    - Viewed (0)
  8. pkg/kubelet/cm/topologymanager/policy_single_numa_node_test.go

    			expected: false,
    		},
    	}
    	numaInfo := commonNUMAInfoTwoNodes()
    
    	for _, tc := range tcases {
    		policy := singleNumaNodePolicy{numaInfo: numaInfo, opts: PolicyOptions{}}
    		result := policy.canAdmitPodResult(&tc.hint)
    
    		if result != tc.expected {
    			t.Errorf("Expected result to be %t, got %t", tc.expected, result)
    		}
    	}
    }
    
    func TestPolicySingleNumaNodeFilterHints(t *testing.T) {
    	tcases := []struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 03 09:45:25 UTC 2022
    - 4.6K bytes
    - Viewed (0)
Back to top