xref: /openbmc/linux/net/netfilter/xt_CT.c (revision 9e3bd0f6)
1 // SPDX-License-Identifier: GPL-2.0-only
2 /*
3  * Copyright (c) 2010 Patrick McHardy <kaber@trash.net>
4  */
5 #define pr_fmt(fmt) KBUILD_MODNAME ": " fmt
6 #include <linux/module.h>
7 #include <linux/gfp.h>
8 #include <linux/skbuff.h>
9 #include <linux/netfilter_ipv4/ip_tables.h>
10 #include <linux/netfilter_ipv6/ip6_tables.h>
11 #include <linux/netfilter/x_tables.h>
12 #include <linux/netfilter/xt_CT.h>
13 #include <net/netfilter/nf_conntrack.h>
14 #include <net/netfilter/nf_conntrack_l4proto.h>
15 #include <net/netfilter/nf_conntrack_helper.h>
16 #include <net/netfilter/nf_conntrack_ecache.h>
17 #include <net/netfilter/nf_conntrack_timeout.h>
18 #include <net/netfilter/nf_conntrack_zones.h>
19 
20 static inline int xt_ct_target(struct sk_buff *skb, struct nf_conn *ct)
21 {
22 	/* Previously seen (loopback)? Ignore. */
23 	if (skb->_nfct != 0)
24 		return XT_CONTINUE;
25 
26 	if (ct) {
27 		atomic_inc(&ct->ct_general.use);
28 		nf_ct_set(skb, ct, IP_CT_NEW);
29 	} else {
30 		nf_ct_set(skb, ct, IP_CT_UNTRACKED);
31 	}
32 
33 	return XT_CONTINUE;
34 }
35 
36 static unsigned int xt_ct_target_v0(struct sk_buff *skb,
37 				    const struct xt_action_param *par)
38 {
39 	const struct xt_ct_target_info *info = par->targinfo;
40 	struct nf_conn *ct = info->ct;
41 
42 	return xt_ct_target(skb, ct);
43 }
44 
45 static unsigned int xt_ct_target_v1(struct sk_buff *skb,
46 				    const struct xt_action_param *par)
47 {
48 	const struct xt_ct_target_info_v1 *info = par->targinfo;
49 	struct nf_conn *ct = info->ct;
50 
51 	return xt_ct_target(skb, ct);
52 }
53 
54 static u8 xt_ct_find_proto(const struct xt_tgchk_param *par)
55 {
56 	if (par->family == NFPROTO_IPV4) {
57 		const struct ipt_entry *e = par->entryinfo;
58 
59 		if (e->ip.invflags & IPT_INV_PROTO)
60 			return 0;
61 		return e->ip.proto;
62 	} else if (par->family == NFPROTO_IPV6) {
63 		const struct ip6t_entry *e = par->entryinfo;
64 
65 		if (e->ipv6.invflags & IP6T_INV_PROTO)
66 			return 0;
67 		return e->ipv6.proto;
68 	} else
69 		return 0;
70 }
71 
72 static int
73 xt_ct_set_helper(struct nf_conn *ct, const char *helper_name,
74 		 const struct xt_tgchk_param *par)
75 {
76 	struct nf_conntrack_helper *helper;
77 	struct nf_conn_help *help;
78 	u8 proto;
79 
80 	proto = xt_ct_find_proto(par);
81 	if (!proto) {
82 		pr_info_ratelimited("You must specify a L4 protocol and not use inversions on it\n");
83 		return -ENOENT;
84 	}
85 
86 	helper = nf_conntrack_helper_try_module_get(helper_name, par->family,
87 						    proto);
88 	if (helper == NULL) {
89 		pr_info_ratelimited("No such helper \"%s\"\n", helper_name);
90 		return -ENOENT;
91 	}
92 
93 	help = nf_ct_helper_ext_add(ct, GFP_KERNEL);
94 	if (help == NULL) {
95 		nf_conntrack_helper_put(helper);
96 		return -ENOMEM;
97 	}
98 
99 	help->helper = helper;
100 	return 0;
101 }
102 
103 static int
104 xt_ct_set_timeout(struct nf_conn *ct, const struct xt_tgchk_param *par,
105 		  const char *timeout_name)
106 {
107 #ifdef CONFIG_NF_CONNTRACK_TIMEOUT
108 	const struct nf_conntrack_l4proto *l4proto;
109 	u8 proto;
110 
111 	proto = xt_ct_find_proto(par);
112 	if (!proto) {
113 		pr_info_ratelimited("You must specify a L4 protocol and not "
114 				    "use inversions on it");
115 		return -EINVAL;
116 	}
117 	l4proto = nf_ct_l4proto_find(proto);
118 	return nf_ct_set_timeout(par->net, ct, par->family, l4proto->l4proto,
119 				 timeout_name);
120 
121 #else
122 	return -EOPNOTSUPP;
123 #endif
124 }
125 
126 static u16 xt_ct_flags_to_dir(const struct xt_ct_target_info_v1 *info)
127 {
128 	switch (info->flags & (XT_CT_ZONE_DIR_ORIG |
129 			       XT_CT_ZONE_DIR_REPL)) {
130 	case XT_CT_ZONE_DIR_ORIG:
131 		return NF_CT_ZONE_DIR_ORIG;
132 	case XT_CT_ZONE_DIR_REPL:
133 		return NF_CT_ZONE_DIR_REPL;
134 	default:
135 		return NF_CT_DEFAULT_ZONE_DIR;
136 	}
137 }
138 
139 static int xt_ct_tg_check(const struct xt_tgchk_param *par,
140 			  struct xt_ct_target_info_v1 *info)
141 {
142 	struct nf_conntrack_zone zone;
143 	struct nf_conn_help *help;
144 	struct nf_conn *ct;
145 	int ret = -EOPNOTSUPP;
146 
147 	if (info->flags & XT_CT_NOTRACK) {
148 		ct = NULL;
149 		goto out;
150 	}
151 
152 #ifndef CONFIG_NF_CONNTRACK_ZONES
153 	if (info->zone || info->flags & (XT_CT_ZONE_DIR_ORIG |
154 					 XT_CT_ZONE_DIR_REPL |
155 					 XT_CT_ZONE_MARK))
156 		goto err1;
157 #endif
158 
159 	ret = nf_ct_netns_get(par->net, par->family);
160 	if (ret < 0)
161 		goto err1;
162 
163 	memset(&zone, 0, sizeof(zone));
164 	zone.id = info->zone;
165 	zone.dir = xt_ct_flags_to_dir(info);
166 	if (info->flags & XT_CT_ZONE_MARK)
167 		zone.flags |= NF_CT_FLAG_MARK;
168 
169 	ct = nf_ct_tmpl_alloc(par->net, &zone, GFP_KERNEL);
170 	if (!ct) {
171 		ret = -ENOMEM;
172 		goto err2;
173 	}
174 
175 	ret = 0;
176 	if ((info->ct_events || info->exp_events) &&
177 	    !nf_ct_ecache_ext_add(ct, info->ct_events, info->exp_events,
178 				  GFP_KERNEL)) {
179 		ret = -EINVAL;
180 		goto err3;
181 	}
182 
183 	if (info->helper[0]) {
184 		if (strnlen(info->helper, sizeof(info->helper)) == sizeof(info->helper)) {
185 			ret = -ENAMETOOLONG;
186 			goto err3;
187 		}
188 
189 		ret = xt_ct_set_helper(ct, info->helper, par);
190 		if (ret < 0)
191 			goto err3;
192 	}
193 
194 	if (info->timeout[0]) {
195 		if (strnlen(info->timeout, sizeof(info->timeout)) == sizeof(info->timeout)) {
196 			ret = -ENAMETOOLONG;
197 			goto err4;
198 		}
199 
200 		ret = xt_ct_set_timeout(ct, par, info->timeout);
201 		if (ret < 0)
202 			goto err4;
203 	}
204 	__set_bit(IPS_CONFIRMED_BIT, &ct->status);
205 	nf_conntrack_get(&ct->ct_general);
206 out:
207 	info->ct = ct;
208 	return 0;
209 
210 err4:
211 	help = nfct_help(ct);
212 	if (help)
213 		nf_conntrack_helper_put(help->helper);
214 err3:
215 	nf_ct_tmpl_free(ct);
216 err2:
217 	nf_ct_netns_put(par->net, par->family);
218 err1:
219 	return ret;
220 }
221 
222 static int xt_ct_tg_check_v0(const struct xt_tgchk_param *par)
223 {
224 	struct xt_ct_target_info *info = par->targinfo;
225 	struct xt_ct_target_info_v1 info_v1 = {
226 		.flags 		= info->flags,
227 		.zone		= info->zone,
228 		.ct_events	= info->ct_events,
229 		.exp_events	= info->exp_events,
230 	};
231 	int ret;
232 
233 	if (info->flags & ~XT_CT_NOTRACK)
234 		return -EINVAL;
235 
236 	memcpy(info_v1.helper, info->helper, sizeof(info->helper));
237 
238 	ret = xt_ct_tg_check(par, &info_v1);
239 	if (ret < 0)
240 		return ret;
241 
242 	info->ct = info_v1.ct;
243 
244 	return ret;
245 }
246 
247 static int xt_ct_tg_check_v1(const struct xt_tgchk_param *par)
248 {
249 	struct xt_ct_target_info_v1 *info = par->targinfo;
250 
251 	if (info->flags & ~XT_CT_NOTRACK)
252 		return -EINVAL;
253 
254 	return xt_ct_tg_check(par, par->targinfo);
255 }
256 
257 static int xt_ct_tg_check_v2(const struct xt_tgchk_param *par)
258 {
259 	struct xt_ct_target_info_v1 *info = par->targinfo;
260 
261 	if (info->flags & ~XT_CT_MASK)
262 		return -EINVAL;
263 
264 	return xt_ct_tg_check(par, par->targinfo);
265 }
266 
267 static void xt_ct_tg_destroy(const struct xt_tgdtor_param *par,
268 			     struct xt_ct_target_info_v1 *info)
269 {
270 	struct nf_conn *ct = info->ct;
271 	struct nf_conn_help *help;
272 
273 	if (ct) {
274 		help = nfct_help(ct);
275 		if (help)
276 			nf_conntrack_helper_put(help->helper);
277 
278 		nf_ct_netns_put(par->net, par->family);
279 
280 		nf_ct_destroy_timeout(ct);
281 		nf_ct_put(info->ct);
282 	}
283 }
284 
285 static void xt_ct_tg_destroy_v0(const struct xt_tgdtor_param *par)
286 {
287 	struct xt_ct_target_info *info = par->targinfo;
288 	struct xt_ct_target_info_v1 info_v1 = {
289 		.flags 		= info->flags,
290 		.zone		= info->zone,
291 		.ct_events	= info->ct_events,
292 		.exp_events	= info->exp_events,
293 		.ct		= info->ct,
294 	};
295 	memcpy(info_v1.helper, info->helper, sizeof(info->helper));
296 
297 	xt_ct_tg_destroy(par, &info_v1);
298 }
299 
300 static void xt_ct_tg_destroy_v1(const struct xt_tgdtor_param *par)
301 {
302 	xt_ct_tg_destroy(par, par->targinfo);
303 }
304 
305 static struct xt_target xt_ct_tg_reg[] __read_mostly = {
306 	{
307 		.name		= "CT",
308 		.family		= NFPROTO_UNSPEC,
309 		.targetsize	= sizeof(struct xt_ct_target_info),
310 		.usersize	= offsetof(struct xt_ct_target_info, ct),
311 		.checkentry	= xt_ct_tg_check_v0,
312 		.destroy	= xt_ct_tg_destroy_v0,
313 		.target		= xt_ct_target_v0,
314 		.table		= "raw",
315 		.me		= THIS_MODULE,
316 	},
317 	{
318 		.name		= "CT",
319 		.family		= NFPROTO_UNSPEC,
320 		.revision	= 1,
321 		.targetsize	= sizeof(struct xt_ct_target_info_v1),
322 		.usersize	= offsetof(struct xt_ct_target_info, ct),
323 		.checkentry	= xt_ct_tg_check_v1,
324 		.destroy	= xt_ct_tg_destroy_v1,
325 		.target		= xt_ct_target_v1,
326 		.table		= "raw",
327 		.me		= THIS_MODULE,
328 	},
329 	{
330 		.name		= "CT",
331 		.family		= NFPROTO_UNSPEC,
332 		.revision	= 2,
333 		.targetsize	= sizeof(struct xt_ct_target_info_v1),
334 		.usersize	= offsetof(struct xt_ct_target_info, ct),
335 		.checkentry	= xt_ct_tg_check_v2,
336 		.destroy	= xt_ct_tg_destroy_v1,
337 		.target		= xt_ct_target_v1,
338 		.table		= "raw",
339 		.me		= THIS_MODULE,
340 	},
341 };
342 
343 static unsigned int
344 notrack_tg(struct sk_buff *skb, const struct xt_action_param *par)
345 {
346 	/* Previously seen (loopback)? Ignore. */
347 	if (skb->_nfct != 0)
348 		return XT_CONTINUE;
349 
350 	nf_ct_set(skb, NULL, IP_CT_UNTRACKED);
351 
352 	return XT_CONTINUE;
353 }
354 
355 static int notrack_chk(const struct xt_tgchk_param *par)
356 {
357 	if (!par->net->xt.notrack_deprecated_warning) {
358 		pr_info("netfilter: NOTRACK target is deprecated, "
359 			"use CT instead or upgrade iptables\n");
360 		par->net->xt.notrack_deprecated_warning = true;
361 	}
362 	return 0;
363 }
364 
365 static struct xt_target notrack_tg_reg __read_mostly = {
366 	.name		= "NOTRACK",
367 	.revision	= 0,
368 	.family		= NFPROTO_UNSPEC,
369 	.checkentry	= notrack_chk,
370 	.target		= notrack_tg,
371 	.table		= "raw",
372 	.me		= THIS_MODULE,
373 };
374 
375 static int __init xt_ct_tg_init(void)
376 {
377 	int ret;
378 
379 	ret = xt_register_target(&notrack_tg_reg);
380 	if (ret < 0)
381 		return ret;
382 
383 	ret = xt_register_targets(xt_ct_tg_reg, ARRAY_SIZE(xt_ct_tg_reg));
384 	if (ret < 0) {
385 		xt_unregister_target(&notrack_tg_reg);
386 		return ret;
387 	}
388 	return 0;
389 }
390 
391 static void __exit xt_ct_tg_exit(void)
392 {
393 	xt_unregister_targets(xt_ct_tg_reg, ARRAY_SIZE(xt_ct_tg_reg));
394 	xt_unregister_target(&notrack_tg_reg);
395 }
396 
397 module_init(xt_ct_tg_init);
398 module_exit(xt_ct_tg_exit);
399 
400 MODULE_LICENSE("GPL");
401 MODULE_DESCRIPTION("Xtables: connection tracking target");
402 MODULE_ALIAS("ipt_CT");
403 MODULE_ALIAS("ip6t_CT");
404 MODULE_ALIAS("ipt_NOTRACK");
405 MODULE_ALIAS("ip6t_NOTRACK");
406