ipmr: do not acquire mrt_lock while calling ip_mr_forward()
authorEric Dumazet <edumazet@google.com>
Thu, 23 Jun 2022 04:34:38 +0000 (04:34 +0000)
committerDavid S. Miller <davem@davemloft.net>
Fri, 24 Jun 2022 10:34:37 +0000 (11:34 +0100)
ip_mr_forward() uses standard RCU protection already.

Signed-off-by: Eric Dumazet <edumazet@google.com>
Signed-off-by: David S. Miller <davem@davemloft.net>
net/ipv4/ipmr.c

index 6ea54bc..b0f2e6d 100644 (file)
@@ -1817,7 +1817,7 @@ static bool ipmr_forward_offloaded(struct sk_buff *skb, struct mr_table *mrt,
 }
 #endif
 
-/* Processing handlers for ipmr_forward */
+/* Processing handlers for ipmr_forward, under rcu_read_lock() */
 
 static void ipmr_queue_xmit(struct net *net, struct mr_table *mrt,
                            int in_vifi, struct sk_buff *skb, int vifi)
@@ -1839,9 +1839,7 @@ static void ipmr_queue_xmit(struct net *net, struct mr_table *mrt,
                WRITE_ONCE(vif->bytes_out, vif->bytes_out + skb->len);
                vif_dev->stats.tx_bytes += skb->len;
                vif_dev->stats.tx_packets++;
-               rcu_read_lock();
                ipmr_cache_report(mrt, skb, vifi, IGMPMSG_WHOLEPKT);
-               rcu_read_unlock();
                goto out_free;
        }
 
@@ -1936,6 +1934,7 @@ static int ipmr_find_vif(const struct mr_table *mrt, struct net_device *dev)
 }
 
 /* "local" means that we should preserve one skb (for local delivery) */
+/* Called uner rcu_read_lock() */
 static void ip_mr_forward(struct net *net, struct mr_table *mrt,
                          struct net_device *dev, struct sk_buff *skb,
                          struct mfc_cache *c, int local)
@@ -1992,12 +1991,10 @@ static void ip_mr_forward(struct net *net, struct mr_table *mrt,
                               c->_c.mfc_un.res.last_assert +
                               MFC_ASSERT_THRESH)) {
                        c->_c.mfc_un.res.last_assert = jiffies;
-                       rcu_read_lock();
                        ipmr_cache_report(mrt, skb, true_vifi, IGMPMSG_WRONGVIF);
                        if (mrt->mroute_do_wrvifwhole)
                                ipmr_cache_report(mrt, skb, true_vifi,
                                                  IGMPMSG_WRVIFWHOLE);
-                       rcu_read_unlock();
                }
                goto dont_forward;
        }
@@ -2169,9 +2166,7 @@ int ip_mr_input(struct sk_buff *skb)
                return -ENODEV;
        }
 
-       read_lock(&mrt_lock);
        ip_mr_forward(net, mrt, dev, skb, cache, local);
-       read_unlock(&mrt_lock);
 
        if (local)
                return ip_local_deliver(skb);