kubernetes/test/e2e_node/topology_manager_test.go

const numaAlignmentCommand …

const numaAlignmentSleepCommand …

const podScopeTopology …

const containerScopeTopology …

const minNumaNodes …

const minNumaNodesPreferClosestNUMA …

const minCoreCount …

const minSriovResource …

type tmCtnAttribute …

func detectNUMANodes() int { … }

func detectCoresPerSocket() int { … }

func detectThreadPerCore() int { … }

// for now we only look for pairs of nodes with minimum distance, we also assume that distance table is symmetric.
func getMinRemoteDistanceForNode(nodeToDistances map[int][]int) int { … }

func detectNUMADistances(numaNodes int) map[int][]int { … }

func makeContainers(ctnCmd string, ctnAttributes []tmCtnAttribute) (ctns []v1.Container) { … }

func makeTopologyManagerTestPod(podName string, tmCtnAttributes, tmInitCtnAttributes []tmCtnAttribute) *v1.Pod { … }

func findNUMANodeWithoutSRIOVDevicesFromConfigMap(configMap *v1.ConfigMap, numaNodes int) (int, bool) { … }

func findNUMANodeWithoutSRIOVDevicesFromSysfs(numaNodes int) (int, bool) { … }

func findNUMANodeWithoutSRIOVDevices(configMap *v1.ConfigMap, numaNodes int) (int, bool) { … }

func configureTopologyManagerInKubelet(oldCfg *kubeletconfig.KubeletConfiguration, policy, scope string, topologyOptions map[string]string, configMap *v1.ConfigMap, numaNodes int) (*kubeletconfig.KubeletConfiguration, string) { … }

// getSRIOVDevicePluginPod returns the Device Plugin pod for sriov resources in e2e tests.
func getSRIOVDevicePluginPod() *v1.Pod { … }

func readConfigMapV1OrDie(objBytes []byte) *v1.ConfigMap { … }

func readServiceAccountV1OrDie(objBytes []byte) *v1.ServiceAccount { … }

func findSRIOVResource(node *v1.Node) (string, int64) { … }

func validatePodAlignment(ctx context.Context, f *framework.Framework, pod *v1.Pod, envInfo *testEnvInfo) { … }

// validatePodAligmentWithPodScope validates whether all pod's CPUs are affined to the same NUMA node.
func validatePodAlignmentWithPodScope(ctx context.Context, f *framework.Framework, pod *v1.Pod, envInfo *testEnvInfo) error { … }

func runTopologyManagerPolicySuiteTests(ctx context.Context, f *framework.Framework) { … }

func runTopologyManagerPositiveTest(ctx context.Context, f *framework.Framework, numPods int, ctnAttrs, initCtnAttrs []tmCtnAttribute, envInfo *testEnvInfo) { … }

func deletePodsAsync(ctx context.Context, f *framework.Framework, podMap map[string]*v1.Pod) { … }

func runTopologyManagerNegativeTest(ctx context.Context, f *framework.Framework, ctnAttrs, initCtnAttrs []tmCtnAttribute, envInfo *testEnvInfo) { … }

func isTopologyAffinityError(pod *v1.Pod) bool { … }

func getSRIOVDevicePluginConfigMap(cmFile string) *v1.ConfigMap { … }

type sriovData …

func setupSRIOVConfigOrFail(ctx context.Context, f *framework.Framework, configMap *v1.ConfigMap) *sriovData { … }

func createSRIOVConfigOrFail(ctx context.Context, f *framework.Framework, configMap *v1.ConfigMap) *sriovData { … }

func createSRIOVPodOrFail(ctx context.Context, f *framework.Framework) *v1.Pod { … }

// waitForSRIOVResources waits until enough SRIOV resources are available, expecting to complete within the timeout.
// if exits successfully, updates the sriovData with the resources which were found.
func waitForSRIOVResources(ctx context.Context, f *framework.Framework, sd *sriovData) { … }

func deleteSRIOVPodOrFail(ctx context.Context, f *framework.Framework, sd *sriovData) { … }

func removeSRIOVConfigOrFail(ctx context.Context, f *framework.Framework, sd *sriovData) { … }

func teardownSRIOVConfigOrFail(ctx context.Context, f *framework.Framework, sd *sriovData) { … }

func runTMScopeResourceAlignmentTestSuite(ctx context.Context, f *framework.Framework, configMap *v1.ConfigMap, reservedSystemCPUs, policy string, numaNodes, coreCount int) { … }

func runTopologyManagerNodeAlignmentSuiteTests(ctx context.Context, f *framework.Framework, sd *sriovData, reservedSystemCPUs, policy string, numaNodes, coreCount int) { … }

func runPreferClosestNUMATestSuite(ctx context.Context, f *framework.Framework, numaNodes int, distances map[int][]int) { … }

func runPreferClosestNUMAOptimalAllocationTest(ctx context.Context, f *framework.Framework, numaNodes int, distances map[int][]int) { … }

func runPreferClosestNUMASubOptimalAllocationTest(ctx context.Context, f *framework.Framework, numaNodes int, distances map[int][]int) { … }

func valiidatePreferClosestNUMAOptimalAllocation(ctx context.Context, f *framework.Framework, podMap map[string]*v1.Pod, numaNodes int, distances map[int][]int) { … }

func runTopologyManagerTests(f *framework.Framework, topologyOptions map[string]string) { … }

func runPreferClosestNUMATests(f *framework.Framework) { … }

func hostPrecheck() (int, int) { … }

var _ …