309 lines · 7.3 KB · C
RawDownload
#ifndef __NET_SCHED_GENERIC_H#define __NET_SCHED_GENERIC_H #include <linux/netdevice.h>#include <linux/types.h>#include <linux/rcupdate.h>#include <linux/module.h>#include <linux/rtnetlink.h>#include <linux/pkt_sched.h>#include <linux/pkt_cls.h>#include <net/gen_stats.h> 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); 	/* 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 *);	u32			protocol; 	/* 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) 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);extern struct Qdisc *qdisc_alloc(struct net_device *dev, struct Qdisc_ops *ops);extern struct Qdisc *qdisc_create_dflt(struct net_device *dev,				       struct Qdisc_ops *ops); static inline voidtcf_destroy(struct tcf_proto *tp){	tp->ops->destroy(tp);	module_put(tp->ops->owner);	kfree(tp);} 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++; #ifdef CONFIG_NET_CLS_POLICE	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;} #endif