From 193b2aefdb41d55209193af1f5e8c8dacb861c84 Mon Sep 17 00:00:00 2001

From: Dumitru Ceara <dceara@redhat.com>

Date: Tue, 24 Sep 2019 10:02:49 +0200

Subject: [PATCH 4/4] ovn-northd: Add static IP multicast flood configuration

Add the following new configuration options to the

Logical_Switch_Port:options column in the OVN Northbound database:

- mcast_flood: if set to 'true' all incoming IP multicast traffic

  (except IP multicast reports) entering the switch will also be

  flooded on the logical switch port.

- mcast_flood_reports: if set to 'true' all incoming IP multicast

  entering the switch will also be flooded on the logical switch

  port. A clone of the packets is also processed by ovn-controller

  for snooping.

Add the following new configuration option to the

Logical_Router_Port:options column in the OVN Northbound database:

- mcast_flood: if set to 'true' all incoming IP multicast traffic

  (including IP multicast reports) entering the router will be also

  flooded on the logical router port.

Due to the fact that in the router pipeline multicast reports are

not treated in a special way there's no need for an explicit

'mcast_flood_reports' option for router ports.

Signed-off-by: Dumitru Ceara <dceara@redhat.com>

Acked-by: Mark Michelson <mmichels@redhat.com>

Signed-off-by: Mark Michelson <mmichels@redhat.com>

(cherry-picked from ovn commit 79308138891ae04a02a07068501696ef78157912)

---

 ovn/lib/mcast-group-index.h |   2 +

 ovn/northd/ovn-northd.8.xml |  30 ++++-

 ovn/northd/ovn-northd.c     | 212 +++++++++++++++++++++++++++++++-----

 ovn/ovn-nb.xml              |  34 ++++++

 tests/ovn.at                |  81 +++++++++++++-

 5 files changed, 325 insertions(+), 34 deletions(-)

diff --git a/ovn/lib/mcast-group-index.h b/ovn/lib/mcast-group-index.h

index 6249cac99..930963b1b 100644

--- a/ovn/lib/mcast-group-index.h

+++ b/ovn/lib/mcast-group-index.h

@@ -28,6 +28,8 @@ enum ovn_mcast_tunnel_keys {

     OVN_MCAST_FLOOD_TUNNEL_KEY = OVN_MIN_MULTICAST,

     OVN_MCAST_UNKNOWN_TUNNEL_KEY,

     OVN_MCAST_MROUTER_FLOOD_TUNNEL_KEY,

+    OVN_MCAST_MROUTER_STATIC_TUNNEL_KEY,

+    OVN_MCAST_STATIC_TUNNEL_KEY,

     OVN_MIN_IP_MULTICAST,

     OVN_MAX_IP_MULTICAST = OVN_MAX_MULTICAST,

 };

diff --git a/ovn/northd/ovn-northd.8.xml b/ovn/northd/ovn-northd.8.xml

index ec9020d2a..b9ae28e14 100644

--- a/ovn/northd/ovn-northd.8.xml

+++ b/ovn/northd/ovn-northd.8.xml

@@ -954,7 +954,11 @@ output;

         A priority-100 flow that punts all IGMP packets to

         ovn-controller if IGMP snooping is enabled on the

-        logical switch.

+        logical switch. The flow also forwards the IGMP packets to the

+        MC_MROUTER_STATIC multicast group, which

+        ovn-northd populates with all the logical ports that

+        have <ref column="options" table="Logical_Switch_Port"/>

+        :mcast_flood_reports='true'.

@@ -976,10 +980,15 @@ output;

         A priority-80 flow that forwards all unregistered IP multicast traffic

-        to the MC_MROUTER_FLOOD multicast group, if any.

-        Otherwise the flow drops all unregistered IP multicast packets.  This

-        flow is added only if 

-        table="Logical_Switch"/>:mcast_flood_unregistered='false'.

+        to the MC_STATIC multicast group, which

+        ovn-northd populates with all the logical ports that

+        have <ref column="options" table="Logical_Switch_Port"/>

+        :mcast_flood='true'. The flow also forwards

