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