diff --git a/cmd/kube-proxy/app/server.go b/cmd/kube-proxy/app/server.go index efea3697fe9..ef2c4945c28 100644 --- a/cmd/kube-proxy/app/server.go +++ b/cmd/kube-proxy/app/server.go @@ -667,7 +667,7 @@ func (s *ProxyServer) Run() error { // This has to start after the calls to NewServiceConfig and NewEndpointsConfig because those // functions must configure their shared informer event handlers first. - go informerFactory.Start(wait.NeverStop) + informerFactory.Start(wait.NeverStop) // Birth Cry after the birth is successful s.birthCry() diff --git a/pkg/controller/resourcequota/resource_quota_controller_test.go b/pkg/controller/resourcequota/resource_quota_controller_test.go index 1d92197b02a..031fe47ebc0 100644 --- a/pkg/controller/resourcequota/resource_quota_controller_test.go +++ b/pkg/controller/resourcequota/resource_quota_controller_test.go @@ -127,7 +127,7 @@ func setupQuotaController(t *testing.T, kubeClient kubernetes.Interface, lister t.Fatal(err) } stop := make(chan struct{}) - go informerFactory.Start(stop) + informerFactory.Start(stop) return quotaController{qc, stop} } diff --git a/pkg/volume/csi/csi_attacher_test.go b/pkg/volume/csi/csi_attacher_test.go index f3b3b991d2d..6e773742361 100644 --- a/pkg/volume/csi/csi_attacher_test.go +++ b/pkg/volume/csi/csi_attacher_test.go @@ -1445,7 +1445,7 @@ func newTestWatchPlugin(t *testing.T, fakeClient *fakeclient.Clientset) (*csiPlu factory := informers.NewSharedInformerFactory(fakeClient, csiResyncPeriod) csiDriverInformer := factory.Storage().V1beta1().CSIDrivers() csiDriverLister := csiDriverInformer.Lister() - go factory.Start(wait.NeverStop) + factory.Start(wait.NeverStop) host := volumetest.NewFakeVolumeHostWithCSINodeName( tmpDir, diff --git a/pkg/volume/csi/csi_test.go b/pkg/volume/csi/csi_test.go index 33e636ee081..120069ed7c3 100644 --- a/pkg/volume/csi/csi_test.go +++ b/pkg/volume/csi/csi_test.go @@ -122,7 +122,7 @@ func TestCSI_VolumeAll(t *testing.T) { fakeWatcher := watch.NewRaceFreeFake() factory := informers.NewSharedInformerFactory(client, csiResyncPeriod) - go factory.Start(wait.NeverStop) + factory.Start(wait.NeverStop) host := volumetest.NewFakeVolumeHostWithCSINodeName( tmpDir, diff --git a/pkg/volume/plugins.go b/pkg/volume/plugins.go index 8b9fce20e9a..53984dc9394 100644 --- a/pkg/volume/plugins.go +++ b/pkg/volume/plugins.go @@ -1034,7 +1034,7 @@ func (pm *VolumePluginMgr) Run(stopCh <-chan struct{}) { // start informer for CSIDriver if utilfeature.DefaultFeatureGate.Enabled(features.CSIDriverRegistry) { informerFactory := kletHost.GetInformerFactory() - go informerFactory.Start(stopCh) + informerFactory.Start(stopCh) } } }