diff --git a/pkg/controller/nodeipam/ipam/controller.go b/pkg/controller/nodeipam/ipam/controller.go index bf59418a488..020ec433a48 100644 --- a/pkg/controller/nodeipam/ipam/controller.go +++ b/pkg/controller/nodeipam/ipam/controller.go @@ -174,14 +174,15 @@ func (c *Controller) onAdd(node *v1.Node) error { c.lock.Lock() defer c.lock.Unlock() - if syncer, ok := c.syncers[node.Name]; !ok { + syncer, ok := c.syncers[node.Name] + if !ok { syncer = c.newSyncer(node.Name) c.syncers[node.Name] = syncer go syncer.Loop(nil) } else { glog.Warningf("Add for node %q that already exists", node.Name) - syncer.Update(node) } + syncer.Update(node) return nil }