[linux.git] / net / sched / act_police.c

/*
 * net/sched/police.c	Input police filter.
 *
 *		This program is free software; you can redistribute it and/or
 *		modify it under the terms of the GNU General Public License
 *		as published by the Free Software Foundation; either version
 *		2 of the License, or (at your option) any later version.
 *
 * Authors:	Alexey Kuznetsov, <[email protected]>
 * 		J Hadi Salim (action changes)
 */

#include <asm/uaccess.h>
#include <asm/system.h>
#include <linux/bitops.h>
#include <linux/module.h>
#include <linux/types.h>
#include <linux/kernel.h>
#include <linux/sched.h>
#include <linux/string.h>
#include <linux/mm.h>
#include <linux/socket.h>
#include <linux/sockios.h>
#include <linux/in.h>
#include <linux/errno.h>
#include <linux/interrupt.h>
#include <linux/netdevice.h>
#include <linux/skbuff.h>
#include <linux/module.h>
#include <linux/rtnetlink.h>
#include <linux/init.h>
#include <net/sock.h>
#include <net/act_api.h>

#define L2T(p,L)   ((p)->R_tab->data[(L)>>(p)->R_tab->rate.cell_log])
#define L2T_P(p,L) ((p)->P_tab->data[(L)>>(p)->P_tab->rate.cell_log])
#define PRIV(a) ((struct tcf_police *) (a)->priv)

/* use generic hash table */
#define MY_TAB_SIZE     16
#define MY_TAB_MASK     15
static u32 idx_gen;
static struct tcf_police *tcf_police_ht[MY_TAB_SIZE];
/* Policer hash table lock */
static DEFINE_RWLOCK(police_lock);

/* Each policer is serialized by its individual spinlock */

static __inline__ unsigned tcf_police_hash(u32 index)
{
	return index&0xF;
}

static __inline__ struct tcf_police * tcf_police_lookup(u32 index)
{
	struct tcf_police *p;

	read_lock(&police_lock);
	for (p = tcf_police_ht[tcf_police_hash(index)]; p; p = p->next) {
		if (p->index == index)
			break;
	}
	read_unlock(&police_lock);
	return p;
}

#ifdef CONFIG_NET_CLS_ACT
static int tcf_act_police_walker(struct sk_buff *skb, struct netlink_callback *cb,
                              int type, struct tc_action *a)
{
	struct tcf_police *p;
	int err = 0, index = -1, i = 0, s_i = 0, n_i = 0;
	struct rtattr *r;

	read_lock(&police_lock);

	s_i = cb->args[0];

	for (i = 0; i < MY_TAB_SIZE; i++) {
		p = tcf_police_ht[tcf_police_hash(i)];

		for (; p; p = p->next) {
			index++;
			if (index < s_i)
				continue;
			a->priv = p;
			a->order = index;
			r = (struct rtattr*) skb->tail;
			RTA_PUT(skb, a->order, 0, NULL);
			if (type == RTM_DELACTION)
				err = tcf_action_dump_1(skb, a, 0, 1);
			else
				err = tcf_action_dump_1(skb, a, 0, 0);
			if (err < 0) {
				index--;
				skb_trim(skb, (u8*)r - skb->data);
				goto done;
			}
			r->rta_len = skb->tail - (u8*)r;
			n_i++;
		}
	}
done:
	read_unlock(&police_lock);
	if (n_i)
		cb->args[0] += n_i;
	return n_i;

rtattr_failure:
	skb_trim(skb, (u8*)r - skb->data);
	goto done;
}

static inline int
tcf_act_police_hash_search(struct tc_action *a, u32 index)
{
	struct tcf_police *p = tcf_police_lookup(index);

	if (p != NULL) {
		a->priv = p;
		return 1;
	} else {
		return 0;
	}
}
#endif

static inline u32 tcf_police_new_index(void)
{
	do {
		if (++idx_gen == 0)
			idx_gen = 1;
	} while (tcf_police_lookup(idx_gen));

	return idx_gen;
}

void tcf_police_destroy(struct tcf_police *p)
{
	unsigned h = tcf_police_hash(p->index);
	struct tcf_police **p1p;
	
	for (p1p = &tcf_police_ht[h]; *p1p; p1p = &(*p1p)->next) {
		if (*p1p == p) {
			write_lock_bh(&police_lock);
			*p1p = p->next;
			write_unlock_bh(&police_lock);
#ifdef CONFIG_NET_ESTIMATOR
			gen_kill_estimator(&p->bstats, &p->rate_est);
#endif
			if (p->R_tab)
				qdisc_put_rtab(p->R_tab);
			if (p->P_tab)
				qdisc_put_rtab(p->P_tab);
			kfree(p);
			return;
		}
	}
	BUG_TRAP(0);
}

#ifdef CONFIG_NET_CLS_ACT
static int tcf_act_police_locate(struct rtattr *rta, struct rtattr *est,
                                 struct tc_action *a, int ovr, int bind)
{
	unsigned h;
	int ret = 0, err;
	struct rtattr *tb[TCA_POLICE_MAX];
	struct tc_police *parm;
	struct tcf_police *p;
	struct qdisc_rate_table *R_tab = NULL, *P_tab = NULL;

	if (rta == NULL || rtattr_parse_nested(tb, TCA_POLICE_MAX, rta) < 0)
		return -EINVAL;

	if (tb[TCA_POLICE_TBF-1] == NULL ||
	    RTA_PAYLOAD(tb[TCA_POLICE_TBF-1]) != sizeof(*parm))
		return -EINVAL;
	parm = RTA_DATA(tb[TCA_POLICE_TBF-1]);

	if (tb[TCA_POLICE_RESULT-1] != NULL &&
	    RTA_PAYLOAD(tb[TCA_POLICE_RESULT-1]) != sizeof(u32))
		return -EINVAL;
	if (tb[TCA_POLICE_RESULT-1] != NULL &&
	    RTA_PAYLOAD(tb[TCA_POLICE_RESULT-1]) != sizeof(u32))
		return -EINVAL;

	if (parm->index && (p = tcf_police_lookup(parm->index)) != NULL) {
		a->priv = p;
		if (bind) {
			p->bindcnt += 1;
			p->refcnt += 1;
		}
		if (ovr)
			goto override;
		return ret;
	}

	p = kzalloc(sizeof(*p), GFP_KERNEL);
	if (p == NULL)
		return -ENOMEM;

	ret = ACT_P_CREATED;
	p->refcnt = 1;
	spin_lock_init(&p->lock);
	p->stats_lock = &p->lock;
	if (bind)
		p->bindcnt = 1;
override:
	if (parm->rate.rate) {
		err = -ENOMEM;
		R_tab = qdisc_get_rtab(&parm->rate, tb[TCA_POLICE_RATE-1]);
		if (R_tab == NULL)
			goto failure;
		if (parm->peakrate.rate) {
			P_tab = qdisc_get_rtab(&parm->peakrate,
					       tb[TCA_POLICE_PEAKRATE-1]);
			if (p->P_tab == NULL) {
				qdisc_put_rtab(R_tab);
				goto failure;
			}
		}
	}
	/* No failure allowed after this point */
	spin_lock_bh(&p->lock);
	if (R_tab != NULL) {
		qdisc_put_rtab(p->R_tab);
		p->R_tab = R_tab;
	}
	if (P_tab != NULL) {
		qdisc_put_rtab(p->P_tab);
		p->P_tab = P_tab;
	}

	if (tb[TCA_POLICE_RESULT-1])
		p->result = *(u32*)RTA_DATA(tb[TCA_POLICE_RESULT-1]);
	p->toks = p->burst = parm->burst;
	p->mtu = parm->mtu;
	if (p->mtu == 0) {
		p->mtu = ~0;
		if (p->R_tab)
			p->mtu = 255<<p->R_tab->rate.cell_log;
	}
	if (p->P_tab)
		p->ptoks = L2T_P(p, p->mtu);
	p->action = parm->action;

#ifdef CONFIG_NET_ESTIMATOR
	if (tb[TCA_POLICE_AVRATE-1])
		p->ewma_rate = *(u32*)RTA_DATA(tb[TCA_POLICE_AVRATE-1]);
	if (est)
		gen_replace_estimator(&p->bstats, &p->rate_est, p->stats_lock, est);
#endif

	spin_unlock_bh(&p->lock);
	if (ret != ACT_P_CREATED)
		return ret;

	PSCHED_GET_TIME(p->t_c);
	p->index = parm->index ? : tcf_police_new_index();
	h = tcf_police_hash(p->index);
	write_lock_bh(&police_lock);
	p->next = tcf_police_ht[h];
	tcf_police_ht[h] = p;
	write_unlock_bh(&police_lock);

	a->priv = p;
	return ret;

failure:
	if (ret == ACT_P_CREATED)
		kfree(p);
	return err;
}

static int tcf_act_police_cleanup(struct tc_action *a, int bind)
{
	struct tcf_police *p = PRIV(a);

	if (p != NULL)
		return tcf_police_release(p, bind);
	return 0;
}

static int tcf_act_police(struct sk_buff *skb, struct tc_action *a,
                          struct tcf_result *res)
{
	psched_time_t now;
	struct tcf_police *p = PRIV(a);
	long toks;
	long ptoks = 0;

	spin_lock(&p->lock);

	p->bstats.bytes += skb->len;
	p->bstats.packets++;

#ifdef CONFIG_NET_ESTIMATOR
	if (p->ewma_rate && p->rate_est.bps >= p->ewma_rate) {
		p->qstats.overlimits++;
		spin_unlock(&p->lock);
		return p->action;
	}
#endif

	if (skb->len <= p->mtu) {
		if (p->R_tab == NULL) {
			spin_unlock(&p->lock);
			return p->result;
		}

		PSCHED_GET_TIME(now);

		toks = PSCHED_TDIFF_SAFE(now, p->t_c, p->burst);

		if (p->P_tab) {
			ptoks = toks + p->ptoks;
			if (ptoks > (long)L2T_P(p, p->mtu))
				ptoks = (long)L2T_P(p, p->mtu);
			ptoks -= L2T_P(p, skb->len);
		}
		toks += p->toks;
		if (toks > (long)p->burst)
			toks = p->burst;
		toks -= L2T(p, skb->len);

		if ((toks|ptoks) >= 0) {
			p->t_c = now;
			p->toks = toks;
			p->ptoks = ptoks;
			spin_unlock(&p->lock);
			return p->result;
		}
	}

	p->qstats.overlimits++;
	spin_unlock(&p->lock);
	return p->action;
}

