Home | History | Annotate | Line # | Download | only in kern
uipc_domain.c revision 1.100
      1  1.100     joerg /*	$NetBSD: uipc_domain.c,v 1.100 2017/09/09 14:41:19 joerg Exp $	*/
      2   1.12       cgd 
      3    1.1       cgd /*
      4   1.11   mycroft  * Copyright (c) 1982, 1986, 1993
      5   1.11   mycroft  *	The Regents of the University of California.  All rights reserved.
      6    1.1       cgd  *
      7    1.1       cgd  * Redistribution and use in source and binary forms, with or without
      8    1.1       cgd  * modification, are permitted provided that the following conditions
      9    1.1       cgd  * are met:
     10    1.1       cgd  * 1. Redistributions of source code must retain the above copyright
     11    1.1       cgd  *    notice, this list of conditions and the following disclaimer.
     12    1.1       cgd  * 2. Redistributions in binary form must reproduce the above copyright
     13    1.1       cgd  *    notice, this list of conditions and the following disclaimer in the
     14    1.1       cgd  *    documentation and/or other materials provided with the distribution.
     15   1.43       agc  * 3. Neither the name of the University nor the names of its contributors
     16    1.1       cgd  *    may be used to endorse or promote products derived from this software
     17    1.1       cgd  *    without specific prior written permission.
     18    1.1       cgd  *
     19    1.1       cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     20    1.1       cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     21    1.1       cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     22    1.1       cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     23    1.1       cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     24    1.1       cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     25    1.1       cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     26    1.1       cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     27    1.1       cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     28    1.1       cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     29    1.1       cgd  * SUCH DAMAGE.
     30    1.1       cgd  *
     31   1.18      fvdl  *	@(#)uipc_domain.c	8.3 (Berkeley) 2/14/95
     32    1.1       cgd  */
     33   1.36     lukem 
     34   1.36     lukem #include <sys/cdefs.h>
     35  1.100     joerg __KERNEL_RCSID(0, "$NetBSD: uipc_domain.c,v 1.100 2017/09/09 14:41:19 joerg Exp $");
     36    1.1       cgd 
     37    1.5   mycroft #include <sys/param.h>
     38    1.5   mycroft #include <sys/socket.h>
     39   1.50    atatat #include <sys/socketvar.h>
     40    1.5   mycroft #include <sys/protosw.h>
     41    1.5   mycroft #include <sys/domain.h>
     42    1.5   mycroft #include <sys/mbuf.h>
     43    1.5   mycroft #include <sys/time.h>
     44    1.5   mycroft #include <sys/kernel.h>
     45   1.11   mycroft #include <sys/systm.h>
     46   1.30   thorpej #include <sys/callout.h>
     47   1.49      matt #include <sys/queue.h>
     48   1.10       cgd #include <sys/proc.h>
     49   1.10       cgd #include <sys/sysctl.h>
     50   1.50    atatat #include <sys/un.h>
     51   1.50    atatat #include <sys/unpcb.h>
     52   1.50    atatat #include <sys/file.h>
     53   1.72        ad #include <sys/filedesc.h>
     54   1.57      elad #include <sys/kauth.h>
     55   1.96  christos 
     56   1.96  christos #include <netatalk/at.h>
     57   1.96  christos #include <net/if_dl.h>
     58   1.88     joerg #include <netinet/in.h>
     59   1.13  christos 
     60   1.69    dyoung MALLOC_DECLARE(M_SOCKADDR);
     61   1.69    dyoung 
     62   1.69    dyoung MALLOC_DEFINE(M_SOCKADDR, "sockaddr", "socket endpoints");
     63   1.69    dyoung 
     64   1.45  junyoung void	pffasttimo(void *);
     65   1.45  junyoung void	pfslowtimo(void *);
     66   1.37      matt 
     67   1.49      matt struct domainhead domains = STAILQ_HEAD_INITIALIZER(domains);
     68   1.64    dyoung static struct domain *domain_array[AF_MAX];
     69   1.11   mycroft 
     70   1.66        ad callout_t pffasttimo_ch, pfslowtimo_ch;
     71   1.30   thorpej 
     72   1.19   thorpej /*
     73   1.19   thorpej  * Current time values for fast and slow timeouts.  We can use u_int
     74   1.19   thorpej  * relatively safely.  The fast timer will roll over in 27 years and
     75   1.19   thorpej  * the slow timer in 68 years.
     76   1.19   thorpej  */
     77   1.19   thorpej u_int	pfslowtimo_now;
     78   1.19   thorpej u_int	pffasttimo_now;
     79   1.19   thorpej 
     80   1.77     pooka static struct sysctllog *domain_sysctllog;
     81   1.77     pooka static void sysctl_net_setup(void);
     82   1.77     pooka 
     83   1.93     pooka /* ensure successful linkage even without any domains in link sets */
     84   1.93     pooka static struct domain domain_dummy;
     85   1.93     pooka __link_set_add_rodata(domains,domain_dummy);
     86   1.93     pooka 
     87   1.49      matt void
     88   1.94     pooka domaininit(bool attach)
     89   1.49      matt {
     90   1.49      matt 	__link_set_decl(domains, struct domain);
     91   1.49      matt 	struct domain * const * dpp;
     92   1.49      matt 	struct domain *rt_domain = NULL;
     93   1.49      matt 
     94   1.77     pooka 	sysctl_net_setup();
     95   1.77     pooka 
     96   1.49      matt 	/*
     97   1.49      matt 	 * Add all of the domains.  Make sure the PF_ROUTE
     98   1.49      matt 	 * domain is added last.
     99   1.49      matt 	 */
    100   1.94     pooka 	if (attach) {
    101   1.94     pooka 		__link_set_foreach(dpp, domains) {
    102   1.94     pooka 			if (*dpp == &domain_dummy)
    103   1.94     pooka 				continue;
    104   1.94     pooka 			if ((*dpp)->dom_family == PF_ROUTE)
    105   1.94     pooka 				rt_domain = *dpp;
    106   1.94     pooka 			else
    107   1.94     pooka 				domain_attach(*dpp);
    108   1.94     pooka 		}
    109   1.94     pooka 		if (rt_domain)
    110   1.94     pooka 			domain_attach(rt_domain);
    111   1.49      matt 	}
    112   1.49      matt 
    113   1.76        ad 	callout_init(&pffasttimo_ch, CALLOUT_MPSAFE);
    114   1.76        ad 	callout_init(&pfslowtimo_ch, CALLOUT_MPSAFE);
    115   1.49      matt 
    116   1.49      matt 	callout_reset(&pffasttimo_ch, 1, pffasttimo, NULL);
    117   1.49      matt 	callout_reset(&pfslowtimo_ch, 1, pfslowtimo, NULL);
    118    1.1       cgd }
    119    1.1       cgd 
    120    1.4    andrew void
    121   1.49      matt domain_attach(struct domain *dp)
    122    1.1       cgd {
    123   1.47      matt 	const struct protosw *pr;
    124    1.1       cgd 
    125   1.49      matt 	STAILQ_INSERT_TAIL(&domains, dp, dom_link);
    126   1.64    dyoung 	if (dp->dom_family < __arraycount(domain_array))
    127   1.64    dyoung 		domain_array[dp->dom_family] = dp;
    128   1.49      matt 
    129   1.49      matt 	if (dp->dom_init)
    130   1.49      matt 		(*dp->dom_init)();
    131    1.1       cgd 
    132   1.38      matt #ifdef MBUFTRACE
    133   1.49      matt 	if (dp->dom_mowner.mo_name[0] == '\0') {
    134   1.49      matt 		strncpy(dp->dom_mowner.mo_name, dp->dom_name,
    135   1.49      matt 		    sizeof(dp->dom_mowner.mo_name));
    136   1.49      matt 		MOWNER_ATTACH(&dp->dom_mowner);
    137   1.49      matt 	}
    138   1.38      matt #endif
    139   1.49      matt 	for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++) {
    140   1.49      matt 		if (pr->pr_init)
    141   1.49      matt 			(*pr->pr_init)();
    142    1.1       cgd 	}
    143    1.1       cgd 
    144   1.16  explorer 	if (max_linkhdr < 16)		/* XXX */
    145   1.16  explorer 		max_linkhdr = 16;
    146    1.1       cgd 	max_hdr = max_linkhdr + max_protohdr;
    147    1.1       cgd 	max_datalen = MHLEN - max_hdr;
    148    1.1       cgd }
    149    1.1       cgd 
    150   1.29   thorpej struct domain *
    151   1.49      matt pffinddomain(int family)
    152   1.29   thorpej {
    153   1.29   thorpej 	struct domain *dp;
    154   1.29   thorpej 
    155   1.64    dyoung 	if (family < __arraycount(domain_array) && domain_array[family] != NULL)
    156   1.64    dyoung 		return domain_array[family];
    157   1.64    dyoung 
    158   1.49      matt 	DOMAIN_FOREACH(dp)
    159   1.29   thorpej 		if (dp->dom_family == family)
    160   1.81    dyoung 			return dp;
    161   1.81    dyoung 	return NULL;
    162   1.29   thorpej }
    163   1.29   thorpej 
    164   1.47      matt const struct protosw *
    165   1.49      matt pffindtype(int family, int type)
    166    1.1       cgd {
    167   1.29   thorpej 	struct domain *dp;
    168   1.47      matt 	const struct protosw *pr;
    169   1.29   thorpej 
    170   1.29   thorpej 	dp = pffinddomain(family);
    171   1.29   thorpej 	if (dp == NULL)
    172   1.81    dyoung 		return NULL;
    173    1.1       cgd 
    174    1.1       cgd 	for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++)
    175    1.1       cgd 		if (pr->pr_type && pr->pr_type == type)
    176   1.81    dyoung 			return pr;
    177   1.29   thorpej 
    178   1.81    dyoung 	return NULL;
    179    1.1       cgd }
    180    1.1       cgd 
    181   1.47      matt const struct protosw *
    182   1.49      matt pffindproto(int family, int protocol, int type)
    183    1.1       cgd {
    184   1.29   thorpej 	struct domain *dp;
    185   1.47      matt 	const struct protosw *pr;
    186   1.47      matt 	const struct protosw *maybe = NULL;
    187    1.1       cgd 
    188    1.1       cgd 	if (family == 0)
    189   1.81    dyoung 		return NULL;
    190   1.29   thorpej 
    191   1.29   thorpej 	dp = pffinddomain(family);
    192   1.29   thorpej 	if (dp == NULL)
    193   1.81    dyoung 		return NULL;
    194   1.29   thorpej 
    195    1.1       cgd 	for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++) {
    196    1.1       cgd 		if ((pr->pr_protocol == protocol) && (pr->pr_type == type))
    197   1.81    dyoung 			return pr;
    198    1.1       cgd 
    199    1.1       cgd 		if (type == SOCK_RAW && pr->pr_type == SOCK_RAW &&
    200   1.29   thorpej 		    pr->pr_protocol == 0 && maybe == NULL)
    201    1.1       cgd 			maybe = pr;
    202    1.1       cgd 	}
    203   1.81    dyoung 	return maybe;
    204   1.10       cgd }
    205   1.10       cgd 
    206   1.71    dyoung void *
    207   1.71    dyoung sockaddr_addr(struct sockaddr *sa, socklen_t *slenp)
    208   1.71    dyoung {
    209   1.71    dyoung 	const struct domain *dom;
    210   1.71    dyoung 
    211   1.71    dyoung 	if ((dom = pffinddomain(sa->sa_family)) == NULL ||
    212   1.71    dyoung 	    dom->dom_sockaddr_addr == NULL)
    213   1.71    dyoung 		return NULL;
    214   1.71    dyoung 
    215   1.71    dyoung 	return (*dom->dom_sockaddr_addr)(sa, slenp);
    216   1.71    dyoung }
    217   1.71    dyoung 
    218   1.71    dyoung const void *
    219   1.71    dyoung sockaddr_const_addr(const struct sockaddr *sa, socklen_t *slenp)
    220   1.71    dyoung {
    221   1.71    dyoung 	const struct domain *dom;
    222   1.83    dyoung 
    223   1.71    dyoung 	if ((dom = pffinddomain(sa->sa_family)) == NULL ||
    224   1.71    dyoung 	    dom->dom_sockaddr_const_addr == NULL)
    225   1.71    dyoung 		return NULL;
    226   1.71    dyoung 
    227   1.71    dyoung 	return (*dom->dom_sockaddr_const_addr)(sa, slenp);
    228   1.71    dyoung }
    229   1.71    dyoung 
    230   1.71    dyoung const struct sockaddr *
    231   1.97  christos sockaddr_any_by_family(sa_family_t family)
    232   1.71    dyoung {
    233   1.71    dyoung 	const struct domain *dom;
    234   1.83    dyoung 
    235   1.80    dyoung 	if ((dom = pffinddomain(family)) == NULL)
    236   1.71    dyoung 		return NULL;
    237   1.71    dyoung 
    238   1.71    dyoung 	return dom->dom_sa_any;
    239   1.71    dyoung }
    240   1.71    dyoung 
    241   1.80    dyoung const struct sockaddr *
    242   1.80    dyoung sockaddr_any(const struct sockaddr *sa)
    243   1.80    dyoung {
    244   1.80    dyoung 	return sockaddr_any_by_family(sa->sa_family);
    245   1.80    dyoung }
    246   1.80    dyoung 
    247   1.71    dyoung const void *
    248   1.71    dyoung sockaddr_anyaddr(const struct sockaddr *sa, socklen_t *slenp)
    249   1.71    dyoung {
    250   1.71    dyoung 	const struct sockaddr *any;
    251   1.71    dyoung 
    252   1.71    dyoung 	if ((any = sockaddr_any(sa)) == NULL)
    253   1.71    dyoung 		return NULL;
    254   1.71    dyoung 
    255   1.71    dyoung 	return sockaddr_const_addr(any, slenp);
    256   1.71    dyoung }
    257   1.71    dyoung 
    258   1.97  christos socklen_t
    259   1.97  christos sockaddr_getsize_by_family(sa_family_t af)
    260   1.96  christos {
    261   1.97  christos 	switch (af) {
    262   1.96  christos 	case AF_INET:
    263   1.97  christos 		return sizeof(struct sockaddr_in);
    264   1.96  christos 	case AF_INET6:
    265   1.97  christos 		return sizeof(struct sockaddr_in6);
    266   1.96  christos 	case AF_UNIX:
    267   1.97  christos 		return sizeof(struct sockaddr_un);
    268   1.96  christos 	case AF_LINK:
    269   1.97  christos 		return sizeof(struct sockaddr_dl);
    270   1.96  christos 	case AF_APPLETALK:
    271   1.97  christos 		return sizeof(struct sockaddr_at);
    272   1.96  christos 	default:
    273   1.97  christos #ifdef DIAGNOSTIC
    274   1.97  christos 		printf("%s: Unhandled address family=%hhu\n", __func__, af);
    275   1.97  christos #endif
    276   1.97  christos 		return 0;
    277   1.97  christos 	}
    278   1.97  christos }
    279   1.97  christos 
    280   1.97  christos #ifdef DIAGNOSTIC
    281   1.97  christos static void
    282   1.97  christos sockaddr_checklen(const struct sockaddr *sa)
    283   1.97  christos {
    284   1.99  christos 	// Can't tell how much was allocated, if it was allocated.
    285   1.99  christos 	if (sa->sa_family == AF_LINK)
    286   1.99  christos 		return;
    287   1.99  christos 
    288   1.97  christos 	socklen_t len = sockaddr_getsize_by_family(sa->sa_family);
    289   1.97  christos 	if (len == 0 || len == sa->sa_len)
    290   1.96  christos 		return;
    291   1.97  christos 
    292   1.97  christos 	char buf[512];
    293   1.97  christos 	sockaddr_format(sa, buf, sizeof(buf));
    294   1.97  christos 	printf("%s: %p bad len af=%hhu socklen=%hhu len=%u [%s]\n",
    295   1.97  christos 	    __func__, sa, sa->sa_family, sa->sa_len, (unsigned)len, buf);
    296   1.96  christos }
    297   1.96  christos #else
    298   1.96  christos #define sockaddr_checklen(sa) ((void)0)
    299   1.96  christos #endif
    300   1.96  christos 
    301   1.64    dyoung struct sockaddr *
    302   1.69    dyoung sockaddr_alloc(sa_family_t af, socklen_t socklen, int flags)
    303   1.64    dyoung {
    304   1.64    dyoung 	struct sockaddr *sa;
    305   1.69    dyoung 	socklen_t reallen = MAX(socklen, offsetof(struct sockaddr, sa_data[0]));
    306   1.64    dyoung 
    307   1.69    dyoung 	if ((sa = malloc(reallen, M_SOCKADDR, flags)) == NULL)
    308   1.64    dyoung 		return NULL;
    309   1.64    dyoung 
    310   1.64    dyoung 	sa->sa_family = af;
    311   1.69    dyoung 	sa->sa_len = reallen;
    312   1.96  christos 	sockaddr_checklen(sa);
    313   1.64    dyoung 	return sa;
    314   1.64    dyoung }
    315   1.64    dyoung 
    316   1.64    dyoung struct sockaddr *
    317   1.69    dyoung sockaddr_copy(struct sockaddr *dst, socklen_t socklen,
    318   1.69    dyoung     const struct sockaddr *src)
    319   1.64    dyoung {
    320   1.70    dyoung 	if (__predict_false(socklen < src->sa_len)) {
    321   1.70    dyoung 		panic("%s: source too long, %d < %d bytes", __func__, socklen,
    322   1.70    dyoung 		    src->sa_len);
    323   1.70    dyoung 	}
    324   1.96  christos 	sockaddr_checklen(src);
    325   1.70    dyoung 	return memcpy(dst, src, src->sa_len);
    326   1.64    dyoung }
    327   1.64    dyoung 
    328   1.84    dyoung struct sockaddr *
    329   1.84    dyoung sockaddr_externalize(struct sockaddr *dst, socklen_t socklen,
    330   1.84    dyoung     const struct sockaddr *src)
    331   1.84    dyoung {
    332   1.84    dyoung 	struct domain *dom;
    333   1.84    dyoung 
    334   1.84    dyoung 	dom = pffinddomain(src->sa_family);
    335   1.84    dyoung 
    336   1.84    dyoung 	if (dom != NULL && dom->dom_sockaddr_externalize != NULL)
    337   1.84    dyoung 		return (*dom->dom_sockaddr_externalize)(dst, socklen, src);
    338   1.84    dyoung 
    339   1.84    dyoung 	return sockaddr_copy(dst, socklen, src);
    340   1.84    dyoung }
    341   1.84    dyoung 
    342   1.64    dyoung int
    343   1.64    dyoung sockaddr_cmp(const struct sockaddr *sa1, const struct sockaddr *sa2)
    344   1.64    dyoung {
    345   1.65    dyoung 	int len, rc;
    346   1.64    dyoung 	struct domain *dom;
    347   1.64    dyoung 
    348   1.64    dyoung 	if (sa1->sa_family != sa2->sa_family)
    349   1.64    dyoung 		return sa1->sa_family - sa2->sa_family;
    350   1.64    dyoung 
    351   1.65    dyoung 	dom = pffinddomain(sa1->sa_family);
    352   1.65    dyoung 
    353   1.65    dyoung 	if (dom != NULL && dom->dom_sockaddr_cmp != NULL)
    354   1.64    dyoung 		return (*dom->dom_sockaddr_cmp)(sa1, sa2);
    355   1.64    dyoung 
    356   1.65    dyoung 	len = MIN(sa1->sa_len, sa2->sa_len);
    357   1.65    dyoung 
    358   1.65    dyoung 	if (dom == NULL || dom->dom_sa_cmplen == 0) {
    359   1.65    dyoung 		if ((rc = memcmp(sa1, sa2, len)) != 0)
    360   1.65    dyoung 			return rc;
    361   1.65    dyoung 		return sa1->sa_len - sa2->sa_len;
    362   1.65    dyoung 	}
    363   1.65    dyoung 
    364   1.65    dyoung 	if ((rc = memcmp((const char *)sa1 + dom->dom_sa_cmpofs,
    365   1.65    dyoung 		         (const char *)sa2 + dom->dom_sa_cmpofs,
    366   1.65    dyoung 			 MIN(dom->dom_sa_cmplen,
    367   1.65    dyoung 			     len - MIN(len, dom->dom_sa_cmpofs)))) != 0)
    368   1.64    dyoung 		return rc;
    369   1.64    dyoung 
    370   1.65    dyoung 	return MIN(dom->dom_sa_cmplen + dom->dom_sa_cmpofs, sa1->sa_len) -
    371   1.65    dyoung 	       MIN(dom->dom_sa_cmplen + dom->dom_sa_cmpofs, sa2->sa_len);
    372   1.64    dyoung }
    373   1.64    dyoung 
    374   1.64    dyoung struct sockaddr *
    375   1.64    dyoung sockaddr_dup(const struct sockaddr *src, int flags)
    376   1.64    dyoung {
    377   1.64    dyoung 	struct sockaddr *dst;
    378   1.64    dyoung 
    379   1.69    dyoung 	if ((dst = sockaddr_alloc(src->sa_family, src->sa_len, flags)) == NULL)
    380   1.64    dyoung 		return NULL;
    381   1.64    dyoung 
    382   1.69    dyoung 	return sockaddr_copy(dst, dst->sa_len, src);
    383   1.64    dyoung }
    384   1.64    dyoung 
    385   1.64    dyoung void
    386   1.64    dyoung sockaddr_free(struct sockaddr *sa)
    387   1.64    dyoung {
    388   1.69    dyoung 	free(sa, M_SOCKADDR);
    389   1.64    dyoung }
    390   1.64    dyoung 
    391   1.96  christos static int
    392   1.96  christos sun_print(char *buf, size_t len, const void *v)
    393   1.96  christos {
    394   1.96  christos 	const struct sockaddr_un *sun = v;
    395   1.96  christos 	return snprintf(buf, len, "%s", sun->sun_path);
    396   1.96  christos }
    397   1.96  christos 
    398   1.96  christos int
    399   1.88     joerg sockaddr_format(const struct sockaddr *sa, char *buf, size_t len)
    400   1.88     joerg {
    401   1.96  christos 	size_t plen = 0;
    402   1.88     joerg 
    403   1.96  christos 	if (sa == NULL)
    404   1.96  christos 		return strlcpy(buf, "(null)", len);
    405   1.88     joerg 
    406   1.88     joerg 	switch (sa->sa_family) {
    407   1.88     joerg 	case AF_LOCAL:
    408   1.96  christos 		plen = strlcpy(buf, "unix: ", len);
    409   1.96  christos 		break;
    410   1.88     joerg 	case AF_INET:
    411   1.96  christos 		plen = strlcpy(buf, "inet: ", len);
    412   1.88     joerg 		break;
    413   1.88     joerg 	case AF_INET6:
    414   1.96  christos 		plen = strlcpy(buf, "inet6: ", len);
    415   1.96  christos 		break;
    416   1.96  christos 	case AF_LINK:
    417   1.96  christos 		plen = strlcpy(buf, "link: ", len);
    418   1.96  christos 		break;
    419   1.96  christos 	case AF_APPLETALK:
    420   1.96  christos 		plen = strlcpy(buf, "atalk: ", len);
    421   1.88     joerg 		break;
    422   1.96  christos 	default:
    423   1.96  christos 		return snprintf(buf, len, "(unknown socket family %d)",
    424   1.96  christos 		    (int)sa->sa_family);
    425   1.88     joerg 	}
    426   1.96  christos 
    427   1.96  christos 	buf += plen;
    428   1.96  christos 	if (plen > len)
    429   1.96  christos 		len = 0;
    430   1.96  christos 	else
    431   1.96  christos 		len -= plen;
    432   1.96  christos 
    433   1.96  christos 	switch (sa->sa_family) {
    434   1.96  christos 	case AF_LOCAL:
    435   1.96  christos 		return sun_print(buf, len, sa);
    436   1.96  christos 	case AF_INET:
    437   1.96  christos 		return sin_print(buf, len, sa);
    438   1.96  christos 	case AF_INET6:
    439   1.96  christos 		return sin6_print(buf, len, sa);
    440   1.96  christos 	case AF_LINK:
    441   1.96  christos 		return sdl_print(buf, len, sa);
    442   1.96  christos 	case AF_APPLETALK:
    443   1.96  christos 		return sat_print(buf, len, sa);
    444   1.96  christos 	default:
    445   1.96  christos 		panic("bad family %hhu", sa->sa_family);
    446   1.88     joerg 	}
    447   1.88     joerg }
    448   1.88     joerg 
    449   1.50    atatat /*
    450   1.50    atatat  * sysctl helper to stuff PF_LOCAL pcbs into sysctl structures
    451   1.50    atatat  */
    452   1.50    atatat static void
    453   1.50    atatat sysctl_dounpcb(struct kinfo_pcb *pcb, const struct socket *so)
    454   1.50    atatat {
    455   1.50    atatat 	struct unpcb *unp = sotounpcb(so);
    456   1.50    atatat 	struct sockaddr_un *un = unp->unp_addr;
    457   1.50    atatat 
    458   1.50    atatat 	memset(pcb, 0, sizeof(*pcb));
    459   1.50    atatat 
    460   1.50    atatat 	pcb->ki_family = so->so_proto->pr_domain->dom_family;
    461   1.50    atatat 	pcb->ki_type = so->so_proto->pr_type;
    462   1.50    atatat 	pcb->ki_protocol = so->so_proto->pr_protocol;
    463   1.50    atatat 	pcb->ki_pflags = unp->unp_flags;
    464   1.50    atatat 
    465   1.50    atatat 	pcb->ki_pcbaddr = PTRTOUINT64(unp);
    466   1.50    atatat 	/* pcb->ki_ppcbaddr = unp has no ppcb... */
    467   1.50    atatat 	pcb->ki_sockaddr = PTRTOUINT64(so);
    468   1.50    atatat 
    469   1.50    atatat 	pcb->ki_sostate = so->so_state;
    470   1.50    atatat 	/* pcb->ki_prstate = unp has no state... */
    471   1.50    atatat 
    472   1.50    atatat 	pcb->ki_rcvq = so->so_rcv.sb_cc;
    473   1.50    atatat 	pcb->ki_sndq = so->so_snd.sb_cc;
    474   1.50    atatat 
    475   1.92  christos 	un = (struct sockaddr_un *)pcb->ki_spad;
    476   1.50    atatat 	/*
    477   1.50    atatat 	 * local domain sockets may bind without having a local
    478   1.50    atatat 	 * endpoint.  bleah!
    479   1.50    atatat 	 */
    480   1.50    atatat 	if (unp->unp_addr != NULL) {
    481   1.91     seanb 		/*
    482   1.91     seanb 		 * We've added one to sun_len when allocating to
    483   1.91     seanb 		 * hold terminating NUL which we want here.  See
    484   1.91     seanb 		 * makeun().
    485   1.91     seanb 		 */
    486   1.91     seanb 		memcpy(un, unp->unp_addr,
    487   1.92  christos 		    min(sizeof(pcb->ki_spad), unp->unp_addr->sun_len + 1));
    488   1.50    atatat 	}
    489   1.50    atatat 	else {
    490   1.50    atatat 		un->sun_len = offsetof(struct sockaddr_un, sun_path);
    491   1.50    atatat 		un->sun_family = pcb->ki_family;
    492   1.50    atatat 	}
    493   1.50    atatat 	if (unp->unp_conn != NULL) {
    494   1.92  christos 		un = (struct sockaddr_un *)pcb->ki_dpad;
    495   1.50    atatat 		if (unp->unp_conn->unp_addr != NULL) {
    496   1.91     seanb 			memcpy(un, unp->unp_conn->unp_addr,
    497   1.92  christos 			    min(sizeof(pcb->ki_dpad), unp->unp_conn->unp_addr->sun_len + 1));
    498   1.50    atatat 		}
    499   1.50    atatat 		else {
    500   1.50    atatat 			un->sun_len = offsetof(struct sockaddr_un, sun_path);
    501   1.50    atatat 			un->sun_family = pcb->ki_family;
    502   1.50    atatat 		}
    503   1.50    atatat 	}
    504   1.50    atatat 
    505   1.50    atatat 	pcb->ki_inode = unp->unp_ino;
    506   1.50    atatat 	pcb->ki_vnode = PTRTOUINT64(unp->unp_vnode);
    507   1.50    atatat 	pcb->ki_conn = PTRTOUINT64(unp->unp_conn);
    508   1.50    atatat 	pcb->ki_refs = PTRTOUINT64(unp->unp_refs);
    509   1.50    atatat 	pcb->ki_nextref = PTRTOUINT64(unp->unp_nextref);
    510   1.50    atatat }
    511   1.50    atatat 
    512   1.50    atatat static int
    513   1.50    atatat sysctl_unpcblist(SYSCTLFN_ARGS)
    514   1.50    atatat {
    515   1.89    martin 	struct file *fp, *dfp;
    516   1.50    atatat 	struct socket *so;
    517   1.50    atatat 	struct kinfo_pcb pcb;
    518   1.50    atatat 	char *dp;
    519   1.50    atatat 	size_t len, needed, elem_size, out_size;
    520   1.89    martin 	int error, elem_count, pf, type;
    521   1.50    atatat 
    522   1.50    atatat 	if (namelen == 1 && name[0] == CTL_QUERY)
    523   1.81    dyoung 		return sysctl_query(SYSCTLFN_CALL(rnode));
    524   1.50    atatat 
    525   1.50    atatat 	if (namelen != 4)
    526   1.81    dyoung 		return EINVAL;
    527   1.50    atatat 
    528   1.56  christos 	if (oldp != NULL) {
    529   1.56  christos 		len = *oldlenp;
    530   1.56  christos 		elem_size = name[2];
    531   1.56  christos 		elem_count = name[3];
    532   1.56  christos 		if (elem_size != sizeof(pcb))
    533   1.56  christos 			return EINVAL;
    534   1.56  christos 	} else {
    535   1.56  christos 		len = 0;
    536   1.56  christos 		elem_size = sizeof(pcb);
    537   1.56  christos 		elem_count = INT_MAX;
    538   1.56  christos 	}
    539   1.50    atatat 	error = 0;
    540   1.50    atatat 	dp = oldp;
    541   1.56  christos 	out_size = elem_size;
    542   1.50    atatat 	needed = 0;
    543   1.50    atatat 
    544   1.50    atatat 	if (name - oname != 4)
    545   1.81    dyoung 		return EINVAL;
    546   1.50    atatat 
    547   1.50    atatat 	pf = oname[1];
    548   1.50    atatat 	type = oname[2];
    549   1.50    atatat 
    550   1.50    atatat 	/*
    551   1.74        ad 	 * allocate dummy file descriptor to make position in list.
    552   1.74        ad 	 */
    553   1.74        ad 	sysctl_unlock();
    554   1.74        ad 	if ((dfp = fgetdummy()) == NULL) {
    555   1.74        ad 	 	sysctl_relock();
    556   1.74        ad 		return ENOMEM;
    557   1.74        ad 	}
    558   1.74        ad 
    559   1.74        ad 	/*
    560   1.50    atatat 	 * there's no "list" of local domain sockets, so we have
    561   1.50    atatat 	 * to walk the file list looking for them.  :-/
    562   1.50    atatat 	 */
    563   1.72        ad 	mutex_enter(&filelist_lock);
    564   1.50    atatat 	LIST_FOREACH(fp, &filehead, f_list) {
    565   1.74        ad 		if (fp->f_count == 0 || fp->f_type != DTYPE_SOCKET ||
    566   1.95      matt 		    fp->f_socket == NULL)
    567   1.74        ad 			continue;
    568   1.95      matt 		so = fp->f_socket;
    569   1.50    atatat 		if (so->so_type != type)
    570   1.50    atatat 			continue;
    571   1.50    atatat 		if (so->so_proto->pr_domain->dom_family != pf)
    572   1.50    atatat 			continue;
    573   1.85      elad 		if (kauth_authorize_network(l->l_cred, KAUTH_NETWORK_SOCKET,
    574   1.85      elad 		    KAUTH_REQ_NETWORK_SOCKET_CANSEE, so, NULL, NULL) != 0)
    575   1.85      elad 			continue;
    576   1.50    atatat 		if (len >= elem_size && elem_count > 0) {
    577   1.75        ad 			mutex_enter(&fp->f_lock);
    578  1.100     joerg 			/*
    579  1.100     joerg 			 * Do not add references, if the count reached 0.
    580  1.100     joerg 			 * Since the check above has been performed without
    581  1.100     joerg 			 * locking, it must be rechecked here as a concurrent
    582  1.100     joerg 			 * closef could have reduced it.
    583  1.100     joerg 			 */
    584  1.100     joerg 			if (fp->f_count == 0) {
    585  1.100     joerg 				mutex_exit(&fp->f_lock);
    586  1.100     joerg 				continue;
    587  1.100     joerg 			}
    588   1.75        ad 			fp->f_count++;
    589   1.75        ad 			mutex_exit(&fp->f_lock);
    590   1.74        ad 			LIST_INSERT_AFTER(fp, dfp, f_list);
    591   1.72        ad 			mutex_exit(&filelist_lock);
    592   1.50    atatat 			sysctl_dounpcb(&pcb, so);
    593   1.50    atatat 			error = copyout(&pcb, dp, out_size);
    594   1.75        ad 			closef(fp);
    595   1.72        ad 			mutex_enter(&filelist_lock);
    596   1.74        ad 			LIST_REMOVE(dfp, f_list);
    597   1.50    atatat 			if (error)
    598   1.50    atatat 				break;
    599   1.50    atatat 			dp += elem_size;
    600   1.50    atatat 			len -= elem_size;
    601   1.50    atatat 		}
    602   1.78       mrg 		needed += elem_size;
    603   1.78       mrg 		if (elem_count > 0 && elem_count != INT_MAX)
    604   1.78       mrg 			elem_count--;
    605   1.50    atatat 	}
    606   1.72        ad 	mutex_exit(&filelist_lock);
    607   1.74        ad 	fputdummy(dfp);
    608   1.74        ad  	*oldlenp = needed;
    609   1.50    atatat 	if (oldp == NULL)
    610   1.50    atatat 		*oldlenp += PCB_SLOP * sizeof(struct kinfo_pcb);
    611   1.74        ad  	sysctl_relock();
    612   1.50    atatat 
    613   1.81    dyoung 	return error;
    614   1.50    atatat }
    615   1.50    atatat 
    616   1.77     pooka static void
    617   1.79    cegger sysctl_net_setup(void)
    618   1.10       cgd {
    619   1.77     pooka 
    620   1.77     pooka 	KASSERT(domain_sysctllog == NULL);
    621   1.77     pooka 	sysctl_createv(&domain_sysctllog, 0, NULL, NULL,
    622   1.46    atatat 		       CTLFLAG_PERMANENT,
    623   1.48    atatat 		       CTLTYPE_NODE, "local",
    624   1.48    atatat 		       SYSCTL_DESCR("PF_LOCAL related settings"),
    625   1.44    atatat 		       NULL, 0, NULL, 0,
    626   1.44    atatat 		       CTL_NET, PF_LOCAL, CTL_EOL);
    627   1.77     pooka 	sysctl_createv(&domain_sysctllog, 0, NULL, NULL,
    628   1.50    atatat 		       CTLFLAG_PERMANENT,
    629   1.50    atatat 		       CTLTYPE_NODE, "stream",
    630   1.50    atatat 		       SYSCTL_DESCR("SOCK_STREAM settings"),
    631   1.50    atatat 		       NULL, 0, NULL, 0,
    632   1.50    atatat 		       CTL_NET, PF_LOCAL, SOCK_STREAM, CTL_EOL);
    633   1.77     pooka 	sysctl_createv(&domain_sysctllog, 0, NULL, NULL,
    634   1.50    atatat 		       CTLFLAG_PERMANENT,
    635   1.86      manu 		       CTLTYPE_NODE, "seqpacket",
    636   1.86      manu 		       SYSCTL_DESCR("SOCK_SEQPACKET settings"),
    637   1.86      manu 		       NULL, 0, NULL, 0,
    638   1.86      manu 		       CTL_NET, PF_LOCAL, SOCK_SEQPACKET, CTL_EOL);
    639   1.86      manu 	sysctl_createv(&domain_sysctllog, 0, NULL, NULL,
    640   1.86      manu 		       CTLFLAG_PERMANENT,
    641   1.50    atatat 		       CTLTYPE_NODE, "dgram",
    642   1.50    atatat 		       SYSCTL_DESCR("SOCK_DGRAM settings"),
    643   1.50    atatat 		       NULL, 0, NULL, 0,
    644   1.50    atatat 		       CTL_NET, PF_LOCAL, SOCK_DGRAM, CTL_EOL);
    645   1.10       cgd 
    646   1.77     pooka 	sysctl_createv(&domain_sysctllog, 0, NULL, NULL,
    647   1.50    atatat 		       CTLFLAG_PERMANENT,
    648   1.50    atatat 		       CTLTYPE_STRUCT, "pcblist",
    649   1.50    atatat 		       SYSCTL_DESCR("SOCK_STREAM protocol control block list"),
    650   1.50    atatat 		       sysctl_unpcblist, 0, NULL, 0,
    651   1.50    atatat 		       CTL_NET, PF_LOCAL, SOCK_STREAM, CTL_CREATE, CTL_EOL);
    652   1.77     pooka 	sysctl_createv(&domain_sysctllog, 0, NULL, NULL,
    653   1.50    atatat 		       CTLFLAG_PERMANENT,
    654   1.50    atatat 		       CTLTYPE_STRUCT, "pcblist",
    655   1.86      manu 		       SYSCTL_DESCR("SOCK_SEQPACKET protocol control "
    656   1.86      manu 				    "block list"),
    657   1.86      manu 		       sysctl_unpcblist, 0, NULL, 0,
    658   1.86      manu 		       CTL_NET, PF_LOCAL, SOCK_SEQPACKET, CTL_CREATE, CTL_EOL);
    659   1.86      manu 	sysctl_createv(&domain_sysctllog, 0, NULL, NULL,
    660   1.86      manu 		       CTLFLAG_PERMANENT,
    661   1.86      manu 		       CTLTYPE_STRUCT, "pcblist",
    662   1.50    atatat 		       SYSCTL_DESCR("SOCK_DGRAM protocol control block list"),
    663   1.50    atatat 		       sysctl_unpcblist, 0, NULL, 0,
    664   1.50    atatat 		       CTL_NET, PF_LOCAL, SOCK_DGRAM, CTL_CREATE, CTL_EOL);
    665    1.1       cgd }
    666    1.1       cgd 
    667    1.4    andrew void
    668   1.63    dyoung pfctlinput(int cmd, const struct sockaddr *sa)
    669    1.1       cgd {
    670   1.31  augustss 	struct domain *dp;
    671   1.47      matt 	const struct protosw *pr;
    672    1.1       cgd 
    673   1.63    dyoung 	DOMAIN_FOREACH(dp) {
    674   1.63    dyoung 		for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++) {
    675   1.63    dyoung 			if (pr->pr_ctlinput != NULL)
    676   1.13  christos 				(*pr->pr_ctlinput)(cmd, sa, NULL);
    677   1.63    dyoung 		}
    678   1.63    dyoung 	}
    679   1.34    itojun }
    680   1.34    itojun 
    681   1.34    itojun void
    682   1.63    dyoung pfctlinput2(int cmd, const struct sockaddr *sa, void *ctlparam)
    683   1.34    itojun {
    684   1.34    itojun 	struct domain *dp;
    685   1.47      matt 	const struct protosw *pr;
    686   1.34    itojun 
    687   1.63    dyoung 	if (sa == NULL)
    688   1.34    itojun 		return;
    689   1.49      matt 
    690   1.49      matt 	DOMAIN_FOREACH(dp) {
    691   1.34    itojun 		/*
    692   1.34    itojun 		 * the check must be made by xx_ctlinput() anyways, to
    693   1.34    itojun 		 * make sure we use data item pointed to by ctlparam in
    694   1.34    itojun 		 * correct way.  the following check is made just for safety.
    695   1.34    itojun 		 */
    696   1.34    itojun 		if (dp->dom_family != sa->sa_family)
    697   1.34    itojun 			continue;
    698   1.34    itojun 
    699   1.63    dyoung 		for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++) {
    700   1.63    dyoung 			if (pr->pr_ctlinput != NULL)
    701   1.34    itojun 				(*pr->pr_ctlinput)(cmd, sa, ctlparam);
    702   1.63    dyoung 		}
    703   1.34    itojun 	}
    704    1.1       cgd }
    705    1.1       cgd 
    706    1.4    andrew void
    707   1.62      yamt pfslowtimo(void *arg)
    708    1.1       cgd {
    709   1.31  augustss 	struct domain *dp;
    710   1.47      matt 	const struct protosw *pr;
    711    1.1       cgd 
    712   1.19   thorpej 	pfslowtimo_now++;
    713   1.19   thorpej 
    714   1.49      matt 	DOMAIN_FOREACH(dp) {
    715    1.1       cgd 		for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++)
    716    1.1       cgd 			if (pr->pr_slowtimo)
    717    1.1       cgd 				(*pr->pr_slowtimo)();
    718   1.49      matt 	}
    719   1.87     seanb 	callout_schedule(&pfslowtimo_ch, hz / PR_SLOWHZ);
    720    1.1       cgd }
    721    1.1       cgd 
    722    1.4    andrew void
    723   1.62      yamt pffasttimo(void *arg)
    724    1.1       cgd {
    725   1.31  augustss 	struct domain *dp;
    726   1.47      matt 	const struct protosw *pr;
    727   1.19   thorpej 
    728   1.19   thorpej 	pffasttimo_now++;
    729    1.1       cgd 
    730   1.49      matt 	DOMAIN_FOREACH(dp) {
    731    1.1       cgd 		for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++)
    732    1.1       cgd 			if (pr->pr_fasttimo)
    733    1.1       cgd 				(*pr->pr_fasttimo)();
    734   1.49      matt 	}
    735   1.87     seanb 	callout_schedule(&pffasttimo_ch, hz / PR_FASTHZ);
    736    1.1       cgd }
    737