Method invokeHandler

pkg/controller/rtctrl/dispatcherv2.go:178–217

(w http.ResponseWriter, r *http.Request)

}

func (s *DispatchServerV2) invokeHandler(w http.ResponseWriter, r *http.Request) {
	conn, _, ok := setupHijackConn(w, r)
	if !ok {
		logs.Error("setupHijackConn failed")
		return
	}
	defer conn.Close()

	runtimeid := r.Header.Get("x-cfc-runtimeid")
	commitid := r.Header.Get("x-cfc-commitid")
	// TODO: [improve] hostip here is always 127.0.0.1
	hostip := r.Header.Get("x-cfc-hostip")
	logs.V(6).Infof("runtime %s@%s connect", runtimeid, hostip)

	runtime, err := s.runtimeDispatcher.GetRuntime(runtimeid)
	if err != nil {
		logs.V(3).Errorf("runtime %s not found", runtimeid)
		return
	}

	warmNotify := make(chan struct{})
	params := &startRuntimeParams{
		commitID:   commitid,
		hostIP:     hostip,
		conn:       conn,
		warmNotify: warmNotify,
		urlParams:  r.URL.Query(),
	}
	go func() {
		select {
		case <-warmNotify:
			logs.V(9).Infof("[resource modify]-[increase]: runtime %s, resource %s", runtime.RuntimeID, runtime.Resource)
			s.runtimeDispatcher.IncreaseUsedResource(runtime.Resource)
		}
	}()
	if err := runtime.startRuntimeLoop(params); err != nil {
		logs.Errorf("init runtime %s failed: %s", runtime.RuntimeID, err.Error())
		return
	}
}

func (s *DispatchServerV2) runnerHandler(w http.ResponseWriter, r *http.Request) {
	runtimeID := r.Header.Get("x-cfc-runtimeid")