Skip to content

Commit

Permalink
mptcp: change is_backup interfaces as get_flags
Browse files Browse the repository at this point in the history
is_backup() interface of the path managers is not very common. A more
common approach is to add a get_flags() interface to obtain the flags
value of a given address. Then is_backup() can be implemented through
get_flags() by test whether backup flag is set in the flags value.

Signed-off-by: Geliang Tang <[email protected]>
  • Loading branch information
Geliang Tang authored and intel-lab-lkp committed Jan 15, 2025
1 parent 1bdad5d commit b8e1f90
Show file tree
Hide file tree
Showing 4 changed files with 19 additions and 13 deletions.
7 changes: 5 additions & 2 deletions net/mptcp/pm.c
Original file line number Diff line number Diff line change
Expand Up @@ -425,13 +425,16 @@ int mptcp_pm_get_local_id(struct mptcp_sock *msk, struct sock_common *skc)
bool mptcp_pm_is_backup(struct mptcp_sock *msk, struct sock_common *skc)
{
struct mptcp_addr_info skc_local;
u8 flags;

mptcp_local_address((struct sock_common *)skc, &skc_local);

if (mptcp_pm_is_userspace(msk))
return mptcp_userspace_pm_is_backup(msk, &skc_local);
flags = mptcp_userspace_pm_get_flags(msk, &skc_local);
else
flags = mptcp_pm_nl_get_flags(msk, &skc_local);

return mptcp_pm_nl_is_backup(msk, &skc_local);
return !!(flags & MPTCP_PM_ADDR_FLAG_BACKUP);
}

static int mptcp_pm_get_addr(u8 id, struct mptcp_pm_addr_entry *addr,
Expand Down
9 changes: 5 additions & 4 deletions net/mptcp/pm_netlink.c
Original file line number Diff line number Diff line change
Expand Up @@ -1172,18 +1172,19 @@ int mptcp_pm_nl_get_local_id(struct mptcp_sock *msk, struct mptcp_addr_info *skc
return ret;
}

bool mptcp_pm_nl_is_backup(struct mptcp_sock *msk, struct mptcp_addr_info *skc)
u8 mptcp_pm_nl_get_flags(struct mptcp_sock *msk,
struct mptcp_addr_info *skc)
{
struct pm_nl_pernet *pernet = pm_nl_get_pernet_from_msk(msk);
struct mptcp_pm_addr_entry *entry;
bool backup;
u8 flags;

rcu_read_lock();
entry = __lookup_addr(pernet, skc);
backup = entry && !!(entry->flags & MPTCP_PM_ADDR_FLAG_BACKUP);
flags = entry ? entry->flags : 0;
rcu_read_unlock();

return backup;
return flags;
}

#define MPTCP_PM_CMD_GRP_OFFSET 0
Expand Down
10 changes: 5 additions & 5 deletions net/mptcp/pm_userspace.c
Original file line number Diff line number Diff line change
Expand Up @@ -154,18 +154,18 @@ int mptcp_userspace_pm_get_local_id(struct mptcp_sock *msk,
return mptcp_userspace_pm_append_new_local_addr(msk, &new_entry, true);
}

bool mptcp_userspace_pm_is_backup(struct mptcp_sock *msk,
struct mptcp_addr_info *skc)
u8 mptcp_userspace_pm_get_flags(struct mptcp_sock *msk,
struct mptcp_addr_info *skc)
{
struct mptcp_pm_addr_entry *entry;
bool backup;
u8 flags;

spin_lock_bh(&msk->pm.lock);
entry = mptcp_userspace_pm_lookup_addr(msk, skc);
backup = entry && !!(entry->flags & MPTCP_PM_ADDR_FLAG_BACKUP);
flags = entry ? entry->flags : 0;
spin_unlock_bh(&msk->pm.lock);

return backup;
return flags;
}

static struct mptcp_sock *mptcp_userspace_pm_get_sock(const struct genl_info *info)
Expand Down
6 changes: 4 additions & 2 deletions net/mptcp/protocol.h
Original file line number Diff line number Diff line change
Expand Up @@ -1132,8 +1132,10 @@ int mptcp_pm_get_local_id(struct mptcp_sock *msk, struct sock_common *skc);
int mptcp_pm_nl_get_local_id(struct mptcp_sock *msk, struct mptcp_addr_info *skc);
int mptcp_userspace_pm_get_local_id(struct mptcp_sock *msk, struct mptcp_addr_info *skc);
bool mptcp_pm_is_backup(struct mptcp_sock *msk, struct sock_common *skc);
bool mptcp_pm_nl_is_backup(struct mptcp_sock *msk, struct mptcp_addr_info *skc);
bool mptcp_userspace_pm_is_backup(struct mptcp_sock *msk, struct mptcp_addr_info *skc);
u8 mptcp_pm_nl_get_flags(struct mptcp_sock *msk,
struct mptcp_addr_info *skc);
u8 mptcp_userspace_pm_get_flags(struct mptcp_sock *msk,
struct mptcp_addr_info *skc);
int mptcp_pm_nl_dump_addr(struct sk_buff *msg,
struct netlink_callback *cb);
int mptcp_userspace_pm_dump_addr(struct sk_buff *msg,
Expand Down

0 comments on commit b8e1f90

Please sign in to comment.