File tree Expand file tree Collapse file tree 1 file changed +10
-17
lines changed
pkg/kubelet/util/pluginwatcher Expand file tree Collapse file tree 1 file changed +10
-17
lines changed Original file line number Diff line number Diff line change @@ -124,24 +124,17 @@ func (w *Watcher) Start() error {
124
124
select {
125
125
case event := <- fsWatcher .Events :
126
126
//TODO: Handle errors by taking corrective measures
127
-
128
- w .wg .Add (1 )
129
- func () {
130
- defer w .wg .Done ()
131
-
132
- if event .Op & fsnotify .Create == fsnotify .Create {
133
- err := w .handleCreateEvent (event )
134
- if err != nil {
135
- klog .Errorf ("error %v when handling create event: %s" , err , event )
136
- }
137
- } else if event .Op & fsnotify .Remove == fsnotify .Remove {
138
- err := w .handleDeleteEvent (event )
139
- if err != nil {
140
- klog .Errorf ("error %v when handling delete event: %s" , err , event )
141
- }
127
+ if event .Op & fsnotify .Create == fsnotify .Create {
128
+ err := w .handleCreateEvent (event )
129
+ if err != nil {
130
+ klog .Errorf ("error %v when handling create event: %s" , err , event )
131
+ }
132
+ } else if event .Op & fsnotify .Remove == fsnotify .Remove {
133
+ err := w .handleDeleteEvent (event )
134
+ if err != nil {
135
+ klog .Errorf ("error %v when handling delete event: %s" , err , event )
142
136
}
143
- return
144
- }()
137
+ }
145
138
continue
146
139
case err := <- fsWatcher .Errors :
147
140
if err != nil {
You can’t perform that action at this time.
0 commit comments