Merge branch 'rdma-dynamic-link-create' into next

Steve Wise  says:

====================

This series adds rdmatool support for creating/deleting rdma links.
This will be used, mainly, by soft rdma drivers to allow adding/deleting
rdma links over netdev interfaces.  It provides the user side for
the following kernel changes merged in linux-5.1.

Changes since v2:

- move checks for required parameters in the parameter handlers
- move final 'link add' processing to link_add_netdev()
- added reviewed-by tags

Changes since v1:

- move error receive checking from rd_sendrecv_msg() to rd_recv_msg().
- Add rd->suppress_errors to allow control over whether errors when
  reading a response should be ignored.  Namely: resource queries can
  get errors like "none found" when querying for resources, and this
  error should not be displayed.  So on a rd object basis, error
  suppression can be controlled.
- Rebased on rdma/for-next UABI (no need to sync rdma_netlink.h now)
- use chains of struct rd_cmd and rd_exec_cmd vs open coding the parsing
  for the 'link add' command.
- minor nit resolution
- added .mailmap file.  If this is not desired for iproute2, then please
  drop the patch.

Changes since RFC:

- add rd_sendrecv_msg() and make use of it in dev_set as well
  as the new link commands.
- fixed problems with the man pages
- changed the command line to use "netdev" as the keyword
  for the network device, do avoid confused with the ib_device
  name.
- got rid of the "type" parameter for link delete.  Also pass
  down the device index instead of the name, using the common
  rd services for validating the device name and fetching the
  index.

====================

Signed-off-by: David Ahern <dsahern@gmail.com>
This commit is contained in:
David Ahern 2019-04-03 12:05:17 -07:00
commit 806a553c81
7 changed files with 157 additions and 1 deletions

8
.mailmap Normal file
View File

@ -0,0 +1,8 @@
#
# This list is used by git-shortlog to fix a few botched name translations
# in the git archive, either because the author's full name was messed up
# and/or not always written the same way, making contributions from the
# same person appearing not to be so or badly displayed.
#
Steve Wise <larrystevenwise@gmail.com> <swise@opengridcomputing.com>
Steve Wise <larrystevenwise@gmail.com> <swise@chelsio.com>

View File

@ -22,6 +22,18 @@ rdma-link \- rdma link configuration
.B rdma link show
.RI "[ " DEV/PORT_INDEX " ]"
.ti -8
.B rdma link add
.BR NAME
.BR type
.BR TYPE
.BR netdev
.BR NETDEV
.ti -8
.B rdma link delete
.RI NAME
.ti -8
.B rdma link help
@ -33,6 +45,31 @@ rdma-link \- rdma link configuration
- specifies the RDMA link to show.
If this argument is omitted all links are listed.
.SS rdma link add NAME type TYPE netdev NETDEV - add an rdma link for the specified type to the network device
.sp
.BR NAME
- specifies the new name of the rdma link to add
.BR TYPE
- specifies which rdma type to use. Link types:
.sp
.in +8
.B rxe
- Soft RoCE driver
.sp
.B siw
- Soft iWARP driver
.in -8
.BR NETDEV
- specifies the network device to which the link is bound
.SS rdma link delete NAME - delete an rdma link
.PP
.BR NAME
- specifies the name of the rdma link to delete
.PP
.SH "EXAMPLES"
.PP
rdma link show
@ -45,6 +82,16 @@ rdma link show mlx5_2/1
Shows the state of specified rdma link.
.RE
.PP
rdma link add rxe_eth0 type rxe netdev eth0
.RS 4
Adds a RXE link named rxe_eth0 to network device eth0
.RE
.PP
rdma link del rxe_eth0
.RS 4
Removes RXE link rxe_eth0
.RE
.PP
.SH SEE ALSO
.BR rdma (8),

View File

@ -268,7 +268,7 @@ static int dev_set_name(struct rd *rd)
mnl_attr_put_u32(rd->nlh, RDMA_NLDEV_ATTR_DEV_INDEX, rd->dev_idx);
mnl_attr_put_strz(rd->nlh, RDMA_NLDEV_ATTR_DEV_NAME, rd_argv(rd));
return rd_send_msg(rd);
return rd_sendrecv_msg(rd, seq);
}
static int dev_one_set(struct rd *rd)

View File

