npf_build.c revision 1.46 1 1.1 rmind /*-
2 1.43 rmind * Copyright (c) 2011-2017 The NetBSD Foundation, Inc.
3 1.1 rmind * All rights reserved.
4 1.1 rmind *
5 1.1 rmind * This material is based upon work partially supported by The
6 1.1 rmind * NetBSD Foundation under a contract with Mindaugas Rasiukevicius.
7 1.1 rmind *
8 1.1 rmind * Redistribution and use in source and binary forms, with or without
9 1.1 rmind * modification, are permitted provided that the following conditions
10 1.1 rmind * are met:
11 1.1 rmind * 1. Redistributions of source code must retain the above copyright
12 1.1 rmind * notice, this list of conditions and the following disclaimer.
13 1.1 rmind * 2. Redistributions in binary form must reproduce the above copyright
14 1.1 rmind * notice, this list of conditions and the following disclaimer in the
15 1.1 rmind * documentation and/or other materials provided with the distribution.
16 1.1 rmind *
17 1.1 rmind * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
18 1.1 rmind * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
19 1.1 rmind * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
20 1.1 rmind * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
21 1.1 rmind * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
22 1.1 rmind * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
23 1.1 rmind * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
24 1.1 rmind * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
25 1.1 rmind * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
26 1.1 rmind * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
27 1.1 rmind * POSSIBILITY OF SUCH DAMAGE.
28 1.1 rmind */
29 1.1 rmind
30 1.1 rmind /*
31 1.1 rmind * npfctl(8) building of the configuration.
32 1.1 rmind */
33 1.1 rmind
34 1.1 rmind #include <sys/cdefs.h>
35 1.46 rmind __RCSID("$NetBSD: npf_build.c,v 1.46 2018/09/29 14:41:36 rmind Exp $");
36 1.1 rmind
37 1.1 rmind #include <sys/types.h>
38 1.41 christos #define __FAVOR_BSD
39 1.37 rmind #include <netinet/tcp.h>
40 1.1 rmind
41 1.1 rmind #include <stdlib.h>
42 1.1 rmind #include <inttypes.h>
43 1.1 rmind #include <string.h>
44 1.29 rmind #include <ctype.h>
45 1.33 rmind #include <unistd.h>
46 1.41 christos #include <fcntl.h>
47 1.14 rmind #include <errno.h>
48 1.1 rmind #include <err.h>
49 1.1 rmind
50 1.25 rmind #include <pcap/pcap.h>
51 1.25 rmind
52 1.1 rmind #include "npfctl.h"
53 1.1 rmind
54 1.18 rmind #define MAX_RULE_NESTING 16
55 1.18 rmind
56 1.1 rmind static nl_config_t * npf_conf = NULL;
57 1.1 rmind static bool npf_debug = false;
58 1.18 rmind static nl_rule_t * the_rule = NULL;
59 1.18 rmind
60 1.46 rmind static bool defgroup = false;
61 1.18 rmind static nl_rule_t * current_group[MAX_RULE_NESTING];
62 1.18 rmind static unsigned rule_nesting_level = 0;
63 1.43 rmind static unsigned npfctl_tid_counter = 0;
64 1.1 rmind
65 1.27 rmind static void npfctl_dump_bpf(struct bpf_program *);
66 1.27 rmind
67 1.1 rmind void
68 1.1 rmind npfctl_config_init(bool debug)
69 1.1 rmind {
70 1.1 rmind npf_conf = npf_config_create();
71 1.1 rmind if (npf_conf == NULL) {
72 1.1 rmind errx(EXIT_FAILURE, "npf_config_create failed");
73 1.1 rmind }
74 1.1 rmind npf_debug = debug;
75 1.18 rmind memset(current_group, 0, sizeof(current_group));
76 1.1 rmind }
77 1.1 rmind
78 1.1 rmind int
79 1.46 rmind npfctl_config_send(int fd)
80 1.1 rmind {
81 1.41 christos npf_error_t errinfo;
82 1.41 christos int error = 0;
83 1.1 rmind
84 1.18 rmind if (!defgroup) {
85 1.1 rmind errx(EXIT_FAILURE, "default group was not defined");
86 1.1 rmind }
87 1.46 rmind error = npf_config_submit(npf_conf, fd, &errinfo);
88 1.39 rmind if (error == EEXIST) { /* XXX */
89 1.39 rmind errx(EXIT_FAILURE, "(re)load failed: "
90 1.39 rmind "some table has a duplicate entry?");
91 1.39 rmind }
92 1.3 rmind if (error) {
93 1.41 christos npfctl_print_error(&errinfo);
94 1.3 rmind }
95 1.41 christos npf_config_destroy(npf_conf);
96 1.41 christos return error;
97 1.41 christos }
98 1.41 christos
99 1.41 christos void
100 1.41 christos npfctl_config_save(nl_config_t *ncf, const char *outfile)
101 1.41 christos {
102 1.41 christos void *blob;
103 1.41 christos size_t len;
104 1.41 christos int fd;
105 1.41 christos
106 1.41 christos blob = npf_config_export(ncf, &len);
107 1.41 christos if (!blob)
108 1.41 christos err(EXIT_FAILURE, "npf_config_export");
109 1.41 christos if ((fd = open(outfile, O_CREAT | O_TRUNC | O_WRONLY, 0644)) == -1)
110 1.41 christos err(EXIT_FAILURE, "could not open %s", outfile);
111 1.41 christos if (write(fd, blob, len) != (ssize_t)len) {
112 1.41 christos err(EXIT_FAILURE, "write to %s failed", outfile);
113 1.25 rmind }
114 1.41 christos free(blob);
115 1.41 christos close(fd);
116 1.1 rmind }
117 1.1 rmind
118 1.46 rmind void
119 1.46 rmind npfctl_config_debug(const char *outfile)
120 1.46 rmind {
121 1.46 rmind printf("\nConfiguration:\n\n");
122 1.46 rmind _npf_config_dump(npf_conf, STDOUT_FILENO);
123 1.46 rmind
124 1.46 rmind printf("\nSaving binary to %s\n", outfile);
125 1.46 rmind npfctl_config_save(npf_conf, outfile);
126 1.46 rmind npf_config_destroy(npf_conf);
127 1.46 rmind }
128 1.46 rmind
129 1.16 rmind nl_config_t *
130 1.16 rmind npfctl_config_ref(void)
131 1.16 rmind {
132 1.16 rmind return npf_conf;
133 1.16 rmind }
134 1.16 rmind
135 1.18 rmind nl_rule_t *
136 1.18 rmind npfctl_rule_ref(void)
137 1.18 rmind {
138 1.18 rmind return the_rule;
139 1.18 rmind }
140 1.18 rmind
141 1.28 rmind bool
142 1.13 rmind npfctl_debug_addif(const char *ifname)
143 1.13 rmind {
144 1.28 rmind const char tname[] = "npftest";
145 1.13 rmind const size_t tnamelen = sizeof(tname) - 1;
146 1.13 rmind
147 1.28 rmind if (npf_debug) {
148 1.28 rmind _npf_debug_addif(npf_conf, ifname);
149 1.28 rmind return strncmp(ifname, tname, tnamelen) == 0;
150 1.13 rmind }
151 1.28 rmind return 0;
152 1.13 rmind }
153 1.13 rmind
154 1.32 rmind unsigned
155 1.32 rmind npfctl_table_getid(const char *name)
156 1.1 rmind {
157 1.32 rmind unsigned tid = (unsigned)-1;
158 1.32 rmind nl_table_t *tl;
159 1.32 rmind
160 1.32 rmind /* XXX dynamic ruleset */
161 1.32 rmind if (!npf_conf) {
162 1.32 rmind return (unsigned)-1;
163 1.32 rmind }
164 1.32 rmind
165 1.32 rmind /* XXX: Iterating all as we need to rewind for the next call. */
166 1.32 rmind while ((tl = npf_table_iterate(npf_conf)) != NULL) {
167 1.32 rmind const char *tname = npf_table_getname(tl);
168 1.32 rmind if (strcmp(tname, name) == 0) {
169 1.32 rmind tid = npf_table_getid(tl);
170 1.32 rmind }
171 1.32 rmind }
172 1.32 rmind return tid;
173 1.1 rmind }
174 1.1 rmind
175 1.7 rmind static in_port_t
176 1.1 rmind npfctl_get_singleport(const npfvar_t *vp)
177 1.1 rmind {
178 1.1 rmind port_range_t *pr;
179 1.7 rmind in_port_t *port;
180 1.1 rmind
181 1.1 rmind if (npfvar_get_count(vp) > 1) {
182 1.1 rmind yyerror("multiple ports are not valid");
183 1.1 rmind }
184 1.1 rmind pr = npfvar_get_data(vp, NPFVAR_PORT_RANGE, 0);
185 1.1 rmind if (pr->pr_start != pr->pr_end) {
186 1.1 rmind yyerror("port range is not valid");
187 1.1 rmind }
188 1.7 rmind port = &pr->pr_start;
189 1.7 rmind return *port;
190 1.1 rmind }
191 1.1 rmind
192 1.1 rmind static fam_addr_mask_t *
193 1.1 rmind npfctl_get_singlefam(const npfvar_t *vp)
194 1.1 rmind {
195 1.1 rmind if (npfvar_get_count(vp) > 1) {
196 1.1 rmind yyerror("multiple addresses are not valid");
197 1.1 rmind }
198 1.1 rmind return npfvar_get_data(vp, NPFVAR_FAM, 0);
199 1.1 rmind }
200 1.1 rmind
201 1.10 rmind static bool
202 1.25 rmind npfctl_build_fam(npf_bpf_t *ctx, sa_family_t family,
203 1.1 rmind fam_addr_mask_t *fam, int opts)
204 1.1 rmind {
205 1.1 rmind /*
206 1.1 rmind * If family is specified, address does not match it and the
207 1.1 rmind * address is extracted from the interface, then simply ignore.
208 1.1 rmind * Otherwise, address of invalid family was passed manually.
209 1.1 rmind */
210 1.1 rmind if (family != AF_UNSPEC && family != fam->fam_family) {
211 1.15 rmind if (!fam->fam_ifindex) {
212 1.1 rmind yyerror("specified address is not of the required "
213 1.1 rmind "family %d", family);
214 1.1 rmind }
215 1.10 rmind return false;
216 1.1 rmind }
217 1.30 rmind
218 1.25 rmind family = fam->fam_family;
219 1.30 rmind if (family != AF_INET && family != AF_INET6) {
220 1.30 rmind yyerror("family %d is not supported", family);
221 1.30 rmind }
222 1.1 rmind
223 1.1 rmind /*
224 1.1 rmind * Optimise 0.0.0.0/0 case to be NOP. Otherwise, address with
225 1.1 rmind * zero mask would never match and therefore is not valid.
226 1.1 rmind */
227 1.1 rmind if (fam->fam_mask == 0) {
228 1.30 rmind static const npf_addr_t zero; /* must be static */
229 1.10 rmind
230 1.1 rmind if (memcmp(&fam->fam_addr, &zero, sizeof(npf_addr_t))) {
231 1.1 rmind yyerror("filter criterion would never match");
232 1.1 rmind }
233 1.10 rmind return false;
234 1.1 rmind }
235 1.1 rmind
236 1.25 rmind npfctl_bpf_cidr(ctx, opts, family, &fam->fam_addr, fam->fam_mask);
237 1.10 rmind return true;
238 1.1 rmind }
239 1.1 rmind
240 1.1 rmind static void
241 1.25 rmind npfctl_build_vars(npf_bpf_t *ctx, sa_family_t family, npfvar_t *vars, int opts)
242 1.1 rmind {
243 1.6 christos const int type = npfvar_get_type(vars, 0);
244 1.1 rmind size_t i;
245 1.1 rmind
246 1.25 rmind npfctl_bpf_group(ctx);
247 1.1 rmind for (i = 0; i < npfvar_get_count(vars); i++) {
248 1.1 rmind void *data = npfvar_get_data(vars, type, i);
249 1.1 rmind assert(data != NULL);
250 1.1 rmind
251 1.1 rmind switch (type) {
252 1.1 rmind case NPFVAR_FAM: {
253 1.1 rmind fam_addr_mask_t *fam = data;
254 1.25 rmind npfctl_build_fam(ctx, family, fam, opts);
255 1.1 rmind break;
256 1.1 rmind }
257 1.1 rmind case NPFVAR_PORT_RANGE: {
258 1.1 rmind port_range_t *pr = data;
259 1.25 rmind npfctl_bpf_ports(ctx, opts, pr->pr_start, pr->pr_end);
260 1.1 rmind break;
261 1.1 rmind }
262 1.1 rmind case NPFVAR_TABLE: {
263 1.32 rmind u_int tid;
264 1.32 rmind memcpy(&tid, data, sizeof(u_int));
265 1.25 rmind npfctl_bpf_table(ctx, opts, tid);
266 1.1 rmind break;
267 1.1 rmind }
268 1.1 rmind default:
269 1.1 rmind assert(false);
270 1.1 rmind }
271 1.1 rmind }
272 1.42 rmind npfctl_bpf_endgroup(ctx, (opts & MATCH_INVERT) != 0);
273 1.1 rmind }
274 1.1 rmind
275 1.25 rmind static void
276 1.25 rmind npfctl_build_proto(npf_bpf_t *ctx, sa_family_t family, const opt_proto_t *op)
277 1.1 rmind {
278 1.1 rmind const npfvar_t *popts = op->op_opts;
279 1.10 rmind const int proto = op->op_proto;
280 1.25 rmind
281 1.25 rmind /* IP version and/or L4 protocol matching. */
282 1.25 rmind if (family != AF_UNSPEC || proto != -1) {
283 1.25 rmind npfctl_bpf_proto(ctx, family, proto);
284 1.25 rmind }
285 1.1 rmind
286 1.10 rmind switch (proto) {
287 1.1 rmind case IPPROTO_TCP:
288 1.25 rmind /* Build TCP flags matching (optional). */
289 1.25 rmind if (popts) {
290 1.25 rmind uint8_t *tf, *tf_mask;
291 1.25 rmind
292 1.25 rmind assert(npfvar_get_count(popts) == 2);
293 1.25 rmind tf = npfvar_get_data(popts, NPFVAR_TCPFLAG, 0);
294 1.25 rmind tf_mask = npfvar_get_data(popts, NPFVAR_TCPFLAG, 1);
295 1.37 rmind npfctl_bpf_tcpfl(ctx, *tf, *tf_mask, false);
296 1.1 rmind }
297 1.1 rmind break;
298 1.1 rmind case IPPROTO_ICMP:
299 1.12 spz case IPPROTO_ICMPV6:
300 1.25 rmind /* Build ICMP/ICMPv6 type and/or code matching. */
301 1.25 rmind if (popts) {
302 1.25 rmind int *icmp_type, *icmp_code;
303 1.25 rmind
304 1.25 rmind assert(npfvar_get_count(popts) == 2);
305 1.25 rmind icmp_type = npfvar_get_data(popts, NPFVAR_ICMP, 0);
306 1.25 rmind icmp_code = npfvar_get_data(popts, NPFVAR_ICMP, 1);
307 1.25 rmind npfctl_bpf_icmp(ctx, *icmp_type, *icmp_code);
308 1.12 spz }
309 1.12 spz break;
310 1.25 rmind default:
311 1.25 rmind /* No options for other protocols. */
312 1.1 rmind break;
313 1.10 rmind }
314 1.1 rmind }
315 1.1 rmind
316 1.1 rmind static bool
317 1.25 rmind npfctl_build_code(nl_rule_t *rl, sa_family_t family, const opt_proto_t *op,
318 1.27 rmind const filt_opts_t *fopts)
319 1.1 rmind {
320 1.38 rmind bool noproto, noaddrs, noports, need_tcpudp = false;
321 1.7 rmind const addr_port_t *apfrom = &fopts->fo_from;
322 1.7 rmind const addr_port_t *apto = &fopts->fo_to;
323 1.10 rmind const int proto = op->op_proto;
324 1.25 rmind npf_bpf_t *bc;
325 1.42 rmind unsigned opts;
326 1.1 rmind size_t len;
327 1.1 rmind
328 1.25 rmind /* If none specified, then no byte-code. */
329 1.25 rmind noproto = family == AF_UNSPEC && proto == -1 && !op->op_opts;
330 1.20 rmind noaddrs = !apfrom->ap_netaddr && !apto->ap_netaddr;
331 1.20 rmind noports = !apfrom->ap_portrange && !apto->ap_portrange;
332 1.25 rmind if (noproto && noaddrs && noports) {
333 1.1 rmind return false;
334 1.25 rmind }
335 1.1 rmind
336 1.25 rmind /*
337 1.25 rmind * Sanity check: ports can only be used with TCP or UDP protocol.
338 1.25 rmind * No filter options are supported for other protocols, only the
339 1.25 rmind * IP addresses are allowed.
340 1.25 rmind */
341 1.25 rmind if (!noports) {
342 1.25 rmind switch (proto) {
343 1.25 rmind case IPPROTO_TCP:
344 1.25 rmind case IPPROTO_UDP:
345 1.38 rmind break;
346 1.25 rmind case -1:
347 1.38 rmind need_tcpudp = true;
348 1.25 rmind break;
349 1.25 rmind default:
350 1.25 rmind yyerror("invalid filter options for protocol %d", proto);
351 1.25 rmind }
352 1.25 rmind }
353 1.1 rmind
354 1.25 rmind bc = npfctl_bpf_create();
355 1.1 rmind
356 1.10 rmind /* Build layer 4 protocol blocks. */
357 1.25 rmind npfctl_build_proto(bc, family, op);
358 1.10 rmind
359 1.37 rmind /*
360 1.37 rmind * If this is a stateful rule and TCP flags are not specified,
361 1.37 rmind * then add "flags S/SAFR" filter for TCP protocol case.
362 1.37 rmind */
363 1.37 rmind if ((npf_rule_getattr(rl) & NPF_RULE_STATEFUL) != 0 &&
364 1.37 rmind (proto == -1 || (proto == IPPROTO_TCP && !op->op_opts))) {
365 1.37 rmind npfctl_bpf_tcpfl(bc, TH_SYN,
366 1.37 rmind TH_SYN | TH_ACK | TH_FIN | TH_RST, proto == -1);
367 1.37 rmind }
368 1.37 rmind
369 1.1 rmind /* Build IP address blocks. */
370 1.42 rmind opts = MATCH_SRC | (fopts->fo_finvert ? MATCH_INVERT : 0);
371 1.42 rmind npfctl_build_vars(bc, family, apfrom->ap_netaddr, opts);
372 1.42 rmind opts = MATCH_DST | (fopts->fo_tinvert ? MATCH_INVERT : 0);
373 1.42 rmind npfctl_build_vars(bc, family, apto->ap_netaddr, opts);
374 1.1 rmind
375 1.1 rmind /* Build port-range blocks. */
376 1.38 rmind if (need_tcpudp) {
377 1.38 rmind /* TCP/UDP check for the ports. */
378 1.38 rmind npfctl_bpf_group(bc);
379 1.38 rmind npfctl_bpf_proto(bc, AF_UNSPEC, IPPROTO_TCP);
380 1.38 rmind npfctl_bpf_proto(bc, AF_UNSPEC, IPPROTO_UDP);
381 1.42 rmind npfctl_bpf_endgroup(bc, false);
382 1.38 rmind }
383 1.27 rmind npfctl_build_vars(bc, family, apfrom->ap_portrange, MATCH_SRC);
384 1.27 rmind npfctl_build_vars(bc, family, apto->ap_portrange, MATCH_DST);
385 1.25 rmind
386 1.25 rmind /* Set the byte-code marks, if any. */
387 1.25 rmind const void *bmarks = npfctl_bpf_bmarks(bc, &len);
388 1.25 rmind if (npf_rule_setinfo(rl, bmarks, len) == -1) {
389 1.25 rmind errx(EXIT_FAILURE, "npf_rule_setinfo failed");
390 1.25 rmind }
391 1.1 rmind
392 1.25 rmind /* Complete BPF byte-code and pass to the rule. */
393 1.25 rmind struct bpf_program *bf = npfctl_bpf_complete(bc);
394 1.40 rmind if (bf == NULL) {
395 1.40 rmind npfctl_bpf_destroy(bc);
396 1.40 rmind return true;
397 1.40 rmind }
398 1.25 rmind len = bf->bf_len * sizeof(struct bpf_insn);
399 1.10 rmind
400 1.25 rmind if (npf_rule_setcode(rl, NPF_CODE_BPF, bf->bf_insns, len) == -1) {
401 1.1 rmind errx(EXIT_FAILURE, "npf_rule_setcode failed");
402 1.1 rmind }
403 1.27 rmind npfctl_dump_bpf(bf);
404 1.25 rmind npfctl_bpf_destroy(bc);
405 1.25 rmind
406 1.1 rmind return true;
407 1.1 rmind }
408 1.1 rmind
409 1.4 rmind static void
410 1.27 rmind npfctl_build_pcap(nl_rule_t *rl, const char *filter)
411 1.27 rmind {
412 1.27 rmind const size_t maxsnaplen = 64 * 1024;
413 1.27 rmind struct bpf_program bf;
414 1.27 rmind size_t len;
415 1.27 rmind
416 1.27 rmind if (pcap_compile_nopcap(maxsnaplen, DLT_RAW, &bf,
417 1.27 rmind filter, 1, PCAP_NETMASK_UNKNOWN) == -1) {
418 1.27 rmind yyerror("invalid pcap-filter(7) syntax");
419 1.27 rmind }
420 1.27 rmind len = bf.bf_len * sizeof(struct bpf_insn);
421 1.27 rmind
422 1.27 rmind if (npf_rule_setcode(rl, NPF_CODE_BPF, bf.bf_insns, len) == -1) {
423 1.27 rmind errx(EXIT_FAILURE, "npf_rule_setcode failed");
424 1.27 rmind }
425 1.27 rmind npfctl_dump_bpf(&bf);
426 1.27 rmind pcap_freecode(&bf);
427 1.27 rmind }
428 1.27 rmind
429 1.27 rmind static void
430 1.4 rmind npfctl_build_rpcall(nl_rproc_t *rp, const char *name, npfvar_t *args)
431 1.4 rmind {
432 1.14 rmind npf_extmod_t *extmod;
433 1.14 rmind nl_ext_t *extcall;
434 1.14 rmind int error;
435 1.4 rmind
436 1.14 rmind extmod = npf_extmod_get(name, &extcall);
437 1.14 rmind if (extmod == NULL) {
438 1.4 rmind yyerror("unknown rule procedure '%s'", name);
439 1.4 rmind }
440 1.4 rmind
441 1.4 rmind for (size_t i = 0; i < npfvar_get_count(args); i++) {
442 1.14 rmind const char *param, *value;
443 1.14 rmind proc_param_t *p;
444 1.4 rmind
445 1.14 rmind p = npfvar_get_data(args, NPFVAR_PROC_PARAM, i);
446 1.14 rmind param = p->pp_param;
447 1.14 rmind value = p->pp_value;
448 1.14 rmind
449 1.14 rmind error = npf_extmod_param(extmod, extcall, param, value);
450 1.14 rmind switch (error) {
451 1.14 rmind case EINVAL:
452 1.14 rmind yyerror("invalid parameter '%s'", param);
453 1.14 rmind default:
454 1.14 rmind break;
455 1.4 rmind }
456 1.4 rmind }
457 1.14 rmind error = npf_rproc_extcall(rp, extcall);
458 1.14 rmind if (error) {
459 1.14 rmind yyerror(error == EEXIST ?
460 1.14 rmind "duplicate procedure call" : "unexpected error");
461 1.14 rmind }
462 1.4 rmind }
463 1.4 rmind
464 1.1 rmind /*
465 1.1 rmind * npfctl_build_rproc: create and insert a rule procedure.
466 1.1 rmind */
467 1.1 rmind void
468 1.4 rmind npfctl_build_rproc(const char *name, npfvar_t *procs)
469 1.1 rmind {
470 1.1 rmind nl_rproc_t *rp;
471 1.4 rmind size_t i;
472 1.1 rmind
473 1.1 rmind rp = npf_rproc_create(name);
474 1.1 rmind if (rp == NULL) {
475 1.23 christos errx(EXIT_FAILURE, "%s failed", __func__);
476 1.1 rmind }
477 1.4 rmind
478 1.4 rmind for (i = 0; i < npfvar_get_count(procs); i++) {
479 1.14 rmind proc_call_t *pc = npfvar_get_data(procs, NPFVAR_PROC, i);
480 1.14 rmind npfctl_build_rpcall(rp, pc->pc_name, pc->pc_opts);
481 1.4 rmind }
482 1.46 rmind npf_rproc_insert(npf_conf, rp);
483 1.1 rmind }
484 1.1 rmind
485 1.22 rmind void
486 1.28 rmind npfctl_build_maprset(const char *name, int attr, const char *ifname)
487 1.22 rmind {
488 1.22 rmind const int attr_di = (NPF_RULE_IN | NPF_RULE_OUT);
489 1.22 rmind nl_rule_t *rl;
490 1.22 rmind
491 1.22 rmind /* If no direction is not specified, then both. */
492 1.22 rmind if ((attr & attr_di) == 0) {
493 1.22 rmind attr |= attr_di;
494 1.22 rmind }
495 1.22 rmind /* Allow only "in/out" attributes. */
496 1.45 rmind attr = NPF_RULE_GROUP | NPF_RULE_DYNAMIC | (attr & attr_di);
497 1.28 rmind rl = npf_rule_create(name, attr, ifname);
498 1.22 rmind npf_nat_insert(npf_conf, rl, NPF_PRI_LAST);
499 1.22 rmind }
500 1.22 rmind
501 1.1 rmind /*
502 1.46 rmind * npfctl_build_group: create a group, update the current group pointer
503 1.46 rmind * and increase the nesting level.
504 1.1 rmind */
505 1.1 rmind void
506 1.28 rmind npfctl_build_group(const char *name, int attr, const char *ifname, bool def)
507 1.1 rmind {
508 1.1 rmind const int attr_di = (NPF_RULE_IN | NPF_RULE_OUT);
509 1.1 rmind nl_rule_t *rl;
510 1.1 rmind
511 1.18 rmind if (def || (attr & attr_di) == 0) {
512 1.18 rmind attr |= attr_di;
513 1.18 rmind }
514 1.18 rmind
515 1.28 rmind rl = npf_rule_create(name, attr | NPF_RULE_GROUP, ifname);
516 1.18 rmind npf_rule_setprio(rl, NPF_PRI_LAST);
517 1.18 rmind if (def) {
518 1.18 rmind if (defgroup) {
519 1.1 rmind yyerror("multiple default groups are not valid");
520 1.1 rmind }
521 1.18 rmind if (rule_nesting_level) {
522 1.18 rmind yyerror("default group can only be at the top level");
523 1.18 rmind }
524 1.46 rmind defgroup = true;
525 1.18 rmind }
526 1.1 rmind
527 1.18 rmind /* Set the current group and increase the nesting level. */
528 1.18 rmind if (rule_nesting_level >= MAX_RULE_NESTING) {
529 1.18 rmind yyerror("rule nesting limit reached");
530 1.1 rmind }
531 1.18 rmind current_group[++rule_nesting_level] = rl;
532 1.18 rmind }
533 1.1 rmind
534 1.18 rmind void
535 1.18 rmind npfctl_build_group_end(void)
536 1.18 rmind {
537 1.46 rmind nl_rule_t *parent, *group;
538 1.46 rmind
539 1.18 rmind assert(rule_nesting_level > 0);
540 1.46 rmind parent = current_group[rule_nesting_level - 1];
541 1.46 rmind group = current_group[rule_nesting_level];
542 1.18 rmind current_group[rule_nesting_level--] = NULL;
543 1.46 rmind
544 1.46 rmind /* Note: if the parent is NULL, then it is a global rule. */
545 1.46 rmind npf_rule_insert(npf_conf, parent, group);
546 1.1 rmind }
547 1.1 rmind
548 1.1 rmind /*
549 1.26 rmind * npfctl_build_rule: create a rule, build byte-code from filter options,
550 1.18 rmind * if any, and insert into the ruleset of current group, or set the rule.
551 1.1 rmind */
552 1.1 rmind void
553 1.28 rmind npfctl_build_rule(uint32_t attr, const char *ifname, sa_family_t family,
554 1.27 rmind const opt_proto_t *op, const filt_opts_t *fopts,
555 1.27 rmind const char *pcap_filter, const char *rproc)
556 1.1 rmind {
557 1.1 rmind nl_rule_t *rl;
558 1.1 rmind
559 1.19 rmind attr |= (npf_conf ? 0 : NPF_RULE_DYNAMIC);
560 1.21 rmind
561 1.28 rmind rl = npf_rule_create(NULL, attr, ifname);
562 1.27 rmind if (pcap_filter) {
563 1.27 rmind npfctl_build_pcap(rl, pcap_filter);
564 1.27 rmind } else {
565 1.27 rmind npfctl_build_code(rl, family, op, fopts);
566 1.27 rmind }
567 1.27 rmind
568 1.18 rmind if (rproc) {
569 1.18 rmind npf_rule_setproc(rl, rproc);
570 1.18 rmind }
571 1.18 rmind
572 1.18 rmind if (npf_conf) {
573 1.18 rmind nl_rule_t *cg = current_group[rule_nesting_level];
574 1.18 rmind
575 1.18 rmind if (rproc && !npf_rproc_exists_p(npf_conf, rproc)) {
576 1.18 rmind yyerror("rule procedure '%s' is not defined", rproc);
577 1.18 rmind }
578 1.18 rmind assert(cg != NULL);
579 1.18 rmind npf_rule_setprio(rl, NPF_PRI_LAST);
580 1.18 rmind npf_rule_insert(npf_conf, cg, rl);
581 1.18 rmind } else {
582 1.18 rmind /* We have parsed a single rule - set it. */
583 1.18 rmind the_rule = rl;
584 1.1 rmind }
585 1.1 rmind }
586 1.1 rmind
587 1.1 rmind /*
588 1.14 rmind * npfctl_build_nat: create a single NAT policy of a specified
589 1.13 rmind * type with a given filter options.
590 1.13 rmind */
591 1.36 rmind static nl_nat_t *
592 1.36 rmind npfctl_build_nat(int type, const char *ifname, const addr_port_t *ap,
593 1.44 rmind const opt_proto_t *op, const filt_opts_t *fopts, u_int flags)
594 1.13 rmind {
595 1.44 rmind const opt_proto_t def_op = { .op_proto = -1, .op_opts = NULL };
596 1.36 rmind fam_addr_mask_t *am = npfctl_get_singlefam(ap->ap_netaddr);
597 1.13 rmind in_port_t port;
598 1.13 rmind nl_nat_t *nat;
599 1.13 rmind
600 1.35 rmind if (ap->ap_portrange) {
601 1.45 rmind /*
602 1.45 rmind * The port forwarding case. In such case, there has to
603 1.45 rmind * be a single port used for translation; we keep the port
604 1.45 rmind * translation on, but disable the port map.
605 1.45 rmind */
606 1.35 rmind port = npfctl_get_singleport(ap->ap_portrange);
607 1.35 rmind flags &= ~NPF_NAT_PORTMAP;
608 1.35 rmind flags |= NPF_NAT_PORTS;
609 1.35 rmind } else {
610 1.13 rmind port = 0;
611 1.13 rmind }
612 1.44 rmind if (!op) {
613 1.44 rmind op = &def_op;
614 1.44 rmind }
615 1.13 rmind
616 1.36 rmind nat = npf_nat_create(type, flags, ifname, am->fam_family,
617 1.36 rmind &am->fam_addr, am->fam_mask, port);
618 1.44 rmind npfctl_build_code(nat, am->fam_family, op, fopts);
619 1.36 rmind return nat;
620 1.13 rmind }
621 1.13 rmind
622 1.13 rmind /*
623 1.14 rmind * npfctl_build_natseg: validate and create NAT policies.
624 1.1 rmind */
625 1.1 rmind void
626 1.45 rmind npfctl_build_natseg(int sd, int type, unsigned mflags, const char *ifname,
627 1.44 rmind const addr_port_t *ap1, const addr_port_t *ap2, const opt_proto_t *op,
628 1.36 rmind const filt_opts_t *fopts, u_int algo)
629 1.1 rmind {
630 1.36 rmind fam_addr_mask_t *am1 = NULL, *am2 = NULL;
631 1.36 rmind nl_nat_t *nt1 = NULL, *nt2 = NULL;
632 1.7 rmind filt_opts_t imfopts;
633 1.36 rmind uint16_t adj = 0;
634 1.35 rmind u_int flags;
635 1.13 rmind bool binat;
636 1.1 rmind
637 1.28 rmind assert(ifname != NULL);
638 1.7 rmind
639 1.13 rmind /*
640 1.13 rmind * Bi-directional NAT is a combination of inbound NAT and outbound
641 1.35 rmind * NAT policies with the translation segments inverted respectively.
642 1.13 rmind */
643 1.13 rmind binat = (NPF_NATIN | NPF_NATOUT) == type;
644 1.7 rmind
645 1.35 rmind switch (sd) {
646 1.35 rmind case NPFCTL_NAT_DYNAMIC:
647 1.35 rmind /*
648 1.35 rmind * Dynamic NAT: traditional NAPT is expected. Unless it
649 1.35 rmind * is bi-directional NAT, perform port mapping.
650 1.35 rmind */
651 1.35 rmind flags = !binat ? (NPF_NAT_PORTS | NPF_NAT_PORTMAP) : 0;
652 1.35 rmind break;
653 1.35 rmind case NPFCTL_NAT_STATIC:
654 1.35 rmind /* Static NAT: mechanic translation. */
655 1.35 rmind flags = NPF_NAT_STATIC;
656 1.35 rmind break;
657 1.35 rmind default:
658 1.35 rmind abort();
659 1.35 rmind }
660 1.35 rmind
661 1.7 rmind /*
662 1.45 rmind * Apply the flag modifications.
663 1.45 rmind */
664 1.45 rmind if (mflags & NPF_NAT_PORTS) {
665 1.45 rmind flags &= ~(NPF_NAT_PORTS | NPF_NAT_PORTMAP);
666 1.45 rmind }
667 1.45 rmind
668 1.45 rmind /*
669 1.36 rmind * Validate the mappings and their configuration.
670 1.36 rmind */
671 1.36 rmind
672 1.36 rmind if ((type & NPF_NATIN) != 0) {
673 1.36 rmind if (!ap1->ap_netaddr)
674 1.36 rmind yyerror("inbound network segment is not specified");
675 1.36 rmind am1 = npfctl_get_singlefam(ap1->ap_netaddr);
676 1.36 rmind }
677 1.36 rmind if ((type & NPF_NATOUT) != 0) {
678 1.36 rmind if (!ap2->ap_netaddr)
679 1.36 rmind yyerror("outbound network segment is not specified");
680 1.36 rmind am2 = npfctl_get_singlefam(ap2->ap_netaddr);
681 1.36 rmind }
682 1.36 rmind
683 1.36 rmind switch (algo) {
684 1.36 rmind case NPF_ALGO_NPT66:
685 1.36 rmind if (am1 == NULL || am2 == NULL)
686 1.36 rmind yyerror("1:1 mapping of two segments must be "
687 1.36 rmind "used for NPTv6");
688 1.36 rmind if (am1->fam_mask != am2->fam_mask)
689 1.36 rmind yyerror("asymmetric translation is not supported");
690 1.36 rmind adj = npfctl_npt66_calcadj(am1->fam_mask,
691 1.36 rmind &am1->fam_addr, &am2->fam_addr);
692 1.36 rmind break;
693 1.36 rmind default:
694 1.36 rmind if ((am1 && am1->fam_mask != NPF_NO_NETMASK) ||
695 1.36 rmind (am2 && am2->fam_mask != NPF_NO_NETMASK))
696 1.36 rmind yyerror("net-to-net translation is not supported");
697 1.36 rmind break;
698 1.36 rmind }
699 1.36 rmind
700 1.36 rmind /*
701 1.13 rmind * If the filter criteria is not specified explicitly, apply implicit
702 1.14 rmind * filtering according to the given network segments.
703 1.13 rmind *
704 1.13 rmind * Note: filled below, depending on the type.
705 1.7 rmind */
706 1.14 rmind if (__predict_true(!fopts)) {
707 1.7 rmind fopts = &imfopts;
708 1.1 rmind }
709 1.1 rmind
710 1.13 rmind if (type & NPF_NATIN) {
711 1.13 rmind memset(&imfopts, 0, sizeof(filt_opts_t));
712 1.13 rmind memcpy(&imfopts.fo_to, ap2, sizeof(addr_port_t));
713 1.44 rmind nt1 = npfctl_build_nat(NPF_NATIN, ifname, ap1, op, fopts, flags);
714 1.13 rmind }
715 1.13 rmind if (type & NPF_NATOUT) {
716 1.13 rmind memset(&imfopts, 0, sizeof(filt_opts_t));
717 1.13 rmind memcpy(&imfopts.fo_from, ap1, sizeof(addr_port_t));
718 1.44 rmind nt2 = npfctl_build_nat(NPF_NATOUT, ifname, ap2, op, fopts, flags);
719 1.36 rmind }
720 1.36 rmind
721 1.36 rmind if (algo == NPF_ALGO_NPT66) {
722 1.36 rmind npf_nat_setnpt66(nt1, ~adj);
723 1.36 rmind npf_nat_setnpt66(nt2, adj);
724 1.1 rmind }
725 1.46 rmind
726 1.46 rmind if (nt1) {
727 1.46 rmind npf_nat_insert(npf_conf, nt1, NPF_PRI_LAST);
728 1.46 rmind }
729 1.46 rmind if (nt2) {
730 1.46 rmind npf_nat_insert(npf_conf, nt2, NPF_PRI_LAST);
731 1.46 rmind }
732 1.1 rmind }
733 1.1 rmind
734 1.1 rmind /*
735 1.1 rmind * npfctl_fill_table: fill NPF table with entries from a specified file.
736 1.1 rmind */
737 1.1 rmind static void
738 1.11 rmind npfctl_fill_table(nl_table_t *tl, u_int type, const char *fname)
739 1.1 rmind {
740 1.1 rmind char *buf = NULL;
741 1.1 rmind int l = 0;
742 1.1 rmind FILE *fp;
743 1.1 rmind size_t n;
744 1.1 rmind
745 1.1 rmind fp = fopen(fname, "r");
746 1.1 rmind if (fp == NULL) {
747 1.1 rmind err(EXIT_FAILURE, "open '%s'", fname);
748 1.1 rmind }
749 1.1 rmind while (l++, getline(&buf, &n, fp) != -1) {
750 1.11 rmind fam_addr_mask_t fam;
751 1.11 rmind int alen;
752 1.1 rmind
753 1.1 rmind if (*buf == '\n' || *buf == '#') {
754 1.1 rmind continue;
755 1.1 rmind }
756 1.11 rmind
757 1.11 rmind if (!npfctl_parse_cidr(buf, &fam, &alen)) {
758 1.11 rmind errx(EXIT_FAILURE,
759 1.11 rmind "%s:%d: invalid table entry", fname, l);
760 1.11 rmind }
761 1.33 rmind if (type != NPF_TABLE_TREE && fam.fam_mask != NPF_NO_NETMASK) {
762 1.33 rmind errx(EXIT_FAILURE, "%s:%d: mask used with the "
763 1.33 rmind "non-tree table", fname, l);
764 1.1 rmind }
765 1.1 rmind
766 1.46 rmind npf_table_add_entry(tl, fam.fam_family,
767 1.46 rmind &fam.fam_addr, fam.fam_mask);
768 1.33 rmind }
769 1.46 rmind free(buf);
770 1.1 rmind }
771 1.1 rmind
772 1.1 rmind /*
773 1.1 rmind * npfctl_build_table: create an NPF table, add to the configuration and,
774 1.1 rmind * if required, fill with contents from a file.
775 1.1 rmind */
776 1.1 rmind void
777 1.29 rmind npfctl_build_table(const char *tname, u_int type, const char *fname)
778 1.1 rmind {
779 1.1 rmind nl_table_t *tl;
780 1.1 rmind
781 1.43 rmind tl = npf_table_create(tname, npfctl_tid_counter++, type);
782 1.1 rmind assert(tl != NULL);
783 1.1 rmind
784 1.1 rmind if (fname) {
785 1.11 rmind npfctl_fill_table(tl, type, fname);
786 1.33 rmind } else if (type == NPF_TABLE_CDB) {
787 1.33 rmind errx(EXIT_FAILURE, "tables of cdb type must be static");
788 1.1 rmind }
789 1.46 rmind
790 1.46 rmind if (npf_table_insert(npf_conf, tl)) {
791 1.46 rmind yyerror("table '%s' is already defined", tname);
792 1.46 rmind }
793 1.1 rmind }
794 1.23 christos
795 1.43 rmind npfvar_t *
796 1.43 rmind npfctl_ifnet_table(const char *ifname)
797 1.43 rmind {
798 1.43 rmind char tname[NPF_TABLE_MAXNAMELEN];
799 1.43 rmind nl_table_t *tl;
800 1.43 rmind u_int tid;
801 1.43 rmind
802 1.43 rmind snprintf(tname, sizeof(tname), ".ifnet-%s", ifname);
803 1.43 rmind
804 1.43 rmind tid = npfctl_table_getid(tname);
805 1.43 rmind if (tid == (unsigned)-1) {
806 1.43 rmind tid = npfctl_tid_counter++;
807 1.43 rmind tl = npf_table_create(tname, tid, NPF_TABLE_TREE);
808 1.43 rmind (void)npf_table_insert(npf_conf, tl);
809 1.43 rmind }
810 1.43 rmind return npfvar_create_element(NPFVAR_TABLE, &tid, sizeof(u_int));
811 1.43 rmind }
812 1.43 rmind
813 1.23 christos /*
814 1.25 rmind * npfctl_build_alg: create an NPF application level gateway and add it
815 1.23 christos * to the configuration.
816 1.23 christos */
817 1.23 christos void
818 1.23 christos npfctl_build_alg(const char *al_name)
819 1.23 christos {
820 1.23 christos if (_npf_alg_load(npf_conf, al_name) != 0) {
821 1.23 christos errx(EXIT_FAILURE, "ALG '%s' already loaded", al_name);
822 1.23 christos }
823 1.23 christos }
824 1.27 rmind
825 1.27 rmind static void
826 1.27 rmind npfctl_dump_bpf(struct bpf_program *bf)
827 1.27 rmind {
828 1.27 rmind if (npf_debug) {
829 1.27 rmind extern char *yytext;
830 1.27 rmind extern int yylineno;
831 1.27 rmind
832 1.27 rmind int rule_line = yylineno - (int)(*yytext == '\n');
833 1.27 rmind printf("\nRULE AT LINE %d\n", rule_line);
834 1.27 rmind bpf_dump(bf, 0);
835 1.27 rmind }
836 1.27 rmind }
837