netfilter: Fix memory leak in nf_register_net_hook
[deliverable/linux.git] / net / netfilter / core.c
CommitLineData
601e68e1 1/* netfilter.c: look after the filters for various protocols.
f6ebe77f
HW
2 * Heavily influenced by the old firewall.c by David Bonn and Alan Cox.
3 *
4 * Thanks to Rob `CmdrTaco' Malda for not influencing this code in any
5 * way.
6 *
7 * Rusty Russell (C)2000 -- This code is GPL.
f229f6ce 8 * Patrick McHardy (c) 2006-2012
f6ebe77f 9 */
f6ebe77f
HW
10#include <linux/kernel.h>
11#include <linux/netfilter.h>
12#include <net/protocol.h>
13#include <linux/init.h>
14#include <linux/skbuff.h>
15#include <linux/wait.h>
16#include <linux/module.h>
17#include <linux/interrupt.h>
18#include <linux/if.h>
19#include <linux/netdevice.h>
56768644 20#include <linux/netfilter_ipv6.h>
f6ebe77f
HW
21#include <linux/inetdevice.h>
22#include <linux/proc_fs.h>
d486dd1f 23#include <linux/mutex.h>
5a0e3ad6 24#include <linux/slab.h>
457c4cbc 25#include <net/net_namespace.h>
f6ebe77f
HW
26#include <net/sock.h>
27
28#include "nf_internals.h"
29
d486dd1f 30static DEFINE_MUTEX(afinfo_mutex);
bce8032e 31
0906a372 32const struct nf_afinfo __rcu *nf_afinfo[NFPROTO_NUMPROTO] __read_mostly;
bce8032e 33EXPORT_SYMBOL(nf_afinfo);
2a7851bf
FW
34const struct nf_ipv6_ops __rcu *nf_ipv6_ops __read_mostly;
35EXPORT_SYMBOL_GPL(nf_ipv6_ops);
bce8032e 36
e7c8899f
FW
37DEFINE_PER_CPU(bool, nf_skb_duplicated);
38EXPORT_SYMBOL_GPL(nf_skb_duplicated);
39
1e796fda 40int nf_register_afinfo(const struct nf_afinfo *afinfo)
bce8032e 41{
7926dbfa 42 mutex_lock(&afinfo_mutex);
a9b3cd7f 43 RCU_INIT_POINTER(nf_afinfo[afinfo->family], afinfo);
d486dd1f 44 mutex_unlock(&afinfo_mutex);
bce8032e
PM
45 return 0;
46}
47EXPORT_SYMBOL_GPL(nf_register_afinfo);
48
1e796fda 49void nf_unregister_afinfo(const struct nf_afinfo *afinfo)
bce8032e 50{
d486dd1f 51 mutex_lock(&afinfo_mutex);
a9b3cd7f 52 RCU_INIT_POINTER(nf_afinfo[afinfo->family], NULL);
d486dd1f 53 mutex_unlock(&afinfo_mutex);
bce8032e
PM
54 synchronize_rcu();
55}
56EXPORT_SYMBOL_GPL(nf_unregister_afinfo);
57
d1c85c2e 58#ifdef HAVE_JUMP_LABEL
c5905afb 59struct static_key nf_hooks_needed[NFPROTO_NUMPROTO][NF_MAX_HOOKS];
a2d7ec58
ED
60EXPORT_SYMBOL(nf_hooks_needed);
61#endif
62
fd706d69 63static DEFINE_MUTEX(nf_hook_mutex);
f6ebe77f 64
085db2c0
EB
65static struct list_head *find_nf_hook_list(struct net *net,
66 const struct nf_hook_ops *reg)
f6ebe77f 67{
0edcf282 68 struct list_head *nf_hook_list = NULL;
f6ebe77f 69
0edcf282 70 if (reg->pf != NFPROTO_NETDEV)
085db2c0 71 nf_hook_list = &net->nf.hooks[reg->pf][reg->hooknum];
0edcf282 72 else if (reg->hooknum == NF_NETDEV_INGRESS) {
e687ad60 73#ifdef CONFIG_NETFILTER_INGRESS
085db2c0 74 if (reg->dev && dev_net(reg->dev) == net)
e687ad60 75 nf_hook_list = &reg->dev->nf_hooks_ingress;
e687ad60 76#endif
e687ad60 77 }
0edcf282
EB
78 return nf_hook_list;
79}
e687ad60 80
085db2c0 81int nf_register_net_hook(struct net *net, const struct nf_hook_ops *reg)
0edcf282
EB
82{
83 struct list_head *nf_hook_list;
085db2c0
EB
84 struct nf_hook_ops *elem, *new;
85
86 new = kzalloc(sizeof(*new), GFP_KERNEL);
87 if (!new)
88 return -ENOMEM;
0edcf282 89
085db2c0
EB
90 new->hook = reg->hook;
91 new->dev = reg->dev;
92 new->owner = reg->owner;
93 new->priv = reg->priv;
94 new->pf = reg->pf;
95 new->hooknum = reg->hooknum;
96 new->priority = reg->priority;
97
98 nf_hook_list = find_nf_hook_list(net, reg);
e317fa50
EB
99 if (!nf_hook_list) {
100 kfree(new);
0edcf282 101 return -ENOENT;
e317fa50 102 }
0edcf282
EB
103
104 mutex_lock(&nf_hook_mutex);
e687ad60 105 list_for_each_entry(elem, nf_hook_list, list) {
4c610979 106 if (reg->priority < elem->priority)
f6ebe77f
HW
107 break;
108 }
085db2c0 109 list_add_rcu(&new->list, elem->list.prev);
fd706d69 110 mutex_unlock(&nf_hook_mutex);
4c091156
EB
111#ifdef CONFIG_NETFILTER_INGRESS
112 if (reg->pf == NFPROTO_NETDEV && reg->hooknum == NF_NETDEV_INGRESS)
113 net_inc_ingress_queue();
114#endif
d1c85c2e 115#ifdef HAVE_JUMP_LABEL
c5905afb 116 static_key_slow_inc(&nf_hooks_needed[reg->pf][reg->hooknum]);
a2d7ec58 117#endif
f6ebe77f
HW
118 return 0;
119}
085db2c0 120EXPORT_SYMBOL(nf_register_net_hook);
f6ebe77f 121
085db2c0 122void nf_unregister_net_hook(struct net *net, const struct nf_hook_ops *reg)
f6ebe77f 123{
085db2c0
EB
124 struct list_head *nf_hook_list;
125 struct nf_hook_ops *elem;
126
127 nf_hook_list = find_nf_hook_list(net, reg);
128 if (!nf_hook_list)
129 return;
130
fd706d69 131 mutex_lock(&nf_hook_mutex);
085db2c0
EB
132 list_for_each_entry(elem, nf_hook_list, list) {
133 if ((reg->hook == elem->hook) &&
134 (reg->dev == elem->dev) &&
135 (reg->owner == elem->owner) &&
136 (reg->priv == elem->priv) &&
137 (reg->pf == elem->pf) &&
138 (reg->hooknum == elem->hooknum) &&
139 (reg->priority == elem->priority)) {
140 list_del_rcu(&elem->list);
141 break;
142 }
143 }
fd706d69 144 mutex_unlock(&nf_hook_mutex);
085db2c0
EB
145 if (&elem->list == nf_hook_list) {
146 WARN(1, "nf_unregister_net_hook: hook not found!\n");
147 return;
148 }
e687ad60 149#ifdef CONFIG_NETFILTER_INGRESS
4c091156
EB
150 if (reg->pf == NFPROTO_NETDEV && reg->hooknum == NF_NETDEV_INGRESS)
151 net_dec_ingress_queue();
e687ad60 152#endif
d1c85c2e 153#ifdef HAVE_JUMP_LABEL
c5905afb 154 static_key_slow_dec(&nf_hooks_needed[reg->pf][reg->hooknum]);
a2d7ec58 155#endif
f6ebe77f 156 synchronize_net();
085db2c0
EB
157 nf_queue_nf_hook_drop(elem);
158 kfree(elem);
159}
160EXPORT_SYMBOL(nf_unregister_net_hook);
161
162int nf_register_net_hooks(struct net *net, const struct nf_hook_ops *reg,
163 unsigned int n)
164{
165 unsigned int i;
166 int err = 0;
167
168 for (i = 0; i < n; i++) {
169 err = nf_register_net_hook(net, &reg[i]);
170 if (err)
171 goto err;
172 }
173 return err;
174
175err:
176 if (i > 0)
177 nf_unregister_net_hooks(net, reg, i);
178 return err;
179}
180EXPORT_SYMBOL(nf_register_net_hooks);
181
182void nf_unregister_net_hooks(struct net *net, const struct nf_hook_ops *reg,
183 unsigned int n)
184{
185 while (n-- > 0)
186 nf_unregister_net_hook(net, &reg[n]);
187}
188EXPORT_SYMBOL(nf_unregister_net_hooks);
189
190static LIST_HEAD(nf_hook_list);
191
192int nf_register_hook(struct nf_hook_ops *reg)
193{
194 struct net *net, *last;
195 int ret;
196
197 rtnl_lock();
198 for_each_net(net) {
199 ret = nf_register_net_hook(net, reg);
200 if (ret && ret != -ENOENT)
201 goto rollback;
202 }
203 list_add_tail(&reg->list, &nf_hook_list);
204 rtnl_unlock();
205
206 return 0;
207rollback:
208 last = net;
209 for_each_net(net) {
210 if (net == last)
211 break;
212 nf_unregister_net_hook(net, reg);
213 }
214 rtnl_unlock();
215 return ret;
216}
217EXPORT_SYMBOL(nf_register_hook);
218
219void nf_unregister_hook(struct nf_hook_ops *reg)
220{
221 struct net *net;
222
223 rtnl_lock();
224 list_del(&reg->list);
225 for_each_net(net)
226 nf_unregister_net_hook(net, reg);
227 rtnl_unlock();
f6ebe77f
HW
228}
229EXPORT_SYMBOL(nf_unregister_hook);
230
972d1cb1
PM
231int nf_register_hooks(struct nf_hook_ops *reg, unsigned int n)
232{
233 unsigned int i;
234 int err = 0;
235
236 for (i = 0; i < n; i++) {
237 err = nf_register_hook(&reg[i]);
238 if (err)
239 goto err;
240 }
241 return err;
242
243err:
244 if (i > 0)
245 nf_unregister_hooks(reg, i);
246 return err;
247}
248EXPORT_SYMBOL(nf_register_hooks);
249
250void nf_unregister_hooks(struct nf_hook_ops *reg, unsigned int n)
251{
f68c5301
CG
252 while (n-- > 0)
253 nf_unregister_hook(&reg[n]);
972d1cb1
PM
254}
255EXPORT_SYMBOL(nf_unregister_hooks);
256
f6ebe77f 257unsigned int nf_iterate(struct list_head *head,
3db05fea 258 struct sk_buff *skb,
cfdfab31
DM
259 struct nf_hook_state *state,
260 struct nf_hook_ops **elemp)
f6ebe77f
HW
261{
262 unsigned int verdict;
263
264 /*
265 * The caller must not block between calls to this
266 * function because of risk of continuing from deleted element.
267 */
2a6decfd 268 list_for_each_entry_continue_rcu((*elemp), head, list) {
cfdfab31 269 if (state->thresh > (*elemp)->priority)
f6ebe77f
HW
270 continue;
271
272 /* Optimization: we don't need to hold module
601e68e1 273 reference here, since function can't sleep. --RR */
de9963f0 274repeat:
238e54c9 275 verdict = (*elemp)->hook(*elemp, skb, state);
f6ebe77f
HW
276 if (verdict != NF_ACCEPT) {
277#ifdef CONFIG_NETFILTER_DEBUG
278 if (unlikely((verdict & NF_VERDICT_MASK)
279 > NF_MAX_VERDICT)) {
280 NFDEBUG("Evil return from %p(%u).\n",
cfdfab31 281 (*elemp)->hook, state->hook);
f6ebe77f
HW
282 continue;
283 }
284#endif
2a6decfd 285 if (verdict != NF_REPEAT)
f6ebe77f 286 return verdict;
de9963f0 287 goto repeat;
f6ebe77f
HW
288 }
289 }
290 return NF_ACCEPT;
291}
292
293
294/* Returns 1 if okfn() needs to be executed by the caller,
295 * -EPERM for NF_DROP, 0 otherwise. */
cfdfab31 296int nf_hook_slow(struct sk_buff *skb, struct nf_hook_state *state)
f6ebe77f 297{
2a6decfd 298 struct nf_hook_ops *elem;
f6ebe77f
HW
299 unsigned int verdict;
300 int ret = 0;
301
302 /* We may already have this, but read-locks nest anyway */
303 rcu_read_lock();
304
f7191483 305 elem = list_entry_rcu(state->hook_list, struct nf_hook_ops, list);
f6ebe77f 306next_hook:
f7191483 307 verdict = nf_iterate(state->hook_list, skb, state, &elem);
f6ebe77f
HW
308 if (verdict == NF_ACCEPT || verdict == NF_STOP) {
309 ret = 1;
da683650 310 } else if ((verdict & NF_VERDICT_MASK) == NF_DROP) {
3db05fea 311 kfree_skb(skb);
f615df76 312 ret = NF_DROP_GETERR(verdict);
da683650
EP
313 if (ret == 0)
314 ret = -EPERM;
f9c63990 315 } else if ((verdict & NF_VERDICT_MASK) == NF_QUEUE) {
cfdfab31
DM
316 int err = nf_queue(skb, elem, state,
317 verdict >> NF_VERDICT_QBITS);
563e1232
FW
318 if (err < 0) {
319 if (err == -ECANCELED)
06cdb634 320 goto next_hook;
563e1232 321 if (err == -ESRCH &&
94b27cc3
FW
322 (verdict & NF_VERDICT_FLAG_QUEUE_BYPASS))
323 goto next_hook;
06cdb634
FW
324 kfree_skb(skb);
325 }
f6ebe77f 326 }
f6ebe77f
HW
327 rcu_read_unlock();
328 return ret;
329}
330EXPORT_SYMBOL(nf_hook_slow);
331
332
37d41879 333int skb_make_writable(struct sk_buff *skb, unsigned int writable_len)
f6ebe77f 334{
37d41879 335 if (writable_len > skb->len)
f6ebe77f
HW
336 return 0;
337
338 /* Not exclusive use of packet? Must copy. */
37d41879
HX
339 if (!skb_cloned(skb)) {
340 if (writable_len <= skb_headlen(skb))
341 return 1;
342 } else if (skb_clone_writable(skb, writable_len))
343 return 1;
344
345 if (writable_len <= skb_headlen(skb))
346 writable_len = 0;
347 else
348 writable_len -= skb_headlen(skb);
349
350 return !!__pskb_pull_tail(skb, writable_len);
f6ebe77f
HW
351}
352EXPORT_SYMBOL(skb_make_writable);
353
c0cd1156 354#if IS_ENABLED(CONFIG_NF_CONNTRACK)
f6ebe77f
HW
355/* This does not belong here, but locally generated errors need it if connection
356 tracking in use: without this, connection may not be in hash table, and hence
357 manufactured ICMP or RST packets will not be associated with it. */
312a0c16
PM
358void (*ip_ct_attach)(struct sk_buff *, const struct sk_buff *)
359 __rcu __read_mostly;
f6ebe77f
HW
360EXPORT_SYMBOL(ip_ct_attach);
361
312a0c16 362void nf_ct_attach(struct sk_buff *new, const struct sk_buff *skb)
f6ebe77f 363{
312a0c16 364 void (*attach)(struct sk_buff *, const struct sk_buff *);
f6ebe77f 365
c3a47ab3
PM
366 if (skb->nfct) {
367 rcu_read_lock();
368 attach = rcu_dereference(ip_ct_attach);
369 if (attach)
370 attach(new, skb);
371 rcu_read_unlock();
f6ebe77f
HW
372 }
373}
374EXPORT_SYMBOL(nf_ct_attach);
de6e05c4 375
0e60ebe0 376void (*nf_ct_destroy)(struct nf_conntrack *) __rcu __read_mostly;
de6e05c4
YK
377EXPORT_SYMBOL(nf_ct_destroy);
378
379void nf_conntrack_destroy(struct nf_conntrack *nfct)
380{
381 void (*destroy)(struct nf_conntrack *);
382
383 rcu_read_lock();
384 destroy = rcu_dereference(nf_ct_destroy);
385 BUG_ON(destroy == NULL);
386 destroy(nfct);
387 rcu_read_unlock();
388}
389EXPORT_SYMBOL(nf_conntrack_destroy);
9cb01766 390
5a05fae5 391struct nfq_ct_hook __rcu *nfq_ct_hook __read_mostly;
9cb01766
PNA
392EXPORT_SYMBOL_GPL(nfq_ct_hook);
393
d584a61a
PNA
394struct nfq_ct_nat_hook __rcu *nfq_ct_nat_hook __read_mostly;
395EXPORT_SYMBOL_GPL(nfq_ct_nat_hook);
396
de6e05c4 397#endif /* CONFIG_NF_CONNTRACK */
f6ebe77f 398
c7232c99
PM
399#ifdef CONFIG_NF_NAT_NEEDED
400void (*nf_nat_decode_session_hook)(struct sk_buff *, struct flowi *);
401EXPORT_SYMBOL(nf_nat_decode_session_hook);
402#endif
403
085db2c0
EB
404static int nf_register_hook_list(struct net *net)
405{
406 struct nf_hook_ops *elem;
407 int ret;
408
409 rtnl_lock();
410 list_for_each_entry(elem, &nf_hook_list, list) {
411 ret = nf_register_net_hook(net, elem);
412 if (ret && ret != -ENOENT)
413 goto out_undo;
414 }
415 rtnl_unlock();
416 return 0;
417
418out_undo:
419 list_for_each_entry_continue_reverse(elem, &nf_hook_list, list)
420 nf_unregister_net_hook(net, elem);
421 rtnl_unlock();
422 return ret;
423}
424
425static void nf_unregister_hook_list(struct net *net)
426{
427 struct nf_hook_ops *elem;
428
429 rtnl_lock();
430 list_for_each_entry(elem, &nf_hook_list, list)
431 nf_unregister_net_hook(net, elem);
432 rtnl_unlock();
433}
434
f3c1a44a
G
435static int __net_init netfilter_net_init(struct net *net)
436{
085db2c0
EB
437 int i, h, ret;
438
439 for (i = 0; i < ARRAY_SIZE(net->nf.hooks); i++) {
440 for (h = 0; h < NF_MAX_HOOKS; h++)
441 INIT_LIST_HEAD(&net->nf.hooks[i][h]);
442 }
443
f3c1a44a
G
444#ifdef CONFIG_PROC_FS
445 net->nf.proc_netfilter = proc_net_mkdir(net, "netfilter",
446 net->proc_net);
12202fa7
PNA
447 if (!net->nf.proc_netfilter) {
448 if (!net_eq(net, &init_net))
449 pr_err("cannot create netfilter proc entry");
450
f3c1a44a
G
451 return -ENOMEM;
452 }
453#endif
085db2c0
EB
454 ret = nf_register_hook_list(net);
455 if (ret)
456 remove_proc_entry("netfilter", net->proc_net);
457
458 return ret;
f3c1a44a
G
459}
460
461static void __net_exit netfilter_net_exit(struct net *net)
462{
085db2c0 463 nf_unregister_hook_list(net);
f3c1a44a
G
464 remove_proc_entry("netfilter", net->proc_net);
465}
466
467static struct pernet_operations netfilter_net_ops = {
468 .init = netfilter_net_init,
469 .exit = netfilter_net_exit,
470};
471
6d11cfdb 472int __init netfilter_init(void)
f6ebe77f 473{
085db2c0 474 int ret;
f6ebe77f 475
6d11cfdb
PNA
476 ret = register_pernet_subsys(&netfilter_net_ops);
477 if (ret < 0)
478 goto err;
479
480 ret = netfilter_log_init();
481 if (ret < 0)
482 goto err_pernet;
f6ebe77f 483
6d11cfdb
PNA
484 return 0;
485err_pernet:
486 unregister_pernet_subsys(&netfilter_net_ops);
487err:
488 return ret;
f6ebe77f 489}
This page took 0.774485 seconds and 5 git commands to generate.