[<prev] [next>] [<thread-prev] [thread-next>] [day] [month] [year] [list]
Message-ID: <20241017070445.4013745-3-gnaaman@drivenets.com>
Date: Thu, 17 Oct 2024 07:04:37 +0000
From: Gilad Naaman <gnaaman@...venets.com>
To: netdev <netdev@...r.kernel.org>,
"David S. Miller" <davem@...emloft.net>,
Eric Dumazet <edumazet@...gle.com>,
Jakub Kicinski <kuba@...nel.org>,
Paolo Abeni <pabeni@...hat.com>
Cc: Gilad Naaman <gnaaman@...venets.com>,
Kuniyuki Iwashima <kuniyu@...zon.com>,
Ido Schimmel <idosch@...dia.com>,
Petr Machata <petrm@...dia.com>
Subject: [PATCH net-next v5 2/6] Define neigh_for_each
Define neigh_for_each in neighbour.h and move old definition
to its only point of usage within the mlxsw driver.
Signed-off-by: Gilad Naaman <gnaaman@...venets.com>
---
.../ethernet/mellanox/mlxsw/spectrum_router.c | 24 +++++++++++++++++--
include/net/neighbour.h | 4 ++--
net/core/neighbour.c | 22 -----------------
3 files changed, 24 insertions(+), 26 deletions(-)
diff --git a/drivers/net/ethernet/mellanox/mlxsw/spectrum_router.c b/drivers/net/ethernet/mellanox/mlxsw/spectrum_router.c
index 800dfb64ec83..de62587c5a63 100644
--- a/drivers/net/ethernet/mellanox/mlxsw/spectrum_router.c
+++ b/drivers/net/ethernet/mellanox/mlxsw/spectrum_router.c
@@ -3006,6 +3006,26 @@ static void mlxsw_sp_neigh_rif_made_sync_each(struct neighbour *n, void *data)
rms->err = -ENOMEM;
}
+static void mlxsw_sp_neigh_for_each(struct neigh_table *tbl,
+ void *cookie)
+{
+ struct neigh_hash_table *nht;
+ int chain;
+
+ rcu_read_lock();
+ nht = rcu_dereference(tbl->nht);
+
+ read_lock_bh(&tbl->lock); /* avoid resizes */
+ for (chain = 0; chain < (1 << nht->hash_shift); chain++) {
+ struct neighbour *n;
+
+ neigh_for_each(n, &nht->hash_heads[chain])
+ mlxsw_sp_neigh_rif_made_sync_each(n, cookie);
+ }
+ read_unlock_bh(&tbl->lock);
+ rcu_read_unlock();
+}
+
static int mlxsw_sp_neigh_rif_made_sync(struct mlxsw_sp *mlxsw_sp,
struct mlxsw_sp_rif *rif)
{
@@ -3014,12 +3034,12 @@ static int mlxsw_sp_neigh_rif_made_sync(struct mlxsw_sp *mlxsw_sp,
.rif = rif,
};
- neigh_for_each(&arp_tbl, mlxsw_sp_neigh_rif_made_sync_each, &rms);
+ mlxsw_sp_neigh_for_each(&arp_tbl, &rms);
if (rms.err)
goto err_arp;
#if IS_ENABLED(CONFIG_IPV6)
- neigh_for_each(&nd_tbl, mlxsw_sp_neigh_rif_made_sync_each, &rms);
+ mlxsw_sp_neigh_for_each(&nd_tbl, &rms);
#endif
if (rms.err)
goto err_nd;
diff --git a/include/net/neighbour.h b/include/net/neighbour.h
index 0402447854c7..37303656ab65 100644
--- a/include/net/neighbour.h
+++ b/include/net/neighbour.h
@@ -277,6 +277,8 @@ static inline void *neighbour_priv(const struct neighbour *n)
extern const struct nla_policy nda_policy[];
+#define neigh_for_each(pos, head) hlist_for_each_entry(pos, head, hash)
+
static inline bool neigh_key_eq32(const struct neighbour *n, const void *pkey)
{
return *(const u32 *)n->primary_key == *(const u32 *)pkey;
@@ -390,8 +392,6 @@ static inline struct net *pneigh_net(const struct pneigh_entry *pneigh)
}
void neigh_app_ns(struct neighbour *n);
-void neigh_for_each(struct neigh_table *tbl,
- void (*cb)(struct neighbour *, void *), void *cookie);
void __neigh_for_each_release(struct neigh_table *tbl,
int (*cb)(struct neighbour *));
int neigh_xmit(int fam, struct net_device *, const void *, struct sk_buff *);
diff --git a/net/core/neighbour.c b/net/core/neighbour.c
index 45c8df801dfb..d9c458e6f627 100644
--- a/net/core/neighbour.c
+++ b/net/core/neighbour.c
@@ -3120,28 +3120,6 @@ static int neigh_get(struct sk_buff *in_skb, struct nlmsghdr *nlh,
return err;
}
-void neigh_for_each(struct neigh_table *tbl, void (*cb)(struct neighbour *, void *), void *cookie)
-{
- int chain;
- struct neigh_hash_table *nht;
-
- rcu_read_lock();
- nht = rcu_dereference(tbl->nht);
-
- read_lock_bh(&tbl->lock); /* avoid resizes */
- for (chain = 0; chain < (1 << nht->hash_shift); chain++) {
- struct neighbour *n;
-
- for (n = rcu_dereference(nht->hash_buckets[chain]);
- n != NULL;
- n = rcu_dereference(n->next))
- cb(n, cookie);
- }
- read_unlock_bh(&tbl->lock);
- rcu_read_unlock();
-}
-EXPORT_SYMBOL(neigh_for_each);
-
/* The tbl->lock must be held as a writer and BH disabled. */
void __neigh_for_each_release(struct neigh_table *tbl,
int (*cb)(struct neighbour *))
--
2.46.0
Powered by blists - more mailing lists