static int
tcf_act_police_dump(struct sk_buff *skb, struct tc_action *a, int bind, int ref)
{
	unsigned char	 *b = skb->tail;
	struct tc_police opt;
	struct tcf_police *p = PRIV(a);

	opt.index = p->index;
	opt.action = p->action;
	opt.mtu = p->mtu;
	opt.burst = p->burst;
	opt.refcnt = p->refcnt - ref;
	opt.bindcnt = p->bindcnt - bind;
	if (p->R_tab)
		opt.rate = p->R_tab->rate;
	else
		memset(&opt.rate, 0, sizeof(opt.rate));
	if (p->P_tab)
		opt.peakrate = p->P_tab->rate;
	else
		memset(&opt.peakrate, 0, sizeof(opt.peakrate));
	RTA_PUT(skb, TCA_POLICE_TBF, sizeof(opt), &opt);
	if (p->result)
		RTA_PUT(skb, TCA_POLICE_RESULT, sizeof(int), &p->result);
#ifdef CONFIG_NET_ESTIMATOR
	if (p->ewma_rate)
		RTA_PUT(skb, TCA_POLICE_AVRATE, 4, &p->ewma_rate);
#endif
	return skb->len;

rtattr_failure:
	skb_trim(skb, b - skb->data);
	return -1;
}

MODULE_AUTHOR("Alexey Kuznetsov");
MODULE_DESCRIPTION("Policing actions");
MODULE_LICENSE("GPL");

static struct tc_action_ops act_police_ops = {
	.kind		=	"police",
	.type		=	TCA_ID_POLICE,
	.capab		=	TCA_CAP_NONE,
	.owner		=	THIS_MODULE,
	.act		=	tcf_act_police,
	.dump		=	tcf_act_police_dump,
	.cleanup	=	tcf_act_police_cleanup,
	.lookup		=	tcf_act_police_hash_search,
	.init		=	tcf_act_police_locate,
	.walk		=	tcf_act_police_walker
};

static int __init
police_init_module(void)
{
	return tcf_register_action(&act_police_ops);
}

static void __exit
police_cleanup_module(void)
{
	tcf_unregister_action(&act_police_ops);
}

module_init(police_init_module);
module_exit(police_cleanup_module);

#else /* CONFIG_NET_CLS_ACT */

struct tcf_police * tcf_police_locate(struct rtattr *rta, struct rtattr *est)
{
	unsigned h;
	struct tcf_police *p;
	struct rtattr *tb[TCA_POLICE_MAX];
	struct tc_police *parm;

	if (rtattr_parse_nested(tb, TCA_POLICE_MAX, rta) < 0)
		return NULL;

	if (tb[TCA_POLICE_TBF-1] == NULL ||
	    RTA_PAYLOAD(tb[TCA_POLICE_TBF-1]) != sizeof(*parm))
		return NULL;

	parm = RTA_DATA(tb[TCA_POLICE_TBF-1]);

	if (parm->index && (p = tcf_police_lookup(parm->index)) != NULL) {
		p->refcnt++;
		return p;
	}

	p = kzalloc(sizeof(*p), GFP_KERNEL);
	if (p == NULL)
		return NULL;

	p->refcnt = 1;
	spin_lock_init(&p->lock);
	p->stats_lock = &p->lock;
	if (parm->rate.rate) {
		p->R_tab = qdisc_get_rtab(&parm->rate, tb[TCA_POLICE_RATE-1]);
		if (p->R_tab == NULL)
			goto failure;
		if (parm->peakrate.rate) {
			p->P_tab = qdisc_get_rtab(&parm->peakrate,
			                          tb[TCA_POLICE_PEAKRATE-1]);
			if (p->P_tab == NULL)
				goto failure;
		}
	}
	if (tb[TCA_POLICE_RESULT-1]) {
		if (RTA_PAYLOAD(tb[TCA_POLICE_RESULT-1]) != sizeof(u32))
			goto failure;
		p->result = *(u32*)RTA_DATA(tb[TCA_POLICE_RESULT-1]);
	}
#ifdef CONFIG_NET_ESTIMATOR
	if (tb[TCA_POLICE_AVRATE-1]) {
		if (RTA_PAYLOAD(tb[TCA_POLICE_AVRATE-1]) != sizeof(u32))
			goto failure;
		p->ewma_rate = *(u32*)RTA_DATA(tb[TCA_POLICE_AVRATE-1]);
	}
#endif
	p->toks = p->burst = parm->burst;
	p->mtu = parm->mtu;
	if (p->mtu == 0) {
		p->mtu = ~0;
		if (p->R_tab)
			p->mtu = 255<<p->R_tab->rate.cell_log;
	}
	if (p->P_tab)
		p->ptoks = L2T_P(p, p->mtu);
	PSCHED_GET_TIME(p->t_c);
	p->index = parm->index ? : tcf_police_new_index();
	p->action = parm->action;
#ifdef CONFIG_NET_ESTIMATOR
	if (est)
		gen_new_estimator(&p->bstats, &p->rate_est, p->stats_lock, est);
#endif
	h = tcf_police_hash(p->index);
	write_lock_bh(&police_lock);
	p->next = tcf_police_ht[h];
	tcf_police_ht[h] = p;
	write_unlock_bh(&police_lock);
	return p;

failure:
	if (p->R_tab)
		qdisc_put_rtab(p->R_tab);
	kfree(p);
	return NULL;
}

