mirrors/node-feature-discovery
mirrors/node-feature-discovery
1
0
Fork 0
mirror of https://github.com/kubernetes-sigs/node-feature-discovery.git synced 2025-03-31 04:04:51 +00:00
Code Activity

rename podHasIntegralCPUs

Browse source
This commit is contained in:
AllenXu93 2025-03-10 14:15:32 +08:00
parent 5d40f7966e
commit d9d6ac5dde
1 changed files with 4 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
pkg/resourcemonitor/podresourcesscanner.go
View file

@ -25,7 +25,6 @@ import (
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
client "k8s.io/client-go/kubernetes"
"k8s.io/klog/v2"
podresourcesapi "k8s.io/kubelet/pkg/apis/podresources/v1"
"github.com/k8stopologyawareschedwg/noderesourcetopology-api/pkg/apis/topology/v1alpha2"
@ -69,16 +68,16 @@ func (resMon *PodResourcesScanner) isWatchable(podResource *podresourcesapi.PodR
return false, false, err
}
podHasExclusiveCPUs := hasExclusiveCPUs(pod)
isPodHasIntegralCPUs := podHasIntegralCPUs(pod)
isPodGuaranteed := qos.GetPodQOS(pod) == corev1.PodQOSGuaranteed
return isPodGuaranteed || hasDevice(podResource), podHasExclusiveCPUs, nil
return isPodGuaranteed || hasDevice(podResource), isPodHasIntegralCPUs, nil
}
// hasExclusiveCPUs returns true if a guaranteed pod is allocated exclusive CPUs else returns false.
// podHasIntegralCPUs returns true if a guaranteed pod is allocated exclusive CPUs else returns false.
// In isWatchable() function we check for the pod QoS and proceed if it is guaranteed (i.e. request == limit)
// and hence we only check for request in the function below.
func hasExclusiveCPUs(pod *corev1.Pod) bool {
func podHasIntegralCPUs(pod *corev1.Pod) bool {
for _, container := range pod.Spec.InitContainers {
if hasIntegralCPUs(&container) {
return true