32 #include <netlink-local.h> 33 #include <netlink-tc.h> 34 #include <netlink/netlink.h> 35 #include <netlink/route/qdisc.h> 36 #include <netlink/route/qdisc-modules.h> 37 #include <netlink/route/sch/fifo.h> 38 #include <netlink/utils.h> 41 #define SCH_FIFO_ATTR_LIMIT 1 44 static inline struct rtnl_fifo *fifo_qdisc(
struct rtnl_qdisc *qdisc)
46 return (
struct rtnl_fifo *) qdisc->q_subdata;
49 static inline struct rtnl_fifo *fifo_alloc(
struct rtnl_qdisc *qdisc)
51 if (!qdisc->q_subdata)
52 qdisc->q_subdata = calloc(1,
sizeof(
struct rtnl_fifo));
54 return fifo_qdisc(qdisc);
57 static int fifo_msg_parser(
struct rtnl_qdisc *qdisc)
59 struct rtnl_fifo *fifo;
60 struct tc_fifo_qopt *opt;
62 if (qdisc->q_opts->d_size <
sizeof(
struct tc_fifo_qopt))
63 return nl_error(EINVAL,
"FIFO options size mismatch");
65 fifo = fifo_alloc(qdisc);
67 return nl_errno(ENOMEM);
69 opt = (
struct tc_fifo_qopt *) qdisc->q_opts->d_data;
70 fifo->qf_limit = opt->limit;
71 fifo->qf_mask = SCH_FIFO_ATTR_LIMIT;
76 static void fifo_free_data(
struct rtnl_qdisc *qdisc)
78 free(qdisc->q_subdata);
81 static int pfifo_dump_brief(
struct rtnl_qdisc *qdisc,
84 struct rtnl_fifo *fifo = fifo_qdisc(qdisc);
87 dp_dump(p,
" limit %u packets", fifo->qf_limit);
92 static int bfifo_dump_brief(
struct rtnl_qdisc *qdisc,
95 struct rtnl_fifo *fifo = fifo_qdisc(qdisc);
102 dp_dump(p,
" limit %.1f%s", r, unit);
108 static struct nl_msg *fifo_get_opts(
struct rtnl_qdisc *qdisc)
110 struct rtnl_fifo *fifo;
111 struct tc_fifo_qopt opts;
114 fifo = fifo_qdisc(qdisc);
115 if (!fifo || !(fifo->qf_mask & SCH_FIFO_ATTR_LIMIT))
122 memset(&opts, 0,
sizeof(opts));
123 opts.limit = fifo->qf_limit;
125 if (
nlmsg_append(msg, &opts,
sizeof(opts), NL_DONTPAD) < 0)
147 struct rtnl_fifo *fifo;
149 fifo = fifo_alloc(qdisc);
151 return nl_errno(ENOMEM);
153 fifo->qf_limit = limit;
154 fifo->qf_mask |= SCH_FIFO_ATTR_LIMIT;
166 struct rtnl_fifo *fifo;
168 fifo = fifo_qdisc(qdisc);
169 if (fifo && fifo->qf_mask & SCH_FIFO_ATTR_LIMIT)
170 return fifo->qf_limit;
172 return nl_errno(ENOMEM);
179 .qo_msg_parser = fifo_msg_parser,
180 .qo_free_data = fifo_free_data,
182 .qo_get_opts = fifo_get_opts,
187 .qo_msg_parser = fifo_msg_parser,
188 .qo_free_data = fifo_free_data,
190 .qo_get_opts = fifo_get_opts,
193 static void __init fifo_init(
void)
199 static void __exit fifo_exit(
void)
Dump object in a brief one-liner.
char qo_kind[32]
Kind/Name of Qdisc.
int rtnl_qdisc_fifo_set_limit(struct rtnl_qdisc *qdisc, int limit)
Set limit of FIFO qdisc.
int rtnl_qdisc_unregister(struct rtnl_qdisc_ops *qops)
Unregister a qdisc module.
struct nl_msg * nlmsg_alloc(void)
Allocate a new netlink message with the default maximum payload size.
void nlmsg_free(struct nl_msg *n)
Free a netlink message.
double nl_cancel_down_bytes(unsigned long long l, char **unit)
Cancel down a byte counter.
int nlmsg_append(struct nl_msg *n, void *data, size_t len, int pad)
Append data to tail of a netlink message.
int rtnl_qdisc_register(struct rtnl_qdisc_ops *qops)
Register a qdisc module.
int rtnl_qdisc_fifo_get_limit(struct rtnl_qdisc *qdisc)
Get limit of a FIFO qdisc.