choke: support TCA_CHOKE_MAX_P
TCA_CHOKE_MAX_P permits to express high resolution RED probability. tc qdisc add dev $DEV parent 1:1 handle 10: est 1sec 8sec choke \ limit 90 ecn min 10 max 30 probability 0.05 bandwidth 10Mbit Before patch : tc -s -d qdisc show dev eth3 qdisc ... limit 90p min 10p max 30p ecn ewma 3 Plog 19 Scell_log 13 After : qdisc ... limit 90p min 10p max 30p ecn ewma 3 probability 0.05 Scell_log 13 Signed-off-by: Eric Dumazet <eric.dumazet@gmail.com>
This commit is contained in:
parent
6987ecf083
commit
650252d8c3
20
tc/q_choke.c
20
tc/q_choke.c
|
|
@ -18,6 +18,7 @@
|
||||||
#include <netinet/in.h>
|
#include <netinet/in.h>
|
||||||
#include <arpa/inet.h>
|
#include <arpa/inet.h>
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
|
#include <math.h>
|
||||||
|
|
||||||
#include "utils.h"
|
#include "utils.h"
|
||||||
#include "tc_util.h"
|
#include "tc_util.h"
|
||||||
|
|
@ -41,6 +42,7 @@ static int choke_parse_opt(struct qdisc_util *qu, int argc, char **argv,
|
||||||
int ecn_ok = 0;
|
int ecn_ok = 0;
|
||||||
int wlog;
|
int wlog;
|
||||||
__u8 sbuf[256];
|
__u8 sbuf[256];
|
||||||
|
__u32 max_P;
|
||||||
struct rtattr *tail;
|
struct rtattr *tail;
|
||||||
|
|
||||||
memset(&opt, 0, sizeof(opt));
|
memset(&opt, 0, sizeof(opt));
|
||||||
|
|
@ -156,25 +158,31 @@ static int choke_parse_opt(struct qdisc_util *qu, int argc, char **argv,
|
||||||
addattr_l(n, 1024, TCA_OPTIONS, NULL, 0);
|
addattr_l(n, 1024, TCA_OPTIONS, NULL, 0);
|
||||||
addattr_l(n, 1024, TCA_CHOKE_PARMS, &opt, sizeof(opt));
|
addattr_l(n, 1024, TCA_CHOKE_PARMS, &opt, sizeof(opt));
|
||||||
addattr_l(n, 1024, TCA_CHOKE_STAB, sbuf, 256);
|
addattr_l(n, 1024, TCA_CHOKE_STAB, sbuf, 256);
|
||||||
|
max_P = probability * pow(2, 32);
|
||||||
|
addattr_l(n, 1024, TCA_CHOKE_MAX_P, &max_P, sizeof(max_P));
|
||||||
tail->rta_len = (void *) NLMSG_TAIL(n) - (void *) tail;
|
tail->rta_len = (void *) NLMSG_TAIL(n) - (void *) tail;
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
static int choke_print_opt(struct qdisc_util *qu, FILE *f, struct rtattr *opt)
|
static int choke_print_opt(struct qdisc_util *qu, FILE *f, struct rtattr *opt)
|
||||||
{
|
{
|
||||||
struct rtattr *tb[TCA_CHOKE_STAB+1];
|
struct rtattr *tb[TCA_CHOKE_MAX+1];
|
||||||
const struct tc_red_qopt *qopt;
|
const struct tc_red_qopt *qopt;
|
||||||
|
__u32 max_P = 0;
|
||||||
|
|
||||||
if (opt == NULL)
|
if (opt == NULL)
|
||||||
return 0;
|
return 0;
|
||||||
|
|
||||||
parse_rtattr_nested(tb, TCA_CHOKE_STAB, opt);
|
parse_rtattr_nested(tb, TCA_CHOKE_MAX, opt);
|
||||||
|
|
||||||
if (tb[TCA_CHOKE_PARMS] == NULL)
|
if (tb[TCA_CHOKE_PARMS] == NULL)
|
||||||
return -1;
|
return -1;
|
||||||
qopt = RTA_DATA(tb[TCA_CHOKE_PARMS]);
|
qopt = RTA_DATA(tb[TCA_CHOKE_PARMS]);
|
||||||
if (RTA_PAYLOAD(tb[TCA_CHOKE_PARMS]) < sizeof(*qopt))
|
if (RTA_PAYLOAD(tb[TCA_CHOKE_PARMS]) < sizeof(*qopt))
|
||||||
return -1;
|
return -1;
|
||||||
|
if (tb[TCA_CHOKE_MAX_P] &&
|
||||||
|
RTA_PAYLOAD(tb[TCA_CHOKE_MAX_P]) >= sizeof(__u32))
|
||||||
|
max_P = *(__u32 *)RTA_DATA(tb[TCA_CHOKE_MAX_P]);
|
||||||
|
|
||||||
fprintf(f, "limit %up min %up max %up ",
|
fprintf(f, "limit %up min %up max %up ",
|
||||||
qopt->limit, qopt->qth_min, qopt->qth_max);
|
qopt->limit, qopt->qth_min, qopt->qth_max);
|
||||||
|
|
@ -183,8 +191,12 @@ static int choke_print_opt(struct qdisc_util *qu, FILE *f, struct rtattr *opt)
|
||||||
fprintf(f, "ecn ");
|
fprintf(f, "ecn ");
|
||||||
|
|
||||||
if (show_details) {
|
if (show_details) {
|
||||||
fprintf(f, "ewma %u Plog %u Scell_log %u",
|
fprintf(f, "ewma %u ", qopt->Wlog);
|
||||||
qopt->Wlog, qopt->Plog, qopt->Scell_log);
|
if (max_P)
|
||||||
|
fprintf(f, "probability %g ", max_P / pow(2, 32));
|
||||||
|
else
|
||||||
|
fprintf(f, "Plog %u ", qopt->Plog);
|
||||||
|
fprintf(f, "Scell_log %u", qopt->Scell_log);
|
||||||
}
|
}
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue