Function synAppInstall

agent/app/service/app_utils.go:1524–1593

(containers map[string]container.Summary, appInstall *model.AppInstall, force bool)

}

func synAppInstall(containers map[string]container.Summary, appInstall *model.AppInstall, force bool) {
	oldStatus := appInstall.Status
	containerNames := strings.Split(appInstall.ContainerName, ",")
	if len(containers) == 0 {
		if appInstall.Status == constant.StatusUpErr && !force {
			return
		}
		appInstall.Status = constant.StatusError
		appInstall.Message = buserr.WithName("ErrContainerNotFound", strings.Join(containerNames, ",")).Error()
		_ = appInstallRepo.Save(context.Background(), appInstall)
		return
	}
	notFoundNames := make([]string, 0)
	exitNames := make([]string, 0)
	exitedCount := 0
	pausedCount := 0
	runningCount := 0
	restartingCount := 0
	total := len(containerNames)
	for _, name := range containerNames {
		if con, ok := containers["/"+name]; ok {
			switch con.State {
			case "exited":
				exitedCount++
				exitNames = append(exitNames, name)
			case "running":
				runningCount++
			case "restarting":
				restartingCount++
			case "paused":
				pausedCount++
			}
		} else {
			notFoundNames = append(notFoundNames, name)
		}
	}
	switch {
	case exitedCount == total:
		appInstall.Status = constant.StatusStopped
	case runningCount == total:
		appInstall.Status = constant.StatusRunning
		if oldStatus == constant.StatusRunning {
			return
		}
	case restartingCount == total:
		appInstall.Status = constant.StatusRestarting
	case pausedCount == total:
		appInstall.Status = constant.StatusPaused
	case len(notFoundNames) == total:
		if appInstall.Status == constant.StatusUpErr && !force {
			return
		}
		appInstall.Status = constant.StatusError
		appInstall.Message = buserr.WithName("ErrContainerNotFound", strings.Join(notFoundNames, ",")).Error()
	default:
		var msg string
		if exitedCount > 0 {
			msg = buserr.WithName("ErrContainerMsg", strings.Join(exitNames, ",")).Error()