[ Agent ] [ App ] - modify srs bugs

agent-go/executor/AppFunction.go

@@ -954,19 +954,31 @@ func (op *AgentOsOperator) deploySRS(funcArgs []string) (bool, []string) {
 	}
 	parseIP := net.ParseIP(funcArgs[0])
 	if parseIP == nil {
-		return false, append(result, "ip args error !")
+		return false, append(result, "ip args error !", funcArgs[0])
 	}
 	if !BasicReplace(k8sSRSYamlFilePath, "A1C2IP", funcArgs[0]) {
 		result = append(result, "替换A1C2IP信息")
 		return false, result
 	}
+
+	//	A1C1IP
+	parseIP = net.ParseIP(funcArgs[3])
+	if parseIP == nil {
+		return false, append(result, "ip args error !", funcArgs[3])
+	}
+	if !BasicReplace(k8sSRSYamlFilePath, "A1C1IP", funcArgs[3]) {
+		result = append(result, "替换A1C1IP信息")
+		return false, result
+	}
 	if !BasicReplace(k8sSRSYamlFilePath, "A1C1JS", funcArgs[4]) {
 		result = append(result, "替换A1C1JS信息")
 		return false, result
 	}
+
+	// M2D2IP
 	parseIP = net.ParseIP(funcArgs[5])
 	if parseIP == nil {
-		return false, append(result, "ip args error !")
+		return false, append(result, "ip args error !", funcArgs[5])
 	}
 	if !BasicReplace(k8sSRSYamlFilePath, "M2D2IP", funcArgs[5]) {
 		result = append(result, "替换M2D2IP信息")
@@ -985,6 +997,16 @@ func (op *AgentOsOperator) deploySRS(funcArgs []string) (bool, []string) {
 	}
 
 	// check pod ok
+	if !K8sCheckPodStatusTimeout("helm-live-srs-rtc-0", funcArgs[1], 120) {
+		return false, []string{
+			"helm-live-srs-rtc-0 run failed !",
+		}
+	}
+	if !K8sCheckDeploymentStatusTimeout("helm-live-op-v2", funcArgs[1], 120) {
+		return false, []string{
+			"helm-live-op-v2 run failed !",
+		}
+	}
 
 	// 成功启动
 	return true, []string{