From cc4d2cbe9d80e75796b7bfd7444caa0030ea8d7c Mon Sep 17 00:00:00 2001 From: vikaschoudhary16 Date: Sat, 23 Dec 2017 03:02:33 -0500 Subject: [PATCH] Fix a race in the endpoint.go --- pkg/kubelet/cm/deviceplugin/endpoint.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/kubelet/cm/deviceplugin/endpoint.go b/pkg/kubelet/cm/deviceplugin/endpoint.go index 29feaf52852..523922d9dc0 100644 --- a/pkg/kubelet/cm/deviceplugin/endpoint.go +++ b/pkg/kubelet/cm/deviceplugin/endpoint.go @@ -164,7 +164,11 @@ func (e *endpointImpl) run() { } e.mutex.Lock() - e.devices = devices + // NOTE: Return a copy of 'devices' instead of returning a direct reference to local 'devices' + e.devices = make(map[string]pluginapi.Device) + for _, d := range devices { + e.devices[d.ID] = d + } e.mutex.Unlock() e.callback(e.resourceName, added, updated, deleted)