func()

in perf-tools/framework/app_manager.go [236:261]

• 26 lines of code
• 6 McCabe index (conditional complexity)

func (dam *DeploymentsAppManager) WaitForAppsToBeCleanedUp(appInfo *AppInfo, timeout time.Duration) error {
	startTime := time.Now()
	i := 1
	return waitForCondition(func() bool {
		err := dam.RefreshAppStatus(appInfo)
		if err != nil {
			return true
		}
		if appInfo.AppStatus.DesiredNum != 0 || appInfo.AppStatus.CreatedNum != 0 || appInfo.AppStatus.ReadyNum != 0 {
			if time.Since(startTime) > 60*time.Duration(i)*time.Second {
				utils.Logger.Info("still waiting for app to be cleaned up",
					zap.String("appID", appInfo.AppID),
					zap.Duration("timeout", timeout),
					zap.Duration("elapseTime", time.Since(startTime)),
					zap.Int("desiredNum", appInfo.AppStatus.DesiredNum),
					zap.Int("createdNum", appInfo.AppStatus.CreatedNum),
					zap.Int("readyNum", appInfo.AppStatus.ReadyNum))
				i++
			}
			return false
		}
		utils.Logger.Info("app is cleaned up", zap.String("appID", appInfo.AppID),
			zap.Any("appStatus", appInfo.AppStatus))
		return true
	}, 1*time.Second, timeout)
}