Skip to content

K
k3s
Commit f7aa5037 authored by xuzhonghu's avatar xuzhonghu
Browse files
Options

fix ut

parent 7e894b33
Hide whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
pkg/controller/cloud/node_controller_test.go
View file @ f7aa5037
...@@ -252,7 +252,7 @@ func TestNodeShutdown(t *testing.T) { ...@@ -252,7 +252,7 @@ func TestNodeShutdown(t *testing.T) {
} }
eventBroadcaster.StartLogging(glog.Infof) eventBroadcaster.StartLogging(glog.Infof)
cloudNodeController.Run() cloudNodeController.Run(wait.NeverStop)
select { select {
case <-fnh.PatchWaitChan: case <-fnh.PatchWaitChan:
...@@ -351,7 +351,7 @@ func TestNodeDeleted(t *testing.T) { ...@@ -351,7 +351,7 @@ func TestNodeDeleted(t *testing.T) {
} }
eventBroadcaster.StartLogging(glog.Infof) eventBroadcaster.StartLogging(glog.Infof)
cloudNodeController.Run() cloudNodeController.Run(wait.NeverStop)
select { select {
case <-fnh.DeleteWaitChan: case <-fnh.DeleteWaitChan:
...@@ -768,7 +768,7 @@ func TestNodeAddresses(t *testing.T) { ...@@ -768,7 +768,7 @@ func TestNodeAddresses(t *testing.T) {
}, },
} }
cloudNodeController.Run() cloudNodeController.Run(wait.NeverStop)
<-time.After(2 * time.Second) <-time.After(2 * time.Second)
...@@ -872,7 +872,7 @@ func TestNodeProvidedIPAddresses(t *testing.T) { ...@@ -872,7 +872,7 @@ func TestNodeProvidedIPAddresses(t *testing.T) {
assert.Equal(t, "node0", fnh.UpdatedNodes[0].Name, "Node was not updated") 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") 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) <-time.After(2 * time.Second)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment