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