Skip to content

Commit 88d0973

Browse files
Geliang Tangkuba-moo
authored andcommitted
mptcp: drop free_list for deleting entries
mptcp_pm_remove_addrs() actually only deletes one address, which does not match its name. This patch renames it to mptcp_pm_remove_addr_entry() and changes the parameter "rm_list" to "entry". With the help of mptcp_pm_remove_addr_entry(), it's no longer necessary to move the entry to be deleted to free_list and then traverse the list to delete the entry, which is not allowed in BPF. The entry can be directly deleted through list_del_rcu() and sock_kfree_s() now. Signed-off-by: Geliang Tang <[email protected]> Reviewed-by: Matthieu Baerts (NGI0) <[email protected]> Signed-off-by: Matthieu Baerts (NGI0) <[email protected]> Link: https://patch.msgid.link/20241213-net-next-mptcp-pm-misc-cleanup-v1-5-ddb6d00109a8@kernel.org Signed-off-by: Jakub Kicinski <[email protected]>
1 parent 8008e77 commit 88d0973

File tree

2 files changed

+17
-28
lines changed

2 files changed

+17
-28
lines changed

net/mptcp/pm_userspace.c

Lines changed: 15 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -287,41 +287,31 @@ static int mptcp_userspace_pm_remove_id_zero_address(struct mptcp_sock *msk,
287287
return err;
288288
}
289289

290-
void mptcp_pm_remove_addrs(struct mptcp_sock *msk, struct list_head *rm_list)
290+
void mptcp_pm_remove_addr_entry(struct mptcp_sock *msk,
291+
struct mptcp_pm_addr_entry *entry)
291292
{
292293
struct mptcp_rm_list alist = { .nr = 0 };
293-
struct mptcp_pm_addr_entry *entry;
294294
int anno_nr = 0;
295295

296-
list_for_each_entry(entry, rm_list, list) {
297-
if (alist.nr >= MPTCP_RM_IDS_MAX)
298-
break;
299-
300-
/* only delete if either announced or matching a subflow */
301-
if (mptcp_remove_anno_list_by_saddr(msk, &entry->addr))
302-
anno_nr++;
303-
else if (!mptcp_lookup_subflow_by_saddr(&msk->conn_list,
304-
&entry->addr))
305-
continue;
296+
/* only delete if either announced or matching a subflow */
297+
if (mptcp_remove_anno_list_by_saddr(msk, &entry->addr))
298+
anno_nr++;
299+
else if (!mptcp_lookup_subflow_by_saddr(&msk->conn_list, &entry->addr))
300+
return;
306301

307-
alist.ids[alist.nr++] = entry->addr.id;
308-
}
302+
alist.ids[alist.nr++] = entry->addr.id;
309303

310-
if (alist.nr) {
311-
spin_lock_bh(&msk->pm.lock);
312-
msk->pm.add_addr_signaled -= anno_nr;
313-
mptcp_pm_remove_addr(msk, &alist);
314-
spin_unlock_bh(&msk->pm.lock);
315-
}
304+
spin_lock_bh(&msk->pm.lock);
305+
msk->pm.add_addr_signaled -= anno_nr;
306+
mptcp_pm_remove_addr(msk, &alist);
307+
spin_unlock_bh(&msk->pm.lock);
316308
}
317309

318310
int mptcp_pm_nl_remove_doit(struct sk_buff *skb, struct genl_info *info)
319311
{
320312
struct nlattr *id = info->attrs[MPTCP_PM_ATTR_LOC_ID];
321313
struct mptcp_pm_addr_entry *match;
322-
struct mptcp_pm_addr_entry *entry;
323314
struct mptcp_sock *msk;
324-
LIST_HEAD(free_list);
325315
int err = -EINVAL;
326316
struct sock *sk;
327317
u8 id_val;
@@ -355,16 +345,14 @@ int mptcp_pm_nl_remove_doit(struct sk_buff *skb, struct genl_info *info)
355345
goto out;
356346
}
357347

358-
list_move(&match->list, &free_list);
348+
list_del_rcu(&match->list);
359349
spin_unlock_bh(&msk->pm.lock);
360350

361-
mptcp_pm_remove_addrs(msk, &free_list);
351+
mptcp_pm_remove_addr_entry(msk, match);
362352

363353
release_sock(sk);
364354

365-
list_for_each_entry_safe(match, entry, &free_list, list) {
366-
sock_kfree_s(sk, match, sizeof(*match));
367-
}
355+
sock_kfree_s(sk, match, sizeof(*match));
368356

369357
err = 0;
370358
out:

net/mptcp/protocol.h

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1038,7 +1038,8 @@ int mptcp_pm_announce_addr(struct mptcp_sock *msk,
10381038
const struct mptcp_addr_info *addr,
10391039
bool echo);
10401040
int mptcp_pm_remove_addr(struct mptcp_sock *msk, const struct mptcp_rm_list *rm_list);
1041-
void mptcp_pm_remove_addrs(struct mptcp_sock *msk, struct list_head *rm_list);
1041+
void mptcp_pm_remove_addr_entry(struct mptcp_sock *msk,
1042+
struct mptcp_pm_addr_entry *entry);
10421043

10431044
void mptcp_free_local_addr_list(struct mptcp_sock *msk);
10441045

0 commit comments

Comments
 (0)