liyujie
2025-08-28 786ff4f4ca2374bdd9177f2e24b503d43e7a3b93
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
/*
 * q_qfq.c    QFQ.
 *
 *        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:    Stephen Hemminger <shemminger@vyatta.com>
 *        Fabio Checconi <fabio@gandalf.sssup.it>
 *
 */
#include <syslog.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"
 
static void explain(void)
{
   fprintf(stderr, "Usage: ... qfq\n");
}
 
static void explain1(const char *arg)
{
   fprintf(stderr, "Illegal \"%s\"\n", arg);
}
 
static void explain_class(void)
{
   fprintf(stderr, "Usage: ... qfq weight NUMBER maxpkt BYTES\n");
}
 
static int qfq_parse_opt(struct qdisc_util *qu, int argc, char **argv,
            struct nlmsghdr *n)
{
   if (argc > 0) {
       if (matches(*argv, "help") != 0)
           fprintf(stderr, "What is \"%s\"?\n", *argv);
       explain();
       return -1;
   }
 
   return 0;
}
 
static int qfq_parse_class_opt(struct qdisc_util *qu, int argc, char **argv,
                  struct nlmsghdr *n)
{
   struct rtattr *tail;
   __u32 tmp;
 
   tail = NLMSG_TAIL(n);
   addattr_l(n, 4096, TCA_OPTIONS, NULL, 0);
 
   while (argc > 0) {
       if (matches(*argv, "weight") == 0) {
           NEXT_ARG();
           if (get_u32(&tmp, *argv, 10)) {
               explain1("weight"); return -1;
           }
           addattr32(n, 4096, TCA_QFQ_WEIGHT, tmp);
       } else if (matches(*argv, "maxpkt") == 0) {
           NEXT_ARG();
           if (get_u32(&tmp, *argv, 10)) {
               explain1("maxpkt"); return -1;
           }
           addattr32(n, 4096, TCA_QFQ_LMAX, tmp);
       } else if (strcmp(*argv, "help") == 0) {
           explain_class();
           return -1;
       } else {
           fprintf(stderr, "What is \"%s\"?\n", *argv);
           explain_class();
           return -1;
       }
       argc--; argv++;
   }
 
   tail->rta_len = (void *)NLMSG_TAIL(n) - (void *)tail;
 
   return 0;
}
 
static int qfq_print_opt(struct qdisc_util *qu, FILE *f, struct rtattr *opt)
{
   struct rtattr *tb[TCA_QFQ_MAX + 1];
 
   if (opt == NULL)
       return 0;
 
   parse_rtattr_nested(tb, TCA_QFQ_MAX, opt);
 
   if (tb[TCA_QFQ_WEIGHT]) {
       fprintf(f, "weight %u ",
           rta_getattr_u32(tb[TCA_QFQ_WEIGHT]));
   }
 
   if (tb[TCA_QFQ_LMAX]) {
       fprintf(f, "maxpkt %u ",
           rta_getattr_u32(tb[TCA_QFQ_LMAX]));
   }
 
   return 0;
}
 
struct qdisc_util qfq_qdisc_util = {
   .id        = "qfq",
   .parse_qopt    = qfq_parse_opt,
   .print_qopt    = qfq_print_opt,
   .parse_copt    = qfq_parse_class_opt,
   .print_copt    = qfq_print_opt,
};