iv/linux
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

net: bridge: multicast: pass host src address to IGMPv3/MLDv2 functions

Browse Source 
We need to pass the host address so later it can be used for explicit
host tracking. No functional change.

Signed-off-by: Nikolay Aleksandrov <nikolay@nvidia.com>
Signed-off-by: Jakub Kicinski <kuba@kernel.org>
This commit is contained in:
Nikolay Aleksandrov
2021-01-20 16:51:51 +02:00
committed by Jakub Kicinski
parent 9e10b9e656
commit 54bea72196
1 changed files with 49 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

90
net/bridge/br_multicast.c
View File

@@ -1799,7 +1799,7 @@ static void __grp_send_query_and_rexmit(struct net_bridge_port_group *pg)
* INCLUDE (A) ALLOW (B) INCLUDE (A+B) (B)=GMI * INCLUDE (A) ALLOW (B) INCLUDE (A+B) (B)=GMI
* EXCLUDE (X,Y) ALLOW (A) EXCLUDE (X+A,Y-A) (A)=GMI * EXCLUDE (X,Y) ALLOW (A) EXCLUDE (X+A,Y-A) (A)=GMI
*/ */
static bool br_multicast_isinc_allow(struct net_bridge_port_group *pg, static bool br_multicast_isinc_allow(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
struct net_bridge *br = pg->key.port->br; struct net_bridge *br = pg->key.port->br;
@@ -1833,7 +1833,7 @@ static bool br_multicast_isinc_allow(struct net_bridge_port_group *pg,
* Delete (A-B) * Delete (A-B)
* Group Timer=GMI * Group Timer=GMI
*/ */
static void __grp_src_isexc_incl(struct net_bridge_port_group *pg, static void __grp_src_isexc_incl(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
struct net_bridge_group_src *ent; struct net_bridge_group_src *ent;
@@ -1866,7 +1866,7 @@ static void __grp_src_isexc_incl(struct net_bridge_port_group *pg,
* Delete (Y-A) * Delete (Y-A)
* Group Timer=GMI * Group Timer=GMI
*/ */
static bool __grp_src_isexc_excl(struct net_bridge_port_group *pg, static bool __grp_src_isexc_excl(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
struct net_bridge *br = pg->key.port->br; struct net_bridge *br = pg->key.port->br;
@@ -1903,7 +1903,7 @@ static bool __grp_src_isexc_excl(struct net_bridge_port_group *pg,
return changed; return changed;
} }
static bool br_multicast_isexc(struct net_bridge_port_group *pg, static bool br_multicast_isexc(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
struct net_bridge *br = pg->key.port->br; struct net_bridge *br = pg->key.port->br;
@@ -1911,12 +1911,12 @@ static bool br_multicast_isexc(struct net_bridge_port_group *pg,
switch (pg->filter_mode) { switch (pg->filter_mode) {
case MCAST_INCLUDE: case MCAST_INCLUDE:
__grp_src_isexc_incl(pg, srcs, nsrcs, addr_size); __grp_src_isexc_incl(pg, h_addr, srcs, nsrcs, addr_size);
br_multicast_star_g_handle_mode(pg, MCAST_EXCLUDE); br_multicast_star_g_handle_mode(pg, MCAST_EXCLUDE);
changed = true; changed = true;
break; break;
case MCAST_EXCLUDE: case MCAST_EXCLUDE:
changed = __grp_src_isexc_excl(pg, srcs, nsrcs, addr_size); changed = __grp_src_isexc_excl(pg, h_addr, srcs, nsrcs, addr_size);
break; break;
} }
@@ -1930,7 +1930,7 @@ static bool br_multicast_isexc(struct net_bridge_port_group *pg,
* INCLUDE (A) TO_IN (B) INCLUDE (A+B) (B)=GMI * INCLUDE (A) TO_IN (B) INCLUDE (A+B) (B)=GMI
* Send Q(G,A-B) * Send Q(G,A-B)
*/ */
static bool __grp_src_toin_incl(struct net_bridge_port_group *pg, static bool __grp_src_toin_incl(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
struct net_bridge *br = pg->key.port->br; struct net_bridge *br = pg->key.port->br;
@@ -1972,7 +1972,7 @@ static bool __grp_src_toin_incl(struct net_bridge_port_group *pg,
* Send Q(G,X-A) * Send Q(G,X-A)
* Send Q(G) * Send Q(G)
*/ */
static bool __grp_src_toin_excl(struct net_bridge_port_group *pg, static bool __grp_src_toin_excl(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
struct net_bridge *br = pg->key.port->br; struct net_bridge *br = pg->key.port->br;
@@ -2014,17 +2014,17 @@ static bool __grp_src_toin_excl(struct net_bridge_port_group *pg,
return changed; return changed;
} }
static bool br_multicast_toin(struct net_bridge_port_group *pg, static bool br_multicast_toin(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
bool changed = false; bool changed = false;
switch (pg->filter_mode) { switch (pg->filter_mode) {
case MCAST_INCLUDE: case MCAST_INCLUDE:
changed = __grp_src_toin_incl(pg, srcs, nsrcs, addr_size); changed = __grp_src_toin_incl(pg, h_addr, srcs, nsrcs, addr_size);
break; break;
case MCAST_EXCLUDE: case MCAST_EXCLUDE:
changed = __grp_src_toin_excl(pg, srcs, nsrcs, addr_size); changed = __grp_src_toin_excl(pg, h_addr, srcs, nsrcs, addr_size);
break; break;
} }
@@ -2037,7 +2037,7 @@ static bool br_multicast_toin(struct net_bridge_port_group *pg,
* Send Q(G,A*B) * Send Q(G,A*B)
* Group Timer=GMI * Group Timer=GMI
*/ */
static void __grp_src_toex_incl(struct net_bridge_port_group *pg, static void __grp_src_toex_incl(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
struct net_bridge_group_src *ent; struct net_bridge_group_src *ent;
@@ -2076,7 +2076,7 @@ static void __grp_src_toex_incl(struct net_bridge_port_group *pg,
* Send Q(G,A-Y) * Send Q(G,A-Y)
* Group Timer=GMI * Group Timer=GMI
*/ */
static bool __grp_src_toex_excl(struct net_bridge_port_group *pg, static bool __grp_src_toex_excl(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
struct net_bridge_group_src *ent; struct net_bridge_group_src *ent;
@@ -2116,7 +2116,7 @@ static bool __grp_src_toex_excl(struct net_bridge_port_group *pg,
return changed; return changed;
} }
static bool br_multicast_toex(struct net_bridge_port_group *pg, static bool br_multicast_toex(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
struct net_bridge *br = pg->key.port->br; struct net_bridge *br = pg->key.port->br;
@@ -2124,12 +2124,12 @@ static bool br_multicast_toex(struct net_bridge_port_group *pg,
switch (pg->filter_mode) { switch (pg->filter_mode) {
case MCAST_INCLUDE: case MCAST_INCLUDE:
__grp_src_toex_incl(pg, srcs, nsrcs, addr_size); __grp_src_toex_incl(pg, h_addr, srcs, nsrcs, addr_size);
br_multicast_star_g_handle_mode(pg, MCAST_EXCLUDE); br_multicast_star_g_handle_mode(pg, MCAST_EXCLUDE);
changed = true; changed = true;
break; break;
case MCAST_EXCLUDE: case MCAST_EXCLUDE:
changed = __grp_src_toex_excl(pg, srcs, nsrcs, addr_size); changed = __grp_src_toex_excl(pg, h_addr, srcs, nsrcs, addr_size);
break; break;
} }
@@ -2142,7 +2142,7 @@ static bool br_multicast_toex(struct net_bridge_port_group *pg,
/* State Msg type New state Actions /* State Msg type New state Actions
* INCLUDE (A) BLOCK (B) INCLUDE (A) Send Q(G,A*B) * INCLUDE (A) BLOCK (B) INCLUDE (A) Send Q(G,A*B)
*/ */
static void __grp_src_block_incl(struct net_bridge_port_group *pg, static void __grp_src_block_incl(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
struct net_bridge_group_src *ent; struct net_bridge_group_src *ent;
@@ -2175,7 +2175,7 @@ static void __grp_src_block_incl(struct net_bridge_port_group *pg,
* EXCLUDE (X,Y) BLOCK (A) EXCLUDE (X+(A-Y),Y) (A-X-Y)=Group Timer * EXCLUDE (X,Y) BLOCK (A) EXCLUDE (X+(A-Y),Y) (A-X-Y)=Group Timer
* Send Q(G,A-Y) * Send Q(G,A-Y)
*/ */
static bool __grp_src_block_excl(struct net_bridge_port_group *pg, static bool __grp_src_block_excl(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
struct net_bridge_group_src *ent; struct net_bridge_group_src *ent;
@@ -2211,17 +2211,17 @@ static bool __grp_src_block_excl(struct net_bridge_port_group *pg,
return changed; return changed;
} }
static bool br_multicast_block(struct net_bridge_port_group *pg, static bool br_multicast_block(struct net_bridge_port_group *pg, void *h_addr,
void *srcs, u32 nsrcs, size_t addr_size) void *srcs, u32 nsrcs, size_t addr_size)
{ {
bool changed = false; bool changed = false;
switch (pg->filter_mode) { switch (pg->filter_mode) {
case MCAST_INCLUDE: case MCAST_INCLUDE:
__grp_src_block_incl(pg, srcs, nsrcs, addr_size); __grp_src_block_incl(pg, h_addr, srcs, nsrcs, addr_size);
break; break;
case MCAST_EXCLUDE: case MCAST_EXCLUDE:
changed = __grp_src_block_excl(pg, srcs, nsrcs, addr_size); changed = __grp_src_block_excl(pg, h_addr, srcs, nsrcs, addr_size);
break; break;
} }
@@ -2257,8 +2257,8 @@ static int br_ip4_multicast_igmp3_report(struct net_bridge *br,
struct igmpv3_report *ih; struct igmpv3_report *ih;
struct igmpv3_grec *grec; struct igmpv3_grec *grec;
int i, len, num, type; int i, len, num, type;
__be32 group, *h_addr;
bool changed = false; bool changed = false;
__be32 group;
int err = 0; int err = 0;
u16 nsrcs; u16 nsrcs;
@@ -2318,32 +2318,33 @@ static int br_ip4_multicast_igmp3_report(struct net_bridge *br,
pg = br_multicast_find_port(mdst, port, src); pg = br_multicast_find_port(mdst, port, src);
if (!pg || (pg->flags & MDB_PG_FLAGS_PERMANENT)) if (!pg || (pg->flags & MDB_PG_FLAGS_PERMANENT))
goto unlock_continue; goto unlock_continue;
/* reload grec */ /* reload grec and host addr */
grec = (void *)(skb->data + len - sizeof(*grec) - (nsrcs * 4)); grec = (void *)(skb->data + len - sizeof(*grec) - (nsrcs * 4));
h_addr = &ip_hdr(skb)->saddr;
switch (type) { switch (type) {
case IGMPV3_ALLOW_NEW_SOURCES: case IGMPV3_ALLOW_NEW_SOURCES:
changed = br_multicast_isinc_allow(pg, grec->grec_src, changed = br_multicast_isinc_allow(pg, h_addr, grec->grec_src,
nsrcs, sizeof(__be32)); nsrcs, sizeof(__be32));
break; break;
case IGMPV3_MODE_IS_INCLUDE: case IGMPV3_MODE_IS_INCLUDE:
changed = br_multicast_isinc_allow(pg, grec->grec_src, nsrcs, changed = br_multicast_isinc_allow(pg, h_addr, grec->grec_src,
sizeof(__be32)); nsrcs, sizeof(__be32));
break; break;
case IGMPV3_MODE_IS_EXCLUDE: case IGMPV3_MODE_IS_EXCLUDE:
changed = br_multicast_isexc(pg, grec->grec_src, nsrcs, changed = br_multicast_isexc(pg, h_addr, grec->grec_src,
sizeof(__be32)); nsrcs, sizeof(__be32));
break; break;
case IGMPV3_CHANGE_TO_INCLUDE: case IGMPV3_CHANGE_TO_INCLUDE:
changed = br_multicast_toin(pg, grec->grec_src, nsrcs, changed = br_multicast_toin(pg, h_addr, grec->grec_src,
sizeof(__be32)); nsrcs, sizeof(__be32));
break; break;
case IGMPV3_CHANGE_TO_EXCLUDE: case IGMPV3_CHANGE_TO_EXCLUDE:
changed = br_multicast_toex(pg, grec->grec_src, nsrcs, changed = br_multicast_toex(pg, h_addr, grec->grec_src,
sizeof(__be32)); nsrcs, sizeof(__be32));
break; break;
case IGMPV3_BLOCK_OLD_SOURCES: case IGMPV3_BLOCK_OLD_SOURCES:
changed = br_multicast_block(pg, grec->grec_src, nsrcs, changed = br_multicast_block(pg, h_addr, grec->grec_src,
sizeof(__be32)); nsrcs, sizeof(__be32));
break; break;
} }
if (changed) if (changed)
@@ -2367,6 +2368,7 @@ static int br_ip6_multicast_mld2_report(struct net_bridge *br,
unsigned int nsrcs_offset; unsigned int nsrcs_offset;
const unsigned char *src; const unsigned char *src;
struct icmp6hdr *icmp6h; struct icmp6hdr *icmp6h;
struct in6_addr *h_addr;
struct mld2_grec *grec; struct mld2_grec *grec;
unsigned int grec_len; unsigned int grec_len;
bool changed = false; bool changed = false;
@@ -2445,30 +2447,36 @@ static int br_ip6_multicast_mld2_report(struct net_bridge *br,
pg = br_multicast_find_port(mdst, port, src); pg = br_multicast_find_port(mdst, port, src);
if (!pg || (pg->flags & MDB_PG_FLAGS_PERMANENT)) if (!pg || (pg->flags & MDB_PG_FLAGS_PERMANENT))
goto unlock_continue; goto unlock_continue;
h_addr = &ipv6_hdr(skb)->saddr;
switch (grec->grec_type) { switch (grec->grec_type) {
case MLD2_ALLOW_NEW_SOURCES: case MLD2_ALLOW_NEW_SOURCES:
changed = br_multicast_isinc_allow(pg, grec->grec_src, changed = br_multicast_isinc_allow(pg, h_addr,
nsrcs, grec->grec_src, nsrcs,
sizeof(struct in6_addr)); sizeof(struct in6_addr));
break; break;
case MLD2_MODE_IS_INCLUDE: case MLD2_MODE_IS_INCLUDE:
changed = br_multicast_isinc_allow(pg, grec->grec_src, nsrcs, changed = br_multicast_isinc_allow(pg, h_addr,
grec->grec_src, nsrcs,
sizeof(struct in6_addr)); sizeof(struct in6_addr));
break; break;
case MLD2_MODE_IS_EXCLUDE: case MLD2_MODE_IS_EXCLUDE:
changed = br_multicast_isexc(pg, grec->grec_src, nsrcs, changed = br_multicast_isexc(pg, h_addr,
grec->grec_src, nsrcs,
sizeof(struct in6_addr)); sizeof(struct in6_addr));
break; break;
case MLD2_CHANGE_TO_INCLUDE: case MLD2_CHANGE_TO_INCLUDE:
changed = br_multicast_toin(pg, grec->grec_src, nsrcs, changed = br_multicast_toin(pg, h_addr,
grec->grec_src, nsrcs,
sizeof(struct in6_addr)); sizeof(struct in6_addr));
break; break;
case MLD2_CHANGE_TO_EXCLUDE: case MLD2_CHANGE_TO_EXCLUDE:
changed = br_multicast_toex(pg, grec->grec_src, nsrcs, changed = br_multicast_toex(pg, h_addr,
grec->grec_src, nsrcs,
sizeof(struct in6_addr)); sizeof(struct in6_addr));
break; break;
case MLD2_BLOCK_OLD_SOURCES: case MLD2_BLOCK_OLD_SOURCES:
changed = br_multicast_block(pg, grec->grec_src, nsrcs, changed = br_multicast_block(pg, h_addr,
grec->grec_src, nsrcs,
sizeof(struct in6_addr)); sizeof(struct in6_addr));
break; break;
} }