rdma: Add dev object

Device (dev) object represents struct ib_device to the user space.

Device properties:
 * Device capabilities
 * FW version to the device output
 * node_guid and sys_image_guid
 * node_type

Signed-off-by: Leon Romanovsky <leonro@mellanox.com>
This commit is contained in:
Leon Romanovsky 2017-08-20 12:58:23 +03:00 committed by Stephen Hemminger
parent 74bd75c2b6
commit 40df8263a0
5 changed files with 303 additions and 3 deletions

View File

@ -2,7 +2,7 @@ include ../Config
ifeq ($(HAVE_MNL),y)
RDMA_OBJ = rdma.o utils.o
RDMA_OBJ = rdma.o utils.o dev.o
TARGETS=rdma
CFLAGS += $(shell $(PKG_CONFIG) libmnl --cflags)

230
rdma/dev.c Normal file
View File

@ -0,0 +1,230 @@
/*
* dev.c RDMA tool
*
* This program is free software; you can redistribute it and/or
* modify it under the terms of the GNU General Public License
* as published by the Free Software Foundation; either version
* 2 of the License, or (at your option) any later version.
*
* Authors: Leon Romanovsky <leonro@mellanox.com>
*/
#include "rdma.h"
static int dev_help(struct rd *rd)
{
pr_out("Usage: %s dev show [DEV]\n", rd->filename);
return 0;
}
static const char *dev_caps_to_str(uint32_t idx)
{
#define RDMA_DEV_FLAGS(x) \
x(RESIZE_MAX_WR, 0) \
x(BAD_PKEY_CNTR, 1) \
x(BAD_QKEY_CNTR, 2) \
x(RAW_MULTI, 3) \
x(AUTO_PATH_MIG, 4) \
x(CHANGE_PHY_PORT, 5) \
x(UD_AV_PORT_ENFORCE_PORT_ENFORCE, 6) \
x(CURR_QP_STATE_MOD, 7) \
x(SHUTDOWN_PORT, 8) \
x(INIT_TYPE, 9) \
x(PORT_ACTIVE_EVENT, 10) \
x(SYS_IMAGE_GUID, 11) \
x(RC_RNR_NAK_GEN, 12) \
x(SRQ_RESIZE, 13) \
x(N_NOTIFY_CQ, 14) \
x(LOCAL_DMA_LKEY, 15) \
x(MEM_WINDOW, 17) \
x(UD_IP_CSUM, 18) \
x(UD_TSO, 19) \
x(XRC, 20) \
x(MEM_MGT_EXTENSIONS, 21) \
x(BLOCK_MULTICAST_LOOPBACK, 22) \
x(MEM_WINDOW_TYPE_2A, 23) \
x(MEM_WINDOW_TYPE_2B, 24) \
x(RC_IP_CSUM, 25) \
x(RAW_IP_CSUM, 26) \
x(CROSS_CHANNEL, 27) \
x(MANAGED_FLOW_STEERING, 29) \
x(SIGNATURE_HANDOVER, 30) \
x(ON_DEMAND_PAGING, 31) \
x(SG_GAPS_REG, 32) \
x(VIRTUAL_FUNCTION, 33) \
x(RAW_SCATTER_FCS, 34) \
x(RDMA_NETDEV_OPA_VNIC, 35)
enum { RDMA_DEV_FLAGS(RDMA_BITMAP_ENUM) };
static const char * const
rdma_dev_names[] = { RDMA_DEV_FLAGS(RDMA_BITMAP_NAMES) };
#undef RDMA_DEV_FLAGS
if (idx < ARRAY_SIZE(rdma_dev_names) && rdma_dev_names[idx])
return rdma_dev_names[idx];
return "UNKNOWN";
}
static void dev_print_caps(struct nlattr **tb)
{
uint64_t caps;
uint32_t idx;
if (!tb[RDMA_NLDEV_ATTR_CAP_FLAGS])
return;
caps = mnl_attr_get_u64(tb[RDMA_NLDEV_ATTR_CAP_FLAGS]);
pr_out("\n caps: <");
for (idx = 0; caps; idx++) {
if (caps & 0x1) {
pr_out("%s", dev_caps_to_str(idx));
if (caps >> 0x1)
pr_out(", ");
}
caps >>= 0x1;
}
pr_out(">");
}
static void dev_print_fw(struct nlattr **tb)
{
if (!tb[RDMA_NLDEV_ATTR_FW_VERSION])
return;
pr_out("fw %s ",
mnl_attr_get_str(tb[RDMA_NLDEV_ATTR_FW_VERSION]));
}
static void dev_print_node_guid(struct nlattr **tb)
{
uint64_t node_guid;
if (!tb[RDMA_NLDEV_ATTR_NODE_GUID])
return;
node_guid = mnl_attr_get_u64(tb[RDMA_NLDEV_ATTR_NODE_GUID]);
rd_print_u64("node_guid", node_guid);
}
static void dev_print_sys_image_guid(struct nlattr **tb)
{
uint64_t sys_image_guid;
if (!tb[RDMA_NLDEV_ATTR_SYS_IMAGE_GUID])
return;
sys_image_guid = mnl_attr_get_u64(tb[RDMA_NLDEV_ATTR_SYS_IMAGE_GUID]);
rd_print_u64("sys_image_guid", sys_image_guid);
}
static const char *node_type_to_str(uint8_t node_type)
{
static const char * const node_type_str[] = { "unknown", "ca",
"switch", "router",
"rnic", "usnic",
"usnic_dp" };
if (node_type < ARRAY_SIZE(node_type_str))
return node_type_str[node_type];
return "unknown";
}
static void dev_print_node_type(struct nlattr **tb)
{
uint8_t node_type;
if (!tb[RDMA_NLDEV_ATTR_DEV_NODE_TYPE])
return;
node_type = mnl_attr_get_u8(tb[RDMA_NLDEV_ATTR_DEV_NODE_TYPE]);
pr_out("node_type %s ", node_type_to_str(node_type));
}
static int dev_parse_cb(const struct nlmsghdr *nlh, void *data)
{
struct nlattr *tb[RDMA_NLDEV_ATTR_MAX] = {};
struct rd *rd = data;
mnl_attr_parse(nlh, 0, rd_attr_cb, tb);
if (!tb[RDMA_NLDEV_ATTR_DEV_INDEX] || !tb[RDMA_NLDEV_ATTR_DEV_NAME])
return MNL_CB_ERROR;
pr_out("%u: %s: ",
mnl_attr_get_u32(tb[RDMA_NLDEV_ATTR_DEV_INDEX]),
mnl_attr_get_str(tb[RDMA_NLDEV_ATTR_DEV_NAME]));
dev_print_node_type(tb);
dev_print_fw(tb);
dev_print_node_guid(tb);
dev_print_sys_image_guid(tb);
if (rd->show_details)
dev_print_caps(tb);
pr_out("\n");
return MNL_CB_OK;
}
static int dev_no_args(struct rd *rd)
{
uint32_t seq;
int ret;
rd_prepare_msg(rd, RDMA_NLDEV_CMD_GET,
&seq, (NLM_F_REQUEST | NLM_F_ACK));
mnl_attr_put_u32(rd->nlh, RDMA_NLDEV_ATTR_DEV_INDEX, rd->dev_idx);
ret = rd_send_msg(rd);
if (ret)
return ret;
return rd_recv_msg(rd, dev_parse_cb, rd, seq);
}
static int dev_one_show(struct rd *rd)
{
const struct rd_cmd cmds[] = {
{ NULL, dev_no_args},
{ 0 }
};
return rd_exec_cmd(rd, cmds, "parameter");
}
static int dev_show(struct rd *rd)
{
struct dev_map *dev_map;
int ret = 0;
if (rd_no_arg(rd)) {
list_for_each_entry(dev_map, &rd->dev_map_list, list) {
rd->dev_idx = dev_map->idx;
ret = dev_one_show(rd);
if (ret)
return ret;
}
} else {
dev_map = dev_map_lookup(rd, false);
if (!dev_map) {
pr_err("Wrong device name\n");
return -ENOENT;
}
rd_arg_inc(rd);
rd->dev_idx = dev_map->idx;
ret = dev_one_show(rd);
}
return ret;
}
int cmd_dev(struct rd *rd)
{
const struct rd_cmd cmds[] = {
{ NULL, dev_show },
{ "show", dev_show },
{ "list", dev_show },
{ "help", dev_help },
{ 0 }
};
return rd_exec_cmd(rd, cmds, "dev command");
}

