]> git.proxmox.com Git - mirror_ubuntu-jammy-kernel.git/blame - include/net/sch_generic.h
Merge branch 'sfc-2.6.39' of git://git.kernel.org/pub/scm/linux/kernel/git/bwh/sfc-2.6
[mirror_ubuntu-jammy-kernel.git] / include / net / sch_generic.h
CommitLineData
1da177e4
LT
1#ifndef __NET_SCHED_GENERIC_H
2#define __NET_SCHED_GENERIC_H
3
1da177e4
LT
4#include <linux/netdevice.h>
5#include <linux/types.h>
6#include <linux/rcupdate.h>
7#include <linux/module.h>
1da177e4
LT
8#include <linux/pkt_sched.h>
9#include <linux/pkt_cls.h>
10#include <net/gen_stats.h>
be577ddc 11#include <net/rtnetlink.h>
1da177e4
LT
12
13struct Qdisc_ops;
14struct qdisc_walker;
15struct tcf_walker;
16struct module;
17
fd2c3ef7 18struct qdisc_rate_table {
1da177e4
LT
19 struct tc_ratespec rate;
20 u32 data[256];
21 struct qdisc_rate_table *next;
22 int refcnt;
23};
24
fd2c3ef7 25enum qdisc_state_t {
37437bb2 26 __QDISC_STATE_SCHED,
a9312ae8 27 __QDISC_STATE_DEACTIVATED,
e2627c8c
DM
28};
29
37112105
ED
30/*
31 * following bits are only changed while qdisc lock is held
32 */
33enum qdisc___state_t {
fd245a4a
ED
34 __QDISC___STATE_RUNNING = 1,
35 __QDISC___STATE_THROTTLED = 2,
37112105
ED
36};
37
175f9c1b 38struct qdisc_size_table {
a2da570d 39 struct rcu_head rcu;
175f9c1b
JK
40 struct list_head list;
41 struct tc_sizespec szopts;
42 int refcnt;
43 u16 data[];
44};
45
fd2c3ef7 46struct Qdisc {
1da177e4
LT
47 int (*enqueue)(struct sk_buff *skb, struct Qdisc *dev);
48 struct sk_buff * (*dequeue)(struct Qdisc *dev);
49 unsigned flags;
b00355db 50#define TCQ_F_BUILTIN 1
fd245a4a
ED
51#define TCQ_F_INGRESS 2
52#define TCQ_F_CAN_BYPASS 4
53#define TCQ_F_MQROOT 8
b00355db 54#define TCQ_F_WARN_NONWC (1 << 16)
1da177e4
LT
55 int padded;
56 struct Qdisc_ops *ops;
a2da570d 57 struct qdisc_size_table __rcu *stab;
5e140dfc 58 struct list_head list;
1da177e4
LT
59 u32 handle;
60 u32 parent;
61 atomic_t refcnt;
1da177e4 62 struct gnet_stats_rate_est rate_est;
1da177e4
LT
63 int (*reshape_fail)(struct sk_buff *skb,
64 struct Qdisc *q);
65
72b25a91
DM
66 void *u32_node;
67
1da177e4
LT
68 /* This field is deprecated, but it is still used by CBQ
69 * and it will live until better solution will be invented.
70 */
71 struct Qdisc *__parent;
5e140dfc
ED
72 struct netdev_queue *dev_queue;
73 struct Qdisc *next_sched;
74
75 struct sk_buff *gso_skb;
76 /*
77 * For performance sake on SMP, we put highly modified fields at the end
78 */
79 unsigned long state;
80 struct sk_buff_head q;
c1a8f1f1 81 struct gnet_stats_basic_packed bstats;
fd245a4a 82 unsigned int __state;
5e140dfc 83 struct gnet_stats_queue qstats;
79640a4c
ED
84 struct rcu_head rcu_head;
85 spinlock_t busylock;
d276055c 86 u32 limit;
1da177e4
LT
87};
88
fd245a4a 89static inline bool qdisc_is_running(const struct Qdisc *qdisc)
bc135b23 90{
fd245a4a 91 return (qdisc->__state & __QDISC___STATE_RUNNING) ? true : false;
bc135b23
ED
92}
93
94static inline bool qdisc_run_begin(struct Qdisc *qdisc)
95{
fd245a4a
ED
96 if (qdisc_is_running(qdisc))
97 return false;
98 qdisc->__state |= __QDISC___STATE_RUNNING;
99 return true;
bc135b23
ED
100}
101
102static inline void qdisc_run_end(struct Qdisc *qdisc)
103{
fd245a4a
ED
104 qdisc->__state &= ~__QDISC___STATE_RUNNING;
105}
106
107static inline bool qdisc_is_throttled(const struct Qdisc *qdisc)
108{
109 return (qdisc->__state & __QDISC___STATE_THROTTLED) ? true : false;
110}
111
112static inline void qdisc_throttled(struct Qdisc *qdisc)
113{
114 qdisc->__state |= __QDISC___STATE_THROTTLED;
115}
116
117static inline void qdisc_unthrottled(struct Qdisc *qdisc)
118{
119 qdisc->__state &= ~__QDISC___STATE_THROTTLED;
bc135b23
ED
120}
121
fd2c3ef7 122struct Qdisc_class_ops {
1da177e4 123 /* Child qdisc manipulation */
926e61b7 124 struct netdev_queue * (*select_queue)(struct Qdisc *, struct tcmsg *);
1da177e4
LT
125 int (*graft)(struct Qdisc *, unsigned long cl,
126 struct Qdisc *, struct Qdisc **);
127 struct Qdisc * (*leaf)(struct Qdisc *, unsigned long cl);
43effa1e 128 void (*qlen_notify)(struct Qdisc *, unsigned long);
1da177e4
LT
129
130 /* Class manipulation routines */
131 unsigned long (*get)(struct Qdisc *, u32 classid);
132 void (*put)(struct Qdisc *, unsigned long);
133 int (*change)(struct Qdisc *, u32, u32,
1e90474c 134 struct nlattr **, unsigned long *);
1da177e4
LT
135 int (*delete)(struct Qdisc *, unsigned long);
136 void (*walk)(struct Qdisc *, struct qdisc_walker * arg);
137
138 /* Filter manipulation */
139 struct tcf_proto ** (*tcf_chain)(struct Qdisc *, unsigned long);
140 unsigned long (*bind_tcf)(struct Qdisc *, unsigned long,
141 u32 classid);
142 void (*unbind_tcf)(struct Qdisc *, unsigned long);
143
144 /* rtnetlink specific */
145 int (*dump)(struct Qdisc *, unsigned long,
146 struct sk_buff *skb, struct tcmsg*);
147 int (*dump_stats)(struct Qdisc *, unsigned long,
148 struct gnet_dump *);
149};
150
fd2c3ef7 151struct Qdisc_ops {
1da177e4 152 struct Qdisc_ops *next;
20fea08b 153 const struct Qdisc_class_ops *cl_ops;
1da177e4
LT
154 char id[IFNAMSIZ];
155 int priv_size;
156
157 int (*enqueue)(struct sk_buff *, struct Qdisc *);
158 struct sk_buff * (*dequeue)(struct Qdisc *);
90d841fd 159 struct sk_buff * (*peek)(struct Qdisc *);
1da177e4
LT
160 unsigned int (*drop)(struct Qdisc *);
161
1e90474c 162 int (*init)(struct Qdisc *, struct nlattr *arg);
1da177e4
LT
163 void (*reset)(struct Qdisc *);
164 void (*destroy)(struct Qdisc *);
1e90474c 165 int (*change)(struct Qdisc *, struct nlattr *arg);
6ec1c69a 166 void (*attach)(struct Qdisc *);
1da177e4
LT
167
168 int (*dump)(struct Qdisc *, struct sk_buff *);
169 int (*dump_stats)(struct Qdisc *, struct gnet_dump *);
170
171 struct module *owner;
172};
173
174
fd2c3ef7 175struct tcf_result {
1da177e4
LT
176 unsigned long class;
177 u32 classid;
178};
179
fd2c3ef7 180struct tcf_proto_ops {
1da177e4
LT
181 struct tcf_proto_ops *next;
182 char kind[IFNAMSIZ];
183
184 int (*classify)(struct sk_buff*, struct tcf_proto*,
185 struct tcf_result *);
186 int (*init)(struct tcf_proto*);
187 void (*destroy)(struct tcf_proto*);
188
189 unsigned long (*get)(struct tcf_proto*, u32 handle);
190 void (*put)(struct tcf_proto*, unsigned long);
191 int (*change)(struct tcf_proto*, unsigned long,
add93b61 192 u32 handle, struct nlattr **,
1da177e4
LT
193 unsigned long *);
194 int (*delete)(struct tcf_proto*, unsigned long);
195 void (*walk)(struct tcf_proto*, struct tcf_walker *arg);
196
197 /* rtnetlink specific */
198 int (*dump)(struct tcf_proto*, unsigned long,
199 struct sk_buff *skb, struct tcmsg*);
200
201 struct module *owner;
202};
203
fd2c3ef7 204struct tcf_proto {
1da177e4
LT
205 /* Fast access part */
206 struct tcf_proto *next;
207 void *root;
208 int (*classify)(struct sk_buff*, struct tcf_proto*,
209 struct tcf_result *);
66c6f529 210 __be16 protocol;
1da177e4
LT
211
212 /* All the rest */
213 u32 prio;
214 u32 classid;
215 struct Qdisc *q;
216 void *data;
217 struct tcf_proto_ops *ops;
218};
219
175f9c1b
JK
220struct qdisc_skb_cb {
221 unsigned int pkt_len;
9e924cf4 222 long data[];
175f9c1b
JK
223};
224
bbd8a0d3
KK
225static inline int qdisc_qlen(struct Qdisc *q)
226{
227 return q->q.qlen;
228}
229
bfe0d029 230static inline struct qdisc_skb_cb *qdisc_skb_cb(const struct sk_buff *skb)
175f9c1b
JK
231{
232 return (struct qdisc_skb_cb *)skb->cb;
233}
234
83874000
DM
235static inline spinlock_t *qdisc_lock(struct Qdisc *qdisc)
236{
237 return &qdisc->q.lock;
238}
239
7698b4fc
DM
240static inline struct Qdisc *qdisc_root(struct Qdisc *qdisc)
241{
242 return qdisc->dev_queue->qdisc;
243}
244
2540e051
JP
245static inline struct Qdisc *qdisc_root_sleeping(struct Qdisc *qdisc)
246{
247 return qdisc->dev_queue->qdisc_sleeping;
248}
249
7e43f112
DM
250/* The qdisc root lock is a mechanism by which to top level
251 * of a qdisc tree can be locked from any qdisc node in the
252 * forest. This allows changing the configuration of some
253 * aspect of the qdisc tree while blocking out asynchronous
254 * qdisc access in the packet processing paths.
255 *
256 * It is only legal to do this when the root will not change
257 * on us. Otherwise we'll potentially lock the wrong qdisc
258 * root. This is enforced by holding the RTNL semaphore, which
259 * all users of this lock accessor must do.
260 */
7698b4fc
DM
261static inline spinlock_t *qdisc_root_lock(struct Qdisc *qdisc)
262{
263 struct Qdisc *root = qdisc_root(qdisc);
264
7e43f112 265 ASSERT_RTNL();
83874000 266 return qdisc_lock(root);
7698b4fc
DM
267}
268
f6f9b93f
JP
269static inline spinlock_t *qdisc_root_sleeping_lock(struct Qdisc *qdisc)
270{
271 struct Qdisc *root = qdisc_root_sleeping(qdisc);
272
273 ASSERT_RTNL();
274 return qdisc_lock(root);
275}
276
5ce2d488
DM
277static inline struct net_device *qdisc_dev(struct Qdisc *qdisc)
278{
279 return qdisc->dev_queue->dev;
280}
1da177e4 281
78a5b30b
DM
282static inline void sch_tree_lock(struct Qdisc *q)
283{
fe439dd0 284 spin_lock_bh(qdisc_root_sleeping_lock(q));
78a5b30b
DM
285}
286
287static inline void sch_tree_unlock(struct Qdisc *q)
288{
fe439dd0 289 spin_unlock_bh(qdisc_root_sleeping_lock(q));
78a5b30b
DM
290}
291
292#define tcf_tree_lock(tp) sch_tree_lock((tp)->q)
293#define tcf_tree_unlock(tp) sch_tree_unlock((tp)->q)
1da177e4 294
e41a33e6
TG
295extern struct Qdisc noop_qdisc;
296extern struct Qdisc_ops noop_qdisc_ops;
6ec1c69a
DM
297extern struct Qdisc_ops pfifo_fast_ops;
298extern struct Qdisc_ops mq_qdisc_ops;
e41a33e6 299
fd2c3ef7 300struct Qdisc_class_common {
6fe1c7a5
PM
301 u32 classid;
302 struct hlist_node hnode;
303};
304
fd2c3ef7 305struct Qdisc_class_hash {
6fe1c7a5
PM
306 struct hlist_head *hash;
307 unsigned int hashsize;
308 unsigned int hashmask;
309 unsigned int hashelems;
310};
311
312static inline unsigned int qdisc_class_hash(u32 id, u32 mask)
313{
314 id ^= id >> 8;
315 id ^= id >> 4;
316 return id & mask;
317}
318
319static inline struct Qdisc_class_common *
320qdisc_class_find(struct Qdisc_class_hash *hash, u32 id)
321{
322 struct Qdisc_class_common *cl;
323 struct hlist_node *n;
324 unsigned int h;
325
326 h = qdisc_class_hash(id, hash->hashmask);
327 hlist_for_each_entry(cl, n, &hash->hash[h], hnode) {
328 if (cl->classid == id)
329 return cl;
330 }
331 return NULL;
332}
333
334extern int qdisc_class_hash_init(struct Qdisc_class_hash *);
335extern void qdisc_class_hash_insert(struct Qdisc_class_hash *, struct Qdisc_class_common *);
336extern void qdisc_class_hash_remove(struct Qdisc_class_hash *, struct Qdisc_class_common *);
337extern void qdisc_class_hash_grow(struct Qdisc *, struct Qdisc_class_hash *);
338extern void qdisc_class_hash_destroy(struct Qdisc_class_hash *);
339
e41a33e6
TG
340extern void dev_init_scheduler(struct net_device *dev);
341extern void dev_shutdown(struct net_device *dev);
342extern void dev_activate(struct net_device *dev);
343extern void dev_deactivate(struct net_device *dev);
44345724 344extern void dev_deactivate_many(struct list_head *head);
589983cd
PM
345extern struct Qdisc *dev_graft_qdisc(struct netdev_queue *dev_queue,
346 struct Qdisc *qdisc);
e41a33e6
TG
347extern void qdisc_reset(struct Qdisc *qdisc);
348extern void qdisc_destroy(struct Qdisc *qdisc);
43effa1e 349extern void qdisc_tree_decrease_qlen(struct Qdisc *qdisc, unsigned int n);
5ce2d488 350extern struct Qdisc *qdisc_alloc(struct netdev_queue *dev_queue,
bb949fbd 351 struct Qdisc_ops *ops);
3511c913 352extern struct Qdisc *qdisc_create_dflt(struct netdev_queue *dev_queue,
9f9afec4 353 struct Qdisc_ops *ops, u32 parentid);
a2da570d
ED
354extern void __qdisc_calculate_pkt_len(struct sk_buff *skb,
355 const struct qdisc_size_table *stab);
a48b5a61 356extern void tcf_destroy(struct tcf_proto *tp);
ff31ab56 357extern void tcf_destroy_chain(struct tcf_proto **fl);
1da177e4 358
f0796d5c
JF
359/* Reset all TX qdiscs greater then index of a device. */
360static inline void qdisc_reset_all_tx_gt(struct net_device *dev, unsigned int i)
5aa70995 361{
4ef6acff
JF
362 struct Qdisc *qdisc;
363
f0796d5c 364 for (; i < dev->num_tx_queues; i++) {
4ef6acff
JF
365 qdisc = netdev_get_tx_queue(dev, i)->qdisc;
366 if (qdisc) {
367 spin_lock_bh(qdisc_lock(qdisc));
368 qdisc_reset(qdisc);
369 spin_unlock_bh(qdisc_lock(qdisc));
370 }
371 }
5aa70995
DM
372}
373
5aa70995
DM
374static inline void qdisc_reset_all_tx(struct net_device *dev)
375{
f0796d5c 376 qdisc_reset_all_tx_gt(dev, 0);
5aa70995
DM
377}
378
3e745dd6
DM
379/* Are all TX queues of the device empty? */
380static inline bool qdisc_all_tx_empty(const struct net_device *dev)
381{
e8a0464c
DM
382 unsigned int i;
383 for (i = 0; i < dev->num_tx_queues; i++) {
384 struct netdev_queue *txq = netdev_get_tx_queue(dev, i);
385 const struct Qdisc *q = txq->qdisc;
3e745dd6 386
e8a0464c
DM
387 if (q->q.qlen)
388 return false;
389 }
390 return true;
3e745dd6
DM
391}
392
6fa9864b
DM
393/* Are any of the TX qdiscs changing? */
394static inline bool qdisc_tx_changing(struct net_device *dev)
395{
e8a0464c
DM
396 unsigned int i;
397 for (i = 0; i < dev->num_tx_queues; i++) {
398 struct netdev_queue *txq = netdev_get_tx_queue(dev, i);
399 if (txq->qdisc != txq->qdisc_sleeping)
400 return true;
401 }
402 return false;
6fa9864b
DM
403}
404
e8a0464c 405/* Is the device using the noop qdisc on all queues? */
05297949
DM
406static inline bool qdisc_tx_is_noop(const struct net_device *dev)
407{
e8a0464c
DM
408 unsigned int i;
409 for (i = 0; i < dev->num_tx_queues; i++) {
410 struct netdev_queue *txq = netdev_get_tx_queue(dev, i);
411 if (txq->qdisc != &noop_qdisc)
412 return false;
413 }
414 return true;
05297949
DM
415}
416
bfe0d029 417static inline unsigned int qdisc_pkt_len(const struct sk_buff *skb)
0abf77e5 418{
175f9c1b 419 return qdisc_skb_cb(skb)->pkt_len;
0abf77e5
JK
420}
421
c27f339a 422/* additional qdisc xmit flags (NET_XMIT_MASK in linux/netdevice.h) */
378a2f09
JP
423enum net_xmit_qdisc_t {
424 __NET_XMIT_STOLEN = 0x00010000,
c27f339a 425 __NET_XMIT_BYPASS = 0x00020000,
378a2f09
JP
426};
427
c27f339a 428#ifdef CONFIG_NET_CLS_ACT
378a2f09 429#define net_xmit_drop_count(e) ((e) & __NET_XMIT_STOLEN ? 0 : 1)
378a2f09
JP
430#else
431#define net_xmit_drop_count(e) (1)
432#endif
433
a2da570d
ED
434static inline void qdisc_calculate_pkt_len(struct sk_buff *skb,
435 const struct Qdisc *sch)
5f86173b 436{
3a682fbd 437#ifdef CONFIG_NET_SCHED
a2da570d
ED
438 struct qdisc_size_table *stab = rcu_dereference_bh(sch->stab);
439
440 if (stab)
441 __qdisc_calculate_pkt_len(skb, stab);
3a682fbd 442#endif
a2da570d
ED
443}
444
445static inline int qdisc_enqueue(struct sk_buff *skb, struct Qdisc *sch)
446{
447 qdisc_calculate_pkt_len(skb, sch);
5f86173b
JK
448 return sch->enqueue(skb, sch);
449}
450
451static inline int qdisc_enqueue_root(struct sk_buff *skb, struct Qdisc *sch)
452{
175f9c1b 453 qdisc_skb_cb(skb)->pkt_len = skb->len;
378a2f09 454 return qdisc_enqueue(skb, sch) & NET_XMIT_MASK;
5f86173b
JK
455}
456
bfe0d029
ED
457
458static inline void bstats_update(struct gnet_stats_basic_packed *bstats,
459 const struct sk_buff *skb)
460{
461 bstats->bytes += qdisc_pkt_len(skb);
462 bstats->packets += skb_is_gso(skb) ? skb_shinfo(skb)->gso_segs : 1;
463}
464
465static inline void qdisc_bstats_update(struct Qdisc *sch,
466 const struct sk_buff *skb)
bbd8a0d3 467{
bfe0d029 468 bstats_update(&sch->bstats, skb);
bbd8a0d3
KK
469}
470
9972b25d
TG
471static inline int __qdisc_enqueue_tail(struct sk_buff *skb, struct Qdisc *sch,
472 struct sk_buff_head *list)
473{
474 __skb_queue_tail(list, skb);
0abf77e5 475 sch->qstats.backlog += qdisc_pkt_len(skb);
9972b25d
TG
476
477 return NET_XMIT_SUCCESS;
478}
479
480static inline int qdisc_enqueue_tail(struct sk_buff *skb, struct Qdisc *sch)
481{
482 return __qdisc_enqueue_tail(skb, sch, &sch->q);
483}
484
485static inline struct sk_buff *__qdisc_dequeue_head(struct Qdisc *sch,
486 struct sk_buff_head *list)
487{
488 struct sk_buff *skb = __skb_dequeue(list);
489
9190b3b3 490 if (likely(skb != NULL)) {
0abf77e5 491 sch->qstats.backlog -= qdisc_pkt_len(skb);
9190b3b3
ED
492 qdisc_bstats_update(sch, skb);
493 }
9972b25d
TG
494
495 return skb;
496}
497
498static inline struct sk_buff *qdisc_dequeue_head(struct Qdisc *sch)
499{
500 return __qdisc_dequeue_head(sch, &sch->q);
57dbb2d8
HPP
501}
502
503static inline unsigned int __qdisc_queue_drop_head(struct Qdisc *sch,
504 struct sk_buff_head *list)
505{
9190b3b3 506 struct sk_buff *skb = __skb_dequeue(list);
57dbb2d8
HPP
507
508 if (likely(skb != NULL)) {
509 unsigned int len = qdisc_pkt_len(skb);
9190b3b3 510 sch->qstats.backlog -= len;
57dbb2d8
HPP
511 kfree_skb(skb);
512 return len;
513 }
514
515 return 0;
516}
517
518static inline unsigned int qdisc_queue_drop_head(struct Qdisc *sch)
519{
520 return __qdisc_queue_drop_head(sch, &sch->q);
9972b25d
TG
521}
522
523static inline struct sk_buff *__qdisc_dequeue_tail(struct Qdisc *sch,
524 struct sk_buff_head *list)
525{
526 struct sk_buff *skb = __skb_dequeue_tail(list);
527
528 if (likely(skb != NULL))
0abf77e5 529 sch->qstats.backlog -= qdisc_pkt_len(skb);
9972b25d
TG
530
531 return skb;
532}
533
534static inline struct sk_buff *qdisc_dequeue_tail(struct Qdisc *sch)
535{
536 return __qdisc_dequeue_tail(sch, &sch->q);
537}
538
48a8f519
PM
539static inline struct sk_buff *qdisc_peek_head(struct Qdisc *sch)
540{
541 return skb_peek(&sch->q);
542}
543
77be155c
JP
544/* generic pseudo peek method for non-work-conserving qdisc */
545static inline struct sk_buff *qdisc_peek_dequeued(struct Qdisc *sch)
546{
547 /* we can reuse ->gso_skb because peek isn't called for root qdiscs */
61c9eaf9 548 if (!sch->gso_skb) {
77be155c 549 sch->gso_skb = sch->dequeue(sch);
61c9eaf9
JP
550 if (sch->gso_skb)
551 /* it's still part of the queue */
552 sch->q.qlen++;
553 }
77be155c
JP
554
555 return sch->gso_skb;
556}
557
558/* use instead of qdisc->dequeue() for all qdiscs queried with ->peek() */
559static inline struct sk_buff *qdisc_dequeue_peeked(struct Qdisc *sch)
560{
561 struct sk_buff *skb = sch->gso_skb;
562
61c9eaf9 563 if (skb) {
77be155c 564 sch->gso_skb = NULL;
61c9eaf9
JP
565 sch->q.qlen--;
566 } else {
77be155c 567 skb = sch->dequeue(sch);
61c9eaf9 568 }
77be155c
JP
569
570 return skb;
571}
572
9972b25d
TG
573static inline void __qdisc_reset_queue(struct Qdisc *sch,
574 struct sk_buff_head *list)
575{
576 /*
577 * We do not know the backlog in bytes of this list, it
578 * is up to the caller to correct it
579 */
93245dd6 580 __skb_queue_purge(list);
9972b25d
TG
581}
582
583static inline void qdisc_reset_queue(struct Qdisc *sch)
584{
585 __qdisc_reset_queue(sch, &sch->q);
586 sch->qstats.backlog = 0;
587}
588
589static inline unsigned int __qdisc_queue_drop(struct Qdisc *sch,
590 struct sk_buff_head *list)
591{
592 struct sk_buff *skb = __qdisc_dequeue_tail(sch, list);
593
594 if (likely(skb != NULL)) {
0abf77e5 595 unsigned int len = qdisc_pkt_len(skb);
9972b25d
TG
596 kfree_skb(skb);
597 return len;
598 }
599
600 return 0;
601}
602
603static inline unsigned int qdisc_queue_drop(struct Qdisc *sch)
604{
605 return __qdisc_queue_drop(sch, &sch->q);
606}
607
608static inline int qdisc_drop(struct sk_buff *skb, struct Qdisc *sch)
609{
610 kfree_skb(skb);
611 sch->qstats.drops++;
612
613 return NET_XMIT_DROP;
614}
615
616static inline int qdisc_reshape_fail(struct sk_buff *skb, struct Qdisc *sch)
617{
618 sch->qstats.drops++;
619
c3bc7cff 620#ifdef CONFIG_NET_CLS_ACT
9972b25d
TG
621 if (sch->reshape_fail == NULL || sch->reshape_fail(skb, sch))
622 goto drop;
623
624 return NET_XMIT_SUCCESS;
625
626drop:
627#endif
628 kfree_skb(skb);
629 return NET_XMIT_DROP;
630}
631
e9bef55d
JDB
632/* Length to Time (L2T) lookup in a qdisc_rate_table, to determine how
633 long it will take to send a packet given its size.
634 */
635static inline u32 qdisc_l2t(struct qdisc_rate_table* rtab, unsigned int pktlen)
636{
e08b0998
JDB
637 int slot = pktlen + rtab->rate.cell_align + rtab->rate.overhead;
638 if (slot < 0)
639 slot = 0;
e9bef55d
JDB
640 slot >>= rtab->rate.cell_log;
641 if (slot > 255)
a02cec21 642 return rtab->data[255]*(slot >> 8) + rtab->data[slot & 0xFF];
e9bef55d
JDB
643 return rtab->data[slot];
644}
645
12da81d1 646#ifdef CONFIG_NET_CLS_ACT
210d6de7
CG
647static inline struct sk_buff *skb_act_clone(struct sk_buff *skb, gfp_t gfp_mask,
648 int action)
12da81d1 649{
210d6de7
CG
650 struct sk_buff *n;
651
17302107 652 n = skb_clone(skb, gfp_mask);
12da81d1
JHS
653
654 if (n) {
655 n->tc_verd = SET_TC_VERD(n->tc_verd, 0);
656 n->tc_verd = CLR_TC_OK2MUNGE(n->tc_verd);
657 n->tc_verd = CLR_TC_MUNGED(n->tc_verd);
12da81d1
JHS
658 }
659 return n;
660}
661#endif
662
1da177e4 663#endif