github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-10 04:27:54 +00:00
Code Issues Projects Releases Wiki Activity

adc remove redundant check

Browse Source
This commit is contained in:
carlory 2023-11-03 16:17:39 +08:00
parent c3eebb233d
commit 957e9a7f1a
1 changed files with 2 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/controller/volume/attachdetach/attach_detach_controller.go
View File

@ -337,17 +337,8 @@ func (adc *attachDetachController) Run(ctx context.Context) {
logger.Info("Starting attach detach controller") logger.Info("Starting attach detach controller")
defer logger.Info("Shutting down attach detach controller") defer logger.Info("Shutting down attach detach controller")
synced := []kcache.InformerSynced{adc.podsSynced, adc.nodesSynced, adc.pvcsSynced, adc.pvsSynced} synced := []kcache.InformerSynced{adc.podsSynced, adc.nodesSynced, adc.pvcsSynced, adc.pvsSynced,
if adc.csiNodeSynced != nil { adc.csiNodeSynced, adc.csiDriversSynced, adc.volumeAttachmentSynced}
synced = append(synced, adc.csiNodeSynced)
}
if adc.csiDriversSynced != nil {
synced = append(synced, adc.csiDriversSynced)
}
if adc.volumeAttachmentSynced != nil {
synced = append(synced, adc.volumeAttachmentSynced)
}
if !kcache.WaitForNamedCacheSync("attach detach", ctx.Done(), synced...) { if !kcache.WaitForNamedCacheSync("attach detach", ctx.Done(), synced...) {
return return
} }