1 /* Expectation handling for nf_conntrack. */
2
3 /* (C) 1999-2001 Paul `Rusty' Russell
4 * (C) 2002-2006 Netfilter Core Team <coreteam@netfilter.org>
5 * (C) 2003,2004 USAGI/WIDE Project <http://www.linux-ipv6.org>
6 * (c) 2005-2012 Patrick McHardy <kaber@trash.net>
7 *
8 * This program is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License version 2 as
10 * published by the Free Software Foundation.
11 */
12
13 #include <linux/types.h>
14 #include <linux/netfilter.h>
15 #include <linux/skbuff.h>
16 #include <linux/proc_fs.h>
17 #include <linux/seq_file.h>
18 #include <linux/stddef.h>
19 #include <linux/slab.h>
20 #include <linux/err.h>
21 #include <linux/percpu.h>
22 #include <linux/kernel.h>
23 #include <linux/jhash.h>
24 #include <linux/moduleparam.h>
25 #include <linux/export.h>
26 #include <net/net_namespace.h>
27 #include <net/netns/hash.h>
28
29 #include <net/netfilter/nf_conntrack.h>
30 #include <net/netfilter/nf_conntrack_core.h>
31 #include <net/netfilter/nf_conntrack_expect.h>
32 #include <net/netfilter/nf_conntrack_helper.h>
33 #include <net/netfilter/nf_conntrack_tuple.h>
34 #include <net/netfilter/nf_conntrack_zones.h>
35
36 unsigned int nf_ct_expect_hsize __read_mostly;
37 EXPORT_SYMBOL_GPL(nf_ct_expect_hsize);
38
39 struct hlist_head *nf_ct_expect_hash __read_mostly;
40 EXPORT_SYMBOL_GPL(nf_ct_expect_hash);
41
42 unsigned int nf_ct_expect_max __read_mostly;
43
44 static struct kmem_cache *nf_ct_expect_cachep __read_mostly;
45 static unsigned int nf_ct_expect_hashrnd __read_mostly;
46
47 /* nf_conntrack_expect helper functions */
nf_ct_unlink_expect_report(struct nf_conntrack_expect * exp,u32 portid,int report)48 void nf_ct_unlink_expect_report(struct nf_conntrack_expect *exp,
49 u32 portid, int report)
50 {
51 struct nf_conn_help *master_help = nfct_help(exp->master);
52 struct net *net = nf_ct_exp_net(exp);
53
54 WARN_ON(!master_help);
55 WARN_ON(timer_pending(&exp->timeout));
56
57 hlist_del_rcu(&exp->hnode);
58 net->ct.expect_count--;
59
60 hlist_del_rcu(&exp->lnode);
61 master_help->expecting[exp->class]--;
62
63 nf_ct_expect_event_report(IPEXP_DESTROY, exp, portid, report);
64 nf_ct_expect_put(exp);
65
66 NF_CT_STAT_INC(net, expect_delete);
67 }
68 EXPORT_SYMBOL_GPL(nf_ct_unlink_expect_report);
69
nf_ct_expectation_timed_out(struct timer_list * t)70 static void nf_ct_expectation_timed_out(struct timer_list *t)
71 {
72 struct nf_conntrack_expect *exp = from_timer(exp, t, timeout);
73
74 spin_lock_bh(&nf_conntrack_expect_lock);
75 nf_ct_unlink_expect(exp);
76 spin_unlock_bh(&nf_conntrack_expect_lock);
77 nf_ct_expect_put(exp);
78 }
79
nf_ct_expect_dst_hash(const struct net * n,const struct nf_conntrack_tuple * tuple)80 static unsigned int nf_ct_expect_dst_hash(const struct net *n, const struct nf_conntrack_tuple *tuple)
81 {
82 unsigned int hash, seed;
83
84 get_random_once(&nf_ct_expect_hashrnd, sizeof(nf_ct_expect_hashrnd));
85
86 seed = nf_ct_expect_hashrnd ^ net_hash_mix(n);
87
88 hash = jhash2(tuple->dst.u3.all, ARRAY_SIZE(tuple->dst.u3.all),
89 (((tuple->dst.protonum ^ tuple->src.l3num) << 16) |
90 (__force __u16)tuple->dst.u.all) ^ seed);
91
92 return reciprocal_scale(hash, nf_ct_expect_hsize);
93 }
94
95 static bool
nf_ct_exp_equal(const struct nf_conntrack_tuple * tuple,const struct nf_conntrack_expect * i,const struct nf_conntrack_zone * zone,const struct net * net)96 nf_ct_exp_equal(const struct nf_conntrack_tuple *tuple,
97 const struct nf_conntrack_expect *i,
98 const struct nf_conntrack_zone *zone,
99 const struct net *net)
100 {
101 return nf_ct_tuple_mask_cmp(tuple, &i->tuple, &i->mask) &&
102 net_eq(net, nf_ct_net(i->master)) &&
103 nf_ct_zone_equal_any(i->master, zone);
104 }
105
nf_ct_remove_expect(struct nf_conntrack_expect * exp)106 bool nf_ct_remove_expect(struct nf_conntrack_expect *exp)
107 {
108 if (del_timer(&exp->timeout)) {
109 nf_ct_unlink_expect(exp);
110 nf_ct_expect_put(exp);
111 return true;
112 }
113 return false;
114 }
115 EXPORT_SYMBOL_GPL(nf_ct_remove_expect);
116
117 struct nf_conntrack_expect *
__nf_ct_expect_find(struct net * net,const struct nf_conntrack_zone * zone,const struct nf_conntrack_tuple * tuple)118 __nf_ct_expect_find(struct net *net,
119 const struct nf_conntrack_zone *zone,
120 const struct nf_conntrack_tuple *tuple)
121 {
122 struct nf_conntrack_expect *i;
123 unsigned int h;
124
125 if (!net->ct.expect_count)
126 return NULL;
127
128 h = nf_ct_expect_dst_hash(net, tuple);
129 hlist_for_each_entry_rcu(i, &nf_ct_expect_hash[h], hnode) {
130 if (nf_ct_exp_equal(tuple, i, zone, net))
131 return i;
132 }
133 return NULL;
134 }
135 EXPORT_SYMBOL_GPL(__nf_ct_expect_find);
136
137 /* Just find a expectation corresponding to a tuple. */
138 struct nf_conntrack_expect *
nf_ct_expect_find_get(struct net * net,const struct nf_conntrack_zone * zone,const struct nf_conntrack_tuple * tuple)139 nf_ct_expect_find_get(struct net *net,
140 const struct nf_conntrack_zone *zone,
141 const struct nf_conntrack_tuple *tuple)
142 {
143 struct nf_conntrack_expect *i;
144
145 rcu_read_lock();
146 i = __nf_ct_expect_find(net, zone, tuple);
147 if (i && !refcount_inc_not_zero(&i->use))
148 i = NULL;
149 rcu_read_unlock();
150
151 return i;
152 }
153 EXPORT_SYMBOL_GPL(nf_ct_expect_find_get);
154
155 /* If an expectation for this connection is found, it gets delete from
156 * global list then returned. */
157 struct nf_conntrack_expect *
nf_ct_find_expectation(struct net * net,const struct nf_conntrack_zone * zone,const struct nf_conntrack_tuple * tuple)158 nf_ct_find_expectation(struct net *net,
159 const struct nf_conntrack_zone *zone,
160 const struct nf_conntrack_tuple *tuple)
161 {
162 struct nf_conntrack_expect *i, *exp = NULL;
163 unsigned int h;
164
165 if (!net->ct.expect_count)
166 return NULL;
167
168 h = nf_ct_expect_dst_hash(net, tuple);
169 hlist_for_each_entry(i, &nf_ct_expect_hash[h], hnode) {
170 if (!(i->flags & NF_CT_EXPECT_INACTIVE) &&
171 nf_ct_exp_equal(tuple, i, zone, net)) {
172 exp = i;
173 break;
174 }
175 }
176 if (!exp)
177 return NULL;
178
179 /* If master is not in hash table yet (ie. packet hasn't left
180 this machine yet), how can other end know about expected?
181 Hence these are not the droids you are looking for (if
182 master ct never got confirmed, we'd hold a reference to it
183 and weird things would happen to future packets). */
184 if (!nf_ct_is_confirmed(exp->master))
185 return NULL;
186
187 /* Avoid race with other CPUs, that for exp->master ct, is
188 * about to invoke ->destroy(), or nf_ct_delete() via timeout
189 * or early_drop().
190 *
191 * The atomic_inc_not_zero() check tells: If that fails, we
192 * know that the ct is being destroyed. If it succeeds, we
193 * can be sure the ct cannot disappear underneath.
194 */
195 if (unlikely(nf_ct_is_dying(exp->master) ||
196 !atomic_inc_not_zero(&exp->master->ct_general.use)))
197 return NULL;
198
199 if (exp->flags & NF_CT_EXPECT_PERMANENT) {
200 refcount_inc(&exp->use);
201 return exp;
202 } else if (del_timer(&exp->timeout)) {
203 nf_ct_unlink_expect(exp);
204 return exp;
205 }
206 /* Undo exp->master refcnt increase, if del_timer() failed */
207 nf_ct_put(exp->master);
208
209 return NULL;
210 }
211
212 /* delete all expectations for this conntrack */
nf_ct_remove_expectations(struct nf_conn * ct)213 void nf_ct_remove_expectations(struct nf_conn *ct)
214 {
215 struct nf_conn_help *help = nfct_help(ct);
216 struct nf_conntrack_expect *exp;
217 struct hlist_node *next;
218
219 /* Optimization: most connection never expect any others. */
220 if (!help)
221 return;
222
223 spin_lock_bh(&nf_conntrack_expect_lock);
224 hlist_for_each_entry_safe(exp, next, &help->expectations, lnode) {
225 nf_ct_remove_expect(exp);
226 }
227 spin_unlock_bh(&nf_conntrack_expect_lock);
228 }
229 EXPORT_SYMBOL_GPL(nf_ct_remove_expectations);
230
231 /* Would two expected things clash? */
expect_clash(const struct nf_conntrack_expect * a,const struct nf_conntrack_expect * b)232 static inline int expect_clash(const struct nf_conntrack_expect *a,
233 const struct nf_conntrack_expect *b)
234 {
235 /* Part covered by intersection of masks must be unequal,
236 otherwise they clash */
237 struct nf_conntrack_tuple_mask intersect_mask;
238 int count;
239
240 intersect_mask.src.u.all = a->mask.src.u.all & b->mask.src.u.all;
241
242 for (count = 0; count < NF_CT_TUPLE_L3SIZE; count++){
243 intersect_mask.src.u3.all[count] =
244 a->mask.src.u3.all[count] & b->mask.src.u3.all[count];
245 }
246
247 return nf_ct_tuple_mask_cmp(&a->tuple, &b->tuple, &intersect_mask) &&
248 net_eq(nf_ct_net(a->master), nf_ct_net(b->master)) &&
249 nf_ct_zone_equal_any(a->master, nf_ct_zone(b->master));
250 }
251
expect_matches(const struct nf_conntrack_expect * a,const struct nf_conntrack_expect * b)252 static inline int expect_matches(const struct nf_conntrack_expect *a,
253 const struct nf_conntrack_expect *b)
254 {
255 return a->master == b->master &&
256 nf_ct_tuple_equal(&a->tuple, &b->tuple) &&
257 nf_ct_tuple_mask_equal(&a->mask, &b->mask) &&
258 net_eq(nf_ct_net(a->master), nf_ct_net(b->master)) &&
259 nf_ct_zone_equal_any(a->master, nf_ct_zone(b->master));
260 }
261
262 /* Generally a bad idea to call this: could have matched already. */
nf_ct_unexpect_related(struct nf_conntrack_expect * exp)263 void nf_ct_unexpect_related(struct nf_conntrack_expect *exp)
264 {
265 spin_lock_bh(&nf_conntrack_expect_lock);
266 nf_ct_remove_expect(exp);
267 spin_unlock_bh(&nf_conntrack_expect_lock);
268 }
269 EXPORT_SYMBOL_GPL(nf_ct_unexpect_related);
270
271 /* We don't increase the master conntrack refcount for non-fulfilled
272 * conntracks. During the conntrack destruction, the expectations are
273 * always killed before the conntrack itself */
nf_ct_expect_alloc(struct nf_conn * me)274 struct nf_conntrack_expect *nf_ct_expect_alloc(struct nf_conn *me)
275 {
276 struct nf_conntrack_expect *new;
277
278 new = kmem_cache_alloc(nf_ct_expect_cachep, GFP_ATOMIC);
279 if (!new)
280 return NULL;
281
282 new->master = me;
283 refcount_set(&new->use, 1);
284 return new;
285 }
286 EXPORT_SYMBOL_GPL(nf_ct_expect_alloc);
287
nf_ct_expect_init(struct nf_conntrack_expect * exp,unsigned int class,u_int8_t family,const union nf_inet_addr * saddr,const union nf_inet_addr * daddr,u_int8_t proto,const __be16 * src,const __be16 * dst)288 void nf_ct_expect_init(struct nf_conntrack_expect *exp, unsigned int class,
289 u_int8_t family,
290 const union nf_inet_addr *saddr,
291 const union nf_inet_addr *daddr,
292 u_int8_t proto, const __be16 *src, const __be16 *dst)
293 {
294 int len;
295
296 if (family == AF_INET)
297 len = 4;
298 else
299 len = 16;
300
301 exp->flags = 0;
302 exp->class = class;
303 exp->expectfn = NULL;
304 exp->helper = NULL;
305 exp->tuple.src.l3num = family;
306 exp->tuple.dst.protonum = proto;
307
308 if (saddr) {
309 memcpy(&exp->tuple.src.u3, saddr, len);
310 if (sizeof(exp->tuple.src.u3) > len)
311 /* address needs to be cleared for nf_ct_tuple_equal */
312 memset((void *)&exp->tuple.src.u3 + len, 0x00,
313 sizeof(exp->tuple.src.u3) - len);
314 memset(&exp->mask.src.u3, 0xFF, len);
315 if (sizeof(exp->mask.src.u3) > len)
316 memset((void *)&exp->mask.src.u3 + len, 0x00,
317 sizeof(exp->mask.src.u3) - len);
318 } else {
319 memset(&exp->tuple.src.u3, 0x00, sizeof(exp->tuple.src.u3));
320 memset(&exp->mask.src.u3, 0x00, sizeof(exp->mask.src.u3));
321 }
322
323 if (src) {
324 exp->tuple.src.u.all = *src;
325 exp->mask.src.u.all = htons(0xFFFF);
326 } else {
327 exp->tuple.src.u.all = 0;
328 exp->mask.src.u.all = 0;
329 }
330
331 memcpy(&exp->tuple.dst.u3, daddr, len);
332 if (sizeof(exp->tuple.dst.u3) > len)
333 /* address needs to be cleared for nf_ct_tuple_equal */
334 memset((void *)&exp->tuple.dst.u3 + len, 0x00,
335 sizeof(exp->tuple.dst.u3) - len);
336
337 exp->tuple.dst.u.all = *dst;
338
339 #ifdef CONFIG_NF_NAT_NEEDED
340 memset(&exp->saved_addr, 0, sizeof(exp->saved_addr));
341 memset(&exp->saved_proto, 0, sizeof(exp->saved_proto));
342 #endif
343 }
344 EXPORT_SYMBOL_GPL(nf_ct_expect_init);
345
nf_ct_expect_free_rcu(struct rcu_head * head)346 static void nf_ct_expect_free_rcu(struct rcu_head *head)
347 {
348 struct nf_conntrack_expect *exp;
349
350 exp = container_of(head, struct nf_conntrack_expect, rcu);
351 kmem_cache_free(nf_ct_expect_cachep, exp);
352 }
353
nf_ct_expect_put(struct nf_conntrack_expect * exp)354 void nf_ct_expect_put(struct nf_conntrack_expect *exp)
355 {
356 if (refcount_dec_and_test(&exp->use))
357 call_rcu(&exp->rcu, nf_ct_expect_free_rcu);
358 }
359 EXPORT_SYMBOL_GPL(nf_ct_expect_put);
360
nf_ct_expect_insert(struct nf_conntrack_expect * exp)361 static void nf_ct_expect_insert(struct nf_conntrack_expect *exp)
362 {
363 struct nf_conn_help *master_help = nfct_help(exp->master);
364 struct nf_conntrack_helper *helper;
365 struct net *net = nf_ct_exp_net(exp);
366 unsigned int h = nf_ct_expect_dst_hash(net, &exp->tuple);
367
368 /* two references : one for hash insert, one for the timer */
369 refcount_add(2, &exp->use);
370
371 timer_setup(&exp->timeout, nf_ct_expectation_timed_out, 0);
372 helper = rcu_dereference_protected(master_help->helper,
373 lockdep_is_held(&nf_conntrack_expect_lock));
374 if (helper) {
375 exp->timeout.expires = jiffies +
376 helper->expect_policy[exp->class].timeout * HZ;
377 }
378 add_timer(&exp->timeout);
379
380 hlist_add_head_rcu(&exp->lnode, &master_help->expectations);
381 master_help->expecting[exp->class]++;
382
383 hlist_add_head_rcu(&exp->hnode, &nf_ct_expect_hash[h]);
384 net->ct.expect_count++;
385
386 NF_CT_STAT_INC(net, expect_create);
387 }
388
389 /* Race with expectations being used means we could have none to find; OK. */
evict_oldest_expect(struct nf_conn * master,struct nf_conntrack_expect * new)390 static void evict_oldest_expect(struct nf_conn *master,
391 struct nf_conntrack_expect *new)
392 {
393 struct nf_conn_help *master_help = nfct_help(master);
394 struct nf_conntrack_expect *exp, *last = NULL;
395
396 hlist_for_each_entry(exp, &master_help->expectations, lnode) {
397 if (exp->class == new->class)
398 last = exp;
399 }
400
401 if (last)
402 nf_ct_remove_expect(last);
403 }
404
__nf_ct_expect_check(struct nf_conntrack_expect * expect)405 static inline int __nf_ct_expect_check(struct nf_conntrack_expect *expect)
406 {
407 const struct nf_conntrack_expect_policy *p;
408 struct nf_conntrack_expect *i;
409 struct nf_conn *master = expect->master;
410 struct nf_conn_help *master_help = nfct_help(master);
411 struct nf_conntrack_helper *helper;
412 struct net *net = nf_ct_exp_net(expect);
413 struct hlist_node *next;
414 unsigned int h;
415 int ret = 0;
416
417 if (!master_help) {
418 ret = -ESHUTDOWN;
419 goto out;
420 }
421 h = nf_ct_expect_dst_hash(net, &expect->tuple);
422 hlist_for_each_entry_safe(i, next, &nf_ct_expect_hash[h], hnode) {
423 if (expect_matches(i, expect)) {
424 if (i->class != expect->class)
425 return -EALREADY;
426
427 if (nf_ct_remove_expect(i))
428 break;
429 } else if (expect_clash(i, expect)) {
430 ret = -EBUSY;
431 goto out;
432 }
433 }
434 /* Will be over limit? */
435 helper = rcu_dereference_protected(master_help->helper,
436 lockdep_is_held(&nf_conntrack_expect_lock));
437 if (helper) {
438 p = &helper->expect_policy[expect->class];
439 if (p->max_expected &&
440 master_help->expecting[expect->class] >= p->max_expected) {
441 evict_oldest_expect(master, expect);
442 if (master_help->expecting[expect->class]
443 >= p->max_expected) {
444 ret = -EMFILE;
445 goto out;
446 }
447 }
448 }
449
450 if (net->ct.expect_count >= nf_ct_expect_max) {
451 net_warn_ratelimited("nf_conntrack: expectation table full\n");
452 ret = -EMFILE;
453 }
454 out:
455 return ret;
456 }
457
nf_ct_expect_related_report(struct nf_conntrack_expect * expect,u32 portid,int report)458 int nf_ct_expect_related_report(struct nf_conntrack_expect *expect,
459 u32 portid, int report)
460 {
461 int ret;
462
463 spin_lock_bh(&nf_conntrack_expect_lock);
464 ret = __nf_ct_expect_check(expect);
465 if (ret < 0)
466 goto out;
467
468 nf_ct_expect_insert(expect);
469
470 spin_unlock_bh(&nf_conntrack_expect_lock);
471 nf_ct_expect_event_report(IPEXP_NEW, expect, portid, report);
472 return 0;
473 out:
474 spin_unlock_bh(&nf_conntrack_expect_lock);
475 return ret;
476 }
477 EXPORT_SYMBOL_GPL(nf_ct_expect_related_report);
478
nf_ct_expect_iterate_destroy(bool (* iter)(struct nf_conntrack_expect * e,void * data),void * data)479 void nf_ct_expect_iterate_destroy(bool (*iter)(struct nf_conntrack_expect *e, void *data),
480 void *data)
481 {
482 struct nf_conntrack_expect *exp;
483 const struct hlist_node *next;
484 unsigned int i;
485
486 spin_lock_bh(&nf_conntrack_expect_lock);
487
488 for (i = 0; i < nf_ct_expect_hsize; i++) {
489 hlist_for_each_entry_safe(exp, next,
490 &nf_ct_expect_hash[i],
491 hnode) {
492 if (iter(exp, data) && del_timer(&exp->timeout)) {
493 nf_ct_unlink_expect(exp);
494 nf_ct_expect_put(exp);
495 }
496 }
497 }
498
499 spin_unlock_bh(&nf_conntrack_expect_lock);
500 }
501 EXPORT_SYMBOL_GPL(nf_ct_expect_iterate_destroy);
502
nf_ct_expect_iterate_net(struct net * net,bool (* iter)(struct nf_conntrack_expect * e,void * data),void * data,u32 portid,int report)503 void nf_ct_expect_iterate_net(struct net *net,
504 bool (*iter)(struct nf_conntrack_expect *e, void *data),
505 void *data,
506 u32 portid, int report)
507 {
508 struct nf_conntrack_expect *exp;
509 const struct hlist_node *next;
510 unsigned int i;
511
512 spin_lock_bh(&nf_conntrack_expect_lock);
513
514 for (i = 0; i < nf_ct_expect_hsize; i++) {
515 hlist_for_each_entry_safe(exp, next,
516 &nf_ct_expect_hash[i],
517 hnode) {
518
519 if (!net_eq(nf_ct_exp_net(exp), net))
520 continue;
521
522 if (iter(exp, data) && del_timer(&exp->timeout)) {
523 nf_ct_unlink_expect_report(exp, portid, report);
524 nf_ct_expect_put(exp);
525 }
526 }
527 }
528
529 spin_unlock_bh(&nf_conntrack_expect_lock);
530 }
531 EXPORT_SYMBOL_GPL(nf_ct_expect_iterate_net);
532
533 #ifdef CONFIG_NF_CONNTRACK_PROCFS
534 struct ct_expect_iter_state {
535 struct seq_net_private p;
536 unsigned int bucket;
537 };
538
ct_expect_get_first(struct seq_file * seq)539 static struct hlist_node *ct_expect_get_first(struct seq_file *seq)
540 {
541 struct ct_expect_iter_state *st = seq->private;
542 struct hlist_node *n;
543
544 for (st->bucket = 0; st->bucket < nf_ct_expect_hsize; st->bucket++) {
545 n = rcu_dereference(hlist_first_rcu(&nf_ct_expect_hash[st->bucket]));
546 if (n)
547 return n;
548 }
549 return NULL;
550 }
551
ct_expect_get_next(struct seq_file * seq,struct hlist_node * head)552 static struct hlist_node *ct_expect_get_next(struct seq_file *seq,
553 struct hlist_node *head)
554 {
555 struct ct_expect_iter_state *st = seq->private;
556
557 head = rcu_dereference(hlist_next_rcu(head));
558 while (head == NULL) {
559 if (++st->bucket >= nf_ct_expect_hsize)
560 return NULL;
561 head = rcu_dereference(hlist_first_rcu(&nf_ct_expect_hash[st->bucket]));
562 }
563 return head;
564 }
565
ct_expect_get_idx(struct seq_file * seq,loff_t pos)566 static struct hlist_node *ct_expect_get_idx(struct seq_file *seq, loff_t pos)
567 {
568 struct hlist_node *head = ct_expect_get_first(seq);
569
570 if (head)
571 while (pos && (head = ct_expect_get_next(seq, head)))
572 pos--;
573 return pos ? NULL : head;
574 }
575
exp_seq_start(struct seq_file * seq,loff_t * pos)576 static void *exp_seq_start(struct seq_file *seq, loff_t *pos)
577 __acquires(RCU)
578 {
579 rcu_read_lock();
580 return ct_expect_get_idx(seq, *pos);
581 }
582
exp_seq_next(struct seq_file * seq,void * v,loff_t * pos)583 static void *exp_seq_next(struct seq_file *seq, void *v, loff_t *pos)
584 {
585 (*pos)++;
586 return ct_expect_get_next(seq, v);
587 }
588
exp_seq_stop(struct seq_file * seq,void * v)589 static void exp_seq_stop(struct seq_file *seq, void *v)
590 __releases(RCU)
591 {
592 rcu_read_unlock();
593 }
594
exp_seq_show(struct seq_file * s,void * v)595 static int exp_seq_show(struct seq_file *s, void *v)
596 {
597 struct nf_conntrack_expect *expect;
598 struct nf_conntrack_helper *helper;
599 struct hlist_node *n = v;
600 char *delim = "";
601
602 expect = hlist_entry(n, struct nf_conntrack_expect, hnode);
603
604 if (expect->timeout.function)
605 seq_printf(s, "%ld ", timer_pending(&expect->timeout)
606 ? (long)(expect->timeout.expires - jiffies)/HZ : 0);
607 else
608 seq_puts(s, "- ");
609 seq_printf(s, "l3proto = %u proto=%u ",
610 expect->tuple.src.l3num,
611 expect->tuple.dst.protonum);
612 print_tuple(s, &expect->tuple,
613 __nf_ct_l4proto_find(expect->tuple.src.l3num,
614 expect->tuple.dst.protonum));
615
616 if (expect->flags & NF_CT_EXPECT_PERMANENT) {
617 seq_puts(s, "PERMANENT");
618 delim = ",";
619 }
620 if (expect->flags & NF_CT_EXPECT_INACTIVE) {
621 seq_printf(s, "%sINACTIVE", delim);
622 delim = ",";
623 }
624 if (expect->flags & NF_CT_EXPECT_USERSPACE)
625 seq_printf(s, "%sUSERSPACE", delim);
626
627 helper = rcu_dereference(nfct_help(expect->master)->helper);
628 if (helper) {
629 seq_printf(s, "%s%s", expect->flags ? " " : "", helper->name);
630 if (helper->expect_policy[expect->class].name[0])
631 seq_printf(s, "/%s",
632 helper->expect_policy[expect->class].name);
633 }
634
635 seq_putc(s, '\n');
636
637 return 0;
638 }
639
640 static const struct seq_operations exp_seq_ops = {
641 .start = exp_seq_start,
642 .next = exp_seq_next,
643 .stop = exp_seq_stop,
644 .show = exp_seq_show
645 };
646 #endif /* CONFIG_NF_CONNTRACK_PROCFS */
647
exp_proc_init(struct net * net)648 static int exp_proc_init(struct net *net)
649 {
650 #ifdef CONFIG_NF_CONNTRACK_PROCFS
651 struct proc_dir_entry *proc;
652 kuid_t root_uid;
653 kgid_t root_gid;
654
655 proc = proc_create_net("nf_conntrack_expect", 0440, net->proc_net,
656 &exp_seq_ops, sizeof(struct ct_expect_iter_state));
657 if (!proc)
658 return -ENOMEM;
659
660 root_uid = make_kuid(net->user_ns, 0);
661 root_gid = make_kgid(net->user_ns, 0);
662 if (uid_valid(root_uid) && gid_valid(root_gid))
663 proc_set_user(proc, root_uid, root_gid);
664 #endif /* CONFIG_NF_CONNTRACK_PROCFS */
665 return 0;
666 }
667
exp_proc_remove(struct net * net)668 static void exp_proc_remove(struct net *net)
669 {
670 #ifdef CONFIG_NF_CONNTRACK_PROCFS
671 remove_proc_entry("nf_conntrack_expect", net->proc_net);
672 #endif /* CONFIG_NF_CONNTRACK_PROCFS */
673 }
674
675 module_param_named(expect_hashsize, nf_ct_expect_hsize, uint, 0400);
676
nf_conntrack_expect_pernet_init(struct net * net)677 int nf_conntrack_expect_pernet_init(struct net *net)
678 {
679 net->ct.expect_count = 0;
680 return exp_proc_init(net);
681 }
682
nf_conntrack_expect_pernet_fini(struct net * net)683 void nf_conntrack_expect_pernet_fini(struct net *net)
684 {
685 exp_proc_remove(net);
686 }
687
nf_conntrack_expect_init(void)688 int nf_conntrack_expect_init(void)
689 {
690 if (!nf_ct_expect_hsize) {
691 nf_ct_expect_hsize = nf_conntrack_htable_size / 256;
692 if (!nf_ct_expect_hsize)
693 nf_ct_expect_hsize = 1;
694 }
695 nf_ct_expect_max = nf_ct_expect_hsize * 4;
696 nf_ct_expect_cachep = kmem_cache_create("nf_conntrack_expect",
697 sizeof(struct nf_conntrack_expect),
698 0, 0, NULL);
699 if (!nf_ct_expect_cachep)
700 return -ENOMEM;
701
702 nf_ct_expect_hash = nf_ct_alloc_hashtable(&nf_ct_expect_hsize, 0);
703 if (!nf_ct_expect_hash) {
704 kmem_cache_destroy(nf_ct_expect_cachep);
705 return -ENOMEM;
706 }
707
708 return 0;
709 }
710
nf_conntrack_expect_fini(void)711 void nf_conntrack_expect_fini(void)
712 {
713 rcu_barrier(); /* Wait for call_rcu() before destroy */
714 kmem_cache_destroy(nf_ct_expect_cachep);
715 kvfree(nf_ct_expect_hash);
716 }
717