github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-02 09:47:06 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #121494 from aojea/fix/flake-unit-test

Browse Source 
Fix/flake TestNewManagerImplStartProbeMode  unit test
This commit is contained in:
Kubernetes Prow Robot
2023-10-25 06:57:04 +02:00
committed by GitHub
parent e279e02076 8e0be64b8f
commit 0b884c0e3a
2 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/kubelet/cm/devicemanager/manager.go
View File

@@ -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

2
pkg/kubelet/cm/devicemanager/plugin/v1beta1/client.go
View File

@@ -69,8 +69,10 @@ func (c *client) Connect() error {
klog.ErrorS(err, "Unable to connect to device plugin client with socket path", "path", c.socket)
return err
}
c.mutex.Lock()
c.grpc = conn
c.client = client
c.mutex.Unlock()
return c.handler.PluginConnected(c.resource, c)
}