Home | History | Annotate | Line # | Download | only in npfctl
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