From bf013b5348aae8fe628b9048cefc9bf119648651 Mon Sep 17 00:00:00 2001 From: Ryan Leung Date: Thu, 8 Feb 2024 15:46:06 +0800 Subject: [PATCH] address the comment Signed-off-by: Ryan Leung --- pkg/mcs/utils/util.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/pkg/mcs/utils/util.go b/pkg/mcs/utils/util.go index 485c6ddaa7f..b6ac2eb37e5 100644 --- a/pkg/mcs/utils/util.go +++ b/pkg/mcs/utils/util.go @@ -123,16 +123,21 @@ func WaitAPIServiceReady(s server) error { ) ticker := time.NewTicker(RetryIntervalWaitAPIService) defer ticker.Stop() + retryTimes := 0 for { ready, err = isAPIServiceReady(s) if err == nil && ready { return nil } - log.Debug("api server is not ready, retrying", errs.ZapError(err), zap.Bool("ready", ready)) select { case <-s.Context().Done(): return errors.New("context canceled while waiting api server ready") case <-ticker.C: + retryTimes++ + if retryTimes/500 > 0 { + log.Warn("api server is not ready, retrying", errs.ZapError(err)) + retryTimes /= 500 + } } } }