CoDel AQM discussions
 help / color / mirror / Atom feed
* [Codel] [PATCH 1/2] codel: Controlled Delay AQM
@ 2012-05-05 19:32 Dave Taht
  2012-05-05 19:32 ` [Codel] [PATCH 2/2] codel: RED is dead Dave Taht
                   ` (2 more replies)
  0 siblings, 3 replies; 32+ messages in thread
From: Dave Taht @ 2012-05-05 19:32 UTC (permalink / raw)
  To: codel; +Cc: Eric Dumazet, Dave Täht

From: Dave Täht <dave.taht@bufferbloat.net>

tc qdisc ... codel [ limit PACKETS ] [ target TIME]
		   [ interval TIME ] [ minbytes BYTES ]

Signed-off-by: Eric Dumazet <edumazet@google.com>
Signed-off-by: Dave Täht <dave.taht@bufferbloat.net>
---
 include/linux/pkt_sched.h |   14 +++++
 tc/Makefile               |    1 +
 tc/q_codel.c              |  136 +++++++++++++++++++++++++++++++++++++++++++++
 3 files changed, 151 insertions(+)
 create mode 100644 tc/q_codel.c

diff --git a/include/linux/pkt_sched.h b/include/linux/pkt_sched.h
index 410b33d..62a73bf 100644
--- a/include/linux/pkt_sched.h
+++ b/include/linux/pkt_sched.h
@@ -509,6 +509,7 @@ enum {
 	TCA_NETEM_CORRUPT,
 	TCA_NETEM_LOSS,
 	TCA_NETEM_RATE,
+	TCA_NETEM_ECN,
 	__TCA_NETEM_MAX,
 };
 
@@ -654,4 +655,17 @@ struct tc_qfq_stats {
 	__u32 lmax;
 };
 
+/* CODEL */
+
+enum {
+	TCA_CODEL_UNSPEC,
+	TCA_CODEL_TARGET,
+	TCA_CODEL_LIMIT,
+	TCA_CODEL_MINBYTES,
+	TCA_CODEL_INTERVAL,
+	__TCA_CODEL_MAX
+};
+
+#define TCA_CODEL_MAX	(__TCA_CODEL_MAX - 1)
+
 #endif
diff --git a/tc/Makefile b/tc/Makefile
index be8cd5a..8a7cc8d 100644
--- a/tc/Makefile
+++ b/tc/Makefile
@@ -47,6 +47,7 @@ TCMODULES += em_cmp.o
 TCMODULES += em_u32.o
 TCMODULES += em_meta.o
 TCMODULES += q_mqprio.o
+TCMODULES += q_codel.o
 
 TCSO :=
 ifeq ($(TC_CONFIG_ATM),y)
diff --git a/tc/q_codel.c b/tc/q_codel.c
new file mode 100644
index 0000000..0a7cf9f
--- /dev/null
+++ b/tc/q_codel.c
@@ -0,0 +1,136 @@
+/*
+ * q_codel.c		Codel.
+ *
+ *		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:	Eric Dumazet <edumazet@google.com>
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <syslog.h>
+#include <fcntl.h>
+#include <sys/socket.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <string.h>
+#include <math.h>
+
+#include "utils.h"
+#include "tc_util.h"
+
+static void explain(void)
+{
+	fprintf(stderr, "Usage: ... codel [ limit PACKETS ] [ target TIME]\n");
+	fprintf(stderr, "                 [ interval TIME ] [ minbytes BYTES ]\n");
+}
+
+static int codel_parse_opt(struct qdisc_util *qu, int argc, char **argv,
+			   struct nlmsghdr *n)
+{
+	struct tc_red_qopt opt;
+	unsigned limit = 0;
+	unsigned target = 0;
+	unsigned interval = 0;
+	unsigned minbytes = 0;
+	struct rtattr *tail;
+
+	while (argc > 0) {
+		if (strcmp(*argv, "limit") == 0) {
+			NEXT_ARG();
+			if (get_unsigned(&limit, *argv, 0)) {
+				fprintf(stderr, "Illegal \"limit\"\n");
+				return -1;
+			}
+		} else if (strcmp(*argv, "minbytes") == 0) {
+			NEXT_ARG();
+			if (get_unsigned(&minbytes, *argv, 0)) {
+				fprintf(stderr, "Illegal \"minbytes\"\n");
+				return -1;
+			}
+		} else if (strcmp(*argv, "target") == 0) {
+			NEXT_ARG();
+			if (get_time(&target, *argv)) {
+				fprintf(stderr, "Illegal \"target\"\n");
+				return -1;
+			}
+		} else if (strcmp(*argv, "interval") == 0) {
+			NEXT_ARG();
+			if (get_time(&interval, *argv)) {
+				fprintf(stderr, "Illegal \"interval\"\n");
+				return -1;
+			}
+		} else if (strcmp(*argv, "help") == 0) {
+			explain();
+			return -1;
+		} else {
+			fprintf(stderr, "What is \"%s\"?\n", *argv);
+			explain();
+			return -1;
+		}
+		argc--; argv++;
+	}
+
+	tail = NLMSG_TAIL(n);
+	addattr_l(n, 1024, TCA_OPTIONS, NULL, 0);
+
+	if (limit)
+		addattr_l(n, 1024, TCA_CODEL_LIMIT, &limit, sizeof(limit));
+	if (minbytes)
+		addattr_l(n, 1024, TCA_CODEL_MINBYTES, &minbytes, sizeof(minbytes));
+	if (interval)
+		addattr_l(n, 1024, TCA_CODEL_INTERVAL, &interval, sizeof(interval));
+	if (target)
+		addattr_l(n, 1024, TCA_CODEL_TARGET, &target, sizeof(target));
+	tail->rta_len = (void *) NLMSG_TAIL(n) - (void *) tail;
+	return 0;
+}
+
+static int codel_print_opt(struct qdisc_util *qu, FILE *f, struct rtattr *opt)
+{
+	struct rtattr *tb[TCA_CODEL_MAX + 1];
+	unsigned limit;
+	unsigned interval;
+	unsigned target;
+	unsigned minbytes;
+	SPRINT_BUF(b1);
+
+	if (opt == NULL)
+		return 0;
+
+	parse_rtattr_nested(tb, TCA_CODEL_MAX, opt);
+
+	if (tb[TCA_CODEL_LIMIT] &&
+	    RTA_PAYLOAD(tb[TCA_CODEL_LIMIT]) >= sizeof(__u32)) {
+		limit = rta_getattr_u32(tb[TCA_CODEL_LIMIT]);
+		fprintf(f, "limit %up ", limit);
+	}
+	if (tb[TCA_CODEL_MINBYTES] &&
+	    RTA_PAYLOAD(tb[TCA_CODEL_MINBYTES]) >= sizeof(__u32)) {
+		minbytes = rta_getattr_u32(tb[TCA_CODEL_MINBYTES]);
+		fprintf(f, "minbytes %u ", minbytes);
+	}
+	if (tb[TCA_CODEL_TARGET] &&
+	    RTA_PAYLOAD(tb[TCA_CODEL_TARGET]) >= sizeof(__u32)) {
+		target = rta_getattr_u32(tb[TCA_CODEL_TARGET]);
+		fprintf(f, "target %s ", sprint_time(target, b1));
+	}
+	if (tb[TCA_CODEL_INTERVAL] &&
+	    RTA_PAYLOAD(tb[TCA_CODEL_INTERVAL]) >= sizeof(__u32)) {
+		interval = rta_getattr_u32(tb[TCA_CODEL_INTERVAL]);
+		fprintf(f, "interval %s ", sprint_time(interval, b1));
+	}
+
+	return 0;
+}
+
+
+struct qdisc_util codel_qdisc_util = {
+	.id		= "codel",
+	.parse_qopt	= codel_parse_opt,
+	.print_qopt	= codel_print_opt,
+};
-- 
1.7.9.5


^ permalink raw reply	[flat|nested] 32+ messages in thread

end of thread, other threads:[~2012-05-08 14:04 UTC | newest]

Thread overview: 32+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2012-05-05 19:32 [Codel] [PATCH 1/2] codel: Controlled Delay AQM Dave Taht
2012-05-05 19:32 ` [Codel] [PATCH 2/2] codel: RED is dead Dave Taht
2012-05-05 19:47 ` [Codel] [PATCH 1/2] codel: Controlled Delay AQM Dave Taht
2012-05-05 20:05   ` Eric Dumazet
2012-05-07 16:43 ` Rick Jones
2012-05-07 17:10   ` Eric Dumazet
2012-05-07 17:18     ` Dave Taht
2012-05-07 17:27     ` Rick Jones
2012-05-07 17:34       ` Eric Dumazet
2012-05-07 17:52         ` Dave Taht
2012-05-07 18:01           ` Eric Dumazet
2012-05-07 18:09             ` Eric Dumazet
2012-05-07 18:15               ` Eric Dumazet
2012-05-07 18:32           ` Jim Gettys
2012-05-07 18:44             ` Dave Taht
2012-05-07 18:50               ` Jim Gettys
2012-05-07 19:16                 ` Eric Dumazet
2012-05-07 19:36                   ` Jim Gettys
2012-05-07 20:03                     ` Eric Dumazet
2012-05-07 20:55                       ` dave taht
2012-05-08  1:15                       ` Jim Gettys
2012-05-08  1:20                         ` Andrew McGregor
2012-05-08  1:45                           ` Jim Gettys
2012-05-08  2:16                             ` Rick Jones
2012-05-08  3:14                               ` Jim Gettys
2012-05-08  3:32                                 ` Rick Jones
2012-05-08  3:40                                   ` Kathleen Nichols
2012-05-08  4:14                                   ` Jim Gettys
2012-05-08  5:10                                     ` Eric Dumazet
2012-05-08 10:25                                       ` Jim Gettys
2012-05-08 13:57                                         ` Kathleen Nichols
2012-05-08 14:04                                           ` Jim Gettys

This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox