1 #ifndef __NET_SCHED_GENERIC_H
2 #define __NET_SCHED_GENERIC_H
4 #include <linux/netdevice.h>
5 #include <linux/types.h>
6 #include <linux/rcupdate.h>
7 #include <linux/module.h>
8 #include <linux/pkt_sched.h>
9 #include <linux/pkt_cls.h>
10 #include <net/gen_stats.h>
11 #include <net/rtnetlink.h>
18 struct qdisc_rate_table
20 struct tc_ratespec rate
;
22 struct qdisc_rate_table
*next
;
28 __QDISC_STATE_RUNNING
,
32 struct qdisc_size_table
{
33 struct list_head list
;
34 struct tc_sizespec szopts
;
41 int (*enqueue
)(struct sk_buff
*skb
, struct Qdisc
*dev
);
42 struct sk_buff
* (*dequeue
)(struct Qdisc
*dev
);
44 #define TCQ_F_BUILTIN 1
45 #define TCQ_F_THROTTLED 2
46 #define TCQ_F_INGRESS 4
48 struct Qdisc_ops
*ops
;
49 struct qdisc_size_table
*stab
;
54 struct sk_buff
*gso_skb
;
55 struct sk_buff_head q
;
56 struct netdev_queue
*dev_queue
;
57 struct Qdisc
*next_sched
;
58 struct list_head list
;
60 struct gnet_stats_basic bstats
;
61 struct gnet_stats_queue qstats
;
62 struct gnet_stats_rate_est rate_est
;
63 struct rcu_head q_rcu
;
64 int (*reshape_fail
)(struct sk_buff
*skb
,
69 /* This field is deprecated, but it is still used by CBQ
70 * and it will live until better solution will be invented.
72 struct Qdisc
*__parent
;
75 struct Qdisc_class_ops
77 /* Child qdisc manipulation */
78 int (*graft
)(struct Qdisc
*, unsigned long cl
,
79 struct Qdisc
*, struct Qdisc
**);
80 struct Qdisc
* (*leaf
)(struct Qdisc
*, unsigned long cl
);
81 void (*qlen_notify
)(struct Qdisc
*, unsigned long);
83 /* Class manipulation routines */
84 unsigned long (*get
)(struct Qdisc
*, u32 classid
);
85 void (*put
)(struct Qdisc
*, unsigned long);
86 int (*change
)(struct Qdisc
*, u32
, u32
,
87 struct nlattr
**, unsigned long *);
88 int (*delete)(struct Qdisc
*, unsigned long);
89 void (*walk
)(struct Qdisc
*, struct qdisc_walker
* arg
);
91 /* Filter manipulation */
92 struct tcf_proto
** (*tcf_chain
)(struct Qdisc
*, unsigned long);
93 unsigned long (*bind_tcf
)(struct Qdisc
*, unsigned long,
95 void (*unbind_tcf
)(struct Qdisc
*, unsigned long);
97 /* rtnetlink specific */
98 int (*dump
)(struct Qdisc
*, unsigned long,
99 struct sk_buff
*skb
, struct tcmsg
*);
100 int (*dump_stats
)(struct Qdisc
*, unsigned long,
106 struct Qdisc_ops
*next
;
107 const struct Qdisc_class_ops
*cl_ops
;
111 int (*enqueue
)(struct sk_buff
*, struct Qdisc
*);
112 struct sk_buff
* (*dequeue
)(struct Qdisc
*);
113 int (*requeue
)(struct sk_buff
*, struct Qdisc
*);
114 unsigned int (*drop
)(struct Qdisc
*);
116 int (*init
)(struct Qdisc
*, struct nlattr
*arg
);
117 void (*reset
)(struct Qdisc
*);
118 void (*destroy
)(struct Qdisc
*);
119 int (*change
)(struct Qdisc
*, struct nlattr
*arg
);
121 int (*dump
)(struct Qdisc
*, struct sk_buff
*);
122 int (*dump_stats
)(struct Qdisc
*, struct gnet_dump
*);
124 struct module
*owner
;
136 struct tcf_proto_ops
*next
;
139 int (*classify
)(struct sk_buff
*, struct tcf_proto
*,
140 struct tcf_result
*);
141 int (*init
)(struct tcf_proto
*);
142 void (*destroy
)(struct tcf_proto
*);
144 unsigned long (*get
)(struct tcf_proto
*, u32 handle
);
145 void (*put
)(struct tcf_proto
*, unsigned long);
146 int (*change
)(struct tcf_proto
*, unsigned long,
147 u32 handle
, struct nlattr
**,
149 int (*delete)(struct tcf_proto
*, unsigned long);
150 void (*walk
)(struct tcf_proto
*, struct tcf_walker
*arg
);
152 /* rtnetlink specific */
153 int (*dump
)(struct tcf_proto
*, unsigned long,
154 struct sk_buff
*skb
, struct tcmsg
*);
156 struct module
*owner
;
161 /* Fast access part */
162 struct tcf_proto
*next
;
164 int (*classify
)(struct sk_buff
*, struct tcf_proto
*,
165 struct tcf_result
*);
173 struct tcf_proto_ops
*ops
;
176 struct qdisc_skb_cb
{
177 unsigned int pkt_len
;
181 static inline struct qdisc_skb_cb
*qdisc_skb_cb(struct sk_buff
*skb
)
183 return (struct qdisc_skb_cb
*)skb
->cb
;
186 static inline spinlock_t
*qdisc_lock(struct Qdisc
*qdisc
)
188 return &qdisc
->q
.lock
;
191 static inline struct Qdisc
*qdisc_root(struct Qdisc
*qdisc
)
193 return qdisc
->dev_queue
->qdisc
;
196 static inline spinlock_t
*qdisc_root_lock(struct Qdisc
*qdisc
)
198 struct Qdisc
*root
= qdisc_root(qdisc
);
200 return qdisc_lock(root
);
203 static inline struct net_device
*qdisc_dev(struct Qdisc
*qdisc
)
205 return qdisc
->dev_queue
->dev
;
208 static inline void sch_tree_lock(struct Qdisc
*q
)
210 spin_lock_bh(qdisc_root_lock(q
));
213 static inline void sch_tree_unlock(struct Qdisc
*q
)
215 spin_unlock_bh(qdisc_root_lock(q
));
218 #define tcf_tree_lock(tp) sch_tree_lock((tp)->q)
219 #define tcf_tree_unlock(tp) sch_tree_unlock((tp)->q)
221 extern struct Qdisc noop_qdisc
;
222 extern struct Qdisc_ops noop_qdisc_ops
;
224 struct Qdisc_class_common
227 struct hlist_node hnode
;
230 struct Qdisc_class_hash
232 struct hlist_head
*hash
;
233 unsigned int hashsize
;
234 unsigned int hashmask
;
235 unsigned int hashelems
;
238 static inline unsigned int qdisc_class_hash(u32 id
, u32 mask
)
245 static inline struct Qdisc_class_common
*
246 qdisc_class_find(struct Qdisc_class_hash
*hash
, u32 id
)
248 struct Qdisc_class_common
*cl
;
249 struct hlist_node
*n
;
252 h
= qdisc_class_hash(id
, hash
->hashmask
);
253 hlist_for_each_entry(cl
, n
, &hash
->hash
[h
], hnode
) {
254 if (cl
->classid
== id
)
260 extern int qdisc_class_hash_init(struct Qdisc_class_hash
*);
261 extern void qdisc_class_hash_insert(struct Qdisc_class_hash
*, struct Qdisc_class_common
*);
262 extern void qdisc_class_hash_remove(struct Qdisc_class_hash
*, struct Qdisc_class_common
*);
263 extern void qdisc_class_hash_grow(struct Qdisc
*, struct Qdisc_class_hash
*);
264 extern void qdisc_class_hash_destroy(struct Qdisc_class_hash
*);
266 extern void dev_init_scheduler(struct net_device
*dev
);
267 extern void dev_shutdown(struct net_device
*dev
);
268 extern void dev_activate(struct net_device
*dev
);
269 extern void dev_deactivate(struct net_device
*dev
);
270 extern void qdisc_reset(struct Qdisc
*qdisc
);
271 extern void qdisc_destroy(struct Qdisc
*qdisc
);
272 extern void qdisc_tree_decrease_qlen(struct Qdisc
*qdisc
, unsigned int n
);
273 extern struct Qdisc
*qdisc_alloc(struct netdev_queue
*dev_queue
,
274 struct Qdisc_ops
*ops
);
275 extern struct Qdisc
*qdisc_create_dflt(struct net_device
*dev
,
276 struct netdev_queue
*dev_queue
,
277 struct Qdisc_ops
*ops
, u32 parentid
);
278 extern void qdisc_calculate_pkt_len(struct sk_buff
*skb
,
279 struct qdisc_size_table
*stab
);
280 extern void tcf_destroy(struct tcf_proto
*tp
);
281 extern void tcf_destroy_chain(struct tcf_proto
**fl
);
283 /* Reset all TX qdiscs of a device. */
284 static inline void qdisc_reset_all_tx(struct net_device
*dev
)
287 for (i
= 0; i
< dev
->num_tx_queues
; i
++)
288 qdisc_reset(netdev_get_tx_queue(dev
, i
)->qdisc
);
291 /* Are all TX queues of the device empty? */
292 static inline bool qdisc_all_tx_empty(const struct net_device
*dev
)
295 for (i
= 0; i
< dev
->num_tx_queues
; i
++) {
296 struct netdev_queue
*txq
= netdev_get_tx_queue(dev
, i
);
297 const struct Qdisc
*q
= txq
->qdisc
;
305 /* Are any of the TX qdiscs changing? */
306 static inline bool qdisc_tx_changing(struct net_device
*dev
)
309 for (i
= 0; i
< dev
->num_tx_queues
; i
++) {
310 struct netdev_queue
*txq
= netdev_get_tx_queue(dev
, i
);
311 if (txq
->qdisc
!= txq
->qdisc_sleeping
)
317 /* Is the device using the noop qdisc on all queues? */
318 static inline bool qdisc_tx_is_noop(const struct net_device
*dev
)
321 for (i
= 0; i
< dev
->num_tx_queues
; i
++) {
322 struct netdev_queue
*txq
= netdev_get_tx_queue(dev
, i
);
323 if (txq
->qdisc
!= &noop_qdisc
)
329 static inline unsigned int qdisc_pkt_len(struct sk_buff
*skb
)
331 return qdisc_skb_cb(skb
)->pkt_len
;
334 static inline int qdisc_enqueue(struct sk_buff
*skb
, struct Qdisc
*sch
)
336 #ifdef CONFIG_NET_SCHED
338 qdisc_calculate_pkt_len(skb
, sch
->stab
);
340 return sch
->enqueue(skb
, sch
);
343 static inline int qdisc_enqueue_root(struct sk_buff
*skb
, struct Qdisc
*sch
)
345 qdisc_skb_cb(skb
)->pkt_len
= skb
->len
;
346 return qdisc_enqueue(skb
, sch
);
349 static inline int __qdisc_enqueue_tail(struct sk_buff
*skb
, struct Qdisc
*sch
,
350 struct sk_buff_head
*list
)
352 __skb_queue_tail(list
, skb
);
353 sch
->qstats
.backlog
+= qdisc_pkt_len(skb
);
354 sch
->bstats
.bytes
+= qdisc_pkt_len(skb
);
355 sch
->bstats
.packets
++;
357 return NET_XMIT_SUCCESS
;
360 static inline int qdisc_enqueue_tail(struct sk_buff
*skb
, struct Qdisc
*sch
)
362 return __qdisc_enqueue_tail(skb
, sch
, &sch
->q
);
365 static inline struct sk_buff
*__qdisc_dequeue_head(struct Qdisc
*sch
,
366 struct sk_buff_head
*list
)
368 struct sk_buff
*skb
= __skb_dequeue(list
);
370 if (likely(skb
!= NULL
))
371 sch
->qstats
.backlog
-= qdisc_pkt_len(skb
);
376 static inline struct sk_buff
*qdisc_dequeue_head(struct Qdisc
*sch
)
378 return __qdisc_dequeue_head(sch
, &sch
->q
);
381 static inline struct sk_buff
*__qdisc_dequeue_tail(struct Qdisc
*sch
,
382 struct sk_buff_head
*list
)
384 struct sk_buff
*skb
= __skb_dequeue_tail(list
);
386 if (likely(skb
!= NULL
))
387 sch
->qstats
.backlog
-= qdisc_pkt_len(skb
);
392 static inline struct sk_buff
*qdisc_dequeue_tail(struct Qdisc
*sch
)
394 return __qdisc_dequeue_tail(sch
, &sch
->q
);
397 static inline int __qdisc_requeue(struct sk_buff
*skb
, struct Qdisc
*sch
,
398 struct sk_buff_head
*list
)
400 __skb_queue_head(list
, skb
);
401 sch
->qstats
.backlog
+= qdisc_pkt_len(skb
);
402 sch
->qstats
.requeues
++;
404 return NET_XMIT_SUCCESS
;
407 static inline int qdisc_requeue(struct sk_buff
*skb
, struct Qdisc
*sch
)
409 return __qdisc_requeue(skb
, sch
, &sch
->q
);
412 static inline void __qdisc_reset_queue(struct Qdisc
*sch
,
413 struct sk_buff_head
*list
)
416 * We do not know the backlog in bytes of this list, it
417 * is up to the caller to correct it
419 __skb_queue_purge(list
);
422 static inline void qdisc_reset_queue(struct Qdisc
*sch
)
424 __qdisc_reset_queue(sch
, &sch
->q
);
425 sch
->qstats
.backlog
= 0;
428 static inline unsigned int __qdisc_queue_drop(struct Qdisc
*sch
,
429 struct sk_buff_head
*list
)
431 struct sk_buff
*skb
= __qdisc_dequeue_tail(sch
, list
);
433 if (likely(skb
!= NULL
)) {
434 unsigned int len
= qdisc_pkt_len(skb
);
442 static inline unsigned int qdisc_queue_drop(struct Qdisc
*sch
)
444 return __qdisc_queue_drop(sch
, &sch
->q
);
447 static inline int qdisc_drop(struct sk_buff
*skb
, struct Qdisc
*sch
)
452 return NET_XMIT_DROP
;
455 static inline int qdisc_reshape_fail(struct sk_buff
*skb
, struct Qdisc
*sch
)
459 #ifdef CONFIG_NET_CLS_ACT
460 if (sch
->reshape_fail
== NULL
|| sch
->reshape_fail(skb
, sch
))
463 return NET_XMIT_SUCCESS
;
468 return NET_XMIT_DROP
;
471 /* Length to Time (L2T) lookup in a qdisc_rate_table, to determine how
472 long it will take to send a packet given its size.
474 static inline u32
qdisc_l2t(struct qdisc_rate_table
* rtab
, unsigned int pktlen
)
476 int slot
= pktlen
+ rtab
->rate
.cell_align
+ rtab
->rate
.overhead
;
479 slot
>>= rtab
->rate
.cell_log
;
481 return (rtab
->data
[255]*(slot
>> 8) + rtab
->data
[slot
& 0xFF]);
482 return rtab
->data
[slot
];
485 #ifdef CONFIG_NET_CLS_ACT
486 static inline struct sk_buff
*skb_act_clone(struct sk_buff
*skb
, gfp_t gfp_mask
)
488 struct sk_buff
*n
= skb_clone(skb
, gfp_mask
);
491 n
->tc_verd
= SET_TC_VERD(n
->tc_verd
, 0);
492 n
->tc_verd
= CLR_TC_OK2MUNGE(n
->tc_verd
);
493 n
->tc_verd
= CLR_TC_MUNGED(n
->tc_verd
);