Home | History | Annotate | Line # | Download | only in libnpf
npf.c revision 1.11
      1  1.11     rmind /*	$NetBSD: npf.c,v 1.11 2012/08/12 03:35:14 rmind Exp $	*/
      2   1.1     rmind 
      3   1.1     rmind /*-
      4   1.6     rmind  * Copyright (c) 2010-2012 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 #include <sys/cdefs.h>
     33  1.11     rmind __KERNEL_RCSID(0, "$NetBSD: npf.c,v 1.11 2012/08/12 03:35:14 rmind Exp $");
     34   1.1     rmind 
     35   1.1     rmind #include <sys/types.h>
     36   1.1     rmind #include <netinet/in_systm.h>
     37   1.1     rmind #include <netinet/in.h>
     38  1.11     rmind #include <net/if.h>
     39   1.1     rmind #include <prop/proplib.h>
     40   1.1     rmind 
     41   1.1     rmind #include <stdlib.h>
     42   1.1     rmind #include <string.h>
     43   1.7     rmind #include <assert.h>
     44   1.1     rmind #include <errno.h>
     45   1.1     rmind #include <err.h>
     46   1.1     rmind 
     47   1.1     rmind #define	_NPF_PRIVATE
     48   1.1     rmind #include "npf.h"
     49   1.1     rmind 
     50   1.1     rmind struct nl_config {
     51   1.1     rmind 	/* Rules, translations, tables, procedures. */
     52   1.8     rmind 	prop_dictionary_t	ncf_dict;
     53   1.1     rmind 	prop_array_t		ncf_rules_list;
     54   1.1     rmind 	prop_array_t		ncf_rproc_list;
     55   1.1     rmind 	prop_array_t		ncf_table_list;
     56   1.1     rmind 	prop_array_t		ncf_nat_list;
     57   1.1     rmind 	/* Priority counters. */
     58   1.1     rmind 	pri_t			ncf_rule_pri;
     59   1.1     rmind 	pri_t			ncf_nat_pri;
     60  1.11     rmind 	/* Debug information. */
     61  1.11     rmind 	prop_dictionary_t	ncf_debug;
     62   1.7     rmind 	/* Error report. */
     63   1.7     rmind 	prop_dictionary_t	ncf_err;
     64   1.4     rmind 	/* Custom file to externalise property-list. */
     65   1.4     rmind 	const char *		ncf_plist;
     66   1.6     rmind 	bool			ncf_flush;
     67   1.1     rmind };
     68   1.1     rmind 
     69   1.1     rmind struct nl_rule {
     70   1.1     rmind 	prop_dictionary_t	nrl_dict;
     71   1.1     rmind };
     72   1.1     rmind 
     73   1.1     rmind struct nl_rproc {
     74   1.1     rmind 	prop_dictionary_t	nrp_dict;
     75   1.1     rmind };
     76   1.1     rmind 
     77   1.1     rmind struct nl_table {
     78   1.1     rmind 	prop_dictionary_t	ntl_dict;
     79   1.1     rmind };
     80   1.1     rmind 
     81   1.1     rmind /*
     82   1.1     rmind  * CONFIGURATION INTERFACE.
     83   1.1     rmind  */
     84   1.1     rmind 
     85   1.1     rmind nl_config_t *
     86   1.1     rmind npf_config_create(void)
     87   1.1     rmind {
     88   1.1     rmind 	nl_config_t *ncf;
     89   1.1     rmind 
     90   1.7     rmind 	ncf = calloc(1, sizeof(*ncf));
     91   1.1     rmind 	if (ncf == NULL) {
     92   1.1     rmind 		return NULL;
     93   1.1     rmind 	}
     94   1.1     rmind 	ncf->ncf_rules_list = prop_array_create();
     95   1.1     rmind 	ncf->ncf_rproc_list = prop_array_create();
     96   1.1     rmind 	ncf->ncf_table_list = prop_array_create();
     97   1.1     rmind 	ncf->ncf_nat_list = prop_array_create();
     98   1.1     rmind 
     99   1.1     rmind 	ncf->ncf_rule_pri = 1;
    100   1.1     rmind 	ncf->ncf_nat_pri = 1;
    101   1.1     rmind 
    102   1.4     rmind 	ncf->ncf_plist = NULL;
    103   1.6     rmind 	ncf->ncf_flush = false;
    104   1.4     rmind 
    105   1.1     rmind 	return ncf;
    106   1.1     rmind }
    107   1.1     rmind 
    108   1.1     rmind int
    109   1.1     rmind npf_config_submit(nl_config_t *ncf, int fd)
    110   1.1     rmind {
    111   1.7     rmind 	const char *plist = ncf->ncf_plist;
    112   1.1     rmind 	prop_dictionary_t npf_dict;
    113   1.1     rmind 	int error = 0;
    114   1.1     rmind 
    115   1.1     rmind 	npf_dict = prop_dictionary_create();
    116   1.1     rmind 	if (npf_dict == NULL) {
    117   1.1     rmind 		return ENOMEM;
    118   1.1     rmind 	}
    119  1.11     rmind 	if (ncf->ncf_debug) {
    120  1.11     rmind 		prop_dictionary_set(npf_dict, "debug", ncf->ncf_debug);
    121  1.11     rmind 	}
    122   1.1     rmind 	prop_dictionary_set(npf_dict, "rules", ncf->ncf_rules_list);
    123   1.1     rmind 	prop_dictionary_set(npf_dict, "rprocs", ncf->ncf_rproc_list);
    124   1.1     rmind 	prop_dictionary_set(npf_dict, "tables", ncf->ncf_table_list);
    125   1.1     rmind 	prop_dictionary_set(npf_dict, "translation", ncf->ncf_nat_list);
    126   1.6     rmind 	prop_dictionary_set_bool(npf_dict, "flush", ncf->ncf_flush);
    127   1.1     rmind 
    128   1.4     rmind 	if (plist) {
    129   1.4     rmind 		if (!prop_dictionary_externalize_to_file(npf_dict, plist)) {
    130   1.4     rmind 			error = errno;
    131   1.4     rmind 		}
    132   1.7     rmind 		prop_object_release(npf_dict);
    133   1.7     rmind 		return error;
    134   1.7     rmind 	}
    135   1.7     rmind 
    136   1.7     rmind 	error = prop_dictionary_sendrecv_ioctl(npf_dict, fd,
    137   1.7     rmind 	    IOC_NPF_RELOAD, &ncf->ncf_err);
    138   1.7     rmind 	if (error) {
    139   1.7     rmind 		prop_object_release(npf_dict);
    140   1.7     rmind 		assert(ncf->ncf_err == NULL);
    141   1.7     rmind 		return error;
    142   1.1     rmind 	}
    143   1.7     rmind 
    144   1.7     rmind 	prop_dictionary_get_int32(ncf->ncf_err, "errno", &error);
    145   1.1     rmind 	prop_object_release(npf_dict);
    146   1.1     rmind 	return error;
    147   1.1     rmind }
    148   1.1     rmind 
    149   1.8     rmind nl_config_t *
    150   1.8     rmind npf_config_retrieve(int fd, bool *active, bool *loaded)
    151   1.8     rmind {
    152   1.8     rmind 	prop_dictionary_t npf_dict;
    153   1.8     rmind 	nl_config_t *ncf;
    154   1.8     rmind 	int error;
    155   1.8     rmind 
    156   1.8     rmind 	error = prop_dictionary_recv_ioctl(fd, IOC_NPF_GETCONF, &npf_dict);
    157   1.8     rmind 	if (error) {
    158   1.8     rmind 		return NULL;
    159   1.8     rmind 	}
    160   1.8     rmind 	ncf = calloc(1, sizeof(*ncf));
    161   1.8     rmind 	if (ncf == NULL) {
    162   1.8     rmind 		prop_object_release(npf_dict);
    163   1.8     rmind 		return NULL;
    164   1.8     rmind 	}
    165   1.8     rmind 	ncf->ncf_dict = npf_dict;
    166   1.8     rmind 	ncf->ncf_rules_list = prop_dictionary_get(npf_dict, "rules");
    167   1.8     rmind 	ncf->ncf_rproc_list = prop_dictionary_get(npf_dict, "rprocs");
    168   1.8     rmind 	ncf->ncf_table_list = prop_dictionary_get(npf_dict, "tables");
    169   1.8     rmind 	ncf->ncf_nat_list = prop_dictionary_get(npf_dict, "translation");
    170   1.8     rmind 
    171   1.8     rmind 	prop_dictionary_get_bool(npf_dict, "active", active);
    172   1.8     rmind 	*loaded = (ncf->ncf_rules_list != NULL);
    173   1.8     rmind 	return ncf;
    174   1.8     rmind }
    175   1.8     rmind 
    176   1.6     rmind int
    177   1.6     rmind npf_config_flush(int fd)
    178   1.6     rmind {
    179   1.6     rmind 	nl_config_t *ncf;
    180   1.6     rmind 	int error;
    181   1.6     rmind 
    182   1.6     rmind 	ncf = npf_config_create();
    183   1.6     rmind 	if (ncf == NULL) {
    184   1.6     rmind 		return ENOMEM;
    185   1.6     rmind 	}
    186   1.6     rmind 	ncf->ncf_flush = true;
    187   1.6     rmind 	error = npf_config_submit(ncf, fd);
    188   1.6     rmind 	npf_config_destroy(ncf);
    189   1.6     rmind 	return error;
    190   1.6     rmind }
    191   1.6     rmind 
    192   1.1     rmind void
    193   1.7     rmind _npf_config_error(nl_config_t *ncf, nl_error_t *ne)
    194   1.7     rmind {
    195   1.7     rmind 	memset(ne, 0, sizeof(*ne));
    196   1.7     rmind 	prop_dictionary_get_int32(ncf->ncf_err, "id", &ne->ne_id);
    197   1.7     rmind 	prop_dictionary_get_cstring(ncf->ncf_err,
    198   1.7     rmind 	    "source-file", &ne->ne_source_file);
    199   1.7     rmind 	prop_dictionary_get_uint32(ncf->ncf_err,
    200   1.7     rmind 	    "source-line", &ne->ne_source_line);
    201   1.7     rmind 	prop_dictionary_get_int32(ncf->ncf_err,
    202   1.7     rmind 	    "ncode-error", &ne->ne_ncode_error);
    203   1.7     rmind 	prop_dictionary_get_int32(ncf->ncf_err,
    204   1.7     rmind 	    "ncode-errat", &ne->ne_ncode_errat);
    205   1.7     rmind }
    206   1.7     rmind 
    207   1.7     rmind void
    208   1.1     rmind npf_config_destroy(nl_config_t *ncf)
    209   1.1     rmind {
    210   1.1     rmind 
    211   1.8     rmind 	if (ncf->ncf_dict == NULL) {
    212   1.8     rmind 		prop_object_release(ncf->ncf_rules_list);
    213   1.8     rmind 		prop_object_release(ncf->ncf_rproc_list);
    214   1.8     rmind 		prop_object_release(ncf->ncf_table_list);
    215   1.8     rmind 		prop_object_release(ncf->ncf_nat_list);
    216   1.8     rmind 	} else {
    217   1.8     rmind 		prop_object_release(ncf->ncf_dict);
    218   1.8     rmind 	}
    219   1.7     rmind 	if (ncf->ncf_err) {
    220   1.7     rmind 		prop_object_release(ncf->ncf_err);
    221   1.7     rmind 	}
    222  1.11     rmind 	if (ncf->ncf_debug) {
    223  1.11     rmind 		prop_object_release(ncf->ncf_debug);
    224  1.11     rmind 	}
    225   1.1     rmind 	free(ncf);
    226   1.1     rmind }
    227   1.1     rmind 
    228   1.4     rmind void
    229   1.4     rmind _npf_config_setsubmit(nl_config_t *ncf, const char *plist_file)
    230   1.4     rmind {
    231   1.4     rmind 
    232   1.4     rmind 	ncf->ncf_plist = plist_file;
    233   1.4     rmind }
    234   1.4     rmind 
    235   1.1     rmind static bool
    236   1.1     rmind _npf_prop_array_lookup(prop_array_t array, const char *key, const char *name)
    237   1.1     rmind {
    238   1.1     rmind 	prop_dictionary_t dict;
    239   1.1     rmind 	prop_object_iterator_t it;
    240   1.1     rmind 
    241   1.1     rmind 	it = prop_array_iterator(array);
    242   1.1     rmind 	while ((dict = prop_object_iterator_next(it)) != NULL) {
    243   1.1     rmind 		const char *lname;
    244   1.1     rmind 		prop_dictionary_get_cstring_nocopy(dict, key, &lname);
    245   1.1     rmind 		if (strcmp(name, lname) == 0)
    246   1.1     rmind 			break;
    247   1.1     rmind 	}
    248   1.1     rmind 	prop_object_iterator_release(it);
    249   1.1     rmind 	return dict ? true : false;
    250   1.1     rmind }
    251   1.1     rmind 
    252   1.1     rmind /*
    253   1.1     rmind  * RULE INTERFACE.
    254   1.1     rmind  */
    255   1.1     rmind 
    256   1.1     rmind nl_rule_t *
    257   1.1     rmind npf_rule_create(const char *name, uint32_t attr, u_int if_idx)
    258   1.1     rmind {
    259   1.1     rmind 	prop_dictionary_t rldict;
    260   1.1     rmind 	nl_rule_t *rl;
    261   1.1     rmind 
    262   1.5  christos 	rl = malloc(sizeof(*rl));
    263   1.1     rmind 	if (rl == NULL) {
    264   1.1     rmind 		return NULL;
    265   1.1     rmind 	}
    266   1.1     rmind 	rldict = prop_dictionary_create();
    267   1.1     rmind 	if (rldict == NULL) {
    268   1.1     rmind 		free(rl);
    269   1.1     rmind 		return NULL;
    270   1.1     rmind 	}
    271   1.1     rmind 	if (name) {
    272   1.1     rmind 		prop_dictionary_set_cstring(rldict, "name", name);
    273   1.1     rmind 	}
    274   1.1     rmind 	prop_dictionary_set_uint32(rldict, "attributes", attr);
    275   1.1     rmind 
    276   1.1     rmind 	if (if_idx) {
    277   1.1     rmind 		prop_dictionary_set_uint32(rldict, "interface", if_idx);
    278   1.1     rmind 	}
    279   1.1     rmind 	rl->nrl_dict = rldict;
    280   1.1     rmind 	return rl;
    281   1.1     rmind }
    282   1.1     rmind 
    283   1.1     rmind int
    284   1.1     rmind npf_rule_setcode(nl_rule_t *rl, int type, const void *code, size_t sz)
    285   1.1     rmind {
    286   1.1     rmind 	prop_dictionary_t rldict = rl->nrl_dict;
    287   1.1     rmind 	prop_data_t cdata;
    288   1.1     rmind 
    289   1.1     rmind 	if (type != NPF_CODE_NCODE) {
    290   1.1     rmind 		return ENOTSUP;
    291   1.1     rmind 	}
    292   1.1     rmind 	cdata = prop_data_create_data(code, sz);
    293   1.1     rmind 	if (cdata == NULL) {
    294   1.1     rmind 		return ENOMEM;
    295   1.1     rmind 	}
    296   1.1     rmind 	prop_dictionary_set(rldict, "ncode", cdata);
    297   1.1     rmind 	prop_object_release(cdata);
    298   1.1     rmind 	return 0;
    299   1.1     rmind }
    300   1.1     rmind 
    301   1.1     rmind int
    302   1.1     rmind npf_rule_setproc(nl_config_t *ncf, nl_rule_t *rl, const char *name)
    303   1.1     rmind {
    304   1.1     rmind 	prop_dictionary_t rldict = rl->nrl_dict;
    305   1.1     rmind 
    306   1.1     rmind 	if (!npf_rproc_exists_p(ncf, name)) {
    307   1.1     rmind 		return ENOENT;
    308   1.1     rmind 	}
    309   1.1     rmind 	prop_dictionary_set_cstring(rldict, "rproc", name);
    310   1.1     rmind 	return 0;
    311   1.1     rmind }
    312   1.1     rmind 
    313   1.1     rmind bool
    314   1.1     rmind npf_rule_exists_p(nl_config_t *ncf, const char *name)
    315   1.1     rmind {
    316   1.1     rmind 
    317   1.1     rmind 	return _npf_prop_array_lookup(ncf->ncf_rules_list, "name", name);
    318   1.1     rmind }
    319   1.1     rmind 
    320   1.1     rmind int
    321   1.1     rmind npf_rule_insert(nl_config_t *ncf, nl_rule_t *parent, nl_rule_t *rl, pri_t pri)
    322   1.1     rmind {
    323   1.1     rmind 	prop_dictionary_t rldict = rl->nrl_dict;
    324   1.1     rmind 	prop_array_t rlset;
    325   1.1     rmind 
    326   1.1     rmind 	if (pri == NPF_PRI_NEXT) {
    327   1.1     rmind 		pri = ncf->ncf_rule_pri++;
    328   1.1     rmind 	} else if (ncf) {
    329   1.1     rmind 		ncf->ncf_rule_pri = pri + 1;
    330   1.1     rmind 	}
    331   1.1     rmind 	prop_dictionary_set_int32(rldict, "priority", pri);
    332   1.1     rmind 
    333   1.1     rmind 	if (parent) {
    334   1.1     rmind 		prop_dictionary_t pdict = parent->nrl_dict;
    335   1.1     rmind 		rlset = prop_dictionary_get(pdict, "subrules");
    336   1.1     rmind 		if (rlset == NULL) {
    337   1.1     rmind 			rlset = prop_array_create();
    338   1.1     rmind 			prop_dictionary_set(pdict, "subrules", rlset);
    339   1.1     rmind 			prop_object_release(rlset);
    340   1.1     rmind 		}
    341   1.1     rmind 	} else {
    342   1.1     rmind 		rlset = ncf->ncf_rules_list;
    343   1.1     rmind 	}
    344   1.1     rmind 	prop_array_add(rlset, rldict);
    345   1.1     rmind 	return 0;
    346   1.1     rmind }
    347   1.1     rmind 
    348   1.8     rmind static int
    349   1.8     rmind _npf_rule_foreach1(prop_array_t rules, unsigned nlevel, nl_rule_callback_t func)
    350   1.8     rmind {
    351   1.8     rmind 	prop_dictionary_t rldict;
    352   1.8     rmind 	prop_object_iterator_t it;
    353   1.8     rmind 
    354   1.8     rmind 	if (!rules || prop_object_type(rules) != PROP_TYPE_ARRAY) {
    355   1.8     rmind 		return ENOENT;
    356   1.8     rmind 	}
    357   1.8     rmind 	it = prop_array_iterator(rules);
    358   1.8     rmind 	if (it == NULL) {
    359   1.8     rmind 		return ENOMEM;
    360   1.8     rmind 	}
    361   1.8     rmind 	while ((rldict = prop_object_iterator_next(it)) != NULL) {
    362   1.8     rmind 		prop_array_t subrules;
    363   1.8     rmind 		nl_rule_t nrl;
    364   1.8     rmind 
    365   1.8     rmind 		nrl.nrl_dict = rldict;
    366   1.8     rmind 		(*func)(&nrl, nlevel);
    367   1.8     rmind 
    368   1.8     rmind 		subrules = prop_dictionary_get(rldict, "subrules");
    369   1.8     rmind 		(void)_npf_rule_foreach1(subrules, nlevel + 1, func);
    370   1.8     rmind 	}
    371   1.8     rmind 	prop_object_iterator_release(it);
    372   1.8     rmind 	return 0;
    373   1.8     rmind }
    374   1.8     rmind 
    375   1.8     rmind int
    376   1.8     rmind _npf_rule_foreach(nl_config_t *ncf, nl_rule_callback_t func)
    377   1.8     rmind {
    378   1.8     rmind 
    379   1.8     rmind 	return _npf_rule_foreach1(ncf->ncf_rules_list, 0, func);
    380   1.8     rmind }
    381   1.8     rmind 
    382   1.8     rmind pri_t
    383   1.8     rmind _npf_rule_getinfo(nl_rule_t *nrl, const char **rname, uint32_t *attr,
    384   1.8     rmind     u_int *if_idx)
    385   1.8     rmind {
    386   1.8     rmind 	prop_dictionary_t rldict = nrl->nrl_dict;
    387   1.8     rmind 	pri_t prio;
    388   1.8     rmind 
    389   1.8     rmind 	prop_dictionary_get_cstring_nocopy(rldict, "name", rname);
    390   1.8     rmind 	prop_dictionary_get_uint32(rldict, "attributes", attr);
    391   1.8     rmind 	prop_dictionary_get_int32(rldict, "priority", &prio);
    392   1.8     rmind 	prop_dictionary_get_uint32(rldict, "interface", if_idx);
    393   1.8     rmind 	return prio;
    394   1.8     rmind }
    395   1.8     rmind 
    396   1.8     rmind const void *
    397   1.8     rmind _npf_rule_ncode(nl_rule_t *nrl, size_t *size)
    398   1.8     rmind {
    399   1.8     rmind 	prop_dictionary_t rldict = nrl->nrl_dict;
    400   1.8     rmind 	prop_object_t obj = prop_dictionary_get(rldict, "ncode");
    401   1.8     rmind 	*size = prop_data_size(obj);
    402   1.8     rmind 	return prop_data_data_nocopy(obj);
    403   1.8     rmind }
    404   1.8     rmind 
    405   1.8     rmind const char *
    406   1.8     rmind _npf_rule_rproc(nl_rule_t *nrl)
    407   1.8     rmind {
    408   1.8     rmind 	prop_dictionary_t rldict = nrl->nrl_dict;
    409   1.8     rmind 	const char *rpname = NULL;
    410   1.8     rmind 
    411   1.8     rmind 	prop_dictionary_get_cstring_nocopy(rldict, "rproc", &rpname);
    412   1.8     rmind 	return rpname;
    413   1.8     rmind }
    414   1.8     rmind 
    415   1.1     rmind void
    416   1.1     rmind npf_rule_destroy(nl_rule_t *rl)
    417   1.1     rmind {
    418   1.1     rmind 
    419   1.1     rmind 	prop_object_release(rl->nrl_dict);
    420   1.1     rmind 	free(rl);
    421   1.1     rmind }
    422   1.1     rmind 
    423   1.1     rmind /*
    424   1.1     rmind  * RULE PROCEDURE INTERFACE.
    425   1.1     rmind  */
    426   1.1     rmind 
    427   1.1     rmind nl_rproc_t *
    428   1.1     rmind npf_rproc_create(const char *name)
    429   1.1     rmind {
    430   1.1     rmind 	prop_dictionary_t rpdict;
    431   1.1     rmind 	nl_rproc_t *nrp;
    432   1.1     rmind 
    433   1.1     rmind 	nrp = malloc(sizeof(nl_rproc_t));
    434   1.1     rmind 	if (nrp == NULL) {
    435   1.1     rmind 		return NULL;
    436   1.1     rmind 	}
    437   1.1     rmind 	rpdict = prop_dictionary_create();
    438   1.1     rmind 	if (rpdict == NULL) {
    439   1.1     rmind 		free(nrp);
    440   1.1     rmind 		return NULL;
    441   1.1     rmind 	}
    442   1.1     rmind 	prop_dictionary_set_cstring(rpdict, "name", name);
    443   1.1     rmind 	nrp->nrp_dict = rpdict;
    444   1.1     rmind 	return nrp;
    445   1.1     rmind }
    446   1.1     rmind 
    447   1.1     rmind bool
    448   1.1     rmind npf_rproc_exists_p(nl_config_t *ncf, const char *name)
    449   1.1     rmind {
    450   1.1     rmind 
    451   1.1     rmind 	return _npf_prop_array_lookup(ncf->ncf_rproc_list, "name", name);
    452   1.1     rmind }
    453   1.1     rmind 
    454   1.1     rmind int
    455   1.5  christos _npf_rproc_setnorm(nl_rproc_t *rp, bool rnd, bool no_df, u_int minttl,
    456   1.5  christos     u_int maxmss)
    457   1.1     rmind {
    458   1.1     rmind 	prop_dictionary_t rpdict = rp->nrp_dict;
    459   1.2     rmind 	uint32_t fl;
    460   1.1     rmind 
    461   1.1     rmind 	prop_dictionary_set_bool(rpdict, "randomize-id", rnd);
    462   1.1     rmind 	prop_dictionary_set_bool(rpdict, "no-df", no_df);
    463   1.1     rmind 	prop_dictionary_set_uint32(rpdict, "min-ttl", minttl);
    464   1.1     rmind 	prop_dictionary_set_uint32(rpdict, "max-mss", maxmss);
    465   1.1     rmind 
    466   1.2     rmind 	prop_dictionary_get_uint32(rpdict, "flags", &fl);
    467   1.2     rmind 	prop_dictionary_set_uint32(rpdict, "flags", fl | NPF_RPROC_NORMALIZE);
    468   1.1     rmind 	return 0;
    469   1.1     rmind }
    470   1.1     rmind 
    471   1.1     rmind int
    472   1.1     rmind _npf_rproc_setlog(nl_rproc_t *rp, u_int if_idx)
    473   1.1     rmind {
    474   1.1     rmind 	prop_dictionary_t rpdict = rp->nrp_dict;
    475   1.2     rmind 	uint32_t fl;
    476   1.1     rmind 
    477   1.1     rmind 	prop_dictionary_set_uint32(rpdict, "log-interface", if_idx);
    478   1.1     rmind 
    479   1.2     rmind 	prop_dictionary_get_uint32(rpdict, "flags", &fl);
    480   1.2     rmind 	prop_dictionary_set_uint32(rpdict, "flags", fl | NPF_RPROC_LOG);
    481   1.1     rmind 	return 0;
    482   1.1     rmind }
    483   1.1     rmind 
    484   1.1     rmind int
    485   1.1     rmind npf_rproc_insert(nl_config_t *ncf, nl_rproc_t *rp)
    486   1.1     rmind {
    487   1.1     rmind 	prop_dictionary_t rpdict = rp->nrp_dict;
    488   1.1     rmind 	const char *name;
    489   1.1     rmind 
    490   1.1     rmind 	if (!prop_dictionary_get_cstring_nocopy(rpdict, "name", &name)) {
    491   1.1     rmind 		return EINVAL;
    492   1.1     rmind 	}
    493   1.1     rmind 	if (npf_rproc_exists_p(ncf, name)) {
    494   1.1     rmind 		return EEXIST;
    495   1.1     rmind 	}
    496   1.1     rmind 	prop_array_add(ncf->ncf_rproc_list, rpdict);
    497   1.1     rmind 	return 0;
    498   1.1     rmind }
    499   1.1     rmind 
    500   1.1     rmind /*
    501   1.1     rmind  * TRANSLATION INTERFACE.
    502   1.1     rmind  */
    503   1.1     rmind 
    504   1.1     rmind nl_nat_t *
    505   1.5  christos npf_nat_create(int type, u_int flags, u_int if_idx,
    506   1.1     rmind     npf_addr_t *addr, int af, in_port_t port)
    507   1.1     rmind {
    508   1.1     rmind 	nl_rule_t *rl;
    509   1.1     rmind 	prop_dictionary_t rldict;
    510   1.1     rmind 	prop_data_t addrdat;
    511   1.1     rmind 	uint32_t attr;
    512   1.1     rmind 	size_t sz;
    513   1.1     rmind 
    514   1.1     rmind 	if (af == AF_INET) {
    515   1.1     rmind 		sz = sizeof(struct in_addr);
    516   1.1     rmind 	} else if (af == AF_INET6) {
    517   1.1     rmind 		sz = sizeof(struct in6_addr);
    518   1.1     rmind 	} else {
    519   1.1     rmind 		return NULL;
    520   1.1     rmind 	}
    521   1.1     rmind 
    522   1.1     rmind 	attr = NPF_RULE_PASS | NPF_RULE_FINAL |
    523   1.2     rmind 	    (type == NPF_NATOUT ? NPF_RULE_OUT : NPF_RULE_IN);
    524   1.1     rmind 
    525   1.1     rmind 	/* Create a rule for NAT policy.  Next, will add translation data. */
    526   1.1     rmind 	rl = npf_rule_create(NULL, attr, if_idx);
    527   1.1     rmind 	if (rl == NULL) {
    528   1.1     rmind 		return NULL;
    529   1.1     rmind 	}
    530   1.1     rmind 	rldict = rl->nrl_dict;
    531   1.1     rmind 
    532   1.1     rmind 	/* Translation type and flags. */
    533   1.1     rmind 	prop_dictionary_set_int32(rldict, "type", type);
    534   1.1     rmind 	prop_dictionary_set_uint32(rldict, "flags", flags);
    535   1.1     rmind 
    536   1.1     rmind 	/* Translation IP. */
    537   1.1     rmind 	addrdat = prop_data_create_data(addr, sz);
    538   1.1     rmind 	if (addrdat == NULL) {
    539   1.1     rmind 		npf_rule_destroy(rl);
    540   1.1     rmind 		return NULL;
    541   1.1     rmind 	}
    542   1.1     rmind 	prop_dictionary_set(rldict, "translation-ip", addrdat);
    543   1.1     rmind 	prop_object_release(addrdat);
    544   1.1     rmind 
    545   1.1     rmind 	/* Translation port (for redirect case). */
    546   1.1     rmind 	prop_dictionary_set_uint16(rldict, "translation-port", port);
    547   1.1     rmind 
    548   1.1     rmind 	return (nl_nat_t *)rl;
    549   1.1     rmind }
    550   1.1     rmind 
    551   1.1     rmind int
    552   1.1     rmind npf_nat_insert(nl_config_t *ncf, nl_nat_t *nt, pri_t pri)
    553   1.1     rmind {
    554   1.1     rmind 	prop_dictionary_t rldict = nt->nrl_dict;
    555   1.1     rmind 
    556   1.1     rmind 	if (pri == NPF_PRI_NEXT) {
    557   1.1     rmind 		pri = ncf->ncf_nat_pri++;
    558   1.1     rmind 	} else {
    559   1.1     rmind 		ncf->ncf_nat_pri = pri + 1;
    560   1.1     rmind 	}
    561   1.1     rmind 	prop_dictionary_set_int32(rldict, "priority", pri);
    562   1.1     rmind 	prop_array_add(ncf->ncf_nat_list, rldict);
    563   1.1     rmind 	return 0;
    564   1.1     rmind }
    565   1.1     rmind 
    566   1.9     rmind int
    567   1.9     rmind _npf_nat_foreach(nl_config_t *ncf, nl_rule_callback_t func)
    568   1.9     rmind {
    569   1.9     rmind 
    570   1.9     rmind 	return _npf_rule_foreach1(ncf->ncf_nat_list, 0, func);
    571   1.9     rmind }
    572   1.9     rmind 
    573   1.9     rmind void
    574   1.9     rmind _npf_nat_getinfo(nl_nat_t *nt, int *type, u_int *flags, npf_addr_t *addr,
    575   1.9     rmind     size_t *alen, in_port_t *port)
    576   1.9     rmind {
    577   1.9     rmind 	prop_dictionary_t rldict = nt->nrl_dict;
    578   1.9     rmind 
    579   1.9     rmind 	prop_dictionary_get_int32(rldict, "type", type);
    580   1.9     rmind 	prop_dictionary_get_uint32(rldict, "flags", flags);
    581   1.9     rmind 
    582   1.9     rmind 	prop_object_t obj = prop_dictionary_get(rldict, "translation-ip");
    583   1.9     rmind 	*alen = prop_data_size(obj);
    584   1.9     rmind 	memcpy(addr, prop_data_data_nocopy(obj), *alen);
    585   1.9     rmind 
    586   1.9     rmind 	prop_dictionary_get_uint16(rldict, "translation-port", port);
    587   1.9     rmind }
    588   1.9     rmind 
    589   1.1     rmind /*
    590   1.1     rmind  * TABLE INTERFACE.
    591   1.1     rmind  */
    592   1.1     rmind 
    593   1.1     rmind nl_table_t *
    594   1.5  christos npf_table_create(u_int id, int type)
    595   1.1     rmind {
    596   1.1     rmind 	prop_dictionary_t tldict;
    597   1.1     rmind 	prop_array_t tblents;
    598   1.1     rmind 	nl_table_t *tl;
    599   1.1     rmind 
    600   1.5  christos 	tl = malloc(sizeof(*tl));
    601   1.1     rmind 	if (tl == NULL) {
    602   1.1     rmind 		return NULL;
    603   1.1     rmind 	}
    604   1.1     rmind 	tldict = prop_dictionary_create();
    605   1.1     rmind 	if (tldict == NULL) {
    606   1.1     rmind 		free(tl);
    607   1.1     rmind 		return NULL;
    608   1.1     rmind 	}
    609   1.1     rmind 	prop_dictionary_set_uint32(tldict, "id", id);
    610   1.1     rmind 	prop_dictionary_set_int32(tldict, "type", type);
    611   1.1     rmind 
    612   1.1     rmind 	tblents = prop_array_create();
    613   1.1     rmind 	if (tblents == NULL) {
    614   1.1     rmind 		prop_object_release(tldict);
    615   1.1     rmind 		free(tl);
    616   1.1     rmind 		return NULL;
    617   1.1     rmind 	}
    618   1.1     rmind 	prop_dictionary_set(tldict, "entries", tblents);
    619   1.1     rmind 	prop_object_release(tblents);
    620   1.1     rmind 
    621   1.1     rmind 	tl->ntl_dict = tldict;
    622   1.1     rmind 	return tl;
    623   1.1     rmind }
    624   1.1     rmind 
    625   1.1     rmind int
    626  1.10     rmind npf_table_add_entry(nl_table_t *tl, const int alen,
    627  1.10     rmind     const npf_addr_t *addr, const npf_netmask_t mask)
    628   1.1     rmind {
    629   1.1     rmind 	prop_dictionary_t tldict = tl->ntl_dict, entdict;
    630   1.1     rmind 	prop_array_t tblents;
    631   1.3    zoltan 	prop_data_t addrdata;
    632   1.1     rmind 
    633   1.1     rmind 	/* Create the table entry. */
    634   1.1     rmind 	entdict = prop_dictionary_create();
    635  1.10     rmind 	if (entdict == NULL) {
    636   1.1     rmind 		return ENOMEM;
    637   1.1     rmind 	}
    638  1.10     rmind 	addrdata = prop_data_create_data(addr, alen);
    639   1.3    zoltan 	prop_dictionary_set(entdict, "addr", addrdata);
    640   1.3    zoltan 	prop_dictionary_set_uint8(entdict, "mask", mask);
    641   1.3    zoltan 	prop_object_release(addrdata);
    642   1.1     rmind 
    643   1.1     rmind 	/* Insert the entry. */
    644   1.1     rmind 	tblents = prop_dictionary_get(tldict, "entries");
    645   1.1     rmind 	prop_array_add(tblents, entdict);
    646   1.1     rmind 	prop_object_release(entdict);
    647   1.1     rmind 	return 0;
    648   1.1     rmind }
    649   1.1     rmind 
    650   1.1     rmind bool
    651   1.1     rmind npf_table_exists_p(nl_config_t *ncf, u_int tid)
    652   1.1     rmind {
    653   1.1     rmind 	prop_dictionary_t tldict;
    654   1.1     rmind 	prop_object_iterator_t it;
    655   1.1     rmind 
    656   1.1     rmind 	it = prop_array_iterator(ncf->ncf_table_list);
    657   1.1     rmind 	while ((tldict = prop_object_iterator_next(it)) != NULL) {
    658   1.1     rmind 		u_int i;
    659   1.1     rmind 		if (prop_dictionary_get_uint32(tldict, "id", &i) && tid == i)
    660   1.1     rmind 			break;
    661   1.1     rmind 	}
    662   1.1     rmind 	prop_object_iterator_release(it);
    663   1.1     rmind 	return tldict ? true : false;
    664   1.1     rmind }
    665   1.1     rmind 
    666   1.1     rmind int
    667   1.1     rmind npf_table_insert(nl_config_t *ncf, nl_table_t *tl)
    668   1.1     rmind {
    669   1.1     rmind 	prop_dictionary_t tldict = tl->ntl_dict;
    670   1.1     rmind 	u_int tid;
    671   1.1     rmind 
    672   1.1     rmind 	if (!prop_dictionary_get_uint32(tldict, "id", &tid)) {
    673   1.1     rmind 		return EINVAL;
    674   1.1     rmind 	}
    675   1.1     rmind 	if (npf_table_exists_p(ncf, tid)) {
    676   1.1     rmind 		return EEXIST;
    677   1.1     rmind 	}
    678   1.1     rmind 	prop_array_add(ncf->ncf_table_list, tldict);
    679   1.1     rmind 	return 0;
    680   1.1     rmind }
    681   1.1     rmind 
    682   1.1     rmind void
    683   1.1     rmind npf_table_destroy(nl_table_t *tl)
    684   1.1     rmind {
    685   1.1     rmind 
    686   1.1     rmind 	prop_object_release(tl->ntl_dict);
    687   1.1     rmind 	free(tl);
    688   1.1     rmind }
    689   1.1     rmind 
    690   1.9     rmind void
    691   1.9     rmind _npf_table_foreach(nl_config_t *ncf, nl_table_callback_t func)
    692   1.9     rmind {
    693   1.9     rmind 	prop_dictionary_t tldict;
    694   1.9     rmind 	prop_object_iterator_t it;
    695   1.9     rmind 
    696   1.9     rmind 	it = prop_array_iterator(ncf->ncf_table_list);
    697   1.9     rmind 	while ((tldict = prop_object_iterator_next(it)) != NULL) {
    698   1.9     rmind 		u_int id;
    699   1.9     rmind 		int type;
    700   1.9     rmind 
    701   1.9     rmind 		prop_dictionary_get_uint32(tldict, "id", &id);
    702   1.9     rmind 		prop_dictionary_get_int32(tldict, "type", &type);
    703   1.9     rmind 		(*func)(id, type);
    704   1.9     rmind 	}
    705   1.9     rmind 	prop_object_iterator_release(it);
    706   1.9     rmind }
    707   1.9     rmind 
    708   1.1     rmind /*
    709   1.1     rmind  * MISC.
    710   1.1     rmind  */
    711   1.1     rmind 
    712   1.1     rmind int
    713   1.5  christos npf_update_rule(int fd, const char *rname __unused, nl_rule_t *rl)
    714   1.1     rmind {
    715   1.7     rmind 	prop_dictionary_t rldict = rl->nrl_dict, errdict = NULL;
    716   1.1     rmind 	int error;
    717   1.1     rmind 
    718   1.7     rmind 	error = prop_dictionary_sendrecv_ioctl(rldict, fd,
    719   1.7     rmind 	    IOC_NPF_UPDATE_RULE, &errdict);
    720   1.7     rmind 	if (errdict) {
    721   1.7     rmind 		prop_object_release(errdict);
    722   1.7     rmind 	}
    723   1.1     rmind 	return error;
    724   1.1     rmind }
    725   1.1     rmind 
    726   1.1     rmind int
    727   1.1     rmind npf_sessions_recv(int fd, const char *fpath)
    728   1.1     rmind {
    729   1.1     rmind 	prop_dictionary_t sdict;
    730   1.1     rmind 	int error;
    731   1.1     rmind 
    732   1.1     rmind 	error = prop_dictionary_recv_ioctl(fd, IOC_NPF_SESSIONS_SAVE, &sdict);
    733   1.1     rmind 	if (error) {
    734   1.1     rmind 		return error;
    735   1.1     rmind 	}
    736   1.1     rmind 	if (!prop_dictionary_externalize_to_file(sdict, fpath)) {
    737   1.1     rmind 		error = errno;
    738   1.1     rmind 	}
    739   1.1     rmind 	prop_object_release(sdict);
    740   1.1     rmind 	return error;
    741   1.1     rmind }
    742   1.1     rmind 
    743   1.1     rmind int
    744   1.1     rmind npf_sessions_send(int fd, const char *fpath)
    745   1.1     rmind {
    746   1.1     rmind 	prop_dictionary_t sdict;
    747   1.1     rmind 	int error;
    748   1.1     rmind 
    749   1.1     rmind 	if (fpath) {
    750   1.1     rmind 		sdict = prop_dictionary_internalize_from_file(fpath);
    751   1.1     rmind 		if (sdict == NULL) {
    752   1.1     rmind 			return errno;
    753   1.1     rmind 		}
    754   1.1     rmind 	} else {
    755   1.1     rmind 		/* Empty: will flush the sessions. */
    756   1.1     rmind 		prop_array_t selist = prop_array_create();
    757   1.1     rmind 		sdict = prop_dictionary_create();
    758   1.1     rmind 		prop_dictionary_set(sdict, "session-list", selist);
    759   1.1     rmind 		prop_object_release(selist);
    760   1.1     rmind 	}
    761   1.1     rmind 	error = prop_dictionary_send_ioctl(sdict, fd, IOC_NPF_SESSIONS_LOAD);
    762   1.1     rmind 	prop_object_release(sdict);
    763   1.1     rmind 	return error;
    764   1.1     rmind }
    765  1.11     rmind 
    766  1.11     rmind static prop_dictionary_t
    767  1.11     rmind _npf_debug_initonce(nl_config_t *ncf)
    768  1.11     rmind {
    769  1.11     rmind 	if (!ncf->ncf_debug) {
    770  1.11     rmind 		prop_array_t iflist = prop_array_create();
    771  1.11     rmind 		ncf->ncf_debug = prop_dictionary_create();
    772  1.11     rmind 		prop_dictionary_set(ncf->ncf_debug, "interfaces", iflist);
    773  1.11     rmind 		prop_object_release(iflist);
    774  1.11     rmind 	}
    775  1.11     rmind 	return ncf->ncf_debug;
    776  1.11     rmind }
    777  1.11     rmind 
    778  1.11     rmind void
    779  1.11     rmind _npf_debug_addif(nl_config_t *ncf, struct ifaddrs *ifa, u_int if_idx)
    780  1.11     rmind {
    781  1.11     rmind 	prop_dictionary_t ifdict, dbg = _npf_debug_initonce(ncf);
    782  1.11     rmind 	prop_array_t iflist = prop_dictionary_get(dbg, "interfaces");
    783  1.11     rmind 
    784  1.11     rmind 	if (_npf_prop_array_lookup(iflist, "name", ifa->ifa_name)) {
    785  1.11     rmind 		return;
    786  1.11     rmind 	}
    787  1.11     rmind 
    788  1.11     rmind 	ifdict = prop_dictionary_create();
    789  1.11     rmind 	prop_dictionary_set_cstring(ifdict, "name", ifa->ifa_name);
    790  1.11     rmind 	prop_dictionary_set_uint32(ifdict, "flags", ifa->ifa_flags);
    791  1.11     rmind 	if (!if_idx) {
    792  1.11     rmind 		if_idx = if_nametoindex(ifa->ifa_name);
    793  1.11     rmind 	}
    794  1.11     rmind 	prop_dictionary_set_uint32(ifdict, "idx", if_idx);
    795  1.11     rmind 
    796  1.11     rmind 	const struct sockaddr *sa = ifa->ifa_addr;
    797  1.11     rmind 	npf_addr_t addr;
    798  1.11     rmind 	size_t alen = 0;
    799  1.11     rmind 
    800  1.11     rmind 	switch (sa ? sa->sa_family : -1) {
    801  1.11     rmind 	case AF_INET: {
    802  1.11     rmind 		const struct sockaddr_in *sin = (const void *)sa;
    803  1.11     rmind 		alen = sizeof(sin->sin_addr);
    804  1.11     rmind 		memcpy(&addr, &sin->sin_addr, alen);
    805  1.11     rmind 		break;
    806  1.11     rmind 	}
    807  1.11     rmind 	case AF_INET6: {
    808  1.11     rmind 		const struct sockaddr_in6 *sin6 = (const void *)sa;
    809  1.11     rmind 		alen = sizeof(sin6->sin6_addr);
    810  1.11     rmind 		memcpy(&addr, &sin6->sin6_addr, alen);
    811  1.11     rmind 		break;
    812  1.11     rmind 	}
    813  1.11     rmind 	default:
    814  1.11     rmind 		break;
    815  1.11     rmind 	}
    816  1.11     rmind 
    817  1.11     rmind 	if (alen) {
    818  1.11     rmind 		prop_data_t addrdata = prop_data_create_data(&addr, alen);
    819  1.11     rmind 		prop_dictionary_set(ifdict, "addr", addrdata);
    820  1.11     rmind 		prop_object_release(addrdata);
    821  1.11     rmind 	}
    822  1.11     rmind 	prop_array_add(iflist, ifdict);
    823  1.11     rmind 	prop_object_release(ifdict);
    824  1.11     rmind }
    825