- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for TopologyHints (0.18 sec)
-
pkg/kubelet/cm/devicemanager/topology_hints.go
// being cleaned before the admission ended m.setPodPendingAdmission(pod) // Garbage collect any stranded device resources before providing TopologyHints m.UpdateAllocatedDevices() // Loop through all device resources and generate TopologyHints for them. deviceHints := make(map[string][]topologymanager.TopologyHint) accumulatedResourceRequests := m.getContainerDeviceRequest(container) m.mutex.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 27 02:10:25 UTC 2024 - 9.9K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_pod.go
var providersHints []map[string][]TopologyHint for _, provider := range s.hintProviders { // Get the TopologyHints for a Pod from a provider. hints := provider.GetPodTopologyHints(pod) providersHints = append(providersHints, hints) klog.InfoS("TopologyHints", "hints", hints, "pod", klog.KObj(pod)) } return providersHints }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 2.6K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope_container.go
var providersHints []map[string][]TopologyHint for _, provider := range s.hintProviders { // Get the TopologyHints for a Container from a provider. hints := provider.GetTopologyHints(pod, container) providersHints = append(providersHints, hints) klog.InfoS("TopologyHints", "hints", hints, "pod", klog.KObj(pod), "containerName", container.Name) } return providersHints }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/scope.go
// Store is the interface for storing pod topology hints Store } type scope struct { mutex sync.Mutex name string // Mapping of a Pods mapping of Containers and their TopologyHints // Indexed by PodUID to ContainerName podTopologyHints podTopologyHints // The list of components registered with the Manager hintProviders []HintProvider // Topology Manager Policy policy Policy
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 14 14:44:24 UTC 2023 - 5K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/policy_static.go
// Generate hints. cpuHints := p.generateCPUTopologyHints(available, reusable, requested) klog.InfoS("TopologyHints generated", "pod", klog.KObj(pod), "cpuHints", cpuHints) return map[string][]topologymanager.TopologyHint{ string(v1.ResourceCPU): cpuHints, } } // generateCPUTopologyHints generates a set of TopologyHints given the set of // available CPUs and the number of CPUs being requested. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 28.8K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/bitmask/bitmask.go
limitations under the License. */ package bitmask import ( "fmt" "math/bits" "strconv" ) // BitMask interface allows hint providers to create BitMasks for TopologyHints type BitMask interface { Add(bits ...int) error Remove(bits ...int) error And(masks ...BitMask) Or(masks ...BitMask) Clear() Fill() IsEqual(mask BitMask) bool IsEmpty() bool IsSet(bit int) bool
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 09:45:09 UTC 2022 - 5.1K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager.go
// The pod is during the admission phase. We need to save the pod to avoid it // being cleaned before the admission ended m.setPodPendingAdmission(pod) // Garbage collect any stranded resources before providing TopologyHints m.removeStaleState() // Delegate to active policy return m.policy.GetTopologyHints(m.state, pod, container) } func (m *manager) GetPodTopologyHints(pod *v1.Pod) map[string][]topologymanager.TopologyHint {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 19.9K bytes - Viewed (2) -
pkg/kubelet/cm/memorymanager/memory_manager.go
// The pod is during the admission phase. We need to save the pod to avoid it // being cleaned before the admission ended m.setPodPendingAdmission(pod) // Garbage collect any stranded resources before providing TopologyHints m.removeStaleState() // Delegate to active policy return m.policy.GetPodTopologyHints(m.state, pod) } // GetTopologyHints returns the topology hints for the topology manager
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 01 00:50:45 UTC 2023 - 17.1K bytes - Viewed (1) -
pkg/kubelet/cm/topologymanager/policy.go
// Returns a merged TopologyHint based on input from hint providers // and a Pod Admit Handler Response based on hints and policy type Merge(providersHints []map[string][]TopologyHint) (TopologyHint, bool) } // Merge a TopologyHints permutation to a single hint by performing a bitwise-AND // of their affinity masks. The hint shall be preferred if all hits in the permutation // are preferred.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 09:45:25 UTC 2022 - 12.7K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static_test.go
if err != nil { t.Fatalf("Unexpected error: %v", err) } topologyHints := p.GetTopologyHints(s, testCase.pod, &testCase.pod.Spec.Containers[0]) if !reflect.DeepEqual(topologyHints, testCase.expectedTopologyHints) { t.Fatalf("The actual topology hints: '%+v' are different from the expected one: '%+v'", topologyHints, testCase.expectedTopologyHints) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Sep 17 05:49:15 UTC 2023 - 100.4K bytes - Viewed (0)