X-Git-Url: https://git.proxmox.com/?a=blobdiff_plain;f=rdma%2Fres-cq.c;h=313f929a29b547ae35835ec236f8f45eab6bc9a7;hb=275eed9be56d641cea06aced9692acdabd49d336;hp=5afb97c5bbf458d35893f48de4d60ea0e56446bc;hpb=be029b3a58148fef541f45df55a09784f15be14e;p=mirror_iproute2.git diff --git a/rdma/res-cq.c b/rdma/res-cq.c index 5afb97c5..313f929a 100644 --- a/rdma/res-cq.c +++ b/rdma/res-cq.c @@ -21,13 +21,36 @@ static void print_poll_ctx(struct rd *rd, uint8_t poll_ctx, struct nlattr *attr) { if (!attr) return; + print_color_string(PRINT_ANY, COLOR_NONE, "poll-ctx", "poll-ctx %s ", + poll_ctx_to_str(poll_ctx)); +} + +static void print_cq_dim_setting(struct rd *rd, struct nlattr *attr) +{ + uint8_t dim_setting; - if (rd->json_output) { - jsonw_string_field(rd->jw, "poll-ctx", - poll_ctx_to_str(poll_ctx)); + if (!attr) return; - } - pr_out("poll-ctx %s ", poll_ctx_to_str(poll_ctx)); + + dim_setting = mnl_attr_get_u8(attr); + if (dim_setting > 1) + return; + + print_on_off(rd, "adaptive-moderation", dim_setting); +} + +static int res_cq_line_raw(struct rd *rd, const char *name, int idx, + struct nlattr **nla_line) +{ + if (!nla_line[RDMA_NLDEV_ATTR_RES_RAW]) + return MNL_CB_ERROR; + + open_json_object(NULL); + print_dev(rd, idx, name); + print_raw_data(rd, nla_line); + newline(rd); + + return MNL_CB_OK; } static int res_cq_line(struct rd *rd, const char *name, int idx, @@ -42,11 +65,8 @@ static int res_cq_line(struct rd *rd, const char *name, int idx, uint32_t cqe; if (!nla_line[RDMA_NLDEV_ATTR_RES_CQE] || - !nla_line[RDMA_NLDEV_ATTR_RES_USECNT] || - (!nla_line[RDMA_NLDEV_ATTR_RES_PID] && - !nla_line[RDMA_NLDEV_ATTR_RES_KERN_NAME])) { + !nla_line[RDMA_NLDEV_ATTR_RES_USECNT]) return MNL_CB_ERROR; - } cqe = mnl_attr_get_u32(nla_line[RDMA_NLDEV_ATTR_RES_CQE]); @@ -88,15 +108,14 @@ static int res_cq_line(struct rd *rd, const char *name, int idx, comm = (char *)mnl_attr_get_str( nla_line[RDMA_NLDEV_ATTR_RES_KERN_NAME]); - if (rd->json_output) - jsonw_start_array(rd->jw); - + open_json_object(NULL); print_dev(rd, idx, name); res_print_uint(rd, "cqn", cqn, nla_line[RDMA_NLDEV_ATTR_RES_CQN]); res_print_uint(rd, "cqe", cqe, nla_line[RDMA_NLDEV_ATTR_RES_CQE]); res_print_uint(rd, "users", users, nla_line[RDMA_NLDEV_ATTR_RES_USECNT]); print_poll_ctx(rd, poll_ctx, nla_line[RDMA_NLDEV_ATTR_RES_POLL_CTX]); + print_cq_dim_setting(rd, nla_line[RDMA_NLDEV_ATTR_DEV_DIM]); res_print_uint(rd, "ctxn", ctxn, nla_line[RDMA_NLDEV_ATTR_RES_CTXN]); res_print_uint(rd, "pid", pid, nla_line[RDMA_NLDEV_ATTR_RES_PID]); print_comm(rd, comm, nla_line); @@ -123,7 +142,8 @@ int res_cq_idx_parse_cb(const struct nlmsghdr *nlh, void *data) name = mnl_attr_get_str(tb[RDMA_NLDEV_ATTR_DEV_NAME]); idx = mnl_attr_get_u32(tb[RDMA_NLDEV_ATTR_DEV_INDEX]); - return res_cq_line(rd, name, idx, tb); + return (rd->show_raw) ? res_cq_line_raw(rd, name, idx, tb) : + res_cq_line(rd, name, idx, tb); } int res_cq_parse_cb(const struct nlmsghdr *nlh, void *data) @@ -151,7 +171,8 @@ int res_cq_parse_cb(const struct nlmsghdr *nlh, void *data) if (ret != MNL_CB_OK) break; - ret = res_cq_line(rd, name, idx, nla_line); + ret = (rd->show_raw) ? res_cq_line_raw(rd, name, idx, nla_line) : + res_cq_line(rd, name, idx, nla_line); if (ret != MNL_CB_OK) break;