Merge pull request kubernetes#94086 from robscott/endpointslice-sync-fix

k8s-ci-robot · web-flow · commit a690a365141b · 2020-08-18T13:25:10.000-07:00
Updating EndpointSlice controller to wait for all caches to be synced
diff --git a/pkg/controller/endpointslice/endpointslice_controller.go b/pkg/controller/endpointslice/endpointslice_controller.go
@@ -237,7 +237,7 @@ func (c *Controller) Run(workers int, stopCh <-chan struct{}) {
 	klog.Infof("Starting endpoint slice controller")
 	defer klog.Infof("Shutting down endpoint slice controller")
 
-	if !cache.WaitForNamedCacheSync("endpoint_slice", stopCh, c.podsSynced, c.servicesSynced) {
+	if !cache.WaitForNamedCacheSync("endpoint_slice", stopCh, c.podsSynced, c.servicesSynced, c.endpointSlicesSynced, c.nodesSynced) {
 		return
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -237,7 +237,7 @@ func (c *Controller) Run(workers int, stopCh <-chan struct{}) {`
`237`	`237`	`klog.Infof("Starting endpoint slice controller")`
`238`	`238`	`defer klog.Infof("Shutting down endpoint slice controller")`
`239`	`239`
`240`		`- if !cache.WaitForNamedCacheSync("endpoint_slice", stopCh, c.podsSynced, c.servicesSynced) {`
	`240`	`+ if !cache.WaitForNamedCacheSync("endpoint_slice", stopCh, c.podsSynced, c.servicesSynced, c.endpointSlicesSynced, c.nodesSynced) {`
`241`	`241`	`return`
`242`	`242`	`}`
`243`	`243`