Commit eca14886 authored by Ke Zhang's avatar Ke Zhang

Redundant code process for container_mananger start

parent aee6d10b
...@@ -468,13 +468,14 @@ func (cm *containerManagerImpl) Start(node *api.Node) error { ...@@ -468,13 +468,14 @@ func (cm *containerManagerImpl) Start(node *api.Node) error {
return err return err
} }
// Don't run a background thread if there are no ensureStateFuncs. // Don't run a background thread if there are no ensureStateFuncs.
numEnsureStateFuncs := 0 hasEnsureStateFuncs := false
for _, cont := range cm.systemContainers { for _, cont := range cm.systemContainers {
if cont.ensureStateFunc != nil { if cont.ensureStateFunc != nil {
numEnsureStateFuncs++ hasEnsureStateFuncs = true
break
} }
} }
if numEnsureStateFuncs >= 0 { if hasEnsureStateFuncs {
// Run ensure state functions every minute. // Run ensure state functions every minute.
go wait.Until(func() { go wait.Until(func() {
for _, cont := range cm.systemContainers { for _, cont := range cm.systemContainers {
......
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