File tree Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Expand file tree Collapse file tree 1 file changed +8
-3
lines changed Original file line number Diff line number Diff line change @@ -353,6 +353,11 @@ func (m *nfdMaster) Run() error {
353
353
return err
354
354
}
355
355
356
+ // Stop the nodeUpdaterPool so that no node updates are underway
357
+ // while we reconfigure the NFD API controller (including the
358
+ // listers) below
359
+ m .nodeUpdaterPool .stop ()
360
+
356
361
// restart NFD API controller
357
362
if m .nfdController != nil {
358
363
klog .InfoS ("stopping the nfd api controller" )
@@ -364,13 +369,13 @@ func (m *nfdMaster) Run() error {
364
369
return nil
365
370
}
366
371
}
372
+ // Restart the nodeUpdaterPool
373
+ m .nodeUpdaterPool .start (m .config .NfdApiParallelism )
374
+
367
375
// Update all nodes when the configuration changes
368
376
if m .nfdController != nil && features .NFDFeatureGate .Enabled (features .NodeFeatureAPI ) {
369
377
m .nfdController .updateAllNodesChan <- struct {}{}
370
378
}
371
- // Restart the node updater pool
372
- m .nodeUpdaterPool .stop ()
373
- m .nodeUpdaterPool .start (m .config .NfdApiParallelism )
374
379
375
380
case <- m .stop :
376
381
klog .InfoS ("shutting down nfd-master" )
You can’t perform that action at this time.
0 commit comments