]> git.proxmox.com Git - mirror_iproute2.git/blob - rdma/res.h
rdma: Rewrite custom JSON and prints logic to use common API
[mirror_iproute2.git] / rdma / res.h
1 /* SPDX-License-Identifier: GPL-2.0 OR Linux-OpenIB */
2 /*
3 * res.h RDMA tool
4 * Authors: Leon Romanovsky <leonro@mellanox.com>
5 */
6 #ifndef _RDMA_TOOL_RES_H_
7 #define _RDMA_TOOL_RES_H_
8
9 #include "rdma.h"
10
11 int _res_send_msg(struct rd *rd, uint32_t command, mnl_cb_t callback);
12 int _res_send_idx_msg(struct rd *rd, uint32_t command, mnl_cb_t callback,
13 uint32_t idx, uint32_t id);
14
15 int res_pd_parse_cb(const struct nlmsghdr *nlh, void *data);
16 int res_pd_idx_parse_cb(const struct nlmsghdr *nlh, void *data);
17 int res_mr_parse_cb(const struct nlmsghdr *nlh, void *data);
18 int res_mr_idx_parse_cb(const struct nlmsghdr *nlh, void *data);
19 int res_cq_parse_cb(const struct nlmsghdr *nlh, void *data);
20 int res_cq_idx_parse_cb(const struct nlmsghdr *nlh, void *data);
21 int res_cm_id_parse_cb(const struct nlmsghdr *nlh, void *data);
22 int res_cm_id_idx_parse_cb(const struct nlmsghdr *nlh, void *data);
23 int res_qp_parse_cb(const struct nlmsghdr *nlh, void *data);
24 int res_qp_idx_parse_cb(const struct nlmsghdr *nlh, void *data);
25
26 #define RES_FUNC(name, command, valid_filters, strict_port, id) \
27 static inline int _##name(struct rd *rd) \
28 { \
29 uint32_t idx; \
30 int ret; \
31 if (id) { \
32 ret = rd_doit_index(rd, &idx); \
33 if (ret) { \
34 rd->suppress_errors = true; \
35 ret = _res_send_idx_msg(rd, command, \
36 name##_idx_parse_cb, \
37 idx, id); \
38 if (!ret) \
39 return ret; \
40 /* Fallback for old systems without .doit callbacks */ \
41 } \
42 } \
43 return _res_send_msg(rd, command, name##_parse_cb); \
44 } \
45 static inline int name(struct rd *rd) \
46 { \
47 int ret = rd_build_filter(rd, valid_filters); \
48 if (ret) \
49 return ret; \
50 if ((uintptr_t)valid_filters != (uintptr_t)NULL) { \
51 ret = rd_set_arg_to_devname(rd); \
52 if (ret) \
53 return ret; \
54 } \
55 if (strict_port) \
56 return rd_exec_dev(rd, _##name); \
57 else \
58 return rd_exec_link(rd, _##name, strict_port); \
59 }
60
61 static const
62 struct filters pd_valid_filters[MAX_NUMBER_OF_FILTERS] = {
63 { .name = "dev", .is_number = false },
64 { .name = "users", .is_number = true },
65 { .name = "pid", .is_number = true },
66 { .name = "ctxn", .is_number = true },
67 { .name = "pdn", .is_number = true, .is_doit = true },
68 { .name = "ctxn", .is_number = true }
69 };
70
71 RES_FUNC(res_pd, RDMA_NLDEV_CMD_RES_PD_GET, pd_valid_filters, true,
72 RDMA_NLDEV_ATTR_RES_PDN);
73
74 static const
75 struct filters mr_valid_filters[MAX_NUMBER_OF_FILTERS] = {
76 { .name = "dev", .is_number = false },
77 { .name = "rkey", .is_number = true },
78 { .name = "lkey", .is_number = true },
79 { .name = "mrlen", .is_number = true },
80 { .name = "pid", .is_number = true },
81 { .name = "mrn", .is_number = true, .is_doit = true },
82 { .name = "pdn", .is_number = true }
83 };
84
85 RES_FUNC(res_mr, RDMA_NLDEV_CMD_RES_MR_GET, mr_valid_filters, true,
86 RDMA_NLDEV_ATTR_RES_MRN);
87
88 static const
89 struct filters cq_valid_filters[MAX_NUMBER_OF_FILTERS] = {
90 { .name = "dev", .is_number = false },
91 { .name = "users", .is_number = true },
92 { .name = "poll-ctx", .is_number = false },
93 { .name = "pid", .is_number = true },
94 { .name = "cqn", .is_number = true, .is_doit = true },
95 { .name = "ctxn", .is_number = true }
96 };
97
98 RES_FUNC(res_cq, RDMA_NLDEV_CMD_RES_CQ_GET, cq_valid_filters, true,
99 RDMA_NLDEV_ATTR_RES_CQN);
100
101 static const
102 struct filters cm_id_valid_filters[MAX_NUMBER_OF_FILTERS] = {
103 { .name = "link", .is_number = false },
104 { .name = "lqpn", .is_number = true },
105 { .name = "qp-type", .is_number = false },
106 { .name = "state", .is_number = false },
107 { .name = "ps", .is_number = false },
108 { .name = "dev-type", .is_number = false },
109 { .name = "transport-type", .is_number = false },
110 { .name = "pid", .is_number = true },
111 { .name = "src-addr", .is_number = false },
112 { .name = "src-port", .is_number = true },
113 { .name = "dst-addr", .is_number = false },
114 { .name = "dst-port", .is_number = true },
115 { .name = "cm-idn", .is_number = true, .is_doit = true }
116 };
117
118 RES_FUNC(res_cm_id, RDMA_NLDEV_CMD_RES_CM_ID_GET, cm_id_valid_filters, false,
119 RDMA_NLDEV_ATTR_RES_CM_IDN);
120
121 static const struct
122 filters qp_valid_filters[MAX_NUMBER_OF_FILTERS] = {
123 { .name = "link", .is_number = false },
124 { .name = "lqpn", .is_number = true, .is_doit = true },
125 { .name = "rqpn", .is_number = true },
126 { .name = "pid", .is_number = true },
127 { .name = "sq-psn", .is_number = true },
128 { .name = "rq-psn", .is_number = true },
129 { .name = "type", .is_number = false },
130 { .name = "path-mig-state", .is_number = false },
131 { .name = "state", .is_number = false },
132 { .name = "pdn", .is_number = true },
133 };
134
135 RES_FUNC(res_qp, RDMA_NLDEV_CMD_RES_QP_GET, qp_valid_filters, false,
136 RDMA_NLDEV_ATTR_RES_LQPN);
137
138 char *get_task_name(uint32_t pid);
139 void print_dev(struct rd *rd, uint32_t idx, const char *name);
140 void print_link(struct rd *rd, uint32_t idx, const char *name, uint32_t port,
141 struct nlattr **nla_line);
142 void print_key(struct rd *rd, const char *name, uint64_t val,
143 struct nlattr *nlattr);
144 void res_print_uint(struct rd *rd, const char *name, uint64_t val,
145 struct nlattr *nlattr);
146 void print_comm(struct rd *rd, const char *str, struct nlattr **nla_line);
147 const char *qp_types_to_str(uint8_t idx);
148
149 #endif /* _RDMA_TOOL_RES_H_ */