fix the panic when the active endpoints of gateway is nil/empty

Author: 珩轩

pkg/proxyengine/proxyserver/interceptor.go

@@ -189,9 +189,9 @@ func serveRequest(conn net.Conn, w http.ResponseWriter, r *http.Request) {
 			ctx := r.Context()
 			select {
 			case <-stopCh:
-				klog.Info("chunked request(%s) normally exit", r.URL.String())
+				klog.Infof("chunked request(%s) normally exit", r.URL.String())
 			case <-ctx.Done():
-				klog.Info("chunked request(%s) to agent(%s) closed by cloud client, %v", r.URL.String(),
+				klog.Infof("chunked request(%s) to agent(%s) closed by cloud client, %v", r.URL.String(),
 					r.Header.Get(utils.RavenProxyHostHeaderKey), ctx.Err())
 				conn.Close()
 			}

pkg/proxyengine/proxyserver/manageheader.go

@@ -145,8 +145,7 @@ func (h *headerManger) getAPIServerRequestDestAddress(r *http.Request) (name, ip
 	}
 	name, err = h.getGatewayNodeName(&node)
 	if err != nil {
-		return "", "", "", fmt.Errorf("gateway include node %s, has no active endpoints, error %s",
-			node.Name, err.Error())
+		return "", "", "", fmt.Errorf("can not find gateway node for node %s, error %s", node.Name, err.Error())
 	}
 	ip = getNodeIP(&node)
 	if ip == "" {
@@ -180,8 +179,7 @@ func (h *headerManger) getNormalRequestDestAddress(r *http.Request) (name, ip, p
 	}
 	name, err = h.getGatewayNodeName(&node)
 	if err != nil {
-		return "", "", "", fmt.Errorf("gateway include node %s, has no active endpoints, error %s",
-			node.Name, err.Error())
+		return "", "", "", fmt.Errorf("can not find gateway node for node %s, error %s", node.Name, err.Error())
 	}
 	ip = getNodeIP(&node)
 	if ip == "" {
@@ -241,6 +239,15 @@ func (h *headerManger) getGatewayNodeName(node *v1.Node) (string, error) {
 		}
 		return "", err
 	}
-	rand.Seed(time.Now().Unix())
-	return gw.Status.ActiveEndpoints[rand.Intn(len(gw.Status.ActiveEndpoints))].NodeName, nil
+	if gw.Status.ActiveEndpoints == nil || len(gw.Status.ActiveEndpoints) == 0 {
+		return "", fmt.Errorf("no active endpoints for gateway %s", gwName)
+	}
+	names := make([]string, 0)
+	for _, ep := range gw.Status.ActiveEndpoints {
+		if ep.Type == v1beta1.Proxy {
+			names = append(names, ep.NodeName)
+		}
+	}
+	rand.New(rand.NewSource(time.Now().Unix()))
+	return names[rand.Intn(len(names))], nil
 }