From f7aa5037c8c09eabd636c10b532ba7e2cc13766f Mon Sep 17 00:00:00 2001 From: xuzhonghu Date: Tue, 15 May 2018 17:22:40 +0800 Subject: [PATCH] fix ut --- pkg/controller/cloud/node_controller_test.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/controller/cloud/node_controller_test.go b/pkg/controller/cloud/node_controller_test.go index 6214c9d85fa..ee25f12f737 100644 --- a/pkg/controller/cloud/node_controller_test.go +++ b/pkg/controller/cloud/node_controller_test.go @@ -252,7 +252,7 @@ func TestNodeShutdown(t *testing.T) { } eventBroadcaster.StartLogging(glog.Infof) - cloudNodeController.Run() + cloudNodeController.Run(wait.NeverStop) select { case <-fnh.PatchWaitChan: @@ -351,7 +351,7 @@ func TestNodeDeleted(t *testing.T) { } eventBroadcaster.StartLogging(glog.Infof) - cloudNodeController.Run() + cloudNodeController.Run(wait.NeverStop) select { case <-fnh.DeleteWaitChan: @@ -768,7 +768,7 @@ func TestNodeAddresses(t *testing.T) { }, } - cloudNodeController.Run() + cloudNodeController.Run(wait.NeverStop) <-time.After(2 * time.Second) @@ -872,7 +872,7 @@ func TestNodeProvidedIPAddresses(t *testing.T) { assert.Equal(t, "node0", fnh.UpdatedNodes[0].Name, "Node was not updated") assert.Equal(t, 3, len(fnh.UpdatedNodes[0].Status.Addresses), "Node status unexpectedly updated") - cloudNodeController.Run() + cloudNodeController.Run(wait.NeverStop) <-time.After(2 * time.Second)