From 88274d96fcf3817e9d1328e5e7c026bda172090e Mon Sep 17 00:00:00 2001 From: huyinhou Date: Mon, 6 Mar 2023 14:23:14 +0800 Subject: [PATCH] update code style Signed-off-by: huyinhou --- pkg/kubelet/cm/devicemanager/topology_hints.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/pkg/kubelet/cm/devicemanager/topology_hints.go b/pkg/kubelet/cm/devicemanager/topology_hints.go index 9e03a9029b9..709cd4d4653 100644 --- a/pkg/kubelet/cm/devicemanager/topology_hints.go +++ b/pkg/kubelet/cm/devicemanager/topology_hints.go @@ -39,10 +39,11 @@ func (m *ManagerImpl) GetTopologyHints(pod *v1.Pod, container *v1.Container) map // Loop through all device resources and generate TopologyHints for them.. deviceHints := make(map[string][]topologymanager.TopologyHint) accumulatedResourceRequests := m.getContainerDeviceRequest(container) + m.mutex.Lock() defer m.mutex.Unlock() for resource, requested := range accumulatedResourceRequests { - // Only consider devices that actually container topology information. + // Only consider devices that actually contain topology information. if aligned := m.deviceHasTopologyAlignment(resource); !aligned { klog.InfoS("Resource does not have a topology preference", "resource", resource) deviceHints[resource] = nil @@ -93,6 +94,7 @@ func (m *ManagerImpl) GetPodTopologyHints(pod *v1.Pod) map[string][]topologymana deviceHints := make(map[string][]topologymanager.TopologyHint) accumulatedResourceRequests := m.getPodDeviceRequest(pod) + m.mutex.Lock() defer m.mutex.Unlock() for resource, requested := range accumulatedResourceRequests {