@@ -71,31 +71,21 @@ func apiServerPID(cr command.Runner) (int, error) {
71
71
func SystemPods (client * kubernetes.Clientset , start time.Time , timeout time.Duration ) error {
72
72
glog .Info ("waiting for kube-system pods to appear ..." )
73
73
pStart := time .Now ()
74
- podStart := time.Time {}
75
74
podList := func () (bool , error ) {
76
75
if time .Since (start ) > timeout {
77
76
return false , fmt .Errorf ("cluster wait timed out during pod check" )
78
77
}
79
78
// Wait for any system pod, as waiting for apiserver may block until etcd
80
79
pods , err := client .CoreV1 ().Pods ("kube-system" ).List (meta.ListOptions {})
81
- if len (pods .Items ) < 2 {
82
- podStart = time.Time {}
83
- return false , nil
84
- }
85
80
if err != nil {
86
- podStart = time. Time {}
81
+ glog . Warningf ( "pod list returned error: %v" , err )
87
82
return false , nil
88
83
}
89
- if podStart .IsZero () {
90
- podStart = time .Now ()
91
- }
92
-
93
- glog .Infof ("%d kube-system pods found since %s" , len (pods .Items ), podStart )
94
- if time .Since (podStart ) > 2 * kconst .APICallRetryInterval {
95
- glog .Infof ("stability requirement met, returning" )
96
- return true , nil
84
+ glog .Infof ("%d kube-system pods found" , len (pods .Items ))
85
+ if len (pods .Items ) < 2 {
86
+ return false , nil
97
87
}
98
- return false , nil
88
+ return true , nil
99
89
}
100
90
if err := wait .PollImmediate (kconst .APICallRetryInterval , kconst .DefaultControlPlaneTimeout , podList ); err != nil {
101
91
return fmt .Errorf ("apiserver never returned a pod list" )
0 commit comments