diff options
author | Imre Kaloz <kaloz@openwrt.org> | 2008-06-11 11:35:49 +0000 |
---|---|---|
committer | Imre Kaloz <kaloz@openwrt.org> | 2008-06-11 11:35:49 +0000 |
commit | 02a4a8019e478173e2a9c01589d0176738ce45f7 (patch) | |
tree | 7d79d23ff5e35707b94caddf7774f48cb0b76809 /target/linux/generic-2.6/patches-2.6.25 | |
parent | 46e3535d08baf2508ef7d9fef60d568ed3cb0052 (diff) | |
download | mtk-20170518-02a4a8019e478173e2a9c01589d0176738ce45f7.zip mtk-20170518-02a4a8019e478173e2a9c01589d0176738ce45f7.tar.gz mtk-20170518-02a4a8019e478173e2a9c01589d0176738ce45f7.tar.bz2 |
add newer, fixed IMQ patch for 2.6.25 and 2.6.26
SVN-Revision: 11433
Diffstat (limited to 'target/linux/generic-2.6/patches-2.6.25')
-rw-r--r-- | target/linux/generic-2.6/patches-2.6.25/150-netfilter_imq.patch | 207 |
1 files changed, 128 insertions, 79 deletions
diff --git a/target/linux/generic-2.6/patches-2.6.25/150-netfilter_imq.patch b/target/linux/generic-2.6/patches-2.6.25/150-netfilter_imq.patch index e5db1d8..fbe2d91 100644 --- a/target/linux/generic-2.6/patches-2.6.25/150-netfilter_imq.patch +++ b/target/linux/generic-2.6/patches-2.6.25/150-netfilter_imq.patch @@ -1,6 +1,6 @@ --- /dev/null +++ b/drivers/net/imq.c -@@ -0,0 +1,410 @@ +@@ -0,0 +1,464 @@ +/* + * Pseudo-driver for the intermediate queue device. + * @@ -24,8 +24,8 @@ + * of IMQ again: http://www.linuximq.net + * + * -+ * 2004/06/30 - New version of IMQ patch to kernels <=2.6.7 including -+ * the following changes: ++ * 2004/06/30 - New version of IMQ patch to kernels <=2.6.7 ++ * including the following changes: + * + * - Correction of ipv6 support "+"s issue (Hasso Tepper) + * - Correction of imq_init_devs() issue that resulted in @@ -49,6 +49,12 @@ + * Kevin Shanahan, Richard Lucassen, Valery Dachev (hopefully + * I didn't forget anybody). I apologize again for my lack of time. + * ++ * ++ * 2008/06/07 - Changed imq.c to use qdisc_run() instead of ++ * qdisc_restart() and moved qdisc_run() to tasklet to avoid ++ * recursive locking. (Jussi Kivilinna) ++ * ++ * + * More info at: http://www.linuximq.net/ (Andre Correa) + */ + @@ -61,14 +67,17 @@ +#include <linux/if_arp.h> +#include <linux/netfilter.h> +#include <linux/netfilter_ipv4.h> -+#if defined(CONFIG_IPV6) || defined (CONFIG_IPV6_MODULE) ++#if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE) + #include <linux/netfilter_ipv6.h> +#endif +#include <linux/imq.h> +#include <net/pkt_sched.h> +#include <net/netfilter/nf_queue.h> + -+extern int qdisc_restart1(struct net_device *dev); ++struct imq_private { ++ struct tasklet_struct tasklet; ++ int tasklet_pending; ++}; + +static nf_hookfn imq_nf_hook; + @@ -96,7 +105,7 @@ +#endif +}; + -+#if defined(CONFIG_IPV6) || defined (CONFIG_IPV6_MODULE) ++#if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE) +static struct nf_hook_ops imq_ingress_ipv6 = { + .hook = imq_nf_hook, + .owner = THIS_MODULE, @@ -132,29 +141,27 @@ + +static struct net_device_stats *imq_get_stats(struct net_device *dev) +{ -+ return (struct net_device_stats *)dev->priv; ++ return &dev->stats; +} + +/* called for packets kfree'd in qdiscs at places other than enqueue */ +static void imq_skb_destructor(struct sk_buff *skb) +{ -+ struct nf_queue_entry *info = skb->nf_queue_entry; -+ -+ if (info) { -+ if (info->indev) -+ dev_put(info->indev); -+ if (info->outdev) -+ dev_put(info->outdev); -+ kfree(info); ++ struct nf_queue_entry *entry = skb->nf_queue_entry; ++ ++ if (entry) { ++ if (entry->indev) ++ dev_put(entry->indev); ++ if (entry->outdev) ++ dev_put(entry->outdev); ++ kfree(entry); + } +} + +static int imq_dev_xmit(struct sk_buff *skb, struct net_device *dev) +{ -+ struct net_device_stats *stats = (struct net_device_stats*) dev->priv; -+ -+ stats->tx_bytes += skb->len; -+ stats->tx_packets++; ++ dev->stats.tx_bytes += skb->len; ++ dev->stats.tx_packets++; + + skb->imq_flags = 0; + skb->destructor = NULL; @@ -164,58 +171,56 @@ + return 0; +} + -+static int imq_nf_queue(struct nf_queue_entry *info, unsigned queue_num) ++static int imq_nf_queue(struct nf_queue_entry *entry, unsigned queue_num) +{ + struct net_device *dev; -+ struct net_device_stats *stats; ++ struct imq_private *priv; + struct sk_buff *skb2 = NULL; + struct Qdisc *q; -+ unsigned int index = info->skb->imq_flags&IMQ_F_IFMASK; ++ unsigned int index = entry->skb->imq_flags & IMQ_F_IFMASK; + int ret = -1; + + if (index > numdevs) + return -1; + + dev = imq_devs + index; ++ priv = netdev_priv(dev); + if (!(dev->flags & IFF_UP)) { -+ info->skb->imq_flags = 0; -+ nf_reinject(info, NF_ACCEPT); ++ entry->skb->imq_flags = 0; ++ nf_reinject(entry, NF_ACCEPT); + return 0; + } + dev->last_rx = jiffies; + -+ if (info->skb->destructor) { -+ skb2 = info->skb; -+ info->skb = skb_clone(info->skb, GFP_ATOMIC); -+ if (!info->skb) ++ if (entry->skb->destructor) { ++ skb2 = entry->skb; ++ entry->skb = skb_clone(entry->skb, GFP_ATOMIC); ++ if (!entry->skb) + return -1; + } -+ info->skb->nf_queue_entry = info; ++ entry->skb->nf_queue_entry = entry; + -+ stats = (struct net_device_stats *)dev->priv; -+ stats->rx_bytes+= info->skb->len; -+ stats->rx_packets++; ++ dev->stats.rx_bytes += entry->skb->len; ++ dev->stats.rx_packets++; + + spin_lock_bh(&dev->queue_lock); + q = dev->qdisc; + if (q->enqueue) { -+ q->enqueue(skb_get(info->skb), q); -+ if (skb_shared(info->skb)) { -+ info->skb->destructor = imq_skb_destructor; -+ kfree_skb(info->skb); ++ q->enqueue(skb_get(entry->skb), q); ++ if (skb_shared(entry->skb)) { ++ entry->skb->destructor = imq_skb_destructor; ++ kfree_skb(entry->skb); + ret = 0; + } + } -+ if (spin_is_locked(&dev->_xmit_lock)) -+ netif_schedule(dev); -+ else -+ while (!netif_queue_stopped(dev) && qdisc_restart1(dev) < 0) -+ /* NOTHING */; + + spin_unlock_bh(&dev->queue_lock); + ++ if (!test_and_set_bit(1, &priv->tasklet_pending)) ++ tasklet_schedule(&priv->tasklet); ++ + if (skb2) -+ kfree_skb(ret ? info->skb : skb2); ++ kfree_skb(ret ? entry->skb : skb2); + + return ret; +} @@ -225,6 +230,18 @@ + .outfn = imq_nf_queue, +}; + ++static void qdisc_run_tasklet(unsigned long arg) ++{ ++ struct net_device *dev = (struct net_device *)arg; ++ struct imq_private *priv = netdev_priv(dev); ++ ++ spin_lock(&dev->queue_lock); ++ qdisc_run(dev); ++ spin_unlock(&dev->queue_lock); ++ ++ clear_bit(1, &priv->tasklet_pending); ++} ++ +static unsigned int imq_nf_hook(unsigned int hook, struct sk_buff *pskb, + const struct net_device *indev, + const struct net_device *outdev, @@ -236,30 +253,59 @@ + return NF_ACCEPT; +} + ++static int imq_close(struct net_device *dev) ++{ ++ struct imq_private *priv = netdev_priv(dev); ++ ++ tasklet_kill(&priv->tasklet); ++ netif_stop_queue(dev); ++ ++ return 0; ++} ++ ++static int imq_open(struct net_device *dev) ++{ ++ struct imq_private *priv = netdev_priv(dev); ++ ++ tasklet_init(&priv->tasklet, qdisc_run_tasklet, (unsigned long)dev); ++ netif_start_queue(dev); ++ ++ return 0; ++} + +static int __init imq_init_hooks(void) +{ + int err; + + err = nf_register_queue_handler(PF_INET, &nfqh); -+ if (err > 0) ++ if (err) + goto err1; -+ if ((err = nf_register_hook(&imq_ingress_ipv4))) ++ ++ err = nf_register_hook(&imq_ingress_ipv4); ++ if (err) + goto err2; -+ if ((err = nf_register_hook(&imq_egress_ipv4))) ++ ++ err = nf_register_hook(&imq_egress_ipv4); ++ if (err) + goto err3; -+#if defined(CONFIG_IPV6) || defined (CONFIG_IPV6_MODULE) -+ if ((err = nf_register_queue_handler(PF_INET6, &nfqh))) ++ ++#if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE) ++ err = nf_register_queue_handler(PF_INET6, &nfqh); ++ if (err) + goto err4; -+ if ((err = nf_register_hook(&imq_ingress_ipv6))) ++ ++ err = nf_register_hook(&imq_ingress_ipv6); ++ if (err) + goto err5; -+ if ((err = nf_register_hook(&imq_egress_ipv6))) ++ ++ err = nf_register_hook(&imq_egress_ipv6); ++ if (err) + goto err6; +#endif + + return 0; + -+#if defined(CONFIG_IPV6) || defined (CONFIG_IPV6_MODULE) ++#if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE) +err6: + nf_unregister_hook(&imq_ingress_ipv6); +err5: @@ -277,7 +323,7 @@ + +static void __exit imq_unhook(void) +{ -+#if defined(CONFIG_IPV6) || defined (CONFIG_IPV6_MODULE) ++#if defined(CONFIG_IPV6) || defined(CONFIG_IPV6_MODULE) + nf_unregister_hook(&imq_ingress_ipv6); + nf_unregister_hook(&imq_egress_ipv6); + nf_unregister_queue_handler(PF_INET6, &nfqh); @@ -290,14 +336,17 @@ +static int __init imq_dev_init(struct net_device *dev) +{ + dev->hard_start_xmit = imq_dev_xmit; ++ dev->open = imq_open; ++ dev->get_stats = imq_get_stats; ++ dev->stop = imq_close; + dev->type = ARPHRD_VOID; + dev->mtu = 16000; + dev->tx_queue_len = 11000; + dev->flags = IFF_NOARP; -+ dev->priv = kzalloc(sizeof(struct net_device_stats), GFP_KERNEL); ++ ++ dev->priv = kzalloc(sizeof(struct imq_private), GFP_KERNEL); + if (dev->priv == NULL) + return -ENOMEM; -+ dev->get_stats = imq_get_stats; + + return 0; +} @@ -310,8 +359,7 @@ +static int __init imq_init_devs(struct net *net) +{ + struct net_device *dev; -+ int i,j; -+ j = numdevs; ++ int i, j; + + if (!numdevs || numdevs > IMQ_MAX_DEVS) { + printk(KERN_ERR "IMQ: numdevs has to be betweed 1 and %u\n", @@ -324,9 +372,9 @@ + return -ENOMEM; + + /* we start counting at zero */ -+ numdevs--; ++ j = numdevs - 1; + -+ for (i = 0, dev = imq_devs; i <= numdevs; i++, dev++) { ++ for (i = 0, dev = imq_devs; i <= j; i++, dev++) { + strcpy(dev->name, "imq%d"); + dev->init = imq_dev_init; + dev->uninit = imq_dev_uninit; @@ -335,7 +383,7 @@ + if (register_netdev(dev) < 0) + goto err_register; + } -+ printk(KERN_INFO "IMQ starting with %u devices...\n", j); ++ printk(KERN_INFO "IMQ starting with %u devices...\n", numdevs); + return 0; + +err_register: @@ -360,11 +408,14 @@ +{ + int err; + -+ if ((err = imq_init_devs(net))) { ++ err = imq_init_devs(net); ++ if (err) { + printk(KERN_ERR "IMQ: Error trying imq_init_devs(net)\n"); + return err; + } -+ if ((err = imq_init_hooks())) { ++ ++ err = imq_init_hooks(); ++ if (err) { + printk(KERN_ERR "IMQ: Error trying imq_init_hooks()\n"); + imq_cleanup_devs(); + return err; @@ -394,23 +445,26 @@ +} + +static struct pernet_operations __net_initdata imq_net_ops = { -+ .init = imq_init_module, -+ .exit = imq_exit_module, ++ .init = imq_init_module, ++ .exit = imq_exit_module, +}; -+ ++ +static int __init imq_init(void) +{ -+ return register_pernet_device(&imq_net_ops); ++ return register_pernet_device(&imq_net_ops); +} + +module_init(imq_init); -+//module_exit(imq_cleanup_module); ++/*module_exit(imq_cleanup_module);*/ + +module_param(numdevs, int, 0); -+MODULE_PARM_DESC(numdevs, "number of IMQ devices (how many imq* devices will be created)"); ++MODULE_PARM_DESC(numdevs, "number of IMQ devices (how many imq* devices will " ++ "be created)"); +MODULE_AUTHOR("http://www.linuximq.net"); -+MODULE_DESCRIPTION("Pseudo-driver for the intermediate queue device. See http://www.linuximq.net/ for more information."); ++MODULE_DESCRIPTION("Pseudo-driver for the intermediate queue device. See " ++ "http://www.linuximq.net/ for more information."); +MODULE_LICENSE("GPL"); ++ --- a/drivers/net/Kconfig +++ b/drivers/net/Kconfig @@ -117,6 +117,129 @@ @@ -716,7 +770,7 @@ +config IP_NF_TARGET_IMQ + tristate "IMQ target support" -+ depends on IP_NF_MANGLE && IMQ ++ depends on IP_NF_MANGLE + help + This option adds a `IMQ' target which is used to specify if and + to which IMQ device packets should get enqueued/dequeued. @@ -818,7 +872,7 @@ +config IP6_NF_TARGET_IMQ + tristate "IMQ target support" -+ depends on IP6_NF_MANGLE && IMQ ++ depends on IP6_NF_MANGLE + help + This option adds a `IMQ' target which is used to specify if and + to which imq device packets should get enqueued/dequeued. @@ -840,16 +894,11 @@ --- a/net/sched/sch_generic.c +++ b/net/sched/sch_generic.c -@@ -182,6 +182,12 @@ - return ret; +@@ -203,6 +203,7 @@ + + clear_bit(__LINK_STATE_QDISC_RUNNING, &dev->state); } ++EXPORT_SYMBOL(__qdisc_run); -+int qdisc_restart1(struct net_device *dev) -+{ -+ return qdisc_restart(dev); -+} -+EXPORT_SYMBOL(qdisc_restart1); -+ - void __qdisc_run(struct net_device *dev) + static void dev_watchdog(unsigned long arg) { - unsigned long start_time = jiffies; |