1
2
3
4
5
6
7
8
9
10
11#include <linux/module.h>
12#include <linux/init.h>
13#include <linux/list.h>
14#include <linux/skbuff.h>
15#include <linux/netlink.h>
16#include <linux/netfilter.h>
17#include <linux/netfilter/nfnetlink.h>
18#include <linux/netfilter/nf_tables.h>
19#include <net/netfilter/nf_tables_core.h>
20#include <net/netfilter/nf_tables.h>
21#include <net/net_namespace.h>
22#include <net/sock.h>
23
24static LIST_HEAD(nf_tables_expressions);
25static LIST_HEAD(nf_tables_objects);
26
27
28
29
30
31
32
33
34
35int nft_register_afinfo(struct net *net, struct nft_af_info *afi)
36{
37 INIT_LIST_HEAD(&afi->tables);
38 nfnl_lock(NFNL_SUBSYS_NFTABLES);
39 list_add_tail_rcu(&afi->list, &net->nft.af_info);
40 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
41 return 0;
42}
43EXPORT_SYMBOL_GPL(nft_register_afinfo);
44
45static void __nft_release_afinfo(struct net *net, struct nft_af_info *afi);
46
47
48
49
50
51
52
53
54void nft_unregister_afinfo(struct net *net, struct nft_af_info *afi)
55{
56 nfnl_lock(NFNL_SUBSYS_NFTABLES);
57 __nft_release_afinfo(net, afi);
58 list_del_rcu(&afi->list);
59 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
60}
61EXPORT_SYMBOL_GPL(nft_unregister_afinfo);
62
63static struct nft_af_info *nft_afinfo_lookup(struct net *net, int family)
64{
65 struct nft_af_info *afi;
66
67 list_for_each_entry(afi, &net->nft.af_info, list) {
68 if (afi->family == family)
69 return afi;
70 }
71 return NULL;
72}
73
74static struct nft_af_info *
75nf_tables_afinfo_lookup(struct net *net, int family, bool autoload)
76{
77 struct nft_af_info *afi;
78
79 afi = nft_afinfo_lookup(net, family);
80 if (afi != NULL)
81 return afi;
82#ifdef CONFIG_MODULES
83 if (autoload) {
84 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
85 request_module("nft-afinfo-%u", family);
86 nfnl_lock(NFNL_SUBSYS_NFTABLES);
87 afi = nft_afinfo_lookup(net, family);
88 if (afi != NULL)
89 return ERR_PTR(-EAGAIN);
90 }
91#endif
92 return ERR_PTR(-EAFNOSUPPORT);
93}
94
95static void nft_ctx_init(struct nft_ctx *ctx,
96 struct net *net,
97 const struct sk_buff *skb,
98 const struct nlmsghdr *nlh,
99 struct nft_af_info *afi,
100 struct nft_table *table,
101 struct nft_chain *chain,
102 const struct nlattr * const *nla)
103{
104 ctx->net = net;
105 ctx->afi = afi;
106 ctx->table = table;
107 ctx->chain = chain;
108 ctx->nla = nla;
109 ctx->portid = NETLINK_CB(skb).portid;
110 ctx->report = nlmsg_report(nlh);
111 ctx->seq = nlh->nlmsg_seq;
112}
113
114static struct nft_trans *nft_trans_alloc_gfp(const struct nft_ctx *ctx,
115 int msg_type, u32 size, gfp_t gfp)
116{
117 struct nft_trans *trans;
118
119 trans = kzalloc(sizeof(struct nft_trans) + size, gfp);
120 if (trans == NULL)
121 return NULL;
122
123 trans->msg_type = msg_type;
124 trans->ctx = *ctx;
125
126 return trans;
127}
128
129static struct nft_trans *nft_trans_alloc(const struct nft_ctx *ctx,
130 int msg_type, u32 size)
131{
132 return nft_trans_alloc_gfp(ctx, msg_type, size, GFP_KERNEL);
133}
134
135static void nft_trans_destroy(struct nft_trans *trans)
136{
137 list_del(&trans->list);
138 kfree(trans);
139}
140
141static int nf_tables_register_hooks(struct net *net,
142 const struct nft_table *table,
143 struct nft_chain *chain,
144 unsigned int hook_nops)
145{
146 if (table->flags & NFT_TABLE_F_DORMANT ||
147 !(chain->flags & NFT_BASE_CHAIN))
148 return 0;
149
150 return nf_register_net_hooks(net, nft_base_chain(chain)->ops,
151 hook_nops);
152}
153
154static void nf_tables_unregister_hooks(struct net *net,
155 const struct nft_table *table,
156 struct nft_chain *chain,
157 unsigned int hook_nops)
158{
159 if (table->flags & NFT_TABLE_F_DORMANT ||
160 !(chain->flags & NFT_BASE_CHAIN))
161 return;
162
163 nf_unregister_net_hooks(net, nft_base_chain(chain)->ops, hook_nops);
164}
165
166static int nft_trans_table_add(struct nft_ctx *ctx, int msg_type)
167{
168 struct nft_trans *trans;
169
170 trans = nft_trans_alloc(ctx, msg_type, sizeof(struct nft_trans_table));
171 if (trans == NULL)
172 return -ENOMEM;
173
174 if (msg_type == NFT_MSG_NEWTABLE)
175 nft_activate_next(ctx->net, ctx->table);
176
177 list_add_tail(&trans->list, &ctx->net->nft.commit_list);
178 return 0;
179}
180
181static int nft_deltable(struct nft_ctx *ctx)
182{
183 int err;
184
185 err = nft_trans_table_add(ctx, NFT_MSG_DELTABLE);
186 if (err < 0)
187 return err;
188
189 nft_deactivate_next(ctx->net, ctx->table);
190 return err;
191}
192
193static int nft_trans_chain_add(struct nft_ctx *ctx, int msg_type)
194{
195 struct nft_trans *trans;
196
197 trans = nft_trans_alloc(ctx, msg_type, sizeof(struct nft_trans_chain));
198 if (trans == NULL)
199 return -ENOMEM;
200
201 if (msg_type == NFT_MSG_NEWCHAIN)
202 nft_activate_next(ctx->net, ctx->chain);
203
204 list_add_tail(&trans->list, &ctx->net->nft.commit_list);
205 return 0;
206}
207
208static int nft_delchain(struct nft_ctx *ctx)
209{
210 int err;
211
212 err = nft_trans_chain_add(ctx, NFT_MSG_DELCHAIN);
213 if (err < 0)
214 return err;
215
216 ctx->table->use--;
217 nft_deactivate_next(ctx->net, ctx->chain);
218
219 return err;
220}
221
222static int
223nf_tables_delrule_deactivate(struct nft_ctx *ctx, struct nft_rule *rule)
224{
225
226 if (nft_is_active_next(ctx->net, rule)) {
227 nft_deactivate_next(ctx->net, rule);
228 ctx->chain->use--;
229 return 0;
230 }
231 return -ENOENT;
232}
233
234static struct nft_trans *nft_trans_rule_add(struct nft_ctx *ctx, int msg_type,
235 struct nft_rule *rule)
236{
237 struct nft_trans *trans;
238
239 trans = nft_trans_alloc(ctx, msg_type, sizeof(struct nft_trans_rule));
240 if (trans == NULL)
241 return NULL;
242
243 nft_trans_rule(trans) = rule;
244 list_add_tail(&trans->list, &ctx->net->nft.commit_list);
245
246 return trans;
247}
248
249static int nft_delrule(struct nft_ctx *ctx, struct nft_rule *rule)
250{
251 struct nft_trans *trans;
252 int err;
253
254 trans = nft_trans_rule_add(ctx, NFT_MSG_DELRULE, rule);
255 if (trans == NULL)
256 return -ENOMEM;
257
258 err = nf_tables_delrule_deactivate(ctx, rule);
259 if (err < 0) {
260 nft_trans_destroy(trans);
261 return err;
262 }
263
264 return 0;
265}
266
267static int nft_delrule_by_chain(struct nft_ctx *ctx)
268{
269 struct nft_rule *rule;
270 int err;
271
272 list_for_each_entry(rule, &ctx->chain->rules, list) {
273 err = nft_delrule(ctx, rule);
274 if (err < 0)
275 return err;
276 }
277 return 0;
278}
279
280static int nft_trans_set_add(struct nft_ctx *ctx, int msg_type,
281 struct nft_set *set)
282{
283 struct nft_trans *trans;
284
285 trans = nft_trans_alloc(ctx, msg_type, sizeof(struct nft_trans_set));
286 if (trans == NULL)
287 return -ENOMEM;
288
289 if (msg_type == NFT_MSG_NEWSET && ctx->nla[NFTA_SET_ID] != NULL) {
290 nft_trans_set_id(trans) =
291 ntohl(nla_get_be32(ctx->nla[NFTA_SET_ID]));
292 nft_activate_next(ctx->net, set);
293 }
294 nft_trans_set(trans) = set;
295 list_add_tail(&trans->list, &ctx->net->nft.commit_list);
296
297 return 0;
298}
299
300static int nft_delset(struct nft_ctx *ctx, struct nft_set *set)
301{
302 int err;
303
304 err = nft_trans_set_add(ctx, NFT_MSG_DELSET, set);
305 if (err < 0)
306 return err;
307
308 nft_deactivate_next(ctx->net, set);
309 ctx->table->use--;
310
311 return err;
312}
313
314static int nft_trans_obj_add(struct nft_ctx *ctx, int msg_type,
315 struct nft_object *obj)
316{
317 struct nft_trans *trans;
318
319 trans = nft_trans_alloc(ctx, msg_type, sizeof(struct nft_trans_obj));
320 if (trans == NULL)
321 return -ENOMEM;
322
323 if (msg_type == NFT_MSG_NEWOBJ)
324 nft_activate_next(ctx->net, obj);
325
326 nft_trans_obj(trans) = obj;
327 list_add_tail(&trans->list, &ctx->net->nft.commit_list);
328
329 return 0;
330}
331
332static int nft_delobj(struct nft_ctx *ctx, struct nft_object *obj)
333{
334 int err;
335
336 err = nft_trans_obj_add(ctx, NFT_MSG_DELOBJ, obj);
337 if (err < 0)
338 return err;
339
340 nft_deactivate_next(ctx->net, obj);
341 ctx->table->use--;
342
343 return err;
344}
345
346
347
348
349
350static struct nft_table *nft_table_lookup(const struct nft_af_info *afi,
351 const struct nlattr *nla,
352 u8 genmask)
353{
354 struct nft_table *table;
355
356 list_for_each_entry(table, &afi->tables, list) {
357 if (!nla_strcmp(nla, table->name) &&
358 nft_active_genmask(table, genmask))
359 return table;
360 }
361 return NULL;
362}
363
364static struct nft_table *nf_tables_table_lookup(const struct nft_af_info *afi,
365 const struct nlattr *nla,
366 u8 genmask)
367{
368 struct nft_table *table;
369
370 if (nla == NULL)
371 return ERR_PTR(-EINVAL);
372
373 table = nft_table_lookup(afi, nla, genmask);
374 if (table != NULL)
375 return table;
376
377 return ERR_PTR(-ENOENT);
378}
379
380static inline u64 nf_tables_alloc_handle(struct nft_table *table)
381{
382 return ++table->hgenerator;
383}
384
385static const struct nf_chain_type *chain_type[AF_MAX][NFT_CHAIN_T_MAX];
386
387static const struct nf_chain_type *
388__nf_tables_chain_type_lookup(int family, const struct nlattr *nla)
389{
390 int i;
391
392 for (i = 0; i < NFT_CHAIN_T_MAX; i++) {
393 if (chain_type[family][i] != NULL &&
394 !nla_strcmp(nla, chain_type[family][i]->name))
395 return chain_type[family][i];
396 }
397 return NULL;
398}
399
400static const struct nf_chain_type *
401nf_tables_chain_type_lookup(const struct nft_af_info *afi,
402 const struct nlattr *nla,
403 bool autoload)
404{
405 const struct nf_chain_type *type;
406
407 type = __nf_tables_chain_type_lookup(afi->family, nla);
408 if (type != NULL)
409 return type;
410#ifdef CONFIG_MODULES
411 if (autoload) {
412 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
413 request_module("nft-chain-%u-%.*s", afi->family,
414 nla_len(nla), (const char *)nla_data(nla));
415 nfnl_lock(NFNL_SUBSYS_NFTABLES);
416 type = __nf_tables_chain_type_lookup(afi->family, nla);
417 if (type != NULL)
418 return ERR_PTR(-EAGAIN);
419 }
420#endif
421 return ERR_PTR(-ENOENT);
422}
423
424static const struct nla_policy nft_table_policy[NFTA_TABLE_MAX + 1] = {
425 [NFTA_TABLE_NAME] = { .type = NLA_STRING,
426 .len = NFT_TABLE_MAXNAMELEN - 1 },
427 [NFTA_TABLE_FLAGS] = { .type = NLA_U32 },
428};
429
430static int nf_tables_fill_table_info(struct sk_buff *skb, struct net *net,
431 u32 portid, u32 seq, int event, u32 flags,
432 int family, const struct nft_table *table)
433{
434 struct nlmsghdr *nlh;
435 struct nfgenmsg *nfmsg;
436
437 event |= NFNL_SUBSYS_NFTABLES << 8;
438 nlh = nlmsg_put(skb, portid, seq, event, sizeof(struct nfgenmsg), flags);
439 if (nlh == NULL)
440 goto nla_put_failure;
441
442 nfmsg = nlmsg_data(nlh);
443 nfmsg->nfgen_family = family;
444 nfmsg->version = NFNETLINK_V0;
445 nfmsg->res_id = htons(net->nft.base_seq & 0xffff);
446
447 if (nla_put_string(skb, NFTA_TABLE_NAME, table->name) ||
448 nla_put_be32(skb, NFTA_TABLE_FLAGS, htonl(table->flags)) ||
449 nla_put_be32(skb, NFTA_TABLE_USE, htonl(table->use)))
450 goto nla_put_failure;
451
452 nlmsg_end(skb, nlh);
453 return 0;
454
455nla_put_failure:
456 nlmsg_trim(skb, nlh);
457 return -1;
458}
459
460static int nf_tables_table_notify(const struct nft_ctx *ctx, int event)
461{
462 struct sk_buff *skb;
463 int err;
464
465 if (!ctx->report &&
466 !nfnetlink_has_listeners(ctx->net, NFNLGRP_NFTABLES))
467 return 0;
468
469 err = -ENOBUFS;
470 skb = nlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL);
471 if (skb == NULL)
472 goto err;
473
474 err = nf_tables_fill_table_info(skb, ctx->net, ctx->portid, ctx->seq,
475 event, 0, ctx->afi->family, ctx->table);
476 if (err < 0) {
477 kfree_skb(skb);
478 goto err;
479 }
480
481 err = nfnetlink_send(skb, ctx->net, ctx->portid, NFNLGRP_NFTABLES,
482 ctx->report, GFP_KERNEL);
483err:
484 if (err < 0) {
485 nfnetlink_set_err(ctx->net, ctx->portid, NFNLGRP_NFTABLES,
486 err);
487 }
488 return err;
489}
490
491static int nf_tables_dump_tables(struct sk_buff *skb,
492 struct netlink_callback *cb)
493{
494 const struct nfgenmsg *nfmsg = nlmsg_data(cb->nlh);
495 const struct nft_af_info *afi;
496 const struct nft_table *table;
497 unsigned int idx = 0, s_idx = cb->args[0];
498 struct net *net = sock_net(skb->sk);
499 int family = nfmsg->nfgen_family;
500
501 rcu_read_lock();
502 cb->seq = net->nft.base_seq;
503
504 list_for_each_entry_rcu(afi, &net->nft.af_info, list) {
505 if (family != NFPROTO_UNSPEC && family != afi->family)
506 continue;
507
508 list_for_each_entry_rcu(table, &afi->tables, list) {
509 if (idx < s_idx)
510 goto cont;
511 if (idx > s_idx)
512 memset(&cb->args[1], 0,
513 sizeof(cb->args) - sizeof(cb->args[0]));
514 if (!nft_is_active(net, table))
515 continue;
516 if (nf_tables_fill_table_info(skb, net,
517 NETLINK_CB(cb->skb).portid,
518 cb->nlh->nlmsg_seq,
519 NFT_MSG_NEWTABLE,
520 NLM_F_MULTI,
521 afi->family, table) < 0)
522 goto done;
523
524 nl_dump_check_consistent(cb, nlmsg_hdr(skb));
525cont:
526 idx++;
527 }
528 }
529done:
530 rcu_read_unlock();
531 cb->args[0] = idx;
532 return skb->len;
533}
534
535static int nf_tables_gettable(struct net *net, struct sock *nlsk,
536 struct sk_buff *skb, const struct nlmsghdr *nlh,
537 const struct nlattr * const nla[])
538{
539 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
540 u8 genmask = nft_genmask_cur(net);
541 const struct nft_af_info *afi;
542 const struct nft_table *table;
543 struct sk_buff *skb2;
544 int family = nfmsg->nfgen_family;
545 int err;
546
547 if (nlh->nlmsg_flags & NLM_F_DUMP) {
548 struct netlink_dump_control c = {
549 .dump = nf_tables_dump_tables,
550 };
551 return netlink_dump_start(nlsk, skb, nlh, &c);
552 }
553
554 afi = nf_tables_afinfo_lookup(net, family, false);
555 if (IS_ERR(afi))
556 return PTR_ERR(afi);
557
558 table = nf_tables_table_lookup(afi, nla[NFTA_TABLE_NAME], genmask);
559 if (IS_ERR(table))
560 return PTR_ERR(table);
561
562 skb2 = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
563 if (!skb2)
564 return -ENOMEM;
565
566 err = nf_tables_fill_table_info(skb2, net, NETLINK_CB(skb).portid,
567 nlh->nlmsg_seq, NFT_MSG_NEWTABLE, 0,
568 family, table);
569 if (err < 0)
570 goto err;
571
572 return nlmsg_unicast(nlsk, skb2, NETLINK_CB(skb).portid);
573
574err:
575 kfree_skb(skb2);
576 return err;
577}
578
579static int nf_tables_table_enable(struct net *net,
580 const struct nft_af_info *afi,
581 struct nft_table *table)
582{
583 struct nft_chain *chain;
584 int err, i = 0;
585
586 list_for_each_entry(chain, &table->chains, list) {
587 if (!nft_is_active_next(net, chain))
588 continue;
589 if (!(chain->flags & NFT_BASE_CHAIN))
590 continue;
591
592 err = nf_register_net_hooks(net, nft_base_chain(chain)->ops,
593 afi->nops);
594 if (err < 0)
595 goto err;
596
597 i++;
598 }
599 return 0;
600err:
601 list_for_each_entry(chain, &table->chains, list) {
602 if (!nft_is_active_next(net, chain))
603 continue;
604 if (!(chain->flags & NFT_BASE_CHAIN))
605 continue;
606
607 if (i-- <= 0)
608 break;
609
610 nf_unregister_net_hooks(net, nft_base_chain(chain)->ops,
611 afi->nops);
612 }
613 return err;
614}
615
616static void nf_tables_table_disable(struct net *net,
617 const struct nft_af_info *afi,
618 struct nft_table *table)
619{
620 struct nft_chain *chain;
621
622 list_for_each_entry(chain, &table->chains, list) {
623 if (!nft_is_active_next(net, chain))
624 continue;
625 if (!(chain->flags & NFT_BASE_CHAIN))
626 continue;
627
628 nf_unregister_net_hooks(net, nft_base_chain(chain)->ops,
629 afi->nops);
630 }
631}
632
633static int nf_tables_updtable(struct nft_ctx *ctx)
634{
635 struct nft_trans *trans;
636 u32 flags;
637 int ret = 0;
638
639 if (!ctx->nla[NFTA_TABLE_FLAGS])
640 return 0;
641
642 flags = ntohl(nla_get_be32(ctx->nla[NFTA_TABLE_FLAGS]));
643 if (flags & ~NFT_TABLE_F_DORMANT)
644 return -EINVAL;
645
646 if (flags == ctx->table->flags)
647 return 0;
648
649 trans = nft_trans_alloc(ctx, NFT_MSG_NEWTABLE,
650 sizeof(struct nft_trans_table));
651 if (trans == NULL)
652 return -ENOMEM;
653
654 if ((flags & NFT_TABLE_F_DORMANT) &&
655 !(ctx->table->flags & NFT_TABLE_F_DORMANT)) {
656 nft_trans_table_enable(trans) = false;
657 } else if (!(flags & NFT_TABLE_F_DORMANT) &&
658 ctx->table->flags & NFT_TABLE_F_DORMANT) {
659 ret = nf_tables_table_enable(ctx->net, ctx->afi, ctx->table);
660 if (ret >= 0) {
661 ctx->table->flags &= ~NFT_TABLE_F_DORMANT;
662 nft_trans_table_enable(trans) = true;
663 }
664 }
665 if (ret < 0)
666 goto err;
667
668 nft_trans_table_update(trans) = true;
669 list_add_tail(&trans->list, &ctx->net->nft.commit_list);
670 return 0;
671err:
672 nft_trans_destroy(trans);
673 return ret;
674}
675
676static int nf_tables_newtable(struct net *net, struct sock *nlsk,
677 struct sk_buff *skb, const struct nlmsghdr *nlh,
678 const struct nlattr * const nla[])
679{
680 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
681 u8 genmask = nft_genmask_next(net);
682 const struct nlattr *name;
683 struct nft_af_info *afi;
684 struct nft_table *table;
685 int family = nfmsg->nfgen_family;
686 u32 flags = 0;
687 struct nft_ctx ctx;
688 int err;
689
690 afi = nf_tables_afinfo_lookup(net, family, true);
691 if (IS_ERR(afi))
692 return PTR_ERR(afi);
693
694 name = nla[NFTA_TABLE_NAME];
695 table = nf_tables_table_lookup(afi, name, genmask);
696 if (IS_ERR(table)) {
697 if (PTR_ERR(table) != -ENOENT)
698 return PTR_ERR(table);
699 table = NULL;
700 }
701
702 if (table != NULL) {
703 if (nlh->nlmsg_flags & NLM_F_EXCL)
704 return -EEXIST;
705 if (nlh->nlmsg_flags & NLM_F_REPLACE)
706 return -EOPNOTSUPP;
707
708 nft_ctx_init(&ctx, net, skb, nlh, afi, table, NULL, nla);
709 return nf_tables_updtable(&ctx);
710 }
711
712 if (nla[NFTA_TABLE_FLAGS]) {
713 flags = ntohl(nla_get_be32(nla[NFTA_TABLE_FLAGS]));
714 if (flags & ~NFT_TABLE_F_DORMANT)
715 return -EINVAL;
716 }
717
718 err = -EAFNOSUPPORT;
719 if (!try_module_get(afi->owner))
720 goto err1;
721
722 err = -ENOMEM;
723 table = kzalloc(sizeof(*table), GFP_KERNEL);
724 if (table == NULL)
725 goto err2;
726
727 nla_strlcpy(table->name, name, NFT_TABLE_MAXNAMELEN);
728 INIT_LIST_HEAD(&table->chains);
729 INIT_LIST_HEAD(&table->sets);
730 INIT_LIST_HEAD(&table->objects);
731 table->flags = flags;
732
733 nft_ctx_init(&ctx, net, skb, nlh, afi, table, NULL, nla);
734 err = nft_trans_table_add(&ctx, NFT_MSG_NEWTABLE);
735 if (err < 0)
736 goto err3;
737
738 list_add_tail_rcu(&table->list, &afi->tables);
739 return 0;
740err3:
741 kfree(table);
742err2:
743 module_put(afi->owner);
744err1:
745 return err;
746}
747
748static int nft_flush_table(struct nft_ctx *ctx)
749{
750 int err;
751 struct nft_chain *chain, *nc;
752 struct nft_object *obj, *ne;
753 struct nft_set *set, *ns;
754
755 list_for_each_entry(chain, &ctx->table->chains, list) {
756 if (!nft_is_active_next(ctx->net, chain))
757 continue;
758
759 ctx->chain = chain;
760
761 err = nft_delrule_by_chain(ctx);
762 if (err < 0)
763 goto out;
764 }
765
766 list_for_each_entry_safe(set, ns, &ctx->table->sets, list) {
767 if (!nft_is_active_next(ctx->net, set))
768 continue;
769
770 if (set->flags & NFT_SET_ANONYMOUS &&
771 !list_empty(&set->bindings))
772 continue;
773
774 err = nft_delset(ctx, set);
775 if (err < 0)
776 goto out;
777 }
778
779 list_for_each_entry_safe(obj, ne, &ctx->table->objects, list) {
780 err = nft_delobj(ctx, obj);
781 if (err < 0)
782 goto out;
783 }
784
785 list_for_each_entry_safe(chain, nc, &ctx->table->chains, list) {
786 if (!nft_is_active_next(ctx->net, chain))
787 continue;
788
789 ctx->chain = chain;
790
791 err = nft_delchain(ctx);
792 if (err < 0)
793 goto out;
794 }
795
796 err = nft_deltable(ctx);
797out:
798 return err;
799}
800
801static int nft_flush(struct nft_ctx *ctx, int family)
802{
803 struct nft_af_info *afi;
804 struct nft_table *table, *nt;
805 const struct nlattr * const *nla = ctx->nla;
806 int err = 0;
807
808 list_for_each_entry(afi, &ctx->net->nft.af_info, list) {
809 if (family != AF_UNSPEC && afi->family != family)
810 continue;
811
812 ctx->afi = afi;
813 list_for_each_entry_safe(table, nt, &afi->tables, list) {
814 if (!nft_is_active_next(ctx->net, table))
815 continue;
816
817 if (nla[NFTA_TABLE_NAME] &&
818 nla_strcmp(nla[NFTA_TABLE_NAME], table->name) != 0)
819 continue;
820
821 ctx->table = table;
822
823 err = nft_flush_table(ctx);
824 if (err < 0)
825 goto out;
826 }
827 }
828out:
829 return err;
830}
831
832static int nf_tables_deltable(struct net *net, struct sock *nlsk,
833 struct sk_buff *skb, const struct nlmsghdr *nlh,
834 const struct nlattr * const nla[])
835{
836 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
837 u8 genmask = nft_genmask_next(net);
838 struct nft_af_info *afi;
839 struct nft_table *table;
840 int family = nfmsg->nfgen_family;
841 struct nft_ctx ctx;
842
843 nft_ctx_init(&ctx, net, skb, nlh, NULL, NULL, NULL, nla);
844 if (family == AF_UNSPEC || nla[NFTA_TABLE_NAME] == NULL)
845 return nft_flush(&ctx, family);
846
847 afi = nf_tables_afinfo_lookup(net, family, false);
848 if (IS_ERR(afi))
849 return PTR_ERR(afi);
850
851 table = nf_tables_table_lookup(afi, nla[NFTA_TABLE_NAME], genmask);
852 if (IS_ERR(table))
853 return PTR_ERR(table);
854
855 ctx.afi = afi;
856 ctx.table = table;
857
858 return nft_flush_table(&ctx);
859}
860
861static void nf_tables_table_destroy(struct nft_ctx *ctx)
862{
863 BUG_ON(ctx->table->use > 0);
864
865 kfree(ctx->table);
866 module_put(ctx->afi->owner);
867}
868
869int nft_register_chain_type(const struct nf_chain_type *ctype)
870{
871 int err = 0;
872
873 nfnl_lock(NFNL_SUBSYS_NFTABLES);
874 if (chain_type[ctype->family][ctype->type] != NULL) {
875 err = -EBUSY;
876 goto out;
877 }
878 chain_type[ctype->family][ctype->type] = ctype;
879out:
880 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
881 return err;
882}
883EXPORT_SYMBOL_GPL(nft_register_chain_type);
884
885void nft_unregister_chain_type(const struct nf_chain_type *ctype)
886{
887 nfnl_lock(NFNL_SUBSYS_NFTABLES);
888 chain_type[ctype->family][ctype->type] = NULL;
889 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
890}
891EXPORT_SYMBOL_GPL(nft_unregister_chain_type);
892
893
894
895
896
897static struct nft_chain *
898nf_tables_chain_lookup_byhandle(const struct nft_table *table, u64 handle,
899 u8 genmask)
900{
901 struct nft_chain *chain;
902
903 list_for_each_entry(chain, &table->chains, list) {
904 if (chain->handle == handle &&
905 nft_active_genmask(chain, genmask))
906 return chain;
907 }
908
909 return ERR_PTR(-ENOENT);
910}
911
912static struct nft_chain *nf_tables_chain_lookup(const struct nft_table *table,
913 const struct nlattr *nla,
914 u8 genmask)
915{
916 struct nft_chain *chain;
917
918 if (nla == NULL)
919 return ERR_PTR(-EINVAL);
920
921 list_for_each_entry(chain, &table->chains, list) {
922 if (!nla_strcmp(nla, chain->name) &&
923 nft_active_genmask(chain, genmask))
924 return chain;
925 }
926
927 return ERR_PTR(-ENOENT);
928}
929
930static const struct nla_policy nft_chain_policy[NFTA_CHAIN_MAX + 1] = {
931 [NFTA_CHAIN_TABLE] = { .type = NLA_STRING,
932 .len = NFT_TABLE_MAXNAMELEN - 1 },
933 [NFTA_CHAIN_HANDLE] = { .type = NLA_U64 },
934 [NFTA_CHAIN_NAME] = { .type = NLA_STRING,
935 .len = NFT_CHAIN_MAXNAMELEN - 1 },
936 [NFTA_CHAIN_HOOK] = { .type = NLA_NESTED },
937 [NFTA_CHAIN_POLICY] = { .type = NLA_U32 },
938 [NFTA_CHAIN_TYPE] = { .type = NLA_STRING },
939 [NFTA_CHAIN_COUNTERS] = { .type = NLA_NESTED },
940};
941
942static const struct nla_policy nft_hook_policy[NFTA_HOOK_MAX + 1] = {
943 [NFTA_HOOK_HOOKNUM] = { .type = NLA_U32 },
944 [NFTA_HOOK_PRIORITY] = { .type = NLA_U32 },
945 [NFTA_HOOK_DEV] = { .type = NLA_STRING,
946 .len = IFNAMSIZ - 1 },
947};
948
949static int nft_dump_stats(struct sk_buff *skb, struct nft_stats __percpu *stats)
950{
951 struct nft_stats *cpu_stats, total;
952 struct nlattr *nest;
953 unsigned int seq;
954 u64 pkts, bytes;
955 int cpu;
956
957 memset(&total, 0, sizeof(total));
958 for_each_possible_cpu(cpu) {
959 cpu_stats = per_cpu_ptr(stats, cpu);
960 do {
961 seq = u64_stats_fetch_begin_irq(&cpu_stats->syncp);
962 pkts = cpu_stats->pkts;
963 bytes = cpu_stats->bytes;
964 } while (u64_stats_fetch_retry_irq(&cpu_stats->syncp, seq));
965 total.pkts += pkts;
966 total.bytes += bytes;
967 }
968 nest = nla_nest_start(skb, NFTA_CHAIN_COUNTERS);
969 if (nest == NULL)
970 goto nla_put_failure;
971
972 if (nla_put_be64(skb, NFTA_COUNTER_PACKETS, cpu_to_be64(total.pkts),
973 NFTA_COUNTER_PAD) ||
974 nla_put_be64(skb, NFTA_COUNTER_BYTES, cpu_to_be64(total.bytes),
975 NFTA_COUNTER_PAD))
976 goto nla_put_failure;
977
978 nla_nest_end(skb, nest);
979 return 0;
980
981nla_put_failure:
982 return -ENOSPC;
983}
984
985static int nf_tables_fill_chain_info(struct sk_buff *skb, struct net *net,
986 u32 portid, u32 seq, int event, u32 flags,
987 int family, const struct nft_table *table,
988 const struct nft_chain *chain)
989{
990 struct nlmsghdr *nlh;
991 struct nfgenmsg *nfmsg;
992
993 event |= NFNL_SUBSYS_NFTABLES << 8;
994 nlh = nlmsg_put(skb, portid, seq, event, sizeof(struct nfgenmsg), flags);
995 if (nlh == NULL)
996 goto nla_put_failure;
997
998 nfmsg = nlmsg_data(nlh);
999 nfmsg->nfgen_family = family;
1000 nfmsg->version = NFNETLINK_V0;
1001 nfmsg->res_id = htons(net->nft.base_seq & 0xffff);
1002
1003 if (nla_put_string(skb, NFTA_CHAIN_TABLE, table->name))
1004 goto nla_put_failure;
1005 if (nla_put_be64(skb, NFTA_CHAIN_HANDLE, cpu_to_be64(chain->handle),
1006 NFTA_CHAIN_PAD))
1007 goto nla_put_failure;
1008 if (nla_put_string(skb, NFTA_CHAIN_NAME, chain->name))
1009 goto nla_put_failure;
1010
1011 if (chain->flags & NFT_BASE_CHAIN) {
1012 const struct nft_base_chain *basechain = nft_base_chain(chain);
1013 const struct nf_hook_ops *ops = &basechain->ops[0];
1014 struct nlattr *nest;
1015
1016 nest = nla_nest_start(skb, NFTA_CHAIN_HOOK);
1017 if (nest == NULL)
1018 goto nla_put_failure;
1019 if (nla_put_be32(skb, NFTA_HOOK_HOOKNUM, htonl(ops->hooknum)))
1020 goto nla_put_failure;
1021 if (nla_put_be32(skb, NFTA_HOOK_PRIORITY, htonl(ops->priority)))
1022 goto nla_put_failure;
1023 if (basechain->dev_name[0] &&
1024 nla_put_string(skb, NFTA_HOOK_DEV, basechain->dev_name))
1025 goto nla_put_failure;
1026 nla_nest_end(skb, nest);
1027
1028 if (nla_put_be32(skb, NFTA_CHAIN_POLICY,
1029 htonl(basechain->policy)))
1030 goto nla_put_failure;
1031
1032 if (nla_put_string(skb, NFTA_CHAIN_TYPE, basechain->type->name))
1033 goto nla_put_failure;
1034
1035 if (nft_dump_stats(skb, nft_base_chain(chain)->stats))
1036 goto nla_put_failure;
1037 }
1038
1039 if (nla_put_be32(skb, NFTA_CHAIN_USE, htonl(chain->use)))
1040 goto nla_put_failure;
1041
1042 nlmsg_end(skb, nlh);
1043 return 0;
1044
1045nla_put_failure:
1046 nlmsg_trim(skb, nlh);
1047 return -1;
1048}
1049
1050static int nf_tables_chain_notify(const struct nft_ctx *ctx, int event)
1051{
1052 struct sk_buff *skb;
1053 int err;
1054
1055 if (!ctx->report &&
1056 !nfnetlink_has_listeners(ctx->net, NFNLGRP_NFTABLES))
1057 return 0;
1058
1059 err = -ENOBUFS;
1060 skb = nlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL);
1061 if (skb == NULL)
1062 goto err;
1063
1064 err = nf_tables_fill_chain_info(skb, ctx->net, ctx->portid, ctx->seq,
1065 event, 0, ctx->afi->family, ctx->table,
1066 ctx->chain);
1067 if (err < 0) {
1068 kfree_skb(skb);
1069 goto err;
1070 }
1071
1072 err = nfnetlink_send(skb, ctx->net, ctx->portid, NFNLGRP_NFTABLES,
1073 ctx->report, GFP_KERNEL);
1074err:
1075 if (err < 0) {
1076 nfnetlink_set_err(ctx->net, ctx->portid, NFNLGRP_NFTABLES,
1077 err);
1078 }
1079 return err;
1080}
1081
1082static int nf_tables_dump_chains(struct sk_buff *skb,
1083 struct netlink_callback *cb)
1084{
1085 const struct nfgenmsg *nfmsg = nlmsg_data(cb->nlh);
1086 const struct nft_af_info *afi;
1087 const struct nft_table *table;
1088 const struct nft_chain *chain;
1089 unsigned int idx = 0, s_idx = cb->args[0];
1090 struct net *net = sock_net(skb->sk);
1091 int family = nfmsg->nfgen_family;
1092
1093 rcu_read_lock();
1094 cb->seq = net->nft.base_seq;
1095
1096 list_for_each_entry_rcu(afi, &net->nft.af_info, list) {
1097 if (family != NFPROTO_UNSPEC && family != afi->family)
1098 continue;
1099
1100 list_for_each_entry_rcu(table, &afi->tables, list) {
1101 list_for_each_entry_rcu(chain, &table->chains, list) {
1102 if (idx < s_idx)
1103 goto cont;
1104 if (idx > s_idx)
1105 memset(&cb->args[1], 0,
1106 sizeof(cb->args) - sizeof(cb->args[0]));
1107 if (!nft_is_active(net, chain))
1108 continue;
1109 if (nf_tables_fill_chain_info(skb, net,
1110 NETLINK_CB(cb->skb).portid,
1111 cb->nlh->nlmsg_seq,
1112 NFT_MSG_NEWCHAIN,
1113 NLM_F_MULTI,
1114 afi->family, table, chain) < 0)
1115 goto done;
1116
1117 nl_dump_check_consistent(cb, nlmsg_hdr(skb));
1118cont:
1119 idx++;
1120 }
1121 }
1122 }
1123done:
1124 rcu_read_unlock();
1125 cb->args[0] = idx;
1126 return skb->len;
1127}
1128
1129static int nf_tables_getchain(struct net *net, struct sock *nlsk,
1130 struct sk_buff *skb, const struct nlmsghdr *nlh,
1131 const struct nlattr * const nla[])
1132{
1133 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
1134 u8 genmask = nft_genmask_cur(net);
1135 const struct nft_af_info *afi;
1136 const struct nft_table *table;
1137 const struct nft_chain *chain;
1138 struct sk_buff *skb2;
1139 int family = nfmsg->nfgen_family;
1140 int err;
1141
1142 if (nlh->nlmsg_flags & NLM_F_DUMP) {
1143 struct netlink_dump_control c = {
1144 .dump = nf_tables_dump_chains,
1145 };
1146 return netlink_dump_start(nlsk, skb, nlh, &c);
1147 }
1148
1149 afi = nf_tables_afinfo_lookup(net, family, false);
1150 if (IS_ERR(afi))
1151 return PTR_ERR(afi);
1152
1153 table = nf_tables_table_lookup(afi, nla[NFTA_CHAIN_TABLE], genmask);
1154 if (IS_ERR(table))
1155 return PTR_ERR(table);
1156
1157 chain = nf_tables_chain_lookup(table, nla[NFTA_CHAIN_NAME], genmask);
1158 if (IS_ERR(chain))
1159 return PTR_ERR(chain);
1160
1161 skb2 = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
1162 if (!skb2)
1163 return -ENOMEM;
1164
1165 err = nf_tables_fill_chain_info(skb2, net, NETLINK_CB(skb).portid,
1166 nlh->nlmsg_seq, NFT_MSG_NEWCHAIN, 0,
1167 family, table, chain);
1168 if (err < 0)
1169 goto err;
1170
1171 return nlmsg_unicast(nlsk, skb2, NETLINK_CB(skb).portid);
1172
1173err:
1174 kfree_skb(skb2);
1175 return err;
1176}
1177
1178static const struct nla_policy nft_counter_policy[NFTA_COUNTER_MAX + 1] = {
1179 [NFTA_COUNTER_PACKETS] = { .type = NLA_U64 },
1180 [NFTA_COUNTER_BYTES] = { .type = NLA_U64 },
1181};
1182
1183static struct nft_stats __percpu *nft_stats_alloc(const struct nlattr *attr)
1184{
1185 struct nlattr *tb[NFTA_COUNTER_MAX+1];
1186 struct nft_stats __percpu *newstats;
1187 struct nft_stats *stats;
1188 int err;
1189
1190 err = nla_parse_nested(tb, NFTA_COUNTER_MAX, attr, nft_counter_policy);
1191 if (err < 0)
1192 return ERR_PTR(err);
1193
1194 if (!tb[NFTA_COUNTER_BYTES] || !tb[NFTA_COUNTER_PACKETS])
1195 return ERR_PTR(-EINVAL);
1196
1197 newstats = netdev_alloc_pcpu_stats(struct nft_stats);
1198 if (newstats == NULL)
1199 return ERR_PTR(-ENOMEM);
1200
1201
1202
1203
1204 preempt_disable();
1205 stats = this_cpu_ptr(newstats);
1206 stats->bytes = be64_to_cpu(nla_get_be64(tb[NFTA_COUNTER_BYTES]));
1207 stats->pkts = be64_to_cpu(nla_get_be64(tb[NFTA_COUNTER_PACKETS]));
1208 preempt_enable();
1209
1210 return newstats;
1211}
1212
1213static void nft_chain_stats_replace(struct nft_base_chain *chain,
1214 struct nft_stats __percpu *newstats)
1215{
1216 if (newstats == NULL)
1217 return;
1218
1219 if (chain->stats) {
1220 struct nft_stats __percpu *oldstats =
1221 nft_dereference(chain->stats);
1222
1223 rcu_assign_pointer(chain->stats, newstats);
1224 synchronize_rcu();
1225 free_percpu(oldstats);
1226 } else
1227 rcu_assign_pointer(chain->stats, newstats);
1228}
1229
1230static void nf_tables_chain_destroy(struct nft_chain *chain)
1231{
1232 BUG_ON(chain->use > 0);
1233
1234 if (chain->flags & NFT_BASE_CHAIN) {
1235 struct nft_base_chain *basechain = nft_base_chain(chain);
1236
1237 module_put(basechain->type->owner);
1238 free_percpu(basechain->stats);
1239 if (basechain->ops[0].dev != NULL)
1240 dev_put(basechain->ops[0].dev);
1241 kfree(basechain);
1242 } else {
1243 kfree(chain);
1244 }
1245}
1246
1247struct nft_chain_hook {
1248 u32 num;
1249 u32 priority;
1250 const struct nf_chain_type *type;
1251 struct net_device *dev;
1252};
1253
1254static int nft_chain_parse_hook(struct net *net,
1255 const struct nlattr * const nla[],
1256 struct nft_af_info *afi,
1257 struct nft_chain_hook *hook, bool create)
1258{
1259 struct nlattr *ha[NFTA_HOOK_MAX + 1];
1260 const struct nf_chain_type *type;
1261 struct net_device *dev;
1262 int err;
1263
1264 err = nla_parse_nested(ha, NFTA_HOOK_MAX, nla[NFTA_CHAIN_HOOK],
1265 nft_hook_policy);
1266 if (err < 0)
1267 return err;
1268
1269 if (ha[NFTA_HOOK_HOOKNUM] == NULL ||
1270 ha[NFTA_HOOK_PRIORITY] == NULL)
1271 return -EINVAL;
1272
1273 hook->num = ntohl(nla_get_be32(ha[NFTA_HOOK_HOOKNUM]));
1274 if (hook->num >= afi->nhooks)
1275 return -EINVAL;
1276
1277 hook->priority = ntohl(nla_get_be32(ha[NFTA_HOOK_PRIORITY]));
1278
1279 type = chain_type[afi->family][NFT_CHAIN_T_DEFAULT];
1280 if (nla[NFTA_CHAIN_TYPE]) {
1281 type = nf_tables_chain_type_lookup(afi, nla[NFTA_CHAIN_TYPE],
1282 create);
1283 if (IS_ERR(type))
1284 return PTR_ERR(type);
1285 }
1286 if (!(type->hook_mask & (1 << hook->num)))
1287 return -EOPNOTSUPP;
1288 if (!try_module_get(type->owner))
1289 return -ENOENT;
1290
1291 hook->type = type;
1292
1293 hook->dev = NULL;
1294 if (afi->flags & NFT_AF_NEEDS_DEV) {
1295 char ifname[IFNAMSIZ];
1296
1297 if (!ha[NFTA_HOOK_DEV]) {
1298 module_put(type->owner);
1299 return -EOPNOTSUPP;
1300 }
1301
1302 nla_strlcpy(ifname, ha[NFTA_HOOK_DEV], IFNAMSIZ);
1303 dev = dev_get_by_name(net, ifname);
1304 if (!dev) {
1305 module_put(type->owner);
1306 return -ENOENT;
1307 }
1308 hook->dev = dev;
1309 } else if (ha[NFTA_HOOK_DEV]) {
1310 module_put(type->owner);
1311 return -EOPNOTSUPP;
1312 }
1313
1314 return 0;
1315}
1316
1317static void nft_chain_release_hook(struct nft_chain_hook *hook)
1318{
1319 module_put(hook->type->owner);
1320 if (hook->dev != NULL)
1321 dev_put(hook->dev);
1322}
1323
1324static int nf_tables_newchain(struct net *net, struct sock *nlsk,
1325 struct sk_buff *skb, const struct nlmsghdr *nlh,
1326 const struct nlattr * const nla[])
1327{
1328 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
1329 const struct nlattr * uninitialized_var(name);
1330 struct nft_af_info *afi;
1331 struct nft_table *table;
1332 struct nft_chain *chain;
1333 struct nft_base_chain *basechain = NULL;
1334 u8 genmask = nft_genmask_next(net);
1335 int family = nfmsg->nfgen_family;
1336 u8 policy = NF_ACCEPT;
1337 u64 handle = 0;
1338 unsigned int i;
1339 struct nft_stats __percpu *stats;
1340 int err;
1341 bool create;
1342 struct nft_ctx ctx;
1343
1344 create = nlh->nlmsg_flags & NLM_F_CREATE ? true : false;
1345
1346 afi = nf_tables_afinfo_lookup(net, family, true);
1347 if (IS_ERR(afi))
1348 return PTR_ERR(afi);
1349
1350 table = nf_tables_table_lookup(afi, nla[NFTA_CHAIN_TABLE], genmask);
1351 if (IS_ERR(table))
1352 return PTR_ERR(table);
1353
1354 chain = NULL;
1355 name = nla[NFTA_CHAIN_NAME];
1356
1357 if (nla[NFTA_CHAIN_HANDLE]) {
1358 handle = be64_to_cpu(nla_get_be64(nla[NFTA_CHAIN_HANDLE]));
1359 chain = nf_tables_chain_lookup_byhandle(table, handle, genmask);
1360 if (IS_ERR(chain))
1361 return PTR_ERR(chain);
1362 } else {
1363 chain = nf_tables_chain_lookup(table, name, genmask);
1364 if (IS_ERR(chain)) {
1365 if (PTR_ERR(chain) != -ENOENT)
1366 return PTR_ERR(chain);
1367 chain = NULL;
1368 }
1369 }
1370
1371 if (nla[NFTA_CHAIN_POLICY]) {
1372 if ((chain != NULL &&
1373 !(chain->flags & NFT_BASE_CHAIN)))
1374 return -EOPNOTSUPP;
1375
1376 if (chain == NULL &&
1377 nla[NFTA_CHAIN_HOOK] == NULL)
1378 return -EOPNOTSUPP;
1379
1380 policy = ntohl(nla_get_be32(nla[NFTA_CHAIN_POLICY]));
1381 switch (policy) {
1382 case NF_DROP:
1383 case NF_ACCEPT:
1384 break;
1385 default:
1386 return -EINVAL;
1387 }
1388 }
1389
1390 if (chain != NULL) {
1391 struct nft_stats *stats = NULL;
1392 struct nft_trans *trans;
1393
1394 if (nlh->nlmsg_flags & NLM_F_EXCL)
1395 return -EEXIST;
1396 if (nlh->nlmsg_flags & NLM_F_REPLACE)
1397 return -EOPNOTSUPP;
1398
1399 if (nla[NFTA_CHAIN_HOOK]) {
1400 struct nft_base_chain *basechain;
1401 struct nft_chain_hook hook;
1402 struct nf_hook_ops *ops;
1403
1404 if (!(chain->flags & NFT_BASE_CHAIN))
1405 return -EBUSY;
1406
1407 err = nft_chain_parse_hook(net, nla, afi, &hook,
1408 create);
1409 if (err < 0)
1410 return err;
1411
1412 basechain = nft_base_chain(chain);
1413 if (basechain->type != hook.type) {
1414 nft_chain_release_hook(&hook);
1415 return -EBUSY;
1416 }
1417
1418 for (i = 0; i < afi->nops; i++) {
1419 ops = &basechain->ops[i];
1420 if (ops->hooknum != hook.num ||
1421 ops->priority != hook.priority ||
1422 ops->dev != hook.dev) {
1423 nft_chain_release_hook(&hook);
1424 return -EBUSY;
1425 }
1426 }
1427 nft_chain_release_hook(&hook);
1428 }
1429
1430 if (nla[NFTA_CHAIN_HANDLE] && name) {
1431 struct nft_chain *chain2;
1432
1433 chain2 = nf_tables_chain_lookup(table,
1434 nla[NFTA_CHAIN_NAME],
1435 genmask);
1436 if (IS_ERR(chain2))
1437 return PTR_ERR(chain2);
1438 }
1439
1440 if (nla[NFTA_CHAIN_COUNTERS]) {
1441 if (!(chain->flags & NFT_BASE_CHAIN))
1442 return -EOPNOTSUPP;
1443
1444 stats = nft_stats_alloc(nla[NFTA_CHAIN_COUNTERS]);
1445 if (IS_ERR(stats))
1446 return PTR_ERR(stats);
1447 }
1448
1449 nft_ctx_init(&ctx, net, skb, nlh, afi, table, chain, nla);
1450 trans = nft_trans_alloc(&ctx, NFT_MSG_NEWCHAIN,
1451 sizeof(struct nft_trans_chain));
1452 if (trans == NULL) {
1453 free_percpu(stats);
1454 return -ENOMEM;
1455 }
1456
1457 nft_trans_chain_stats(trans) = stats;
1458 nft_trans_chain_update(trans) = true;
1459
1460 if (nla[NFTA_CHAIN_POLICY])
1461 nft_trans_chain_policy(trans) = policy;
1462 else
1463 nft_trans_chain_policy(trans) = -1;
1464
1465 if (nla[NFTA_CHAIN_HANDLE] && name) {
1466 nla_strlcpy(nft_trans_chain_name(trans), name,
1467 NFT_CHAIN_MAXNAMELEN);
1468 }
1469 list_add_tail(&trans->list, &net->nft.commit_list);
1470 return 0;
1471 }
1472
1473 if (table->use == UINT_MAX)
1474 return -EOVERFLOW;
1475
1476 if (nla[NFTA_CHAIN_HOOK]) {
1477 struct nft_chain_hook hook;
1478 struct nf_hook_ops *ops;
1479 nf_hookfn *hookfn;
1480
1481 err = nft_chain_parse_hook(net, nla, afi, &hook, create);
1482 if (err < 0)
1483 return err;
1484
1485 basechain = kzalloc(sizeof(*basechain), GFP_KERNEL);
1486 if (basechain == NULL) {
1487 nft_chain_release_hook(&hook);
1488 return -ENOMEM;
1489 }
1490
1491 if (hook.dev != NULL)
1492 strncpy(basechain->dev_name, hook.dev->name, IFNAMSIZ);
1493
1494 if (nla[NFTA_CHAIN_COUNTERS]) {
1495 stats = nft_stats_alloc(nla[NFTA_CHAIN_COUNTERS]);
1496 if (IS_ERR(stats)) {
1497 nft_chain_release_hook(&hook);
1498 kfree(basechain);
1499 return PTR_ERR(stats);
1500 }
1501 basechain->stats = stats;
1502 } else {
1503 stats = netdev_alloc_pcpu_stats(struct nft_stats);
1504 if (stats == NULL) {
1505 nft_chain_release_hook(&hook);
1506 kfree(basechain);
1507 return -ENOMEM;
1508 }
1509 rcu_assign_pointer(basechain->stats, stats);
1510 }
1511
1512 hookfn = hook.type->hooks[hook.num];
1513 basechain->type = hook.type;
1514 chain = &basechain->chain;
1515
1516 for (i = 0; i < afi->nops; i++) {
1517 ops = &basechain->ops[i];
1518 ops->pf = family;
1519 ops->hooknum = hook.num;
1520 ops->priority = hook.priority;
1521 ops->priv = chain;
1522 ops->hook = afi->hooks[ops->hooknum];
1523 ops->dev = hook.dev;
1524 if (hookfn)
1525 ops->hook = hookfn;
1526 if (afi->hook_ops_init)
1527 afi->hook_ops_init(ops, i);
1528 }
1529
1530 chain->flags |= NFT_BASE_CHAIN;
1531 basechain->policy = policy;
1532 } else {
1533 chain = kzalloc(sizeof(*chain), GFP_KERNEL);
1534 if (chain == NULL)
1535 return -ENOMEM;
1536 }
1537
1538 INIT_LIST_HEAD(&chain->rules);
1539 chain->handle = nf_tables_alloc_handle(table);
1540 chain->table = table;
1541 nla_strlcpy(chain->name, name, NFT_CHAIN_MAXNAMELEN);
1542
1543 err = nf_tables_register_hooks(net, table, chain, afi->nops);
1544 if (err < 0)
1545 goto err1;
1546
1547 nft_ctx_init(&ctx, net, skb, nlh, afi, table, chain, nla);
1548 err = nft_trans_chain_add(&ctx, NFT_MSG_NEWCHAIN);
1549 if (err < 0)
1550 goto err2;
1551
1552 table->use++;
1553 list_add_tail_rcu(&chain->list, &table->chains);
1554 return 0;
1555err2:
1556 nf_tables_unregister_hooks(net, table, chain, afi->nops);
1557err1:
1558 nf_tables_chain_destroy(chain);
1559 return err;
1560}
1561
1562static int nf_tables_delchain(struct net *net, struct sock *nlsk,
1563 struct sk_buff *skb, const struct nlmsghdr *nlh,
1564 const struct nlattr * const nla[])
1565{
1566 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
1567 u8 genmask = nft_genmask_next(net);
1568 struct nft_af_info *afi;
1569 struct nft_table *table;
1570 struct nft_chain *chain;
1571 int family = nfmsg->nfgen_family;
1572 struct nft_ctx ctx;
1573
1574 afi = nf_tables_afinfo_lookup(net, family, false);
1575 if (IS_ERR(afi))
1576 return PTR_ERR(afi);
1577
1578 table = nf_tables_table_lookup(afi, nla[NFTA_CHAIN_TABLE], genmask);
1579 if (IS_ERR(table))
1580 return PTR_ERR(table);
1581
1582 chain = nf_tables_chain_lookup(table, nla[NFTA_CHAIN_NAME], genmask);
1583 if (IS_ERR(chain))
1584 return PTR_ERR(chain);
1585 if (chain->use > 0)
1586 return -EBUSY;
1587
1588 nft_ctx_init(&ctx, net, skb, nlh, afi, table, chain, nla);
1589
1590 return nft_delchain(&ctx);
1591}
1592
1593
1594
1595
1596
1597
1598
1599
1600
1601
1602
1603
1604int nft_register_expr(struct nft_expr_type *type)
1605{
1606 nfnl_lock(NFNL_SUBSYS_NFTABLES);
1607 if (type->family == NFPROTO_UNSPEC)
1608 list_add_tail_rcu(&type->list, &nf_tables_expressions);
1609 else
1610 list_add_rcu(&type->list, &nf_tables_expressions);
1611 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
1612 return 0;
1613}
1614EXPORT_SYMBOL_GPL(nft_register_expr);
1615
1616
1617
1618
1619
1620
1621
1622void nft_unregister_expr(struct nft_expr_type *type)
1623{
1624 nfnl_lock(NFNL_SUBSYS_NFTABLES);
1625 list_del_rcu(&type->list);
1626 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
1627}
1628EXPORT_SYMBOL_GPL(nft_unregister_expr);
1629
1630static const struct nft_expr_type *__nft_expr_type_get(u8 family,
1631 struct nlattr *nla)
1632{
1633 const struct nft_expr_type *type;
1634
1635 list_for_each_entry(type, &nf_tables_expressions, list) {
1636 if (!nla_strcmp(nla, type->name) &&
1637 (!type->family || type->family == family))
1638 return type;
1639 }
1640 return NULL;
1641}
1642
1643static const struct nft_expr_type *nft_expr_type_get(u8 family,
1644 struct nlattr *nla)
1645{
1646 const struct nft_expr_type *type;
1647
1648 if (nla == NULL)
1649 return ERR_PTR(-EINVAL);
1650
1651 type = __nft_expr_type_get(family, nla);
1652 if (type != NULL && try_module_get(type->owner))
1653 return type;
1654
1655#ifdef CONFIG_MODULES
1656 if (type == NULL) {
1657 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
1658 request_module("nft-expr-%u-%.*s", family,
1659 nla_len(nla), (char *)nla_data(nla));
1660 nfnl_lock(NFNL_SUBSYS_NFTABLES);
1661 if (__nft_expr_type_get(family, nla))
1662 return ERR_PTR(-EAGAIN);
1663
1664 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
1665 request_module("nft-expr-%.*s",
1666 nla_len(nla), (char *)nla_data(nla));
1667 nfnl_lock(NFNL_SUBSYS_NFTABLES);
1668 if (__nft_expr_type_get(family, nla))
1669 return ERR_PTR(-EAGAIN);
1670 }
1671#endif
1672 return ERR_PTR(-ENOENT);
1673}
1674
1675static const struct nla_policy nft_expr_policy[NFTA_EXPR_MAX + 1] = {
1676 [NFTA_EXPR_NAME] = { .type = NLA_STRING },
1677 [NFTA_EXPR_DATA] = { .type = NLA_NESTED },
1678};
1679
1680static int nf_tables_fill_expr_info(struct sk_buff *skb,
1681 const struct nft_expr *expr)
1682{
1683 if (nla_put_string(skb, NFTA_EXPR_NAME, expr->ops->type->name))
1684 goto nla_put_failure;
1685
1686 if (expr->ops->dump) {
1687 struct nlattr *data = nla_nest_start(skb, NFTA_EXPR_DATA);
1688 if (data == NULL)
1689 goto nla_put_failure;
1690 if (expr->ops->dump(skb, expr) < 0)
1691 goto nla_put_failure;
1692 nla_nest_end(skb, data);
1693 }
1694
1695 return skb->len;
1696
1697nla_put_failure:
1698 return -1;
1699};
1700
1701int nft_expr_dump(struct sk_buff *skb, unsigned int attr,
1702 const struct nft_expr *expr)
1703{
1704 struct nlattr *nest;
1705
1706 nest = nla_nest_start(skb, attr);
1707 if (!nest)
1708 goto nla_put_failure;
1709 if (nf_tables_fill_expr_info(skb, expr) < 0)
1710 goto nla_put_failure;
1711 nla_nest_end(skb, nest);
1712 return 0;
1713
1714nla_put_failure:
1715 return -1;
1716}
1717
1718struct nft_expr_info {
1719 const struct nft_expr_ops *ops;
1720 struct nlattr *tb[NFT_EXPR_MAXATTR + 1];
1721};
1722
1723static int nf_tables_expr_parse(const struct nft_ctx *ctx,
1724 const struct nlattr *nla,
1725 struct nft_expr_info *info)
1726{
1727 const struct nft_expr_type *type;
1728 const struct nft_expr_ops *ops;
1729 struct nlattr *tb[NFTA_EXPR_MAX + 1];
1730 int err;
1731
1732 err = nla_parse_nested(tb, NFTA_EXPR_MAX, nla, nft_expr_policy);
1733 if (err < 0)
1734 return err;
1735
1736 type = nft_expr_type_get(ctx->afi->family, tb[NFTA_EXPR_NAME]);
1737 if (IS_ERR(type))
1738 return PTR_ERR(type);
1739
1740 if (tb[NFTA_EXPR_DATA]) {
1741 err = nla_parse_nested(info->tb, type->maxattr,
1742 tb[NFTA_EXPR_DATA], type->policy);
1743 if (err < 0)
1744 goto err1;
1745 } else
1746 memset(info->tb, 0, sizeof(info->tb[0]) * (type->maxattr + 1));
1747
1748 if (type->select_ops != NULL) {
1749 ops = type->select_ops(ctx,
1750 (const struct nlattr * const *)info->tb);
1751 if (IS_ERR(ops)) {
1752 err = PTR_ERR(ops);
1753 goto err1;
1754 }
1755 } else
1756 ops = type->ops;
1757
1758 info->ops = ops;
1759 return 0;
1760
1761err1:
1762 module_put(type->owner);
1763 return err;
1764}
1765
1766static int nf_tables_newexpr(const struct nft_ctx *ctx,
1767 const struct nft_expr_info *info,
1768 struct nft_expr *expr)
1769{
1770 const struct nft_expr_ops *ops = info->ops;
1771 int err;
1772
1773 expr->ops = ops;
1774 if (ops->init) {
1775 err = ops->init(ctx, expr, (const struct nlattr **)info->tb);
1776 if (err < 0)
1777 goto err1;
1778 }
1779
1780 return 0;
1781
1782err1:
1783 expr->ops = NULL;
1784 return err;
1785}
1786
1787static void nf_tables_expr_destroy(const struct nft_ctx *ctx,
1788 struct nft_expr *expr)
1789{
1790 if (expr->ops->destroy)
1791 expr->ops->destroy(ctx, expr);
1792 module_put(expr->ops->type->owner);
1793}
1794
1795struct nft_expr *nft_expr_init(const struct nft_ctx *ctx,
1796 const struct nlattr *nla)
1797{
1798 struct nft_expr_info info;
1799 struct nft_expr *expr;
1800 int err;
1801
1802 err = nf_tables_expr_parse(ctx, nla, &info);
1803 if (err < 0)
1804 goto err1;
1805
1806 err = -ENOMEM;
1807 expr = kzalloc(info.ops->size, GFP_KERNEL);
1808 if (expr == NULL)
1809 goto err2;
1810
1811 err = nf_tables_newexpr(ctx, &info, expr);
1812 if (err < 0)
1813 goto err3;
1814
1815 return expr;
1816err3:
1817 kfree(expr);
1818err2:
1819 module_put(info.ops->type->owner);
1820err1:
1821 return ERR_PTR(err);
1822}
1823
1824void nft_expr_destroy(const struct nft_ctx *ctx, struct nft_expr *expr)
1825{
1826 nf_tables_expr_destroy(ctx, expr);
1827 kfree(expr);
1828}
1829
1830
1831
1832
1833
1834static struct nft_rule *__nf_tables_rule_lookup(const struct nft_chain *chain,
1835 u64 handle)
1836{
1837 struct nft_rule *rule;
1838
1839
1840 list_for_each_entry(rule, &chain->rules, list) {
1841 if (handle == rule->handle)
1842 return rule;
1843 }
1844
1845 return ERR_PTR(-ENOENT);
1846}
1847
1848static struct nft_rule *nf_tables_rule_lookup(const struct nft_chain *chain,
1849 const struct nlattr *nla)
1850{
1851 if (nla == NULL)
1852 return ERR_PTR(-EINVAL);
1853
1854 return __nf_tables_rule_lookup(chain, be64_to_cpu(nla_get_be64(nla)));
1855}
1856
1857static const struct nla_policy nft_rule_policy[NFTA_RULE_MAX + 1] = {
1858 [NFTA_RULE_TABLE] = { .type = NLA_STRING,
1859 .len = NFT_TABLE_MAXNAMELEN - 1 },
1860 [NFTA_RULE_CHAIN] = { .type = NLA_STRING,
1861 .len = NFT_CHAIN_MAXNAMELEN - 1 },
1862 [NFTA_RULE_HANDLE] = { .type = NLA_U64 },
1863 [NFTA_RULE_EXPRESSIONS] = { .type = NLA_NESTED },
1864 [NFTA_RULE_COMPAT] = { .type = NLA_NESTED },
1865 [NFTA_RULE_POSITION] = { .type = NLA_U64 },
1866 [NFTA_RULE_USERDATA] = { .type = NLA_BINARY,
1867 .len = NFT_USERDATA_MAXLEN },
1868};
1869
1870static int nf_tables_fill_rule_info(struct sk_buff *skb, struct net *net,
1871 u32 portid, u32 seq, int event,
1872 u32 flags, int family,
1873 const struct nft_table *table,
1874 const struct nft_chain *chain,
1875 const struct nft_rule *rule)
1876{
1877 struct nlmsghdr *nlh;
1878 struct nfgenmsg *nfmsg;
1879 const struct nft_expr *expr, *next;
1880 struct nlattr *list;
1881 const struct nft_rule *prule;
1882 int type = event | NFNL_SUBSYS_NFTABLES << 8;
1883
1884 nlh = nlmsg_put(skb, portid, seq, type, sizeof(struct nfgenmsg),
1885 flags);
1886 if (nlh == NULL)
1887 goto nla_put_failure;
1888
1889 nfmsg = nlmsg_data(nlh);
1890 nfmsg->nfgen_family = family;
1891 nfmsg->version = NFNETLINK_V0;
1892 nfmsg->res_id = htons(net->nft.base_seq & 0xffff);
1893
1894 if (nla_put_string(skb, NFTA_RULE_TABLE, table->name))
1895 goto nla_put_failure;
1896 if (nla_put_string(skb, NFTA_RULE_CHAIN, chain->name))
1897 goto nla_put_failure;
1898 if (nla_put_be64(skb, NFTA_RULE_HANDLE, cpu_to_be64(rule->handle),
1899 NFTA_RULE_PAD))
1900 goto nla_put_failure;
1901
1902 if ((event != NFT_MSG_DELRULE) && (rule->list.prev != &chain->rules)) {
1903 prule = list_entry(rule->list.prev, struct nft_rule, list);
1904 if (nla_put_be64(skb, NFTA_RULE_POSITION,
1905 cpu_to_be64(prule->handle),
1906 NFTA_RULE_PAD))
1907 goto nla_put_failure;
1908 }
1909
1910 list = nla_nest_start(skb, NFTA_RULE_EXPRESSIONS);
1911 if (list == NULL)
1912 goto nla_put_failure;
1913 nft_rule_for_each_expr(expr, next, rule) {
1914 if (nft_expr_dump(skb, NFTA_LIST_ELEM, expr) < 0)
1915 goto nla_put_failure;
1916 }
1917 nla_nest_end(skb, list);
1918
1919 if (rule->udata) {
1920 struct nft_userdata *udata = nft_userdata(rule);
1921 if (nla_put(skb, NFTA_RULE_USERDATA, udata->len + 1,
1922 udata->data) < 0)
1923 goto nla_put_failure;
1924 }
1925
1926 nlmsg_end(skb, nlh);
1927 return 0;
1928
1929nla_put_failure:
1930 nlmsg_trim(skb, nlh);
1931 return -1;
1932}
1933
1934static int nf_tables_rule_notify(const struct nft_ctx *ctx,
1935 const struct nft_rule *rule,
1936 int event)
1937{
1938 struct sk_buff *skb;
1939 int err;
1940
1941 if (!ctx->report &&
1942 !nfnetlink_has_listeners(ctx->net, NFNLGRP_NFTABLES))
1943 return 0;
1944
1945 err = -ENOBUFS;
1946 skb = nlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL);
1947 if (skb == NULL)
1948 goto err;
1949
1950 err = nf_tables_fill_rule_info(skb, ctx->net, ctx->portid, ctx->seq,
1951 event, 0, ctx->afi->family, ctx->table,
1952 ctx->chain, rule);
1953 if (err < 0) {
1954 kfree_skb(skb);
1955 goto err;
1956 }
1957
1958 err = nfnetlink_send(skb, ctx->net, ctx->portid, NFNLGRP_NFTABLES,
1959 ctx->report, GFP_KERNEL);
1960err:
1961 if (err < 0) {
1962 nfnetlink_set_err(ctx->net, ctx->portid, NFNLGRP_NFTABLES,
1963 err);
1964 }
1965 return err;
1966}
1967
1968struct nft_rule_dump_ctx {
1969 char table[NFT_TABLE_MAXNAMELEN];
1970 char chain[NFT_CHAIN_MAXNAMELEN];
1971};
1972
1973static int nf_tables_dump_rules(struct sk_buff *skb,
1974 struct netlink_callback *cb)
1975{
1976 const struct nfgenmsg *nfmsg = nlmsg_data(cb->nlh);
1977 const struct nft_rule_dump_ctx *ctx = cb->data;
1978 const struct nft_af_info *afi;
1979 const struct nft_table *table;
1980 const struct nft_chain *chain;
1981 const struct nft_rule *rule;
1982 unsigned int idx = 0, s_idx = cb->args[0];
1983 struct net *net = sock_net(skb->sk);
1984 int family = nfmsg->nfgen_family;
1985
1986 rcu_read_lock();
1987 cb->seq = net->nft.base_seq;
1988
1989 list_for_each_entry_rcu(afi, &net->nft.af_info, list) {
1990 if (family != NFPROTO_UNSPEC && family != afi->family)
1991 continue;
1992
1993 list_for_each_entry_rcu(table, &afi->tables, list) {
1994 if (ctx && ctx->table[0] &&
1995 strcmp(ctx->table, table->name) != 0)
1996 continue;
1997
1998 list_for_each_entry_rcu(chain, &table->chains, list) {
1999 if (ctx && ctx->chain[0] &&
2000 strcmp(ctx->chain, chain->name) != 0)
2001 continue;
2002
2003 list_for_each_entry_rcu(rule, &chain->rules, list) {
2004 if (!nft_is_active(net, rule))
2005 goto cont;
2006 if (idx < s_idx)
2007 goto cont;
2008 if (idx > s_idx)
2009 memset(&cb->args[1], 0,
2010 sizeof(cb->args) - sizeof(cb->args[0]));
2011 if (nf_tables_fill_rule_info(skb, net, NETLINK_CB(cb->skb).portid,
2012 cb->nlh->nlmsg_seq,
2013 NFT_MSG_NEWRULE,
2014 NLM_F_MULTI | NLM_F_APPEND,
2015 afi->family, table, chain, rule) < 0)
2016 goto done;
2017
2018 nl_dump_check_consistent(cb, nlmsg_hdr(skb));
2019cont:
2020 idx++;
2021 }
2022 }
2023 }
2024 }
2025done:
2026 rcu_read_unlock();
2027
2028 cb->args[0] = idx;
2029 return skb->len;
2030}
2031
2032static int nf_tables_dump_rules_done(struct netlink_callback *cb)
2033{
2034 kfree(cb->data);
2035 return 0;
2036}
2037
2038static int nf_tables_getrule(struct net *net, struct sock *nlsk,
2039 struct sk_buff *skb, const struct nlmsghdr *nlh,
2040 const struct nlattr * const nla[])
2041{
2042 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
2043 u8 genmask = nft_genmask_cur(net);
2044 const struct nft_af_info *afi;
2045 const struct nft_table *table;
2046 const struct nft_chain *chain;
2047 const struct nft_rule *rule;
2048 struct sk_buff *skb2;
2049 int family = nfmsg->nfgen_family;
2050 int err;
2051
2052 if (nlh->nlmsg_flags & NLM_F_DUMP) {
2053 struct netlink_dump_control c = {
2054 .dump = nf_tables_dump_rules,
2055 .done = nf_tables_dump_rules_done,
2056 };
2057
2058 if (nla[NFTA_RULE_TABLE] || nla[NFTA_RULE_CHAIN]) {
2059 struct nft_rule_dump_ctx *ctx;
2060
2061 ctx = kzalloc(sizeof(*ctx), GFP_KERNEL);
2062 if (!ctx)
2063 return -ENOMEM;
2064
2065 if (nla[NFTA_RULE_TABLE])
2066 nla_strlcpy(ctx->table, nla[NFTA_RULE_TABLE],
2067 sizeof(ctx->table));
2068 if (nla[NFTA_RULE_CHAIN])
2069 nla_strlcpy(ctx->chain, nla[NFTA_RULE_CHAIN],
2070 sizeof(ctx->chain));
2071 c.data = ctx;
2072 }
2073
2074 return netlink_dump_start(nlsk, skb, nlh, &c);
2075 }
2076
2077 afi = nf_tables_afinfo_lookup(net, family, false);
2078 if (IS_ERR(afi))
2079 return PTR_ERR(afi);
2080
2081 table = nf_tables_table_lookup(afi, nla[NFTA_RULE_TABLE], genmask);
2082 if (IS_ERR(table))
2083 return PTR_ERR(table);
2084
2085 chain = nf_tables_chain_lookup(table, nla[NFTA_RULE_CHAIN], genmask);
2086 if (IS_ERR(chain))
2087 return PTR_ERR(chain);
2088
2089 rule = nf_tables_rule_lookup(chain, nla[NFTA_RULE_HANDLE]);
2090 if (IS_ERR(rule))
2091 return PTR_ERR(rule);
2092
2093 skb2 = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
2094 if (!skb2)
2095 return -ENOMEM;
2096
2097 err = nf_tables_fill_rule_info(skb2, net, NETLINK_CB(skb).portid,
2098 nlh->nlmsg_seq, NFT_MSG_NEWRULE, 0,
2099 family, table, chain, rule);
2100 if (err < 0)
2101 goto err;
2102
2103 return nlmsg_unicast(nlsk, skb2, NETLINK_CB(skb).portid);
2104
2105err:
2106 kfree_skb(skb2);
2107 return err;
2108}
2109
2110static void nf_tables_rule_destroy(const struct nft_ctx *ctx,
2111 struct nft_rule *rule)
2112{
2113 struct nft_expr *expr;
2114
2115
2116
2117
2118
2119 expr = nft_expr_first(rule);
2120 while (expr != nft_expr_last(rule) && expr->ops) {
2121 nf_tables_expr_destroy(ctx, expr);
2122 expr = nft_expr_next(expr);
2123 }
2124 kfree(rule);
2125}
2126
2127#define NFT_RULE_MAXEXPRS 128
2128
2129static struct nft_expr_info *info;
2130
2131static int nf_tables_newrule(struct net *net, struct sock *nlsk,
2132 struct sk_buff *skb, const struct nlmsghdr *nlh,
2133 const struct nlattr * const nla[])
2134{
2135 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
2136 u8 genmask = nft_genmask_next(net);
2137 struct nft_af_info *afi;
2138 struct nft_table *table;
2139 struct nft_chain *chain;
2140 struct nft_rule *rule, *old_rule = NULL;
2141 struct nft_userdata *udata;
2142 struct nft_trans *trans = NULL;
2143 struct nft_expr *expr;
2144 struct nft_ctx ctx;
2145 struct nlattr *tmp;
2146 unsigned int size, i, n, ulen = 0, usize = 0;
2147 int err, rem;
2148 bool create;
2149 u64 handle, pos_handle;
2150
2151 create = nlh->nlmsg_flags & NLM_F_CREATE ? true : false;
2152
2153 afi = nf_tables_afinfo_lookup(net, nfmsg->nfgen_family, create);
2154 if (IS_ERR(afi))
2155 return PTR_ERR(afi);
2156
2157 table = nf_tables_table_lookup(afi, nla[NFTA_RULE_TABLE], genmask);
2158 if (IS_ERR(table))
2159 return PTR_ERR(table);
2160
2161 chain = nf_tables_chain_lookup(table, nla[NFTA_RULE_CHAIN], genmask);
2162 if (IS_ERR(chain))
2163 return PTR_ERR(chain);
2164
2165 if (nla[NFTA_RULE_HANDLE]) {
2166 handle = be64_to_cpu(nla_get_be64(nla[NFTA_RULE_HANDLE]));
2167 rule = __nf_tables_rule_lookup(chain, handle);
2168 if (IS_ERR(rule))
2169 return PTR_ERR(rule);
2170
2171 if (nlh->nlmsg_flags & NLM_F_EXCL)
2172 return -EEXIST;
2173 if (nlh->nlmsg_flags & NLM_F_REPLACE)
2174 old_rule = rule;
2175 else
2176 return -EOPNOTSUPP;
2177 } else {
2178 if (!create || nlh->nlmsg_flags & NLM_F_REPLACE)
2179 return -EINVAL;
2180 handle = nf_tables_alloc_handle(table);
2181
2182 if (chain->use == UINT_MAX)
2183 return -EOVERFLOW;
2184 }
2185
2186 if (nla[NFTA_RULE_POSITION]) {
2187 if (!(nlh->nlmsg_flags & NLM_F_CREATE))
2188 return -EOPNOTSUPP;
2189
2190 pos_handle = be64_to_cpu(nla_get_be64(nla[NFTA_RULE_POSITION]));
2191 old_rule = __nf_tables_rule_lookup(chain, pos_handle);
2192 if (IS_ERR(old_rule))
2193 return PTR_ERR(old_rule);
2194 }
2195
2196 nft_ctx_init(&ctx, net, skb, nlh, afi, table, chain, nla);
2197
2198 n = 0;
2199 size = 0;
2200 if (nla[NFTA_RULE_EXPRESSIONS]) {
2201 nla_for_each_nested(tmp, nla[NFTA_RULE_EXPRESSIONS], rem) {
2202 err = -EINVAL;
2203 if (nla_type(tmp) != NFTA_LIST_ELEM)
2204 goto err1;
2205 if (n == NFT_RULE_MAXEXPRS)
2206 goto err1;
2207 err = nf_tables_expr_parse(&ctx, tmp, &info[n]);
2208 if (err < 0)
2209 goto err1;
2210 size += info[n].ops->size;
2211 n++;
2212 }
2213 }
2214
2215 err = -EFBIG;
2216 if (size >= 1 << 12)
2217 goto err1;
2218
2219 if (nla[NFTA_RULE_USERDATA]) {
2220 ulen = nla_len(nla[NFTA_RULE_USERDATA]);
2221 if (ulen > 0)
2222 usize = sizeof(struct nft_userdata) + ulen;
2223 }
2224
2225 err = -ENOMEM;
2226 rule = kzalloc(sizeof(*rule) + size + usize, GFP_KERNEL);
2227 if (rule == NULL)
2228 goto err1;
2229
2230 nft_activate_next(net, rule);
2231
2232 rule->handle = handle;
2233 rule->dlen = size;
2234 rule->udata = ulen ? 1 : 0;
2235
2236 if (ulen) {
2237 udata = nft_userdata(rule);
2238 udata->len = ulen - 1;
2239 nla_memcpy(udata->data, nla[NFTA_RULE_USERDATA], ulen);
2240 }
2241
2242 expr = nft_expr_first(rule);
2243 for (i = 0; i < n; i++) {
2244 err = nf_tables_newexpr(&ctx, &info[i], expr);
2245 if (err < 0)
2246 goto err2;
2247 info[i].ops = NULL;
2248 expr = nft_expr_next(expr);
2249 }
2250
2251 if (nlh->nlmsg_flags & NLM_F_REPLACE) {
2252 if (nft_is_active_next(net, old_rule)) {
2253 trans = nft_trans_rule_add(&ctx, NFT_MSG_DELRULE,
2254 old_rule);
2255 if (trans == NULL) {
2256 err = -ENOMEM;
2257 goto err2;
2258 }
2259 nft_deactivate_next(net, old_rule);
2260 chain->use--;
2261 list_add_tail_rcu(&rule->list, &old_rule->list);
2262 } else {
2263 err = -ENOENT;
2264 goto err2;
2265 }
2266 } else if (nlh->nlmsg_flags & NLM_F_APPEND)
2267 if (old_rule)
2268 list_add_rcu(&rule->list, &old_rule->list);
2269 else
2270 list_add_tail_rcu(&rule->list, &chain->rules);
2271 else {
2272 if (old_rule)
2273 list_add_tail_rcu(&rule->list, &old_rule->list);
2274 else
2275 list_add_rcu(&rule->list, &chain->rules);
2276 }
2277
2278 if (nft_trans_rule_add(&ctx, NFT_MSG_NEWRULE, rule) == NULL) {
2279 err = -ENOMEM;
2280 goto err3;
2281 }
2282 chain->use++;
2283 return 0;
2284
2285err3:
2286 list_del_rcu(&rule->list);
2287err2:
2288 nf_tables_rule_destroy(&ctx, rule);
2289err1:
2290 for (i = 0; i < n; i++) {
2291 if (info[i].ops != NULL)
2292 module_put(info[i].ops->type->owner);
2293 }
2294 return err;
2295}
2296
2297static int nf_tables_delrule(struct net *net, struct sock *nlsk,
2298 struct sk_buff *skb, const struct nlmsghdr *nlh,
2299 const struct nlattr * const nla[])
2300{
2301 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
2302 u8 genmask = nft_genmask_next(net);
2303 struct nft_af_info *afi;
2304 struct nft_table *table;
2305 struct nft_chain *chain = NULL;
2306 struct nft_rule *rule;
2307 int family = nfmsg->nfgen_family, err = 0;
2308 struct nft_ctx ctx;
2309
2310 afi = nf_tables_afinfo_lookup(net, family, false);
2311 if (IS_ERR(afi))
2312 return PTR_ERR(afi);
2313
2314 table = nf_tables_table_lookup(afi, nla[NFTA_RULE_TABLE], genmask);
2315 if (IS_ERR(table))
2316 return PTR_ERR(table);
2317
2318 if (nla[NFTA_RULE_CHAIN]) {
2319 chain = nf_tables_chain_lookup(table, nla[NFTA_RULE_CHAIN],
2320 genmask);
2321 if (IS_ERR(chain))
2322 return PTR_ERR(chain);
2323 }
2324
2325 nft_ctx_init(&ctx, net, skb, nlh, afi, table, chain, nla);
2326
2327 if (chain) {
2328 if (nla[NFTA_RULE_HANDLE]) {
2329 rule = nf_tables_rule_lookup(chain,
2330 nla[NFTA_RULE_HANDLE]);
2331 if (IS_ERR(rule))
2332 return PTR_ERR(rule);
2333
2334 err = nft_delrule(&ctx, rule);
2335 } else {
2336 err = nft_delrule_by_chain(&ctx);
2337 }
2338 } else {
2339 list_for_each_entry(chain, &table->chains, list) {
2340 if (!nft_is_active_next(net, chain))
2341 continue;
2342
2343 ctx.chain = chain;
2344 err = nft_delrule_by_chain(&ctx);
2345 if (err < 0)
2346 break;
2347 }
2348 }
2349
2350 return err;
2351}
2352
2353
2354
2355
2356
2357static LIST_HEAD(nf_tables_set_ops);
2358
2359int nft_register_set(struct nft_set_ops *ops)
2360{
2361 nfnl_lock(NFNL_SUBSYS_NFTABLES);
2362 list_add_tail_rcu(&ops->list, &nf_tables_set_ops);
2363 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
2364 return 0;
2365}
2366EXPORT_SYMBOL_GPL(nft_register_set);
2367
2368void nft_unregister_set(struct nft_set_ops *ops)
2369{
2370 nfnl_lock(NFNL_SUBSYS_NFTABLES);
2371 list_del_rcu(&ops->list);
2372 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
2373}
2374EXPORT_SYMBOL_GPL(nft_unregister_set);
2375
2376
2377
2378
2379
2380
2381static const struct nft_set_ops *
2382nft_select_set_ops(const struct nlattr * const nla[],
2383 const struct nft_set_desc *desc,
2384 enum nft_set_policies policy)
2385{
2386 const struct nft_set_ops *ops, *bops;
2387 struct nft_set_estimate est, best;
2388 u32 features;
2389
2390#ifdef CONFIG_MODULES
2391 if (list_empty(&nf_tables_set_ops)) {
2392 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
2393 request_module("nft-set");
2394 nfnl_lock(NFNL_SUBSYS_NFTABLES);
2395 if (!list_empty(&nf_tables_set_ops))
2396 return ERR_PTR(-EAGAIN);
2397 }
2398#endif
2399 features = 0;
2400 if (nla[NFTA_SET_FLAGS] != NULL) {
2401 features = ntohl(nla_get_be32(nla[NFTA_SET_FLAGS]));
2402 features &= NFT_SET_INTERVAL | NFT_SET_MAP | NFT_SET_TIMEOUT;
2403 }
2404
2405 bops = NULL;
2406 best.size = ~0;
2407 best.class = ~0;
2408
2409 list_for_each_entry(ops, &nf_tables_set_ops, list) {
2410 if ((ops->features & features) != features)
2411 continue;
2412 if (!ops->estimate(desc, features, &est))
2413 continue;
2414
2415 switch (policy) {
2416 case NFT_SET_POL_PERFORMANCE:
2417 if (est.class < best.class)
2418 break;
2419 if (est.class == best.class && est.size < best.size)
2420 break;
2421 continue;
2422 case NFT_SET_POL_MEMORY:
2423 if (est.size < best.size)
2424 break;
2425 if (est.size == best.size && est.class < best.class)
2426 break;
2427 continue;
2428 default:
2429 break;
2430 }
2431
2432 if (!try_module_get(ops->owner))
2433 continue;
2434 if (bops != NULL)
2435 module_put(bops->owner);
2436
2437 bops = ops;
2438 best = est;
2439 }
2440
2441 if (bops != NULL)
2442 return bops;
2443
2444 return ERR_PTR(-EOPNOTSUPP);
2445}
2446
2447static const struct nla_policy nft_set_policy[NFTA_SET_MAX + 1] = {
2448 [NFTA_SET_TABLE] = { .type = NLA_STRING,
2449 .len = NFT_TABLE_MAXNAMELEN - 1 },
2450 [NFTA_SET_NAME] = { .type = NLA_STRING,
2451 .len = NFT_SET_MAXNAMELEN - 1 },
2452 [NFTA_SET_FLAGS] = { .type = NLA_U32 },
2453 [NFTA_SET_KEY_TYPE] = { .type = NLA_U32 },
2454 [NFTA_SET_KEY_LEN] = { .type = NLA_U32 },
2455 [NFTA_SET_DATA_TYPE] = { .type = NLA_U32 },
2456 [NFTA_SET_DATA_LEN] = { .type = NLA_U32 },
2457 [NFTA_SET_POLICY] = { .type = NLA_U32 },
2458 [NFTA_SET_DESC] = { .type = NLA_NESTED },
2459 [NFTA_SET_ID] = { .type = NLA_U32 },
2460 [NFTA_SET_TIMEOUT] = { .type = NLA_U64 },
2461 [NFTA_SET_GC_INTERVAL] = { .type = NLA_U32 },
2462 [NFTA_SET_USERDATA] = { .type = NLA_BINARY,
2463 .len = NFT_USERDATA_MAXLEN },
2464 [NFTA_SET_OBJ_TYPE] = { .type = NLA_U32 },
2465};
2466
2467static const struct nla_policy nft_set_desc_policy[NFTA_SET_DESC_MAX + 1] = {
2468 [NFTA_SET_DESC_SIZE] = { .type = NLA_U32 },
2469};
2470
2471static int nft_ctx_init_from_setattr(struct nft_ctx *ctx, struct net *net,
2472 const struct sk_buff *skb,
2473 const struct nlmsghdr *nlh,
2474 const struct nlattr * const nla[],
2475 u8 genmask)
2476{
2477 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
2478 struct nft_af_info *afi = NULL;
2479 struct nft_table *table = NULL;
2480
2481 if (nfmsg->nfgen_family != NFPROTO_UNSPEC) {
2482 afi = nf_tables_afinfo_lookup(net, nfmsg->nfgen_family, false);
2483 if (IS_ERR(afi))
2484 return PTR_ERR(afi);
2485 }
2486
2487 if (nla[NFTA_SET_TABLE] != NULL) {
2488 if (afi == NULL)
2489 return -EAFNOSUPPORT;
2490
2491 table = nf_tables_table_lookup(afi, nla[NFTA_SET_TABLE],
2492 genmask);
2493 if (IS_ERR(table))
2494 return PTR_ERR(table);
2495 }
2496
2497 nft_ctx_init(ctx, net, skb, nlh, afi, table, NULL, nla);
2498 return 0;
2499}
2500
2501struct nft_set *nf_tables_set_lookup(const struct nft_table *table,
2502 const struct nlattr *nla, u8 genmask)
2503{
2504 struct nft_set *set;
2505
2506 if (nla == NULL)
2507 return ERR_PTR(-EINVAL);
2508
2509 list_for_each_entry(set, &table->sets, list) {
2510 if (!nla_strcmp(nla, set->name) &&
2511 nft_active_genmask(set, genmask))
2512 return set;
2513 }
2514 return ERR_PTR(-ENOENT);
2515}
2516EXPORT_SYMBOL_GPL(nf_tables_set_lookup);
2517
2518struct nft_set *nf_tables_set_lookup_byid(const struct net *net,
2519 const struct nlattr *nla,
2520 u8 genmask)
2521{
2522 struct nft_trans *trans;
2523 u32 id = ntohl(nla_get_be32(nla));
2524
2525 list_for_each_entry(trans, &net->nft.commit_list, list) {
2526 struct nft_set *set = nft_trans_set(trans);
2527
2528 if (trans->msg_type == NFT_MSG_NEWSET &&
2529 id == nft_trans_set_id(trans) &&
2530 nft_active_genmask(set, genmask))
2531 return set;
2532 }
2533 return ERR_PTR(-ENOENT);
2534}
2535EXPORT_SYMBOL_GPL(nf_tables_set_lookup_byid);
2536
2537static int nf_tables_set_alloc_name(struct nft_ctx *ctx, struct nft_set *set,
2538 const char *name)
2539{
2540 const struct nft_set *i;
2541 const char *p;
2542 unsigned long *inuse;
2543 unsigned int n = 0, min = 0;
2544
2545 p = strnchr(name, NFT_SET_MAXNAMELEN, '%');
2546 if (p != NULL) {
2547 if (p[1] != 'd' || strchr(p + 2, '%'))
2548 return -EINVAL;
2549
2550 inuse = (unsigned long *)get_zeroed_page(GFP_KERNEL);
2551 if (inuse == NULL)
2552 return -ENOMEM;
2553cont:
2554 list_for_each_entry(i, &ctx->table->sets, list) {
2555 int tmp;
2556
2557 if (!nft_is_active_next(ctx->net, set))
2558 continue;
2559 if (!sscanf(i->name, name, &tmp))
2560 continue;
2561 if (tmp < min || tmp >= min + BITS_PER_BYTE * PAGE_SIZE)
2562 continue;
2563
2564 set_bit(tmp - min, inuse);
2565 }
2566
2567 n = find_first_zero_bit(inuse, BITS_PER_BYTE * PAGE_SIZE);
2568 if (n >= BITS_PER_BYTE * PAGE_SIZE) {
2569 min += BITS_PER_BYTE * PAGE_SIZE;
2570 memset(inuse, 0, PAGE_SIZE);
2571 goto cont;
2572 }
2573 free_page((unsigned long)inuse);
2574 }
2575
2576 snprintf(set->name, sizeof(set->name), name, min + n);
2577 list_for_each_entry(i, &ctx->table->sets, list) {
2578 if (!nft_is_active_next(ctx->net, i))
2579 continue;
2580 if (!strcmp(set->name, i->name))
2581 return -ENFILE;
2582 }
2583 return 0;
2584}
2585
2586static int nf_tables_fill_set(struct sk_buff *skb, const struct nft_ctx *ctx,
2587 const struct nft_set *set, u16 event, u16 flags)
2588{
2589 struct nfgenmsg *nfmsg;
2590 struct nlmsghdr *nlh;
2591 struct nlattr *desc;
2592 u32 portid = ctx->portid;
2593 u32 seq = ctx->seq;
2594
2595 event |= NFNL_SUBSYS_NFTABLES << 8;
2596 nlh = nlmsg_put(skb, portid, seq, event, sizeof(struct nfgenmsg),
2597 flags);
2598 if (nlh == NULL)
2599 goto nla_put_failure;
2600
2601 nfmsg = nlmsg_data(nlh);
2602 nfmsg->nfgen_family = ctx->afi->family;
2603 nfmsg->version = NFNETLINK_V0;
2604 nfmsg->res_id = htons(ctx->net->nft.base_seq & 0xffff);
2605
2606 if (nla_put_string(skb, NFTA_SET_TABLE, ctx->table->name))
2607 goto nla_put_failure;
2608 if (nla_put_string(skb, NFTA_SET_NAME, set->name))
2609 goto nla_put_failure;
2610 if (set->flags != 0)
2611 if (nla_put_be32(skb, NFTA_SET_FLAGS, htonl(set->flags)))
2612 goto nla_put_failure;
2613
2614 if (nla_put_be32(skb, NFTA_SET_KEY_TYPE, htonl(set->ktype)))
2615 goto nla_put_failure;
2616 if (nla_put_be32(skb, NFTA_SET_KEY_LEN, htonl(set->klen)))
2617 goto nla_put_failure;
2618 if (set->flags & NFT_SET_MAP) {
2619 if (nla_put_be32(skb, NFTA_SET_DATA_TYPE, htonl(set->dtype)))
2620 goto nla_put_failure;
2621 if (nla_put_be32(skb, NFTA_SET_DATA_LEN, htonl(set->dlen)))
2622 goto nla_put_failure;
2623 }
2624 if (set->flags & NFT_SET_OBJECT &&
2625 nla_put_be32(skb, NFTA_SET_OBJ_TYPE, htonl(set->objtype)))
2626 goto nla_put_failure;
2627
2628 if (set->timeout &&
2629 nla_put_be64(skb, NFTA_SET_TIMEOUT,
2630 cpu_to_be64(jiffies_to_msecs(set->timeout)),
2631 NFTA_SET_PAD))
2632 goto nla_put_failure;
2633 if (set->gc_int &&
2634 nla_put_be32(skb, NFTA_SET_GC_INTERVAL, htonl(set->gc_int)))
2635 goto nla_put_failure;
2636
2637 if (set->policy != NFT_SET_POL_PERFORMANCE) {
2638 if (nla_put_be32(skb, NFTA_SET_POLICY, htonl(set->policy)))
2639 goto nla_put_failure;
2640 }
2641
2642 if (nla_put(skb, NFTA_SET_USERDATA, set->udlen, set->udata))
2643 goto nla_put_failure;
2644
2645 desc = nla_nest_start(skb, NFTA_SET_DESC);
2646 if (desc == NULL)
2647 goto nla_put_failure;
2648 if (set->size &&
2649 nla_put_be32(skb, NFTA_SET_DESC_SIZE, htonl(set->size)))
2650 goto nla_put_failure;
2651 nla_nest_end(skb, desc);
2652
2653 nlmsg_end(skb, nlh);
2654 return 0;
2655
2656nla_put_failure:
2657 nlmsg_trim(skb, nlh);
2658 return -1;
2659}
2660
2661static int nf_tables_set_notify(const struct nft_ctx *ctx,
2662 const struct nft_set *set,
2663 int event, gfp_t gfp_flags)
2664{
2665 struct sk_buff *skb;
2666 u32 portid = ctx->portid;
2667 int err;
2668
2669 if (!ctx->report &&
2670 !nfnetlink_has_listeners(ctx->net, NFNLGRP_NFTABLES))
2671 return 0;
2672
2673 err = -ENOBUFS;
2674 skb = nlmsg_new(NLMSG_GOODSIZE, gfp_flags);
2675 if (skb == NULL)
2676 goto err;
2677
2678 err = nf_tables_fill_set(skb, ctx, set, event, 0);
2679 if (err < 0) {
2680 kfree_skb(skb);
2681 goto err;
2682 }
2683
2684 err = nfnetlink_send(skb, ctx->net, portid, NFNLGRP_NFTABLES,
2685 ctx->report, gfp_flags);
2686err:
2687 if (err < 0)
2688 nfnetlink_set_err(ctx->net, portid, NFNLGRP_NFTABLES, err);
2689 return err;
2690}
2691
2692static int nf_tables_dump_sets(struct sk_buff *skb, struct netlink_callback *cb)
2693{
2694 const struct nft_set *set;
2695 unsigned int idx, s_idx = cb->args[0];
2696 struct nft_af_info *afi;
2697 struct nft_table *table, *cur_table = (struct nft_table *)cb->args[2];
2698 struct net *net = sock_net(skb->sk);
2699 int cur_family = cb->args[3];
2700 struct nft_ctx *ctx = cb->data, ctx_set;
2701
2702 if (cb->args[1])
2703 return skb->len;
2704
2705 rcu_read_lock();
2706 cb->seq = net->nft.base_seq;
2707
2708 list_for_each_entry_rcu(afi, &net->nft.af_info, list) {
2709 if (ctx->afi && ctx->afi != afi)
2710 continue;
2711
2712 if (cur_family) {
2713 if (afi->family != cur_family)
2714 continue;
2715
2716 cur_family = 0;
2717 }
2718 list_for_each_entry_rcu(table, &afi->tables, list) {
2719 if (ctx->table && ctx->table != table)
2720 continue;
2721
2722 if (cur_table) {
2723 if (cur_table != table)
2724 continue;
2725
2726 cur_table = NULL;
2727 }
2728 idx = 0;
2729 list_for_each_entry_rcu(set, &table->sets, list) {
2730 if (idx < s_idx)
2731 goto cont;
2732 if (!nft_is_active(net, set))
2733 goto cont;
2734
2735 ctx_set = *ctx;
2736 ctx_set.table = table;
2737 ctx_set.afi = afi;
2738 if (nf_tables_fill_set(skb, &ctx_set, set,
2739 NFT_MSG_NEWSET,
2740 NLM_F_MULTI) < 0) {
2741 cb->args[0] = idx;
2742 cb->args[2] = (unsigned long) table;
2743 cb->args[3] = afi->family;
2744 goto done;
2745 }
2746 nl_dump_check_consistent(cb, nlmsg_hdr(skb));
2747cont:
2748 idx++;
2749 }
2750 if (s_idx)
2751 s_idx = 0;
2752 }
2753 }
2754 cb->args[1] = 1;
2755done:
2756 rcu_read_unlock();
2757 return skb->len;
2758}
2759
2760static int nf_tables_dump_sets_done(struct netlink_callback *cb)
2761{
2762 kfree(cb->data);
2763 return 0;
2764}
2765
2766static int nf_tables_getset(struct net *net, struct sock *nlsk,
2767 struct sk_buff *skb, const struct nlmsghdr *nlh,
2768 const struct nlattr * const nla[])
2769{
2770 u8 genmask = nft_genmask_cur(net);
2771 const struct nft_set *set;
2772 struct nft_ctx ctx;
2773 struct sk_buff *skb2;
2774 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
2775 int err;
2776
2777
2778 err = nft_ctx_init_from_setattr(&ctx, net, skb, nlh, nla, genmask);
2779 if (err < 0)
2780 return err;
2781
2782 if (nlh->nlmsg_flags & NLM_F_DUMP) {
2783 struct netlink_dump_control c = {
2784 .dump = nf_tables_dump_sets,
2785 .done = nf_tables_dump_sets_done,
2786 };
2787 struct nft_ctx *ctx_dump;
2788
2789 ctx_dump = kmalloc(sizeof(*ctx_dump), GFP_KERNEL);
2790 if (ctx_dump == NULL)
2791 return -ENOMEM;
2792
2793 *ctx_dump = ctx;
2794 c.data = ctx_dump;
2795
2796 return netlink_dump_start(nlsk, skb, nlh, &c);
2797 }
2798
2799
2800 if (nfmsg->nfgen_family == NFPROTO_UNSPEC)
2801 return -EAFNOSUPPORT;
2802 if (!nla[NFTA_SET_TABLE])
2803 return -EINVAL;
2804
2805 set = nf_tables_set_lookup(ctx.table, nla[NFTA_SET_NAME], genmask);
2806 if (IS_ERR(set))
2807 return PTR_ERR(set);
2808
2809 skb2 = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
2810 if (skb2 == NULL)
2811 return -ENOMEM;
2812
2813 err = nf_tables_fill_set(skb2, &ctx, set, NFT_MSG_NEWSET, 0);
2814 if (err < 0)
2815 goto err;
2816
2817 return nlmsg_unicast(nlsk, skb2, NETLINK_CB(skb).portid);
2818
2819err:
2820 kfree_skb(skb2);
2821 return err;
2822}
2823
2824static int nf_tables_set_desc_parse(const struct nft_ctx *ctx,
2825 struct nft_set_desc *desc,
2826 const struct nlattr *nla)
2827{
2828 struct nlattr *da[NFTA_SET_DESC_MAX + 1];
2829 int err;
2830
2831 err = nla_parse_nested(da, NFTA_SET_DESC_MAX, nla, nft_set_desc_policy);
2832 if (err < 0)
2833 return err;
2834
2835 if (da[NFTA_SET_DESC_SIZE] != NULL)
2836 desc->size = ntohl(nla_get_be32(da[NFTA_SET_DESC_SIZE]));
2837
2838 return 0;
2839}
2840
2841static int nf_tables_newset(struct net *net, struct sock *nlsk,
2842 struct sk_buff *skb, const struct nlmsghdr *nlh,
2843 const struct nlattr * const nla[])
2844{
2845 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
2846 u8 genmask = nft_genmask_next(net);
2847 const struct nft_set_ops *ops;
2848 struct nft_af_info *afi;
2849 struct nft_table *table;
2850 struct nft_set *set;
2851 struct nft_ctx ctx;
2852 char name[NFT_SET_MAXNAMELEN];
2853 unsigned int size;
2854 bool create;
2855 u64 timeout;
2856 u32 ktype, dtype, flags, policy, gc_int, objtype;
2857 struct nft_set_desc desc;
2858 unsigned char *udata;
2859 u16 udlen;
2860 int err;
2861
2862 if (nla[NFTA_SET_TABLE] == NULL ||
2863 nla[NFTA_SET_NAME] == NULL ||
2864 nla[NFTA_SET_KEY_LEN] == NULL ||
2865 nla[NFTA_SET_ID] == NULL)
2866 return -EINVAL;
2867
2868 memset(&desc, 0, sizeof(desc));
2869
2870 ktype = NFT_DATA_VALUE;
2871 if (nla[NFTA_SET_KEY_TYPE] != NULL) {
2872 ktype = ntohl(nla_get_be32(nla[NFTA_SET_KEY_TYPE]));
2873 if ((ktype & NFT_DATA_RESERVED_MASK) == NFT_DATA_RESERVED_MASK)
2874 return -EINVAL;
2875 }
2876
2877 desc.klen = ntohl(nla_get_be32(nla[NFTA_SET_KEY_LEN]));
2878 if (desc.klen == 0 || desc.klen > NFT_DATA_VALUE_MAXLEN)
2879 return -EINVAL;
2880
2881 flags = 0;
2882 if (nla[NFTA_SET_FLAGS] != NULL) {
2883 flags = ntohl(nla_get_be32(nla[NFTA_SET_FLAGS]));
2884 if (flags & ~(NFT_SET_ANONYMOUS | NFT_SET_CONSTANT |
2885 NFT_SET_INTERVAL | NFT_SET_TIMEOUT |
2886 NFT_SET_MAP | NFT_SET_EVAL |
2887 NFT_SET_OBJECT))
2888 return -EINVAL;
2889
2890 if ((flags & (NFT_SET_MAP | NFT_SET_EVAL | NFT_SET_OBJECT)) ==
2891 (NFT_SET_MAP | NFT_SET_EVAL | NFT_SET_OBJECT))
2892 return -EOPNOTSUPP;
2893 }
2894
2895 dtype = 0;
2896 if (nla[NFTA_SET_DATA_TYPE] != NULL) {
2897 if (!(flags & NFT_SET_MAP))
2898 return -EINVAL;
2899
2900 dtype = ntohl(nla_get_be32(nla[NFTA_SET_DATA_TYPE]));
2901 if ((dtype & NFT_DATA_RESERVED_MASK) == NFT_DATA_RESERVED_MASK &&
2902 dtype != NFT_DATA_VERDICT)
2903 return -EINVAL;
2904
2905 if (dtype != NFT_DATA_VERDICT) {
2906 if (nla[NFTA_SET_DATA_LEN] == NULL)
2907 return -EINVAL;
2908 desc.dlen = ntohl(nla_get_be32(nla[NFTA_SET_DATA_LEN]));
2909 if (desc.dlen == 0 || desc.dlen > NFT_DATA_VALUE_MAXLEN)
2910 return -EINVAL;
2911 } else
2912 desc.dlen = sizeof(struct nft_verdict);
2913 } else if (flags & NFT_SET_MAP)
2914 return -EINVAL;
2915
2916 if (nla[NFTA_SET_OBJ_TYPE] != NULL) {
2917 if (!(flags & NFT_SET_OBJECT))
2918 return -EINVAL;
2919
2920 objtype = ntohl(nla_get_be32(nla[NFTA_SET_OBJ_TYPE]));
2921 if (objtype == NFT_OBJECT_UNSPEC ||
2922 objtype > NFT_OBJECT_MAX)
2923 return -EINVAL;
2924 } else if (flags & NFT_SET_OBJECT)
2925 return -EINVAL;
2926 else
2927 objtype = NFT_OBJECT_UNSPEC;
2928
2929 timeout = 0;
2930 if (nla[NFTA_SET_TIMEOUT] != NULL) {
2931 if (!(flags & NFT_SET_TIMEOUT))
2932 return -EINVAL;
2933 timeout = msecs_to_jiffies(be64_to_cpu(nla_get_be64(
2934 nla[NFTA_SET_TIMEOUT])));
2935 }
2936 gc_int = 0;
2937 if (nla[NFTA_SET_GC_INTERVAL] != NULL) {
2938 if (!(flags & NFT_SET_TIMEOUT))
2939 return -EINVAL;
2940 gc_int = ntohl(nla_get_be32(nla[NFTA_SET_GC_INTERVAL]));
2941 }
2942
2943 policy = NFT_SET_POL_PERFORMANCE;
2944 if (nla[NFTA_SET_POLICY] != NULL)
2945 policy = ntohl(nla_get_be32(nla[NFTA_SET_POLICY]));
2946
2947 if (nla[NFTA_SET_DESC] != NULL) {
2948 err = nf_tables_set_desc_parse(&ctx, &desc, nla[NFTA_SET_DESC]);
2949 if (err < 0)
2950 return err;
2951 }
2952
2953 create = nlh->nlmsg_flags & NLM_F_CREATE ? true : false;
2954
2955 afi = nf_tables_afinfo_lookup(net, nfmsg->nfgen_family, create);
2956 if (IS_ERR(afi))
2957 return PTR_ERR(afi);
2958
2959 table = nf_tables_table_lookup(afi, nla[NFTA_SET_TABLE], genmask);
2960 if (IS_ERR(table))
2961 return PTR_ERR(table);
2962
2963 nft_ctx_init(&ctx, net, skb, nlh, afi, table, NULL, nla);
2964
2965 set = nf_tables_set_lookup(table, nla[NFTA_SET_NAME], genmask);
2966 if (IS_ERR(set)) {
2967 if (PTR_ERR(set) != -ENOENT)
2968 return PTR_ERR(set);
2969 set = NULL;
2970 }
2971
2972 if (set != NULL) {
2973 if (nlh->nlmsg_flags & NLM_F_EXCL)
2974 return -EEXIST;
2975 if (nlh->nlmsg_flags & NLM_F_REPLACE)
2976 return -EOPNOTSUPP;
2977 return 0;
2978 }
2979
2980 if (!(nlh->nlmsg_flags & NLM_F_CREATE))
2981 return -ENOENT;
2982
2983 ops = nft_select_set_ops(nla, &desc, policy);
2984 if (IS_ERR(ops))
2985 return PTR_ERR(ops);
2986
2987 udlen = 0;
2988 if (nla[NFTA_SET_USERDATA])
2989 udlen = nla_len(nla[NFTA_SET_USERDATA]);
2990
2991 size = 0;
2992 if (ops->privsize != NULL)
2993 size = ops->privsize(nla);
2994
2995 err = -ENOMEM;
2996 set = kzalloc(sizeof(*set) + size + udlen, GFP_KERNEL);
2997 if (set == NULL)
2998 goto err1;
2999
3000 nla_strlcpy(name, nla[NFTA_SET_NAME], sizeof(set->name));
3001 err = nf_tables_set_alloc_name(&ctx, set, name);
3002 if (err < 0)
3003 goto err2;
3004
3005 udata = NULL;
3006 if (udlen) {
3007 udata = set->data + size;
3008 nla_memcpy(udata, nla[NFTA_SET_USERDATA], udlen);
3009 }
3010
3011 INIT_LIST_HEAD(&set->bindings);
3012 set->ops = ops;
3013 set->ktype = ktype;
3014 set->klen = desc.klen;
3015 set->dtype = dtype;
3016 set->objtype = objtype;
3017 set->dlen = desc.dlen;
3018 set->flags = flags;
3019 set->size = desc.size;
3020 set->policy = policy;
3021 set->udlen = udlen;
3022 set->udata = udata;
3023 set->timeout = timeout;
3024 set->gc_int = gc_int;
3025
3026 err = ops->init(set, &desc, nla);
3027 if (err < 0)
3028 goto err2;
3029
3030 err = nft_trans_set_add(&ctx, NFT_MSG_NEWSET, set);
3031 if (err < 0)
3032 goto err3;
3033
3034 list_add_tail_rcu(&set->list, &table->sets);
3035 table->use++;
3036 return 0;
3037
3038err3:
3039 ops->destroy(set);
3040err2:
3041 kfree(set);
3042err1:
3043 module_put(ops->owner);
3044 return err;
3045}
3046
3047static void nft_set_destroy(struct nft_set *set)
3048{
3049 set->ops->destroy(set);
3050 module_put(set->ops->owner);
3051 kfree(set);
3052}
3053
3054static void nf_tables_set_destroy(const struct nft_ctx *ctx, struct nft_set *set)
3055{
3056 list_del_rcu(&set->list);
3057 nf_tables_set_notify(ctx, set, NFT_MSG_DELSET, GFP_ATOMIC);
3058 nft_set_destroy(set);
3059}
3060
3061static int nf_tables_delset(struct net *net, struct sock *nlsk,
3062 struct sk_buff *skb, const struct nlmsghdr *nlh,
3063 const struct nlattr * const nla[])
3064{
3065 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
3066 u8 genmask = nft_genmask_next(net);
3067 struct nft_set *set;
3068 struct nft_ctx ctx;
3069 int err;
3070
3071 if (nfmsg->nfgen_family == NFPROTO_UNSPEC)
3072 return -EAFNOSUPPORT;
3073 if (nla[NFTA_SET_TABLE] == NULL)
3074 return -EINVAL;
3075
3076 err = nft_ctx_init_from_setattr(&ctx, net, skb, nlh, nla, genmask);
3077 if (err < 0)
3078 return err;
3079
3080 set = nf_tables_set_lookup(ctx.table, nla[NFTA_SET_NAME], genmask);
3081 if (IS_ERR(set))
3082 return PTR_ERR(set);
3083 if (!list_empty(&set->bindings))
3084 return -EBUSY;
3085
3086 return nft_delset(&ctx, set);
3087}
3088
3089static int nf_tables_bind_check_setelem(const struct nft_ctx *ctx,
3090 struct nft_set *set,
3091 const struct nft_set_iter *iter,
3092 struct nft_set_elem *elem)
3093{
3094 const struct nft_set_ext *ext = nft_set_elem_ext(set, elem->priv);
3095 enum nft_registers dreg;
3096
3097 dreg = nft_type_to_reg(set->dtype);
3098 return nft_validate_register_store(ctx, dreg, nft_set_ext_data(ext),
3099 set->dtype == NFT_DATA_VERDICT ?
3100 NFT_DATA_VERDICT : NFT_DATA_VALUE,
3101 set->dlen);
3102}
3103
3104int nf_tables_bind_set(const struct nft_ctx *ctx, struct nft_set *set,
3105 struct nft_set_binding *binding)
3106{
3107 struct nft_set_binding *i;
3108 struct nft_set_iter iter;
3109
3110 if (!list_empty(&set->bindings) && set->flags & NFT_SET_ANONYMOUS)
3111 return -EBUSY;
3112
3113 if (binding->flags & NFT_SET_MAP) {
3114
3115
3116
3117 list_for_each_entry(i, &set->bindings, list) {
3118 if (i->flags & NFT_SET_MAP &&
3119 i->chain == binding->chain)
3120 goto bind;
3121 }
3122
3123 iter.genmask = nft_genmask_next(ctx->net);
3124 iter.skip = 0;
3125 iter.count = 0;
3126 iter.err = 0;
3127 iter.fn = nf_tables_bind_check_setelem;
3128
3129 set->ops->walk(ctx, set, &iter);
3130 if (iter.err < 0)
3131 return iter.err;
3132 }
3133bind:
3134 binding->chain = ctx->chain;
3135 list_add_tail_rcu(&binding->list, &set->bindings);
3136 return 0;
3137}
3138EXPORT_SYMBOL_GPL(nf_tables_bind_set);
3139
3140void nf_tables_unbind_set(const struct nft_ctx *ctx, struct nft_set *set,
3141 struct nft_set_binding *binding)
3142{
3143 list_del_rcu(&binding->list);
3144
3145 if (list_empty(&set->bindings) && set->flags & NFT_SET_ANONYMOUS &&
3146 nft_is_active(ctx->net, set))
3147 nf_tables_set_destroy(ctx, set);
3148}
3149EXPORT_SYMBOL_GPL(nf_tables_unbind_set);
3150
3151const struct nft_set_ext_type nft_set_ext_types[] = {
3152 [NFT_SET_EXT_KEY] = {
3153 .align = __alignof__(u32),
3154 },
3155 [NFT_SET_EXT_DATA] = {
3156 .align = __alignof__(u32),
3157 },
3158 [NFT_SET_EXT_EXPR] = {
3159 .align = __alignof__(struct nft_expr),
3160 },
3161 [NFT_SET_EXT_OBJREF] = {
3162 .len = sizeof(struct nft_object *),
3163 .align = __alignof__(struct nft_object *),
3164 },
3165 [NFT_SET_EXT_FLAGS] = {
3166 .len = sizeof(u8),
3167 .align = __alignof__(u8),
3168 },
3169 [NFT_SET_EXT_TIMEOUT] = {
3170 .len = sizeof(u64),
3171 .align = __alignof__(u64),
3172 },
3173 [NFT_SET_EXT_EXPIRATION] = {
3174 .len = sizeof(unsigned long),
3175 .align = __alignof__(unsigned long),
3176 },
3177 [NFT_SET_EXT_USERDATA] = {
3178 .len = sizeof(struct nft_userdata),
3179 .align = __alignof__(struct nft_userdata),
3180 },
3181};
3182EXPORT_SYMBOL_GPL(nft_set_ext_types);
3183
3184
3185
3186
3187
3188static const struct nla_policy nft_set_elem_policy[NFTA_SET_ELEM_MAX + 1] = {
3189 [NFTA_SET_ELEM_KEY] = { .type = NLA_NESTED },
3190 [NFTA_SET_ELEM_DATA] = { .type = NLA_NESTED },
3191 [NFTA_SET_ELEM_FLAGS] = { .type = NLA_U32 },
3192 [NFTA_SET_ELEM_TIMEOUT] = { .type = NLA_U64 },
3193 [NFTA_SET_ELEM_USERDATA] = { .type = NLA_BINARY,
3194 .len = NFT_USERDATA_MAXLEN },
3195};
3196
3197static const struct nla_policy nft_set_elem_list_policy[NFTA_SET_ELEM_LIST_MAX + 1] = {
3198 [NFTA_SET_ELEM_LIST_TABLE] = { .type = NLA_STRING,
3199 .len = NFT_TABLE_MAXNAMELEN - 1 },
3200 [NFTA_SET_ELEM_LIST_SET] = { .type = NLA_STRING,
3201 .len = NFT_SET_MAXNAMELEN - 1 },
3202 [NFTA_SET_ELEM_LIST_ELEMENTS] = { .type = NLA_NESTED },
3203 [NFTA_SET_ELEM_LIST_SET_ID] = { .type = NLA_U32 },
3204};
3205
3206static int nft_ctx_init_from_elemattr(struct nft_ctx *ctx, struct net *net,
3207 const struct sk_buff *skb,
3208 const struct nlmsghdr *nlh,
3209 const struct nlattr * const nla[],
3210 u8 genmask)
3211{
3212 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
3213 struct nft_af_info *afi;
3214 struct nft_table *table;
3215
3216 afi = nf_tables_afinfo_lookup(net, nfmsg->nfgen_family, false);
3217 if (IS_ERR(afi))
3218 return PTR_ERR(afi);
3219
3220 table = nf_tables_table_lookup(afi, nla[NFTA_SET_ELEM_LIST_TABLE],
3221 genmask);
3222 if (IS_ERR(table))
3223 return PTR_ERR(table);
3224
3225 nft_ctx_init(ctx, net, skb, nlh, afi, table, NULL, nla);
3226 return 0;
3227}
3228
3229static int nf_tables_fill_setelem(struct sk_buff *skb,
3230 const struct nft_set *set,
3231 const struct nft_set_elem *elem)
3232{
3233 const struct nft_set_ext *ext = nft_set_elem_ext(set, elem->priv);
3234 unsigned char *b = skb_tail_pointer(skb);
3235 struct nlattr *nest;
3236
3237 nest = nla_nest_start(skb, NFTA_LIST_ELEM);
3238 if (nest == NULL)
3239 goto nla_put_failure;
3240
3241 if (nft_data_dump(skb, NFTA_SET_ELEM_KEY, nft_set_ext_key(ext),
3242 NFT_DATA_VALUE, set->klen) < 0)
3243 goto nla_put_failure;
3244
3245 if (nft_set_ext_exists(ext, NFT_SET_EXT_DATA) &&
3246 nft_data_dump(skb, NFTA_SET_ELEM_DATA, nft_set_ext_data(ext),
3247 set->dtype == NFT_DATA_VERDICT ? NFT_DATA_VERDICT : NFT_DATA_VALUE,
3248 set->dlen) < 0)
3249 goto nla_put_failure;
3250
3251 if (nft_set_ext_exists(ext, NFT_SET_EXT_EXPR) &&
3252 nft_expr_dump(skb, NFTA_SET_ELEM_EXPR, nft_set_ext_expr(ext)) < 0)
3253 goto nla_put_failure;
3254
3255 if (nft_set_ext_exists(ext, NFT_SET_EXT_OBJREF) &&
3256 nla_put_string(skb, NFTA_SET_ELEM_OBJREF,
3257 (*nft_set_ext_obj(ext))->name) < 0)
3258 goto nla_put_failure;
3259
3260 if (nft_set_ext_exists(ext, NFT_SET_EXT_FLAGS) &&
3261 nla_put_be32(skb, NFTA_SET_ELEM_FLAGS,
3262 htonl(*nft_set_ext_flags(ext))))
3263 goto nla_put_failure;
3264
3265 if (nft_set_ext_exists(ext, NFT_SET_EXT_TIMEOUT) &&
3266 nla_put_be64(skb, NFTA_SET_ELEM_TIMEOUT,
3267 cpu_to_be64(jiffies_to_msecs(
3268 *nft_set_ext_timeout(ext))),
3269 NFTA_SET_ELEM_PAD))
3270 goto nla_put_failure;
3271
3272 if (nft_set_ext_exists(ext, NFT_SET_EXT_EXPIRATION)) {
3273 unsigned long expires, now = jiffies;
3274
3275 expires = *nft_set_ext_expiration(ext);
3276 if (time_before(now, expires))
3277 expires -= now;
3278 else
3279 expires = 0;
3280
3281 if (nla_put_be64(skb, NFTA_SET_ELEM_EXPIRATION,
3282 cpu_to_be64(jiffies_to_msecs(expires)),
3283 NFTA_SET_ELEM_PAD))
3284 goto nla_put_failure;
3285 }
3286
3287 if (nft_set_ext_exists(ext, NFT_SET_EXT_USERDATA)) {
3288 struct nft_userdata *udata;
3289
3290 udata = nft_set_ext_userdata(ext);
3291 if (nla_put(skb, NFTA_SET_ELEM_USERDATA,
3292 udata->len + 1, udata->data))
3293 goto nla_put_failure;
3294 }
3295
3296 nla_nest_end(skb, nest);
3297 return 0;
3298
3299nla_put_failure:
3300 nlmsg_trim(skb, b);
3301 return -EMSGSIZE;
3302}
3303
3304struct nft_set_dump_args {
3305 const struct netlink_callback *cb;
3306 struct nft_set_iter iter;
3307 struct sk_buff *skb;
3308};
3309
3310static int nf_tables_dump_setelem(const struct nft_ctx *ctx,
3311 struct nft_set *set,
3312 const struct nft_set_iter *iter,
3313 struct nft_set_elem *elem)
3314{
3315 struct nft_set_dump_args *args;
3316
3317 args = container_of(iter, struct nft_set_dump_args, iter);
3318 return nf_tables_fill_setelem(args->skb, set, elem);
3319}
3320
3321static int nf_tables_dump_set(struct sk_buff *skb, struct netlink_callback *cb)
3322{
3323 struct net *net = sock_net(skb->sk);
3324 u8 genmask = nft_genmask_cur(net);
3325 struct nft_set *set;
3326 struct nft_set_dump_args args;
3327 struct nft_ctx ctx;
3328 struct nlattr *nla[NFTA_SET_ELEM_LIST_MAX + 1];
3329 struct nfgenmsg *nfmsg;
3330 struct nlmsghdr *nlh;
3331 struct nlattr *nest;
3332 u32 portid, seq;
3333 int event, err;
3334
3335 err = nlmsg_parse(cb->nlh, sizeof(struct nfgenmsg), nla,
3336 NFTA_SET_ELEM_LIST_MAX, nft_set_elem_list_policy);
3337 if (err < 0)
3338 return err;
3339
3340 err = nft_ctx_init_from_elemattr(&ctx, net, cb->skb, cb->nlh,
3341 (void *)nla, genmask);
3342 if (err < 0)
3343 return err;
3344
3345 set = nf_tables_set_lookup(ctx.table, nla[NFTA_SET_ELEM_LIST_SET],
3346 genmask);
3347 if (IS_ERR(set))
3348 return PTR_ERR(set);
3349
3350 event = NFT_MSG_NEWSETELEM;
3351 event |= NFNL_SUBSYS_NFTABLES << 8;
3352 portid = NETLINK_CB(cb->skb).portid;
3353 seq = cb->nlh->nlmsg_seq;
3354
3355 nlh = nlmsg_put(skb, portid, seq, event, sizeof(struct nfgenmsg),
3356 NLM_F_MULTI);
3357 if (nlh == NULL)
3358 goto nla_put_failure;
3359
3360 nfmsg = nlmsg_data(nlh);
3361 nfmsg->nfgen_family = ctx.afi->family;
3362 nfmsg->version = NFNETLINK_V0;
3363 nfmsg->res_id = htons(ctx.net->nft.base_seq & 0xffff);
3364
3365 if (nla_put_string(skb, NFTA_SET_ELEM_LIST_TABLE, ctx.table->name))
3366 goto nla_put_failure;
3367 if (nla_put_string(skb, NFTA_SET_ELEM_LIST_SET, set->name))
3368 goto nla_put_failure;
3369
3370 nest = nla_nest_start(skb, NFTA_SET_ELEM_LIST_ELEMENTS);
3371 if (nest == NULL)
3372 goto nla_put_failure;
3373
3374 args.cb = cb;
3375 args.skb = skb;
3376 args.iter.genmask = nft_genmask_cur(ctx.net);
3377 args.iter.skip = cb->args[0];
3378 args.iter.count = 0;
3379 args.iter.err = 0;
3380 args.iter.fn = nf_tables_dump_setelem;
3381 set->ops->walk(&ctx, set, &args.iter);
3382
3383 nla_nest_end(skb, nest);
3384 nlmsg_end(skb, nlh);
3385
3386 if (args.iter.err && args.iter.err != -EMSGSIZE)
3387 return args.iter.err;
3388 if (args.iter.count == cb->args[0])
3389 return 0;
3390
3391 cb->args[0] = args.iter.count;
3392 return skb->len;
3393
3394nla_put_failure:
3395 return -ENOSPC;
3396}
3397
3398static int nf_tables_getsetelem(struct net *net, struct sock *nlsk,
3399 struct sk_buff *skb, const struct nlmsghdr *nlh,
3400 const struct nlattr * const nla[])
3401{
3402 u8 genmask = nft_genmask_cur(net);
3403 const struct nft_set *set;
3404 struct nft_ctx ctx;
3405 int err;
3406
3407 err = nft_ctx_init_from_elemattr(&ctx, net, skb, nlh, nla, genmask);
3408 if (err < 0)
3409 return err;
3410
3411 set = nf_tables_set_lookup(ctx.table, nla[NFTA_SET_ELEM_LIST_SET],
3412 genmask);
3413 if (IS_ERR(set))
3414 return PTR_ERR(set);
3415
3416 if (nlh->nlmsg_flags & NLM_F_DUMP) {
3417 struct netlink_dump_control c = {
3418 .dump = nf_tables_dump_set,
3419 };
3420 return netlink_dump_start(nlsk, skb, nlh, &c);
3421 }
3422 return -EOPNOTSUPP;
3423}
3424
3425static int nf_tables_fill_setelem_info(struct sk_buff *skb,
3426 const struct nft_ctx *ctx, u32 seq,
3427 u32 portid, int event, u16 flags,
3428 const struct nft_set *set,
3429 const struct nft_set_elem *elem)
3430{
3431 struct nfgenmsg *nfmsg;
3432 struct nlmsghdr *nlh;
3433 struct nlattr *nest;
3434 int err;
3435
3436 event |= NFNL_SUBSYS_NFTABLES << 8;
3437 nlh = nlmsg_put(skb, portid, seq, event, sizeof(struct nfgenmsg),
3438 flags);
3439 if (nlh == NULL)
3440 goto nla_put_failure;
3441
3442 nfmsg = nlmsg_data(nlh);
3443 nfmsg->nfgen_family = ctx->afi->family;
3444 nfmsg->version = NFNETLINK_V0;
3445 nfmsg->res_id = htons(ctx->net->nft.base_seq & 0xffff);
3446
3447 if (nla_put_string(skb, NFTA_SET_TABLE, ctx->table->name))
3448 goto nla_put_failure;
3449 if (nla_put_string(skb, NFTA_SET_NAME, set->name))
3450 goto nla_put_failure;
3451
3452 nest = nla_nest_start(skb, NFTA_SET_ELEM_LIST_ELEMENTS);
3453 if (nest == NULL)
3454 goto nla_put_failure;
3455
3456 err = nf_tables_fill_setelem(skb, set, elem);
3457 if (err < 0)
3458 goto nla_put_failure;
3459
3460 nla_nest_end(skb, nest);
3461
3462 nlmsg_end(skb, nlh);
3463 return 0;
3464
3465nla_put_failure:
3466 nlmsg_trim(skb, nlh);
3467 return -1;
3468}
3469
3470static int nf_tables_setelem_notify(const struct nft_ctx *ctx,
3471 const struct nft_set *set,
3472 const struct nft_set_elem *elem,
3473 int event, u16 flags)
3474{
3475 struct net *net = ctx->net;
3476 u32 portid = ctx->portid;
3477 struct sk_buff *skb;
3478 int err;
3479
3480 if (!ctx->report && !nfnetlink_has_listeners(net, NFNLGRP_NFTABLES))
3481 return 0;
3482
3483 err = -ENOBUFS;
3484 skb = nlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL);
3485 if (skb == NULL)
3486 goto err;
3487
3488 err = nf_tables_fill_setelem_info(skb, ctx, 0, portid, event, flags,
3489 set, elem);
3490 if (err < 0) {
3491 kfree_skb(skb);
3492 goto err;
3493 }
3494
3495 err = nfnetlink_send(skb, net, portid, NFNLGRP_NFTABLES, ctx->report,
3496 GFP_KERNEL);
3497err:
3498 if (err < 0)
3499 nfnetlink_set_err(net, portid, NFNLGRP_NFTABLES, err);
3500 return err;
3501}
3502
3503static struct nft_trans *nft_trans_elem_alloc(struct nft_ctx *ctx,
3504 int msg_type,
3505 struct nft_set *set)
3506{
3507 struct nft_trans *trans;
3508
3509 trans = nft_trans_alloc(ctx, msg_type, sizeof(struct nft_trans_elem));
3510 if (trans == NULL)
3511 return NULL;
3512
3513 nft_trans_elem_set(trans) = set;
3514 return trans;
3515}
3516
3517void *nft_set_elem_init(const struct nft_set *set,
3518 const struct nft_set_ext_tmpl *tmpl,
3519 const u32 *key, const u32 *data,
3520 u64 timeout, gfp_t gfp)
3521{
3522 struct nft_set_ext *ext;
3523 void *elem;
3524
3525 elem = kzalloc(set->ops->elemsize + tmpl->len, gfp);
3526 if (elem == NULL)
3527 return NULL;
3528
3529 ext = nft_set_elem_ext(set, elem);
3530 nft_set_ext_init(ext, tmpl);
3531
3532 memcpy(nft_set_ext_key(ext), key, set->klen);
3533 if (nft_set_ext_exists(ext, NFT_SET_EXT_DATA))
3534 memcpy(nft_set_ext_data(ext), data, set->dlen);
3535 if (nft_set_ext_exists(ext, NFT_SET_EXT_EXPIRATION))
3536 *nft_set_ext_expiration(ext) =
3537 jiffies + timeout;
3538 if (nft_set_ext_exists(ext, NFT_SET_EXT_TIMEOUT))
3539 *nft_set_ext_timeout(ext) = timeout;
3540
3541 return elem;
3542}
3543
3544void nft_set_elem_destroy(const struct nft_set *set, void *elem,
3545 bool destroy_expr)
3546{
3547 struct nft_set_ext *ext = nft_set_elem_ext(set, elem);
3548
3549 nft_data_uninit(nft_set_ext_key(ext), NFT_DATA_VALUE);
3550 if (nft_set_ext_exists(ext, NFT_SET_EXT_DATA))
3551 nft_data_uninit(nft_set_ext_data(ext), set->dtype);
3552 if (destroy_expr && nft_set_ext_exists(ext, NFT_SET_EXT_EXPR))
3553 nf_tables_expr_destroy(NULL, nft_set_ext_expr(ext));
3554 if (nft_set_ext_exists(ext, NFT_SET_EXT_OBJREF))
3555 (*nft_set_ext_obj(ext))->use--;
3556 kfree(elem);
3557}
3558EXPORT_SYMBOL_GPL(nft_set_elem_destroy);
3559
3560static int nft_setelem_parse_flags(const struct nft_set *set,
3561 const struct nlattr *attr, u32 *flags)
3562{
3563 if (attr == NULL)
3564 return 0;
3565
3566 *flags = ntohl(nla_get_be32(attr));
3567 if (*flags & ~NFT_SET_ELEM_INTERVAL_END)
3568 return -EINVAL;
3569 if (!(set->flags & NFT_SET_INTERVAL) &&
3570 *flags & NFT_SET_ELEM_INTERVAL_END)
3571 return -EINVAL;
3572
3573 return 0;
3574}
3575
3576static int nft_add_set_elem(struct nft_ctx *ctx, struct nft_set *set,
3577 const struct nlattr *attr, u32 nlmsg_flags)
3578{
3579 struct nlattr *nla[NFTA_SET_ELEM_MAX + 1];
3580 u8 genmask = nft_genmask_next(ctx->net);
3581 struct nft_data_desc d1, d2;
3582 struct nft_set_ext_tmpl tmpl;
3583 struct nft_set_ext *ext, *ext2;
3584 struct nft_set_elem elem;
3585 struct nft_set_binding *binding;
3586 struct nft_object *obj = NULL;
3587 struct nft_userdata *udata;
3588 struct nft_data data;
3589 enum nft_registers dreg;
3590 struct nft_trans *trans;
3591 u32 flags = 0;
3592 u64 timeout;
3593 u8 ulen;
3594 int err;
3595
3596 err = nla_parse_nested(nla, NFTA_SET_ELEM_MAX, attr,
3597 nft_set_elem_policy);
3598 if (err < 0)
3599 return err;
3600
3601 if (nla[NFTA_SET_ELEM_KEY] == NULL)
3602 return -EINVAL;
3603
3604 nft_set_ext_prepare(&tmpl);
3605
3606 err = nft_setelem_parse_flags(set, nla[NFTA_SET_ELEM_FLAGS], &flags);
3607 if (err < 0)
3608 return err;
3609 if (flags != 0)
3610 nft_set_ext_add(&tmpl, NFT_SET_EXT_FLAGS);
3611
3612 if (set->flags & NFT_SET_MAP) {
3613 if (nla[NFTA_SET_ELEM_DATA] == NULL &&
3614 !(flags & NFT_SET_ELEM_INTERVAL_END))
3615 return -EINVAL;
3616 if (nla[NFTA_SET_ELEM_DATA] != NULL &&
3617 flags & NFT_SET_ELEM_INTERVAL_END)
3618 return -EINVAL;
3619 } else {
3620 if (nla[NFTA_SET_ELEM_DATA] != NULL)
3621 return -EINVAL;
3622 }
3623
3624 timeout = 0;
3625 if (nla[NFTA_SET_ELEM_TIMEOUT] != NULL) {
3626 if (!(set->flags & NFT_SET_TIMEOUT))
3627 return -EINVAL;
3628 timeout = msecs_to_jiffies(be64_to_cpu(nla_get_be64(
3629 nla[NFTA_SET_ELEM_TIMEOUT])));
3630 } else if (set->flags & NFT_SET_TIMEOUT) {
3631 timeout = set->timeout;
3632 }
3633
3634 err = nft_data_init(ctx, &elem.key.val, sizeof(elem.key), &d1,
3635 nla[NFTA_SET_ELEM_KEY]);
3636 if (err < 0)
3637 goto err1;
3638 err = -EINVAL;
3639 if (d1.type != NFT_DATA_VALUE || d1.len != set->klen)
3640 goto err2;
3641
3642 nft_set_ext_add_length(&tmpl, NFT_SET_EXT_KEY, d1.len);
3643 if (timeout > 0) {
3644 nft_set_ext_add(&tmpl, NFT_SET_EXT_EXPIRATION);
3645 if (timeout != set->timeout)
3646 nft_set_ext_add(&tmpl, NFT_SET_EXT_TIMEOUT);
3647 }
3648
3649 if (nla[NFTA_SET_ELEM_OBJREF] != NULL) {
3650 if (!(set->flags & NFT_SET_OBJECT)) {
3651 err = -EINVAL;
3652 goto err2;
3653 }
3654 obj = nf_tables_obj_lookup(ctx->table, nla[NFTA_SET_ELEM_OBJREF],
3655 set->objtype, genmask);
3656 if (IS_ERR(obj)) {
3657 err = PTR_ERR(obj);
3658 goto err2;
3659 }
3660 nft_set_ext_add(&tmpl, NFT_SET_EXT_OBJREF);
3661 }
3662
3663 if (nla[NFTA_SET_ELEM_DATA] != NULL) {
3664 err = nft_data_init(ctx, &data, sizeof(data), &d2,
3665 nla[NFTA_SET_ELEM_DATA]);
3666 if (err < 0)
3667 goto err2;
3668
3669 err = -EINVAL;
3670 if (set->dtype != NFT_DATA_VERDICT && d2.len != set->dlen)
3671 goto err3;
3672
3673 dreg = nft_type_to_reg(set->dtype);
3674 list_for_each_entry(binding, &set->bindings, list) {
3675 struct nft_ctx bind_ctx = {
3676 .net = ctx->net,
3677 .afi = ctx->afi,
3678 .table = ctx->table,
3679 .chain = (struct nft_chain *)binding->chain,
3680 };
3681
3682 if (!(binding->flags & NFT_SET_MAP))
3683 continue;
3684
3685 err = nft_validate_register_store(&bind_ctx, dreg,
3686 &data,
3687 d2.type, d2.len);
3688 if (err < 0)
3689 goto err3;
3690 }
3691
3692 nft_set_ext_add_length(&tmpl, NFT_SET_EXT_DATA, d2.len);
3693 }
3694
3695
3696
3697
3698
3699 ulen = 0;
3700 if (nla[NFTA_SET_ELEM_USERDATA] != NULL) {
3701 ulen = nla_len(nla[NFTA_SET_ELEM_USERDATA]);
3702 if (ulen > 0)
3703 nft_set_ext_add_length(&tmpl, NFT_SET_EXT_USERDATA,
3704 ulen);
3705 }
3706
3707 err = -ENOMEM;
3708 elem.priv = nft_set_elem_init(set, &tmpl, elem.key.val.data, data.data,
3709 timeout, GFP_KERNEL);
3710 if (elem.priv == NULL)
3711 goto err3;
3712
3713 ext = nft_set_elem_ext(set, elem.priv);
3714 if (flags)
3715 *nft_set_ext_flags(ext) = flags;
3716 if (ulen > 0) {
3717 udata = nft_set_ext_userdata(ext);
3718 udata->len = ulen - 1;
3719 nla_memcpy(&udata->data, nla[NFTA_SET_ELEM_USERDATA], ulen);
3720 }
3721 if (obj) {
3722 *nft_set_ext_obj(ext) = obj;
3723 obj->use++;
3724 }
3725
3726 trans = nft_trans_elem_alloc(ctx, NFT_MSG_NEWSETELEM, set);
3727 if (trans == NULL)
3728 goto err4;
3729
3730 ext->genmask = nft_genmask_cur(ctx->net) | NFT_SET_ELEM_BUSY_MASK;
3731 err = set->ops->insert(ctx->net, set, &elem, &ext2);
3732 if (err) {
3733 if (err == -EEXIST) {
3734 if ((nft_set_ext_exists(ext, NFT_SET_EXT_DATA) &&
3735 nft_set_ext_exists(ext2, NFT_SET_EXT_DATA) &&
3736 memcmp(nft_set_ext_data(ext),
3737 nft_set_ext_data(ext2), set->dlen) != 0) ||
3738 (nft_set_ext_exists(ext, NFT_SET_EXT_OBJREF) &&
3739 nft_set_ext_exists(ext2, NFT_SET_EXT_OBJREF) &&
3740 *nft_set_ext_obj(ext) != *nft_set_ext_obj(ext2)))
3741 err = -EBUSY;
3742 else if (!(nlmsg_flags & NLM_F_EXCL))
3743 err = 0;
3744 }
3745 goto err5;
3746 }
3747
3748 if (set->size &&
3749 !atomic_add_unless(&set->nelems, 1, set->size + set->ndeact)) {
3750 err = -ENFILE;
3751 goto err6;
3752 }
3753
3754 nft_trans_elem(trans) = elem;
3755 list_add_tail(&trans->list, &ctx->net->nft.commit_list);
3756 return 0;
3757
3758err6:
3759 set->ops->remove(set, &elem);
3760err5:
3761 kfree(trans);
3762err4:
3763 kfree(elem.priv);
3764err3:
3765 if (nla[NFTA_SET_ELEM_DATA] != NULL)
3766 nft_data_uninit(&data, d2.type);
3767err2:
3768 nft_data_uninit(&elem.key.val, d1.type);
3769err1:
3770 return err;
3771}
3772
3773static int nf_tables_newsetelem(struct net *net, struct sock *nlsk,
3774 struct sk_buff *skb, const struct nlmsghdr *nlh,
3775 const struct nlattr * const nla[])
3776{
3777 u8 genmask = nft_genmask_next(net);
3778 const struct nlattr *attr;
3779 struct nft_set *set;
3780 struct nft_ctx ctx;
3781 int rem, err = 0;
3782
3783 if (nla[NFTA_SET_ELEM_LIST_ELEMENTS] == NULL)
3784 return -EINVAL;
3785
3786 err = nft_ctx_init_from_elemattr(&ctx, net, skb, nlh, nla, genmask);
3787 if (err < 0)
3788 return err;
3789
3790 set = nf_tables_set_lookup(ctx.table, nla[NFTA_SET_ELEM_LIST_SET],
3791 genmask);
3792 if (IS_ERR(set)) {
3793 if (nla[NFTA_SET_ELEM_LIST_SET_ID]) {
3794 set = nf_tables_set_lookup_byid(net,
3795 nla[NFTA_SET_ELEM_LIST_SET_ID],
3796 genmask);
3797 }
3798 if (IS_ERR(set))
3799 return PTR_ERR(set);
3800 }
3801
3802 if (!list_empty(&set->bindings) && set->flags & NFT_SET_CONSTANT)
3803 return -EBUSY;
3804
3805 nla_for_each_nested(attr, nla[NFTA_SET_ELEM_LIST_ELEMENTS], rem) {
3806 err = nft_add_set_elem(&ctx, set, attr, nlh->nlmsg_flags);
3807 if (err < 0)
3808 break;
3809 }
3810 return err;
3811}
3812
3813static int nft_del_setelem(struct nft_ctx *ctx, struct nft_set *set,
3814 const struct nlattr *attr)
3815{
3816 struct nlattr *nla[NFTA_SET_ELEM_MAX + 1];
3817 struct nft_set_ext_tmpl tmpl;
3818 struct nft_data_desc desc;
3819 struct nft_set_elem elem;
3820 struct nft_set_ext *ext;
3821 struct nft_trans *trans;
3822 u32 flags = 0;
3823 void *priv;
3824 int err;
3825
3826 err = nla_parse_nested(nla, NFTA_SET_ELEM_MAX, attr,
3827 nft_set_elem_policy);
3828 if (err < 0)
3829 goto err1;
3830
3831 err = -EINVAL;
3832 if (nla[NFTA_SET_ELEM_KEY] == NULL)
3833 goto err1;
3834
3835 nft_set_ext_prepare(&tmpl);
3836
3837 err = nft_setelem_parse_flags(set, nla[NFTA_SET_ELEM_FLAGS], &flags);
3838 if (err < 0)
3839 return err;
3840 if (flags != 0)
3841 nft_set_ext_add(&tmpl, NFT_SET_EXT_FLAGS);
3842
3843 err = nft_data_init(ctx, &elem.key.val, sizeof(elem.key), &desc,
3844 nla[NFTA_SET_ELEM_KEY]);
3845 if (err < 0)
3846 goto err1;
3847
3848 err = -EINVAL;
3849 if (desc.type != NFT_DATA_VALUE || desc.len != set->klen)
3850 goto err2;
3851
3852 nft_set_ext_add_length(&tmpl, NFT_SET_EXT_KEY, desc.len);
3853
3854 err = -ENOMEM;
3855 elem.priv = nft_set_elem_init(set, &tmpl, elem.key.val.data, NULL, 0,
3856 GFP_KERNEL);
3857 if (elem.priv == NULL)
3858 goto err2;
3859
3860 ext = nft_set_elem_ext(set, elem.priv);
3861 if (flags)
3862 *nft_set_ext_flags(ext) = flags;
3863
3864 trans = nft_trans_elem_alloc(ctx, NFT_MSG_DELSETELEM, set);
3865 if (trans == NULL) {
3866 err = -ENOMEM;
3867 goto err3;
3868 }
3869
3870 priv = set->ops->deactivate(ctx->net, set, &elem);
3871 if (priv == NULL) {
3872 err = -ENOENT;
3873 goto err4;
3874 }
3875 kfree(elem.priv);
3876 elem.priv = priv;
3877
3878 nft_trans_elem(trans) = elem;
3879 list_add_tail(&trans->list, &ctx->net->nft.commit_list);
3880 return 0;
3881
3882err4:
3883 kfree(trans);
3884err3:
3885 kfree(elem.priv);
3886err2:
3887 nft_data_uninit(&elem.key.val, desc.type);
3888err1:
3889 return err;
3890}
3891
3892static int nft_flush_set(const struct nft_ctx *ctx,
3893 struct nft_set *set,
3894 const struct nft_set_iter *iter,
3895 struct nft_set_elem *elem)
3896{
3897 struct nft_trans *trans;
3898 int err;
3899
3900 trans = nft_trans_alloc_gfp(ctx, NFT_MSG_DELSETELEM,
3901 sizeof(struct nft_trans_elem), GFP_ATOMIC);
3902 if (!trans)
3903 return -ENOMEM;
3904
3905 if (!set->ops->deactivate_one(ctx->net, set, elem->priv)) {
3906 err = -ENOENT;
3907 goto err1;
3908 }
3909 set->ndeact++;
3910
3911 nft_trans_elem_set(trans) = set;
3912 nft_trans_elem(trans) = *elem;
3913 list_add_tail(&trans->list, &ctx->net->nft.commit_list);
3914
3915 return 0;
3916err1:
3917 kfree(trans);
3918 return err;
3919}
3920
3921static int nf_tables_delsetelem(struct net *net, struct sock *nlsk,
3922 struct sk_buff *skb, const struct nlmsghdr *nlh,
3923 const struct nlattr * const nla[])
3924{
3925 u8 genmask = nft_genmask_next(net);
3926 const struct nlattr *attr;
3927 struct nft_set *set;
3928 struct nft_ctx ctx;
3929 int rem, err = 0;
3930
3931 err = nft_ctx_init_from_elemattr(&ctx, net, skb, nlh, nla, genmask);
3932 if (err < 0)
3933 return err;
3934
3935 set = nf_tables_set_lookup(ctx.table, nla[NFTA_SET_ELEM_LIST_SET],
3936 genmask);
3937 if (IS_ERR(set))
3938 return PTR_ERR(set);
3939 if (!list_empty(&set->bindings) && set->flags & NFT_SET_CONSTANT)
3940 return -EBUSY;
3941
3942 if (nla[NFTA_SET_ELEM_LIST_ELEMENTS] == NULL) {
3943 struct nft_set_dump_args args = {
3944 .iter = {
3945 .genmask = genmask,
3946 .fn = nft_flush_set,
3947 },
3948 };
3949 set->ops->walk(&ctx, set, &args.iter);
3950
3951 return args.iter.err;
3952 }
3953
3954 nla_for_each_nested(attr, nla[NFTA_SET_ELEM_LIST_ELEMENTS], rem) {
3955 err = nft_del_setelem(&ctx, set, attr);
3956 if (err < 0)
3957 break;
3958
3959 set->ndeact++;
3960 }
3961 return err;
3962}
3963
3964void nft_set_gc_batch_release(struct rcu_head *rcu)
3965{
3966 struct nft_set_gc_batch *gcb;
3967 unsigned int i;
3968
3969 gcb = container_of(rcu, struct nft_set_gc_batch, head.rcu);
3970 for (i = 0; i < gcb->head.cnt; i++)
3971 nft_set_elem_destroy(gcb->head.set, gcb->elems[i], true);
3972 kfree(gcb);
3973}
3974EXPORT_SYMBOL_GPL(nft_set_gc_batch_release);
3975
3976struct nft_set_gc_batch *nft_set_gc_batch_alloc(const struct nft_set *set,
3977 gfp_t gfp)
3978{
3979 struct nft_set_gc_batch *gcb;
3980
3981 gcb = kzalloc(sizeof(*gcb), gfp);
3982 if (gcb == NULL)
3983 return gcb;
3984 gcb->head.set = set;
3985 return gcb;
3986}
3987EXPORT_SYMBOL_GPL(nft_set_gc_batch_alloc);
3988
3989
3990
3991
3992
3993
3994
3995
3996
3997
3998
3999
4000int nft_register_obj(struct nft_object_type *obj_type)
4001{
4002 if (obj_type->type == NFT_OBJECT_UNSPEC)
4003 return -EINVAL;
4004
4005 nfnl_lock(NFNL_SUBSYS_NFTABLES);
4006 list_add_rcu(&obj_type->list, &nf_tables_objects);
4007 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
4008 return 0;
4009}
4010EXPORT_SYMBOL_GPL(nft_register_obj);
4011
4012
4013
4014
4015
4016
4017
4018void nft_unregister_obj(struct nft_object_type *obj_type)
4019{
4020 nfnl_lock(NFNL_SUBSYS_NFTABLES);
4021 list_del_rcu(&obj_type->list);
4022 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
4023}
4024EXPORT_SYMBOL_GPL(nft_unregister_obj);
4025
4026struct nft_object *nf_tables_obj_lookup(const struct nft_table *table,
4027 const struct nlattr *nla,
4028 u32 objtype, u8 genmask)
4029{
4030 struct nft_object *obj;
4031
4032 list_for_each_entry(obj, &table->objects, list) {
4033 if (!nla_strcmp(nla, obj->name) &&
4034 objtype == obj->type->type &&
4035 nft_active_genmask(obj, genmask))
4036 return obj;
4037 }
4038 return ERR_PTR(-ENOENT);
4039}
4040EXPORT_SYMBOL_GPL(nf_tables_obj_lookup);
4041
4042static const struct nla_policy nft_obj_policy[NFTA_OBJ_MAX + 1] = {
4043 [NFTA_OBJ_TABLE] = { .type = NLA_STRING,
4044 .len = NFT_TABLE_MAXNAMELEN - 1 },
4045 [NFTA_OBJ_NAME] = { .type = NLA_STRING,
4046 .len = NFT_OBJ_MAXNAMELEN - 1 },
4047 [NFTA_OBJ_TYPE] = { .type = NLA_U32 },
4048 [NFTA_OBJ_DATA] = { .type = NLA_NESTED },
4049};
4050
4051static struct nft_object *nft_obj_init(const struct nft_object_type *type,
4052 const struct nlattr *attr)
4053{
4054 struct nlattr *tb[type->maxattr + 1];
4055 struct nft_object *obj;
4056 int err;
4057
4058 if (attr) {
4059 err = nla_parse_nested(tb, type->maxattr, attr, type->policy);
4060 if (err < 0)
4061 goto err1;
4062 } else {
4063 memset(tb, 0, sizeof(tb[0]) * (type->maxattr + 1));
4064 }
4065
4066 err = -ENOMEM;
4067 obj = kzalloc(sizeof(struct nft_object) + type->size, GFP_KERNEL);
4068 if (obj == NULL)
4069 goto err1;
4070
4071 err = type->init((const struct nlattr * const *)tb, obj);
4072 if (err < 0)
4073 goto err2;
4074
4075 obj->type = type;
4076 return obj;
4077err2:
4078 kfree(obj);
4079err1:
4080 return ERR_PTR(err);
4081}
4082
4083static int nft_object_dump(struct sk_buff *skb, unsigned int attr,
4084 struct nft_object *obj, bool reset)
4085{
4086 struct nlattr *nest;
4087
4088 nest = nla_nest_start(skb, attr);
4089 if (!nest)
4090 goto nla_put_failure;
4091 if (obj->type->dump(skb, obj, reset) < 0)
4092 goto nla_put_failure;
4093 nla_nest_end(skb, nest);
4094 return 0;
4095
4096nla_put_failure:
4097 return -1;
4098}
4099
4100static const struct nft_object_type *__nft_obj_type_get(u32 objtype)
4101{
4102 const struct nft_object_type *type;
4103
4104 list_for_each_entry(type, &nf_tables_objects, list) {
4105 if (objtype == type->type)
4106 return type;
4107 }
4108 return NULL;
4109}
4110
4111static const struct nft_object_type *nft_obj_type_get(u32 objtype)
4112{
4113 const struct nft_object_type *type;
4114
4115 type = __nft_obj_type_get(objtype);
4116 if (type != NULL && try_module_get(type->owner))
4117 return type;
4118
4119#ifdef CONFIG_MODULES
4120 if (type == NULL) {
4121 nfnl_unlock(NFNL_SUBSYS_NFTABLES);
4122 request_module("nft-obj-%u", objtype);
4123 nfnl_lock(NFNL_SUBSYS_NFTABLES);
4124 if (__nft_obj_type_get(objtype))
4125 return ERR_PTR(-EAGAIN);
4126 }
4127#endif
4128 return ERR_PTR(-ENOENT);
4129}
4130
4131static int nf_tables_newobj(struct net *net, struct sock *nlsk,
4132 struct sk_buff *skb, const struct nlmsghdr *nlh,
4133 const struct nlattr * const nla[])
4134{
4135 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
4136 const struct nft_object_type *type;
4137 u8 genmask = nft_genmask_next(net);
4138 int family = nfmsg->nfgen_family;
4139 struct nft_af_info *afi;
4140 struct nft_table *table;
4141 struct nft_object *obj;
4142 struct nft_ctx ctx;
4143 u32 objtype;
4144 int err;
4145
4146 if (!nla[NFTA_OBJ_TYPE] ||
4147 !nla[NFTA_OBJ_NAME] ||
4148 !nla[NFTA_OBJ_DATA])
4149 return -EINVAL;
4150
4151 afi = nf_tables_afinfo_lookup(net, family, true);
4152 if (IS_ERR(afi))
4153 return PTR_ERR(afi);
4154
4155 table = nf_tables_table_lookup(afi, nla[NFTA_OBJ_TABLE], genmask);
4156 if (IS_ERR(table))
4157 return PTR_ERR(table);
4158
4159 objtype = ntohl(nla_get_be32(nla[NFTA_OBJ_TYPE]));
4160 obj = nf_tables_obj_lookup(table, nla[NFTA_OBJ_NAME], objtype, genmask);
4161 if (IS_ERR(obj)) {
4162 err = PTR_ERR(obj);
4163 if (err != -ENOENT)
4164 return err;
4165
4166 obj = NULL;
4167 }
4168
4169 if (obj != NULL) {
4170 if (nlh->nlmsg_flags & NLM_F_EXCL)
4171 return -EEXIST;
4172
4173 return 0;
4174 }
4175
4176 nft_ctx_init(&ctx, net, skb, nlh, afi, table, NULL, nla);
4177
4178 type = nft_obj_type_get(objtype);
4179 if (IS_ERR(type))
4180 return PTR_ERR(type);
4181
4182 obj = nft_obj_init(type, nla[NFTA_OBJ_DATA]);
4183 if (IS_ERR(obj)) {
4184 err = PTR_ERR(obj);
4185 goto err1;
4186 }
4187 obj->table = table;
4188 nla_strlcpy(obj->name, nla[NFTA_OBJ_NAME], NFT_OBJ_MAXNAMELEN);
4189
4190 err = nft_trans_obj_add(&ctx, NFT_MSG_NEWOBJ, obj);
4191 if (err < 0)
4192 goto err2;
4193
4194 list_add_tail_rcu(&obj->list, &table->objects);
4195 table->use++;
4196 return 0;
4197err2:
4198 if (obj->type->destroy)
4199 obj->type->destroy(obj);
4200 kfree(obj);
4201err1:
4202 module_put(type->owner);
4203 return err;
4204}
4205
4206static int nf_tables_fill_obj_info(struct sk_buff *skb, struct net *net,
4207 u32 portid, u32 seq, int event, u32 flags,
4208 int family, const struct nft_table *table,
4209 struct nft_object *obj, bool reset)
4210{
4211 struct nfgenmsg *nfmsg;
4212 struct nlmsghdr *nlh;
4213
4214 event |= NFNL_SUBSYS_NFTABLES << 8;
4215 nlh = nlmsg_put(skb, portid, seq, event, sizeof(struct nfgenmsg), flags);
4216 if (nlh == NULL)
4217 goto nla_put_failure;
4218
4219 nfmsg = nlmsg_data(nlh);
4220 nfmsg->nfgen_family = family;
4221 nfmsg->version = NFNETLINK_V0;
4222 nfmsg->res_id = htons(net->nft.base_seq & 0xffff);
4223
4224 if (nla_put_string(skb, NFTA_OBJ_TABLE, table->name) ||
4225 nla_put_string(skb, NFTA_OBJ_NAME, obj->name) ||
4226 nla_put_be32(skb, NFTA_OBJ_TYPE, htonl(obj->type->type)) ||
4227 nla_put_be32(skb, NFTA_OBJ_USE, htonl(obj->use)) ||
4228 nft_object_dump(skb, NFTA_OBJ_DATA, obj, reset))
4229 goto nla_put_failure;
4230
4231 nlmsg_end(skb, nlh);
4232 return 0;
4233
4234nla_put_failure:
4235 nlmsg_trim(skb, nlh);
4236 return -1;
4237}
4238
4239struct nft_obj_filter {
4240 char table[NFT_OBJ_MAXNAMELEN];
4241 u32 type;
4242};
4243
4244static int nf_tables_dump_obj(struct sk_buff *skb, struct netlink_callback *cb)
4245{
4246 const struct nfgenmsg *nfmsg = nlmsg_data(cb->nlh);
4247 const struct nft_af_info *afi;
4248 const struct nft_table *table;
4249 unsigned int idx = 0, s_idx = cb->args[0];
4250 struct nft_obj_filter *filter = cb->data;
4251 struct net *net = sock_net(skb->sk);
4252 int family = nfmsg->nfgen_family;
4253 struct nft_object *obj;
4254 bool reset = false;
4255
4256 if (NFNL_MSG_TYPE(cb->nlh->nlmsg_type) == NFT_MSG_GETOBJ_RESET)
4257 reset = true;
4258
4259 rcu_read_lock();
4260 cb->seq = net->nft.base_seq;
4261
4262 list_for_each_entry_rcu(afi, &net->nft.af_info, list) {
4263 if (family != NFPROTO_UNSPEC && family != afi->family)
4264 continue;
4265
4266 list_for_each_entry_rcu(table, &afi->tables, list) {
4267 list_for_each_entry_rcu(obj, &table->objects, list) {
4268 if (!nft_is_active(net, obj))
4269 goto cont;
4270 if (idx < s_idx)
4271 goto cont;
4272 if (idx > s_idx)
4273 memset(&cb->args[1], 0,
4274 sizeof(cb->args) - sizeof(cb->args[0]));
4275 if (filter && filter->table[0] &&
4276 strcmp(filter->table, table->name))
4277 goto cont;
4278 if (filter &&
4279 filter->type != NFT_OBJECT_UNSPEC &&
4280 obj->type->type != filter->type)
4281 goto cont;
4282
4283 if (nf_tables_fill_obj_info(skb, net, NETLINK_CB(cb->skb).portid,
4284 cb->nlh->nlmsg_seq,
4285 NFT_MSG_NEWOBJ,
4286 NLM_F_MULTI | NLM_F_APPEND,
4287 afi->family, table, obj, reset) < 0)
4288 goto done;
4289
4290 nl_dump_check_consistent(cb, nlmsg_hdr(skb));
4291cont:
4292 idx++;
4293 }
4294 }
4295 }
4296done:
4297 rcu_read_unlock();
4298
4299 cb->args[0] = idx;
4300 return skb->len;
4301}
4302
4303static int nf_tables_dump_obj_done(struct netlink_callback *cb)
4304{
4305 kfree(cb->data);
4306
4307 return 0;
4308}
4309
4310static struct nft_obj_filter *
4311nft_obj_filter_alloc(const struct nlattr * const nla[])
4312{
4313 struct nft_obj_filter *filter;
4314
4315 filter = kzalloc(sizeof(*filter), GFP_KERNEL);
4316 if (!filter)
4317 return ERR_PTR(-ENOMEM);
4318
4319 if (nla[NFTA_OBJ_TABLE])
4320 nla_strlcpy(filter->table, nla[NFTA_OBJ_TABLE],
4321 NFT_TABLE_MAXNAMELEN);
4322 if (nla[NFTA_OBJ_TYPE])
4323 filter->type = ntohl(nla_get_be32(nla[NFTA_OBJ_TYPE]));
4324
4325 return filter;
4326}
4327
4328static int nf_tables_getobj(struct net *net, struct sock *nlsk,
4329 struct sk_buff *skb, const struct nlmsghdr *nlh,
4330 const struct nlattr * const nla[])
4331{
4332 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
4333 u8 genmask = nft_genmask_cur(net);
4334 int family = nfmsg->nfgen_family;
4335 const struct nft_af_info *afi;
4336 const struct nft_table *table;
4337 struct nft_object *obj;
4338 struct sk_buff *skb2;
4339 bool reset = false;
4340 u32 objtype;
4341 int err;
4342
4343 if (nlh->nlmsg_flags & NLM_F_DUMP) {
4344 struct netlink_dump_control c = {
4345 .dump = nf_tables_dump_obj,
4346 .done = nf_tables_dump_obj_done,
4347 };
4348
4349 if (nla[NFTA_OBJ_TABLE] ||
4350 nla[NFTA_OBJ_TYPE]) {
4351 struct nft_obj_filter *filter;
4352
4353 filter = nft_obj_filter_alloc(nla);
4354 if (IS_ERR(filter))
4355 return -ENOMEM;
4356
4357 c.data = filter;
4358 }
4359 return netlink_dump_start(nlsk, skb, nlh, &c);
4360 }
4361
4362 if (!nla[NFTA_OBJ_NAME] ||
4363 !nla[NFTA_OBJ_TYPE])
4364 return -EINVAL;
4365
4366 afi = nf_tables_afinfo_lookup(net, family, false);
4367 if (IS_ERR(afi))
4368 return PTR_ERR(afi);
4369
4370 table = nf_tables_table_lookup(afi, nla[NFTA_OBJ_TABLE], genmask);
4371 if (IS_ERR(table))
4372 return PTR_ERR(table);
4373
4374 objtype = ntohl(nla_get_be32(nla[NFTA_OBJ_TYPE]));
4375 obj = nf_tables_obj_lookup(table, nla[NFTA_OBJ_NAME], objtype, genmask);
4376 if (IS_ERR(obj))
4377 return PTR_ERR(obj);
4378
4379 skb2 = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
4380 if (!skb2)
4381 return -ENOMEM;
4382
4383 if (NFNL_MSG_TYPE(nlh->nlmsg_type) == NFT_MSG_GETOBJ_RESET)
4384 reset = true;
4385
4386 err = nf_tables_fill_obj_info(skb2, net, NETLINK_CB(skb).portid,
4387 nlh->nlmsg_seq, NFT_MSG_NEWOBJ, 0,
4388 family, table, obj, reset);
4389 if (err < 0)
4390 goto err;
4391
4392 return nlmsg_unicast(nlsk, skb2, NETLINK_CB(skb).portid);
4393err:
4394 kfree_skb(skb2);
4395 return err;
4396
4397 return 0;
4398}
4399
4400static void nft_obj_destroy(struct nft_object *obj)
4401{
4402 if (obj->type->destroy)
4403 obj->type->destroy(obj);
4404
4405 module_put(obj->type->owner);
4406 kfree(obj);
4407}
4408
4409static int nf_tables_delobj(struct net *net, struct sock *nlsk,
4410 struct sk_buff *skb, const struct nlmsghdr *nlh,
4411 const struct nlattr * const nla[])
4412{
4413 const struct nfgenmsg *nfmsg = nlmsg_data(nlh);
4414 u8 genmask = nft_genmask_next(net);
4415 int family = nfmsg->nfgen_family;
4416 struct nft_af_info *afi;
4417 struct nft_table *table;
4418 struct nft_object *obj;
4419 struct nft_ctx ctx;
4420 u32 objtype;
4421
4422 if (!nla[NFTA_OBJ_TYPE] ||
4423 !nla[NFTA_OBJ_NAME])
4424 return -EINVAL;
4425
4426 afi = nf_tables_afinfo_lookup(net, family, true);
4427 if (IS_ERR(afi))
4428 return PTR_ERR(afi);
4429
4430 table = nf_tables_table_lookup(afi, nla[NFTA_OBJ_TABLE], genmask);
4431 if (IS_ERR(table))
4432 return PTR_ERR(table);
4433
4434 objtype = ntohl(nla_get_be32(nla[NFTA_OBJ_TYPE]));
4435 obj = nf_tables_obj_lookup(table, nla[NFTA_OBJ_NAME], objtype, genmask);
4436 if (IS_ERR(obj))
4437 return PTR_ERR(obj);
4438 if (obj->use > 0)
4439 return -EBUSY;
4440
4441 nft_ctx_init(&ctx, net, skb, nlh, afi, table, NULL, nla);
4442
4443 return nft_delobj(&ctx, obj);
4444}
4445
4446int nft_obj_notify(struct net *net, struct nft_table *table,
4447 struct nft_object *obj, u32 portid, u32 seq, int event,
4448 int family, int report, gfp_t gfp)
4449{
4450 struct sk_buff *skb;
4451 int err;
4452
4453 if (!report &&
4454 !nfnetlink_has_listeners(net, NFNLGRP_NFTABLES))
4455 return 0;
4456
4457 err = -ENOBUFS;
4458 skb = nlmsg_new(NLMSG_GOODSIZE, gfp);
4459 if (skb == NULL)
4460 goto err;
4461
4462 err = nf_tables_fill_obj_info(skb, net, portid, seq, event, 0, family,
4463 table, obj, false);
4464 if (err < 0) {
4465 kfree_skb(skb);
4466 goto err;
4467 }
4468
4469 err = nfnetlink_send(skb, net, portid, NFNLGRP_NFTABLES, report, gfp);
4470err:
4471 if (err < 0) {
4472 nfnetlink_set_err(net, portid, NFNLGRP_NFTABLES, err);
4473 }
4474 return err;
4475}
4476EXPORT_SYMBOL_GPL(nft_obj_notify);
4477
4478static int nf_tables_obj_notify(const struct nft_ctx *ctx,
4479 struct nft_object *obj, int event)
4480{
4481 return nft_obj_notify(ctx->net, ctx->table, obj, ctx->portid,
4482 ctx->seq, event, ctx->afi->family, ctx->report,
4483 GFP_KERNEL);
4484}
4485
4486static int nf_tables_fill_gen_info(struct sk_buff *skb, struct net *net,
4487 u32 portid, u32 seq)
4488{
4489 struct nlmsghdr *nlh;
4490 struct nfgenmsg *nfmsg;
4491 int event = (NFNL_SUBSYS_NFTABLES << 8) | NFT_MSG_NEWGEN;
4492
4493 nlh = nlmsg_put(skb, portid, seq, event, sizeof(struct nfgenmsg), 0);
4494 if (nlh == NULL)
4495 goto nla_put_failure;
4496
4497 nfmsg = nlmsg_data(nlh);
4498 nfmsg->nfgen_family = AF_UNSPEC;
4499 nfmsg->version = NFNETLINK_V0;
4500 nfmsg->res_id = htons(net->nft.base_seq & 0xffff);
4501
4502 if (nla_put_be32(skb, NFTA_GEN_ID, htonl(net->nft.base_seq)))
4503 goto nla_put_failure;
4504
4505 nlmsg_end(skb, nlh);
4506 return 0;
4507
4508nla_put_failure:
4509 nlmsg_trim(skb, nlh);
4510 return -EMSGSIZE;
4511}
4512
4513static int nf_tables_gen_notify(struct net *net, struct sk_buff *skb, int event)
4514{
4515 struct nlmsghdr *nlh = nlmsg_hdr(skb);
4516 struct sk_buff *skb2;
4517 int err;
4518
4519 if (nlmsg_report(nlh) &&
4520 !nfnetlink_has_listeners(net, NFNLGRP_NFTABLES))
4521 return 0;
4522
4523 err = -ENOBUFS;
4524 skb2 = nlmsg_new(NLMSG_GOODSIZE, GFP_KERNEL);
4525 if (skb2 == NULL)
4526 goto err;
4527
4528 err = nf_tables_fill_gen_info(skb2, net, NETLINK_CB(skb).portid,
4529 nlh->nlmsg_seq);
4530 if (err < 0) {
4531 kfree_skb(skb2);
4532 goto err;
4533 }
4534
4535 err = nfnetlink_send(skb2, net, NETLINK_CB(skb).portid,
4536 NFNLGRP_NFTABLES, nlmsg_report(nlh), GFP_KERNEL);
4537err:
4538 if (err < 0) {
4539 nfnetlink_set_err(net, NETLINK_CB(skb).portid, NFNLGRP_NFTABLES,
4540 err);
4541 }
4542 return err;
4543}
4544
4545static int nf_tables_getgen(struct net *net, struct sock *nlsk,
4546 struct sk_buff *skb, const struct nlmsghdr *nlh,
4547 const struct nlattr * const nla[])
4548{
4549 struct sk_buff *skb2;
4550 int err;
4551
4552 skb2 = alloc_skb(NLMSG_GOODSIZE, GFP_KERNEL);
4553 if (skb2 == NULL)
4554 return -ENOMEM;
4555
4556 err = nf_tables_fill_gen_info(skb2, net, NETLINK_CB(skb).portid,
4557 nlh->nlmsg_seq);
4558 if (err < 0)
4559 goto err;
4560
4561 return nlmsg_unicast(nlsk, skb2, NETLINK_CB(skb).portid);
4562err:
4563 kfree_skb(skb2);
4564 return err;
4565}
4566
4567static const struct nfnl_callback nf_tables_cb[NFT_MSG_MAX] = {
4568 [NFT_MSG_NEWTABLE] = {
4569 .call_batch = nf_tables_newtable,
4570 .attr_count = NFTA_TABLE_MAX,
4571 .policy = nft_table_policy,
4572 },
4573 [NFT_MSG_GETTABLE] = {
4574 .call = nf_tables_gettable,
4575 .attr_count = NFTA_TABLE_MAX,
4576 .policy = nft_table_policy,
4577 },
4578 [NFT_MSG_DELTABLE] = {
4579 .call_batch = nf_tables_deltable,
4580 .attr_count = NFTA_TABLE_MAX,
4581 .policy = nft_table_policy,
4582 },
4583 [NFT_MSG_NEWCHAIN] = {
4584 .call_batch = nf_tables_newchain,
4585 .attr_count = NFTA_CHAIN_MAX,
4586 .policy = nft_chain_policy,
4587 },
4588 [NFT_MSG_GETCHAIN] = {
4589 .call = nf_tables_getchain,
4590 .attr_count = NFTA_CHAIN_MAX,
4591 .policy = nft_chain_policy,
4592 },
4593 [NFT_MSG_DELCHAIN] = {
4594 .call_batch = nf_tables_delchain,
4595 .attr_count = NFTA_CHAIN_MAX,
4596 .policy = nft_chain_policy,
4597 },
4598 [NFT_MSG_NEWRULE] = {
4599 .call_batch = nf_tables_newrule,
4600 .attr_count = NFTA_RULE_MAX,
4601 .policy = nft_rule_policy,
4602 },
4603 [NFT_MSG_GETRULE] = {
4604 .call = nf_tables_getrule,
4605 .attr_count = NFTA_RULE_MAX,
4606 .policy = nft_rule_policy,
4607 },
4608 [NFT_MSG_DELRULE] = {
4609 .call_batch = nf_tables_delrule,
4610 .attr_count = NFTA_RULE_MAX,
4611 .policy = nft_rule_policy,
4612 },
4613 [NFT_MSG_NEWSET] = {
4614 .call_batch = nf_tables_newset,
4615 .attr_count = NFTA_SET_MAX,
4616 .policy = nft_set_policy,
4617 },
4618 [NFT_MSG_GETSET] = {
4619 .call = nf_tables_getset,
4620 .attr_count = NFTA_SET_MAX,
4621 .policy = nft_set_policy,
4622 },
4623 [NFT_MSG_DELSET] = {
4624 .call_batch = nf_tables_delset,
4625 .attr_count = NFTA_SET_MAX,
4626 .policy = nft_set_policy,
4627 },
4628 [NFT_MSG_NEWSETELEM] = {
4629 .call_batch = nf_tables_newsetelem,
4630 .attr_count = NFTA_SET_ELEM_LIST_MAX,
4631 .policy = nft_set_elem_list_policy,
4632 },
4633 [NFT_MSG_GETSETELEM] = {
4634 .call = nf_tables_getsetelem,
4635 .attr_count = NFTA_SET_ELEM_LIST_MAX,
4636 .policy = nft_set_elem_list_policy,
4637 },
4638 [NFT_MSG_DELSETELEM] = {
4639 .call_batch = nf_tables_delsetelem,
4640 .attr_count = NFTA_SET_ELEM_LIST_MAX,
4641 .policy = nft_set_elem_list_policy,
4642 },
4643 [NFT_MSG_GETGEN] = {
4644 .call = nf_tables_getgen,
4645 },
4646 [NFT_MSG_NEWOBJ] = {
4647 .call_batch = nf_tables_newobj,
4648 .attr_count = NFTA_OBJ_MAX,
4649 .policy = nft_obj_policy,
4650 },
4651 [NFT_MSG_GETOBJ] = {
4652 .call = nf_tables_getobj,
4653 .attr_count = NFTA_OBJ_MAX,
4654 .policy = nft_obj_policy,
4655 },
4656 [NFT_MSG_DELOBJ] = {
4657 .call_batch = nf_tables_delobj,
4658 .attr_count = NFTA_OBJ_MAX,
4659 .policy = nft_obj_policy,
4660 },
4661 [NFT_MSG_GETOBJ_RESET] = {
4662 .call = nf_tables_getobj,
4663 .attr_count = NFTA_OBJ_MAX,
4664 .policy = nft_obj_policy,
4665 },
4666};
4667
4668static void nft_chain_commit_update(struct nft_trans *trans)
4669{
4670 struct nft_base_chain *basechain;
4671
4672 if (nft_trans_chain_name(trans)[0])
4673 strcpy(trans->ctx.chain->name, nft_trans_chain_name(trans));
4674
4675 if (!(trans->ctx.chain->flags & NFT_BASE_CHAIN))
4676 return;
4677
4678 basechain = nft_base_chain(trans->ctx.chain);
4679 nft_chain_stats_replace(basechain, nft_trans_chain_stats(trans));
4680
4681 switch (nft_trans_chain_policy(trans)) {
4682 case NF_DROP:
4683 case NF_ACCEPT:
4684 basechain->policy = nft_trans_chain_policy(trans);
4685 break;
4686 }
4687}
4688
4689static void nf_tables_commit_release(struct nft_trans *trans)
4690{
4691 switch (trans->msg_type) {
4692 case NFT_MSG_DELTABLE:
4693 nf_tables_table_destroy(&trans->ctx);
4694 break;
4695 case NFT_MSG_DELCHAIN:
4696 nf_tables_chain_destroy(trans->ctx.chain);
4697 break;
4698 case NFT_MSG_DELRULE:
4699 nf_tables_rule_destroy(&trans->ctx, nft_trans_rule(trans));
4700 break;
4701 case NFT_MSG_DELSET:
4702 nft_set_destroy(nft_trans_set(trans));
4703 break;
4704 case NFT_MSG_DELSETELEM:
4705 nft_set_elem_destroy(nft_trans_elem_set(trans),
4706 nft_trans_elem(trans).priv, true);
4707 break;
4708 case NFT_MSG_DELOBJ:
4709 nft_obj_destroy(nft_trans_obj(trans));
4710 break;
4711 }
4712 kfree(trans);
4713}
4714
4715static int nf_tables_commit(struct net *net, struct sk_buff *skb)
4716{
4717 struct nft_trans *trans, *next;
4718 struct nft_trans_elem *te;
4719
4720
4721 while (++net->nft.base_seq == 0);
4722
4723
4724 net->nft.gencursor = nft_gencursor_next(net);
4725
4726
4727
4728
4729 synchronize_rcu();
4730
4731 list_for_each_entry_safe(trans, next, &net->nft.commit_list, list) {
4732 switch (trans->msg_type) {
4733 case NFT_MSG_NEWTABLE:
4734 if (nft_trans_table_update(trans)) {
4735 if (!nft_trans_table_enable(trans)) {
4736 nf_tables_table_disable(net,
4737 trans->ctx.afi,
4738 trans->ctx.table);
4739 trans->ctx.table->flags |= NFT_TABLE_F_DORMANT;
4740 }
4741 } else {
4742 nft_clear(net, trans->ctx.table);
4743 }
4744 nf_tables_table_notify(&trans->ctx, NFT_MSG_NEWTABLE);
4745 nft_trans_destroy(trans);
4746 break;
4747 case NFT_MSG_DELTABLE:
4748 list_del_rcu(&trans->ctx.table->list);
4749 nf_tables_table_notify(&trans->ctx, NFT_MSG_DELTABLE);
4750 break;
4751 case NFT_MSG_NEWCHAIN:
4752 if (nft_trans_chain_update(trans))
4753 nft_chain_commit_update(trans);
4754 else
4755 nft_clear(net, trans->ctx.chain);
4756
4757 nf_tables_chain_notify(&trans->ctx, NFT_MSG_NEWCHAIN);
4758 nft_trans_destroy(trans);
4759 break;
4760 case NFT_MSG_DELCHAIN:
4761 list_del_rcu(&trans->ctx.chain->list);
4762 nf_tables_chain_notify(&trans->ctx, NFT_MSG_DELCHAIN);
4763 nf_tables_unregister_hooks(trans->ctx.net,
4764 trans->ctx.table,
4765 trans->ctx.chain,
4766 trans->ctx.afi->nops);
4767 break;
4768 case NFT_MSG_NEWRULE:
4769 nft_clear(trans->ctx.net, nft_trans_rule(trans));
4770 nf_tables_rule_notify(&trans->ctx,
4771 nft_trans_rule(trans),
4772 NFT_MSG_NEWRULE);
4773 nft_trans_destroy(trans);
4774 break;
4775 case NFT_MSG_DELRULE:
4776 list_del_rcu(&nft_trans_rule(trans)->list);
4777 nf_tables_rule_notify(&trans->ctx,
4778 nft_trans_rule(trans),
4779 NFT_MSG_DELRULE);
4780 break;
4781 case NFT_MSG_NEWSET:
4782 nft_clear(net, nft_trans_set(trans));
4783
4784
4785
4786 if (nft_trans_set(trans)->flags & NFT_SET_ANONYMOUS &&
4787 !list_empty(&nft_trans_set(trans)->bindings))
4788 trans->ctx.table->use--;
4789
4790 nf_tables_set_notify(&trans->ctx, nft_trans_set(trans),
4791 NFT_MSG_NEWSET, GFP_KERNEL);
4792 nft_trans_destroy(trans);
4793 break;
4794 case NFT_MSG_DELSET:
4795 list_del_rcu(&nft_trans_set(trans)->list);
4796 nf_tables_set_notify(&trans->ctx, nft_trans_set(trans),
4797 NFT_MSG_DELSET, GFP_KERNEL);
4798 break;
4799 case NFT_MSG_NEWSETELEM:
4800 te = (struct nft_trans_elem *)trans->data;
4801
4802 te->set->ops->activate(net, te->set, &te->elem);
4803 nf_tables_setelem_notify(&trans->ctx, te->set,
4804 &te->elem,
4805 NFT_MSG_NEWSETELEM, 0);
4806 nft_trans_destroy(trans);
4807 break;
4808 case NFT_MSG_DELSETELEM:
4809 te = (struct nft_trans_elem *)trans->data;
4810
4811 nf_tables_setelem_notify(&trans->ctx, te->set,
4812 &te->elem,
4813 NFT_MSG_DELSETELEM, 0);
4814 te->set->ops->remove(te->set, &te->elem);
4815 atomic_dec(&te->set->nelems);
4816 te->set->ndeact--;
4817 break;
4818 case NFT_MSG_NEWOBJ:
4819 nft_clear(net, nft_trans_obj(trans));
4820 nf_tables_obj_notify(&trans->ctx, nft_trans_obj(trans),
4821 NFT_MSG_NEWOBJ);
4822 nft_trans_destroy(trans);
4823 break;
4824 case NFT_MSG_DELOBJ:
4825 list_del_rcu(&nft_trans_obj(trans)->list);
4826 nf_tables_obj_notify(&trans->ctx, nft_trans_obj(trans),
4827 NFT_MSG_DELOBJ);
4828 break;
4829 }
4830 }
4831
4832 synchronize_rcu();
4833
4834 list_for_each_entry_safe(trans, next, &net->nft.commit_list, list) {
4835 list_del(&trans->list);
4836 nf_tables_commit_release(trans);
4837 }
4838
4839 nf_tables_gen_notify(net, skb, NFT_MSG_NEWGEN);
4840
4841 return 0;
4842}
4843
4844static void nf_tables_abort_release(struct nft_trans *trans)
4845{
4846 switch (trans->msg_type) {
4847 case NFT_MSG_NEWTABLE:
4848 nf_tables_table_destroy(&trans->ctx);
4849 break;
4850 case NFT_MSG_NEWCHAIN:
4851 nf_tables_chain_destroy(trans->ctx.chain);
4852 break;
4853 case NFT_MSG_NEWRULE:
4854 nf_tables_rule_destroy(&trans->ctx, nft_trans_rule(trans));
4855 break;
4856 case NFT_MSG_NEWSET:
4857 nft_set_destroy(nft_trans_set(trans));
4858 break;
4859 case NFT_MSG_NEWSETELEM:
4860 nft_set_elem_destroy(nft_trans_elem_set(trans),
4861 nft_trans_elem(trans).priv, true);
4862 break;
4863 case NFT_MSG_NEWOBJ:
4864 nft_obj_destroy(nft_trans_obj(trans));
4865 break;
4866 }
4867 kfree(trans);
4868}
4869
4870static int nf_tables_abort(struct net *net, struct sk_buff *skb)
4871{
4872 struct nft_trans *trans, *next;
4873 struct nft_trans_elem *te;
4874
4875 list_for_each_entry_safe_reverse(trans, next, &net->nft.commit_list,
4876 list) {
4877 switch (trans->msg_type) {
4878 case NFT_MSG_NEWTABLE:
4879 if (nft_trans_table_update(trans)) {
4880 if (nft_trans_table_enable(trans)) {
4881 nf_tables_table_disable(net,
4882 trans->ctx.afi,
4883 trans->ctx.table);
4884 trans->ctx.table->flags |= NFT_TABLE_F_DORMANT;
4885 }
4886 nft_trans_destroy(trans);
4887 } else {
4888 list_del_rcu(&trans->ctx.table->list);
4889 }
4890 break;
4891 case NFT_MSG_DELTABLE:
4892 nft_clear(trans->ctx.net, trans->ctx.table);
4893 nft_trans_destroy(trans);
4894 break;
4895 case NFT_MSG_NEWCHAIN:
4896 if (nft_trans_chain_update(trans)) {
4897 free_percpu(nft_trans_chain_stats(trans));
4898
4899 nft_trans_destroy(trans);
4900 } else {
4901 trans->ctx.table->use--;
4902 list_del_rcu(&trans->ctx.chain->list);
4903 nf_tables_unregister_hooks(trans->ctx.net,
4904 trans->ctx.table,
4905 trans->ctx.chain,
4906 trans->ctx.afi->nops);
4907 }
4908 break;
4909 case NFT_MSG_DELCHAIN:
4910 trans->ctx.table->use++;
4911 nft_clear(trans->ctx.net, trans->ctx.chain);
4912 nft_trans_destroy(trans);
4913 break;
4914 case NFT_MSG_NEWRULE:
4915 trans->ctx.chain->use--;
4916 list_del_rcu(&nft_trans_rule(trans)->list);
4917 break;
4918 case NFT_MSG_DELRULE:
4919 trans->ctx.chain->use++;
4920 nft_clear(trans->ctx.net, nft_trans_rule(trans));
4921 nft_trans_destroy(trans);
4922 break;
4923 case NFT_MSG_NEWSET:
4924 trans->ctx.table->use--;
4925 list_del_rcu(&nft_trans_set(trans)->list);
4926 break;
4927 case NFT_MSG_DELSET:
4928 trans->ctx.table->use++;
4929 nft_clear(trans->ctx.net, nft_trans_set(trans));
4930 nft_trans_destroy(trans);
4931 break;
4932 case NFT_MSG_NEWSETELEM:
4933 te = (struct nft_trans_elem *)trans->data;
4934
4935 te->set->ops->remove(te->set, &te->elem);
4936 atomic_dec(&te->set->nelems);
4937 break;
4938 case NFT_MSG_DELSETELEM:
4939 te = (struct nft_trans_elem *)trans->data;
4940
4941 te->set->ops->activate(net, te->set, &te->elem);
4942 te->set->ndeact--;
4943
4944 nft_trans_destroy(trans);
4945 break;
4946 case NFT_MSG_NEWOBJ:
4947 trans->ctx.table->use--;
4948 list_del_rcu(&nft_trans_obj(trans)->list);
4949 break;
4950 case NFT_MSG_DELOBJ:
4951 trans->ctx.table->use++;
4952 nft_clear(trans->ctx.net, nft_trans_obj(trans));
4953 nft_trans_destroy(trans);
4954 break;
4955 }
4956 }
4957
4958 synchronize_rcu();
4959
4960 list_for_each_entry_safe_reverse(trans, next,
4961 &net->nft.commit_list, list) {
4962 list_del(&trans->list);
4963 nf_tables_abort_release(trans);
4964 }
4965
4966 return 0;
4967}
4968
4969static const struct nfnetlink_subsystem nf_tables_subsys = {
4970 .name = "nf_tables",
4971 .subsys_id = NFNL_SUBSYS_NFTABLES,
4972 .cb_count = NFT_MSG_MAX,
4973 .cb = nf_tables_cb,
4974 .commit = nf_tables_commit,
4975 .abort = nf_tables_abort,
4976};
4977
4978int nft_chain_validate_dependency(const struct nft_chain *chain,
4979 enum nft_chain_type type)
4980{
4981 const struct nft_base_chain *basechain;
4982
4983 if (chain->flags & NFT_BASE_CHAIN) {
4984 basechain = nft_base_chain(chain);
4985 if (basechain->type->type != type)
4986 return -EOPNOTSUPP;
4987 }
4988 return 0;
4989}
4990EXPORT_SYMBOL_GPL(nft_chain_validate_dependency);
4991
4992int nft_chain_validate_hooks(const struct nft_chain *chain,
4993 unsigned int hook_flags)
4994{
4995 struct nft_base_chain *basechain;
4996
4997 if (chain->flags & NFT_BASE_CHAIN) {
4998 basechain = nft_base_chain(chain);
4999
5000 if ((1 << basechain->ops[0].hooknum) & hook_flags)
5001 return 0;
5002
5003 return -EOPNOTSUPP;
5004 }
5005
5006 return 0;
5007}
5008EXPORT_SYMBOL_GPL(nft_chain_validate_hooks);
5009
5010
5011
5012
5013
5014
5015
5016
5017
5018
5019static int nf_tables_check_loops(const struct nft_ctx *ctx,
5020 const struct nft_chain *chain);
5021
5022static int nf_tables_loop_check_setelem(const struct nft_ctx *ctx,
5023 struct nft_set *set,
5024 const struct nft_set_iter *iter,
5025 struct nft_set_elem *elem)
5026{
5027 const struct nft_set_ext *ext = nft_set_elem_ext(set, elem->priv);
5028 const struct nft_data *data;
5029
5030 if (nft_set_ext_exists(ext, NFT_SET_EXT_FLAGS) &&
5031 *nft_set_ext_flags(ext) & NFT_SET_ELEM_INTERVAL_END)
5032 return 0;
5033
5034 data = nft_set_ext_data(ext);
5035 switch (data->verdict.code) {
5036 case NFT_JUMP:
5037 case NFT_GOTO:
5038 return nf_tables_check_loops(ctx, data->verdict.chain);
5039 default:
5040 return 0;
5041 }
5042}
5043
5044static int nf_tables_check_loops(const struct nft_ctx *ctx,
5045 const struct nft_chain *chain)
5046{
5047 const struct nft_rule *rule;
5048 const struct nft_expr *expr, *last;
5049 struct nft_set *set;
5050 struct nft_set_binding *binding;
5051 struct nft_set_iter iter;
5052
5053 if (ctx->chain == chain)
5054 return -ELOOP;
5055
5056 list_for_each_entry(rule, &chain->rules, list) {
5057 nft_rule_for_each_expr(expr, last, rule) {
5058 const struct nft_data *data = NULL;
5059 int err;
5060
5061 if (!expr->ops->validate)
5062 continue;
5063
5064 err = expr->ops->validate(ctx, expr, &data);
5065 if (err < 0)
5066 return err;
5067
5068 if (data == NULL)
5069 continue;
5070
5071 switch (data->verdict.code) {
5072 case NFT_JUMP:
5073 case NFT_GOTO:
5074 err = nf_tables_check_loops(ctx,
5075 data->verdict.chain);
5076 if (err < 0)
5077 return err;
5078 default:
5079 break;
5080 }
5081 }
5082 }
5083
5084 list_for_each_entry(set, &ctx->table->sets, list) {
5085 if (!nft_is_active_next(ctx->net, set))
5086 continue;
5087 if (!(set->flags & NFT_SET_MAP) ||
5088 set->dtype != NFT_DATA_VERDICT)
5089 continue;
5090
5091 list_for_each_entry(binding, &set->bindings, list) {
5092 if (!(binding->flags & NFT_SET_MAP) ||
5093 binding->chain != chain)
5094 continue;
5095
5096 iter.genmask = nft_genmask_next(ctx->net);
5097 iter.skip = 0;
5098 iter.count = 0;
5099 iter.err = 0;
5100 iter.fn = nf_tables_loop_check_setelem;
5101
5102 set->ops->walk(ctx, set, &iter);
5103 if (iter.err < 0)
5104 return iter.err;
5105 }
5106 }
5107
5108 return 0;
5109}
5110
5111
5112
5113
5114
5115
5116
5117
5118
5119
5120
5121
5122
5123int nft_parse_u32_check(const struct nlattr *attr, int max, u32 *dest)
5124{
5125 u32 val;
5126
5127 val = ntohl(nla_get_be32(attr));
5128 if (val > max)
5129 return -ERANGE;
5130
5131 *dest = val;
5132 return 0;
5133}
5134EXPORT_SYMBOL_GPL(nft_parse_u32_check);
5135
5136
5137
5138
5139
5140
5141
5142
5143
5144
5145unsigned int nft_parse_register(const struct nlattr *attr)
5146{
5147 unsigned int reg;
5148
5149 reg = ntohl(nla_get_be32(attr));
5150 switch (reg) {
5151 case NFT_REG_VERDICT...NFT_REG_4:
5152 return reg * NFT_REG_SIZE / NFT_REG32_SIZE;
5153 default:
5154 return reg + NFT_REG_SIZE / NFT_REG32_SIZE - NFT_REG32_00;
5155 }
5156}
5157EXPORT_SYMBOL_GPL(nft_parse_register);
5158
5159
5160
5161
5162
5163
5164
5165
5166
5167
5168
5169
5170int nft_dump_register(struct sk_buff *skb, unsigned int attr, unsigned int reg)
5171{
5172 if (reg % (NFT_REG_SIZE / NFT_REG32_SIZE) == 0)
5173 reg = reg / (NFT_REG_SIZE / NFT_REG32_SIZE);
5174 else
5175 reg = reg - NFT_REG_SIZE / NFT_REG32_SIZE + NFT_REG32_00;
5176
5177 return nla_put_be32(skb, attr, htonl(reg));
5178}
5179EXPORT_SYMBOL_GPL(nft_dump_register);
5180
5181
5182
5183
5184
5185
5186
5187
5188
5189
5190int nft_validate_register_load(enum nft_registers reg, unsigned int len)
5191{
5192 if (reg < NFT_REG_1 * NFT_REG_SIZE / NFT_REG32_SIZE)
5193 return -EINVAL;
5194 if (len == 0)
5195 return -EINVAL;
5196 if (reg * NFT_REG32_SIZE + len > FIELD_SIZEOF(struct nft_regs, data))
5197 return -ERANGE;
5198
5199 return 0;
5200}
5201EXPORT_SYMBOL_GPL(nft_validate_register_load);
5202
5203
5204
5205
5206
5207
5208
5209
5210
5211
5212
5213
5214
5215
5216
5217int nft_validate_register_store(const struct nft_ctx *ctx,
5218 enum nft_registers reg,
5219 const struct nft_data *data,
5220 enum nft_data_types type, unsigned int len)
5221{
5222 int err;
5223
5224 switch (reg) {
5225 case NFT_REG_VERDICT:
5226 if (type != NFT_DATA_VERDICT)
5227 return -EINVAL;
5228
5229 if (data != NULL &&
5230 (data->verdict.code == NFT_GOTO ||
5231 data->verdict.code == NFT_JUMP)) {
5232 err = nf_tables_check_loops(ctx, data->verdict.chain);
5233 if (err < 0)
5234 return err;
5235
5236 if (ctx->chain->level + 1 >
5237 data->verdict.chain->level) {
5238 if (ctx->chain->level + 1 == NFT_JUMP_STACK_SIZE)
5239 return -EMLINK;
5240 data->verdict.chain->level = ctx->chain->level + 1;
5241 }
5242 }
5243
5244 return 0;
5245 default:
5246 if (reg < NFT_REG_1 * NFT_REG_SIZE / NFT_REG32_SIZE)
5247 return -EINVAL;
5248 if (len == 0)
5249 return -EINVAL;
5250 if (reg * NFT_REG32_SIZE + len >
5251 FIELD_SIZEOF(struct nft_regs, data))
5252 return -ERANGE;
5253
5254 if (data != NULL && type != NFT_DATA_VALUE)
5255 return -EINVAL;
5256 return 0;
5257 }
5258}
5259EXPORT_SYMBOL_GPL(nft_validate_register_store);
5260
5261static const struct nla_policy nft_verdict_policy[NFTA_VERDICT_MAX + 1] = {
5262 [NFTA_VERDICT_CODE] = { .type = NLA_U32 },
5263 [NFTA_VERDICT_CHAIN] = { .type = NLA_STRING,
5264 .len = NFT_CHAIN_MAXNAMELEN - 1 },
5265};
5266
5267static int nft_verdict_init(const struct nft_ctx *ctx, struct nft_data *data,
5268 struct nft_data_desc *desc, const struct nlattr *nla)
5269{
5270 u8 genmask = nft_genmask_next(ctx->net);
5271 struct nlattr *tb[NFTA_VERDICT_MAX + 1];
5272 struct nft_chain *chain;
5273 int err;
5274
5275 err = nla_parse_nested(tb, NFTA_VERDICT_MAX, nla, nft_verdict_policy);
5276 if (err < 0)
5277 return err;
5278
5279 if (!tb[NFTA_VERDICT_CODE])
5280 return -EINVAL;
5281 data->verdict.code = ntohl(nla_get_be32(tb[NFTA_VERDICT_CODE]));
5282
5283 switch (data->verdict.code) {
5284 default:
5285 switch (data->verdict.code & NF_VERDICT_MASK) {
5286 case NF_ACCEPT:
5287 case NF_DROP:
5288 case NF_QUEUE:
5289 break;
5290 default:
5291 return -EINVAL;
5292 }
5293
5294 case NFT_CONTINUE:
5295 case NFT_BREAK:
5296 case NFT_RETURN:
5297 break;
5298 case NFT_JUMP:
5299 case NFT_GOTO:
5300 if (!tb[NFTA_VERDICT_CHAIN])
5301 return -EINVAL;
5302 chain = nf_tables_chain_lookup(ctx->table,
5303 tb[NFTA_VERDICT_CHAIN], genmask);
5304 if (IS_ERR(chain))
5305 return PTR_ERR(chain);
5306 if (chain->flags & NFT_BASE_CHAIN)
5307 return -EOPNOTSUPP;
5308
5309 chain->use++;
5310 data->verdict.chain = chain;
5311 break;
5312 }
5313
5314 desc->len = sizeof(data->verdict);
5315 desc->type = NFT_DATA_VERDICT;
5316 return 0;
5317}
5318
5319static void nft_verdict_uninit(const struct nft_data *data)
5320{
5321 switch (data->verdict.code) {
5322 case NFT_JUMP:
5323 case NFT_GOTO:
5324 data->verdict.chain->use--;
5325 break;
5326 }
5327}
5328
5329int nft_verdict_dump(struct sk_buff *skb, int type, const struct nft_verdict *v)
5330{
5331 struct nlattr *nest;
5332
5333 nest = nla_nest_start(skb, type);
5334 if (!nest)
5335 goto nla_put_failure;
5336
5337 if (nla_put_be32(skb, NFTA_VERDICT_CODE, htonl(v->code)))
5338 goto nla_put_failure;
5339
5340 switch (v->code) {
5341 case NFT_JUMP:
5342 case NFT_GOTO:
5343 if (nla_put_string(skb, NFTA_VERDICT_CHAIN,
5344 v->chain->name))
5345 goto nla_put_failure;
5346 }
5347 nla_nest_end(skb, nest);
5348 return 0;
5349
5350nla_put_failure:
5351 return -1;
5352}
5353
5354static int nft_value_init(const struct nft_ctx *ctx,
5355 struct nft_data *data, unsigned int size,
5356 struct nft_data_desc *desc, const struct nlattr *nla)
5357{
5358 unsigned int len;
5359
5360 len = nla_len(nla);
5361 if (len == 0)
5362 return -EINVAL;
5363 if (len > size)
5364 return -EOVERFLOW;
5365
5366 nla_memcpy(data->data, nla, len);
5367 desc->type = NFT_DATA_VALUE;
5368 desc->len = len;
5369 return 0;
5370}
5371
5372static int nft_value_dump(struct sk_buff *skb, const struct nft_data *data,
5373 unsigned int len)
5374{
5375 return nla_put(skb, NFTA_DATA_VALUE, len, data->data);
5376}
5377
5378static const struct nla_policy nft_data_policy[NFTA_DATA_MAX + 1] = {
5379 [NFTA_DATA_VALUE] = { .type = NLA_BINARY },
5380 [NFTA_DATA_VERDICT] = { .type = NLA_NESTED },
5381};
5382
5383
5384
5385
5386
5387
5388
5389
5390
5391
5392
5393
5394
5395
5396
5397
5398int nft_data_init(const struct nft_ctx *ctx,
5399 struct nft_data *data, unsigned int size,
5400 struct nft_data_desc *desc, const struct nlattr *nla)
5401{
5402 struct nlattr *tb[NFTA_DATA_MAX + 1];
5403 int err;
5404
5405 err = nla_parse_nested(tb, NFTA_DATA_MAX, nla, nft_data_policy);
5406 if (err < 0)
5407 return err;
5408
5409 if (tb[NFTA_DATA_VALUE])
5410 return nft_value_init(ctx, data, size, desc,
5411 tb[NFTA_DATA_VALUE]);
5412 if (tb[NFTA_DATA_VERDICT] && ctx != NULL)
5413 return nft_verdict_init(ctx, data, desc, tb[NFTA_DATA_VERDICT]);
5414 return -EINVAL;
5415}
5416EXPORT_SYMBOL_GPL(nft_data_init);
5417
5418
5419
5420
5421
5422
5423
5424
5425
5426
5427void nft_data_uninit(const struct nft_data *data, enum nft_data_types type)
5428{
5429 if (type < NFT_DATA_VERDICT)
5430 return;
5431 switch (type) {
5432 case NFT_DATA_VERDICT:
5433 return nft_verdict_uninit(data);
5434 default:
5435 WARN_ON(1);
5436 }
5437}
5438EXPORT_SYMBOL_GPL(nft_data_uninit);
5439
5440int nft_data_dump(struct sk_buff *skb, int attr, const struct nft_data *data,
5441 enum nft_data_types type, unsigned int len)
5442{
5443 struct nlattr *nest;
5444 int err;
5445
5446 nest = nla_nest_start(skb, attr);
5447 if (nest == NULL)
5448 return -1;
5449
5450 switch (type) {
5451 case NFT_DATA_VALUE:
5452 err = nft_value_dump(skb, data, len);
5453 break;
5454 case NFT_DATA_VERDICT:
5455 err = nft_verdict_dump(skb, NFTA_DATA_VERDICT, &data->verdict);
5456 break;
5457 default:
5458 err = -EINVAL;
5459 WARN_ON(1);
5460 }
5461
5462 nla_nest_end(skb, nest);
5463 return err;
5464}
5465EXPORT_SYMBOL_GPL(nft_data_dump);
5466
5467static int __net_init nf_tables_init_net(struct net *net)
5468{
5469 INIT_LIST_HEAD(&net->nft.af_info);
5470 INIT_LIST_HEAD(&net->nft.commit_list);
5471 net->nft.base_seq = 1;
5472 return 0;
5473}
5474
5475int __nft_release_basechain(struct nft_ctx *ctx)
5476{
5477 struct nft_rule *rule, *nr;
5478
5479 BUG_ON(!(ctx->chain->flags & NFT_BASE_CHAIN));
5480
5481 nf_tables_unregister_hooks(ctx->net, ctx->chain->table, ctx->chain,
5482 ctx->afi->nops);
5483 list_for_each_entry_safe(rule, nr, &ctx->chain->rules, list) {
5484 list_del(&rule->list);
5485 ctx->chain->use--;
5486 nf_tables_rule_destroy(ctx, rule);
5487 }
5488 list_del(&ctx->chain->list);
5489 ctx->table->use--;
5490 nf_tables_chain_destroy(ctx->chain);
5491
5492 return 0;
5493}
5494EXPORT_SYMBOL_GPL(__nft_release_basechain);
5495
5496
5497static void __nft_release_afinfo(struct net *net, struct nft_af_info *afi)
5498{
5499 struct nft_table *table, *nt;
5500 struct nft_chain *chain, *nc;
5501 struct nft_object *obj, *ne;
5502 struct nft_rule *rule, *nr;
5503 struct nft_set *set, *ns;
5504 struct nft_ctx ctx = {
5505 .net = net,
5506 .afi = afi,
5507 };
5508
5509 list_for_each_entry_safe(table, nt, &afi->tables, list) {
5510 list_for_each_entry(chain, &table->chains, list)
5511 nf_tables_unregister_hooks(net, table, chain,
5512 afi->nops);
5513
5514 ctx.table = table;
5515 list_for_each_entry(chain, &table->chains, list) {
5516 ctx.chain = chain;
5517 list_for_each_entry_safe(rule, nr, &chain->rules, list) {
5518 list_del(&rule->list);
5519 chain->use--;
5520 nf_tables_rule_destroy(&ctx, rule);
5521 }
5522 }
5523 list_for_each_entry_safe(set, ns, &table->sets, list) {
5524 list_del(&set->list);
5525 table->use--;
5526 nft_set_destroy(set);
5527 }
5528 list_for_each_entry_safe(obj, ne, &table->objects, list) {
5529 list_del(&obj->list);
5530 table->use--;
5531 nft_obj_destroy(obj);
5532 }
5533 list_for_each_entry_safe(chain, nc, &table->chains, list) {
5534 list_del(&chain->list);
5535 table->use--;
5536 nf_tables_chain_destroy(chain);
5537 }
5538 list_del(&table->list);
5539 nf_tables_table_destroy(&ctx);
5540 }
5541}
5542
5543static struct pernet_operations nf_tables_net_ops = {
5544 .init = nf_tables_init_net,
5545};
5546
5547static int __init nf_tables_module_init(void)
5548{
5549 int err;
5550
5551 info = kmalloc(sizeof(struct nft_expr_info) * NFT_RULE_MAXEXPRS,
5552 GFP_KERNEL);
5553 if (info == NULL) {
5554 err = -ENOMEM;
5555 goto err1;
5556 }
5557
5558 err = nf_tables_core_module_init();
5559 if (err < 0)
5560 goto err2;
5561
5562 err = nfnetlink_subsys_register(&nf_tables_subsys);
5563 if (err < 0)
5564 goto err3;
5565
5566 pr_info("nf_tables: (c) 2007-2009 Patrick McHardy <kaber@trash.net>\n");
5567 return register_pernet_subsys(&nf_tables_net_ops);
5568err3:
5569 nf_tables_core_module_exit();
5570err2:
5571 kfree(info);
5572err1:
5573 return err;
5574}
5575
5576static void __exit nf_tables_module_exit(void)
5577{
5578 unregister_pernet_subsys(&nf_tables_net_ops);
5579 nfnetlink_subsys_unregister(&nf_tables_subsys);
5580 rcu_barrier();
5581 nf_tables_core_module_exit();
5582 kfree(info);
5583}
5584
5585module_init(nf_tables_module_init);
5586module_exit(nf_tables_module_exit);
5587
5588MODULE_LICENSE("GPL");
5589MODULE_AUTHOR("Patrick McHardy <kaber@trash.net>");
5590MODULE_ALIAS_NFNL_SUBSYS(NFNL_SUBSYS_NFTABLES);
5591
