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
)
12 print_color_string(PRINT_ANY
, COLOR_NONE
, "qp-type", "qp-type %s ",
13 qp_types_to_str(val
));
16 static const char *cm_id_state_to_str(uint8_t idx
)
18 static const char *const cm_id_states_str
[] = {
19 "IDLE", "ADDR_QUERY", "ADDR_RESOLVED",
20 "ROUTE_QUERY", "ROUTE_RESOLVED", "CONNECT",
21 "DISCONNECT", "ADDR_BOUND", "LISTEN",
22 "DEVICE_REMOVAL", "DESTROYING"
25 if (idx
< ARRAY_SIZE(cm_id_states_str
))
26 return cm_id_states_str
[idx
];
30 static const char *cm_id_ps_to_str(uint32_t ps
)
46 static void print_cm_id_state(struct rd
*rd
, uint8_t state
)
48 print_color_string(PRINT_ANY
, COLOR_NONE
, "state", "state %s ",
49 cm_id_state_to_str(state
));
52 static void print_ps(struct rd
*rd
, uint32_t ps
)
54 print_color_string(PRINT_ANY
, COLOR_NONE
, "ps", "ps %s ",
58 static void print_ipaddr(struct rd
*rd
, const char *key
, char *addrstr
,
61 int name_size
= INET6_ADDRSTRLEN
+ strlen(":65535");
62 char json_name
[name_size
];
64 snprintf(json_name
, name_size
, "%s:%u", addrstr
, port
);
65 print_color_string(PRINT_ANY
, COLOR_NONE
, key
, key
, json_name
);
66 print_color_string(PRINT_FP
, COLOR_NONE
, NULL
, " %s:", addrstr
);
67 print_color_uint(PRINT_FP
, COLOR_NONE
, NULL
, "%u ", port
);
70 static int ss_ntop(struct nlattr
*nla_line
, char *addr_str
, uint16_t *port
)
72 struct __kernel_sockaddr_storage
*addr
;
74 addr
= (struct __kernel_sockaddr_storage
*)mnl_attr_get_payload(
76 switch (addr
->ss_family
) {
78 struct sockaddr_in
*sin
= (struct sockaddr_in
*)addr
;
80 if (!inet_ntop(AF_INET
, (const void *)&sin
->sin_addr
, addr_str
,
83 *port
= ntohs(sin
->sin_port
);
87 struct sockaddr_in6
*sin6
= (struct sockaddr_in6
*)addr
;
89 if (!inet_ntop(AF_INET6
, (const void *)&sin6
->sin6_addr
,
90 addr_str
, INET6_ADDRSTRLEN
))
92 *port
= ntohs(sin6
->sin6_port
);
100 static int res_cm_id_line(struct rd
*rd
, const char *name
, int idx
,
101 struct nlattr
**nla_line
)
103 char src_addr_str
[INET6_ADDRSTRLEN
];
104 char dst_addr_str
[INET6_ADDRSTRLEN
];
105 uint16_t src_port
, dst_port
;
106 uint32_t port
= 0, pid
= 0;
107 uint8_t type
= 0, state
;
108 uint32_t lqpn
= 0, ps
;
112 if (!nla_line
[RDMA_NLDEV_ATTR_RES_STATE
] ||
113 !nla_line
[RDMA_NLDEV_ATTR_RES_PS
])
116 if (nla_line
[RDMA_NLDEV_ATTR_PORT_INDEX
])
117 port
= mnl_attr_get_u32(nla_line
[RDMA_NLDEV_ATTR_PORT_INDEX
]);
119 if (port
&& port
!= rd
->port_idx
)
122 if (nla_line
[RDMA_NLDEV_ATTR_RES_LQPN
])
123 lqpn
= mnl_attr_get_u32(nla_line
[RDMA_NLDEV_ATTR_RES_LQPN
]);
125 if (rd_is_filtered_attr(rd
, "lqpn", lqpn
,
126 nla_line
[RDMA_NLDEV_ATTR_RES_LQPN
]))
129 if (nla_line
[RDMA_NLDEV_ATTR_RES_TYPE
])
130 type
= mnl_attr_get_u8(nla_line
[RDMA_NLDEV_ATTR_RES_TYPE
]);
131 if (rd_is_string_filtered_attr(rd
, "qp-type", qp_types_to_str(type
),
132 nla_line
[RDMA_NLDEV_ATTR_RES_TYPE
]))
135 ps
= mnl_attr_get_u32(nla_line
[RDMA_NLDEV_ATTR_RES_PS
]);
136 if (rd_is_string_filtered_attr(rd
, "ps", cm_id_ps_to_str(ps
),
137 nla_line
[RDMA_NLDEV_ATTR_RES_PS
]))
140 state
= mnl_attr_get_u8(nla_line
[RDMA_NLDEV_ATTR_RES_STATE
]);
141 if (rd_is_string_filtered_attr(rd
, "state", cm_id_state_to_str(state
),
142 nla_line
[RDMA_NLDEV_ATTR_RES_STATE
]))
145 if (nla_line
[RDMA_NLDEV_ATTR_RES_SRC_ADDR
])
146 if (ss_ntop(nla_line
[RDMA_NLDEV_ATTR_RES_SRC_ADDR
],
147 src_addr_str
, &src_port
))
149 if (rd_is_string_filtered_attr(rd
, "src-addr", src_addr_str
,
150 nla_line
[RDMA_NLDEV_ATTR_RES_SRC_ADDR
]))
152 if (rd_is_filtered_attr(rd
, "src-port", src_port
,
153 nla_line
[RDMA_NLDEV_ATTR_RES_SRC_ADDR
]))
156 if (nla_line
[RDMA_NLDEV_ATTR_RES_DST_ADDR
])
157 if (ss_ntop(nla_line
[RDMA_NLDEV_ATTR_RES_DST_ADDR
],
158 dst_addr_str
, &dst_port
))
160 if (rd_is_string_filtered_attr(rd
, "dst-addr", dst_addr_str
,
161 nla_line
[RDMA_NLDEV_ATTR_RES_DST_ADDR
]))
163 if (rd_is_filtered_attr(rd
, "dst-port", dst_port
,
164 nla_line
[RDMA_NLDEV_ATTR_RES_DST_ADDR
]))
167 if (nla_line
[RDMA_NLDEV_ATTR_RES_PID
]) {
168 pid
= mnl_attr_get_u32(nla_line
[RDMA_NLDEV_ATTR_RES_PID
]);
169 comm
= get_task_name(pid
);
172 if (rd_is_filtered_attr(rd
, "pid", pid
,
173 nla_line
[RDMA_NLDEV_ATTR_RES_PID
]))
176 if (nla_line
[RDMA_NLDEV_ATTR_RES_CM_IDN
])
177 cm_idn
= mnl_attr_get_u32(nla_line
[RDMA_NLDEV_ATTR_RES_CM_IDN
]);
178 if (rd_is_filtered_attr(rd
, "cm-idn", cm_idn
,
179 nla_line
[RDMA_NLDEV_ATTR_RES_CM_IDN
]))
182 if (nla_line
[RDMA_NLDEV_ATTR_RES_KERN_NAME
]) {
183 /* discard const from mnl_attr_get_str */
184 comm
= (char *)mnl_attr_get_str(
185 nla_line
[RDMA_NLDEV_ATTR_RES_KERN_NAME
]);
188 open_json_object(NULL
);
189 print_link(rd
, idx
, name
, port
, nla_line
);
190 res_print_uint(rd
, "cm-idn", cm_idn
,
191 nla_line
[RDMA_NLDEV_ATTR_RES_CM_IDN
]);
192 res_print_uint(rd
, "lqpn", lqpn
, nla_line
[RDMA_NLDEV_ATTR_RES_LQPN
]);
193 if (nla_line
[RDMA_NLDEV_ATTR_RES_TYPE
])
194 print_qp_type(rd
, type
);
195 print_cm_id_state(rd
, state
);
197 res_print_uint(rd
, "pid", pid
, nla_line
[RDMA_NLDEV_ATTR_RES_PID
]);
198 print_comm(rd
, comm
, nla_line
);
200 if (nla_line
[RDMA_NLDEV_ATTR_RES_SRC_ADDR
])
201 print_ipaddr(rd
, "src-addr", src_addr_str
, src_port
);
202 if (nla_line
[RDMA_NLDEV_ATTR_RES_DST_ADDR
])
203 print_ipaddr(rd
, "dst-addr", dst_addr_str
, dst_port
);
205 print_driver_table(rd
, nla_line
[RDMA_NLDEV_ATTR_DRIVER
]);
208 out
: if (nla_line
[RDMA_NLDEV_ATTR_RES_PID
])
213 int res_cm_id_idx_parse_cb(const struct nlmsghdr
*nlh
, void *data
)
215 struct nlattr
*tb
[RDMA_NLDEV_ATTR_MAX
] = {};
216 struct rd
*rd
= data
;
220 mnl_attr_parse(nlh
, 0, rd_attr_cb
, tb
);
221 if (!tb
[RDMA_NLDEV_ATTR_DEV_INDEX
] || !tb
[RDMA_NLDEV_ATTR_DEV_NAME
])
224 name
= mnl_attr_get_str(tb
[RDMA_NLDEV_ATTR_DEV_NAME
]);
225 idx
= mnl_attr_get_u32(tb
[RDMA_NLDEV_ATTR_DEV_INDEX
]);
227 return res_cm_id_line(rd
, name
, idx
, tb
);
230 int res_cm_id_parse_cb(const struct nlmsghdr
*nlh
, void *data
)
232 struct nlattr
*tb
[RDMA_NLDEV_ATTR_MAX
] = {};
233 struct nlattr
*nla_table
, *nla_entry
;
234 struct rd
*rd
= data
;
239 mnl_attr_parse(nlh
, 0, rd_attr_cb
, tb
);
240 if (!tb
[RDMA_NLDEV_ATTR_DEV_INDEX
] || !tb
[RDMA_NLDEV_ATTR_DEV_NAME
] ||
241 !tb
[RDMA_NLDEV_ATTR_RES_CM_ID
])
244 name
= mnl_attr_get_str(tb
[RDMA_NLDEV_ATTR_DEV_NAME
]);
245 idx
= mnl_attr_get_u32(tb
[RDMA_NLDEV_ATTR_DEV_INDEX
]);
246 nla_table
= tb
[RDMA_NLDEV_ATTR_RES_CM_ID
];
248 mnl_attr_for_each_nested(nla_entry
, nla_table
) {
249 struct nlattr
*nla_line
[RDMA_NLDEV_ATTR_MAX
] = {};
251 ret
= mnl_attr_parse_nested(nla_entry
, rd_attr_cb
, nla_line
);
252 if (ret
!= MNL_CB_OK
)
255 ret
= res_cm_id_line(rd
, name
, idx
, nla_line
);
256 if (ret
!= MNL_CB_OK
)