1 // SPDX-License-Identifier: GPL-2.0 OR Linux-OpenIB
4 * Authors: Leon Romanovsky <leonro@mellanox.com>
10 static void print_qp_type(struct rd
*rd
, uint32_t val
)
13 jsonw_string_field(rd
->jw
, "qp-type", qp_types_to_str(val
));
15 pr_out("qp-type %s ", qp_types_to_str(val
));
18 static const char *cm_id_state_to_str(uint8_t idx
)
20 static const char *const cm_id_states_str
[] = {
21 "IDLE", "ADDR_QUERY", "ADDR_RESOLVED",
22 "ROUTE_QUERY", "ROUTE_RESOLVED", "CONNECT",
23 "DISCONNECT", "ADDR_BOUND", "LISTEN",
24 "DEVICE_REMOVAL", "DESTROYING"
27 if (idx
< ARRAY_SIZE(cm_id_states_str
))
28 return cm_id_states_str
[idx
];
32 static const char *cm_id_ps_to_str(uint32_t ps
)
48 static void print_cm_id_state(struct rd
*rd
, uint8_t state
)
50 if (rd
->json_output
) {
51 jsonw_string_field(rd
->jw
, "state", cm_id_state_to_str(state
));
54 pr_out("state %s ", cm_id_state_to_str(state
));
57 static void print_ps(struct rd
*rd
, uint32_t ps
)
59 if (rd
->json_output
) {
60 jsonw_string_field(rd
->jw
, "ps", cm_id_ps_to_str(ps
));
63 pr_out("ps %s ", cm_id_ps_to_str(ps
));
66 static void print_ipaddr(struct rd
*rd
, const char *key
, char *addrstr
,
69 if (rd
->json_output
) {
70 int name_size
= INET6_ADDRSTRLEN
+ strlen(":65535");
71 char json_name
[name_size
];
73 snprintf(json_name
, name_size
, "%s:%u", addrstr
, port
);
74 jsonw_string_field(rd
->jw
, key
, json_name
);
77 pr_out("%s %s:%u ", key
, addrstr
, port
);
80 static int ss_ntop(struct nlattr
*nla_line
, char *addr_str
, uint16_t *port
)
82 struct __kernel_sockaddr_storage
*addr
;
84 addr
= (struct __kernel_sockaddr_storage
*)mnl_attr_get_payload(
86 switch (addr
->ss_family
) {
88 struct sockaddr_in
*sin
= (struct sockaddr_in
*)addr
;
90 if (!inet_ntop(AF_INET
, (const void *)&sin
->sin_addr
, addr_str
,
93 *port
= ntohs(sin
->sin_port
);
97 struct sockaddr_in6
*sin6
= (struct sockaddr_in6
*)addr
;
99 if (!inet_ntop(AF_INET6
, (const void *)&sin6
->sin6_addr
,
100 addr_str
, INET6_ADDRSTRLEN
))
102 *port
= ntohs(sin6
->sin6_port
);
111 int res_cm_id_parse_cb(const struct nlmsghdr
*nlh
, void *data
)
113 struct nlattr
*tb
[RDMA_NLDEV_ATTR_MAX
] = {};
114 struct nlattr
*nla_table
, *nla_entry
;
115 struct rd
*rd
= data
;
119 mnl_attr_parse(nlh
, 0, rd_attr_cb
, tb
);
120 if (!tb
[RDMA_NLDEV_ATTR_DEV_INDEX
] || !tb
[RDMA_NLDEV_ATTR_DEV_NAME
] ||
121 !tb
[RDMA_NLDEV_ATTR_RES_CM_ID
])
124 name
= mnl_attr_get_str(tb
[RDMA_NLDEV_ATTR_DEV_NAME
]);
125 idx
= mnl_attr_get_u32(tb
[RDMA_NLDEV_ATTR_DEV_INDEX
]);
126 nla_table
= tb
[RDMA_NLDEV_ATTR_RES_CM_ID
];
127 mnl_attr_for_each_nested(nla_entry
, nla_table
) {
128 struct nlattr
*nla_line
[RDMA_NLDEV_ATTR_MAX
] = {};
129 char src_addr_str
[INET6_ADDRSTRLEN
];
130 char dst_addr_str
[INET6_ADDRSTRLEN
];
131 uint16_t src_port
, dst_port
;
132 uint32_t port
= 0, pid
= 0;
133 uint8_t type
= 0, state
;
134 uint32_t lqpn
= 0, ps
;
139 err
= mnl_attr_parse_nested(nla_entry
, rd_attr_cb
, nla_line
);
140 if (err
!= MNL_CB_OK
)
143 if (!nla_line
[RDMA_NLDEV_ATTR_RES_STATE
] ||
144 !nla_line
[RDMA_NLDEV_ATTR_RES_PS
] ||
145 (!nla_line
[RDMA_NLDEV_ATTR_RES_PID
] &&
146 !nla_line
[RDMA_NLDEV_ATTR_RES_KERN_NAME
])) {
150 if (nla_line
[RDMA_NLDEV_ATTR_PORT_INDEX
])
151 port
= mnl_attr_get_u32(
152 nla_line
[RDMA_NLDEV_ATTR_PORT_INDEX
]);
154 if (port
&& port
!= rd
->port_idx
)
157 if (nla_line
[RDMA_NLDEV_ATTR_RES_LQPN
]) {
158 lqpn
= mnl_attr_get_u32(
159 nla_line
[RDMA_NLDEV_ATTR_RES_LQPN
]);
160 if (rd_check_is_filtered(rd
, "lqpn", lqpn
))
163 if (nla_line
[RDMA_NLDEV_ATTR_RES_TYPE
]) {
164 type
= mnl_attr_get_u8(
165 nla_line
[RDMA_NLDEV_ATTR_RES_TYPE
]);
166 if (rd_check_is_string_filtered(rd
, "qp-type",
167 qp_types_to_str(type
)))
171 ps
= mnl_attr_get_u32(nla_line
[RDMA_NLDEV_ATTR_RES_PS
]);
172 if (rd_check_is_string_filtered(rd
, "ps", cm_id_ps_to_str(ps
)))
175 state
= mnl_attr_get_u8(nla_line
[RDMA_NLDEV_ATTR_RES_STATE
]);
176 if (rd_check_is_string_filtered(rd
, "state",
177 cm_id_state_to_str(state
)))
180 if (nla_line
[RDMA_NLDEV_ATTR_RES_SRC_ADDR
]) {
181 if (ss_ntop(nla_line
[RDMA_NLDEV_ATTR_RES_SRC_ADDR
],
182 src_addr_str
, &src_port
))
184 if (rd_check_is_string_filtered(rd
, "src-addr",
187 if (rd_check_is_filtered(rd
, "src-port", src_port
))
191 if (nla_line
[RDMA_NLDEV_ATTR_RES_DST_ADDR
]) {
192 if (ss_ntop(nla_line
[RDMA_NLDEV_ATTR_RES_DST_ADDR
],
193 dst_addr_str
, &dst_port
))
195 if (rd_check_is_string_filtered(rd
, "dst-addr",
198 if (rd_check_is_filtered(rd
, "dst-port", dst_port
))
202 if (nla_line
[RDMA_NLDEV_ATTR_RES_PID
]) {
203 pid
= mnl_attr_get_u32(
204 nla_line
[RDMA_NLDEV_ATTR_RES_PID
]);
205 comm
= get_task_name(pid
);
208 if (rd_check_is_filtered(rd
, "pid", pid
)) {
213 if (nla_line
[RDMA_NLDEV_ATTR_RES_CM_IDN
])
214 cm_idn
= mnl_attr_get_u32(
215 nla_line
[RDMA_NLDEV_ATTR_RES_CM_IDN
]);
216 if (rd_check_is_filtered(rd
, "cm-idn", cm_idn
))
219 if (nla_line
[RDMA_NLDEV_ATTR_RES_KERN_NAME
]) {
220 /* discard const from mnl_attr_get_str */
221 comm
= (char *)mnl_attr_get_str(
222 nla_line
[RDMA_NLDEV_ATTR_RES_KERN_NAME
]);
226 jsonw_start_array(rd
->jw
);
228 print_link(rd
, idx
, name
, port
, nla_line
);
229 if (nla_line
[RDMA_NLDEV_ATTR_RES_LQPN
])
230 print_lqpn(rd
, lqpn
);
231 if (nla_line
[RDMA_NLDEV_ATTR_RES_TYPE
])
232 print_qp_type(rd
, type
);
233 print_cm_id_state(rd
, state
);
236 print_comm(rd
, comm
, nla_line
);
237 if (nla_line
[RDMA_NLDEV_ATTR_RES_CM_IDN
])
238 res_print_uint(rd
, "cm-idn", cm_idn
);
240 if (nla_line
[RDMA_NLDEV_ATTR_RES_SRC_ADDR
])
241 print_ipaddr(rd
, "src-addr", src_addr_str
, src_port
);
242 if (nla_line
[RDMA_NLDEV_ATTR_RES_DST_ADDR
])
243 print_ipaddr(rd
, "dst-addr", dst_addr_str
, dst_port
);
245 if (nla_line
[RDMA_NLDEV_ATTR_RES_PID
])
248 print_driver_table(rd
, nla_line
[RDMA_NLDEV_ATTR_DRIVER
]);