@ -9,6 +9,9 @@
static int link_help(struct rd *rd)
{
pr_out("Usage: %s link show [DEV/PORT_INDEX]\n", rd->filename);
pr_out("Usage: %s link add NAME type TYPE netdev NETDEV\n",
rd->filename);
pr_out("Usage: %s link delete NAME\n", rd->filename);
return 0;
}
@ -336,10 +339,85 @@ static int link_show(struct rd *rd)
return rd_exec_link(rd, link_one_show, true);
}
static int link_add_netdev(struct rd *rd)
{
char *link_netdev;
uint32_t seq;
if (rd_no_arg(rd)) {
pr_err("Please provide a net device name.\n");
return -EINVAL;
}
link_netdev = rd_argv(rd);
rd_prepare_msg(rd, RDMA_NLDEV_CMD_NEWLINK, &seq,
(NLM_F_REQUEST | NLM_F_ACK));
mnl_attr_put_strz(rd->nlh, RDMA_NLDEV_ATTR_DEV_NAME, rd->link_name);
mnl_attr_put_strz(rd->nlh, RDMA_NLDEV_ATTR_LINK_TYPE, rd->link_type);
mnl_attr_put_strz(rd->nlh, RDMA_NLDEV_ATTR_NDEV_NAME, link_netdev);
return rd_sendrecv_msg(rd, seq);
}
static int link_add_type(struct rd *rd)
{
const struct rd_cmd cmds[] = {
{ NULL, link_help},
{ "netdev", link_add_netdev},
{ 0 }
};
if (rd_no_arg(rd)) {
pr_err("Please provide a link type name.\n");
return -EINVAL;
}
rd->link_type = rd_argv(rd);
rd_arg_inc(rd);
return rd_exec_cmd(rd, cmds, "parameter");
}
static int link_add(struct rd *rd)
{
const struct rd_cmd cmds[] = {
{ NULL, link_help},
{ "type", link_add_type},
{ 0 }
};
if (rd_no_arg(rd)) {
pr_err("Please provide a link name to add.\n");
return -EINVAL;
}
rd->link_name = rd_argv(rd);
rd_arg_inc(rd);
return rd_exec_cmd(rd, cmds, "parameter");
}
static int _link_del(struct rd *rd)
{
uint32_t seq;
if (!rd_no_arg(rd)) {
pr_err("Unknown parameter %s\n", rd_argv(rd));
return -EINVAL;
}
rd_prepare_msg(rd, RDMA_NLDEV_CMD_DELLINK, &seq,
(NLM_F_REQUEST | NLM_F_ACK));
mnl_attr_put_u32(rd->nlh, RDMA_NLDEV_ATTR_DEV_INDEX, rd->dev_idx);
return rd_sendrecv_msg(rd, seq);
}
static int link_del(struct rd *rd)
{
return rd_exec_require_dev(rd, _link_del);
}
int cmd_link(struct rd *rd)
{
const struct rd_cmd cmds[] = {
{ NULL, link_show },
{ "add", link_add },
{ "delete", link_del },
{ "show", link_show },
{ "list", link_show },
{ "help", link_help },

View File

@ -68,7 +68,10 @@ struct rd {
json_writer_t *jw;
bool json_output;
bool pretty_output;
bool suppress_errors;
struct list_head filter_list;
char *link_name;
char *link_type;
};
struct rd_cmd {
@ -119,6 +122,7 @@ bool rd_is_string_filtered_attr(struct rd *rd, const char *key, const char *val,
*/
int rd_send_msg(struct rd *rd);
int rd_recv_msg(struct rd *rd, mnl_cb_t callback, void *data, uint32_t seq);
int rd_sendrecv_msg(struct rd *rd, unsigned int seq);
void rd_prepare_msg(struct rd *rd, uint32_t cmd, uint32_t *seq, uint16_t flags);
int rd_dev_init_cb(const struct nlmsghdr *nlh, void *data);
int rd_attr_cb(const struct nlattr *attr, void *data);

View File

@ -31,6 +31,7 @@ int res_qp_idx_parse_cb(const struct nlmsghdr *nlh, void *data);
if (id) { \
ret = rd_doit_index(rd, &idx); \
if (ret) { \
rd->suppress_errors = true; \
ret = _res_send_idx_msg(rd, command, \
name##_idx_parse_cb, \
idx, id); \

View File

@ -693,10 +693,28 @@ int rd_recv_msg(struct rd *rd, mnl_cb_t callback, void *data, unsigned int seq)
ret = mnl_cb_run(buf, ret, seq, portid, callback, data);
} while (ret > 0);
if (ret < 0 && !rd->suppress_errors)
perror("error");
mnl_socket_close(rd->nl);
return ret;
}
static int null_cb(const struct nlmsghdr *nlh, void *data)
{
return MNL_CB_OK;
}
int rd_sendrecv_msg(struct rd *rd, unsigned int seq)
{
int ret;
ret = rd_send_msg(rd);
if (!ret)
ret = rd_recv_msg(rd, null_cb, rd, seq);
return ret;
}
static struct dev_map *_dev_map_lookup(struct rd *rd, const char *dev_name)
{
struct dev_map *dev_map;