int tcf_police(struct sk_buff *skb, struct tcf_police *p)
{
	psched_time_t now;
	long toks;
	long ptoks = 0;

	spin_lock(&p->lock);

	p->bstats.bytes += skb->len;
	p->bstats.packets++;

#ifdef CONFIG_NET_ESTIMATOR
	if (p->ewma_rate && p->rate_est.bps >= p->ewma_rate) {
		p->qstats.overlimits++;
		spin_unlock(&p->lock);
		return p->action;
	}
#endif

	if (skb->len <= p->mtu) {
		if (p->R_tab == NULL) {
			spin_unlock(&p->lock);
			return p->result;
		}

		PSCHED_GET_TIME(now);

		toks = PSCHED_TDIFF_SAFE(now, p->t_c, p->burst);

		if (p->P_tab) {
			ptoks = toks + p->ptoks;
			if (ptoks > (long)L2T_P(p, p->mtu))
				ptoks = (long)L2T_P(p, p->mtu);
			ptoks -= L2T_P(p, skb->len);
		}
		toks += p->toks;
		if (toks > (long)p->burst)
			toks = p->burst;
		toks -= L2T(p, skb->len);

		if ((toks|ptoks) >= 0) {
			p->t_c = now;
			p->toks = toks;
			p->ptoks = ptoks;
			spin_unlock(&p->lock);
			return p->result;
		}
	}

	p->qstats.overlimits++;
	spin_unlock(&p->lock);
	return p->action;
}
EXPORT_SYMBOL(tcf_police);

int tcf_police_dump(struct sk_buff *skb, struct tcf_police *p)
{
	unsigned char	 *b = skb->tail;
	struct tc_police opt;

	opt.index = p->index;
	opt.action = p->action;
	opt.mtu = p->mtu;
	opt.burst = p->burst;
	if (p->R_tab)
		opt.rate = p->R_tab->rate;
	else
		memset(&opt.rate, 0, sizeof(opt.rate));
	if (p->P_tab)
		opt.peakrate = p->P_tab->rate;
	else
		memset(&opt.peakrate, 0, sizeof(opt.peakrate));
	RTA_PUT(skb, TCA_POLICE_TBF, sizeof(opt), &opt);
	if (p->result)
		RTA_PUT(skb, TCA_POLICE_RESULT, sizeof(int), &p->result);
#ifdef CONFIG_NET_ESTIMATOR
	if (p->ewma_rate)
		RTA_PUT(skb, TCA_POLICE_AVRATE, 4, &p->ewma_rate);
#endif
	return skb->len;

rtattr_failure:
	skb_trim(skb, b - skb->data);
	return -1;
}

int tcf_police_dump_stats(struct sk_buff *skb, struct tcf_police *p)
{
	struct gnet_dump d;
	
	if (gnet_stats_start_copy_compat(skb, TCA_STATS2, TCA_STATS,
			TCA_XSTATS, p->stats_lock, &d) < 0)
		goto errout;
	
	if (gnet_stats_copy_basic(&d, &p->bstats) < 0 ||
#ifdef CONFIG_NET_ESTIMATOR
	    gnet_stats_copy_rate_est(&d, &p->rate_est) < 0 ||
#endif
	    gnet_stats_copy_queue(&d, &p->qstats) < 0)
		goto errout;

	if (gnet_stats_finish_copy(&d) < 0)
		goto errout;

	return 0;

errout:
	return -1;
}

#endif /* CONFIG_NET_CLS_ACT */
Commit	Line	Data
1da177e4 LT	1	/*
	2	* net/sched/police.c Input police filter.
	3	*
	4	* This program is free software; you can redistribute it and/or
	5	* modify it under the terms of the GNU General Public License
	6	* as published by the Free Software Foundation; either version
	7	* 2 of the License, or (at your option) any later version.
	8	*
	9	* Authors: Alexey Kuznetsov, <[email protected]>
	10	* J Hadi Salim (action changes)
	11	*/
	12
	13	#include <asm/uaccess.h>
	14	#include <asm/system.h>
	15	#include <linux/bitops.h>
1da177e4 LT	16	#include <linux/module.h>
	17	#include <linux/types.h>
	18	#include <linux/kernel.h>
	19	#include <linux/sched.h>
	20	#include <linux/string.h>
	21	#include <linux/mm.h>
	22	#include <linux/socket.h>
	23	#include <linux/sockios.h>
	24	#include <linux/in.h>
	25	#include <linux/errno.h>
	26	#include <linux/interrupt.h>
	27	#include <linux/netdevice.h>
	28	#include <linux/skbuff.h>
	29	#include <linux/module.h>
	30	#include <linux/rtnetlink.h>
	31	#include <linux/init.h>
	32	#include <net/sock.h>
	33	#include <net/act_api.h>
	34
	35	#define L2T(p,L) ((p)->R_tab->data[(L)>>(p)->R_tab->rate.cell_log])
	36	#define L2T_P(p,L) ((p)->P_tab->data[(L)>>(p)->P_tab->rate.cell_log])
	37	#define PRIV(a) ((struct tcf_police *) (a)->priv)
	38
	39	/* use generic hash table */
	40	#define MY_TAB_SIZE 16
	41	#define MY_TAB_MASK 15
	42	static u32 idx_gen;
	43	static struct tcf_police *tcf_police_ht[MY_TAB_SIZE];
	44	/* Policer hash table lock */
	45	static DEFINE_RWLOCK(police_lock);
	46
	47	/* Each policer is serialized by its individual spinlock */
	48
	49	static __inline__ unsigned tcf_police_hash(u32 index)
	50	{
	51	return index&0xF;
	52	}
	53
	54	static __inline__ struct tcf_police * tcf_police_lookup(u32 index)
	55	{
	56	struct tcf_police *p;
	57
	58	read_lock(&police_lock);
	59	for (p = tcf_police_ht[tcf_police_hash(index)]; p; p = p->next) {
	60	if (p->index == index)
	61	break;
	62	}
	63	read_unlock(&police_lock);
	64	return p;
	65	}
	66
	67	#ifdef CONFIG_NET_CLS_ACT
