diff --git a/pkg/kubelet/cm/deviceplugin/device_plugin_handler.go b/pkg/kubelet/cm/deviceplugin/device_plugin_handler.go index 23d67c3fd6d..38248733c9a 100644 --- a/pkg/kubelet/cm/deviceplugin/device_plugin_handler.go +++ b/pkg/kubelet/cm/deviceplugin/device_plugin_handler.go @@ -77,6 +77,10 @@ func NewHandlerImpl(updateCapacityFunc func(v1.ResourceList)) (*HandlerImpl, err deviceManagerMonitorCallback := func(resourceName string, added, updated, deleted []pluginapi.Device) { var capacity = v1.ResourceList{} kept := append(updated, added...) + + handler.Lock() + defer handler.Unlock() + if _, ok := handler.allDevices[resourceName]; !ok { handler.allDevices[resourceName] = sets.NewString() }