deviceplugin: fix race when multiple plugins are registered

Signed-off-by: Martin Polednik <mpolednik@redhat.com>
This commit is contained in:
Martin Polednik 2017-11-16 15:01:07 +01:00
parent c2a18cca6b
commit 6e3f8f3890

View File

@ -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()
}