[mirror_iproute2.git] / tc / q_cbq.c

/*
 * q_cbq.c		CBQ.
 *
 *		This program is free software; you can redistribute it and/or
 *		modify it under the terms of the GNU General Public License
 *		as published by the Free Software Foundation; either version
 *		2 of the License, or (at your option) any later version.
 *
 * Authors:	Alexey Kuznetsov, <kuznet@ms2.inr.ac.ru>
 *
 */

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <fcntl.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>

#include "utils.h"
#include "tc_util.h"
#include "tc_cbq.h"

static void explain_class(void)
{
	fprintf(stderr, "Usage: ... cbq bandwidth BPS rate BPS maxburst PKTS [ avpkt BYTES ]\n");
	fprintf(stderr, "               [ minburst PKTS ] [ bounded ] [ isolated ]\n");
	fprintf(stderr, "               [ allot BYTES ] [ mpu BYTES ] [ weight RATE ]\n");
	fprintf(stderr, "               [ prio NUMBER ] [ cell BYTES ] [ ewma LOG ]\n");
	fprintf(stderr, "               [ estimator INTERVAL TIME_CONSTANT ]\n");
	fprintf(stderr, "               [ split CLASSID ] [ defmap MASK/CHANGE ]\n");
	fprintf(stderr, "               [ overhead BYTES ] [ linklayer TYPE ]\n");
}

static void explain(void)
{
	fprintf(stderr, "Usage: ... cbq bandwidth BPS avpkt BYTES [ mpu BYTES ]\n");
	fprintf(stderr, "               [ cell BYTES ] [ ewma LOG ]\n");
}

static void explain1(char *arg)
{
	fprintf(stderr, "Illegal \"%s\"\n", arg);
}


static int cbq_parse_opt(struct qdisc_util *qu, int argc, char **argv, struct nlmsghdr *n, const char *dev)
{
	struct tc_ratespec r = {};
	struct tc_cbq_lssopt lss = {};
	__u32 rtab[256];
	unsigned mpu = 0, avpkt = 0, allot = 0;
	unsigned short overhead = 0;
	unsigned int linklayer = LINKLAYER_ETHERNET; /* Assume ethernet */
	int cell_log =  -1;
	int ewma_log =  -1;
	struct rtattr *tail;

	while (argc > 0) {
		if (matches(*argv, "bandwidth") == 0 ||
		    matches(*argv, "rate") == 0) {
			NEXT_ARG();
			if (strchr(*argv, '%')) {
				if (get_percent_rate(&r.rate, *argv, dev)) {
					explain1("bandwidth");
					return -1;
				}
			} else if (get_rate(&r.rate, *argv)) {
				explain1("bandwidth");
				return -1;
			}
		} else if (matches(*argv, "ewma") == 0) {
			NEXT_ARG();
			if (get_integer(&ewma_log, *argv, 0)) {
				explain1("ewma");
				return -1;
			}
			if (ewma_log > 31) {
				fprintf(stderr, "ewma_log must be < 32\n");
				return -1;
			}
		} else if (matches(*argv, "cell") == 0) {
			unsigned int cell;
			int i;

			NEXT_ARG();
			if (get_size(&cell, *argv)) {
				explain1("cell");
				return -1;
			}
			for (i = 0; i < 32; i++)
				if ((1<<i) == cell)
					break;
			if (i >= 32) {
				fprintf(stderr, "cell must be 2^n\n");
				return -1;
			}
			cell_log = i;
		} else if (matches(*argv, "avpkt") == 0) {
			NEXT_ARG();
			if (get_size(&avpkt, *argv)) {
				explain1("avpkt");
				return -1;
			}
		} else if (matches(*argv, "mpu") == 0) {
			NEXT_ARG();
			if (get_size(&mpu, *argv)) {
				explain1("mpu");
				return -1;
			}
		} else if (matches(*argv, "allot") == 0) {
			NEXT_ARG();
			/* Accept and ignore "allot" for backward compatibility */
			if (get_size(&allot, *argv)) {
				explain1("allot");
				return -1;
			}
		} else if (matches(*argv, "overhead") == 0) {
			NEXT_ARG();
			if (get_u16(&overhead, *argv, 10)) {
				explain1("overhead"); return -1;
			}
		} else if (matches(*argv, "linklayer") == 0) {
			NEXT_ARG();
			if (get_linklayer(&linklayer, *argv)) {
				explain1("linklayer"); return -1;
			}
		} else if (matches(*argv, "help") == 0) {
			explain();
			return -1;
		} else {
			fprintf(stderr, "What is \"%s\"?\n", *argv);
			explain();
			return -1;
		}
		argc--; argv++;
	}

	/* OK. All options are parsed. */

	if (r.rate == 0) {
		fprintf(stderr, "CBQ: bandwidth is required parameter.\n");
		return -1;
	}
	if (avpkt == 0) {
		fprintf(stderr, "CBQ: \"avpkt\" is required.\n");
		return -1;
	}
	if (allot < (avpkt*3)/2)
		allot = (avpkt*3)/2;

	r.mpu = mpu;
	r.overhead = overhead;
	if (tc_calc_rtable(&r, rtab, cell_log, allot, linklayer) < 0) {
		fprintf(stderr, "CBQ: failed to calculate rate table.\n");
		return -1;
	}

	if (ewma_log < 0)
		ewma_log = TC_CBQ_DEF_EWMA;
	lss.ewma_log = ewma_log;
	lss.maxidle = tc_calc_xmittime(r.rate, avpkt);
	lss.change = TCF_CBQ_LSS_MAXIDLE|TCF_CBQ_LSS_EWMA|TCF_CBQ_LSS_AVPKT;
	lss.avpkt = avpkt;

	tail = NLMSG_TAIL(n);
	addattr_l(n, 1024, TCA_OPTIONS, NULL, 0);
	addattr_l(n, 1024, TCA_CBQ_RATE, &r, sizeof(r));
	addattr_l(n, 1024, TCA_CBQ_LSSOPT, &lss, sizeof(lss));
	addattr_l(n, 3024, TCA_CBQ_RTAB, rtab, 1024);
	if (show_raw) {
		int i;

		for (i = 0; i < 256; i++)
			printf("%u ", rtab[i]);
		printf("\n");
	}
	tail->rta_len = (void *) NLMSG_TAIL(n) - (void *) tail;
	return 0;
}

static int cbq_parse_class_opt(struct qdisc_util *qu, int argc, char **argv, struct nlmsghdr *n, const char *dev)
{
	int wrr_ok = 0, fopt_ok = 0;
	struct tc_ratespec r = {};
	struct tc_cbq_lssopt lss = {};
	struct tc_cbq_wrropt wrr = {};
	struct tc_cbq_fopt fopt = {};
	__u32 rtab[256];
	unsigned mpu = 0;
	int cell_log =  -1;
	int ewma_log =  -1;
	unsigned int bndw = 0;
	unsigned minburst = 0, maxburst = 0;
	unsigned short overhead = 0;
	unsigned int linklayer = LINKLAYER_ETHERNET; /* Assume ethernet */
	struct rtattr *tail;

	while (argc > 0) {
		if (matches(*argv, "rate") == 0) {
			NEXT_ARG();
			if (strchr(*argv, '%')) {
				if (get_percent_rate(&r.rate, *argv, dev)) {
					explain1("rate");
					return -1;
				}
			} else if (get_rate(&r.rate, *argv)) {
				explain1("rate");
				return -1;
			}
		} else if (matches(*argv, "bandwidth") == 0) {
			NEXT_ARG();
			if (strchr(*argv, '%')) {
				if (get_percent_rate(&bndw, *argv, dev)) {
					explain1("bandwidth");
					return -1;
				}
			} else if (get_rate(&bndw, *argv)) {
				explain1("bandwidth");
				return -1;
			}
		} else if (matches(*argv, "minidle") == 0) {
			NEXT_ARG();
			if (get_u32(&lss.minidle, *argv, 0)) {
				explain1("minidle");
				return -1;
			}
			lss.change |= TCF_CBQ_LSS_MINIDLE;
		} else if (matches(*argv, "minburst") == 0) {
			NEXT_ARG();
			if (get_u32(&minburst, *argv, 0)) {
				explain1("minburst");
				return -1;
			}
			lss.change |= TCF_CBQ_LSS_OFFTIME;
		} else if (matches(*argv, "maxburst") == 0) {
			NEXT_ARG();
			if (get_u32(&maxburst, *argv, 0)) {
				explain1("maxburst");
				return -1;
			}
			lss.change |= TCF_CBQ_LSS_MAXIDLE;
		} else if (matches(*argv, "bounded") == 0) {
			lss.flags |= TCF_CBQ_LSS_BOUNDED;
			lss.change |= TCF_CBQ_LSS_FLAGS;
		} else if (matches(*argv, "borrow") == 0) {
			lss.flags &= ~TCF_CBQ_LSS_BOUNDED;
			lss.change |= TCF_CBQ_LSS_FLAGS;
		} else if (matches(*argv, "isolated") == 0) {
			lss.flags |= TCF_CBQ_LSS_ISOLATED;
			lss.change |= TCF_CBQ_LSS_FLAGS;
		} else if (matches(*argv, "sharing") == 0) {
			lss.flags &= ~TCF_CBQ_LSS_ISOLATED;
			lss.change |= TCF_CBQ_LSS_FLAGS;
		} else if (matches(*argv, "ewma") == 0) {
			NEXT_ARG();
			if (get_integer(&ewma_log, *argv, 0)) {
				explain1("ewma");
				return -1;
			}
			if (ewma_log > 31) {
				fprintf(stderr, "ewma_log must be < 32\n");
				return -1;
			}
			lss.change |= TCF_CBQ_LSS_EWMA;
		} else if (matches(*argv, "cell") == 0) {
			unsigned int cell;
			int i;

			NEXT_ARG();
			if (get_size(&cell, *argv)) {
				explain1("cell");
				return -1;
			}
			for (i = 0; i < 32; i++)
				if ((1<<i) == cell)
					break;
			if (i >= 32) {
				fprintf(stderr, "cell must be 2^n\n");
				return -1;
			}
			cell_log = i;
		} else if (matches(*argv, "prio") == 0) {
			unsigned int prio;

			NEXT_ARG();
			if (get_u32(&prio, *argv, 0)) {
				explain1("prio");
				return -1;
			}
			if (prio > TC_CBQ_MAXPRIO) {
				fprintf(stderr, "\"prio\" must be number in the range 1...%d\n", TC_CBQ_MAXPRIO);
				return -1;
			}
			wrr.priority = prio;
			wrr_ok++;
		} else if (matches(*argv, "allot") == 0) {
			NEXT_ARG();
			if (get_size(&wrr.allot, *argv)) {
				explain1("allot");
				return -1;
			}
		} else if (matches(*argv, "avpkt") == 0) {
			NEXT_ARG();
			if (get_size(&lss.avpkt, *argv)) {
				explain1("avpkt");
				return -1;
			}
			lss.change |= TCF_CBQ_LSS_AVPKT;
		} else if (matches(*argv, "mpu") == 0) {
			NEXT_ARG();
			if (get_size(&mpu, *argv)) {
				explain1("mpu");
				return -1;
			}
		} else if (matches(*argv, "weight") == 0) {
			NEXT_ARG();
			if (get_size(&wrr.weight, *argv)) {
				explain1("weight");
				return -1;
			}
			wrr_ok++;
		} else if (matches(*argv, "split") == 0) {
			NEXT_ARG();
			if (get_tc_classid(&fopt.split, *argv)) {
				fprintf(stderr, "Invalid split node ID.\n");
				return -1;
			}
			fopt_ok++;
		} else if (matches(*argv, "defmap") == 0) {
			int err;

			NEXT_ARG();
			err = sscanf(*argv, "%08x/%08x", &fopt.defmap, &fopt.defchange);
			if (err < 1) {
				fprintf(stderr, "Invalid defmap, should be MASK32[/MASK]\n");
				return -1;
			}
			if (err == 1)
				fopt.defchange = ~0;
			fopt_ok++;
		} else if (matches(*argv, "overhead") == 0) {
			NEXT_ARG();
			if (get_u16(&overhead, *argv, 10)) {
				explain1("overhead"); return -1;
			}
		} else if (matches(*argv, "linklayer") == 0) {
			NEXT_ARG();
			if (get_linklayer(&linklayer, *argv)) {
				explain1("linklayer"); return -1;
			}
		} else if (matches(*argv, "help") == 0) {
			explain_class();
			return -1;
		} else {
			fprintf(stderr, "What is \"%s\"?\n", *argv);
			explain_class();
			return -1;
		}
		argc--; argv++;
	}

	/* OK. All options are parsed. */

	/* 1. Prepare link sharing scheduler parameters */
	if (r.rate) {
		unsigned int pktsize = wrr.allot;

		if (wrr.allot < (lss.avpkt*3)/2)
			wrr.allot = (lss.avpkt*3)/2;
		r.mpu = mpu;
		r.overhead = overhead;
		if (tc_calc_rtable(&r, rtab, cell_log, pktsize, linklayer) < 0) {
			fprintf(stderr, "CBQ: failed to calculate rate table.\n");
			return -1;
		}
	}
	if (ewma_log < 0)
		ewma_log = TC_CBQ_DEF_EWMA;
	lss.ewma_log = ewma_log;
	if (lss.change&(TCF_CBQ_LSS_OFFTIME|TCF_CBQ_LSS_MAXIDLE)) {
		if (lss.avpkt == 0) {
			fprintf(stderr, "CBQ: avpkt is required for max/minburst.\n");
			return -1;
		}
		if (bndw == 0 || r.rate == 0) {
			fprintf(stderr, "CBQ: bandwidth&rate are required for max/minburst.\n");
			return -1;
		}
	}
	if (wrr.priority == 0 && (n->nlmsg_flags&NLM_F_EXCL)) {
		wrr_ok = 1;
		wrr.priority = TC_CBQ_MAXPRIO;
		if (wrr.allot == 0)
			wrr.allot = (lss.avpkt*3)/2;
	}
	if (wrr_ok) {
		if (wrr.weight == 0)
			wrr.weight = (wrr.priority == TC_CBQ_MAXPRIO) ? 1 : r.rate;
		if (wrr.allot == 0) {
			fprintf(stderr, "CBQ: \"allot\" is required to set WRR parameters.\n");
			return -1;
		}
	}
	if (lss.change&TCF_CBQ_LSS_MAXIDLE) {
		lss.maxidle = tc_cbq_calc_maxidle(bndw, r.rate, lss.avpkt, ewma_log, maxburst);
		lss.change |= TCF_CBQ_LSS_MAXIDLE;
		lss.change |= TCF_CBQ_LSS_EWMA|TCF_CBQ_LSS_AVPKT;
	}
	if (lss.change&TCF_CBQ_LSS_OFFTIME) {
		lss.offtime = tc_cbq_calc_offtime(bndw, r.rate, lss.avpkt, ewma_log, minburst);
		lss.change |= TCF_CBQ_LSS_OFFTIME;
		lss.change |= TCF_CBQ_LSS_EWMA|TCF_CBQ_LSS_AVPKT;
	}
	if (lss.change&TCF_CBQ_LSS_MINIDLE) {
		lss.minidle <<= lss.ewma_log;
		lss.change |= TCF_CBQ_LSS_EWMA;
	}

	tail = NLMSG_TAIL(n);
	addattr_l(n, 1024, TCA_OPTIONS, NULL, 0);
	if (lss.change) {
		lss.change |= TCF_CBQ_LSS_FLAGS;
		addattr_l(n, 1024, TCA_CBQ_LSSOPT, &lss, sizeof(lss));
	}
	if (wrr_ok)
		addattr_l(n, 1024, TCA_CBQ_WRROPT, &wrr, sizeof(wrr));
	if (fopt_ok)
		addattr_l(n, 1024, TCA_CBQ_FOPT, &fopt, sizeof(fopt));
	if (r.rate) {
		addattr_l(n, 1024, TCA_CBQ_RATE, &r, sizeof(r));
		addattr_l(n, 3024, TCA_CBQ_RTAB, rtab, 1024);
		if (show_raw) {
			int i;

			for (i = 0; i < 256; i++)
				printf("%u ", rtab[i]);
			printf("\n");
		}
	}
	tail->rta_len = (void *) NLMSG_TAIL(n) - (void *) tail;
	return 0;
}


static int cbq_print_opt(struct qdisc_util *qu, FILE *f, struct rtattr *opt)
{
	struct rtattr *tb[TCA_CBQ_MAX+1];
	struct tc_ratespec *r = NULL;
	struct tc_cbq_lssopt *lss = NULL;
	struct tc_cbq_wrropt *wrr = NULL;
	struct tc_cbq_fopt *fopt = NULL;
	struct tc_cbq_ovl *ovl = NULL;
	unsigned int linklayer;

	SPRINT_BUF(b1);
	SPRINT_BUF(b2);

	if (opt == NULL)
		return 0;

	parse_rtattr_nested(tb, TCA_CBQ_MAX, opt);

	if (tb[TCA_CBQ_RATE]) {
		if (RTA_PAYLOAD(tb[TCA_CBQ_RATE]) < sizeof(*r))
			fprintf(stderr, "CBQ: too short rate opt\n");
		else
			r = RTA_DATA(tb[TCA_CBQ_RATE]);
	}
	if (tb[TCA_CBQ_LSSOPT]) {
		if (RTA_PAYLOAD(tb[TCA_CBQ_LSSOPT]) < sizeof(*lss))
			fprintf(stderr, "CBQ: too short lss opt\n");
		else
			lss = RTA_DATA(tb[TCA_CBQ_LSSOPT]);
	}
	if (tb[TCA_CBQ_WRROPT]) {
		if (RTA_PAYLOAD(tb[TCA_CBQ_WRROPT]) < sizeof(*wrr))
			fprintf(stderr, "CBQ: too short wrr opt\n");
		else
			wrr = RTA_DATA(tb[TCA_CBQ_WRROPT]);
	}
	if (tb[TCA_CBQ_FOPT]) {
		if (RTA_PAYLOAD(tb[TCA_CBQ_FOPT]) < sizeof(*fopt))
			fprintf(stderr, "CBQ: too short fopt\n");
		else
			fopt = RTA_DATA(tb[TCA_CBQ_FOPT]);
	}
	if (tb[TCA_CBQ_OVL_STRATEGY]) {
		if (RTA_PAYLOAD(tb[TCA_CBQ_OVL_STRATEGY]) < sizeof(*ovl))
			fprintf(stderr, "CBQ: too short overlimit strategy %u/%u\n",
				(unsigned int) RTA_PAYLOAD(tb[TCA_CBQ_OVL_STRATEGY]),
				(unsigned int) sizeof(*ovl));
		else
			ovl = RTA_DATA(tb[TCA_CBQ_OVL_STRATEGY]);
	}

	if (r) {
		char buf[64];

		print_rate(buf, sizeof(buf), r->rate);
		fprintf(f, "rate %s ", buf);
		linklayer = (r->linklayer & TC_LINKLAYER_MASK);
		if (linklayer > TC_LINKLAYER_ETHERNET || show_details)
			fprintf(f, "linklayer %s ", sprint_linklayer(linklayer, b2));
		if (show_details) {
			fprintf(f, "cell %ub ", 1<<r->cell_log);
			if (r->mpu)
				fprintf(f, "mpu %ub ", r->mpu);
			if (r->overhead)
				fprintf(f, "overhead %ub ", r->overhead);
		}
	}
	if (lss && lss->flags) {
		int comma = 0;

		fprintf(f, "(");
		if (lss->flags&TCF_CBQ_LSS_BOUNDED) {
			fprintf(f, "bounded");
			comma = 1;
		}
		if (lss->flags&TCF_CBQ_LSS_ISOLATED) {
			if (comma)
				fprintf(f, ",");
			fprintf(f, "isolated");
		}
		fprintf(f, ") ");
	}
	if (wrr) {
		if (wrr->priority != TC_CBQ_MAXPRIO)
			fprintf(f, "prio %u", wrr->priority);
		else
			fprintf(f, "prio no-transmit");
		if (show_details) {
			char buf[64];

			fprintf(f, "/%u ", wrr->cpriority);
			if (wrr->weight != 1) {
				print_rate(buf, sizeof(buf), wrr->weight);
				fprintf(f, "weight %s ", buf);
			}
			if (wrr->allot)
				fprintf(f, "allot %ub ", wrr->allot);
		}
	}
	if (lss && show_details) {
		fprintf(f, "\nlevel %u ewma %u avpkt %ub ", lss->level, lss->ewma_log, lss->avpkt);
		if (lss->maxidle) {
			fprintf(f, "maxidle %s ", sprint_ticks(lss->maxidle>>lss->ewma_log, b1));
			if (show_raw)
				fprintf(f, "[%08x] ", lss->maxidle);
		}
		if (lss->minidle != 0x7fffffff) {
			fprintf(f, "minidle %s ", sprint_ticks(lss->minidle>>lss->ewma_log, b1));
			if (show_raw)
				fprintf(f, "[%08x] ", lss->minidle);
		}
		if (lss->offtime) {
			fprintf(f, "offtime %s ", sprint_ticks(lss->offtime, b1));
			if (show_raw)
				fprintf(f, "[%08x] ", lss->offtime);
		}
	}
	if (fopt && show_details) {
		char buf[64];

		print_tc_classid(buf, sizeof(buf), fopt->split);
		fprintf(f, "\nsplit %s ", buf);
		if (fopt->defmap) {
			fprintf(f, "defmap %08x", fopt->defmap);
		}
	}
	return 0;
}

