mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-08-06 18:54:06 +00:00
commit
5cf72fbfae
@ -338,17 +338,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
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user