Blame view

include/net/sch_generic.h 7.45 KB
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1
2
  #ifndef __NET_SCHED_GENERIC_H
  #define __NET_SCHED_GENERIC_H
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
3
4
5
6
  #include <linux/netdevice.h>
  #include <linux/types.h>
  #include <linux/rcupdate.h>
  #include <linux/module.h>
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
7
8
9
  #include <linux/pkt_sched.h>
  #include <linux/pkt_cls.h>
  #include <net/gen_stats.h>
be577ddc2   Thomas Graf   [PKT_SCHED] qdisc...
10
  #include <net/rtnetlink.h>
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
  
  struct Qdisc_ops;
  struct qdisc_walker;
  struct tcf_walker;
  struct module;
  
  struct qdisc_rate_table
  {
  	struct tc_ratespec rate;
  	u32		data[256];
  	struct qdisc_rate_table *next;
  	int		refcnt;
  };
  
  struct Qdisc
  {
  	int 			(*enqueue)(struct sk_buff *skb, struct Qdisc *dev);
  	struct sk_buff *	(*dequeue)(struct Qdisc *dev);
  	unsigned		flags;
  #define TCQ_F_BUILTIN	1
  #define TCQ_F_THROTTLED	2
  #define TCQ_F_INGRESS	4
  	int			padded;
  	struct Qdisc_ops	*ops;
  	u32			handle;
  	u32			parent;
  	atomic_t		refcnt;
  	struct sk_buff_head	q;
  	struct net_device	*dev;
  	struct list_head	list;
  
  	struct gnet_stats_basic	bstats;
  	struct gnet_stats_queue	qstats;
  	struct gnet_stats_rate_est	rate_est;
  	spinlock_t		*stats_lock;
  	struct rcu_head 	q_rcu;
  	int			(*reshape_fail)(struct sk_buff *skb,
  					struct Qdisc *q);
  
  	/* This field is deprecated, but it is still used by CBQ
  	 * and it will live until better solution will be invented.
  	 */
  	struct Qdisc		*__parent;
  };
  
  struct Qdisc_class_ops
  {
  	/* Child qdisc manipulation */
  	int			(*graft)(struct Qdisc *, unsigned long cl,
  					struct Qdisc *, struct Qdisc **);
  	struct Qdisc *		(*leaf)(struct Qdisc *, unsigned long cl);
43effa1e5   Patrick McHardy   [NET_SCHED]: Fix ...
62
  	void			(*qlen_notify)(struct Qdisc *, unsigned long);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
  
  	/* Class manipulation routines */
  	unsigned long		(*get)(struct Qdisc *, u32 classid);
  	void			(*put)(struct Qdisc *, unsigned long);
  	int			(*change)(struct Qdisc *, u32, u32,
  					struct rtattr **, unsigned long *);
  	int			(*delete)(struct Qdisc *, unsigned long);
  	void			(*walk)(struct Qdisc *, struct qdisc_walker * arg);
  
  	/* Filter manipulation */
  	struct tcf_proto **	(*tcf_chain)(struct Qdisc *, unsigned long);
  	unsigned long		(*bind_tcf)(struct Qdisc *, unsigned long,
  					u32 classid);
  	void			(*unbind_tcf)(struct Qdisc *, unsigned long);
  
  	/* rtnetlink specific */
  	int			(*dump)(struct Qdisc *, unsigned long,
  					struct sk_buff *skb, struct tcmsg*);
  	int			(*dump_stats)(struct Qdisc *, unsigned long,
  					struct gnet_dump *);
  };
  
  struct Qdisc_ops
  {
  	struct Qdisc_ops	*next;
  	struct Qdisc_class_ops	*cl_ops;
  	char			id[IFNAMSIZ];
  	int			priv_size;
  
  	int 			(*enqueue)(struct sk_buff *, struct Qdisc *);
  	struct sk_buff *	(*dequeue)(struct Qdisc *);
  	int 			(*requeue)(struct sk_buff *, struct Qdisc *);
  	unsigned int		(*drop)(struct Qdisc *);
  
  	int			(*init)(struct Qdisc *, struct rtattr *arg);
  	void			(*reset)(struct Qdisc *);
  	void			(*destroy)(struct Qdisc *);
  	int			(*change)(struct Qdisc *, struct rtattr *arg);
  
  	int			(*dump)(struct Qdisc *, struct sk_buff *);
  	int			(*dump_stats)(struct Qdisc *, struct gnet_dump *);
  
  	struct module		*owner;
  };
  
  
  struct tcf_result
  {
  	unsigned long	class;
  	u32		classid;
  };
  
  struct tcf_proto_ops
  {
  	struct tcf_proto_ops	*next;
  	char			kind[IFNAMSIZ];
  
  	int			(*classify)(struct sk_buff*, struct tcf_proto*,
  					struct tcf_result *);
  	int			(*init)(struct tcf_proto*);
  	void			(*destroy)(struct tcf_proto*);
  
  	unsigned long		(*get)(struct tcf_proto*, u32 handle);
  	void			(*put)(struct tcf_proto*, unsigned long);
  	int			(*change)(struct tcf_proto*, unsigned long,
  					u32 handle, struct rtattr **,
  					unsigned long *);
  	int			(*delete)(struct tcf_proto*, unsigned long);
  	void			(*walk)(struct tcf_proto*, struct tcf_walker *arg);
  
  	/* rtnetlink specific */
  	int			(*dump)(struct tcf_proto*, unsigned long,
  					struct sk_buff *skb, struct tcmsg*);
  
  	struct module		*owner;
  };
  
  struct tcf_proto
  {
  	/* Fast access part */
  	struct tcf_proto	*next;
  	void			*root;
  	int			(*classify)(struct sk_buff*, struct tcf_proto*,
  					struct tcf_result *);
66c6f529c   Al Viro   [NET]: net/sched ...
147
  	__be16			protocol;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
  
  	/* All the rest */
  	u32			prio;
  	u32			classid;
  	struct Qdisc		*q;
  	void			*data;
  	struct tcf_proto_ops	*ops;
  };
  
  
  extern void qdisc_lock_tree(struct net_device *dev);
  extern void qdisc_unlock_tree(struct net_device *dev);
  
  #define sch_tree_lock(q)	qdisc_lock_tree((q)->dev)
  #define sch_tree_unlock(q)	qdisc_unlock_tree((q)->dev)
  #define tcf_tree_lock(tp)	qdisc_lock_tree((tp)->q->dev)
  #define tcf_tree_unlock(tp)	qdisc_unlock_tree((tp)->q->dev)
