[ovs-dev] [PATCH 15/18] dpif-xlate: Add functions to update multicast snooping db

[Flavio Leitner]

This patch adds the functions needed to update the multicast
snooping database based on the Report/Leave/Query received.

They are marked with OVS_UNUSED for now.

Signed-off-by: Flavio Leitner <fbl at redhat.com>
---
 ofproto/ofproto-dpif-xlate.c | 80 ++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 80 insertions(+)

diff --git a/ofproto/ofproto-dpif-xlate.c b/ofproto/ofproto-dpif-xlate.c
index e38be4c..427958c 100644
--- a/ofproto/ofproto-dpif-xlate.c
+++ b/ofproto/ofproto-dpif-xlate.c
@@ -1401,6 +1401,86 @@ update_learning_table(const struct xbridge *xbridge,
     }
 }
 
+/* Updates multicast snooping table 'ms' given that a packet matching 'flow'
+ * was received on 'in_xbundle' in 'vlan' and is Report or Query. */
+OVS_UNUSED static void
+update_mcast_snooping_table__(const struct xbridge *xbridge,
+                              const struct flow *flow,
+                              const struct mcast_ip *grp, int vlan,
+                              struct xbundle *in_xbundle)
+OVS_REQ_WRLOCK(xbridge->ms->rwlock)
+{
+    static struct vlog_rate_limit rl = VLOG_RATE_LIMIT_INIT(60, 30);
+
+    switch (ntohs(flow->igmp_type)) {
+        case IGMP_HOST_MEMBERSHIP_REPORT:
+        case IGMPV2_HOST_MEMBERSHIP_REPORT:
+            if (mcast_snooping_add_group(xbridge->ms, grp, vlan,
+                in_xbundle->ofbundle)) {
+                VLOG_DBG_RL(&rl, "bridge %s: multicast snooping learned that "
+                            IP_FMT" is on port %s in VLAN %d",
+                            xbridge->name, IP_ARGS(grp->u.ip4),
+                            in_xbundle->name, vlan);
+            }
+            break;
+        case IGMP_HOST_LEAVE_MESSAGE:
+            if (mcast_snooping_leave_group(xbridge->ms, grp, vlan,
+                in_xbundle->ofbundle)) {
+                VLOG_DBG_RL(&rl, "bridge %s: multicast snooping leaving "
+                            IP_FMT" is on port %s in VLAN %d",
+                            xbridge->name, IP_ARGS(grp->u.ip4),
+                            in_xbundle->name, vlan);
+            }
+            break;
+        case IGMP_HOST_MEMBERSHIP_QUERY:
+            if (flow->nw_src && mcast_snooping_add_mrouter(xbridge->ms, vlan,
+                in_xbundle->ofbundle)) {
+                VLOG_DBG_RL(&rl, "bridge %s: multicast snooping query from "
+                            IP_FMT" is on port %s in VLAN %d",
+                            xbridge->name, IP_ARGS(flow->nw_src),
+                            in_xbundle->name, vlan);
+            }
+            break;
+    }
+}
+
+/* Updates multicast snooping table 'ms' given that a packet matching 'flow'
+ * was received on 'in_xbundle' in 'vlan'. */
+OVS_UNUSED static void
+update_mcast_snooping_table(const struct xbridge *xbridge,
+                            const struct flow *flow, int vlan,
+                            struct xbundle *in_xbundle)
+{
+    struct mcast_ip maddr;
+    struct xbundle *mcast_xbundle;
+    struct mcast_fport_bundle *fport;
+
+    /* Don't learn the OFPP_NONE port. */
+    if (in_xbundle == &ofpp_none_bundle) {
+        return;
+    }
+
+    /* Don't learn from flood ports */
+    mcast_xbundle = NULL;
+    ovs_rwlock_wrlock(&xbridge->ms->rwlock);
+    LIST_FOR_EACH(fport, list_node, &xbridge->ms->fport_list) {
+        mcast_xbundle = xbundle_lookup(fport->port.p);
+        if (mcast_xbundle == in_xbundle) {
+            break;
+        }
+    }
+
+    if (mcast_xbundle && mcast_xbundle == in_xbundle) {
+        ovs_rwlock_unlock(&xbridge->ms->rwlock);
+        return;
+    }
+
+    maddr.proto = flow->dl_type;
+    maddr.u.ip4 = flow->igmp_group.u.ip4;
+    update_mcast_snooping_table__(xbridge, flow, &maddr, vlan, in_xbundle);
+    ovs_rwlock_unlock(&xbridge->ms->rwlock);
+}
+
 /* send the packet to ports having the multicast group learned */
 OVS_UNUSED static void
 xlate_normal_mcast_send_group(struct xlate_ctx *ctx, struct mcast_entry *mcast,
-- 
1.9.0