View File

@ -15,7 +15,7 @@
static void help(char *name)
{
pr_out("Usage: %s [ OPTIONS ] OBJECT { COMMAND | help }\n"
"where OBJECT := { help }\n"
"where OBJECT := { dev | help }\n"
" OPTIONS := { -V[ersion] | -d[etails]}\n", name);
}
@ -30,6 +30,7 @@ static int rd_cmd(struct rd *rd)
const struct rd_cmd cmds[] = {
{ NULL, cmd_help },
{ "help", cmd_help },
{ "dev", cmd_dev },
{ 0 }
};

View File

@ -20,10 +20,14 @@
#include <time.h>
#include "list.h"
#include "utils.h"
#define pr_err(args...) fprintf(stderr, ##args)
#define pr_out(args...) fprintf(stdout, ##args)
#define RDMA_BITMAP_ENUM(name, bit_no) RDMA_BITMAP_##name = BIT(bit_no),
#define RDMA_BITMAP_NAMES(name, bit_no) [bit_no] = #name,
struct dev_map {
struct list_head list;
char *dev_name;
@ -37,6 +41,8 @@ struct rd {
char *filename;
bool show_details;
struct list_head dev_map_list;
uint32_t dev_idx;
uint32_t port_idx;
struct mnl_socket *nl;
struct nlmsghdr *nlh;
char *buff;
@ -53,12 +59,23 @@ struct rd_cmd {
bool rd_no_arg(struct rd *rd);
void rd_arg_inc(struct rd *rd);
char *rd_argv(struct rd *rd);
uint32_t get_port_from_argv(struct rd *rd);
void rd_print_u64(char *name, uint64_t val);
/*
* Commands interface
*/
int cmd_dev(struct rd *rd);
int cmd_link(struct rd *rd);
int rd_exec_cmd(struct rd *rd, const struct rd_cmd *c, const char *str);
/*
* Device manipulation
*/
void rd_free_devmap(struct rd *rd);
struct dev_map *dev_map_lookup(struct rd *rd, bool allow_port_index);
struct dev_map *_dev_map_lookup(struct rd *rd, const char *dev_name);
/*
* Netlink

View File

@ -16,7 +16,7 @@ static int rd_argc(struct rd *rd)
return rd->argc;
}
static char *rd_argv(struct rd *rd)
char *rd_argv(struct rd *rd)
{
if (!rd_argc(rd))
return NULL;
@ -50,6 +50,23 @@ bool rd_no_arg(struct rd *rd)
return rd_argc(rd) == 0;
}
uint32_t get_port_from_argv(struct rd *rd)
{
char *slash;
slash = strchr(rd_argv(rd), '/');
/* if no port found, return 0 */
return slash ? atoi(slash + 1) : 0;
}
void rd_print_u64(char *name, uint64_t val)
{
uint16_t vp[4];
memcpy(vp, &val, sizeof(uint64_t));
pr_out("%s %04x:%04x:%04x:%04x ", name, vp[3], vp[2], vp[1], vp[0]);
}
static struct dev_map *dev_map_alloc(const char *dev_name)
{
struct dev_map *dev_map;
@ -83,8 +100,14 @@ static void dev_map_cleanup(struct rd *rd)
}
static const enum mnl_attr_data_type nldev_policy[RDMA_NLDEV_ATTR_MAX] = {
[RDMA_NLDEV_ATTR_DEV_INDEX] = MNL_TYPE_U32,
[RDMA_NLDEV_ATTR_DEV_NAME] = MNL_TYPE_NUL_STRING,
[RDMA_NLDEV_ATTR_PORT_INDEX] = MNL_TYPE_U32,
[RDMA_NLDEV_ATTR_CAP_FLAGS] = MNL_TYPE_U64,
[RDMA_NLDEV_ATTR_FW_VERSION] = MNL_TYPE_NUL_STRING,
[RDMA_NLDEV_ATTR_NODE_GUID] = MNL_TYPE_U64,
[RDMA_NLDEV_ATTR_SYS_IMAGE_GUID] = MNL_TYPE_U64,
[RDMA_NLDEV_ATTR_DEV_NODE_TYPE] = MNL_TYPE_U8,
};
int rd_attr_cb(const struct nlattr *attr, void *data)
@ -215,3 +238,32 @@ int rd_recv_msg(struct rd *rd, mnl_cb_t callback, void *data, unsigned int seq)
mnl_socket_close(rd->nl);
return ret;
}
struct dev_map *_dev_map_lookup(struct rd *rd, const char *dev_name)
{
struct dev_map *dev_map;
list_for_each_entry(dev_map, &rd->dev_map_list, list)
if (strcmp(dev_name, dev_map->dev_name) == 0)
return dev_map;
return NULL;
}
struct dev_map *dev_map_lookup(struct rd *rd, bool allow_port_index)
{
struct dev_map *dev_map;
char *dev_name;
char *slash;
dev_name = strdup(rd_argv(rd));
if (allow_port_index) {
slash = strrchr(dev_name, '/');
if (slash)
*slash = '\0';
}
dev_map = _dev_map_lookup(rd, dev_name);
free(dev_name);
return dev_map;
}