diff --git a/pkg/kubelet/cm/cpumanager/cpu_manager.go b/pkg/kubelet/cm/cpumanager/cpu_manager.go index 00f8bb02d1c..c0d0f1aa69b 100644 --- a/pkg/kubelet/cm/cpumanager/cpu_manager.go +++ b/pkg/kubelet/cm/cpumanager/cpu_manager.go @@ -441,9 +441,9 @@ func findContainerIDByName(status *v1.PodStatus, name string) (string, error) { } func findContainerStatusByName(status *v1.PodStatus, name string) (*v1.ContainerStatus, error) { - for _, status := range append(status.InitContainerStatuses, status.ContainerStatuses...) { - if status.Name == name { - return &status, nil + for _, containerStatus := range append(status.InitContainerStatuses, status.ContainerStatuses...) { + if containerStatus.Name == name { + return &containerStatus, nil } } return nil, fmt.Errorf("unable to find status for container with name %v in pod status (it may not be running)", name) diff --git a/pkg/kubelet/cm/cpumanager/cpu_manager_test.go b/pkg/kubelet/cm/cpumanager/cpu_manager_test.go index 7d7a7fb2b60..82f38262c39 100644 --- a/pkg/kubelet/cm/cpumanager/cpu_manager_test.go +++ b/pkg/kubelet/cm/cpumanager/cpu_manager_test.go @@ -476,14 +476,14 @@ func TestCPUManagerAddWithInitContainers(t *testing.T) { for _, testCase := range testCases { policy, _ := NewStaticPolicy(testCase.topo, testCase.numReservedCPUs, cpuset.NewCPUSet(), topologymanager.NewFakeManager()) - state := &mockState{ + mockState := &mockState{ assignments: testCase.stAssignments, defaultCPUSet: testCase.stDefaultCPUSet, } mgr := &manager{ policy: policy, - state: state, + state: mockState, containerRuntime: mockRuntimeService{}, containerMap: containermap.NewContainerMap(), podStatusProvider: mockPodStatusProvider{}, @@ -521,10 +521,10 @@ func TestCPUManagerAddWithInitContainers(t *testing.T) { testCase.description, containerIDs[i], err) } - cset, found := state.assignments[string(testCase.pod.UID)][containers[i].Name] + cset, found := mockState.assignments[string(testCase.pod.UID)][containers[i].Name] if !expCSets[i].IsEmpty() && !found { t.Errorf("StaticPolicy AddContainer() error (%v). expected container %v to be present in assignments %v", - testCase.description, containers[i].Name, state.assignments) + testCase.description, containers[i].Name, mockState.assignments) } if found && !cset.Equals(expCSets[i]) { @@ -535,9 +535,9 @@ func TestCPUManagerAddWithInitContainers(t *testing.T) { cumCSet = cumCSet.Union(cset) } - if !testCase.stDefaultCPUSet.Difference(cumCSet).Equals(state.defaultCPUSet) { + if !testCase.stDefaultCPUSet.Difference(cumCSet).Equals(mockState.defaultCPUSet) { t.Errorf("StaticPolicy error (%v). expected final state for defaultCPUSet %v but got %v", - testCase.description, testCase.stDefaultCPUSet.Difference(cumCSet), state.defaultCPUSet) + testCase.description, testCase.stDefaultCPUSet.Difference(cumCSet), mockState.defaultCPUSet) } } }