Home | History | Annotate | Line # | Download | only in npf
npf_ctl.c revision 1.32
      1  1.32     rmind /*	$NetBSD: npf_ctl.c,v 1.32 2013/11/12 00:46:34 rmind Exp $	*/
      2   1.1     rmind 
      3   1.1     rmind /*-
      4  1.21     rmind  * Copyright (c) 2009-2013 The NetBSD Foundation, Inc.
      5   1.1     rmind  * All rights reserved.
      6   1.1     rmind  *
      7   1.1     rmind  * This material is based upon work partially supported by The
      8   1.1     rmind  * NetBSD Foundation under a contract with Mindaugas Rasiukevicius.
      9   1.1     rmind  *
     10   1.1     rmind  * Redistribution and use in source and binary forms, with or without
     11   1.1     rmind  * modification, are permitted provided that the following conditions
     12   1.1     rmind  * are met:
     13   1.1     rmind  * 1. Redistributions of source code must retain the above copyright
     14   1.1     rmind  *    notice, this list of conditions and the following disclaimer.
     15   1.1     rmind  * 2. Redistributions in binary form must reproduce the above copyright
     16   1.1     rmind  *    notice, this list of conditions and the following disclaimer in the
     17   1.1     rmind  *    documentation and/or other materials provided with the distribution.
     18   1.1     rmind  *
     19   1.1     rmind  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     20   1.1     rmind  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     21   1.1     rmind  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     22   1.1     rmind  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     23   1.1     rmind  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     24   1.1     rmind  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     25   1.1     rmind  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     26   1.1     rmind  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     27   1.1     rmind  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     28   1.1     rmind  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     29   1.1     rmind  * POSSIBILITY OF SUCH DAMAGE.
     30   1.1     rmind  */
     31   1.1     rmind 
     32   1.1     rmind /*
     33   1.1     rmind  * NPF device control.
     34   1.1     rmind  *
     35   1.1     rmind  * Implementation of (re)loading, construction of tables and rules.
     36   1.1     rmind  * NPF proplib(9) dictionary consumer.
     37   1.1     rmind  */
     38   1.1     rmind 
     39   1.1     rmind #include <sys/cdefs.h>
     40  1.32     rmind __KERNEL_RCSID(0, "$NetBSD: npf_ctl.c,v 1.32 2013/11/12 00:46:34 rmind Exp $");
     41   1.1     rmind 
     42   1.1     rmind #include <sys/param.h>
     43   1.1     rmind #include <sys/conf.h>
     44  1.21     rmind #include <sys/kmem.h>
     45  1.21     rmind #include <net/bpf.h>
     46   1.1     rmind 
     47   1.1     rmind #include <prop/proplib.h>
     48   1.1     rmind 
     49   1.1     rmind #include "npf_impl.h"
     50   1.1     rmind 
     51  1.12     rmind #if defined(DEBUG) || defined(DIAGNOSTIC)
     52  1.12     rmind #define	NPF_ERR_DEBUG(e) \
     53  1.12     rmind 	prop_dictionary_set_cstring_nocopy((e), "source-file", __FILE__); \
     54  1.12     rmind 	prop_dictionary_set_uint32((e), "source-line", __LINE__);
     55  1.12     rmind #else
     56  1.12     rmind #define	NPF_ERR_DEBUG(e)
     57  1.12     rmind #endif
     58  1.12     rmind 
     59   1.1     rmind /*
     60   1.1     rmind  * npfctl_switch: enable or disable packet inspection.
     61   1.1     rmind  */
     62   1.1     rmind int
     63   1.1     rmind npfctl_switch(void *data)
     64   1.1     rmind {
     65   1.1     rmind 	const bool onoff = *(int *)data ? true : false;
     66   1.1     rmind 	int error;
     67   1.1     rmind 
     68   1.1     rmind 	if (onoff) {
     69   1.1     rmind 		/* Enable: add pfil hooks. */
     70  1.31     rmind 		error = npf_pfil_register(false);
     71   1.1     rmind 	} else {
     72   1.1     rmind 		/* Disable: remove pfil hooks. */
     73  1.31     rmind 		npf_pfil_unregister(false);
     74   1.1     rmind 		error = 0;
     75   1.1     rmind 	}
     76   1.1     rmind 	return error;
     77   1.1     rmind }
     78   1.1     rmind 
     79   1.6     rmind static int __noinline
     80  1.12     rmind npf_mk_tables(npf_tableset_t *tblset, prop_array_t tables,
     81  1.12     rmind     prop_dictionary_t errdict)
     82   1.1     rmind {
     83   1.1     rmind 	prop_object_iterator_t it;
     84   1.1     rmind 	prop_dictionary_t tbldict;
     85   1.1     rmind 	int error = 0;
     86   1.1     rmind 
     87   1.1     rmind 	/* Tables - array. */
     88  1.12     rmind 	if (prop_object_type(tables) != PROP_TYPE_ARRAY) {
     89  1.12     rmind 		NPF_ERR_DEBUG(errdict);
     90   1.1     rmind 		return EINVAL;
     91  1.12     rmind 	}
     92   1.1     rmind 
     93   1.1     rmind 	it = prop_array_iterator(tables);
     94   1.1     rmind 	while ((tbldict = prop_object_iterator_next(it)) != NULL) {
     95   1.1     rmind 		prop_dictionary_t ent;
     96   1.1     rmind 		prop_object_iterator_t eit;
     97   1.1     rmind 		prop_array_t entries;
     98  1.32     rmind 		const char *name;
     99   1.1     rmind 		npf_table_t *t;
    100   1.1     rmind 		u_int tid;
    101   1.1     rmind 		int type;
    102   1.1     rmind 
    103   1.1     rmind 		/* Table - dictionary. */
    104   1.1     rmind 		if (prop_object_type(tbldict) != PROP_TYPE_DICTIONARY) {
    105  1.12     rmind 			NPF_ERR_DEBUG(errdict);
    106   1.1     rmind 			error = EINVAL;
    107   1.1     rmind 			break;
    108   1.1     rmind 		}
    109   1.1     rmind 
    110  1.32     rmind 		/* Table name, ID and type.  Validate them. */
    111  1.32     rmind 		if (!prop_dictionary_get_cstring_nocopy(tbldict, "name", &name)) {
    112  1.32     rmind 			NPF_ERR_DEBUG(errdict);
    113  1.32     rmind 			error = EINVAL;
    114  1.32     rmind 			break;
    115  1.32     rmind 		}
    116   1.6     rmind 		prop_dictionary_get_uint32(tbldict, "id", &tid);
    117   1.6     rmind 		prop_dictionary_get_int32(tbldict, "type", &type);
    118  1.32     rmind 		error = npf_table_check(tblset, name, tid, type);
    119  1.32     rmind 		if (error) {
    120  1.32     rmind 			NPF_ERR_DEBUG(errdict);
    121   1.1     rmind 			break;
    122  1.32     rmind 		}
    123   1.1     rmind 
    124   1.1     rmind 		/* Create and insert the table. */
    125  1.32     rmind 		t = npf_table_create(name, tid, type, 1024);	/* XXX */
    126   1.1     rmind 		if (t == NULL) {
    127  1.12     rmind 			NPF_ERR_DEBUG(errdict);
    128   1.1     rmind 			error = ENOMEM;
    129   1.1     rmind 			break;
    130   1.1     rmind 		}
    131   1.1     rmind 		error = npf_tableset_insert(tblset, t);
    132   1.1     rmind 		KASSERT(error == 0);
    133   1.1     rmind 
    134   1.1     rmind 		/* Entries. */
    135   1.1     rmind 		entries = prop_dictionary_get(tbldict, "entries");
    136   1.1     rmind 		if (prop_object_type(entries) != PROP_TYPE_ARRAY) {
    137  1.12     rmind 			NPF_ERR_DEBUG(errdict);
    138   1.1     rmind 			error = EINVAL;
    139   1.1     rmind 			break;
    140   1.1     rmind 		}
    141   1.1     rmind 		eit = prop_array_iterator(entries);
    142   1.1     rmind 		while ((ent = prop_object_iterator_next(eit)) != NULL) {
    143   1.7    zoltan 			const npf_addr_t *addr;
    144   1.9     rmind 			npf_netmask_t mask;
    145  1.16     rmind 			int alen;
    146   1.1     rmind 
    147   1.6     rmind 			/* Get address and mask.  Add a table entry. */
    148  1.16     rmind 			prop_object_t obj = prop_dictionary_get(ent, "addr");
    149  1.16     rmind 			addr = (const npf_addr_t *)prop_data_data_nocopy(obj);
    150   1.7    zoltan 			prop_dictionary_get_uint8(ent, "mask", &mask);
    151  1.16     rmind 			alen = prop_data_size(obj);
    152  1.16     rmind 
    153  1.32     rmind 			error = npf_table_insert(t, alen, addr, mask);
    154   1.1     rmind 			if (error)
    155   1.1     rmind 				break;
    156   1.1     rmind 		}
    157   1.1     rmind 		prop_object_iterator_release(eit);
    158   1.1     rmind 		if (error)
    159   1.1     rmind 			break;
    160   1.1     rmind 	}
    161   1.1     rmind 	prop_object_iterator_release(it);
    162   1.1     rmind 	/*
    163   1.4     rmind 	 * Note: in a case of error, caller will free the tableset.
    164   1.1     rmind 	 */
    165   1.1     rmind 	return error;
    166   1.1     rmind }
    167   1.1     rmind 
    168   1.5     rmind static npf_rproc_t *
    169  1.21     rmind npf_mk_singlerproc(prop_dictionary_t rpdict)
    170   1.5     rmind {
    171   1.5     rmind 	prop_object_iterator_t it;
    172  1.21     rmind 	prop_dictionary_t extdict;
    173  1.18     rmind 	prop_array_t extlist;
    174   1.5     rmind 	npf_rproc_t *rp;
    175  1.18     rmind 
    176  1.18     rmind 	extlist = prop_dictionary_get(rpdict, "extcalls");
    177  1.18     rmind 	if (prop_object_type(extlist) != PROP_TYPE_ARRAY) {
    178  1.18     rmind 		return NULL;
    179  1.18     rmind 	}
    180  1.18     rmind 
    181  1.18     rmind 	rp = npf_rproc_create(rpdict);
    182  1.21     rmind 	if (rp == NULL) {
    183  1.18     rmind 		return NULL;
    184  1.18     rmind 	}
    185  1.21     rmind 
    186  1.18     rmind 	it = prop_array_iterator(extlist);
    187  1.18     rmind 	while ((extdict = prop_object_iterator_next(it)) != NULL) {
    188  1.21     rmind 		const char *name;
    189  1.21     rmind 
    190  1.18     rmind 		if (!prop_dictionary_get_cstring_nocopy(extdict,
    191  1.18     rmind 		    "name", &name) || npf_ext_construct(name, rp, extdict)) {
    192  1.18     rmind 			npf_rproc_release(rp);
    193  1.18     rmind 			rp = NULL;
    194  1.18     rmind 			break;
    195  1.18     rmind 		}
    196  1.18     rmind 	}
    197  1.18     rmind 	prop_object_iterator_release(it);
    198  1.21     rmind 	return rp;
    199  1.21     rmind }
    200  1.21     rmind 
    201  1.21     rmind static int __noinline
    202  1.21     rmind npf_mk_rprocs(npf_rprocset_t *rpset, prop_array_t rprocs,
    203  1.21     rmind     prop_dictionary_t errdict)
    204  1.21     rmind {
    205  1.21     rmind 	prop_object_iterator_t it;
    206  1.21     rmind 	prop_dictionary_t rpdict;
    207  1.21     rmind 	int error = 0;
    208  1.21     rmind 
    209  1.21     rmind 	it = prop_array_iterator(rprocs);
    210  1.21     rmind 	while ((rpdict = prop_object_iterator_next(it)) != NULL) {
    211  1.21     rmind 		npf_rproc_t *rp;
    212  1.18     rmind 
    213  1.21     rmind 		if ((rp = npf_mk_singlerproc(rpdict)) == NULL) {
    214  1.21     rmind 			NPF_ERR_DEBUG(errdict);
    215  1.21     rmind 			error = EINVAL;
    216  1.21     rmind 			break;
    217  1.21     rmind 		}
    218  1.21     rmind 		npf_rprocset_insert(rpset, rp);
    219   1.5     rmind 	}
    220  1.21     rmind 	prop_object_iterator_release(it);
    221  1.21     rmind 	return error;
    222   1.5     rmind }
    223   1.5     rmind 
    224  1.24  christos static npf_alg_t *
    225  1.24  christos npf_mk_singlealg(prop_dictionary_t aldict)
    226  1.24  christos {
    227  1.24  christos 	const char *name;
    228  1.24  christos 
    229  1.24  christos 	if (!prop_dictionary_get_cstring_nocopy(aldict, "name", &name))
    230  1.24  christos 		return NULL;
    231  1.24  christos 	return npf_alg_construct(name);
    232  1.24  christos }
    233  1.24  christos 
    234  1.24  christos static int __noinline
    235  1.24  christos npf_mk_algs(prop_array_t alglist, prop_dictionary_t errdict)
    236  1.24  christos {
    237  1.24  christos 	prop_object_iterator_t it;
    238  1.24  christos 	prop_dictionary_t nadict;
    239  1.24  christos 	int error = 0;
    240  1.24  christos 
    241  1.24  christos 	it = prop_array_iterator(alglist);
    242  1.24  christos 	while ((nadict = prop_object_iterator_next(it)) != NULL) {
    243  1.24  christos 		if (npf_mk_singlealg(nadict) == NULL) {
    244  1.24  christos 			NPF_ERR_DEBUG(errdict);
    245  1.24  christos 			error = EINVAL;
    246  1.24  christos 			break;
    247  1.24  christos 		}
    248  1.24  christos 	}
    249  1.24  christos 	prop_object_iterator_release(it);
    250  1.24  christos 	return error;
    251  1.24  christos }
    252  1.24  christos 
    253   1.6     rmind static int __noinline
    254  1.21     rmind npf_mk_code(prop_object_t obj, int type, void **code, size_t *csize,
    255  1.12     rmind     prop_dictionary_t errdict)
    256  1.12     rmind {
    257  1.21     rmind 	const void *cptr;
    258  1.21     rmind 	size_t clen;
    259  1.21     rmind 	void *bc;
    260  1.12     rmind 
    261  1.29     rmind 	if (type != NPF_CODE_BPF) {
    262  1.29     rmind 		return ENOTSUP;
    263  1.29     rmind 	}
    264  1.21     rmind 	cptr = prop_data_data_nocopy(obj);
    265  1.21     rmind 	if (cptr == NULL || (clen = prop_data_size(obj)) == 0) {
    266  1.12     rmind 		NPF_ERR_DEBUG(errdict);
    267  1.21     rmind 		return EINVAL;
    268  1.12     rmind 	}
    269  1.29     rmind 	if (!npf_bpf_validate(cptr, clen)) {
    270  1.29     rmind 		NPF_ERR_DEBUG(errdict);
    271  1.29     rmind 		return EINVAL;
    272  1.12     rmind 	}
    273  1.21     rmind 	bc = kmem_alloc(clen, KM_SLEEP);
    274  1.21     rmind 	memcpy(bc, cptr, clen);
    275  1.21     rmind 
    276  1.21     rmind 	*code = bc;
    277  1.21     rmind 	*csize = clen;
    278  1.12     rmind 	return 0;
    279  1.12     rmind }
    280  1.12     rmind 
    281  1.12     rmind static int __noinline
    282  1.21     rmind npf_mk_singlerule(prop_dictionary_t rldict, npf_rprocset_t *rpset,
    283  1.21     rmind     npf_rule_t **rlret, prop_dictionary_t errdict)
    284   1.1     rmind {
    285  1.21     rmind 	npf_rule_t *rl;
    286  1.21     rmind 	const char *rname;
    287   1.1     rmind 	prop_object_t obj;
    288  1.21     rmind 	int p, error = 0;
    289   1.1     rmind 
    290   1.1     rmind 	/* Rule - dictionary. */
    291  1.12     rmind 	if (prop_object_type(rldict) != PROP_TYPE_DICTIONARY) {
    292  1.12     rmind 		NPF_ERR_DEBUG(errdict);
    293   1.1     rmind 		return EINVAL;
    294  1.12     rmind 	}
    295  1.21     rmind 	if ((rl = npf_rule_alloc(rldict)) == NULL) {
    296  1.21     rmind 		NPF_ERR_DEBUG(errdict);
    297  1.21     rmind 		return EINVAL;
    298  1.21     rmind 	}
    299   1.1     rmind 
    300  1.21     rmind 	/* Assign rule procedure, if any. */
    301  1.21     rmind 	if (prop_dictionary_get_cstring_nocopy(rldict, "rproc", &rname)) {
    302  1.21     rmind 		npf_rproc_t *rp;
    303  1.21     rmind 
    304  1.21     rmind 		if (rpset == NULL) {
    305  1.21     rmind 			error = EINVAL;
    306  1.21     rmind 			goto err;
    307  1.21     rmind 		}
    308  1.21     rmind 		if ((rp = npf_rprocset_lookup(rpset, rname)) == NULL) {
    309  1.18     rmind 			NPF_ERR_DEBUG(errdict);
    310  1.18     rmind 			error = EINVAL;
    311  1.18     rmind 			goto err;
    312  1.18     rmind 		}
    313  1.21     rmind 		npf_rule_setrproc(rl, rp);
    314  1.18     rmind 	}
    315  1.18     rmind 
    316  1.21     rmind 	/* Filter code (binary data). */
    317  1.21     rmind 	if ((obj = prop_dictionary_get(rldict, "code")) != NULL) {
    318  1.21     rmind 		int type;
    319  1.21     rmind 		size_t len;
    320  1.21     rmind 		void *code;
    321  1.21     rmind 
    322  1.21     rmind 		prop_dictionary_get_int32(rldict, "code-type", &type);
    323  1.21     rmind 		error = npf_mk_code(obj, type, &code, &len, errdict);
    324  1.12     rmind 		if (error) {
    325  1.12     rmind 			goto err;
    326   1.4     rmind 		}
    327  1.21     rmind 		npf_rule_setcode(rl, type, code, len);
    328   1.1     rmind 	}
    329   1.1     rmind 
    330  1.21     rmind 	*rlret = rl;
    331   1.6     rmind 	return 0;
    332  1.12     rmind err:
    333  1.21     rmind 	npf_rule_free(rl);
    334  1.12     rmind 	prop_dictionary_get_int32(rldict, "priority", &p); /* XXX */
    335  1.12     rmind 	prop_dictionary_set_int32(errdict, "id", p);
    336  1.12     rmind 	return error;
    337   1.6     rmind }
    338   1.6     rmind 
    339   1.6     rmind static int __noinline
    340  1.21     rmind npf_mk_rules(npf_ruleset_t *rlset, prop_array_t rules, npf_rprocset_t *rpset,
    341  1.12     rmind     prop_dictionary_t errdict)
    342   1.6     rmind {
    343   1.6     rmind 	prop_object_iterator_t it;
    344   1.6     rmind 	prop_dictionary_t rldict;
    345  1.21     rmind 	int error;
    346   1.6     rmind 
    347   1.6     rmind 	if (prop_object_type(rules) != PROP_TYPE_ARRAY) {
    348  1.12     rmind 		NPF_ERR_DEBUG(errdict);
    349   1.6     rmind 		return EINVAL;
    350   1.6     rmind 	}
    351   1.5     rmind 
    352   1.4     rmind 	error = 0;
    353   1.1     rmind 	it = prop_array_iterator(rules);
    354   1.1     rmind 	while ((rldict = prop_object_iterator_next(it)) != NULL) {
    355  1.21     rmind 		npf_rule_t *rl = NULL;
    356   1.1     rmind 
    357   1.1     rmind 		/* Generate a single rule. */
    358  1.21     rmind 		error = npf_mk_singlerule(rldict, rpset, &rl, errdict);
    359   1.6     rmind 		if (error) {
    360   1.1     rmind 			break;
    361   1.6     rmind 		}
    362   1.6     rmind 		npf_ruleset_insert(rlset, rl);
    363   1.1     rmind 	}
    364   1.1     rmind 	prop_object_iterator_release(it);
    365   1.1     rmind 	/*
    366   1.4     rmind 	 * Note: in a case of error, caller will free the ruleset.
    367   1.1     rmind 	 */
    368   1.1     rmind 	return error;
    369   1.1     rmind }
    370   1.1     rmind 
    371   1.6     rmind static int __noinline
    372  1.12     rmind npf_mk_natlist(npf_ruleset_t *nset, prop_array_t natlist,
    373  1.12     rmind     prop_dictionary_t errdict)
    374   1.1     rmind {
    375   1.1     rmind 	prop_object_iterator_t it;
    376   1.1     rmind 	prop_dictionary_t natdict;
    377   1.1     rmind 	int error;
    378   1.1     rmind 
    379   1.1     rmind 	/* NAT policies - array. */
    380  1.12     rmind 	if (prop_object_type(natlist) != PROP_TYPE_ARRAY) {
    381  1.12     rmind 		NPF_ERR_DEBUG(errdict);
    382   1.1     rmind 		return EINVAL;
    383  1.12     rmind 	}
    384   1.1     rmind 
    385   1.4     rmind 	error = 0;
    386   1.1     rmind 	it = prop_array_iterator(natlist);
    387   1.1     rmind 	while ((natdict = prop_object_iterator_next(it)) != NULL) {
    388  1.21     rmind 		npf_rule_t *rl = NULL;
    389   1.1     rmind 		npf_natpolicy_t *np;
    390   1.1     rmind 
    391   1.1     rmind 		/* NAT policy - dictionary. */
    392   1.1     rmind 		if (prop_object_type(natdict) != PROP_TYPE_DICTIONARY) {
    393  1.12     rmind 			NPF_ERR_DEBUG(errdict);
    394   1.1     rmind 			error = EINVAL;
    395   1.1     rmind 			break;
    396   1.1     rmind 		}
    397   1.1     rmind 
    398   1.1     rmind 		/*
    399   1.1     rmind 		 * NAT policies are standard rules, plus additional
    400   1.1     rmind 		 * information for translation.  Make a rule.
    401   1.1     rmind 		 */
    402  1.12     rmind 		error = npf_mk_singlerule(natdict, NULL, &rl, errdict);
    403   1.6     rmind 		if (error) {
    404   1.1     rmind 			break;
    405   1.6     rmind 		}
    406   1.6     rmind 		npf_ruleset_insert(nset, rl);
    407   1.6     rmind 
    408   1.6     rmind 		/* If rule is named, it is a group with NAT policies. */
    409   1.6     rmind 		if (prop_dictionary_get(natdict, "name") &&
    410   1.6     rmind 		    prop_dictionary_get(natdict, "subrules")) {
    411   1.6     rmind 			continue;
    412   1.6     rmind 		}
    413   1.1     rmind 
    414   1.1     rmind 		/* Allocate a new NAT policy and assign to the rule. */
    415   1.5     rmind 		np = npf_nat_newpolicy(natdict, nset);
    416   1.1     rmind 		if (np == NULL) {
    417  1.12     rmind 			NPF_ERR_DEBUG(errdict);
    418   1.1     rmind 			error = ENOMEM;
    419   1.1     rmind 			break;
    420   1.1     rmind 		}
    421   1.1     rmind 		npf_rule_setnat(rl, np);
    422   1.1     rmind 	}
    423   1.1     rmind 	prop_object_iterator_release(it);
    424   1.1     rmind 	/*
    425   1.1     rmind 	 * Note: in a case of error, caller will free entire NAT ruleset
    426   1.1     rmind 	 * with assigned NAT policies.
    427   1.1     rmind 	 */
    428   1.1     rmind 	return error;
    429   1.1     rmind }
    430   1.1     rmind 
    431   1.1     rmind /*
    432   1.1     rmind  * npfctl_reload: store passed data i.e. update settings, create passed
    433   1.1     rmind  * tables, rules and atomically activate all them.
    434   1.1     rmind  */
    435   1.1     rmind int
    436   1.1     rmind npfctl_reload(u_long cmd, void *data)
    437   1.1     rmind {
    438  1.12     rmind 	struct plistref *pref = data;
    439  1.14     rmind 	prop_dictionary_t npf_dict, errdict;
    440  1.24  christos 	prop_array_t alglist, natlist, tables, rprocs, rules;
    441   1.1     rmind 	npf_tableset_t *tblset = NULL;
    442  1.21     rmind 	npf_rprocset_t *rpset = NULL;
    443   1.1     rmind 	npf_ruleset_t *rlset = NULL;
    444   1.1     rmind 	npf_ruleset_t *nset = NULL;
    445  1.20     rmind 	uint32_t ver = 0;
    446  1.21     rmind 	size_t nitems;
    447  1.11     rmind 	bool flush;
    448   1.1     rmind 	int error;
    449   1.1     rmind 
    450   1.1     rmind 	/* Retrieve the dictionary. */
    451  1.15     rmind #ifndef _NPF_TESTING
    452  1.14     rmind 	error = prop_dictionary_copyin_ioctl(pref, cmd, &npf_dict);
    453   1.1     rmind 	if (error)
    454   1.1     rmind 		return error;
    455   1.1     rmind #else
    456  1.15     rmind 	npf_dict = (prop_dictionary_t)pref;
    457   1.1     rmind #endif
    458  1.15     rmind 
    459  1.20     rmind 	/* Dictionary for error reporting and version check. */
    460  1.12     rmind 	errdict = prop_dictionary_create();
    461  1.20     rmind 	prop_dictionary_get_uint32(npf_dict, "version", &ver);
    462  1.20     rmind 	if (ver != NPF_VERSION) {
    463  1.20     rmind 		error = EPROGMISMATCH;
    464  1.20     rmind 		goto fail;
    465  1.20     rmind 	}
    466  1.12     rmind 
    467  1.24  christos 	/* ALGs. */
    468  1.24  christos 	alglist = prop_dictionary_get(npf_dict, "algs");
    469  1.24  christos 	error = npf_mk_algs(alglist, errdict);
    470  1.24  christos 	if (error) {
    471  1.24  christos 		goto fail;
    472  1.24  christos 	}
    473  1.24  christos 
    474   1.1     rmind 	/* NAT policies. */
    475  1.14     rmind 	natlist = prop_dictionary_get(npf_dict, "translation");
    476  1.30     rmind 	if ((nitems = prop_array_count(natlist)) > NPF_MAX_RULES) {
    477  1.30     rmind 		goto fail;
    478  1.30     rmind 	}
    479  1.21     rmind 
    480  1.21     rmind 	nset = npf_ruleset_create(nitems);
    481  1.12     rmind 	error = npf_mk_natlist(nset, natlist, errdict);
    482  1.10     rmind 	if (error) {
    483   1.1     rmind 		goto fail;
    484  1.10     rmind 	}
    485   1.1     rmind 
    486   1.1     rmind 	/* Tables. */
    487  1.14     rmind 	tables = prop_dictionary_get(npf_dict, "tables");
    488  1.32     rmind 	if ((nitems = prop_array_count(tables)) > NPF_MAX_TABLES) {
    489  1.32     rmind 		goto fail;
    490  1.32     rmind 	}
    491  1.32     rmind 	tblset = npf_tableset_create(nitems);
    492  1.12     rmind 	error = npf_mk_tables(tblset, tables, errdict);
    493  1.10     rmind 	if (error) {
    494   1.1     rmind 		goto fail;
    495  1.10     rmind 	}
    496   1.1     rmind 
    497  1.21     rmind 	/* Rule procedures. */
    498  1.32     rmind 	rprocs = prop_dictionary_get(npf_dict, "rprocs");
    499  1.32     rmind 	if ((nitems = prop_array_count(rprocs)) > NPF_MAX_RPROCS) {
    500  1.32     rmind 		goto fail;
    501  1.32     rmind 	}
    502  1.21     rmind 	rpset = npf_rprocset_create();
    503  1.21     rmind 	error = npf_mk_rprocs(rpset, rprocs, errdict);
    504  1.21     rmind 	if (error) {
    505  1.21     rmind 		goto fail;
    506  1.21     rmind 	}
    507  1.21     rmind 
    508  1.21     rmind 	/* Rules. */
    509  1.14     rmind 	rules = prop_dictionary_get(npf_dict, "rules");
    510  1.30     rmind 	if ((nitems = prop_array_count(rules)) > NPF_MAX_RULES) {
    511  1.30     rmind 		goto fail;
    512  1.30     rmind 	}
    513  1.21     rmind 
    514  1.21     rmind 	rlset = npf_ruleset_create(nitems);
    515  1.21     rmind 	error = npf_mk_rules(rlset, rules, rpset, errdict);
    516  1.10     rmind 	if (error) {
    517   1.1     rmind 		goto fail;
    518  1.10     rmind 	}
    519   1.1     rmind 
    520  1.11     rmind 	flush = false;
    521  1.14     rmind 	prop_dictionary_get_bool(npf_dict, "flush", &flush);
    522  1.11     rmind 
    523   1.1     rmind 	/*
    524  1.21     rmind 	 * Finally - perform the reload.
    525   1.1     rmind 	 */
    526  1.21     rmind 	npf_config_reload(npf_dict, rlset, tblset, nset, rpset, flush);
    527   1.1     rmind 
    528  1.11     rmind 	/* Turn on/off session tracking accordingly. */
    529  1.11     rmind 	npf_session_tracking(!flush);
    530  1.11     rmind 
    531   1.1     rmind 	/* Done.  Since data is consumed now, we shall not destroy it. */
    532   1.1     rmind 	tblset = NULL;
    533  1.21     rmind 	rpset = NULL;
    534   1.1     rmind 	rlset = NULL;
    535   1.1     rmind 	nset = NULL;
    536   1.1     rmind fail:
    537   1.1     rmind 	/*
    538   1.1     rmind 	 * Note: destroy rulesets first, to drop references to the tableset.
    539   1.1     rmind 	 */
    540  1.21     rmind 	KASSERT(error == 0 || (nset || rpset || rlset || tblset));
    541   1.1     rmind 	if (nset) {
    542   1.1     rmind 		npf_ruleset_destroy(nset);
    543   1.1     rmind 	}
    544   1.1     rmind 	if (rlset) {
    545   1.1     rmind 		npf_ruleset_destroy(rlset);
    546   1.1     rmind 	}
    547  1.21     rmind 	if (rpset) {
    548  1.21     rmind 		npf_rprocset_destroy(rpset);
    549  1.21     rmind 	}
    550   1.1     rmind 	if (tblset) {
    551   1.1     rmind 		npf_tableset_destroy(tblset);
    552   1.1     rmind 	}
    553  1.14     rmind 	if (error) {
    554  1.14     rmind 		prop_object_release(npf_dict);
    555  1.14     rmind 	}
    556  1.12     rmind 
    557  1.12     rmind 	/* Error report. */
    558  1.18     rmind #ifndef _NPF_TESTING
    559  1.12     rmind 	prop_dictionary_set_int32(errdict, "errno", error);
    560  1.12     rmind 	prop_dictionary_copyout_ioctl(pref, cmd, errdict);
    561  1.18     rmind 	prop_object_release(errdict);
    562  1.18     rmind 	error = 0;
    563  1.13     rmind #endif
    564  1.18     rmind 	return error;
    565   1.6     rmind }
    566   1.6     rmind 
    567  1.21     rmind /*
    568  1.21     rmind  * npfctl_rule: add or remove dynamic rules in the specified ruleset.
    569  1.21     rmind  */
    570  1.14     rmind int
    571  1.21     rmind npfctl_rule(u_long cmd, void *data)
    572  1.14     rmind {
    573  1.14     rmind 	struct plistref *pref = data;
    574  1.21     rmind 	prop_dictionary_t npf_rule, retdict = NULL;
    575  1.21     rmind 	npf_ruleset_t *rlset;
    576  1.21     rmind 	npf_rule_t *rl = NULL;
    577  1.21     rmind 	const char *ruleset_name;
    578  1.21     rmind 	uint32_t rcmd = 0;
    579  1.14     rmind 	int error;
    580  1.14     rmind 
    581  1.21     rmind 	error = prop_dictionary_copyin_ioctl(pref, cmd, &npf_rule);
    582  1.21     rmind 	if (error) {
    583  1.21     rmind 		return error;
    584  1.21     rmind 	}
    585  1.21     rmind 	prop_dictionary_get_uint32(npf_rule, "command", &rcmd);
    586  1.21     rmind 	if (!prop_dictionary_get_cstring_nocopy(npf_rule,
    587  1.21     rmind 	    "ruleset-name", &ruleset_name)) {
    588  1.27     rmind 		error = EINVAL;
    589  1.27     rmind 		goto out;
    590  1.21     rmind 	}
    591  1.21     rmind 
    592  1.21     rmind 	if (rcmd == NPF_CMD_RULE_ADD) {
    593  1.27     rmind 		retdict = prop_dictionary_create();
    594  1.27     rmind 		if (npf_mk_singlerule(npf_rule, NULL, &rl, retdict) != 0) {
    595  1.27     rmind 			error = EINVAL;
    596  1.27     rmind 			goto out;
    597  1.21     rmind 		}
    598  1.21     rmind 	}
    599  1.21     rmind 
    600  1.21     rmind 	npf_config_enter();
    601  1.21     rmind 	rlset = npf_config_ruleset();
    602  1.21     rmind 
    603  1.21     rmind 	switch (rcmd) {
    604  1.21     rmind 	case NPF_CMD_RULE_ADD: {
    605  1.21     rmind 		if ((error = npf_ruleset_add(rlset, ruleset_name, rl)) == 0) {
    606  1.21     rmind 			/* Success. */
    607  1.23     rmind 			uint64_t id = npf_rule_getid(rl);
    608  1.23     rmind 			prop_dictionary_set_uint64(retdict, "id", id);
    609  1.21     rmind 			rl = NULL;
    610  1.21     rmind 		}
    611  1.21     rmind 		break;
    612  1.21     rmind 	}
    613  1.21     rmind 	case NPF_CMD_RULE_REMOVE: {
    614  1.23     rmind 		uint64_t id;
    615  1.21     rmind 
    616  1.23     rmind 		if (!prop_dictionary_get_uint64(npf_rule, "id", &id)) {
    617  1.21     rmind 			error = EINVAL;
    618  1.21     rmind 			break;
    619  1.21     rmind 		}
    620  1.23     rmind 		error = npf_ruleset_remove(rlset, ruleset_name, id);
    621  1.21     rmind 		break;
    622  1.21     rmind 	}
    623  1.21     rmind 	case NPF_CMD_RULE_REMKEY: {
    624  1.21     rmind 		prop_object_t obj = prop_dictionary_get(npf_rule, "key");
    625  1.21     rmind 		const void *key = prop_data_data_nocopy(obj);
    626  1.21     rmind 		size_t len = prop_data_size(obj);
    627  1.21     rmind 
    628  1.21     rmind 		if (len == 0 || len > NPF_RULE_MAXKEYLEN) {
    629  1.21     rmind 			error = EINVAL;
    630  1.21     rmind 			break;
    631  1.21     rmind 		}
    632  1.22     rmind 		error = npf_ruleset_remkey(rlset, ruleset_name, key, len);
    633  1.22     rmind 		break;
    634  1.22     rmind 	}
    635  1.22     rmind 	case NPF_CMD_RULE_LIST: {
    636  1.22     rmind 		retdict = npf_ruleset_list(rlset, ruleset_name);
    637  1.22     rmind 		break;
    638  1.22     rmind 	}
    639  1.22     rmind 	case NPF_CMD_RULE_FLUSH: {
    640  1.22     rmind 		error = npf_ruleset_flush(rlset, ruleset_name);
    641  1.21     rmind 		break;
    642  1.21     rmind 	}
    643  1.21     rmind 	default:
    644  1.21     rmind 		error = EINVAL;
    645  1.21     rmind 		break;
    646  1.21     rmind 	}
    647  1.22     rmind 
    648  1.22     rmind 	/* Destroy any removed rules. */
    649  1.22     rmind 	if (!error && rcmd != NPF_CMD_RULE_ADD && rcmd != NPF_CMD_RULE_LIST) {
    650  1.22     rmind 		npf_config_sync();
    651  1.22     rmind 		npf_ruleset_gc(rlset);
    652  1.22     rmind 	}
    653  1.21     rmind 	npf_config_exit();
    654  1.14     rmind 
    655  1.21     rmind 	if (rl) {
    656  1.21     rmind 		npf_rule_free(rl);
    657  1.21     rmind 	}
    658  1.27     rmind out:
    659  1.21     rmind 	if (retdict) {
    660  1.21     rmind 		prop_object_release(npf_rule);
    661  1.21     rmind 		prop_dictionary_copyout_ioctl(pref, cmd, retdict);
    662  1.21     rmind 		prop_object_release(retdict);
    663  1.21     rmind 	}
    664  1.14     rmind 	return error;
    665  1.14     rmind }
    666  1.14     rmind 
    667   1.6     rmind /*
    668  1.21     rmind  * npfctl_getconf: return the config dictionary as it was submitted.
    669  1.21     rmind  * Additionally, indicate whether the ruleset is currently active.
    670   1.6     rmind  */
    671   1.6     rmind int
    672  1.21     rmind npfctl_getconf(u_long cmd, void *data)
    673   1.6     rmind {
    674  1.12     rmind 	struct plistref *pref = data;
    675  1.21     rmind 	prop_dictionary_t npf_dict;
    676   1.6     rmind 	int error;
    677   1.6     rmind 
    678  1.21     rmind 	npf_config_enter();
    679  1.21     rmind 	npf_dict = npf_config_dict();
    680  1.21     rmind 	prop_dictionary_set_bool(npf_dict, "active", npf_pfil_registered_p());
    681  1.21     rmind 	error = prop_dictionary_copyout_ioctl(pref, cmd, npf_dict);
    682  1.21     rmind 	npf_config_exit();
    683  1.12     rmind 
    684   1.1     rmind 	return error;
    685   1.1     rmind }
    686   1.1     rmind 
    687   1.1     rmind /*
    688   1.4     rmind  * npfctl_sessions_save: construct a list of sessions and export for saving.
    689   1.4     rmind  */
    690   1.4     rmind int
    691   1.4     rmind npfctl_sessions_save(u_long cmd, void *data)
    692   1.4     rmind {
    693   1.4     rmind 	struct plistref *pref = data;
    694   1.4     rmind 	prop_dictionary_t sesdict;
    695   1.4     rmind 	prop_array_t selist, nplist;
    696   1.4     rmind 	int error;
    697   1.4     rmind 
    698   1.4     rmind 	/* Create a dictionary and two lists. */
    699   1.4     rmind 	sesdict = prop_dictionary_create();
    700   1.4     rmind 	selist = prop_array_create();
    701   1.4     rmind 	nplist = prop_array_create();
    702   1.4     rmind 
    703   1.4     rmind 	/* Save the sessions. */
    704   1.4     rmind 	error = npf_session_save(selist, nplist);
    705   1.4     rmind 	if (error) {
    706   1.4     rmind 		goto fail;
    707   1.4     rmind 	}
    708   1.4     rmind 
    709   1.4     rmind 	/* Set the session list, NAT policy list and export the dictionary. */
    710   1.4     rmind 	prop_dictionary_set(sesdict, "session-list", selist);
    711   1.4     rmind 	prop_dictionary_set(sesdict, "nat-policy-list", nplist);
    712   1.4     rmind 	error = prop_dictionary_copyout_ioctl(pref, cmd, sesdict);
    713   1.4     rmind fail:
    714   1.4     rmind 	prop_object_release(sesdict);
    715   1.4     rmind 	return error;
    716   1.4     rmind }
    717   1.4     rmind 
    718   1.4     rmind /*
    719   1.4     rmind  * npfctl_sessions_load: import a list of sessions, reconstruct them and load.
    720   1.4     rmind  */
    721   1.4     rmind int
    722   1.4     rmind npfctl_sessions_load(u_long cmd, void *data)
    723   1.4     rmind {
    724   1.4     rmind 	const struct plistref *pref = data;
    725   1.4     rmind 	npf_sehash_t *sehasht = NULL;
    726   1.4     rmind 	prop_dictionary_t sesdict, sedict;
    727   1.4     rmind 	prop_object_iterator_t it;
    728   1.4     rmind 	prop_array_t selist;
    729   1.4     rmind 	int error;
    730   1.4     rmind 
    731   1.4     rmind 	/* Retrieve the dictionary containing session and NAT policy lists. */
    732   1.4     rmind 	error = prop_dictionary_copyin_ioctl(pref, cmd, &sesdict);
    733   1.4     rmind 	if (error)
    734   1.4     rmind 		return error;
    735  1.15     rmind 
    736   1.4     rmind 	/*
    737   1.4     rmind 	 * Note: session objects contain the references to the NAT policy
    738   1.4     rmind 	 * entries.  Therefore, no need to directly access it.
    739   1.4     rmind 	 */
    740   1.4     rmind 	selist = prop_dictionary_get(sesdict, "session-list");
    741   1.4     rmind 	if (prop_object_type(selist) != PROP_TYPE_ARRAY) {
    742  1.21     rmind 		prop_object_release(selist);
    743  1.21     rmind 		return EINVAL;
    744   1.4     rmind 	}
    745   1.4     rmind 
    746   1.4     rmind 	/* Create a session hash table. */
    747   1.4     rmind 	sehasht = sess_htable_create();
    748   1.4     rmind 
    749   1.4     rmind 	/*
    750  1.21     rmind 	 * Iterate through and construct each session.  Note: acquire the
    751  1.21     rmind 	 * config lock as we access NAT policies during the restore.
    752   1.4     rmind 	 */
    753   1.4     rmind 	error = 0;
    754  1.26     rmind 	it = prop_array_iterator(selist);
    755  1.26     rmind 
    756  1.21     rmind 	npf_config_enter();
    757   1.4     rmind 	while ((sedict = prop_object_iterator_next(it)) != NULL) {
    758   1.4     rmind 		/* Session - dictionary. */
    759   1.4     rmind 		if (prop_object_type(sedict) != PROP_TYPE_DICTIONARY) {
    760   1.4     rmind 			error = EINVAL;
    761  1.26     rmind 			break;
    762   1.4     rmind 		}
    763   1.4     rmind 		/* Construct and insert real session structure. */
    764   1.4     rmind 		error = npf_session_restore(sehasht, sedict);
    765   1.4     rmind 		if (error) {
    766  1.26     rmind 			break;
    767   1.4     rmind 		}
    768   1.4     rmind 	}
    769  1.21     rmind 	npf_config_exit();
    770  1.26     rmind 
    771  1.21     rmind 	prop_object_iterator_release(it);
    772   1.4     rmind 	prop_object_release(selist);
    773  1.26     rmind 
    774  1.26     rmind 	if (!error) {
    775  1.26     rmind 		/* Finally, load the new table. */
    776  1.26     rmind 		npf_session_load(sehasht);
    777  1.26     rmind 	} else {
    778   1.4     rmind 		/* Destroy session table. */
    779   1.4     rmind 		sess_htable_destroy(sehasht);
    780   1.4     rmind 	}
    781   1.4     rmind 	return error;
    782   1.4     rmind }
    783   1.4     rmind 
    784   1.4     rmind /*
    785   1.2     rmind  * npfctl_table: add, remove or query entries in the specified table.
    786   1.1     rmind  *
    787   1.1     rmind  * For maximum performance, interface is avoiding proplib(3)'s overhead.
    788   1.1     rmind  */
    789   1.1     rmind int
    790   1.1     rmind npfctl_table(void *data)
    791   1.1     rmind {
    792  1.19     rmind 	const npf_ioctl_table_t *nct = data;
    793  1.32     rmind 	char tname[NPF_TABLE_MAXNAMELEN];
    794  1.32     rmind 	npf_tableset_t *ts;
    795  1.32     rmind 	npf_table_t *t;
    796  1.32     rmind 	int s, error;
    797  1.32     rmind 
    798  1.32     rmind 	error = copyinstr(nct->nct_name, tname, sizeof(tname), NULL);
    799  1.32     rmind 	if (error) {
    800  1.32     rmind 		return error;
    801  1.32     rmind 	}
    802   1.1     rmind 
    803  1.32     rmind 	s = npf_config_read_enter(); /* XXX */
    804  1.32     rmind 	ts = npf_config_tableset();
    805  1.32     rmind 	if ((t = npf_tableset_getbyname(ts, tname)) == NULL) {
    806  1.32     rmind 		npf_config_read_exit(s);
    807  1.32     rmind 		return EINVAL;
    808  1.32     rmind 	}
    809  1.21     rmind 
    810  1.21     rmind 	switch (nct->nct_cmd) {
    811  1.21     rmind 	case NPF_CMD_TABLE_LOOKUP:
    812  1.32     rmind 		error = npf_table_lookup(t, nct->nct_data.ent.alen,
    813  1.32     rmind 		    &nct->nct_data.ent.addr);
    814  1.20     rmind 		break;
    815  1.21     rmind 	case NPF_CMD_TABLE_ADD:
    816  1.32     rmind 		error = npf_table_insert(t, nct->nct_data.ent.alen,
    817  1.32     rmind 		    &nct->nct_data.ent.addr, nct->nct_data.ent.mask);
    818   1.1     rmind 		break;
    819  1.21     rmind 	case NPF_CMD_TABLE_REMOVE:
    820  1.32     rmind 		error = npf_table_remove(t, nct->nct_data.ent.alen,
    821  1.32     rmind 		    &nct->nct_data.ent.addr, nct->nct_data.ent.mask);
    822  1.19     rmind 		break;
    823  1.21     rmind 	case NPF_CMD_TABLE_LIST:
    824  1.32     rmind 		error = npf_table_list(t, nct->nct_data.buf.buf,
    825  1.32     rmind 		    nct->nct_data.buf.len);
    826   1.1     rmind 		break;
    827  1.25     rmind 	case NPF_CMD_TABLE_FLUSH:
    828  1.32     rmind 		error = npf_table_flush(t);
    829  1.25     rmind 		break;
    830   1.1     rmind 	default:
    831  1.19     rmind 		error = EINVAL;
    832  1.19     rmind 		break;
    833   1.1     rmind 	}
    834  1.32     rmind 	npf_config_read_exit(s);
    835  1.21     rmind 
    836   1.1     rmind 	return error;
    837   1.1     rmind }
    838