github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-29 14:37:00 +00:00
Code Issues Projects Releases Wiki Activity

fix: use locked func to replace the raw one to avoid concurrent read

Browse Source
This commit is contained in:
caiweidong 2019-04-23 20:59:10 +08:00
parent e6390ce3ff
commit 2fe823ba46
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/kubelet/util/pluginwatcher/plugin_watcher.go
View File

@ -275,7 +275,7 @@ func (w *Watcher) handlePluginRegistration(socketPath string) error {
return fmt.Errorf("failed to get plugin info using RPC GetInfo at socket %s, err: %v", socketPath, err)
}
handler, ok := w.handlers[infoResp.Type]
handler, ok := w.getHandler(infoResp.Type)
if !ok {
return w.notifyPlugin(client, false, fmt.Sprintf("no handler registered for plugin type: %s at socket %s", infoResp.Type, socketPath))
}