static int cbq_print_xstats(struct qdisc_util *qu, FILE *f, struct rtattr *xstats)
{
	struct tc_cbq_xstats *st;

	if (xstats == NULL)
		return 0;

	if (RTA_PAYLOAD(xstats) < sizeof(*st))
		return -1;

	st = RTA_DATA(xstats);
	fprintf(f, "  borrowed %u overactions %u avgidle %g undertime %g", st->borrows,
		st->overactions, (double)st->avgidle, (double)st->undertime);
	return 0;
}

struct qdisc_util cbq_qdisc_util = {
	.id		= "cbq",
	.parse_qopt	= cbq_parse_opt,
	.print_qopt	= cbq_print_opt,
	.print_xstats	= cbq_print_xstats,
	.parse_copt	= cbq_parse_class_opt,
	.print_copt	= cbq_print_opt,
};
Commit	Line	Data
aba5acdf SH	1	/*
	2	* q_cbq.c CBQ.
	3	*
	4	* This program is free software; you can redistribute it and/or
	5	* modify it under the terms of the GNU General Public License
	6	* as published by the Free Software Foundation; either version
	7	* 2 of the License, or (at your option) any later version.
	8	*
	9	* Authors: Alexey Kuznetsov, <kuznet@ms2.inr.ac.ru>
	10	*
	11	*/
	12
	13	#include <stdio.h>
	14	#include <stdlib.h>
	15	#include <unistd.h>
aba5acdf SH	16	#include <fcntl.h>
	17	#include <sys/socket.h>
	18	#include <netinet/in.h>
	19	#include <arpa/inet.h>
	20	#include <string.h>
	21
	22	#include "utils.h"
	23	#include "tc_util.h"
	24	#include "tc_cbq.h"
	25
	26	static void explain_class(void)
	27	{
	28	fprintf(stderr, "Usage: ... cbq bandwidth BPS rate BPS maxburst PKTS [ avpkt BYTES ]\n");
	29	fprintf(stderr, " [ minburst PKTS ] [ bounded ] [ isolated ]\n");
	30	fprintf(stderr, " [ allot BYTES ] [ mpu BYTES ] [ weight RATE ]\n");
	31	fprintf(stderr, " [ prio NUMBER ] [ cell BYTES ] [ ewma LOG ]\n");
	32	fprintf(stderr, " [ estimator INTERVAL TIME_CONSTANT ]\n");
	33	fprintf(stderr, " [ split CLASSID ] [ defmap MASK/CHANGE ]\n");
292f29b4	34	fprintf(stderr, " [ overhead BYTES ] [ linklayer TYPE ]\n");
aba5acdf SH	35	}
	36
	37	static void explain(void)
	38	{
	39	fprintf(stderr, "Usage: ... cbq bandwidth BPS avpkt BYTES [ mpu BYTES ]\n");
	40	fprintf(stderr, " [ cell BYTES ] [ ewma LOG ]\n");
	41	}
	42
	43	static void explain1(char *arg)
	44	{
	45	fprintf(stderr, "Illegal \"%s\"\n", arg);
	46	}
	47
