Release 4.8 net/sched/act_police.c
/*
* net/sched/act_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, <kuznet@ms2.inr.ac.ru>
* J Hadi Salim (action changes)
*/
#include <linux/module.h>
#include <linux/types.h>
#include <linux/kernel.h>
#include <linux/string.h>
#include <linux/errno.h>
#include <linux/skbuff.h>
#include <linux/rtnetlink.h>
#include <linux/init.h>
#include <linux/slab.h>
#include <net/act_api.h>
#include <net/netlink.h>
struct tcf_police {
struct tc_action common;
int tcfp_result;
u32 tcfp_ewma_rate;
s64 tcfp_burst;
u32 tcfp_mtu;
s64 tcfp_toks;
s64 tcfp_ptoks;
s64 tcfp_mtu_ptoks;
s64 tcfp_t_c;
struct psched_ratecfg rate;
bool rate_present;
struct psched_ratecfg peak;
bool peak_present;
};
#define to_police(pc) ((struct tcf_police *)pc)
#define POL_TAB_MASK 15
/* old policer structure from before tc actions */
struct tc_police_compat {
u32 index;
int action;
u32 limit;
u32 burst;
u32 mtu;
struct tc_ratespec rate;
struct tc_ratespec peakrate;
};
/* Each policer is serialized by its individual spinlock */
static int police_net_id;
static struct tc_action_ops act_police_ops;
static int tcf_act_police_walker(struct net *net, struct sk_buff *skb,
struct netlink_callback *cb, int type,
const struct tc_action_ops *ops)
{
struct tc_action_net *tn = net_generic(net, police_net_id);
return tcf_generic_walker(tn, skb, cb, type, ops);
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
jamal hadi salim | jamal hadi salim | 23 | 41.07% | 2 | 25.00% |
americo wang | americo wang | 19 | 33.93% | 2 | 25.00% |
pre-git | pre-git | 6 | 10.71% | 1 | 12.50% |
roman mashak | roman mashak | 6 | 10.71% | 1 | 12.50% |
patrick mchardy | patrick mchardy | 1 | 1.79% | 1 | 12.50% |
david s. miller | david s. miller | 1 | 1.79% | 1 | 12.50% |
| Total | 56 | 100.00% | 8 | 100.00% |
static const struct nla_policy police_policy[TCA_POLICE_MAX + 1] = {
[TCA_POLICE_RATE] = { .len = TC_RTAB_SIZE },
[TCA_POLICE_PEAKRATE] = { .len = TC_RTAB_SIZE },
[TCA_POLICE_AVRATE] = { .type = NLA_U32 },
[TCA_POLICE_RESULT] = { .type = NLA_U32 },
};
static int tcf_act_police_init(struct net *net, struct nlattr *nla,
struct nlattr *est, struct tc_action **a,
int ovr, int bind)
{
int ret = 0, err;
struct nlattr *tb[TCA_POLICE_MAX + 1];
struct tc_police *parm;
struct tcf_police *police;
struct qdisc_rate_table *R_tab = NULL, *P_tab = NULL;
struct tc_action_net *tn = net_generic(net, police_net_id);
bool exists = false;
int size;
if (nla == NULL)
return -EINVAL;
err = nla_parse_nested(tb, TCA_POLICE_MAX, nla, police_policy);
if (err < 0)
return err;
if (tb[TCA_POLICE_TBF] == NULL)
return -EINVAL;
size = nla_len(tb[TCA_POLICE_TBF]);
if (size != sizeof(*parm) && size != sizeof(struct tc_police_compat))
return -EINVAL;
parm = nla_data(tb[TCA_POLICE_TBF]);
exists = tcf_hash_check(tn, parm->index, a, bind);
if (exists && bind)
return 0;
if (!exists) {
ret = tcf_hash_create(tn, parm->index, NULL, a,
&act_police_ops, bind, false);
if (ret)
return ret;
ret = ACT_P_CREATED;
} else {
tcf_hash_release(*a, bind);
if (!ovr)
return -EEXIST;
}
police = to_police(*a);
if (parm->rate.rate) {
err = -ENOMEM;
R_tab = qdisc_get_rtab(&parm->rate, tb[TCA_POLICE_RATE]);
if (R_tab == NULL)
goto failure;
if (parm->peakrate.rate) {
P_tab = qdisc_get_rtab(&parm->peakrate,
tb[TCA_POLICE_PEAKRATE]);
if (P_tab == NULL)
goto failure;
}
}
spin_lock_bh(&police->tcf_lock);
if (est) {
err = gen_replace_estimator(&police->tcf_bstats, NULL,
&police->tcf_rate_est,
&police->tcf_lock,
NULL, est);
if (err)
goto failure_unlock;
} else if (tb[TCA_POLICE_AVRATE] &&
(ret == ACT_P_CREATED ||
!gen_estimator_active(&police->tcf_bstats,
&police->tcf_rate_est))) {
err = -EINVAL;
goto failure_unlock;
}
/* No failure allowed after this point */
police->tcfp_mtu = parm->mtu;
if (police->tcfp_mtu == 0) {
police->tcfp_mtu = ~0;
if (R_tab)
police->tcfp_mtu = 255 << R_tab->rate.cell_log;
}
if (R_tab) {
police->rate_present = true;
psched_ratecfg_precompute(&police->rate, &R_tab->rate, 0);
qdisc_put_rtab(R_tab);
} else {
police->rate_present = false;
}
if (P_tab) {
police->peak_present = true;
psched_ratecfg_precompute(&police->peak, &P_tab->rate, 0);
qdisc_put_rtab(P_tab);
} else {
police->peak_present = false;
}
if (tb[TCA_POLICE_RESULT])
police->tcfp_result = nla_get_u32(tb[TCA_POLICE_RESULT]);
police->tcfp_burst = PSCHED_TICKS2NS(parm->burst);
police->tcfp_toks = police->tcfp_burst;
if (police->peak_present) {
police->tcfp_mtu_ptoks = (s64) psched_l2t_ns(&police->peak,
police->tcfp_mtu);
police->tcfp_ptoks = police->tcfp_mtu_ptoks;
}
police->tcf_action = parm->action;
if (tb[TCA_POLICE_AVRATE])
police->tcfp_ewma_rate = nla_get_u32(tb[TCA_POLICE_AVRATE]);
spin_unlock_bh(&police->tcf_lock);
if (ret != ACT_P_CREATED)
return ret;
police->tcfp_t_c = ktime_get_ns();
tcf_hash_insert(tn, *a);
return ret;
failure_unlock:
spin_unlock_bh(&police->tcf_lock);
failure:
qdisc_put_rtab(P_tab);
qdisc_put_rtab(R_tab);
if (ret == ACT_P_CREATED)
tcf_hash_cleanup(*a, est);
return err;
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
jamal hadi salim | jamal hadi salim | 232 | 31.91% | 2 | 6.67% |
patrick mchardy | patrick mchardy | 131 | 18.02% | 9 | 30.00% |
jiri pirko | jiri pirko | 106 | 14.58% | 1 | 3.33% |
americo wang | americo wang | 91 | 12.52% | 7 | 23.33% |
stephen hemminger | stephen hemminger | 58 | 7.98% | 1 | 3.33% |
jarek poplawski | jarek poplawski | 38 | 5.23% | 1 | 3.33% |
david s. miller | david s. miller | 31 | 4.26% | 1 | 3.33% |
thomas graf | thomas graf | 23 | 3.16% | 1 | 3.33% |
eric dumazet | eric dumazet | 9 | 1.24% | 4 | 13.33% |
benjamin lahaise | benjamin lahaise | 5 | 0.69% | 1 | 3.33% |
john fastabend | john fastabend | 2 | 0.28% | 1 | 3.33% |
adrian bunk | adrian bunk | 1 | 0.14% | 1 | 3.33% |
| Total | 727 | 100.00% | 30 | 100.00% |
static int tcf_act_police(struct sk_buff *skb, const struct tc_action *a,
struct tcf_result *res)
{
struct tcf_police *police = to_police(a);
s64 now;
s64 toks;
s64 ptoks = 0;
spin_lock(&police->tcf_lock);
bstats_update(&police->tcf_bstats, skb);
tcf_lastuse_update(&police->tcf_tm);
if (police->tcfp_ewma_rate &&
police->tcf_rate_est.bps >= police->tcfp_ewma_rate) {
police->tcf_qstats.overlimits++;
if (police->tcf_action == TC_ACT_SHOT)
police->tcf_qstats.drops++;
spin_unlock(&police->tcf_lock);
return police->tcf_action;
}
if (qdisc_pkt_len(skb) <= police->tcfp_mtu) {
if (!police->rate_present) {
spin_unlock(&police->tcf_lock);
return police->tcfp_result;
}
now = ktime_get_ns();
toks = min_t(s64, now - police->tcfp_t_c,
police->tcfp_burst);
if (police->peak_present) {
ptoks = toks + police->tcfp_ptoks;
if (ptoks > police->tcfp_mtu_ptoks)
ptoks = police->tcfp_mtu_ptoks;
ptoks -= (s64) psched_l2t_ns(&police->peak,
qdisc_pkt_len(skb));
}
toks += police->tcfp_toks;
if (toks > police->tcfp_burst)
toks = police->tcfp_burst;
toks -= (s64) psched_l2t_ns(&police->rate, qdisc_pkt_len(skb));
if ((toks|ptoks) >= 0) {
police->tcfp_t_c = now;
police->tcfp_toks = toks;
police->tcfp_ptoks = ptoks;
spin_unlock(&police->tcf_lock);
return police->tcfp_result;
}
}
police->tcf_qstats.overlimits++;
if (police->tcf_action == TC_ACT_SHOT)
police->tcf_qstats.drops++;
spin_unlock(&police->tcf_lock);
return police->tcf_action;
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
jamal hadi salim | jamal hadi salim | 198 | 57.73% | 2 | 13.33% |
david s. miller | david s. miller | 59 | 17.20% | 1 | 6.67% |
jarek poplawski | jarek poplawski | 30 | 8.75% | 1 | 6.67% |
jiri pirko | jiri pirko | 26 | 7.58% | 1 | 6.67% |
jussi kivilinna | jussi kivilinna | 10 | 2.92% | 1 | 6.67% |
patrick mchardy | patrick mchardy | 10 | 2.92% | 4 | 26.67% |
eric dumazet | eric dumazet | 6 | 1.75% | 3 | 20.00% |
americo wang | americo wang | 3 | 0.87% | 1 | 6.67% |
adrian bunk | adrian bunk | 1 | 0.29% | 1 | 6.67% |
| Total | 343 | 100.00% | 15 | 100.00% |
static int
tcf_act_police_dump(struct sk_buff *skb, struct tc_action *a, int bind, int ref)
{
unsigned char *b = skb_tail_pointer(skb);
struct tcf_police *police = to_police(a);
struct tc_police opt = {
.index = police->tcf_index,
.action = police->tcf_action,
.mtu = police->tcfp_mtu,
.burst = PSCHED_NS2TICKS(police->tcfp_burst),
.refcnt = police->tcf_refcnt - ref,
.bindcnt = police->tcf_bindcnt - bind,
};
struct tcf_t t;
if (police->rate_present)
psched_ratecfg_getrate(&opt.rate, &police->rate);
if (police->peak_present)
psched_ratecfg_getrate(&opt.peakrate, &police->peak);
if (nla_put(skb, TCA_POLICE_TBF, sizeof(opt), &opt))
goto nla_put_failure;
if (police->tcfp_result &&
nla_put_u32(skb, TCA_POLICE_RESULT, police->tcfp_result))
goto nla_put_failure;
if (police->tcfp_ewma_rate &&
nla_put_u32(skb, TCA_POLICE_AVRATE, police->tcfp_ewma_rate))
goto nla_put_failure;
t.install = jiffies_to_clock_t(jiffies - police->tcf_tm.install);
t.lastuse = jiffies_to_clock_t(jiffies - police->tcf_tm.lastuse);
t.firstuse = jiffies_to_clock_t(jiffies - police->tcf_tm.firstuse);
t.expires = jiffies_to_clock_t(police->tcf_tm.expires);
if (nla_put_64bit(skb, TCA_POLICE_TM, sizeof(t), &t, TCA_POLICE_PAD))
goto nla_put_failure;
return skb->len;
nla_put_failure:
nlmsg_trim(skb, b);
return -1;
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
jamal hadi salim | jamal hadi salim | 185 | 62.29% | 3 | 18.75% |
david s. miller | david s. miller | 48 | 16.16% | 2 | 12.50% |
pre-git | pre-git | 27 | 9.09% | 2 | 12.50% |
jiri pirko | jiri pirko | 10 | 3.37% | 1 | 6.25% |
jeff mahoney | jeff mahoney | 9 | 3.03% | 1 | 6.25% |
eric dumazet | eric dumazet | 8 | 2.69% | 1 | 6.25% |
arnaldo carvalho de melo | arnaldo carvalho de melo | 4 | 1.35% | 2 | 12.50% |
americo wang | americo wang | 3 | 1.01% | 1 | 6.25% |
patrick mchardy | patrick mchardy | 2 | 0.67% | 2 | 12.50% |
adrian bunk | adrian bunk | 1 | 0.34% | 1 | 6.25% |
| Total | 297 | 100.00% | 16 | 100.00% |
static int tcf_police_search(struct net *net, struct tc_action **a, u32 index)
{
struct tc_action_net *tn = net_generic(net, police_net_id);
return tcf_hash_search(tn, a, index);
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
americo wang | americo wang | 42 | 100.00% | 2 | 100.00% |
| Total | 42 | 100.00% | 2 | 100.00% |
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,
.owner = THIS_MODULE,
.act = tcf_act_police,
.dump = tcf_act_police_dump,
.init = tcf_act_police_init,
.walk = tcf_act_police_walker,
.lookup = tcf_police_search,
.size = sizeof(struct tcf_police),
};
static __net_init int police_init_net(struct net *net)
{
struct tc_action_net *tn = net_generic(net, police_net_id);
return tc_action_net_init(tn, &act_police_ops, POL_TAB_MASK);
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
americo wang | americo wang | 34 | 97.14% | 1 | 50.00% |
pre-git | pre-git | 1 | 2.86% | 1 | 50.00% |
| Total | 35 | 100.00% | 2 | 100.00% |
static void __net_exit police_exit_net(struct net *net)
{
struct tc_action_net *tn = net_generic(net, police_net_id);
tc_action_net_exit(tn);
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
americo wang | americo wang | 29 | 100.00% | 1 | 100.00% |
| Total | 29 | 100.00% | 1 | 100.00% |
static struct pernet_operations police_net_ops = {
.init = police_init_net,
.exit = police_exit_net,
.id = &police_net_id,
.size = sizeof(struct tc_action_net),
};
static int __init
police_init_module(void)
{
return tcf_register_action(&act_police_ops, &police_net_ops);
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
jamal hadi salim | jamal hadi salim | 10 | 52.63% | 1 | 20.00% |
david s. miller | david s. miller | 5 | 26.32% | 1 | 20.00% |
americo wang | americo wang | 3 | 15.79% | 2 | 40.00% |
pre-git | pre-git | 1 | 5.26% | 1 | 20.00% |
| Total | 19 | 100.00% | 5 | 100.00% |
static void __exit
police_cleanup_module(void)
{
tcf_unregister_action(&act_police_ops, &police_net_ops);
}
Contributors
| Person | Tokens | Prop | Commits | CommitProp |
david s. miller | david s. miller | 15 | 83.33% | 1 | 50.00% |
americo wang | americo wang | 3 | 16.67% | 1 | 50.00% |
| Total | 18 | 100.00% | 2 | 100.00% |
module_init(police_init_module);
module_exit(police_cleanup_module);
Overall Contributors
| Person | Tokens | Prop | Commits | CommitProp |
jamal hadi salim | jamal hadi salim | 706 | 37.81% | 6 | 10.91% |
americo wang | americo wang | 286 | 15.32% | 9 | 16.36% |
patrick mchardy | patrick mchardy | 230 | 12.32% | 12 | 21.82% |
jiri pirko | jiri pirko | 195 | 10.44% | 3 | 5.45% |
david s. miller | david s. miller | 171 | 9.16% | 2 | 3.64% |
jarek poplawski | jarek poplawski | 68 | 3.64% | 2 | 3.64% |
pre-git | pre-git | 58 | 3.11% | 2 | 3.64% |
stephen hemminger | stephen hemminger | 58 | 3.11% | 1 | 1.82% |
thomas graf | thomas graf | 24 | 1.29% | 2 | 3.64% |
eric dumazet | eric dumazet | 23 | 1.23% | 6 | 10.91% |
jussi kivilinna | jussi kivilinna | 10 | 0.54% | 1 | 1.82% |
arnaldo carvalho de melo | arnaldo carvalho de melo | 10 | 0.54% | 3 | 5.45% |
jeff mahoney | jeff mahoney | 9 | 0.48% | 1 | 1.82% |
roman mashak | roman mashak | 6 | 0.32% | 1 | 1.82% |
benjamin lahaise | benjamin lahaise | 5 | 0.27% | 1 | 1.82% |
adrian bunk | adrian bunk | 3 | 0.16% | 1 | 1.82% |
tejun heo | tejun heo | 3 | 0.16% | 1 | 1.82% |
john fastabend | john fastabend | 2 | 0.11% | 1 | 1.82% |
| Total | 1867 | 100.00% | 55 | 100.00% |
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.