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