+        unregistered IP multicast traffic to the MC_MROUTER_FLOOD

+        multicast group, which ovn-northd populates with all the

+        logical ports connected to logical routers that have

+        <ref column="options" table="Logical_Router"/>

+        :mcast_relay='true'.

@@ -2092,6 +2101,17 @@ output;

+      

+        

+          Priority-450 flow that matches unregistered IP multicast traffic

+          and sets outport to the MC_STATIC

+          multicast group, which ovn-northd populates with the

+          logical ports that have

+          <ref column="options" table="Logical_Router_Port"/>

+          :mcast_flood='true'.

+        

+      

+

           For distributed logical routers where one of the logical router

diff --git a/ovn/northd/ovn-northd.c b/ovn/northd/ovn-northd.c

index 2f6826f17..250529eb7 100644

--- a/ovn/northd/ovn-northd.c

+++ b/ovn/northd/ovn-northd.c

@@ -459,7 +459,12 @@ struct mcast_switch_info {

                                  * should be flooded to the mrouter. Only

                                  * applicable if flood_unregistered == false.

                                  */

-

+    bool flood_reports;         /* True if the switch has at least one port

+                                 * configured to flood reports.

+                                 */

+    bool flood_static;          /* True if the switch has at least one port

+                                 * configured to flood traffic.

+                                 */

     int64_t table_size;         /* Max number of IP multicast groups. */

     int64_t idle_timeout;       /* Timeout after which an idle group is

                                  * flushed.

@@ -477,7 +482,10 @@ struct mcast_switch_info {

 };

 struct mcast_router_info {

-    bool relay; /* True if the router should relay IP multicast. */

+    bool relay;        /* True if the router should relay IP multicast. */

+    bool flood_static; /* True if the router has at least one port configured

+                        * to flood traffic.

+                        */

 };

 struct mcast_info {

@@ -492,6 +500,34 @@ struct mcast_info {

     };

 };

+struct mcast_port_info {

+    bool flood;         /* True if the port should flood IP multicast traffic

+                         * regardless if it's registered or not. */

+    bool flood_reports; /* True if the port should flood IP multicast reports

+                         * (e.g., IGMP join/leave). */

+};

+

+static void

+init_mcast_port_info(struct mcast_port_info *mcast_info,

+                     const struct nbrec_logical_switch_port *nbsp,

+                     const struct nbrec_logical_router_port *nbrp)

+{

+    if (nbsp) {

+        mcast_info->flood =

+            smap_get_bool(&nbsp->options, "mcast_flood", false);

+        mcast_info->flood_reports =

+            smap_get_bool(&nbsp->options, "mcast_flood_reports",

+                          false);

+    } else if (nbrp) {

+        /* We don't process multicast reports in any special way on logical

+         * routers so just treat them as regular multicast traffic.

+         */

+        mcast_info->flood =

+            smap_get_bool(&nbrp->options, "mcast_flood", false);

+        mcast_info->flood_reports = mcast_info->flood;

+    }

+}

+

 static uint32_t

 ovn_mcast_group_allocate_key(struct mcast_info *mcast_info)

 {

@@ -1033,7 +1069,7 @@ build_datapaths(struct northd_context *ctx, struct hmap *datapaths,

         ovn_datapath_destroy(datapaths, od);

     }

 }

-