e41a33e6e   Thomas Graf   [PKT_SCHED]: Move...
165
166
167
168
169
170
171
172
173
  extern struct Qdisc noop_qdisc;
  extern struct Qdisc_ops noop_qdisc_ops;
  
  extern void dev_init_scheduler(struct net_device *dev);
  extern void dev_shutdown(struct net_device *dev);
  extern void dev_activate(struct net_device *dev);
  extern void dev_deactivate(struct net_device *dev);
  extern void qdisc_reset(struct Qdisc *qdisc);
  extern void qdisc_destroy(struct Qdisc *qdisc);
43effa1e5   Patrick McHardy   [NET_SCHED]: Fix ...
174
  extern void qdisc_tree_decrease_qlen(struct Qdisc *qdisc, unsigned int n);
3d54b82fd   Thomas Graf   [PKT_SCHED]: Clea...
175
  extern struct Qdisc *qdisc_alloc(struct net_device *dev, struct Qdisc_ops *ops);
e41a33e6e   Thomas Graf   [PKT_SCHED]: Move...
176
  extern struct Qdisc *qdisc_create_dflt(struct net_device *dev,
9f9afec48   Patrick McHardy   [NET_SCHED]: Set ...
177
  				       struct Qdisc_ops *ops, u32 parentid);
a48b5a614   Patrick McHardy   [NET_SCHED]: Unli...
178
179
  extern void tcf_destroy(struct tcf_proto *tp);
  extern void tcf_destroy_chain(struct tcf_proto *fl);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
180

