Method sendGenericRequestLoop

pkg/controller/rtctrl/runtime.go:124–150

sendGenericRequestLoop

()

// sendGenericRequestLoop
func (info *RuntimeInfo) sendGenericRequestLoop() {
	encoder := json.NewEncoder(info.runtimeConn)
loop:
	for {
		select {
		case request := <-info.requestChan:
			err := encoder.Encode(request)
			requestInfo := info.loadRequest(request.RequestID)
			if err != nil {
				logs.Errorf("marshal invokeReq failed. %s", err.Error())
				if requestInfo != nil {
					requestInfo.InvokeResult(StatusFailed,
						fmt.Sprintf("RequestID: %s Process exited before completing request", request.RequestID))
					requestInfo.Notify()
				}
			}
			if requestInfo != nil {
				requestInfo.StepDone(StageSendRequest)
			}
		case <-info.runtimeStopChan:
			break loop
		}
	}

	info.runtimeWaitGroup.Done()
	logs.Infof("runtime %s stop sending request", info.RuntimeID)
}

func (info *RuntimeInfo) sendHTTPRequestLoop() {
	needStop := false