+

 struct ovn_port {

     struct hmap_node key_node;  /* Index on 'key'. */

     char *key;                  /* nbs->name, nbr->name, sb->logical_port. */

@@ -1055,6 +1091,9 @@ struct ovn_port {

     struct lport_addresses lrp_networks;

+    /* Logical port multicast data. */

+    struct mcast_port_info mcast_info;

+

     bool derived; /* Indicates whether this is an additional port

                    * derived from nbsp or nbrp. */

@@ -1071,6 +1110,23 @@ struct ovn_port {

     struct ovs_list list;       /* In list of similar records. */

 };

+static void

+ovn_port_set_sb(struct ovn_port *op,

+                const struct sbrec_port_binding *sb)

+{

+    op->sb = sb;

+}

+

+static void

+ovn_port_set_nb(struct ovn_port *op,

+                const struct nbrec_logical_switch_port *nbsp,

+                const struct nbrec_logical_router_port *nbrp)

+{

+    op->nbsp = nbsp;

+    op->nbrp = nbrp;

+    init_mcast_port_info(&op->mcast_info, op->nbsp, op->nbrp);

+}

+

 static struct ovn_port *

 ovn_port_create(struct hmap *ports, const char *key,

                 const struct nbrec_logical_switch_port *nbsp,

@@ -1084,9 +1140,8 @@ ovn_port_create(struct hmap *ports, const char *key,

     op->json_key = ds_steal_cstr(&json_key);

     op->key = xstrdup(key);

-    op->sb = sb;

-    op->nbsp = nbsp;

-    op->nbrp = nbrp;

+    ovn_port_set_sb(op, sb);

+    ovn_port_set_nb(op, nbsp, nbrp);

     op->derived = false;

     hmap_insert(ports, &op->key_node, hash_string(op->key, 0));

     return op;

@@ -1882,7 +1937,7 @@ join_logical_ports(struct northd_context *ctx,

                                      nbsp->name);

                         continue;

                     }

-                    op->nbsp = nbsp;

+                    ovn_port_set_nb(op, nbsp, NULL);

                     ovs_list_remove(&op->list);

                     uint32_t queue_id = smap_get_int(&op->sb->options,

@@ -1973,7 +2028,7 @@ join_logical_ports(struct northd_context *ctx,

                                      nbrp->name);

                         continue;

                     }

-                    op->nbrp = nbrp;

+                    ovn_port_set_nb(op, NULL, nbrp);

                     ovs_list_remove(&op->list);

                     ovs_list_push_back(both, &op->list);

@@ -2018,7 +2073,7 @@ join_logical_ports(struct northd_context *ctx,

                     struct ovn_port *crp = ovn_port_find(ports, redirect_name);

                     if (crp) {

                         crp->derived = true;

-                        crp->nbrp = nbrp;

+                        ovn_port_set_nb(crp, NULL, nbrp);

                         ovs_list_remove(&crp->list);

                         ovs_list_push_back(both, &crp->list);

                     } else {

@@ -2896,7 +2951,7 @@ build_ports(struct northd_context *ctx,

             continue;

         }

-        op->sb = sbrec_port_binding_insert(ctx->ovnsb_txn);

+        ovn_port_set_sb(op, sbrec_port_binding_insert(ctx->ovnsb_txn));

         ovn_port_update_sbrec(ctx, sbrec_chassis_by_name, op,

                               &chassis_qdisc_queues,

                               &active_ha_chassis_grps);

@@ -2938,6 +2993,14 @@ static const struct multicast_group mc_flood =

 static const struct multicast_group mc_mrouter_flood =

     { MC_MROUTER_FLOOD, OVN_MCAST_MROUTER_FLOOD_TUNNEL_KEY };

+#define MC_MROUTER_STATIC "_MC_mrouter_static"

+static const struct multicast_group mc_mrouter_static =

+    { MC_MROUTER_STATIC, OVN_MCAST_MROUTER_STATIC_TUNNEL_KEY };

+

+#define MC_STATIC "_MC_static"

+static const struct multicast_group mc_static =

+    { MC_STATIC, OVN_MCAST_STATIC_TUNNEL_KEY };

+

 #define MC_UNKNOWN "_MC_unknown"

 static const struct multicast_group mc_unknown =

     { MC_UNKNOWN, OVN_MCAST_UNKNOWN_TUNNEL_KEY };

@@ -3151,7 +3214,23 @@ ovn_igmp_group_get_ports(const struct sbrec_igmp_group *sb_igmp_group,

      *n_ports = 0;

      for (size_t i = 0; i < sb_igmp_group->n_ports; i++) {

-        ports[(*n_ports)] =

+        struct ovn_port *port =

+            ovn_port_find(ovn_ports, sb_igmp_group->ports[i]->logical_port);

+

+        /* If this is already a flood port skip it for the group. */

+        if (port->mcast_info.flood) {

+            continue;

+        }

+

+        /* If this is already a port of a router on which relay is enabled,

+         * skip it for the group. Traffic is flooded there anyway.

+         */

+        if (port->peer && port->peer->od &&

+                port->peer->od->mcast_info.rtr.relay) {

+            continue;

+        }

+

+        ports[(*n_ports)] = port;

             ovn_port_find(ovn_ports, sb_igmp_group->ports[i]->logical_port);

         if (ports[(*n_ports)]) {

             (*n_ports)++;

@@ -5531,9 +5610,18 @@ build_lswitch_flows(struct hmap *datapaths, struct hmap *ports,

         struct mcast_switch_info *mcast_sw_info = &od->mcast_info.sw;

         if (mcast_sw_info->enabled) {

+            ds_clear(&actions);

+            if (mcast_sw_info->flood_reports) {

+                ds_put_cstr(&actions,

+                            "clone { "

+                                "outport = \""MC_MROUTER_STATIC"\"; "

+                                "output; "

+                            "};");

+            }

+            ds_put_cstr(&actions, "igmp;");

             /* Punt IGMP traffic to controller. */

             ovn_lflow_add(lflows, od, S_SWITCH_IN_L2_LKUP, 100,

-                          "ip4 && ip.proto == 2", "igmp;");

+                          "ip4 && ip.proto == 2", ds_cstr(&actions));

             /* Flood all IP multicast traffic destined to 224.0.0.X to all

              * ports - RFC 4541, section 2.1.2, item 2.

@@ -5542,17 +5630,30 @@ build_lswitch_flows(struct hmap *datapaths, struct hmap *ports,

                           "ip4 && ip4.dst == 224.0.0.0/24",

                           "outport = \""MC_FLOOD"\"; output;");

-            /* Drop unregistered IP multicast if not allowed. */

+            /* Forward uregistered IP multicast to routers with relay enabled

+             * and to any ports configured to flood IP multicast traffic.

+             * If configured to flood unregistered traffic this will be

+             * handled by the L2 multicast flow.

+             */

             if (!mcast_sw_info->flood_unregistered) {

-                /* Forward unregistered IP multicast to mrouter (if any). */

+                ds_clear(&actions);

+

                 if (mcast_sw_info->flood_relay) {

-                    ovn_lflow_add(lflows, od, S_SWITCH_IN_L2_LKUP, 80,

-                                  "ip4 && ip4.mcast",

-                                  "outport = \""MC_MROUTER_FLOOD"\"; output;");

+                    ds_put_cstr(&actions,

+                                "clone { "

+                                    "outport = \""MC_MROUTER_FLOOD"\"; "

+                                    "output; "

+                                "}; ");

+                }

+

+                if (mcast_sw_info->flood_static) {

+                    ds_put_cstr(&actions, "outport =\""MC_STATIC"\"; output;");

                 } else {

-                    ovn_lflow_add(lflows, od, S_SWITCH_IN_L2_LKUP, 80,

-                                  "ip4 && ip4.mcast", "drop;");

+                    ds_put_cstr(&actions, "drop;");

                 }

+

+                ovn_lflow_add(lflows, od, S_SWITCH_IN_L2_LKUP, 80,

+                              "ip4 && ip4.mcast", ds_cstr(&actions));

             }

         }

@@ -5582,11 +5683,20 @@ build_lswitch_flows(struct hmap *datapaths, struct hmap *ports,

         ds_put_format(&match, "eth.mcast && ip4 && ip4.dst == %s ",

                       igmp_group->mcgroup.name);

+

         /* Also flood traffic to all multicast routers with relay enabled. */

         if (mcast_sw_info->flood_relay) {

             ds_put_cstr(&actions,

                         "clone { "

-                            "outport = \""MC_MROUTER_FLOOD "\"; output; "

+                            "outport = \""MC_MROUTER_FLOOD "\"; "

+                            "output; "

+                        "};");

+        }

+        if (mcast_sw_info->flood_static) {

+            ds_put_cstr(&actions,

+                        "clone { "

+                            "outport =\""MC_STATIC"\"; "

+                            "output; "

                         "};");

         }

         ds_put_format(&actions, "outport = \"%s\"; output; ",

@@ -7783,6 +7893,7 @@ build_lrouter_flows(struct hmap *datapaths, struct hmap *ports,

         if (!od->nbr || !od->mcast_info.rtr.relay) {

             continue;

         }

+

         struct ovn_igmp_group *igmp_group;

         LIST_FOR_EACH (igmp_group, list_node, &od->mcast_info.groups) {

@@ -7790,11 +7901,35 @@ build_lrouter_flows(struct hmap *datapaths, struct hmap *ports,

             ds_clear(&actions);

             ds_put_format(&match, "ip4 && ip4.dst == %s ",

                           igmp_group->mcgroup.name);

+            if (od->mcast_info.rtr.flood_static) {

+                ds_put_cstr(&actions,

+                            "clone { "

+                                "outport = \""MC_STATIC"\"; "

+                                "ip.ttl--; "

+                                "next; "

+                            "};");

+            }

             ds_put_format(&actions, "outport = \"%s\"; ip.ttl--; next;",

                           igmp_group->mcgroup.name);

             ovn_lflow_add(lflows, od, S_ROUTER_IN_IP_ROUTING, 500,

                           ds_cstr(&match), ds_cstr(&actions));

         }

+

+        /* If needed, flood unregistered multicast on statically configured

+         * ports.

+         */

+        if (od->mcast_info.rtr.flood_static) {

+            ds_clear(&match);

+            ds_clear(&actions);

+            ds_put_format(&match, "ip4.mcast");

+            ovn_lflow_add(lflows, od, S_ROUTER_IN_IP_ROUTING, 450,

+                          "ip4.mcast",

+                          "clone { "

+                                "outport = \""MC_STATIC"\"; "

+                                "ip.ttl--; "

+                                "next; "

+                          "};");

+        }

     }

     /* Logical router ingress table 8: Policy.

@@ -8943,11 +9078,15 @@ build_mcast_groups(struct northd_context *ctx,

     hmap_init(igmp_groups);

     HMAP_FOR_EACH (op, key_node, ports) {

-        if (!op->nbsp) {

-            continue;

-        }

-

-        if (lsp_is_enabled(op->nbsp)) {

+        if (op->nbrp && lrport_is_enabled(op->nbrp)) {

+            /* If this port is configured to always flood multicast traffic

+             * add it to the MC_STATIC group.

+             */

+            if (op->mcast_info.flood) {

+                ovn_multicast_add(mcast_groups, &mc_static, op);

+                op->od->mcast_info.rtr.flood_static = true;

+            }

+        } else if (op->nbsp && lsp_is_enabled(op->nbsp)) {

             ovn_multicast_add(mcast_groups, &mc_flood, op);

             /* If this port is connected to a multicast router then add it

@@ -8957,6 +9096,22 @@ build_mcast_groups(struct northd_context *ctx,

                     op->peer->od && op->peer->od->mcast_info.rtr.relay) {

                 ovn_multicast_add(mcast_groups, &mc_mrouter_flood, op);

             }

+

+            /* If this port is configured to always flood multicast reports

+             * add it to the MC_MROUTER_STATIC group.

+             */

+            if (op->mcast_info.flood_reports) {

+                ovn_multicast_add(mcast_groups, &mc_mrouter_static, op);

+                op->od->mcast_info.sw.flood_reports = true;

+            }

+

+            /* If this port is configured to always flood multicast traffic

+             * add it to the MC_STATIC group.

+             */

+            if (op->mcast_info.flood) {

+                ovn_multicast_add(mcast_groups, &mc_static, op);

+                op->od->mcast_info.sw.flood_static = true;

+            }

         }

     }

@@ -9017,8 +9172,13 @@ build_mcast_groups(struct northd_context *ctx,

         for (size_t i = 0; i < od->n_router_ports; i++) {

             struct ovn_port *router_port = od->router_ports[i]->peer;

+            /* If the router the port connects to doesn't have multicast

+             * relay enabled or if it was already configured to flood

+             * multicast traffic then skip it.

+             */

             if (!router_port || !router_port->od ||

-                    !router_port->od->mcast_info.rtr.relay) {

+                    !router_port->od->mcast_info.rtr.relay ||

+                    router_port->mcast_info.flood) {

                 continue;

             }

diff --git a/ovn/ovn-nb.xml b/ovn/ovn-nb.xml

index c2472a04a..e0051db25 100644

--- a/ovn/ovn-nb.xml

+++ b/ovn/ovn-nb.xml

@@ -671,6 +671,26 @@

         </column>

       </group>

+      <group title="IP Multicast Snooping Options">

+        

+          These options apply when the port is part of a logical switch

+          which has <ref table="Logical_Switch" column="other_config"/>

+          :mcast_snoop set to true.

+        

+

+        

+                type='{"type": "boolean"}'>

+          If set to true, multicast packets (except reports) are

+          unconditionally forwarded to the specific port.

+        </column>

+

+        

+                type='{"type": "boolean"}'>

+          If set to true, multicast reports are unconditionally

+          forwarded to the specific port.

+        </column>

+      </group>

+

     </group>

     <group title="Containers">

@@ -1962,6 +1982,20 @@

           issues.

       </column>

+

+      

+              type='{"type": "boolean"}'>

+        

+          If set to true, multicast traffic (including reports)

+          are unconditionally forwarded to the specific port.

+        

+

+        

+          This option applies when the port is part of a logical router which

+          has <ref table="Logical_Router" column="options"/>:mcast_relay set

+          to true.

+        

+      </column>

     </group>

     <group title="Attachment">

diff --git a/tests/ovn.at b/tests/ovn.at

index d52c97541..410a56fe5 100644

--- a/tests/ovn.at

+++ b/tests/ovn.at

@@ -16258,7 +16258,6 @@ OVN_CHECK_PACKETS([hv2/vif3-tx.pcap], [expected_empty])

 # Flush IGMP groups.

 ovn-sbctl ip-multicast-flush sw1

-ovn-nbctl --wait=hv -t 3 sync

 OVS_WAIT_UNTIL([

     total_entries=`ovn-sbctl find IGMP_Group | grep "239.0.1.68" | wc -l`

     test "${total_entries}" = "0"

@@ -16310,12 +16309,12 @@ send_ip_multicast_pkt hv2-vif4 hv2 \

 # Sleep a bit to make sure no traffic is received and then check.

 sleep 1

 OVN_CHECK_PACKETS([hv1/vif1-tx.pcap], [expected_empty])

-OVN_CHECK_PACKETS([hv2/vif3-tx.pcap], [expected_empty])

-OVN_CHECK_PACKETS([hv1/vif4-tx.pcap], [expected_empty])

 OVN_CHECK_PACKETS([hv1/vif2-tx.pcap], [expected_empty])

 OVN_CHECK_PACKETS([hv1/vif3-tx.pcap], [expected_empty])

+OVN_CHECK_PACKETS([hv1/vif4-tx.pcap], [expected_empty])

 OVN_CHECK_PACKETS([hv2/vif1-tx.pcap], [expected_empty])

 OVN_CHECK_PACKETS([hv2/vif2-tx.pcap], [expected_empty])

+OVN_CHECK_PACKETS([hv2/vif3-tx.pcap], [expected_empty])

 OVN_CHECK_PACKETS([hv2/vif4-tx.pcap], [expected_empty])

 # Enable IGMP relay on rtr

@@ -16386,6 +16385,82 @@ OVN_CHECK_PACKETS([hv2/vif1-tx.pcap], [expected_empty])

 OVN_CHECK_PACKETS([hv2/vif2-tx.pcap], [expected_empty])

 OVN_CHECK_PACKETS([hv2/vif4-tx.pcap], [expected_empty])

+# Flush IGMP groups.

+ovn-sbctl ip-multicast-flush sw1

+ovn-sbctl ip-multicast-flush sw2

+ovn-sbctl ip-multicast-flush sw3

+OVS_WAIT_UNTIL([

+    total_entries=`ovn-sbctl find IGMP_Group | grep "239.0.1.68" | wc -l`

+    test "${total_entries}" = "0"

+])

+

+as hv1 reset_pcap_file hv1-vif1 hv1/vif1

+as hv1 reset_pcap_file hv1-vif2 hv1/vif2

+as hv1 reset_pcap_file hv1-vif3 hv1/vif3

+as hv1 reset_pcap_file hv1-vif4 hv1/vif4

+as hv2 reset_pcap_file hv2-vif1 hv2/vif1

+as hv2 reset_pcap_file hv2-vif2 hv2/vif2

+as hv2 reset_pcap_file hv2-vif3 hv2/vif3

+as hv2 reset_pcap_file hv2-vif4 hv2/vif4

+

+truncate -s 0 expected_empty

+truncate -s 0 expected_switched

+truncate -s 0 expected_routed

+truncate -s 0 expected_reports

+

+# Enable mcast_flood on sw1-p11

+ovn-nbctl set Logical_Switch_Port sw1-p11 options:mcast_flood='true'

+

+# Enable mcast_flood_reports on sw1-p21

+ovn-nbctl set Logical_Switch_Port sw1-p21 options:mcast_flood_reports='true'

+# Enable mcast_flood on rtr-sw2

+ovn-nbctl set Logical_Router_Port rtr-sw2 options:mcast_flood='true'

+# Enable mcast_flood on sw2-p1

+ovn-nbctl set Logical_Switch_Port sw2-p1 options:mcast_flood='true'

+

+ovn-nbctl --wait=hv sync

+

+# Inject IGMP Join for 239.0.1.68 on sw1-p12.

+send_igmp_v3_report hv1-vif2 hv1 \

+    000000000001 $(ip_to_hex 10 0 0 1) f9f8 \

+    $(ip_to_hex 239 0 1 68) 04 e9b9 \

+    expected_reports

+

+# Check that the IGMP Group is learned.

+OVS_WAIT_UNTIL([

+    total_entries=`ovn-sbctl find IGMP_Group | grep "239.0.1.68" | wc -l`

+    test "${total_entries}" = "1"

+])

+

+# Send traffic from sw1-p21

+send_ip_multicast_pkt hv2-vif1 hv2 \

+    000000000001 01005e000144 \

+    $(ip_to_hex 10 0 0 42) $(ip_to_hex 239 0 1 68) 1e 20 ca70 11 \

+    e518e518000a3b3a0000

+store_ip_multicast_pkt \

+    000000000001 01005e000144 \

+    $(ip_to_hex 10 0 0 42) $(ip_to_hex 239 0 1 68) 1e 20 ca70 11 \

+    e518e518000a3b3a0000 expected_switched

+store_ip_multicast_pkt \

+    000000000200 01005e000144 \

+    $(ip_to_hex 10 0 0 42) $(ip_to_hex 239 0 1 68) 1e 1f cb70 11 \

+    e518e518000a3b3a0000 expected_routed

+

+# Sleep a bit to make sure no duplicate traffic is received

+sleep 1

+

+# Check that traffic is switched to sw1-p11 and sw1-p12

+# Check that IGMP join is flooded on sw1-p21

+# Check that traffic is routed by rtr to rtr-sw2 and then switched to sw2-p1

+OVN_CHECK_PACKETS([hv1/vif1-tx.pcap], [expected_switched])

+OVN_CHECK_PACKETS([hv1/vif2-tx.pcap], [expected_switched])

+OVN_CHECK_PACKETS([hv1/vif3-tx.pcap], [expected_routed])

+OVN_CHECK_PACKETS([hv1/vif4-tx.pcap], [expected_empty])

+OVN_CHECK_PACKETS([hv2/vif1-tx.pcap], [expected_reports])

+OVN_CHECK_PACKETS([hv2/vif2-tx.pcap], [expected_empty])

+OVN_CHECK_PACKETS([hv2/vif3-tx.pcap], [expected_empty])

+OVN_CHECK_PACKETS([hv2/vif4-tx.pcap], [expected_empty])

+

 OVN_CLEANUP([hv1], [hv2])

 AT_CLEANUP

-- 

2.21.0