pimd: added support for multi-oif static mroute

Signed-off-by: e-wing <[email protected]>

Author: e-wing

pimd/pim_cmd_common.c

@@ -468,7 +468,11 @@ int pim_process_ip_gmp_proxy_cmd(struct vty *vty, bool enable)
 int pim_process_ip_mroute_cmd(struct vty *vty, const char *interface,
 			      const char *group_str, const char *source_str)
 {
-	nb_cli_enqueue_change(vty, "./oif", NB_OP_MODIFY, interface);
+	/* managing list of oif regarding (iif,mcast group, mcast source)*/
+	char xpath[XPATH_MAXLEN];
+	snprintf(xpath, sizeof(xpath), "./oif[.='%s']", interface);
+
+	nb_cli_enqueue_change(vty, xpath, NB_OP_CREATE, NULL);
 
 	if (!source_str) {
 		char buf[SRCDEST2STR_BUFFER];
@@ -487,17 +491,21 @@ int pim_process_ip_mroute_cmd(struct vty *vty, const char *interface,
 int pim_process_no_ip_mroute_cmd(struct vty *vty, const char *interface,
 				 const char *group_str, const char *source_str)
 {
-	nb_cli_enqueue_change(vty, ".", NB_OP_DESTROY, NULL);
+	/* managing list of oif regarding (iif,mcast group, mcast source)*/
+	char xpath[XPATH_MAXLEN];
+	snprintf(xpath, sizeof(xpath), "./oif[.='%s']", interface);
 
+	nb_cli_enqueue_change(vty, xpath, NB_OP_DESTROY, NULL);
+	
 	if (!source_str) {
 		char buf[SRCDEST2STR_BUFFER];
-
+		
 		inet_ntop(AF_INET6, &in6addr_any, buf, sizeof(buf));
 		return nb_cli_apply_changes(vty, FRR_PIM_MROUTE_XPATH,
-					    FRR_PIM_AF_XPATH_VAL, buf,
-					    group_str);
+			FRR_PIM_AF_XPATH_VAL, buf,
+			group_str);
 	}
-
+		
 	return nb_cli_apply_changes(vty, FRR_PIM_MROUTE_XPATH,
 				    FRR_PIM_AF_XPATH_VAL, source_str,
 				    group_str);

pimd/pim_nb.c

@@ -418,13 +418,13 @@ const struct frr_yang_module_info frr_pim_info = {
 			.xpath = "/frr-interface:lib/interface/frr-pim:pim/address-family/mroute",
 			.cbs = {
 				.create = lib_interface_pim_address_family_mroute_create,
-				.destroy = lib_interface_pim_address_family_mroute_destroy,
+				.destroy = lib_interface_pim_address_family_mroute_oif_destroy,
 			}
 		},
 		{
 			.xpath = "/frr-interface:lib/interface/frr-pim:pim/address-family/mroute/oif",
 			.cbs = {
-				.modify = lib_interface_pim_address_family_mroute_oif_modify,
+				.create = lib_interface_pim_address_family_mroute_oif_create,
 				.destroy = lib_interface_pim_address_family_mroute_oif_destroy,
 			}
 		},

pimd/pim_nb.h

@@ -166,8 +166,8 @@ int lib_interface_pim_address_family_mroute_create(
 	struct nb_cb_create_args *args);
 int lib_interface_pim_address_family_mroute_destroy(
 	struct nb_cb_destroy_args *args);
-int lib_interface_pim_address_family_mroute_oif_modify(
-	struct nb_cb_modify_args *args);
+int lib_interface_pim_address_family_mroute_oif_create(
+	struct nb_cb_create_args *args);
 int lib_interface_pim_address_family_mroute_oif_destroy(
 	struct nb_cb_destroy_args *args);
 

pimd/pim_nb_config.c

@@ -2960,8 +2960,8 @@ int lib_interface_pim_address_family_mroute_destroy(
 /*
  * XPath: /frr-interface:lib/interface/frr-pim:pim/address-family/mroute/oif
  */
-int lib_interface_pim_address_family_mroute_oif_modify(
-	struct nb_cb_modify_args *args)
+int lib_interface_pim_address_family_mroute_oif_create(
+	struct nb_cb_create_args *args)
 {
 	struct pim_instance *pim;
 	struct pim_interface *pim_iifp;
@@ -3004,7 +3004,16 @@ int lib_interface_pim_address_family_mroute_oif_modify(
 	case NB_EV_ABORT:
 		break;
 	case NB_EV_APPLY:
-		iif = nb_running_get_entry(args->dnode, NULL, true);
+		if_dnode = yang_dnode_get_parent(args->dnode, "interface");
+		if (!if_dnode) {
+			snprintf(args->errmsg, args->errmsg_len,
+				 "%% Enable PIM and/or IGMP on this interface first");
+			return NB_ERR_INCONSISTENCY;
+		}
+		iif = nb_running_get_entry(if_dnode, NULL, true);
+		if (!iif) {
+			return NB_ERR_INCONSISTENCY;
+		}
 		pim_iifp = iif->info;
 		pim = pim_iifp->pim;
 
@@ -3035,11 +3044,59 @@ int lib_interface_pim_address_family_mroute_oif_modify(
 int lib_interface_pim_address_family_mroute_oif_destroy(
 	struct nb_cb_destroy_args *args)
 {
+	struct pim_instance *pim;
+	struct pim_interface *pim_iifp;
+	struct interface *iif;
+	struct interface *oif;
+	const char *oifname;
+	pim_addr source_addr;
+	pim_addr group_addr;
+	const struct lyd_node *if_dnode;
+
 	switch (args->event) {
 	case NB_EV_VALIDATE:
+		if_dnode = yang_dnode_get_parent(args->dnode, "interface");
+		if (!is_pim_interface(if_dnode)) {
+			snprintf(args->errmsg, args->errmsg_len,
+				 "%% Enable PIM and/or IGMP on this interface first");
+			return NB_ERR_VALIDATION;
+		}
+		break;
 	case NB_EV_PREPARE:
 	case NB_EV_ABORT:
+		break;
 	case NB_EV_APPLY:
+		if_dnode = yang_dnode_get_parent(args->dnode, "interface");
+		if (!if_dnode) {
+			snprintf(args->errmsg, args->errmsg_len,
+				 "%% Enable PIM and/or IGMP on this interface first");
+			return NB_ERR_INCONSISTENCY;
+		}
+		iif = nb_running_get_entry(if_dnode, NULL, true);
+		if (!iif) {
+			return NB_ERR_INCONSISTENCY;
+		}
+
+		pim_iifp = iif->info;
+		pim = pim_iifp->pim;
+
+		oifname = yang_dnode_get_string(args->dnode, NULL);
+		oif = if_lookup_by_name(oifname, pim->vrf->vrf_id);
+		if (!oif) {
+			snprintf(args->errmsg, args->errmsg_len,
+				 "No such interface name %s",
+				 oifname);
+			return NB_ERR_INCONSISTENCY;
+		}
+
+		yang_dnode_get_pimaddr(&source_addr, args->dnode, "../source-addr");
+		yang_dnode_get_pimaddr(&group_addr, args->dnode, "../group-addr");
+
+		if (pim_static_del(pim, iif, oif, group_addr, source_addr)) {
+			snprintf(args->errmsg, args->errmsg_len,
+				 "Failed to del static mroute");
+			return NB_ERR_INCONSISTENCY;
+		}
 		break;
 	}
 

yang/frr-pim.yang

@@ -650,10 +650,10 @@ module frr-pim {
       description
         "Add multicast route.";
 
-      leaf oif {
+      leaf-list oif {
         type frr-interface:interface-ref;
         description
-          "Outgoing interface name.";
+          "List of Outgoing interface names.";
       }
 
       leaf source-addr {