From f56455753b0e9054bfe756807c002f1a67704dcd Mon Sep 17 00:00:00 2001 From: Fabio Bertinatto Date: Tue, 16 Apr 2019 18:44:48 +0200 Subject: [PATCH] Remove unnecessary in-line function --- .../util/pluginwatcher/plugin_watcher.go | 27 +++++++------------ 1 file changed, 10 insertions(+), 17 deletions(-) diff --git a/pkg/kubelet/util/pluginwatcher/plugin_watcher.go b/pkg/kubelet/util/pluginwatcher/plugin_watcher.go index 8fed9fe156c..b749a593c0f 100644 --- a/pkg/kubelet/util/pluginwatcher/plugin_watcher.go +++ b/pkg/kubelet/util/pluginwatcher/plugin_watcher.go @@ -124,24 +124,17 @@ func (w *Watcher) Start() error { select { case event := <-fsWatcher.Events: //TODO: Handle errors by taking corrective measures - - w.wg.Add(1) - func() { - defer w.wg.Done() - - if event.Op&fsnotify.Create == fsnotify.Create { - err := w.handleCreateEvent(event) - if err != nil { - klog.Errorf("error %v when handling create event: %s", err, event) - } - } else if event.Op&fsnotify.Remove == fsnotify.Remove { - err := w.handleDeleteEvent(event) - if err != nil { - klog.Errorf("error %v when handling delete event: %s", err, event) - } + if event.Op&fsnotify.Create == fsnotify.Create { + err := w.handleCreateEvent(event) + if err != nil { + klog.Errorf("error %v when handling create event: %s", err, event) } - return - }() + } else if event.Op&fsnotify.Remove == fsnotify.Remove { + err := w.handleDeleteEvent(event) + if err != nil { + klog.Errorf("error %v when handling delete event: %s", err, event) + } + } continue case err := <-fsWatcher.Errors: if err != nil {