Method stopRuntime

pkg/controller/rtctrl/runtime.go:355–389

stopRuntime

()

// stopRuntime
func (info *RuntimeInfo) stopRuntime() {
	info.invokeLock.Lock()
	defer info.invokeLock.Unlock()

	logs.V(5).Infof("close runtime %s", info.RuntimeID)

	info.PreLoadTimeMS = 0
	info.PostLoadTimeMS = 0
	info.PreInitTimeMS = 0
	info.PostInitTimeMS = 0
	info.AcceptReqCnt = 0
	info.RejectReqCnt = 0
	info.Concurrency = 0

	info.requestMap.Range(func(key, value interface{}) bool {
		id := key.(string)
		request := value.(*RequestInfo)
		request.InvokeResult(StatusFailed, fmt.Sprintf("RequestID: %s Process exited before completing request", id))
		request.Notify()
		return true
	})
	info.requestMap = sync.Map{}
	close(info.runtimeStopChan)
	if !info.WithStreamMode {
		info.runtimeConn.Close()
	} else {
		info.httpClient = nil
	}
	info.runtimeWaitGroup.Wait()
	info.updateStreamMode(false)

	info.SetState(RuntimeStateStopped)

	info.runtimeRunChan = make(chan struct{})
}

// InvokeFunc
func (info *RuntimeInfo) InvokeFunc(request *RequestInfo, invokeReq *InvokeRequest) error {