9972b25d0   Thomas Graf   [PKT_SCHED]: Gene...
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
  static inline int __qdisc_enqueue_tail(struct sk_buff *skb, struct Qdisc *sch,
  				       struct sk_buff_head *list)
  {
  	__skb_queue_tail(list, skb);
  	sch->qstats.backlog += skb->len;
  	sch->bstats.bytes += skb->len;
  	sch->bstats.packets++;
  
  	return NET_XMIT_SUCCESS;
  }
  
  static inline int qdisc_enqueue_tail(struct sk_buff *skb, struct Qdisc *sch)
  {
  	return __qdisc_enqueue_tail(skb, sch, &sch->q);
  }
  
  static inline struct sk_buff *__qdisc_dequeue_head(struct Qdisc *sch,
  						   struct sk_buff_head *list)
  {
  	struct sk_buff *skb = __skb_dequeue(list);
  
  	if (likely(skb != NULL))
  		sch->qstats.backlog -= skb->len;
  
  	return skb;
  }
  
  static inline struct sk_buff *qdisc_dequeue_head(struct Qdisc *sch)
  {
  	return __qdisc_dequeue_head(sch, &sch->q);
  }
  
  static inline struct sk_buff *__qdisc_dequeue_tail(struct Qdisc *sch,
  						   struct sk_buff_head *list)
  {
  	struct sk_buff *skb = __skb_dequeue_tail(list);
  
  	if (likely(skb != NULL))
  		sch->qstats.backlog -= skb->len;
  
  	return skb;
  }
  
  static inline struct sk_buff *qdisc_dequeue_tail(struct Qdisc *sch)
  {
  	return __qdisc_dequeue_tail(sch, &sch->q);
  }
  
  static inline int __qdisc_requeue(struct sk_buff *skb, struct Qdisc *sch,
  				  struct sk_buff_head *list)
  {
  	__skb_queue_head(list, skb);
  	sch->qstats.backlog += skb->len;
  	sch->qstats.requeues++;
  
  	return NET_XMIT_SUCCESS;
  }
  
  static inline int qdisc_requeue(struct sk_buff *skb, struct Qdisc *sch)
  {
  	return __qdisc_requeue(skb, sch, &sch->q);
  }
  
  static inline void __qdisc_reset_queue(struct Qdisc *sch,
  				       struct sk_buff_head *list)
  {
  	/*
  	 * We do not know the backlog in bytes of this list, it
  	 * is up to the caller to correct it
  	 */
  	skb_queue_purge(list);
  }
  
  static inline void qdisc_reset_queue(struct Qdisc *sch)
  {
  	__qdisc_reset_queue(sch, &sch->q);
  	sch->qstats.backlog = 0;
  }
  
  static inline unsigned int __qdisc_queue_drop(struct Qdisc *sch,
  					      struct sk_buff_head *list)
  {
  	struct sk_buff *skb = __qdisc_dequeue_tail(sch, list);
  
  	if (likely(skb != NULL)) {
  		unsigned int len = skb->len;
  		kfree_skb(skb);
  		return len;
  	}
  
  	return 0;
  }
  
  static inline unsigned int qdisc_queue_drop(struct Qdisc *sch)
  {
  	return __qdisc_queue_drop(sch, &sch->q);
  }
  
  static inline int qdisc_drop(struct sk_buff *skb, struct Qdisc *sch)
  {
  	kfree_skb(skb);
  	sch->qstats.drops++;
  
  	return NET_XMIT_DROP;
  }
  
  static inline int qdisc_reshape_fail(struct sk_buff *skb, struct Qdisc *sch)
  {
  	sch->qstats.drops++;
c3bc7cff8   Patrick McHardy   [NET_SCHED]: Kill...
290
  #ifdef CONFIG_NET_CLS_ACT
9972b25d0   Thomas Graf   [PKT_SCHED]: Gene...
291
292
293
294
295
296
297
298
299
300
  	if (sch->reshape_fail == NULL || sch->reshape_fail(skb, sch))
  		goto drop;
  
  	return NET_XMIT_SUCCESS;
  
  drop:
  #endif
  	kfree_skb(skb);
  	return NET_XMIT_DROP;
  }
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
301
  #endif