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

Remove returned value of func handleCreateEvent

Browse Source
This commit is contained in:
caiweidong 2019-06-14 15:27:59 +08:00
parent 16bc6c1d02
commit 017aad3b60
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher.go
View File

@ -94,10 +94,7 @@ func (w *Watcher) Start(stopCh <-chan struct{}) error {
klog.Errorf("error %v when handling create event: %s", err, event) klog.Errorf("error %v when handling create event: %s", err, event)
} }
} else if event.Op&fsnotify.Remove == fsnotify.Remove { } else if event.Op&fsnotify.Remove == fsnotify.Remove {
err := w.handleDeleteEvent(event) w.handleDeleteEvent(event)
if err != nil {
klog.Errorf("error %v when handling delete event: %s", err, event)
}
} }
continue continue
case err := <-fsWatcher.Errors: case err := <-fsWatcher.Errors:
@ -219,14 +216,12 @@ func (w *Watcher) handlePluginRegistration(socketPath string) error {
return nil return nil
} }
func (w *Watcher) handleDeleteEvent(event fsnotify.Event) error { func (w *Watcher) handleDeleteEvent(event fsnotify.Event) {
klog.V(6).Infof("Handling delete event: %v", event) klog.V(6).Infof("Handling delete event: %v", event)
socketPath := event.Name socketPath := event.Name
klog.V(2).Infof("Removing socket path %s from desired state cache", socketPath) klog.V(2).Infof("Removing socket path %s from desired state cache", socketPath)
w.desiredStateOfWorld.RemovePlugin(socketPath) w.desiredStateOfWorld.RemovePlugin(socketPath)
return nil
} }
// While deprecated dir is supported, to add extra protection around #69015 // While deprecated dir is supported, to add extra protection around #69015