Method coolDown

pkg/controller/task.go:126–193

coolDown

(runtime *rtctrl.RuntimeInfo, logger *logs.Logger)

// coolDown
func (controller *Controller) coolDown(runtime *rtctrl.RuntimeInfo, logger *logs.Logger) {
	recommend, err := controller.runtimeDispatcher.CoolDownRuntime(runtime)
	if err != nil {
		return
	}
	res := runtime.Resource.Copy()
	used := runtime.Used
	marked := runtime.Marked

	runtime.RebootBegin()
	defer runtime.RebootEnd()

	if recommend != nil {
		for _, ID := range recommend.ResetContainers {
			info, _ := controller.runtimeDispatcher.GetRuntime(ID)
			info.RebootBegin()
		}
		defer func() {
			for _, ID := range recommend.ResetContainers {
				info, _ := controller.runtimeDispatcher.GetRuntime(ID)
				info.RebootEnd()
			}
		}()
	}

	requestID := id.GetRequestID()
	response, err := controller.FuncletClient.CoolDown(&api.FuncletClientCoolDownInput{
		ContainerID:             runtime.RuntimeID,
		RequestID:               requestID,
		ScaleDownRecommendation: recommend,
	})
	logger.Infof("cool down runtime %s request id %s response %v err %v", runtime.RuntimeID, requestID, response, err)
	if err == nil {
		logger.V(9).Infof("[resource modify]-[decrease]: used %t, runtime %s, resource %s", used, runtime.RuntimeID, res)
		if used {
			if !controller.runtimeDispatcher.ReleaseUsedResource(res) {
				logs.Errorf("cool down runtime %s release memory %d failed", runtime.RuntimeID, runtime.Resource.Memory)
			} else {
				runtime.SetUsed(false)
			}
		}
		if marked {
			if !controller.runtimeDispatcher.ReleaseMarkedResource(res) {
				logger.Errorf("cool down runtime %s release memory %d failed", runtime.RuntimeID, runtime.Resource.Memory)
			} else {
				runtime.SetMarked(false)
			}
		}
	}
	if err != nil {
		logger.Errorf("cool down runtime %s failed: %s", runtime.RuntimeID, err.Error())
		runtime.Invalidate()
	}
	if recommend != nil && response == nil {
		for _, ID := range recommend.ResetContainers {
			rt, _ := controller.runtimeDispatcher.GetRuntime(ID)
			rt.Invalidate()
		}