83b950c8	68	static int tcf_act_police_walker(struct sk_buff skb, struct netlink_callback cb,
1da177e4 LT	69	int type, struct tc_action *a)
	70	{
	71	struct tcf_police *p;
	72	int err = 0, index = -1, i = 0, s_i = 0, n_i = 0;
	73	struct rtattr *r;
	74
	75	read_lock(&police_lock);
	76
	77	s_i = cb->args[0];
	78
	79	for (i = 0; i < MY_TAB_SIZE; i++) {
	80	p = tcf_police_ht[tcf_police_hash(i)];
	81
	82	for (; p; p = p->next) {
	83	index++;
	84	if (index < s_i)
	85	continue;
	86	a->priv = p;
	87	a->order = index;
	88	r = (struct rtattr*) skb->tail;
	89	RTA_PUT(skb, a->order, 0, NULL);
	90	if (type == RTM_DELACTION)
	91	err = tcf_action_dump_1(skb, a, 0, 1);
	92	else
	93	err = tcf_action_dump_1(skb, a, 0, 0);
	94	if (err < 0) {
	95	index--;
	96	skb_trim(skb, (u8*)r - skb->data);
	97	goto done;
	98	}
	99	r->rta_len = skb->tail - (u8*)r;
	100	n_i++;
	101	}
	102	}
	103	done:
	104	read_unlock(&police_lock);
	105	if (n_i)
	106	cb->args[0] += n_i;
	107	return n_i;
	108
	109	rtattr_failure:
	110	skb_trim(skb, (u8*)r - skb->data);
	111	goto done;
	112	}
	113
	114	static inline int
83b950c8	115	tcf_act_police_hash_search(struct tc_action *a, u32 index)
1da177e4 LT	116	{
	117	struct tcf_police *p = tcf_police_lookup(index);
	118
	119	if (p != NULL) {
	120	a->priv = p;
	121	return 1;
	122	} else {
	123	return 0;
	124	}
	125	}
	126	#endif
	127
	128	static inline u32 tcf_police_new_index(void)
	129	{
	130	do {
	131	if (++idx_gen == 0)
	132	idx_gen = 1;
	133	} while (tcf_police_lookup(idx_gen));
	134
	135	return idx_gen;
	136	}
	137
	138	void tcf_police_destroy(struct tcf_police *p)
	139	{
	140	unsigned h = tcf_police_hash(p->index);
	141	struct tcf_police **p1p;
	142
	143	for (p1p = &tcf_police_ht[h]; p1p; p1p = &(p1p)->next) {
	144	if (*p1p == p) {
	145	write_lock_bh(&police_lock);
	146	*p1p = p->next;
	147	write_unlock_bh(&police_lock);
	148	#ifdef CONFIG_NET_ESTIMATOR
	149	gen_kill_estimator(&p->bstats, &p->rate_est);
	150	#endif
	151	if (p->R_tab)
	152	qdisc_put_rtab(p->R_tab);
	153	if (p->P_tab)
	154	qdisc_put_rtab(p->P_tab);
	155	kfree(p);
	156	return;
	157	}
	158	}
	159	BUG_TRAP(0);
	160	}
	161
	162	#ifdef CONFIG_NET_CLS_ACT
	163	static int tcf_act_police_locate(struct rtattr rta, struct rtattr est,
	164	struct tc_action *a, int ovr, int bind)
	165	{
	166	unsigned h;
	167	int ret = 0, err;
	168	struct rtattr *tb[TCA_POLICE_MAX];
	169	struct tc_police *parm;
	170	struct tcf_police *p;
	171	struct qdisc_rate_table R_tab = NULL, P_tab = NULL;
	172
	173	if (rta == NULL \|\| rtattr_parse_nested(tb, TCA_POLICE_MAX, rta) < 0)
	174	return -EINVAL;
	175
	176	if (tb[TCA_POLICE_TBF-1] == NULL \|\|
	177	RTA_PAYLOAD(tb[TCA_POLICE_TBF-1]) != sizeof(*parm))
	178	return -EINVAL;
	179	parm = RTA_DATA(tb[TCA_POLICE_TBF-1]);
180
181	if (tb[TCA_POLICE_RESULT-1] != NULL &&
182	RTA_PAYLOAD(tb[TCA_POLICE_RESULT-1]) != sizeof(u32))
183	return -EINVAL;
184	if (tb[TCA_POLICE_RESULT-1] != NULL &&
185	RTA_PAYLOAD(tb[TCA_POLICE_RESULT-1]) != sizeof(u32))
186	return -EINVAL;
187
188	if (parm->index && (p = tcf_police_lookup(parm->index)) != NULL) {
189	a->priv = p;
190	if (bind) {
191	p->bindcnt += 1;
192	p->refcnt += 1;
193	}
194	if (ovr)
195	goto override;
196	return ret;
197	}
198
0da974f4	199	p = kzalloc(sizeof(*p), GFP_KERNEL);
1da177e4 LT	200	if (p == NULL)
1da177e4 LT	201	return -ENOMEM;
1da177e4 LT	202
	203	ret = ACT_P_CREATED;
	204	p->refcnt = 1;
	205	spin_lock_init(&p->lock);
	206	p->stats_lock = &p->lock;
	207	if (bind)
	208	p->bindcnt = 1;
	209	override:
	210	if (parm->rate.rate) {
	211	err = -ENOMEM;
	212	R_tab = qdisc_get_rtab(&parm->rate, tb[TCA_POLICE_RATE-1]);
	213	if (R_tab == NULL)
	214	goto failure;
	215	if (parm->peakrate.rate) {
	216	P_tab = qdisc_get_rtab(&parm->peakrate,
	217	tb[TCA_POLICE_PEAKRATE-1]);
	218	if (p->P_tab == NULL) {
	219	qdisc_put_rtab(R_tab);
	220	goto failure;
	221	}
	222	}
	223	}
	224	/* No failure allowed after this point */
	225	spin_lock_bh(&p->lock);
	226	if (R_tab != NULL) {
	227	qdisc_put_rtab(p->R_tab);
	228	p->R_tab = R_tab;
	229	}
	230	if (P_tab != NULL) {
	231	qdisc_put_rtab(p->P_tab);
	232	p->P_tab = P_tab;
	233	}
	234
	235	if (tb[TCA_POLICE_RESULT-1])
	236	p->result = (u32)RTA_DATA(tb[TCA_POLICE_RESULT-1]);
	237	p->toks = p->burst = parm->burst;
	238	p->mtu = parm->mtu;
	239	if (p->mtu == 0) {
	240	p->mtu = ~0;
	241	if (p->R_tab)
	242	p->mtu = 255<<p->R_tab->rate.cell_log;
	243	}
	244	if (p->P_tab)
	245	p->ptoks = L2T_P(p, p->mtu);
	246	p->action = parm->action;
	247
	248	#ifdef CONFIG_NET_ESTIMATOR
	249	if (tb[TCA_POLICE_AVRATE-1])
	250	p->ewma_rate = (u32)RTA_DATA(tb[TCA_POLICE_AVRATE-1]);
	251	if (est)
	252	gen_replace_estimator(&p->bstats, &p->rate_est, p->stats_lock, est);
	253	#endif
	254
	255	spin_unlock_bh(&p->lock);
	256	if (ret != ACT_P_CREATED)
	257	return ret;
	258
	259	PSCHED_GET_TIME(p->t_c);
	260	p->index = parm->index ? : tcf_police_new_index();
	261	h = tcf_police_hash(p->index);
	262	write_lock_bh(&police_lock);
	263	p->next = tcf_police_ht[h];
	264	tcf_police_ht[h] = p;
	265	write_unlock_bh(&police_lock);
266
267	a->priv = p;
268	return ret;
269
270	failure:
271	if (ret == ACT_P_CREATED)
272	kfree(p);
273	return err;
274	}
275
276	static int tcf_act_police_cleanup(struct tc_action *a, int bind)
277	{
278	struct tcf_police *p = PRIV(a);
279
280	if (p != NULL)
281	return tcf_police_release(p, bind);
282	return 0;
283	}
284
f43c5a0d	285	static int tcf_act_police(struct sk_buff skb, struct tc_action a,
abc3bc58	286	struct tcf_result *res)
1da177e4 LT	287	{
1da177e4 LT	288	psched_time_t now;
1da177e4 LT	289	struct tcf_police *p = PRIV(a);
	290	long toks;
	291	long ptoks = 0;
	292
	293	spin_lock(&p->lock);
	294
	295	p->bstats.bytes += skb->len;
	296	p->bstats.packets++;
	297
	298	#ifdef CONFIG_NET_ESTIMATOR
	299	if (p->ewma_rate && p->rate_est.bps >= p->ewma_rate) {
	300	p->qstats.overlimits++;
	301	spin_unlock(&p->lock);
	302	return p->action;
	303	}
	304	#endif
	305
	306	if (skb->len <= p->mtu) {
	307	if (p->R_tab == NULL) {
	308	spin_unlock(&p->lock);
	309	return p->result;
	310	}
	311
	312	PSCHED_GET_TIME(now);
	313
	314	toks = PSCHED_TDIFF_SAFE(now, p->t_c, p->burst);
	315
	316	if (p->P_tab) {
	317	ptoks = toks + p->ptoks;
	318	if (ptoks > (long)L2T_P(p, p->mtu))
	319	ptoks = (long)L2T_P(p, p->mtu);
	320	ptoks -= L2T_P(p, skb->len);
	321	}
	322	toks += p->toks;
	323	if (toks > (long)p->burst)
	324	toks = p->burst;
	325	toks -= L2T(p, skb->len);
	326
	327	if ((toks\|ptoks) >= 0) {
	328	p->t_c = now;
	329	p->toks = toks;
	330	p->ptoks = ptoks;
	331	spin_unlock(&p->lock);
	332	return p->result;
	333	}
	334	}
	335
	336	p->qstats.overlimits++;
	337	spin_unlock(&p->lock);
	338	return p->action;
	339	}
	340
	341	static int
	342	tcf_act_police_dump(struct sk_buff skb, struct tc_action a, int bind, int ref)
	343	{
	344	unsigned char *b = skb->tail;
	345	struct tc_police opt;
	346	struct tcf_police *p = PRIV(a);
	347
	348	opt.index = p->index;
	349	opt.action = p->action;
	350	opt.mtu = p->mtu;
	351	opt.burst = p->burst;
	352	opt.refcnt = p->refcnt - ref;
353	opt.bindcnt = p->bindcnt - bind;
354	if (p->R_tab)
355	opt.rate = p->R_tab->rate;
356	else
357	memset(&opt.rate, 0, sizeof(opt.rate));
358	if (p->P_tab)
359	opt.peakrate = p->P_tab->rate;
360	else
361	memset(&opt.peakrate, 0, sizeof(opt.peakrate));
362	RTA_PUT(skb, TCA_POLICE_TBF, sizeof(opt), &opt);
363	if (p->result)
364	RTA_PUT(skb, TCA_POLICE_RESULT, sizeof(int), &p->result);
365	#ifdef CONFIG_NET_ESTIMATOR
366	if (p->ewma_rate)
367	RTA_PUT(skb, TCA_POLICE_AVRATE, 4, &p->ewma_rate);
368	#endif
369	return skb->len;
370
371	rtattr_failure:
372	skb_trim(skb, b - skb->data);
373	return -1;
374	}
375
376	MODULE_AUTHOR("Alexey Kuznetsov");
377	MODULE_DESCRIPTION("Policing actions");
378	MODULE_LICENSE("GPL");
379
380	static struct tc_action_ops act_police_ops = {
381	.kind = "police",
382	.type = TCA_ID_POLICE,
383	.capab = TCA_CAP_NONE,
384	.owner = THIS_MODULE,
385	.act = tcf_act_police,
386	.dump = tcf_act_police_dump,
387	.cleanup = tcf_act_police_cleanup,
83b950c8	388	.lookup = tcf_act_police_hash_search,
1da177e4	389	.init = tcf_act_police_locate,
83b950c8	390	.walk = tcf_act_police_walker
1da177e4 LT	391	};
	392
	393	static int __init
	394	police_init_module(void)
	395	{
	396	return tcf_register_action(&act_police_ops);
	397	}
	398
	399	static void __exit
	400	police_cleanup_module(void)
	401	{
	402	tcf_unregister_action(&act_police_ops);
	403	}
	404
	405	module_init(police_init_module);
	406	module_exit(police_cleanup_module);
	407
