net/sched/sch_ingress.c

   1 /* net/sched/sch_ingress.c - Ingress and clsact qdisc
   2  *
   3  *              This program is free software; you can redistribute it and/or
   4  *              modify it under the terms of the GNU General Public License
   5  *              as published by the Free Software Foundation; either version
   6  *              2 of the License, or (at your option) any later version.
   7  *
   8  * Authors:     Jamal Hadi Salim 1999
   9  */
  10
  11 #include <linux/module.h>
  12 #include <linux/types.h>
  13 #include <linux/list.h>
  14 #include <linux/skbuff.h>
  15 #include <linux/rtnetlink.h>
  16
  17 #include <net/netlink.h>
  18 #include <net/pkt_sched.h>
  19
  20 static struct Qdisc *ingress_leaf(struct Qdisc *sch, unsigned long arg)
  21 {
  22         return NULL;
  23 }
  24
  25 static unsigned long ingress_get(struct Qdisc *sch, u32 classid)
  26 {
  27         return TC_H_MIN(classid) + 1;
  28 }
  29
  30 static unsigned long ingress_bind_filter(struct Qdisc *sch,
  31                                          unsigned long parent, u32 classid)
  32 {
  33         return ingress_get(sch, classid);
  34 }
  35
  36 static void ingress_put(struct Qdisc *sch, unsigned long cl)
  37 {
  38 }
  39
  40 static void ingress_walk(struct Qdisc *sch, struct qdisc_walker *walker)
  41 {
  42 }
  43
  44 static struct tcf_proto __rcu **ingress_find_tcf(struct Qdisc *sch,
  45                                                  unsigned long cl)
  46 {
  47         struct net_device *dev = qdisc_dev(sch);
  48
  49         return &dev->ingress_cl_list;
  50 }
  51
  52 static int ingress_init(struct Qdisc *sch, struct nlattr *opt)
  53 {
  54         net_inc_ingress_queue();
  55         sch->flags |= TCQ_F_CPUSTATS;
  56
  57         return 0;
  58 }
  59
  60 static void ingress_destroy(struct Qdisc *sch)
  61 {
  62         struct net_device *dev = qdisc_dev(sch);
  63
  64         tcf_destroy_chain(&dev->ingress_cl_list);
  65         net_dec_ingress_queue();
  66 }
  67
  68 static int ingress_dump(struct Qdisc *sch, struct sk_buff *skb)
  69 {
  70         struct nlattr *nest;
  71
  72         nest = nla_nest_start(skb, TCA_OPTIONS);
  73         if (nest == NULL)
  74                 goto nla_put_failure;
  75
  76         return nla_nest_end(skb, nest);
  77
  78 nla_put_failure:
  79         nla_nest_cancel(skb, nest);
  80         return -1;
  81 }
  82
  83 static const struct Qdisc_class_ops ingress_class_ops = {
  84         .leaf           =       ingress_leaf,
  85         .get            =       ingress_get,
  86         .put            =       ingress_put,
  87         .walk           =       ingress_walk,
  88         .tcf_chain      =       ingress_find_tcf,
  89         .bind_tcf       =       ingress_bind_filter,
  90         .unbind_tcf     =       ingress_put,
  91 };
  92
  93 static struct Qdisc_ops ingress_qdisc_ops __read_mostly = {
  94         .cl_ops         =       &ingress_class_ops,
  95         .id             =       "ingress",
  96         .init           =       ingress_init,
  97         .destroy        =       ingress_destroy,
  98         .dump           =       ingress_dump,
  99         .owner          =       THIS_MODULE,
 100 };
 101
 102 static unsigned long clsact_get(struct Qdisc *sch, u32 classid)
 103 {
 104         switch (TC_H_MIN(classid)) {
 105         case TC_H_MIN(TC_H_MIN_INGRESS):
 106         case TC_H_MIN(TC_H_MIN_EGRESS):
 107                 return TC_H_MIN(classid);
 108         default:
 109                 return 0;
 110         }
 111 }
 112
 113 static unsigned long clsact_bind_filter(struct Qdisc *sch,
 114                                         unsigned long parent, u32 classid)
 115 {
 116         return clsact_get(sch, classid);
 117 }
 118
 119 static struct tcf_proto __rcu **clsact_find_tcf(struct Qdisc *sch,
 120                                                 unsigned long cl)
 121 {
 122         struct net_device *dev = qdisc_dev(sch);
 123
 124         switch (cl) {
 125         case TC_H_MIN(TC_H_MIN_INGRESS):
 126                 return &dev->ingress_cl_list;
 127         case TC_H_MIN(TC_H_MIN_EGRESS):
 128                 return &dev->egress_cl_list;
 129         default:
 130                 return NULL;
 131         }
 132 }
 133
 134 static int clsact_init(struct Qdisc *sch, struct nlattr *opt)
 135 {
 136         net_inc_ingress_queue();
 137         net_inc_egress_queue();
 138
 139         sch->flags |= TCQ_F_CPUSTATS;
 140
 141         return 0;
 142 }
 143
 144 static void clsact_destroy(struct Qdisc *sch)
 145 {
 146         struct net_device *dev = qdisc_dev(sch);
 147
 148         tcf_destroy_chain(&dev->ingress_cl_list);
 149         tcf_destroy_chain(&dev->egress_cl_list);
 150
 151         net_dec_ingress_queue();
 152         net_dec_egress_queue();
 153 }
 154
 155 static const struct Qdisc_class_ops clsact_class_ops = {
 156         .leaf           =       ingress_leaf,
 157         .get            =       clsact_get,
 158         .put            =       ingress_put,
 159         .walk           =       ingress_walk,
 160         .tcf_chain      =       clsact_find_tcf,
 161         .bind_tcf       =       clsact_bind_filter,
 162         .unbind_tcf     =       ingress_put,
 163 };
 164
 165 static struct Qdisc_ops clsact_qdisc_ops __read_mostly = {
 166         .cl_ops         =       &clsact_class_ops,
 167         .id             =       "clsact",
 168         .init           =       clsact_init,
 169         .destroy        =       clsact_destroy,
 170         .dump           =       ingress_dump,
 171         .owner          =       THIS_MODULE,
 172 };
 173
 174 static int __init ingress_module_init(void)
 175 {
 176         int ret;
 177
 178         ret = register_qdisc(&ingress_qdisc_ops);
 179         if (!ret) {
 180                 ret = register_qdisc(&clsact_qdisc_ops);
 181                 if (ret)
 182                         unregister_qdisc(&ingress_qdisc_ops);
 183         }
 184
 185         return ret;
 186 }
 187
 188 static void __exit ingress_module_exit(void)
 189 {
 190         unregister_qdisc(&ingress_qdisc_ops);
 191         unregister_qdisc(&clsact_qdisc_ops);
 192 }
 193
 194 module_init(ingress_module_init);
 195 module_exit(ingress_module_exit);
 196
 197 MODULE_ALIAS("sch_clsact");
 198 MODULE_LICENSE("GPL");