Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for TopologyHints (0.18 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top