Commit 2475ed15 authored by Jiri Pirko's avatar Jiri Pirko Committed by Jakub Kicinski

devlink: move and rename devlink_dpipe_send_and_alloc_skb() helper

Since both dpipe and resource code is using this helper, in preparation
for code split to separate files, move
devlink_dpipe_send_and_alloc_skb() helper into netlink.c. Rename it on
the way.
Signed-off-by: default avatarJiri Pirko <jiri@nvidia.com>
Link: https://lore.kernel.org/r/20230828061657.300667-5-jiri@resnulli.usSigned-off-by: default avatarJakub Kicinski <kuba@kernel.org>
parent 2b4d8bb0
...@@ -150,6 +150,8 @@ devlink_nl_put_handle(struct sk_buff *msg, struct devlink *devlink) ...@@ -150,6 +150,8 @@ devlink_nl_put_handle(struct sk_buff *msg, struct devlink *devlink)
return 0; return 0;
} }
int devlink_nl_msg_reply_and_new(struct sk_buff **msg, struct genl_info *info);
/* Notify */ /* Notify */
void devlink_notify(struct devlink *devlink, enum devlink_command cmd); void devlink_notify(struct devlink *devlink, enum devlink_command cmd);
void devlink_ports_notify_register(struct devlink *devlink); void devlink_ports_notify_register(struct devlink *devlink);
......
...@@ -1277,22 +1277,6 @@ static int devlink_dpipe_table_put(struct sk_buff *skb, ...@@ -1277,22 +1277,6 @@ static int devlink_dpipe_table_put(struct sk_buff *skb,
return -EMSGSIZE; return -EMSGSIZE;
} }
static int devlink_dpipe_send_and_alloc_skb(struct sk_buff **pskb,
struct genl_info *info)
{
int err;
if (*pskb) {
err = genlmsg_reply(*pskb, info);
if (err)
return err;
}
*pskb = genlmsg_new(GENLMSG_DEFAULT_SIZE, GFP_KERNEL);
if (!*pskb)
return -ENOMEM;
return 0;
}
static int devlink_dpipe_tables_fill(struct genl_info *info, static int devlink_dpipe_tables_fill(struct genl_info *info,
enum devlink_command cmd, int flags, enum devlink_command cmd, int flags,
struct list_head *dpipe_tables, struct list_head *dpipe_tables,
...@@ -1311,7 +1295,7 @@ static int devlink_dpipe_tables_fill(struct genl_info *info, ...@@ -1311,7 +1295,7 @@ static int devlink_dpipe_tables_fill(struct genl_info *info,
table = list_first_entry(dpipe_tables, table = list_first_entry(dpipe_tables,
struct devlink_dpipe_table, list); struct devlink_dpipe_table, list);
start_again: start_again:
err = devlink_dpipe_send_and_alloc_skb(&skb, info); err = devlink_nl_msg_reply_and_new(&skb, info);
if (err) if (err)
return err; return err;
...@@ -1358,7 +1342,7 @@ static int devlink_dpipe_tables_fill(struct genl_info *info, ...@@ -1358,7 +1342,7 @@ static int devlink_dpipe_tables_fill(struct genl_info *info,
nlh = nlmsg_put(skb, info->snd_portid, info->snd_seq, nlh = nlmsg_put(skb, info->snd_portid, info->snd_seq,
NLMSG_DONE, 0, flags | NLM_F_MULTI); NLMSG_DONE, 0, flags | NLM_F_MULTI);
if (!nlh) { if (!nlh) {
err = devlink_dpipe_send_and_alloc_skb(&skb, info); err = devlink_nl_msg_reply_and_new(&skb, info);
if (err) if (err)
return err; return err;
goto send_done; goto send_done;
...@@ -1551,8 +1535,8 @@ int devlink_dpipe_entry_ctx_prepare(struct devlink_dpipe_dump_ctx *dump_ctx) ...@@ -1551,8 +1535,8 @@ int devlink_dpipe_entry_ctx_prepare(struct devlink_dpipe_dump_ctx *dump_ctx)
struct devlink *devlink; struct devlink *devlink;
int err; int err;
err = devlink_dpipe_send_and_alloc_skb(&dump_ctx->skb, err = devlink_nl_msg_reply_and_new(&dump_ctx->skb,
dump_ctx->info); dump_ctx->info);
if (err) if (err)
return err; return err;
...@@ -1638,7 +1622,7 @@ static int devlink_dpipe_entries_fill(struct genl_info *info, ...@@ -1638,7 +1622,7 @@ static int devlink_dpipe_entries_fill(struct genl_info *info,
nlh = nlmsg_put(dump_ctx.skb, info->snd_portid, info->snd_seq, nlh = nlmsg_put(dump_ctx.skb, info->snd_portid, info->snd_seq,
NLMSG_DONE, 0, flags | NLM_F_MULTI); NLMSG_DONE, 0, flags | NLM_F_MULTI);
if (!nlh) { if (!nlh) {
err = devlink_dpipe_send_and_alloc_skb(&dump_ctx.skb, info); err = devlink_nl_msg_reply_and_new(&dump_ctx.skb, info);
if (err) if (err)
return err; return err;
goto send_done; goto send_done;
...@@ -1746,7 +1730,7 @@ static int devlink_dpipe_headers_fill(struct genl_info *info, ...@@ -1746,7 +1730,7 @@ static int devlink_dpipe_headers_fill(struct genl_info *info,
i = 0; i = 0;
start_again: start_again:
err = devlink_dpipe_send_and_alloc_skb(&skb, info); err = devlink_nl_msg_reply_and_new(&skb, info);
if (err) if (err)
return err; return err;
...@@ -1782,7 +1766,7 @@ static int devlink_dpipe_headers_fill(struct genl_info *info, ...@@ -1782,7 +1766,7 @@ static int devlink_dpipe_headers_fill(struct genl_info *info,
nlh = nlmsg_put(skb, info->snd_portid, info->snd_seq, nlh = nlmsg_put(skb, info->snd_portid, info->snd_seq,
NLMSG_DONE, 0, flags | NLM_F_MULTI); NLMSG_DONE, 0, flags | NLM_F_MULTI);
if (!nlh) { if (!nlh) {
err = devlink_dpipe_send_and_alloc_skb(&skb, info); err = devlink_nl_msg_reply_and_new(&skb, info);
if (err) if (err)
return err; return err;
goto send_done; goto send_done;
...@@ -2047,7 +2031,7 @@ static int devlink_resource_fill(struct genl_info *info, ...@@ -2047,7 +2031,7 @@ static int devlink_resource_fill(struct genl_info *info,
resource = list_first_entry(&devlink->resource_list, resource = list_first_entry(&devlink->resource_list,
struct devlink_resource, list); struct devlink_resource, list);
start_again: start_again:
err = devlink_dpipe_send_and_alloc_skb(&skb, info); err = devlink_nl_msg_reply_and_new(&skb, info);
if (err) if (err)
return err; return err;
...@@ -2086,7 +2070,7 @@ static int devlink_resource_fill(struct genl_info *info, ...@@ -2086,7 +2070,7 @@ static int devlink_resource_fill(struct genl_info *info,
nlh = nlmsg_put(skb, info->snd_portid, info->snd_seq, nlh = nlmsg_put(skb, info->snd_portid, info->snd_seq,
NLMSG_DONE, 0, flags | NLM_F_MULTI); NLMSG_DONE, 0, flags | NLM_F_MULTI);
if (!nlh) { if (!nlh) {
err = devlink_dpipe_send_and_alloc_skb(&skb, info); err = devlink_nl_msg_reply_and_new(&skb, info);
if (err) if (err)
return err; return err;
goto send_done; goto send_done;
......
...@@ -82,6 +82,21 @@ static const struct nla_policy devlink_nl_policy[DEVLINK_ATTR_MAX + 1] = { ...@@ -82,6 +82,21 @@ static const struct nla_policy devlink_nl_policy[DEVLINK_ATTR_MAX + 1] = {
[DEVLINK_ATTR_REGION_DIRECT] = { .type = NLA_FLAG }, [DEVLINK_ATTR_REGION_DIRECT] = { .type = NLA_FLAG },
}; };
int devlink_nl_msg_reply_and_new(struct sk_buff **msg, struct genl_info *info)
{
int err;
if (*msg) {
err = genlmsg_reply(*msg, info);
if (err)
return err;
}
*msg = genlmsg_new(GENLMSG_DEFAULT_SIZE, GFP_KERNEL);
if (!*msg)
return -ENOMEM;
return 0;
}
struct devlink * struct devlink *
devlink_get_from_attrs_lock(struct net *net, struct nlattr **attrs) devlink_get_from_attrs_lock(struct net *net, struct nlattr **attrs)
{ {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment