14#include "nl-default.h"
16#include <netlink/netlink.h>
17#include <netlink/route/qdisc.h>
18#include <netlink/route/qdisc/fq_codel.h>
19#include <netlink/utils.h>
34#define SCH_FQ_CODEL_ATTR_TARGET 0x1
35#define SCH_FQ_CODEL_ATTR_LIMIT 0x2
36#define SCH_FQ_CODEL_ATTR_INTERVAL 0x4
37#define SCH_FQ_CODEL_ATTR_FLOWS 0x8
38#define SCH_FQ_CODEL_ATTR_QUANTUM 0x10
39#define SCH_FQ_CODEL_ATTR_ECN 0x20
42static struct nla_policy fq_codel_policy[TCA_FQ_CODEL_MAX + 1] = {
44 [TCA_FQ_CODEL_LIMIT] = { .type =
NLA_U32 },
45 [TCA_FQ_CODEL_INTERVAL] = { .type =
NLA_U32 },
46 [TCA_FQ_CODEL_ECN] = { .type =
NLA_U32 },
47 [TCA_FQ_CODEL_FLOWS] = { .type =
NLA_U32 },
48 [TCA_FQ_CODEL_QUANTUM] = { .type =
NLA_U32 },
51static int fq_codel_msg_parser(
struct rtnl_tc *tc,
void *data)
53 struct rtnl_fq_codel *fq_codel = data;
54 struct nlattr *tb[TCA_FQ_CODEL_MAX + 1];
57 err = tca_parse(tb, TCA_FQ_CODEL_MAX, tc, fq_codel_policy);
61 if (tb[TCA_FQ_CODEL_TARGET]) {
62 fq_codel->fq_target =
nla_get_u32(tb[TCA_FQ_CODEL_TARGET]);
63 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_TARGET;
66 if (tb[TCA_FQ_CODEL_INTERVAL]) {
67 fq_codel->fq_interval =
nla_get_u32(tb[TCA_FQ_CODEL_INTERVAL]);
68 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_INTERVAL;
71 if (tb[TCA_FQ_CODEL_LIMIT]) {
72 fq_codel->fq_limit =
nla_get_u32(tb[TCA_FQ_CODEL_LIMIT]);
73 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_LIMIT;
76 if (tb[TCA_FQ_CODEL_QUANTUM]) {
77 fq_codel->fq_quantum =
nla_get_u32(tb[TCA_FQ_CODEL_QUANTUM]);
78 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_QUANTUM;
81 if (tb[TCA_FQ_CODEL_FLOWS]) {
82 fq_codel->fq_flows =
nla_get_u32(tb[TCA_FQ_CODEL_FLOWS]);
83 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_FLOWS;
86 if (tb[TCA_FQ_CODEL_ECN]) {
87 fq_codel->fq_ecn =
nla_get_u32(tb[TCA_FQ_CODEL_ECN]);
88 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_ECN;
94static void fq_codel_dump_line(
struct rtnl_tc *tc,
void *data,
97 struct rtnl_fq_codel *fq_codel = data;
102 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_LIMIT)
103 nl_dump(p,
" limit %u packets", fq_codel->fq_limit);
104 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_TARGET)
105 nl_dump(p,
" target %u", fq_codel->fq_target);
106 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_INTERVAL)
107 nl_dump(p,
" interval %u", fq_codel->fq_interval);
108 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_ECN)
109 nl_dump(p,
" ecn %u", fq_codel->fq_ecn);
110 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_FLOWS)
111 nl_dump(p,
" flows %u", fq_codel->fq_flows);
112 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_QUANTUM)
113 nl_dump(p,
" quantum %u", fq_codel->fq_quantum);
116static int fq_codel_msg_fill(
struct rtnl_tc *tc,
void *data,
struct nl_msg *msg)
118 struct rtnl_fq_codel *fq_codel = data;
123 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_LIMIT)
124 NLA_PUT_U32(msg, TCA_FQ_CODEL_LIMIT, fq_codel->fq_limit);
125 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_INTERVAL)
126 NLA_PUT_U32(msg, TCA_FQ_CODEL_INTERVAL, fq_codel->fq_interval);
127 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_TARGET)
128 NLA_PUT_U32(msg, TCA_FQ_CODEL_TARGET, fq_codel->fq_target);
129 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_QUANTUM)
130 NLA_PUT_U32(msg, TCA_FQ_CODEL_QUANTUM, fq_codel->fq_quantum);
131 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_FLOWS)
132 NLA_PUT_U32(msg, TCA_FQ_CODEL_FLOWS, fq_codel->fq_flows);
133 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_ECN)
134 NLA_PUT_U32(msg, TCA_FQ_CODEL_ECN, fq_codel->fq_ecn);
155 struct rtnl_fq_codel *fq_codel;
160 fq_codel->fq_limit = limit;
161 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_LIMIT;
173 struct rtnl_fq_codel *fq_codel;
178 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_LIMIT)
179 return fq_codel->fq_limit;
192 struct rtnl_fq_codel *fq_codel;
197 fq_codel->fq_target = target;
198 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_TARGET;
210 struct rtnl_fq_codel *fq_codel;
213 fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_TARGET)
214 return fq_codel->fq_target;
227 struct rtnl_fq_codel *fq_codel;
232 fq_codel->fq_interval = interval;
233 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_INTERVAL;
245 struct rtnl_fq_codel *fq_codel;
248 fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_INTERVAL)
249 return fq_codel->fq_interval;
262 struct rtnl_fq_codel *fq_codel;
267 fq_codel->fq_quantum = quantum;
268 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_QUANTUM;
280 struct rtnl_fq_codel *fq_codel;
283 (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_QUANTUM))
284 return fq_codel->fq_quantum;
297 struct rtnl_fq_codel *fq_codel;
302 fq_codel->fq_flows = flows;
303 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_FLOWS;
315 struct rtnl_fq_codel *fq_codel;
320 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_FLOWS)
321 return fq_codel->fq_flows;
333 struct rtnl_fq_codel *fq_codel;
338 fq_codel->fq_ecn = ecn;
339 fq_codel->fq_mask |= SCH_FQ_CODEL_ATTR_ECN;
351 struct rtnl_fq_codel *fq_codel;
356 if (fq_codel->fq_mask & SCH_FQ_CODEL_ATTR_ECN)
357 return fq_codel->fq_ecn;
363static struct rtnl_tc_ops fq_codel_ops = {
364 .to_kind =
"fq_codel",
365 .to_type = RTNL_TC_TYPE_QDISC,
366 .to_size =
sizeof(
struct rtnl_fq_codel),
367 .to_msg_parser = fq_codel_msg_parser,
369 .to_msg_fill = fq_codel_msg_fill,
372static void _nl_init fq_codel_init(
void)
377static void _nl_exit fq_codel_exit(
void)
uint32_t nla_get_u32(const struct nlattr *nla)
Return payload of 32 bit integer attribute.
#define NLA_PUT_U32(msg, attrtype, value)
Add 32 bit integer attribute to netlink message.
int rtnl_qdisc_fq_codel_get_ecn(struct rtnl_qdisc *qdisc)
Get ecn of a fq_codel qdisc.
int rtnl_qdisc_fq_codel_get_flows(struct rtnl_qdisc *qdisc)
Get flows of a fq_codel qdisc.
int rtnl_qdisc_fq_codel_set_target(struct rtnl_qdisc *qdisc, uint32_t target)
Set target of fq_codel qdisc.
uint32_t rtnl_qdisc_fq_codel_get_target(struct rtnl_qdisc *qdisc)
Get target of a fq_codel qdisc.
int rtnl_qdisc_fq_codel_set_interval(struct rtnl_qdisc *qdisc, uint32_t interval)
Set interval of fq_codel qdisc.
int rtnl_qdisc_fq_codel_set_flows(struct rtnl_qdisc *qdisc, int flows)
Set flows of fq_codel qdisc.
int rtnl_qdisc_fq_codel_set_quantum(struct rtnl_qdisc *qdisc, uint32_t quantum)
Set quantum of fq_codel qdisc.
uint32_t rtnl_qdisc_fq_codel_get_quantum(struct rtnl_qdisc *qdisc)
Get quantum of a fq_codel qdisc.
int rtnl_qdisc_fq_codel_set_ecn(struct rtnl_qdisc *qdisc, int ecn)
Set ecn of fq_codel qdisc.
int rtnl_qdisc_fq_codel_set_limit(struct rtnl_qdisc *qdisc, int limit)
Set limit of fq_codel qdisc.
uint32_t rtnl_qdisc_fq_codel_get_interval(struct rtnl_qdisc *qdisc)
Get target of a fq_codel qdisc.
int rtnl_qdisc_fq_codel_get_limit(struct rtnl_qdisc *qdisc)
Get limit of a fq_codel qdisc.
#define TC_CAST(ptr)
Macro to cast qdisc/class/classifier to tc object.
void * rtnl_tc_data(struct rtnl_tc *)
Return pointer to private data of traffic control object.
int rtnl_tc_register(struct rtnl_tc_ops *)
Register a traffic control module.
void rtnl_tc_unregister(struct rtnl_tc_ops *)
Unregister a traffic control module.
void nl_dump(struct nl_dump_params *params, const char *fmt,...)
Dump a formatted character string.
@ NL_DUMP_LINE
Dump object briefly on one line.
Attribute validation policy.
uint16_t type
Type of attribute or NLA_UNSPEC.