31bd06eb	408	#else /* CONFIG_NET_CLS_ACT */
1da177e4 LT	409
	410	struct tcf_police * tcf_police_locate(struct rtattr rta, struct rtattr est)
	411	{
	412	unsigned h;
	413	struct tcf_police *p;
	414	struct rtattr *tb[TCA_POLICE_MAX];
	415	struct tc_police *parm;
	416
	417	if (rtattr_parse_nested(tb, TCA_POLICE_MAX, rta) < 0)
	418	return NULL;
	419
	420	if (tb[TCA_POLICE_TBF-1] == NULL \|\|
	421	RTA_PAYLOAD(tb[TCA_POLICE_TBF-1]) != sizeof(*parm))
	422	return NULL;
	423
	424	parm = RTA_DATA(tb[TCA_POLICE_TBF-1]);
	425
	426	if (parm->index && (p = tcf_police_lookup(parm->index)) != NULL) {
	427	p->refcnt++;
	428	return p;
	429	}
	430
0da974f4	431	p = kzalloc(sizeof(*p), GFP_KERNEL);
1da177e4 LT	432	if (p == NULL)
	433	return NULL;
	434
1da177e4 LT	435	p->refcnt = 1;
	436	spin_lock_init(&p->lock);
	437	p->stats_lock = &p->lock;
	438	if (parm->rate.rate) {
	439	p->R_tab = qdisc_get_rtab(&parm->rate, tb[TCA_POLICE_RATE-1]);
	440	if (p->R_tab == NULL)
	441	goto failure;
	442	if (parm->peakrate.rate) {
	443	p->P_tab = qdisc_get_rtab(&parm->peakrate,
	444	tb[TCA_POLICE_PEAKRATE-1]);
	445	if (p->P_tab == NULL)
	446	goto failure;
	447	}
	448	}
	449	if (tb[TCA_POLICE_RESULT-1]) {
	450	if (RTA_PAYLOAD(tb[TCA_POLICE_RESULT-1]) != sizeof(u32))
	451	goto failure;
	452	p->result = (u32)RTA_DATA(tb[TCA_POLICE_RESULT-1]);
	453	}
	454	#ifdef CONFIG_NET_ESTIMATOR
	455	if (tb[TCA_POLICE_AVRATE-1]) {
	456	if (RTA_PAYLOAD(tb[TCA_POLICE_AVRATE-1]) != sizeof(u32))
	457	goto failure;
	458	p->ewma_rate = (u32)RTA_DATA(tb[TCA_POLICE_AVRATE-1]);
	459	}
	460	#endif
	461	p->toks = p->burst = parm->burst;
	462	p->mtu = parm->mtu;
	463	if (p->mtu == 0) {
	464	p->mtu = ~0;
	465	if (p->R_tab)
	466	p->mtu = 255<<p->R_tab->rate.cell_log;
	467	}
	468	if (p->P_tab)
	469	p->ptoks = L2T_P(p, p->mtu);
	470	PSCHED_GET_TIME(p->t_c);
	471	p->index = parm->index ? : tcf_police_new_index();
	472	p->action = parm->action;
	473	#ifdef CONFIG_NET_ESTIMATOR
	474	if (est)
	475	gen_new_estimator(&p->bstats, &p->rate_est, p->stats_lock, est);
	476	#endif
	477	h = tcf_police_hash(p->index);
	478	write_lock_bh(&police_lock);
	479	p->next = tcf_police_ht[h];
	480	tcf_police_ht[h] = p;
	481	write_unlock_bh(&police_lock);
	482	return p;
	483
	484	failure:
	485	if (p->R_tab)
	486	qdisc_put_rtab(p->R_tab);
	487	kfree(p);
	488	return NULL;
	489	}
	490
	491	int tcf_police(struct sk_buff skb, struct tcf_police p)
	492	{
	493	psched_time_t now;
	494	long toks;
	495	long ptoks = 0;
	496
	497	spin_lock(&p->lock);
	498
499	p->bstats.bytes += skb->len;
500	p->bstats.packets++;
501
502	#ifdef CONFIG_NET_ESTIMATOR
503	if (p->ewma_rate && p->rate_est.bps >= p->ewma_rate) {
504	p->qstats.overlimits++;
505	spin_unlock(&p->lock);
506	return p->action;
507	}
508	#endif
509
510	if (skb->len <= p->mtu) {
511	if (p->R_tab == NULL) {
512	spin_unlock(&p->lock);
513	return p->result;
514	}
515
516	PSCHED_GET_TIME(now);
517
518	toks = PSCHED_TDIFF_SAFE(now, p->t_c, p->burst);
519
520	if (p->P_tab) {
521	ptoks = toks + p->ptoks;
522	if (ptoks > (long)L2T_P(p, p->mtu))
523	ptoks = (long)L2T_P(p, p->mtu);
524	ptoks -= L2T_P(p, skb->len);
525	}
526	toks += p->toks;
527	if (toks > (long)p->burst)
528	toks = p->burst;
529	toks -= L2T(p, skb->len);
530
531	if ((toks\|ptoks) >= 0) {
532	p->t_c = now;
533	p->toks = toks;
534	p->ptoks = ptoks;
535	spin_unlock(&p->lock);
536	return p->result;
537	}
538	}
539
540	p->qstats.overlimits++;
541	spin_unlock(&p->lock);
542	return p->action;
543	}
31bd06eb	544	EXPORT_SYMBOL(tcf_police);
1da177e4 LT	545
	546	int tcf_police_dump(struct sk_buff skb, struct tcf_police p)
	547	{
	548	unsigned char *b = skb->tail;
	549	struct tc_police opt;
	550
	551	opt.index = p->index;
	552	opt.action = p->action;
	553	opt.mtu = p->mtu;
	554	opt.burst = p->burst;
	555	if (p->R_tab)
	556	opt.rate = p->R_tab->rate;
	557	else
	558	memset(&opt.rate, 0, sizeof(opt.rate));
	559	if (p->P_tab)
	560	opt.peakrate = p->P_tab->rate;
	561	else
	562	memset(&opt.peakrate, 0, sizeof(opt.peakrate));
	563	RTA_PUT(skb, TCA_POLICE_TBF, sizeof(opt), &opt);
	564	if (p->result)
	565	RTA_PUT(skb, TCA_POLICE_RESULT, sizeof(int), &p->result);
	566	#ifdef CONFIG_NET_ESTIMATOR
	567	if (p->ewma_rate)
	568	RTA_PUT(skb, TCA_POLICE_AVRATE, 4, &p->ewma_rate);
	569	#endif
	570	return skb->len;
	571
	572	rtattr_failure:
	573	skb_trim(skb, b - skb->data);
	574	return -1;
	575	}
	576
	577	int tcf_police_dump_stats(struct sk_buff skb, struct tcf_police p)
	578	{
	579	struct gnet_dump d;
	580
	581	if (gnet_stats_start_copy_compat(skb, TCA_STATS2, TCA_STATS,
	582	TCA_XSTATS, p->stats_lock, &d) < 0)
	583	goto errout;
	584
	585	if (gnet_stats_copy_basic(&d, &p->bstats) < 0 \|\|
	586	#ifdef CONFIG_NET_ESTIMATOR
	587	gnet_stats_copy_rate_est(&d, &p->rate_est) < 0 \|\|
	588	#endif
	589	gnet_stats_copy_queue(&d, &p->qstats) < 0)
	590	goto errout;
	591
	592	if (gnet_stats_finish_copy(&d) < 0)
	593	goto errout;
	594
	595	return 0;
	596
	597	errout:
	598	return -1;
	599	}
	600
31bd06eb	601	#endif /* CONFIG_NET_CLS_ACT */