From 35f4d29d73554f1bca2b08f9b6174ed65a1aeb70 Mon Sep 17 00:00:00 2001 From: Shiming Zhang Date: Tue, 24 Oct 2023 11:01:08 +0800 Subject: [PATCH] Fix unit test --- pkg/kubelet/cm/devicemanager/manager.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/kubelet/cm/devicemanager/manager.go b/pkg/kubelet/cm/devicemanager/manager.go index 3808ccfa0d3..f552addbfab 100644 --- a/pkg/kubelet/cm/devicemanager/manager.go +++ b/pkg/kubelet/cm/devicemanager/manager.go @@ -236,12 +236,12 @@ func (m *ManagerImpl) PluginDisconnected(resourceName string) { m.mutex.Lock() defer m.mutex.Unlock() - if _, exists := m.endpoints[resourceName]; exists { + if ep, exists := m.endpoints[resourceName]; exists { m.markResourceUnhealthy(resourceName) - klog.V(2).InfoS("Endpoint became unhealthy", "resourceName", resourceName, "endpoint", m.endpoints[resourceName]) - } + klog.V(2).InfoS("Endpoint became unhealthy", "resourceName", resourceName, "endpoint", ep) - m.endpoints[resourceName].e.setStopTime(time.Now()) + ep.e.setStopTime(time.Now()) + } } // PluginListAndWatchReceiver receives ListAndWatchResponse from a device plugin