Method reborn

pkg/controller/task.go:195–261

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

}

func (controller *Controller) reborn(runtime *rtctrl.RuntimeInfo, logger *logs.Logger) {
	recommend, err := controller.runtimeDispatcher.ResetRuntime(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.Reborn(&api.FuncletClientRebornInput{
		ContainerID:             runtime.RuntimeID,
		RequestID:               requestID,
		ScaleDownRecommendation: recommend,
	})
	logger.Infof("reborn runtime %s request id %s response %v err %v", runtime.RuntimeID, requestID, response, err)
	if err == nil {
		logs.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) {
				logs.Errorf("cool down runtime %s release memory %d failed", runtime.RuntimeID, runtime.Resource.Memory)
			} else {
				runtime.SetMarked(false)
			}
		}
	}
	if err != nil {
		logger.Errorf("reborn runtime %s failed: %s", runtime.RuntimeID, err.Error())
	}
	if recommend != nil && response == nil {
		for _, ID := range recommend.ResetContainers {
			rt, _ := controller.runtimeDispatcher.GetRuntime(ID)
			rt.Invalidate()
		}
		logger.Errorf("scale down runtime %s failed: %v", runtime.RuntimeID, recommend.ResetContainers)