aba5acdf	48
927e3cfb	49	static int cbq_parse_opt(struct qdisc_util qu, int argc, char argv, struct nlmsghdr n, const char *dev)
aba5acdf	50	{
d17b136f PS	51	struct tc_ratespec r = {};
d17b136f PS	52	struct tc_cbq_lssopt lss = {};
aba5acdf	53	__u32 rtab[256];
32a121cb SH	54	unsigned mpu = 0, avpkt = 0, allot = 0;
32a121cb SH	55	unsigned short overhead = 0;
292f29b4	56	unsigned int linklayer = LINKLAYER_ETHERNET; /* Assume ethernet */
32a121cb SH	57	int cell_log = -1;
32a121cb SH	58	int ewma_log = -1;
aba5acdf SH	59	struct rtattr *tail;
aba5acdf SH	60
aba5acdf	61	while (argc > 0) {
1db5e2ec JDB	62	if (matches(*argv, "bandwidth") == 0 \|\|
1db5e2ec JDB	63	matches(*argv, "rate") == 0) {
aba5acdf	64	NEXT_ARG();
927e3cfb ND	65	if (strchr(*argv, '%')) {
	66	if (get_percent_rate(&r.rate, *argv, dev)) {
	67	explain1("bandwidth");
	68	return -1;
	69	}
	70	} else if (get_rate(&r.rate, *argv)) {
aba5acdf SH	71	explain1("bandwidth");
	72	return -1;
	73	}
1db5e2ec	74	} else if (matches(*argv, "ewma") == 0) {
aba5acdf	75	NEXT_ARG();
f332d169	76	if (get_integer(&ewma_log, *argv, 0)) {
aba5acdf SH	77	explain1("ewma");
	78	return -1;
	79	}
	80	if (ewma_log > 31) {
	81	fprintf(stderr, "ewma_log must be < 32\n");
	82	return -1;
	83	}
1db5e2ec	84	} else if (matches(*argv, "cell") == 0) {
32a121cb	85	unsigned int cell;
aba5acdf	86	int i;
32a121cb	87
aba5acdf SH	88	NEXT_ARG();
	89	if (get_size(&cell, *argv)) {
	90	explain1("cell");
	91	return -1;
	92	}
32a121cb	93	for (i = 0; i < 32; i++)
aba5acdf SH	94	if ((1<<i) == cell)
aba5acdf SH	95	break;
32a121cb	96	if (i >= 32) {
aba5acdf SH	97	fprintf(stderr, "cell must be 2^n\n");
	98	return -1;
	99	}
	100	cell_log = i;
1db5e2ec	101	} else if (matches(*argv, "avpkt") == 0) {
aba5acdf SH	102	NEXT_ARG();
	103	if (get_size(&avpkt, *argv)) {
	104	explain1("avpkt");
	105	return -1;
	106	}
1db5e2ec	107	} else if (matches(*argv, "mpu") == 0) {
aba5acdf SH	108	NEXT_ARG();
	109	if (get_size(&mpu, *argv)) {
	110	explain1("mpu");
	111	return -1;
	112	}
1db5e2ec	113	} else if (matches(*argv, "allot") == 0) {
aba5acdf SH	114	NEXT_ARG();
	115	/* Accept and ignore "allot" for backward compatibility */
	116	if (get_size(&allot, *argv)) {
	117	explain1("allot");
	118	return -1;
	119	}
08fd0184 JDB	120	} else if (matches(*argv, "overhead") == 0) {
	121	NEXT_ARG();
	122	if (get_u16(&overhead, *argv, 10)) {
	123	explain1("overhead"); return -1;
	124	}
292f29b4 JDB	125	} else if (matches(*argv, "linklayer") == 0) {
	126	NEXT_ARG();
	127	if (get_linklayer(&linklayer, *argv)) {
	128	explain1("linklayer"); return -1;
	129	}
1db5e2ec	130	} else if (matches(*argv, "help") == 0) {
aba5acdf SH	131	explain();
	132	return -1;
	133	} else {
	134	fprintf(stderr, "What is \"%s\"?\n", *argv);
	135	explain();
	136	return -1;
	137	}
	138	argc--; argv++;
	139	}
	140
	141	/* OK. All options are parsed. */
	142
	143	if (r.rate == 0) {
	144	fprintf(stderr, "CBQ: bandwidth is required parameter.\n");
	145	return -1;
	146	}
	147	if (avpkt == 0) {
	148	fprintf(stderr, "CBQ: \"avpkt\" is required.\n");
	149	return -1;
	150	}
	151	if (allot < (avpkt*3)/2)
	152	allot = (avpkt*3)/2;
	153
d5f46f9c	154	r.mpu = mpu;
08fd0184	155	r.overhead = overhead;
292f29b4	156	if (tc_calc_rtable(&r, rtab, cell_log, allot, linklayer) < 0) {
aba5acdf SH	157	fprintf(stderr, "CBQ: failed to calculate rate table.\n");
	158	return -1;
	159	}
aba5acdf SH	160
	161	if (ewma_log < 0)
	162	ewma_log = TC_CBQ_DEF_EWMA;
	163	lss.ewma_log = ewma_log;
476daa72	164	lss.maxidle = tc_calc_xmittime(r.rate, avpkt);
aba5acdf SH	165	lss.change = TCF_CBQ_LSS_MAXIDLE\|TCF_CBQ_LSS_EWMA\|TCF_CBQ_LSS_AVPKT;
	166	lss.avpkt = avpkt;
	167
034102f2	168	tail = NLMSG_TAIL(n);
aba5acdf SH	169	addattr_l(n, 1024, TCA_OPTIONS, NULL, 0);
	170	addattr_l(n, 1024, TCA_CBQ_RATE, &r, sizeof(r));
	171	addattr_l(n, 1024, TCA_CBQ_LSSOPT, &lss, sizeof(lss));
	172	addattr_l(n, 3024, TCA_CBQ_RTAB, rtab, 1024);
	173	if (show_raw) {
	174	int i;
32a121cb SH	175
32a121cb SH	176	for (i = 0; i < 256; i++)
aba5acdf SH	177	printf("%u ", rtab[i]);
	178	printf("\n");
	179	}
034102f2	180	tail->rta_len = (void ) NLMSG_TAIL(n) - (void ) tail;
aba5acdf SH	181	return 0;
	182	}
	183
