diff --git a/tc/q_mqprio.c b/tc/q_mqprio.c index 0eb41308..f26ba8d7 100644 --- a/tc/q_mqprio.c +++ b/tc/q_mqprio.c @@ -48,6 +48,7 @@ static int mqprio_parse_opt(struct qdisc_util *qu, int argc, __u64 max_rate64[TC_QOPT_MAX_QUEUE] = {0}; __u16 shaper = TC_MQPRIO_SHAPER_DCB; __u16 mode = TC_MQPRIO_MODE_DCB; + int cnt_off_pairs = 0; struct rtattr *tail; __u32 flags = 0; @@ -94,6 +95,7 @@ static int mqprio_parse_opt(struct qdisc_util *qu, int argc, } free(tmp); idx++; + cnt_off_pairs++; } } else if (strcmp(*argv, "hw") == 0) { NEXT_ARG(); @@ -173,6 +175,12 @@ static int mqprio_parse_opt(struct qdisc_util *qu, int argc, argc--; argv++; } + if (cnt_off_pairs > opt.num_tc) { + fprintf(stderr, "queues count/offset pair count %d can not be higher than given num_tc %d\n", + cnt_off_pairs, opt.num_tc); + return -1; + } + tail = NLMSG_TAIL(n); addattr_l(n, 1024, TCA_OPTIONS, &opt, sizeof(opt));