927e3cfb	184	static int cbq_parse_class_opt(struct qdisc_util qu, int argc, char argv, struct nlmsghdr n, const char *dev)
aba5acdf	185	{
32a121cb	186	int wrr_ok = 0, fopt_ok = 0;
d17b136f PS	187	struct tc_ratespec r = {};
	188	struct tc_cbq_lssopt lss = {};
	189	struct tc_cbq_wrropt wrr = {};
	190	struct tc_cbq_fopt fopt = {};
aba5acdf	191	__u32 rtab[256];
32a121cb SH	192	unsigned mpu = 0;
	193	int cell_log = -1;
	194	int ewma_log = -1;
	195	unsigned int bndw = 0;
	196	unsigned minburst = 0, maxburst = 0;
	197	unsigned short overhead = 0;
292f29b4	198	unsigned int linklayer = LINKLAYER_ETHERNET; /* Assume ethernet */
aba5acdf SH	199	struct rtattr *tail;
aba5acdf SH	200
aba5acdf	201	while (argc > 0) {
1db5e2ec	202	if (matches(*argv, "rate") == 0) {
aba5acdf	203	NEXT_ARG();
927e3cfb ND	204	if (strchr(*argv, '%')) {
	205	if (get_percent_rate(&r.rate, *argv, dev)) {
	206	explain1("rate");
	207	return -1;
	208	}
	209	} else if (get_rate(&r.rate, *argv)) {
aba5acdf SH	210	explain1("rate");
	211	return -1;
	212	}
1db5e2ec	213	} else if (matches(*argv, "bandwidth") == 0) {
aba5acdf	214	NEXT_ARG();
927e3cfb ND	215	if (strchr(*argv, '%')) {
	216	if (get_percent_rate(&bndw, *argv, dev)) {
	217	explain1("bandwidth");
	218	return -1;
	219	}
	220	} else if (get_rate(&bndw, *argv)) {
aba5acdf SH	221	explain1("bandwidth");
	222	return -1;
	223	}
1db5e2ec	224	} else if (matches(*argv, "minidle") == 0) {
aba5acdf SH	225	NEXT_ARG();
	226	if (get_u32(&lss.minidle, *argv, 0)) {
	227	explain1("minidle");
	228	return -1;
	229	}
	230	lss.change \|= TCF_CBQ_LSS_MINIDLE;
1db5e2ec	231	} else if (matches(*argv, "minburst") == 0) {
aba5acdf SH	232	NEXT_ARG();
	233	if (get_u32(&minburst, *argv, 0)) {
	234	explain1("minburst");
	235	return -1;
	236	}
	237	lss.change \|= TCF_CBQ_LSS_OFFTIME;
1db5e2ec	238	} else if (matches(*argv, "maxburst") == 0) {
aba5acdf SH	239	NEXT_ARG();
	240	if (get_u32(&maxburst, *argv, 0)) {
	241	explain1("maxburst");
	242	return -1;
	243	}
	244	lss.change \|= TCF_CBQ_LSS_MAXIDLE;
1db5e2ec	245	} else if (matches(*argv, "bounded") == 0) {
aba5acdf SH	246	lss.flags \|= TCF_CBQ_LSS_BOUNDED;
aba5acdf SH	247	lss.change \|= TCF_CBQ_LSS_FLAGS;
1db5e2ec	248	} else if (matches(*argv, "borrow") == 0) {
aba5acdf SH	249	lss.flags &= ~TCF_CBQ_LSS_BOUNDED;
aba5acdf SH	250	lss.change \|= TCF_CBQ_LSS_FLAGS;
1db5e2ec	251	} else if (matches(*argv, "isolated") == 0) {
aba5acdf SH	252	lss.flags \|= TCF_CBQ_LSS_ISOLATED;
aba5acdf SH	253	lss.change \|= TCF_CBQ_LSS_FLAGS;
1db5e2ec	254	} else if (matches(*argv, "sharing") == 0) {
aba5acdf SH	255	lss.flags &= ~TCF_CBQ_LSS_ISOLATED;
aba5acdf SH	256	lss.change \|= TCF_CBQ_LSS_FLAGS;
1db5e2ec	257	} else if (matches(*argv, "ewma") == 0) {
aba5acdf	258	NEXT_ARG();
f332d169	259	if (get_integer(&ewma_log, *argv, 0)) {
aba5acdf SH	260	explain1("ewma");
	261	return -1;
	262	}
	263	if (ewma_log > 31) {
	264	fprintf(stderr, "ewma_log must be < 32\n");
	265	return -1;
	266	}
	267	lss.change \|= TCF_CBQ_LSS_EWMA;
1db5e2ec	268	} else if (matches(*argv, "cell") == 0) {
32a121cb	269	unsigned int cell;
aba5acdf	270	int i;
32a121cb	271
aba5acdf SH	272	NEXT_ARG();
	273	if (get_size(&cell, *argv)) {
	274	explain1("cell");
	275	return -1;
	276	}
32a121cb	277	for (i = 0; i < 32; i++)
aba5acdf SH	278	if ((1<<i) == cell)
aba5acdf SH	279	break;
32a121cb	280	if (i >= 32) {
aba5acdf SH	281	fprintf(stderr, "cell must be 2^n\n");
	282	return -1;
	283	}
	284	cell_log = i;
1db5e2ec	285	} else if (matches(*argv, "prio") == 0) {
32a121cb SH	286	unsigned int prio;
32a121cb SH	287
aba5acdf SH	288	NEXT_ARG();
	289	if (get_u32(&prio, *argv, 0)) {
	290	explain1("prio");
	291	return -1;
	292	}
	293	if (prio > TC_CBQ_MAXPRIO) {
	294	fprintf(stderr, "\"prio\" must be number in the range 1...%d\n", TC_CBQ_MAXPRIO);
	295	return -1;
	296	}
	297	wrr.priority = prio;
	298	wrr_ok++;
1db5e2ec	299	} else if (matches(*argv, "allot") == 0) {
aba5acdf SH	300	NEXT_ARG();
	301	if (get_size(&wrr.allot, *argv)) {
	302	explain1("allot");
	303	return -1;
	304	}
1db5e2ec	305	} else if (matches(*argv, "avpkt") == 0) {
aba5acdf SH	306	NEXT_ARG();
	307	if (get_size(&lss.avpkt, *argv)) {
	308	explain1("avpkt");
	309	return -1;
	310	}
	311	lss.change \|= TCF_CBQ_LSS_AVPKT;
1db5e2ec	312	} else if (matches(*argv, "mpu") == 0) {
aba5acdf SH	313	NEXT_ARG();
	314	if (get_size(&mpu, *argv)) {
	315	explain1("mpu");
	316	return -1;
	317	}
1db5e2ec	318	} else if (matches(*argv, "weight") == 0) {
aba5acdf SH	319	NEXT_ARG();
	320	if (get_size(&wrr.weight, *argv)) {
	321	explain1("weight");
	322	return -1;
	323	}
	324	wrr_ok++;
1db5e2ec	325	} else if (matches(*argv, "split") == 0) {
aba5acdf SH	326	NEXT_ARG();
	327	if (get_tc_classid(&fopt.split, *argv)) {
	328	fprintf(stderr, "Invalid split node ID.\n");
8d8de113	329	return -1;
aba5acdf SH	330	}
aba5acdf SH	331	fopt_ok++;
1db5e2ec	332	} else if (matches(*argv, "defmap") == 0) {
aba5acdf	333	int err;
32a121cb	334
aba5acdf SH	335	NEXT_ARG();
	336	err = sscanf(*argv, "%08x/%08x", &fopt.defmap, &fopt.defchange);
	337	if (err < 1) {
	338	fprintf(stderr, "Invalid defmap, should be MASK32[/MASK]\n");
	339	return -1;
	340	}
	341	if (err == 1)
	342	fopt.defchange = ~0;
	343	fopt_ok++;
08fd0184 JDB	344	} else if (matches(*argv, "overhead") == 0) {
	345	NEXT_ARG();
	346	if (get_u16(&overhead, *argv, 10)) {
	347	explain1("overhead"); return -1;
	348	}
292f29b4 JDB	349	} else if (matches(*argv, "linklayer") == 0) {
	350	NEXT_ARG();
	351	if (get_linklayer(&linklayer, *argv)) {
	352	explain1("linklayer"); return -1;
	353	}
1db5e2ec	354	} else if (matches(*argv, "help") == 0) {
aba5acdf SH	355	explain_class();
	356	return -1;
	357	} else {
	358	fprintf(stderr, "What is \"%s\"?\n", *argv);
	359	explain_class();
	360	return -1;
	361	}
	362	argc--; argv++;
	363	}
	364
	365	/* OK. All options are parsed. */
	366
	367	/* 1. Prepare link sharing scheduler parameters */
	368	if (r.rate) {
32a121cb SH	369	unsigned int pktsize = wrr.allot;
32a121cb SH	370
aba5acdf SH	371	if (wrr.allot < (lss.avpkt*3)/2)
aba5acdf SH	372	wrr.allot = (lss.avpkt*3)/2;
d5f46f9c	373	r.mpu = mpu;
08fd0184	374	r.overhead = overhead;
292f29b4	375	if (tc_calc_rtable(&r, rtab, cell_log, pktsize, linklayer) < 0) {
aba5acdf SH	376	fprintf(stderr, "CBQ: failed to calculate rate table.\n");
	377	return -1;
	378	}
aba5acdf SH	379	}
	380	if (ewma_log < 0)
	381	ewma_log = TC_CBQ_DEF_EWMA;
	382	lss.ewma_log = ewma_log;
	383	if (lss.change&(TCF_CBQ_LSS_OFFTIME\|TCF_CBQ_LSS_MAXIDLE)) {
	384	if (lss.avpkt == 0) {
	385	fprintf(stderr, "CBQ: avpkt is required for max/minburst.\n");
	386	return -1;
	387	}
32a121cb	388	if (bndw == 0 \|\| r.rate == 0) {
aba5acdf SH	389	fprintf(stderr, "CBQ: bandwidth&rate are required for max/minburst.\n");
	390	return -1;
	391	}
	392	}
	393	if (wrr.priority == 0 && (n->nlmsg_flags&NLM_F_EXCL)) {
	394	wrr_ok = 1;
	395	wrr.priority = TC_CBQ_MAXPRIO;
	396	if (wrr.allot == 0)
	397	wrr.allot = (lss.avpkt*3)/2;
	398	}
	399	if (wrr_ok) {
	400	if (wrr.weight == 0)
	401	wrr.weight = (wrr.priority == TC_CBQ_MAXPRIO) ? 1 : r.rate;
	402	if (wrr.allot == 0) {
	403	fprintf(stderr, "CBQ: \"allot\" is required to set WRR parameters.\n");
	404	return -1;
	405	}
	406	}
	407	if (lss.change&TCF_CBQ_LSS_MAXIDLE) {
	408	lss.maxidle = tc_cbq_calc_maxidle(bndw, r.rate, lss.avpkt, ewma_log, maxburst);
	409	lss.change \|= TCF_CBQ_LSS_MAXIDLE;
	410	lss.change \|= TCF_CBQ_LSS_EWMA\|TCF_CBQ_LSS_AVPKT;
	411	}
	412	if (lss.change&TCF_CBQ_LSS_OFFTIME) {
	413	lss.offtime = tc_cbq_calc_offtime(bndw, r.rate, lss.avpkt, ewma_log, minburst);
	414	lss.change \|= TCF_CBQ_LSS_OFFTIME;
	415	lss.change \|= TCF_CBQ_LSS_EWMA\|TCF_CBQ_LSS_AVPKT;
	416	}
	417	if (lss.change&TCF_CBQ_LSS_MINIDLE) {
	418	lss.minidle <<= lss.ewma_log;
	419	lss.change \|= TCF_CBQ_LSS_EWMA;
	420	}
	421
034102f2	422	tail = NLMSG_TAIL(n);
aba5acdf SH	423	addattr_l(n, 1024, TCA_OPTIONS, NULL, 0);
	424	if (lss.change) {
	425	lss.change \|= TCF_CBQ_LSS_FLAGS;
	426	addattr_l(n, 1024, TCA_CBQ_LSSOPT, &lss, sizeof(lss));
	427	}
	428	if (wrr_ok)
	429	addattr_l(n, 1024, TCA_CBQ_WRROPT, &wrr, sizeof(wrr));
	430	if (fopt_ok)
	431	addattr_l(n, 1024, TCA_CBQ_FOPT, &fopt, sizeof(fopt));
	432	if (r.rate) {
	433	addattr_l(n, 1024, TCA_CBQ_RATE, &r, sizeof(r));
	434	addattr_l(n, 3024, TCA_CBQ_RTAB, rtab, 1024);
	435	if (show_raw) {
	436	int i;
32a121cb SH	437
32a121cb SH	438	for (i = 0; i < 256; i++)
aba5acdf SH	439	printf("%u ", rtab[i]);
	440	printf("\n");
	441	}
	442	}
034102f2	443	tail->rta_len = (void ) NLMSG_TAIL(n) - (void ) tail;
aba5acdf SH	444	return 0;
	445	}
	446
	447
	448	static int cbq_print_opt(struct qdisc_util qu, FILE f, struct rtattr *opt)
	449	{
	450	struct rtattr *tb[TCA_CBQ_MAX+1];
	451	struct tc_ratespec *r = NULL;
	452	struct tc_cbq_lssopt *lss = NULL;
	453	struct tc_cbq_wrropt *wrr = NULL;
	454	struct tc_cbq_fopt *fopt = NULL;
	455	struct tc_cbq_ovl *ovl = NULL;
3e92ff52	456	unsigned int linklayer;
32a121cb	457
bd29e35d	458	SPRINT_BUF(b1);
3e92ff52	459	SPRINT_BUF(b2);
aba5acdf SH	460
	461	if (opt == NULL)
	462	return 0;
	463
021ed13f	464	parse_rtattr_nested(tb, TCA_CBQ_MAX, opt);
aba5acdf SH	465
	466	if (tb[TCA_CBQ_RATE]) {
	467	if (RTA_PAYLOAD(tb[TCA_CBQ_RATE]) < sizeof(*r))
	468	fprintf(stderr, "CBQ: too short rate opt\n");
	469	else
	470	r = RTA_DATA(tb[TCA_CBQ_RATE]);
	471	}
	472	if (tb[TCA_CBQ_LSSOPT]) {
	473	if (RTA_PAYLOAD(tb[TCA_CBQ_LSSOPT]) < sizeof(*lss))
	474	fprintf(stderr, "CBQ: too short lss opt\n");
	475	else
	476	lss = RTA_DATA(tb[TCA_CBQ_LSSOPT]);
	477	}
	478	if (tb[TCA_CBQ_WRROPT]) {
	479	if (RTA_PAYLOAD(tb[TCA_CBQ_WRROPT]) < sizeof(*wrr))
	480	fprintf(stderr, "CBQ: too short wrr opt\n");
	481	else
	482	wrr = RTA_DATA(tb[TCA_CBQ_WRROPT]);
	483	}
	484	if (tb[TCA_CBQ_FOPT]) {
	485	if (RTA_PAYLOAD(tb[TCA_CBQ_FOPT]) < sizeof(*fopt))
	486	fprintf(stderr, "CBQ: too short fopt\n");
	487	else
	488	fopt = RTA_DATA(tb[TCA_CBQ_FOPT]);
	489	}
	490	if (tb[TCA_CBQ_OVL_STRATEGY]) {
	491	if (RTA_PAYLOAD(tb[TCA_CBQ_OVL_STRATEGY]) < sizeof(*ovl))
	492	fprintf(stderr, "CBQ: too short overlimit strategy %u/%u\n",
32a121cb SH	493	(unsigned int) RTA_PAYLOAD(tb[TCA_CBQ_OVL_STRATEGY]),
32a121cb SH	494	(unsigned int) sizeof(*ovl));
aba5acdf SH	495	else
	496	ovl = RTA_DATA(tb[TCA_CBQ_OVL_STRATEGY]);
	497	}
	498
	499	if (r) {
	500	char buf[64];
32a121cb	501
aba5acdf SH	502	print_rate(buf, sizeof(buf), r->rate);
aba5acdf SH	503	fprintf(f, "rate %s ", buf);
3e92ff52 JDB	504	linklayer = (r->linklayer & TC_LINKLAYER_MASK);
	505	if (linklayer > TC_LINKLAYER_ETHERNET \|\| show_details)
	506	fprintf(f, "linklayer %s ", sprint_linklayer(linklayer, b2));
aba5acdf SH	507	if (show_details) {
	508	fprintf(f, "cell %ub ", 1<<r->cell_log);
	509	if (r->mpu)
	510	fprintf(f, "mpu %ub ", r->mpu);
08fd0184 JDB	511	if (r->overhead)
08fd0184 JDB	512	fprintf(f, "overhead %ub ", r->overhead);
aba5acdf SH	513	}
	514	}
	515	if (lss && lss->flags) {
32a121cb SH	516	int comma = 0;
32a121cb SH	517
aba5acdf SH	518	fprintf(f, "(");
	519	if (lss->flags&TCF_CBQ_LSS_BOUNDED) {
	520	fprintf(f, "bounded");
32a121cb	521	comma = 1;
aba5acdf SH	522	}
	523	if (lss->flags&TCF_CBQ_LSS_ISOLATED) {
	524	if (comma)
	525	fprintf(f, ",");
	526	fprintf(f, "isolated");
	527	}
	528	fprintf(f, ") ");
	529	}
	530	if (wrr) {
	531	if (wrr->priority != TC_CBQ_MAXPRIO)
	532	fprintf(f, "prio %u", wrr->priority);
	533	else
	534	fprintf(f, "prio no-transmit");
	535	if (show_details) {
	536	char buf[64];
32a121cb	537
aba5acdf SH	538	fprintf(f, "/%u ", wrr->cpriority);
	539	if (wrr->weight != 1) {
	540	print_rate(buf, sizeof(buf), wrr->weight);
	541	fprintf(f, "weight %s ", buf);
	542	}
	543	if (wrr->allot)
	544	fprintf(f, "allot %ub ", wrr->allot);
	545	}
	546	}
	547	if (lss && show_details) {
	548	fprintf(f, "\nlevel %u ewma %u avpkt %ub ", lss->level, lss->ewma_log, lss->avpkt);
	549	if (lss->maxidle) {
bd29e35d	550	fprintf(f, "maxidle %s ", sprint_ticks(lss->maxidle>>lss->ewma_log, b1));
aba5acdf SH	551	if (show_raw)
	552	fprintf(f, "[%08x] ", lss->maxidle);
	553	}
32a121cb	554	if (lss->minidle != 0x7fffffff) {
bd29e35d	555	fprintf(f, "minidle %s ", sprint_ticks(lss->minidle>>lss->ewma_log, b1));
aba5acdf SH	556	if (show_raw)
	557	fprintf(f, "[%08x] ", lss->minidle);
	558	}
	559	if (lss->offtime) {
bd29e35d	560	fprintf(f, "offtime %s ", sprint_ticks(lss->offtime, b1));
aba5acdf SH	561	if (show_raw)
	562	fprintf(f, "[%08x] ", lss->offtime);
	563	}
	564	}
	565	if (fopt && show_details) {
	566	char buf[64];
32a121cb	567
aba5acdf SH	568	print_tc_classid(buf, sizeof(buf), fopt->split);
	569	fprintf(f, "\nsplit %s ", buf);
	570	if (fopt->defmap) {
	571	fprintf(f, "defmap %08x", fopt->defmap);
	572	}
	573	}
	574	return 0;
	575	}
	576
	577	static int cbq_print_xstats(struct qdisc_util qu, FILE f, struct rtattr *xstats)
	578	{
	579	struct tc_cbq_xstats *st;
	580
	581	if (xstats == NULL)
	582	return 0;
	583
	584	if (RTA_PAYLOAD(xstats) < sizeof(*st))
	585	return -1;
	586
	587	st = RTA_DATA(xstats);
	588	fprintf(f, " borrowed %u overactions %u avgidle %g undertime %g", st->borrows,
	589	st->overactions, (double)st->avgidle, (double)st->undertime);
	590	return 0;
	591	}
	592
95812b56	593	struct qdisc_util cbq_qdisc_util = {
f2f99e2e SH	594	.id = "cbq",
	595	.parse_qopt = cbq_parse_opt,
	596	.print_qopt = cbq_print_opt,
	597	.print_xstats = cbq_print_xstats,
	598	.parse_copt = cbq_parse_class_opt,
	599	.print_copt = cbq_print_opt,
aba5acdf	600	};