1df8bae1dSRodney W. Grimes /* 2df8bae1dSRodney W. Grimes * Copyright (c) 1982, 1986, 1989, 1991, 1993 3df8bae1dSRodney W. Grimes * The Regents of the University of California. All rights reserved. 4df8bae1dSRodney W. Grimes * 5df8bae1dSRodney W. Grimes * Redistribution and use in source and binary forms, with or without 6df8bae1dSRodney W. Grimes * modification, are permitted provided that the following conditions 7df8bae1dSRodney W. Grimes * are met: 8df8bae1dSRodney W. Grimes * 1. Redistributions of source code must retain the above copyright 9df8bae1dSRodney W. Grimes * notice, this list of conditions and the following disclaimer. 10df8bae1dSRodney W. Grimes * 2. Redistributions in binary form must reproduce the above copyright 11df8bae1dSRodney W. Grimes * notice, this list of conditions and the following disclaimer in the 12df8bae1dSRodney W. Grimes * documentation and/or other materials provided with the distribution. 13df8bae1dSRodney W. Grimes * 3. All advertising materials mentioning features or use of this software 14df8bae1dSRodney W. Grimes * must display the following acknowledgement: 15df8bae1dSRodney W. Grimes * This product includes software developed by the University of 16df8bae1dSRodney W. Grimes * California, Berkeley and its contributors. 17df8bae1dSRodney W. Grimes * 4. Neither the name of the University nor the names of its contributors 18df8bae1dSRodney W. Grimes * may be used to endorse or promote products derived from this software 19df8bae1dSRodney W. Grimes * without specific prior written permission. 20df8bae1dSRodney W. Grimes * 21df8bae1dSRodney W. Grimes * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND 22df8bae1dSRodney W. Grimes * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 23df8bae1dSRodney W. Grimes * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 24df8bae1dSRodney W. Grimes * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE 25df8bae1dSRodney W. Grimes * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 26df8bae1dSRodney W. Grimes * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 27df8bae1dSRodney W. Grimes * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 28df8bae1dSRodney W. Grimes * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 29df8bae1dSRodney W. Grimes * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 30df8bae1dSRodney W. Grimes * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 31df8bae1dSRodney W. Grimes * SUCH DAMAGE. 32df8bae1dSRodney W. Grimes * 33748e0b0aSGarrett Wollman * From: @(#)uipc_usrreq.c 8.3 (Berkeley) 1/4/94 34df8bae1dSRodney W. Grimes */ 35df8bae1dSRodney W. Grimes 36677b542eSDavid E. O'Brien #include <sys/cdefs.h> 37677b542eSDavid E. O'Brien __FBSDID("$FreeBSD$"); 38677b542eSDavid E. O'Brien 39335654d7SRobert Watson #include "opt_mac.h" 40335654d7SRobert Watson 41df8bae1dSRodney W. Grimes #include <sys/param.h> 42fb919e4dSMark Murray #include <sys/domain.h> 43960ed29cSSeigo Tanimura #include <sys/fcntl.h> 44d826c479SBruce Evans #include <sys/malloc.h> /* XXX must be before <sys/file.h> */ 45639acc13SGarrett Wollman #include <sys/file.h> 46960ed29cSSeigo Tanimura #include <sys/filedesc.h> 47960ed29cSSeigo Tanimura #include <sys/jail.h> 48960ed29cSSeigo Tanimura #include <sys/kernel.h> 49960ed29cSSeigo Tanimura #include <sys/lock.h> 506ea48a90SRobert Watson #include <sys/mac.h> 51639acc13SGarrett Wollman #include <sys/mbuf.h> 52960ed29cSSeigo Tanimura #include <sys/mutex.h> 53639acc13SGarrett Wollman #include <sys/namei.h> 54639acc13SGarrett Wollman #include <sys/proc.h> 55df8bae1dSRodney W. Grimes #include <sys/protosw.h> 56960ed29cSSeigo Tanimura #include <sys/resourcevar.h> 57df8bae1dSRodney W. Grimes #include <sys/socket.h> 58df8bae1dSRodney W. Grimes #include <sys/socketvar.h> 59960ed29cSSeigo Tanimura #include <sys/signalvar.h> 60df8bae1dSRodney W. Grimes #include <sys/stat.h> 61960ed29cSSeigo Tanimura #include <sys/sx.h> 62639acc13SGarrett Wollman #include <sys/sysctl.h> 63960ed29cSSeigo Tanimura #include <sys/systm.h> 64639acc13SGarrett Wollman #include <sys/un.h> 6598271db4SGarrett Wollman #include <sys/unpcb.h> 66639acc13SGarrett Wollman #include <sys/vnode.h> 67df8bae1dSRodney W. Grimes 689e9d298aSJeff Roberson #include <vm/uma.h> 6998271db4SGarrett Wollman 709e9d298aSJeff Roberson static uma_zone_t unp_zone; 7198271db4SGarrett Wollman static unp_gen_t unp_gencnt; 7298271db4SGarrett Wollman static u_int unp_count; 7398271db4SGarrett Wollman 7498271db4SGarrett Wollman static struct unp_head unp_shead, unp_dhead; 7598271db4SGarrett Wollman 76df8bae1dSRodney W. Grimes /* 77df8bae1dSRodney W. Grimes * Unix communications domain. 78df8bae1dSRodney W. Grimes * 79df8bae1dSRodney W. Grimes * TODO: 80df8bae1dSRodney W. Grimes * SEQPACKET, RDM 81df8bae1dSRodney W. Grimes * rethink name space problems 82df8bae1dSRodney W. Grimes * need a proper out-of-band 8398271db4SGarrett Wollman * lock pushdown 84df8bae1dSRodney W. Grimes */ 85f708ef1bSPoul-Henning Kamp static struct sockaddr sun_noname = { sizeof(sun_noname), AF_LOCAL }; 86f708ef1bSPoul-Henning Kamp static ino_t unp_ino; /* prototype for fake inode numbers */ 87f708ef1bSPoul-Henning Kamp 884d77a549SAlfred Perlstein static int unp_attach(struct socket *); 894d77a549SAlfred Perlstein static void unp_detach(struct unpcb *); 904d77a549SAlfred Perlstein static int unp_bind(struct unpcb *,struct sockaddr *, struct thread *); 9170f52b48SBruce Evans static int unp_connect(struct socket *,struct sockaddr *, struct thread *); 924d77a549SAlfred Perlstein static void unp_disconnect(struct unpcb *); 934d77a549SAlfred Perlstein static void unp_shutdown(struct unpcb *); 944d77a549SAlfred Perlstein static void unp_drop(struct unpcb *, int); 954d77a549SAlfred Perlstein static void unp_gc(void); 964d77a549SAlfred Perlstein static void unp_scan(struct mbuf *, void (*)(struct file *)); 974d77a549SAlfred Perlstein static void unp_mark(struct file *); 984d77a549SAlfred Perlstein static void unp_discard(struct file *); 994d77a549SAlfred Perlstein static void unp_freerights(struct file **, int); 1004d77a549SAlfred Perlstein static int unp_internalize(struct mbuf **, struct thread *); 1014d77a549SAlfred Perlstein static int unp_listen(struct unpcb *, struct thread *); 102f708ef1bSPoul-Henning Kamp 103a29f300eSGarrett Wollman static int 104a29f300eSGarrett Wollman uipc_abort(struct socket *so) 105df8bae1dSRodney W. Grimes { 106df8bae1dSRodney W. Grimes struct unpcb *unp = sotounpcb(so); 107df8bae1dSRodney W. Grimes 108a29f300eSGarrett Wollman if (unp == 0) 109e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 110a29f300eSGarrett Wollman unp_drop(unp, ECONNABORTED); 111ddb7d629SIan Dowse unp_detach(unp); 112ddb7d629SIan Dowse sotryfree(so); 113e5aeaa0cSDag-Erling Smørgrav return (0); 114df8bae1dSRodney W. Grimes } 115df8bae1dSRodney W. Grimes 116a29f300eSGarrett Wollman static int 11757bf258eSGarrett Wollman uipc_accept(struct socket *so, struct sockaddr **nam) 118a29f300eSGarrett Wollman { 119a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 120df8bae1dSRodney W. Grimes 121a29f300eSGarrett Wollman if (unp == 0) 122e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 123df8bae1dSRodney W. Grimes 124df8bae1dSRodney W. Grimes /* 125df8bae1dSRodney W. Grimes * Pass back name of connected socket, 126df8bae1dSRodney W. Grimes * if it was bound and we are still connected 127df8bae1dSRodney W. Grimes * (our peer may have closed already!). 128df8bae1dSRodney W. Grimes */ 129df8bae1dSRodney W. Grimes if (unp->unp_conn && unp->unp_conn->unp_addr) { 13057bf258eSGarrett Wollman *nam = dup_sockaddr((struct sockaddr *)unp->unp_conn->unp_addr, 13157bf258eSGarrett Wollman 1); 132df8bae1dSRodney W. Grimes } else { 13357bf258eSGarrett Wollman *nam = dup_sockaddr((struct sockaddr *)&sun_noname, 1); 134df8bae1dSRodney W. Grimes } 135e5aeaa0cSDag-Erling Smørgrav return (0); 136a29f300eSGarrett Wollman } 137df8bae1dSRodney W. Grimes 138a29f300eSGarrett Wollman static int 139b40ce416SJulian Elischer uipc_attach(struct socket *so, int proto, struct thread *td) 140a29f300eSGarrett Wollman { 141a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 142df8bae1dSRodney W. Grimes 143a29f300eSGarrett Wollman if (unp != 0) 144e5aeaa0cSDag-Erling Smørgrav return (EISCONN); 145e5aeaa0cSDag-Erling Smørgrav return (unp_attach(so)); 146a29f300eSGarrett Wollman } 147a29f300eSGarrett Wollman 148a29f300eSGarrett Wollman static int 149b40ce416SJulian Elischer uipc_bind(struct socket *so, struct sockaddr *nam, struct thread *td) 150a29f300eSGarrett Wollman { 151a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 152a29f300eSGarrett Wollman 153a29f300eSGarrett Wollman if (unp == 0) 154e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 155a29f300eSGarrett Wollman 156e5aeaa0cSDag-Erling Smørgrav return (unp_bind(unp, nam, td)); 157a29f300eSGarrett Wollman } 158a29f300eSGarrett Wollman 159a29f300eSGarrett Wollman static int 160b40ce416SJulian Elischer uipc_connect(struct socket *so, struct sockaddr *nam, struct thread *td) 161a29f300eSGarrett Wollman { 162a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 163a29f300eSGarrett Wollman 164a29f300eSGarrett Wollman if (unp == 0) 165e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 166e5aeaa0cSDag-Erling Smørgrav return (unp_connect(so, nam, curthread)); 167a29f300eSGarrett Wollman } 168a29f300eSGarrett Wollman 169a29f300eSGarrett Wollman static int 170a29f300eSGarrett Wollman uipc_connect2(struct socket *so1, struct socket *so2) 171a29f300eSGarrett Wollman { 172a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so1); 173a29f300eSGarrett Wollman 174a29f300eSGarrett Wollman if (unp == 0) 175e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 176a29f300eSGarrett Wollman 177e5aeaa0cSDag-Erling Smørgrav return (unp_connect2(so1, so2)); 178a29f300eSGarrett Wollman } 179a29f300eSGarrett Wollman 180a29f300eSGarrett Wollman /* control is EOPNOTSUPP */ 181a29f300eSGarrett Wollman 182a29f300eSGarrett Wollman static int 183a29f300eSGarrett Wollman uipc_detach(struct socket *so) 184a29f300eSGarrett Wollman { 185a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 186a29f300eSGarrett Wollman 187a29f300eSGarrett Wollman if (unp == 0) 188e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 189a29f300eSGarrett Wollman 190a29f300eSGarrett Wollman unp_detach(unp); 191e5aeaa0cSDag-Erling Smørgrav return (0); 192a29f300eSGarrett Wollman } 193a29f300eSGarrett Wollman 194a29f300eSGarrett Wollman static int 195a29f300eSGarrett Wollman uipc_disconnect(struct socket *so) 196a29f300eSGarrett Wollman { 197a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 198a29f300eSGarrett Wollman 199a29f300eSGarrett Wollman if (unp == 0) 200e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 201a29f300eSGarrett Wollman unp_disconnect(unp); 202e5aeaa0cSDag-Erling Smørgrav return (0); 203a29f300eSGarrett Wollman } 204a29f300eSGarrett Wollman 205a29f300eSGarrett Wollman static int 206b40ce416SJulian Elischer uipc_listen(struct socket *so, struct thread *td) 207a29f300eSGarrett Wollman { 208a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 209a29f300eSGarrett Wollman 210a29f300eSGarrett Wollman if (unp == 0 || unp->unp_vnode == 0) 211e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 212e5aeaa0cSDag-Erling Smørgrav return (unp_listen(unp, td)); 213a29f300eSGarrett Wollman } 214a29f300eSGarrett Wollman 215a29f300eSGarrett Wollman static int 21657bf258eSGarrett Wollman uipc_peeraddr(struct socket *so, struct sockaddr **nam) 217a29f300eSGarrett Wollman { 218a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 219a29f300eSGarrett Wollman 220a29f300eSGarrett Wollman if (unp == 0) 221e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 22257bf258eSGarrett Wollman if (unp->unp_conn && unp->unp_conn->unp_addr) 22357bf258eSGarrett Wollman *nam = dup_sockaddr((struct sockaddr *)unp->unp_conn->unp_addr, 22457bf258eSGarrett Wollman 1); 225bdc5f6a3SHajimu UMEMOTO else { 226bdc5f6a3SHajimu UMEMOTO /* 227bdc5f6a3SHajimu UMEMOTO * XXX: It seems that this test always fails even when 228bdc5f6a3SHajimu UMEMOTO * connection is established. So, this else clause is 229bdc5f6a3SHajimu UMEMOTO * added as workaround to return PF_LOCAL sockaddr. 230bdc5f6a3SHajimu UMEMOTO */ 23156b3905fSHajimu UMEMOTO *nam = dup_sockaddr((struct sockaddr *)&sun_noname, 1); 232bdc5f6a3SHajimu UMEMOTO } 233e5aeaa0cSDag-Erling Smørgrav return (0); 234a29f300eSGarrett Wollman } 235a29f300eSGarrett Wollman 236a29f300eSGarrett Wollman static int 237a29f300eSGarrett Wollman uipc_rcvd(struct socket *so, int flags) 238a29f300eSGarrett Wollman { 239a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 240a29f300eSGarrett Wollman struct socket *so2; 2416aef685fSBrian Feldman u_long newhiwat; 242a29f300eSGarrett Wollman 243a29f300eSGarrett Wollman if (unp == 0) 244e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 245df8bae1dSRodney W. Grimes switch (so->so_type) { 246df8bae1dSRodney W. Grimes case SOCK_DGRAM: 247a29f300eSGarrett Wollman panic("uipc_rcvd DGRAM?"); 248df8bae1dSRodney W. Grimes /*NOTREACHED*/ 249df8bae1dSRodney W. Grimes 250df8bae1dSRodney W. Grimes case SOCK_STREAM: 251df8bae1dSRodney W. Grimes if (unp->unp_conn == 0) 252df8bae1dSRodney W. Grimes break; 253df8bae1dSRodney W. Grimes so2 = unp->unp_conn->unp_socket; 254df8bae1dSRodney W. Grimes /* 255df8bae1dSRodney W. Grimes * Adjust backpressure on sender 256df8bae1dSRodney W. Grimes * and wakeup any waiting to write. 257df8bae1dSRodney W. Grimes */ 258ff8b0106SBrian Feldman so2->so_snd.sb_mbmax += unp->unp_mbcnt - so->so_rcv.sb_mbcnt; 259ff8b0106SBrian Feldman unp->unp_mbcnt = so->so_rcv.sb_mbcnt; 2606aef685fSBrian Feldman newhiwat = so2->so_snd.sb_hiwat + unp->unp_cc - 2616aef685fSBrian Feldman so->so_rcv.sb_cc; 262f535380cSDon Lewis (void)chgsbsize(so2->so_cred->cr_uidinfo, &so2->so_snd.sb_hiwat, 2636aef685fSBrian Feldman newhiwat, RLIM_INFINITY); 264ff8b0106SBrian Feldman unp->unp_cc = so->so_rcv.sb_cc; 265df8bae1dSRodney W. Grimes sowwakeup(so2); 266df8bae1dSRodney W. Grimes break; 267df8bae1dSRodney W. Grimes 268df8bae1dSRodney W. Grimes default: 269a29f300eSGarrett Wollman panic("uipc_rcvd unknown socktype"); 270df8bae1dSRodney W. Grimes } 271e5aeaa0cSDag-Erling Smørgrav return (0); 272a29f300eSGarrett Wollman } 273df8bae1dSRodney W. Grimes 274a29f300eSGarrett Wollman /* pru_rcvoob is EOPNOTSUPP */ 275a29f300eSGarrett Wollman 276a29f300eSGarrett Wollman static int 27757bf258eSGarrett Wollman uipc_send(struct socket *so, int flags, struct mbuf *m, struct sockaddr *nam, 278b40ce416SJulian Elischer struct mbuf *control, struct thread *td) 279a29f300eSGarrett Wollman { 280a29f300eSGarrett Wollman int error = 0; 281a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 282a29f300eSGarrett Wollman struct socket *so2; 2836aef685fSBrian Feldman u_long newhiwat; 284a29f300eSGarrett Wollman 285a29f300eSGarrett Wollman if (unp == 0) { 286a29f300eSGarrett Wollman error = EINVAL; 287a29f300eSGarrett Wollman goto release; 288a29f300eSGarrett Wollman } 289a29f300eSGarrett Wollman if (flags & PRUS_OOB) { 290a29f300eSGarrett Wollman error = EOPNOTSUPP; 291a29f300eSGarrett Wollman goto release; 292a29f300eSGarrett Wollman } 293a29f300eSGarrett Wollman 2942bc21ed9SDavid Malone if (control && (error = unp_internalize(&control, td))) 295a29f300eSGarrett Wollman goto release; 296df8bae1dSRodney W. Grimes 297a29f300eSGarrett Wollman switch (so->so_type) { 298a29f300eSGarrett Wollman case SOCK_DGRAM: 299a29f300eSGarrett Wollman { 300df8bae1dSRodney W. Grimes struct sockaddr *from; 301df8bae1dSRodney W. Grimes 302df8bae1dSRodney W. Grimes if (nam) { 303df8bae1dSRodney W. Grimes if (unp->unp_conn) { 304df8bae1dSRodney W. Grimes error = EISCONN; 305df8bae1dSRodney W. Grimes break; 306df8bae1dSRodney W. Grimes } 307b40ce416SJulian Elischer error = unp_connect(so, nam, td); 308df8bae1dSRodney W. Grimes if (error) 309df8bae1dSRodney W. Grimes break; 310df8bae1dSRodney W. Grimes } else { 311df8bae1dSRodney W. Grimes if (unp->unp_conn == 0) { 312df8bae1dSRodney W. Grimes error = ENOTCONN; 313df8bae1dSRodney W. Grimes break; 314df8bae1dSRodney W. Grimes } 315df8bae1dSRodney W. Grimes } 316df8bae1dSRodney W. Grimes so2 = unp->unp_conn->unp_socket; 317df8bae1dSRodney W. Grimes if (unp->unp_addr) 31857bf258eSGarrett Wollman from = (struct sockaddr *)unp->unp_addr; 319df8bae1dSRodney W. Grimes else 320df8bae1dSRodney W. Grimes from = &sun_noname; 321df8bae1dSRodney W. Grimes if (sbappendaddr(&so2->so_rcv, from, m, control)) { 322df8bae1dSRodney W. Grimes sorwakeup(so2); 323df8bae1dSRodney W. Grimes m = 0; 324df8bae1dSRodney W. Grimes control = 0; 325e5aeaa0cSDag-Erling Smørgrav } else { 326df8bae1dSRodney W. Grimes error = ENOBUFS; 327e5aeaa0cSDag-Erling Smørgrav } 328df8bae1dSRodney W. Grimes if (nam) 329df8bae1dSRodney W. Grimes unp_disconnect(unp); 330df8bae1dSRodney W. Grimes break; 331df8bae1dSRodney W. Grimes } 332df8bae1dSRodney W. Grimes 333df8bae1dSRodney W. Grimes case SOCK_STREAM: 3346b8fda4dSGarrett Wollman /* Connect if not connected yet. */ 3356b8fda4dSGarrett Wollman /* 3366b8fda4dSGarrett Wollman * Note: A better implementation would complain 337402cc72dSDavid Greenman * if not equal to the peer's address. 3386b8fda4dSGarrett Wollman */ 339402cc72dSDavid Greenman if ((so->so_state & SS_ISCONNECTED) == 0) { 340402cc72dSDavid Greenman if (nam) { 341b40ce416SJulian Elischer error = unp_connect(so, nam, td); 342402cc72dSDavid Greenman if (error) 3436b8fda4dSGarrett Wollman break; /* XXX */ 344402cc72dSDavid Greenman } else { 345402cc72dSDavid Greenman error = ENOTCONN; 346402cc72dSDavid Greenman break; 347402cc72dSDavid Greenman } 348402cc72dSDavid Greenman } 349402cc72dSDavid Greenman 350df8bae1dSRodney W. Grimes if (so->so_state & SS_CANTSENDMORE) { 351df8bae1dSRodney W. Grimes error = EPIPE; 352df8bae1dSRodney W. Grimes break; 353df8bae1dSRodney W. Grimes } 354df8bae1dSRodney W. Grimes if (unp->unp_conn == 0) 355a29f300eSGarrett Wollman panic("uipc_send connected but no connection?"); 356df8bae1dSRodney W. Grimes so2 = unp->unp_conn->unp_socket; 357df8bae1dSRodney W. Grimes /* 358df8bae1dSRodney W. Grimes * Send to paired receive port, and then reduce 359df8bae1dSRodney W. Grimes * send buffer hiwater marks to maintain backpressure. 360df8bae1dSRodney W. Grimes * Wake up readers. 361df8bae1dSRodney W. Grimes */ 362df8bae1dSRodney W. Grimes if (control) { 363ff8b0106SBrian Feldman if (sbappendcontrol(&so2->so_rcv, m, control)) 364df8bae1dSRodney W. Grimes control = 0; 365e5aeaa0cSDag-Erling Smørgrav } else { 366ff8b0106SBrian Feldman sbappend(&so2->so_rcv, m); 367e5aeaa0cSDag-Erling Smørgrav } 368ff8b0106SBrian Feldman so->so_snd.sb_mbmax -= 369ff8b0106SBrian Feldman so2->so_rcv.sb_mbcnt - unp->unp_conn->unp_mbcnt; 370ff8b0106SBrian Feldman unp->unp_conn->unp_mbcnt = so2->so_rcv.sb_mbcnt; 3716aef685fSBrian Feldman newhiwat = so->so_snd.sb_hiwat - 3726aef685fSBrian Feldman (so2->so_rcv.sb_cc - unp->unp_conn->unp_cc); 373f535380cSDon Lewis (void)chgsbsize(so->so_cred->cr_uidinfo, &so->so_snd.sb_hiwat, 3746aef685fSBrian Feldman newhiwat, RLIM_INFINITY); 375ff8b0106SBrian Feldman unp->unp_conn->unp_cc = so2->so_rcv.sb_cc; 376df8bae1dSRodney W. Grimes sorwakeup(so2); 377df8bae1dSRodney W. Grimes m = 0; 378df8bae1dSRodney W. Grimes break; 379df8bae1dSRodney W. Grimes 380df8bae1dSRodney W. Grimes default: 381a29f300eSGarrett Wollman panic("uipc_send unknown socktype"); 382df8bae1dSRodney W. Grimes } 383a29f300eSGarrett Wollman 3846b8fda4dSGarrett Wollman /* 3856b8fda4dSGarrett Wollman * SEND_EOF is equivalent to a SEND followed by 3866b8fda4dSGarrett Wollman * a SHUTDOWN. 3876b8fda4dSGarrett Wollman */ 388a29f300eSGarrett Wollman if (flags & PRUS_EOF) { 3896b8fda4dSGarrett Wollman socantsendmore(so); 3906b8fda4dSGarrett Wollman unp_shutdown(unp); 3916b8fda4dSGarrett Wollman } 392df8bae1dSRodney W. Grimes 393bd508d39SDon Lewis if (control && error != 0) 394bd508d39SDon Lewis unp_dispose(control); 395bd508d39SDon Lewis 396a29f300eSGarrett Wollman release: 397a29f300eSGarrett Wollman if (control) 398a29f300eSGarrett Wollman m_freem(control); 399a29f300eSGarrett Wollman if (m) 400a29f300eSGarrett Wollman m_freem(m); 401e5aeaa0cSDag-Erling Smørgrav return (error); 402a29f300eSGarrett Wollman } 403df8bae1dSRodney W. Grimes 404a29f300eSGarrett Wollman static int 405a29f300eSGarrett Wollman uipc_sense(struct socket *so, struct stat *sb) 406a29f300eSGarrett Wollman { 407a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 408a29f300eSGarrett Wollman struct socket *so2; 409a29f300eSGarrett Wollman 410a29f300eSGarrett Wollman if (unp == 0) 411e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 412a29f300eSGarrett Wollman sb->st_blksize = so->so_snd.sb_hiwat; 413df8bae1dSRodney W. Grimes if (so->so_type == SOCK_STREAM && unp->unp_conn != 0) { 414df8bae1dSRodney W. Grimes so2 = unp->unp_conn->unp_socket; 415a29f300eSGarrett Wollman sb->st_blksize += so2->so_rcv.sb_cc; 416df8bae1dSRodney W. Grimes } 417bfbb9ce6SPoul-Henning Kamp sb->st_dev = NOUDEV; 418df8bae1dSRodney W. Grimes if (unp->unp_ino == 0) 4196f782c46SJeffrey Hsu unp->unp_ino = (++unp_ino == 0) ? ++unp_ino : unp_ino; 420a29f300eSGarrett Wollman sb->st_ino = unp->unp_ino; 421df8bae1dSRodney W. Grimes return (0); 422a29f300eSGarrett Wollman } 423df8bae1dSRodney W. Grimes 424a29f300eSGarrett Wollman static int 425a29f300eSGarrett Wollman uipc_shutdown(struct socket *so) 426a29f300eSGarrett Wollman { 427a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 428df8bae1dSRodney W. Grimes 429a29f300eSGarrett Wollman if (unp == 0) 430e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 431a29f300eSGarrett Wollman socantsendmore(so); 432a29f300eSGarrett Wollman unp_shutdown(unp); 433e5aeaa0cSDag-Erling Smørgrav return (0); 434a29f300eSGarrett Wollman } 435df8bae1dSRodney W. Grimes 436a29f300eSGarrett Wollman static int 43757bf258eSGarrett Wollman uipc_sockaddr(struct socket *so, struct sockaddr **nam) 438a29f300eSGarrett Wollman { 439a29f300eSGarrett Wollman struct unpcb *unp = sotounpcb(so); 440a29f300eSGarrett Wollman 441a29f300eSGarrett Wollman if (unp == 0) 442e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 44357bf258eSGarrett Wollman if (unp->unp_addr) 44457bf258eSGarrett Wollman *nam = dup_sockaddr((struct sockaddr *)unp->unp_addr, 1); 44583f3198bSThomas Moestl else 44683f3198bSThomas Moestl *nam = dup_sockaddr((struct sockaddr *)&sun_noname, 1); 447e5aeaa0cSDag-Erling Smørgrav return (0); 448df8bae1dSRodney W. Grimes } 449a29f300eSGarrett Wollman 450a29f300eSGarrett Wollman struct pr_usrreqs uipc_usrreqs = { 451a29f300eSGarrett Wollman uipc_abort, uipc_accept, uipc_attach, uipc_bind, uipc_connect, 452a29f300eSGarrett Wollman uipc_connect2, pru_control_notsupp, uipc_detach, uipc_disconnect, 453a29f300eSGarrett Wollman uipc_listen, uipc_peeraddr, uipc_rcvd, pru_rcvoob_notsupp, 454a29f300eSGarrett Wollman uipc_send, uipc_sense, uipc_shutdown, uipc_sockaddr, 455a557af22SRobert Watson sosend, soreceive, sopoll, pru_sosetlabel_null 456a29f300eSGarrett Wollman }; 457df8bae1dSRodney W. Grimes 4580c1bb4fbSDima Dorfman int 4590c1bb4fbSDima Dorfman uipc_ctloutput(so, sopt) 4600c1bb4fbSDima Dorfman struct socket *so; 4610c1bb4fbSDima Dorfman struct sockopt *sopt; 4620c1bb4fbSDima Dorfman { 4630c1bb4fbSDima Dorfman struct unpcb *unp = sotounpcb(so); 4640c1bb4fbSDima Dorfman int error; 4650c1bb4fbSDima Dorfman 4660c1bb4fbSDima Dorfman switch (sopt->sopt_dir) { 4670c1bb4fbSDima Dorfman case SOPT_GET: 4680c1bb4fbSDima Dorfman switch (sopt->sopt_name) { 4690c1bb4fbSDima Dorfman case LOCAL_PEERCRED: 4700c1bb4fbSDima Dorfman if (unp->unp_flags & UNP_HAVEPC) 4710c1bb4fbSDima Dorfman error = sooptcopyout(sopt, &unp->unp_peercred, 4720c1bb4fbSDima Dorfman sizeof(unp->unp_peercred)); 4730c1bb4fbSDima Dorfman else { 4740c1bb4fbSDima Dorfman if (so->so_type == SOCK_STREAM) 4750c1bb4fbSDima Dorfman error = ENOTCONN; 4760c1bb4fbSDima Dorfman else 4770c1bb4fbSDima Dorfman error = EINVAL; 4780c1bb4fbSDima Dorfman } 4790c1bb4fbSDima Dorfman break; 4800c1bb4fbSDima Dorfman default: 4810c1bb4fbSDima Dorfman error = EOPNOTSUPP; 4820c1bb4fbSDima Dorfman break; 4830c1bb4fbSDima Dorfman } 4840c1bb4fbSDima Dorfman break; 4850c1bb4fbSDima Dorfman case SOPT_SET: 4860c1bb4fbSDima Dorfman default: 4870c1bb4fbSDima Dorfman error = EOPNOTSUPP; 4880c1bb4fbSDima Dorfman break; 4890c1bb4fbSDima Dorfman } 4900c1bb4fbSDima Dorfman return (error); 4910c1bb4fbSDima Dorfman } 4920c1bb4fbSDima Dorfman 493df8bae1dSRodney W. Grimes /* 494df8bae1dSRodney W. Grimes * Both send and receive buffers are allocated PIPSIZ bytes of buffering 495df8bae1dSRodney W. Grimes * for stream sockets, although the total for sender and receiver is 496df8bae1dSRodney W. Grimes * actually only PIPSIZ. 497df8bae1dSRodney W. Grimes * Datagram sockets really use the sendspace as the maximum datagram size, 498df8bae1dSRodney W. Grimes * and don't really want to reserve the sendspace. Their recvspace should 499df8bae1dSRodney W. Grimes * be large enough for at least one max-size datagram plus address. 500df8bae1dSRodney W. Grimes */ 5015dce41c5SJohn Dyson #ifndef PIPSIZ 5025dce41c5SJohn Dyson #define PIPSIZ 8192 5035dce41c5SJohn Dyson #endif 504f708ef1bSPoul-Henning Kamp static u_long unpst_sendspace = PIPSIZ; 505f708ef1bSPoul-Henning Kamp static u_long unpst_recvspace = PIPSIZ; 506f708ef1bSPoul-Henning Kamp static u_long unpdg_sendspace = 2*1024; /* really max datagram size */ 507f708ef1bSPoul-Henning Kamp static u_long unpdg_recvspace = 4*1024; 508df8bae1dSRodney W. Grimes 509f708ef1bSPoul-Henning Kamp static int unp_rights; /* file descriptors in flight */ 510df8bae1dSRodney W. Grimes 511ce02431fSDoug Rabson SYSCTL_DECL(_net_local_stream); 512639acc13SGarrett Wollman SYSCTL_INT(_net_local_stream, OID_AUTO, sendspace, CTLFLAG_RW, 513639acc13SGarrett Wollman &unpst_sendspace, 0, ""); 514639acc13SGarrett Wollman SYSCTL_INT(_net_local_stream, OID_AUTO, recvspace, CTLFLAG_RW, 515639acc13SGarrett Wollman &unpst_recvspace, 0, ""); 516ce02431fSDoug Rabson SYSCTL_DECL(_net_local_dgram); 517639acc13SGarrett Wollman SYSCTL_INT(_net_local_dgram, OID_AUTO, maxdgram, CTLFLAG_RW, 518639acc13SGarrett Wollman &unpdg_sendspace, 0, ""); 519639acc13SGarrett Wollman SYSCTL_INT(_net_local_dgram, OID_AUTO, recvspace, CTLFLAG_RW, 520639acc13SGarrett Wollman &unpdg_recvspace, 0, ""); 521ce02431fSDoug Rabson SYSCTL_DECL(_net_local); 522639acc13SGarrett Wollman SYSCTL_INT(_net_local, OID_AUTO, inflight, CTLFLAG_RD, &unp_rights, 0, ""); 523639acc13SGarrett Wollman 524f708ef1bSPoul-Henning Kamp static int 525df8bae1dSRodney W. Grimes unp_attach(so) 526df8bae1dSRodney W. Grimes struct socket *so; 527df8bae1dSRodney W. Grimes { 528df8bae1dSRodney W. Grimes register struct unpcb *unp; 529df8bae1dSRodney W. Grimes int error; 530df8bae1dSRodney W. Grimes 531df8bae1dSRodney W. Grimes if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) { 532df8bae1dSRodney W. Grimes switch (so->so_type) { 533df8bae1dSRodney W. Grimes 534df8bae1dSRodney W. Grimes case SOCK_STREAM: 535df8bae1dSRodney W. Grimes error = soreserve(so, unpst_sendspace, unpst_recvspace); 536df8bae1dSRodney W. Grimes break; 537df8bae1dSRodney W. Grimes 538df8bae1dSRodney W. Grimes case SOCK_DGRAM: 539df8bae1dSRodney W. Grimes error = soreserve(so, unpdg_sendspace, unpdg_recvspace); 540df8bae1dSRodney W. Grimes break; 541df8bae1dSRodney W. Grimes 542df8bae1dSRodney W. Grimes default: 543df8bae1dSRodney W. Grimes panic("unp_attach"); 544df8bae1dSRodney W. Grimes } 545df8bae1dSRodney W. Grimes if (error) 546df8bae1dSRodney W. Grimes return (error); 547df8bae1dSRodney W. Grimes } 548a163d034SWarner Losh unp = uma_zalloc(unp_zone, M_WAITOK); 54957bf258eSGarrett Wollman if (unp == NULL) 550df8bae1dSRodney W. Grimes return (ENOBUFS); 55157bf258eSGarrett Wollman bzero(unp, sizeof *unp); 55298271db4SGarrett Wollman unp->unp_gencnt = ++unp_gencnt; 55398271db4SGarrett Wollman unp_count++; 55498271db4SGarrett Wollman LIST_INIT(&unp->unp_refs); 555df8bae1dSRodney W. Grimes unp->unp_socket = so; 55698271db4SGarrett Wollman LIST_INSERT_HEAD(so->so_type == SOCK_DGRAM ? &unp_dhead 55798271db4SGarrett Wollman : &unp_shead, unp, unp_link); 558210a5a71SAlfred Perlstein so->so_pcb = unp; 559df8bae1dSRodney W. Grimes return (0); 560df8bae1dSRodney W. Grimes } 561df8bae1dSRodney W. Grimes 562f708ef1bSPoul-Henning Kamp static void 563df8bae1dSRodney W. Grimes unp_detach(unp) 564df8bae1dSRodney W. Grimes register struct unpcb *unp; 565df8bae1dSRodney W. Grimes { 56698271db4SGarrett Wollman LIST_REMOVE(unp, unp_link); 56798271db4SGarrett Wollman unp->unp_gencnt = ++unp_gencnt; 56898271db4SGarrett Wollman --unp_count; 569df8bae1dSRodney W. Grimes if (unp->unp_vnode) { 570df8bae1dSRodney W. Grimes unp->unp_vnode->v_socket = 0; 571df8bae1dSRodney W. Grimes vrele(unp->unp_vnode); 572df8bae1dSRodney W. Grimes unp->unp_vnode = 0; 573df8bae1dSRodney W. Grimes } 574df8bae1dSRodney W. Grimes if (unp->unp_conn) 575df8bae1dSRodney W. Grimes unp_disconnect(unp); 5762e3c8fcbSPoul-Henning Kamp while (!LIST_EMPTY(&unp->unp_refs)) 5772e3c8fcbSPoul-Henning Kamp unp_drop(LIST_FIRST(&unp->unp_refs), ECONNRESET); 578df8bae1dSRodney W. Grimes soisdisconnected(unp->unp_socket); 579df8bae1dSRodney W. Grimes unp->unp_socket->so_pcb = 0; 580df8bae1dSRodney W. Grimes if (unp_rights) { 581df8bae1dSRodney W. Grimes /* 582df8bae1dSRodney W. Grimes * Normally the receive buffer is flushed later, 583df8bae1dSRodney W. Grimes * in sofree, but if our receive buffer holds references 584df8bae1dSRodney W. Grimes * to descriptors that are now garbage, we will dispose 585df8bae1dSRodney W. Grimes * of those descriptor references after the garbage collector 586df8bae1dSRodney W. Grimes * gets them (resulting in a "panic: closef: count < 0"). 587df8bae1dSRodney W. Grimes */ 588df8bae1dSRodney W. Grimes sorflush(unp->unp_socket); 589df8bae1dSRodney W. Grimes unp_gc(); 590df8bae1dSRodney W. Grimes } 59157bf258eSGarrett Wollman if (unp->unp_addr) 59257bf258eSGarrett Wollman FREE(unp->unp_addr, M_SONAME); 5939e9d298aSJeff Roberson uma_zfree(unp_zone, unp); 594df8bae1dSRodney W. Grimes } 595df8bae1dSRodney W. Grimes 596f708ef1bSPoul-Henning Kamp static int 597b40ce416SJulian Elischer unp_bind(unp, nam, td) 598df8bae1dSRodney W. Grimes struct unpcb *unp; 59957bf258eSGarrett Wollman struct sockaddr *nam; 600b40ce416SJulian Elischer struct thread *td; 601df8bae1dSRodney W. Grimes { 60257bf258eSGarrett Wollman struct sockaddr_un *soun = (struct sockaddr_un *)nam; 603f2a2857bSKirk McKusick struct vnode *vp; 604f2a2857bSKirk McKusick struct mount *mp; 605df8bae1dSRodney W. Grimes struct vattr vattr; 60657bf258eSGarrett Wollman int error, namelen; 607df8bae1dSRodney W. Grimes struct nameidata nd; 6088f364875SJulian Elischer char *buf; 609df8bae1dSRodney W. Grimes 610df8bae1dSRodney W. Grimes if (unp->unp_vnode != NULL) 611df8bae1dSRodney W. Grimes return (EINVAL); 61255c85568SRobert Drehmel 61357bf258eSGarrett Wollman namelen = soun->sun_len - offsetof(struct sockaddr_un, sun_path); 61457bf258eSGarrett Wollman if (namelen <= 0) 615e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 61655c85568SRobert Drehmel 617a163d034SWarner Losh buf = malloc(namelen + 1, M_TEMP, M_WAITOK); 61855c85568SRobert Drehmel strlcpy(buf, soun->sun_path, namelen + 1); 61955c85568SRobert Drehmel 620f2a2857bSKirk McKusick restart: 621b65f6f6bSRobert Watson NDINIT(&nd, CREATE, NOFOLLOW | LOCKPARENT | SAVENAME, UIO_SYSSPACE, 622b40ce416SJulian Elischer buf, td); 623df8bae1dSRodney W. Grimes /* SHOULD BE ABLE TO ADOPT EXISTING AND wakeup() ALA FIFO's */ 624797f2d22SPoul-Henning Kamp error = namei(&nd); 6258f364875SJulian Elischer if (error) { 6268f364875SJulian Elischer free(buf, M_TEMP); 627ad4ff090SJulian Elischer return (error); 6288f364875SJulian Elischer } 629df8bae1dSRodney W. Grimes vp = nd.ni_vp; 630f2a2857bSKirk McKusick if (vp != NULL || vn_start_write(nd.ni_dvp, &mp, V_NOWAIT) != 0) { 631762e6b85SEivind Eklund NDFREE(&nd, NDF_ONLY_PNBUF); 632df8bae1dSRodney W. Grimes if (nd.ni_dvp == vp) 633df8bae1dSRodney W. Grimes vrele(nd.ni_dvp); 634df8bae1dSRodney W. Grimes else 635df8bae1dSRodney W. Grimes vput(nd.ni_dvp); 636f2a2857bSKirk McKusick if (vp != NULL) { 637df8bae1dSRodney W. Grimes vrele(vp); 6388f364875SJulian Elischer free(buf, M_TEMP); 639df8bae1dSRodney W. Grimes return (EADDRINUSE); 640df8bae1dSRodney W. Grimes } 6418f364875SJulian Elischer error = vn_start_write(NULL, &mp, V_XSLEEP | PCATCH); 6428f364875SJulian Elischer if (error) { 6438f364875SJulian Elischer free(buf, M_TEMP); 644f2a2857bSKirk McKusick return (error); 6458f364875SJulian Elischer } 646f2a2857bSKirk McKusick goto restart; 647f2a2857bSKirk McKusick } 648df8bae1dSRodney W. Grimes VATTR_NULL(&vattr); 649df8bae1dSRodney W. Grimes vattr.va_type = VSOCK; 650b40ce416SJulian Elischer vattr.va_mode = (ACCESSPERMS & ~td->td_proc->p_fd->fd_cmask); 6516ea48a90SRobert Watson #ifdef MAC 6526ea48a90SRobert Watson error = mac_check_vnode_create(td->td_ucred, nd.ni_dvp, &nd.ni_cnd, 6536ea48a90SRobert Watson &vattr); 6546151efaaSRobert Watson #endif 6556ea48a90SRobert Watson if (error == 0) { 656a854ed98SJohn Baldwin VOP_LEASE(nd.ni_dvp, td, td->td_ucred, LEASE_WRITE); 6577be2d300SMike Smith error = VOP_CREATE(nd.ni_dvp, &nd.ni_vp, &nd.ni_cnd, &vattr); 6586ea48a90SRobert Watson } 659762e6b85SEivind Eklund NDFREE(&nd, NDF_ONLY_PNBUF); 6607be2d300SMike Smith vput(nd.ni_dvp); 6618f364875SJulian Elischer if (error) { 6628f364875SJulian Elischer free(buf, M_TEMP); 663df8bae1dSRodney W. Grimes return (error); 6648f364875SJulian Elischer } 665df8bae1dSRodney W. Grimes vp = nd.ni_vp; 666df8bae1dSRodney W. Grimes vp->v_socket = unp->unp_socket; 667df8bae1dSRodney W. Grimes unp->unp_vnode = vp; 66857bf258eSGarrett Wollman unp->unp_addr = (struct sockaddr_un *)dup_sockaddr(nam, 1); 669b40ce416SJulian Elischer VOP_UNLOCK(vp, 0, td); 670f2a2857bSKirk McKusick vn_finished_write(mp); 6718f364875SJulian Elischer free(buf, M_TEMP); 672df8bae1dSRodney W. Grimes return (0); 673df8bae1dSRodney W. Grimes } 674df8bae1dSRodney W. Grimes 675f708ef1bSPoul-Henning Kamp static int 676b40ce416SJulian Elischer unp_connect(so, nam, td) 677df8bae1dSRodney W. Grimes struct socket *so; 67857bf258eSGarrett Wollman struct sockaddr *nam; 679b40ce416SJulian Elischer struct thread *td; 680df8bae1dSRodney W. Grimes { 68157bf258eSGarrett Wollman register struct sockaddr_un *soun = (struct sockaddr_un *)nam; 682df8bae1dSRodney W. Grimes register struct vnode *vp; 683df8bae1dSRodney W. Grimes register struct socket *so2, *so3; 6840c1bb4fbSDima Dorfman struct unpcb *unp, *unp2, *unp3; 68557bf258eSGarrett Wollman int error, len; 686df8bae1dSRodney W. Grimes struct nameidata nd; 68757bf258eSGarrett Wollman char buf[SOCK_MAXADDRLEN]; 688df8bae1dSRodney W. Grimes 68957bf258eSGarrett Wollman len = nam->sa_len - offsetof(struct sockaddr_un, sun_path); 69057bf258eSGarrett Wollman if (len <= 0) 691e5aeaa0cSDag-Erling Smørgrav return (EINVAL); 69255c85568SRobert Drehmel strlcpy(buf, soun->sun_path, len + 1); 69357bf258eSGarrett Wollman 694b40ce416SJulian Elischer NDINIT(&nd, LOOKUP, FOLLOW | LOCKLEAF, UIO_SYSSPACE, buf, td); 695797f2d22SPoul-Henning Kamp error = namei(&nd); 696797f2d22SPoul-Henning Kamp if (error) 697df8bae1dSRodney W. Grimes return (error); 698df8bae1dSRodney W. Grimes vp = nd.ni_vp; 699762e6b85SEivind Eklund NDFREE(&nd, NDF_ONLY_PNBUF); 700df8bae1dSRodney W. Grimes if (vp->v_type != VSOCK) { 701df8bae1dSRodney W. Grimes error = ENOTSOCK; 702df8bae1dSRodney W. Grimes goto bad; 703df8bae1dSRodney W. Grimes } 704a854ed98SJohn Baldwin error = VOP_ACCESS(vp, VWRITE, td->td_ucred, td); 705797f2d22SPoul-Henning Kamp if (error) 706df8bae1dSRodney W. Grimes goto bad; 707df8bae1dSRodney W. Grimes so2 = vp->v_socket; 708df8bae1dSRodney W. Grimes if (so2 == 0) { 709df8bae1dSRodney W. Grimes error = ECONNREFUSED; 710df8bae1dSRodney W. Grimes goto bad; 711df8bae1dSRodney W. Grimes } 712df8bae1dSRodney W. Grimes if (so->so_type != so2->so_type) { 713df8bae1dSRodney W. Grimes error = EPROTOTYPE; 714df8bae1dSRodney W. Grimes goto bad; 715df8bae1dSRodney W. Grimes } 716df8bae1dSRodney W. Grimes if (so->so_proto->pr_flags & PR_CONNREQUIRED) { 7174cc20ab1SSeigo Tanimura if ((so2->so_options & SO_ACCEPTCONN) == 0 || 7184cc20ab1SSeigo Tanimura (so3 = sonewconn(so2, 0)) == 0) { 719df8bae1dSRodney W. Grimes error = ECONNREFUSED; 720df8bae1dSRodney W. Grimes goto bad; 721df8bae1dSRodney W. Grimes } 7220c1bb4fbSDima Dorfman unp = sotounpcb(so); 723df8bae1dSRodney W. Grimes unp2 = sotounpcb(so2); 724df8bae1dSRodney W. Grimes unp3 = sotounpcb(so3); 725df8bae1dSRodney W. Grimes if (unp2->unp_addr) 72657bf258eSGarrett Wollman unp3->unp_addr = (struct sockaddr_un *) 72757bf258eSGarrett Wollman dup_sockaddr((struct sockaddr *) 72857bf258eSGarrett Wollman unp2->unp_addr, 1); 7290c1bb4fbSDima Dorfman 7300c1bb4fbSDima Dorfman /* 7310c1bb4fbSDima Dorfman * unp_peercred management: 7320c1bb4fbSDima Dorfman * 7330c1bb4fbSDima Dorfman * The connecter's (client's) credentials are copied 7340c1bb4fbSDima Dorfman * from its process structure at the time of connect() 7350c1bb4fbSDima Dorfman * (which is now). 7360c1bb4fbSDima Dorfman */ 737a854ed98SJohn Baldwin cru2x(td->td_ucred, &unp3->unp_peercred); 7380c1bb4fbSDima Dorfman unp3->unp_flags |= UNP_HAVEPC; 7390c1bb4fbSDima Dorfman /* 7400c1bb4fbSDima Dorfman * The receiver's (server's) credentials are copied 7410c1bb4fbSDima Dorfman * from the unp_peercred member of socket on which the 7420c1bb4fbSDima Dorfman * former called listen(); unp_listen() cached that 7430c1bb4fbSDima Dorfman * process's credentials at that time so we can use 7440c1bb4fbSDima Dorfman * them now. 7450c1bb4fbSDima Dorfman */ 7460c1bb4fbSDima Dorfman KASSERT(unp2->unp_flags & UNP_HAVEPCCACHED, 7470c1bb4fbSDima Dorfman ("unp_connect: listener without cached peercred")); 7480c1bb4fbSDima Dorfman memcpy(&unp->unp_peercred, &unp2->unp_peercred, 7490c1bb4fbSDima Dorfman sizeof(unp->unp_peercred)); 7500c1bb4fbSDima Dorfman unp->unp_flags |= UNP_HAVEPC; 751335654d7SRobert Watson #ifdef MAC 752335654d7SRobert Watson mac_set_socket_peer_from_socket(so, so3); 753335654d7SRobert Watson mac_set_socket_peer_from_socket(so3, so); 754335654d7SRobert Watson #endif 7550c1bb4fbSDima Dorfman 756df8bae1dSRodney W. Grimes so2 = so3; 757df8bae1dSRodney W. Grimes } 758df8bae1dSRodney W. Grimes error = unp_connect2(so, so2); 759df8bae1dSRodney W. Grimes bad: 760df8bae1dSRodney W. Grimes vput(vp); 761df8bae1dSRodney W. Grimes return (error); 762df8bae1dSRodney W. Grimes } 763df8bae1dSRodney W. Grimes 76426f9a767SRodney W. Grimes int 765df8bae1dSRodney W. Grimes unp_connect2(so, so2) 766df8bae1dSRodney W. Grimes register struct socket *so; 767df8bae1dSRodney W. Grimes register struct socket *so2; 768df8bae1dSRodney W. Grimes { 769df8bae1dSRodney W. Grimes register struct unpcb *unp = sotounpcb(so); 770df8bae1dSRodney W. Grimes register struct unpcb *unp2; 771df8bae1dSRodney W. Grimes 772df8bae1dSRodney W. Grimes if (so2->so_type != so->so_type) 773df8bae1dSRodney W. Grimes return (EPROTOTYPE); 774df8bae1dSRodney W. Grimes unp2 = sotounpcb(so2); 775df8bae1dSRodney W. Grimes unp->unp_conn = unp2; 776df8bae1dSRodney W. Grimes switch (so->so_type) { 777df8bae1dSRodney W. Grimes 778df8bae1dSRodney W. Grimes case SOCK_DGRAM: 77998271db4SGarrett Wollman LIST_INSERT_HEAD(&unp2->unp_refs, unp, unp_reflink); 780df8bae1dSRodney W. Grimes soisconnected(so); 781df8bae1dSRodney W. Grimes break; 782df8bae1dSRodney W. Grimes 783df8bae1dSRodney W. Grimes case SOCK_STREAM: 784df8bae1dSRodney W. Grimes unp2->unp_conn = unp; 785df8bae1dSRodney W. Grimes soisconnected(so); 786df8bae1dSRodney W. Grimes soisconnected(so2); 787df8bae1dSRodney W. Grimes break; 788df8bae1dSRodney W. Grimes 789df8bae1dSRodney W. Grimes default: 790df8bae1dSRodney W. Grimes panic("unp_connect2"); 791df8bae1dSRodney W. Grimes } 792df8bae1dSRodney W. Grimes return (0); 793df8bae1dSRodney W. Grimes } 794df8bae1dSRodney W. Grimes 795f708ef1bSPoul-Henning Kamp static void 796df8bae1dSRodney W. Grimes unp_disconnect(unp) 797df8bae1dSRodney W. Grimes struct unpcb *unp; 798df8bae1dSRodney W. Grimes { 799df8bae1dSRodney W. Grimes register struct unpcb *unp2 = unp->unp_conn; 800df8bae1dSRodney W. Grimes 801df8bae1dSRodney W. Grimes if (unp2 == 0) 802df8bae1dSRodney W. Grimes return; 803df8bae1dSRodney W. Grimes unp->unp_conn = 0; 804df8bae1dSRodney W. Grimes switch (unp->unp_socket->so_type) { 805df8bae1dSRodney W. Grimes 806df8bae1dSRodney W. Grimes case SOCK_DGRAM: 80798271db4SGarrett Wollman LIST_REMOVE(unp, unp_reflink); 808df8bae1dSRodney W. Grimes unp->unp_socket->so_state &= ~SS_ISCONNECTED; 809df8bae1dSRodney W. Grimes break; 810df8bae1dSRodney W. Grimes 811df8bae1dSRodney W. Grimes case SOCK_STREAM: 812df8bae1dSRodney W. Grimes soisdisconnected(unp->unp_socket); 813df8bae1dSRodney W. Grimes unp2->unp_conn = 0; 814df8bae1dSRodney W. Grimes soisdisconnected(unp2->unp_socket); 815df8bae1dSRodney W. Grimes break; 816df8bae1dSRodney W. Grimes } 817df8bae1dSRodney W. Grimes } 818df8bae1dSRodney W. Grimes 819df8bae1dSRodney W. Grimes #ifdef notdef 82026f9a767SRodney W. Grimes void 821df8bae1dSRodney W. Grimes unp_abort(unp) 822df8bae1dSRodney W. Grimes struct unpcb *unp; 823df8bae1dSRodney W. Grimes { 824df8bae1dSRodney W. Grimes 825df8bae1dSRodney W. Grimes unp_detach(unp); 826df8bae1dSRodney W. Grimes } 827df8bae1dSRodney W. Grimes #endif 828df8bae1dSRodney W. Grimes 82998271db4SGarrett Wollman static int 83082d9ae4eSPoul-Henning Kamp unp_pcblist(SYSCTL_HANDLER_ARGS) 83198271db4SGarrett Wollman { 832f5ef029eSPoul-Henning Kamp int error, i, n; 83398271db4SGarrett Wollman struct unpcb *unp, **unp_list; 83498271db4SGarrett Wollman unp_gen_t gencnt; 8358f364875SJulian Elischer struct xunpgen *xug; 83698271db4SGarrett Wollman struct unp_head *head; 8378f364875SJulian Elischer struct xunpcb *xu; 83898271db4SGarrett Wollman 839a23d65bfSBruce Evans head = ((intptr_t)arg1 == SOCK_DGRAM ? &unp_dhead : &unp_shead); 84098271db4SGarrett Wollman 84198271db4SGarrett Wollman /* 84298271db4SGarrett Wollman * The process of preparing the PCB list is too time-consuming and 84398271db4SGarrett Wollman * resource-intensive to repeat twice on every request. 84498271db4SGarrett Wollman */ 84598271db4SGarrett Wollman if (req->oldptr == 0) { 84698271db4SGarrett Wollman n = unp_count; 8478f364875SJulian Elischer req->oldidx = 2 * (sizeof *xug) 84898271db4SGarrett Wollman + (n + n/8) * sizeof(struct xunpcb); 849e5aeaa0cSDag-Erling Smørgrav return (0); 85098271db4SGarrett Wollman } 85198271db4SGarrett Wollman 85298271db4SGarrett Wollman if (req->newptr != 0) 853e5aeaa0cSDag-Erling Smørgrav return (EPERM); 85498271db4SGarrett Wollman 85598271db4SGarrett Wollman /* 85698271db4SGarrett Wollman * OK, now we're committed to doing something. 85798271db4SGarrett Wollman */ 858a163d034SWarner Losh xug = malloc(sizeof(*xug), M_TEMP, M_WAITOK); 85998271db4SGarrett Wollman gencnt = unp_gencnt; 86098271db4SGarrett Wollman n = unp_count; 86198271db4SGarrett Wollman 8628f364875SJulian Elischer xug->xug_len = sizeof *xug; 8638f364875SJulian Elischer xug->xug_count = n; 8648f364875SJulian Elischer xug->xug_gen = gencnt; 8658f364875SJulian Elischer xug->xug_sogen = so_gencnt; 8668f364875SJulian Elischer error = SYSCTL_OUT(req, xug, sizeof *xug); 8678f364875SJulian Elischer if (error) { 8688f364875SJulian Elischer free(xug, M_TEMP); 869e5aeaa0cSDag-Erling Smørgrav return (error); 8708f364875SJulian Elischer } 87198271db4SGarrett Wollman 872a163d034SWarner Losh unp_list = malloc(n * sizeof *unp_list, M_TEMP, M_WAITOK); 87398271db4SGarrett Wollman 8742e3c8fcbSPoul-Henning Kamp for (unp = LIST_FIRST(head), i = 0; unp && i < n; 8752e3c8fcbSPoul-Henning Kamp unp = LIST_NEXT(unp, unp_link)) { 8768a7d8cc6SRobert Watson if (unp->unp_gencnt <= gencnt) { 877a854ed98SJohn Baldwin if (cr_cansee(req->td->td_ucred, 8788a7d8cc6SRobert Watson unp->unp_socket->so_cred)) 8794787fd37SPaul Saab continue; 88098271db4SGarrett Wollman unp_list[i++] = unp; 88198271db4SGarrett Wollman } 8824787fd37SPaul Saab } 88398271db4SGarrett Wollman n = i; /* in case we lost some during malloc */ 88498271db4SGarrett Wollman 88598271db4SGarrett Wollman error = 0; 886a163d034SWarner Losh xu = malloc(sizeof(*xu), M_TEMP, M_WAITOK); 88798271db4SGarrett Wollman for (i = 0; i < n; i++) { 88898271db4SGarrett Wollman unp = unp_list[i]; 88998271db4SGarrett Wollman if (unp->unp_gencnt <= gencnt) { 8908f364875SJulian Elischer xu->xu_len = sizeof *xu; 8918f364875SJulian Elischer xu->xu_unpp = unp; 89298271db4SGarrett Wollman /* 89398271db4SGarrett Wollman * XXX - need more locking here to protect against 89498271db4SGarrett Wollman * connect/disconnect races for SMP. 89598271db4SGarrett Wollman */ 89698271db4SGarrett Wollman if (unp->unp_addr) 8978f364875SJulian Elischer bcopy(unp->unp_addr, &xu->xu_addr, 89898271db4SGarrett Wollman unp->unp_addr->sun_len); 89998271db4SGarrett Wollman if (unp->unp_conn && unp->unp_conn->unp_addr) 90098271db4SGarrett Wollman bcopy(unp->unp_conn->unp_addr, 9018f364875SJulian Elischer &xu->xu_caddr, 90298271db4SGarrett Wollman unp->unp_conn->unp_addr->sun_len); 9038f364875SJulian Elischer bcopy(unp, &xu->xu_unp, sizeof *unp); 9048f364875SJulian Elischer sotoxsocket(unp->unp_socket, &xu->xu_socket); 9058f364875SJulian Elischer error = SYSCTL_OUT(req, xu, sizeof *xu); 90698271db4SGarrett Wollman } 90798271db4SGarrett Wollman } 9088f364875SJulian Elischer free(xu, M_TEMP); 90998271db4SGarrett Wollman if (!error) { 91098271db4SGarrett Wollman /* 91198271db4SGarrett Wollman * Give the user an updated idea of our state. 91298271db4SGarrett Wollman * If the generation differs from what we told 91398271db4SGarrett Wollman * her before, she knows that something happened 91498271db4SGarrett Wollman * while we were processing this request, and it 91598271db4SGarrett Wollman * might be necessary to retry. 91698271db4SGarrett Wollman */ 9178f364875SJulian Elischer xug->xug_gen = unp_gencnt; 9188f364875SJulian Elischer xug->xug_sogen = so_gencnt; 9198f364875SJulian Elischer xug->xug_count = unp_count; 9208f364875SJulian Elischer error = SYSCTL_OUT(req, xug, sizeof *xug); 92198271db4SGarrett Wollman } 92298271db4SGarrett Wollman free(unp_list, M_TEMP); 9238f364875SJulian Elischer free(xug, M_TEMP); 924e5aeaa0cSDag-Erling Smørgrav return (error); 92598271db4SGarrett Wollman } 92698271db4SGarrett Wollman 92798271db4SGarrett Wollman SYSCTL_PROC(_net_local_dgram, OID_AUTO, pcblist, CTLFLAG_RD, 92898271db4SGarrett Wollman (caddr_t)(long)SOCK_DGRAM, 0, unp_pcblist, "S,xunpcb", 92998271db4SGarrett Wollman "List of active local datagram sockets"); 93098271db4SGarrett Wollman SYSCTL_PROC(_net_local_stream, OID_AUTO, pcblist, CTLFLAG_RD, 93198271db4SGarrett Wollman (caddr_t)(long)SOCK_STREAM, 0, unp_pcblist, "S,xunpcb", 93298271db4SGarrett Wollman "List of active local stream sockets"); 93398271db4SGarrett Wollman 934f708ef1bSPoul-Henning Kamp static void 935df8bae1dSRodney W. Grimes unp_shutdown(unp) 936df8bae1dSRodney W. Grimes struct unpcb *unp; 937df8bae1dSRodney W. Grimes { 938df8bae1dSRodney W. Grimes struct socket *so; 939df8bae1dSRodney W. Grimes 940df8bae1dSRodney W. Grimes if (unp->unp_socket->so_type == SOCK_STREAM && unp->unp_conn && 941df8bae1dSRodney W. Grimes (so = unp->unp_conn->unp_socket)) 942df8bae1dSRodney W. Grimes socantrcvmore(so); 943df8bae1dSRodney W. Grimes } 944df8bae1dSRodney W. Grimes 945f708ef1bSPoul-Henning Kamp static void 946df8bae1dSRodney W. Grimes unp_drop(unp, errno) 947df8bae1dSRodney W. Grimes struct unpcb *unp; 948df8bae1dSRodney W. Grimes int errno; 949df8bae1dSRodney W. Grimes { 950df8bae1dSRodney W. Grimes struct socket *so = unp->unp_socket; 951df8bae1dSRodney W. Grimes 952df8bae1dSRodney W. Grimes so->so_error = errno; 953df8bae1dSRodney W. Grimes unp_disconnect(unp); 954df8bae1dSRodney W. Grimes } 955df8bae1dSRodney W. Grimes 956df8bae1dSRodney W. Grimes #ifdef notdef 95726f9a767SRodney W. Grimes void 958df8bae1dSRodney W. Grimes unp_drain() 959df8bae1dSRodney W. Grimes { 960df8bae1dSRodney W. Grimes 961df8bae1dSRodney W. Grimes } 962df8bae1dSRodney W. Grimes #endif 963df8bae1dSRodney W. Grimes 9642bc21ed9SDavid Malone static void 9652bc21ed9SDavid Malone unp_freerights(rp, fdcount) 9662bc21ed9SDavid Malone struct file **rp; 9672bc21ed9SDavid Malone int fdcount; 968df8bae1dSRodney W. Grimes { 9692bc21ed9SDavid Malone int i; 9702bc21ed9SDavid Malone struct file *fp; 971df8bae1dSRodney W. Grimes 9722bc21ed9SDavid Malone for (i = 0; i < fdcount; i++) { 973df8bae1dSRodney W. Grimes fp = *rp; 9748692c025SYoshinobu Inoue /* 9752bc21ed9SDavid Malone * zero the pointer before calling 9762bc21ed9SDavid Malone * unp_discard since it may end up 9772bc21ed9SDavid Malone * in unp_gc().. 9788692c025SYoshinobu Inoue */ 979df8bae1dSRodney W. Grimes *rp++ = 0; 9808692c025SYoshinobu Inoue unp_discard(fp); 981df8bae1dSRodney W. Grimes } 9822bc21ed9SDavid Malone } 9832bc21ed9SDavid Malone 9842bc21ed9SDavid Malone int 9852bc21ed9SDavid Malone unp_externalize(control, controlp) 9862bc21ed9SDavid Malone struct mbuf *control, **controlp; 9872bc21ed9SDavid Malone { 9882bc21ed9SDavid Malone struct thread *td = curthread; /* XXX */ 9892bc21ed9SDavid Malone struct cmsghdr *cm = mtod(control, struct cmsghdr *); 9902bc21ed9SDavid Malone int i; 9912bc21ed9SDavid Malone int *fdp; 9922bc21ed9SDavid Malone struct file **rp; 9932bc21ed9SDavid Malone struct file *fp; 9942bc21ed9SDavid Malone void *data; 9952bc21ed9SDavid Malone socklen_t clen = control->m_len, datalen; 9962bc21ed9SDavid Malone int error, newfds; 9972bc21ed9SDavid Malone int f; 9982bc21ed9SDavid Malone u_int newlen; 9992bc21ed9SDavid Malone 10002bc21ed9SDavid Malone error = 0; 10012bc21ed9SDavid Malone if (controlp != NULL) /* controlp == NULL => free control messages */ 10022bc21ed9SDavid Malone *controlp = NULL; 10032bc21ed9SDavid Malone 10042bc21ed9SDavid Malone while (cm != NULL) { 10052bc21ed9SDavid Malone if (sizeof(*cm) > clen || cm->cmsg_len > clen) { 10062bc21ed9SDavid Malone error = EINVAL; 10072bc21ed9SDavid Malone break; 10082bc21ed9SDavid Malone } 10092bc21ed9SDavid Malone 10102bc21ed9SDavid Malone data = CMSG_DATA(cm); 10112bc21ed9SDavid Malone datalen = (caddr_t)cm + cm->cmsg_len - (caddr_t)data; 10122bc21ed9SDavid Malone 10132bc21ed9SDavid Malone if (cm->cmsg_level == SOL_SOCKET 10142bc21ed9SDavid Malone && cm->cmsg_type == SCM_RIGHTS) { 10152bc21ed9SDavid Malone newfds = datalen / sizeof(struct file *); 10162bc21ed9SDavid Malone rp = data; 10172bc21ed9SDavid Malone 1018e2f9a08bSOlivier Houchard /* If we're not outputting the descriptors free them. */ 10192bc21ed9SDavid Malone if (error || controlp == NULL) { 10202bc21ed9SDavid Malone unp_freerights(rp, newfds); 10212bc21ed9SDavid Malone goto next; 10222bc21ed9SDavid Malone } 1023426da3bcSAlfred Perlstein FILEDESC_LOCK(td->td_proc->p_fd); 10242bc21ed9SDavid Malone /* if the new FD's will not fit free them. */ 10252bc21ed9SDavid Malone if (!fdavail(td, newfds)) { 1026426da3bcSAlfred Perlstein FILEDESC_UNLOCK(td->td_proc->p_fd); 10272bc21ed9SDavid Malone error = EMSGSIZE; 10282bc21ed9SDavid Malone unp_freerights(rp, newfds); 10292bc21ed9SDavid Malone goto next; 1030df8bae1dSRodney W. Grimes } 1031ed5b7817SJulian Elischer /* 10322bc21ed9SDavid Malone * now change each pointer to an fd in the global 10332bc21ed9SDavid Malone * table to an integer that is the index to the 10342bc21ed9SDavid Malone * local fd table entry that we set up to point 10352bc21ed9SDavid Malone * to the global one we are transferring. 1036ed5b7817SJulian Elischer */ 10372bc21ed9SDavid Malone newlen = newfds * sizeof(int); 10382bc21ed9SDavid Malone *controlp = sbcreatecontrol(NULL, newlen, 10392bc21ed9SDavid Malone SCM_RIGHTS, SOL_SOCKET); 10402bc21ed9SDavid Malone if (*controlp == NULL) { 1041426da3bcSAlfred Perlstein FILEDESC_UNLOCK(td->td_proc->p_fd); 10422bc21ed9SDavid Malone error = E2BIG; 10432bc21ed9SDavid Malone unp_freerights(rp, newfds); 10442bc21ed9SDavid Malone goto next; 10452bc21ed9SDavid Malone } 10462bc21ed9SDavid Malone 10472bc21ed9SDavid Malone fdp = (int *) 10482bc21ed9SDavid Malone CMSG_DATA(mtod(*controlp, struct cmsghdr *)); 1049df8bae1dSRodney W. Grimes for (i = 0; i < newfds; i++) { 1050b40ce416SJulian Elischer if (fdalloc(td, 0, &f)) 10512bc21ed9SDavid Malone panic("unp_externalize fdalloc failed"); 10528692c025SYoshinobu Inoue fp = *rp++; 1053b40ce416SJulian Elischer td->td_proc->p_fd->fd_ofiles[f] = fp; 1054426da3bcSAlfred Perlstein FILE_LOCK(fp); 1055df8bae1dSRodney W. Grimes fp->f_msgcount--; 1056426da3bcSAlfred Perlstein FILE_UNLOCK(fp); 1057df8bae1dSRodney W. Grimes unp_rights--; 10588692c025SYoshinobu Inoue *fdp++ = f; 1059df8bae1dSRodney W. Grimes } 1060426da3bcSAlfred Perlstein FILEDESC_UNLOCK(td->td_proc->p_fd); 10612bc21ed9SDavid Malone } else { /* We can just copy anything else across */ 10622bc21ed9SDavid Malone if (error || controlp == NULL) 10632bc21ed9SDavid Malone goto next; 10642bc21ed9SDavid Malone *controlp = sbcreatecontrol(NULL, datalen, 10652bc21ed9SDavid Malone cm->cmsg_type, cm->cmsg_level); 10662bc21ed9SDavid Malone if (*controlp == NULL) { 10672bc21ed9SDavid Malone error = ENOBUFS; 10682bc21ed9SDavid Malone goto next; 10692bc21ed9SDavid Malone } 10702bc21ed9SDavid Malone bcopy(data, 10712bc21ed9SDavid Malone CMSG_DATA(mtod(*controlp, struct cmsghdr *)), 10722bc21ed9SDavid Malone datalen); 10732bc21ed9SDavid Malone } 10742bc21ed9SDavid Malone 10752bc21ed9SDavid Malone controlp = &(*controlp)->m_next; 10762bc21ed9SDavid Malone 10772bc21ed9SDavid Malone next: 10782bc21ed9SDavid Malone if (CMSG_SPACE(datalen) < clen) { 10792bc21ed9SDavid Malone clen -= CMSG_SPACE(datalen); 10802bc21ed9SDavid Malone cm = (struct cmsghdr *) 10812bc21ed9SDavid Malone ((caddr_t)cm + CMSG_SPACE(datalen)); 10828692c025SYoshinobu Inoue } else { 10832bc21ed9SDavid Malone clen = 0; 10842bc21ed9SDavid Malone cm = NULL; 10858692c025SYoshinobu Inoue } 10868692c025SYoshinobu Inoue } 10878692c025SYoshinobu Inoue 10882bc21ed9SDavid Malone m_freem(control); 10892bc21ed9SDavid Malone 10902bc21ed9SDavid Malone return (error); 1091df8bae1dSRodney W. Grimes } 1092df8bae1dSRodney W. Grimes 109398271db4SGarrett Wollman void 109498271db4SGarrett Wollman unp_init(void) 109598271db4SGarrett Wollman { 10969e9d298aSJeff Roberson unp_zone = uma_zcreate("unpcb", sizeof(struct unpcb), NULL, NULL, 10979e9d298aSJeff Roberson NULL, NULL, UMA_ALIGN_PTR, UMA_ZONE_NOFREE); 1098586c8b6bSJeff Roberson uma_zone_set_max(unp_zone, nmbclusters); 109998271db4SGarrett Wollman if (unp_zone == 0) 110098271db4SGarrett Wollman panic("unp_init"); 110198271db4SGarrett Wollman LIST_INIT(&unp_dhead); 110298271db4SGarrett Wollman LIST_INIT(&unp_shead); 110398271db4SGarrett Wollman } 110498271db4SGarrett Wollman 1105f708ef1bSPoul-Henning Kamp static int 11062bc21ed9SDavid Malone unp_internalize(controlp, td) 11072bc21ed9SDavid Malone struct mbuf **controlp; 1108b40ce416SJulian Elischer struct thread *td; 1109df8bae1dSRodney W. Grimes { 11102bc21ed9SDavid Malone struct mbuf *control = *controlp; 1111b40ce416SJulian Elischer struct proc *p = td->td_proc; 11128692c025SYoshinobu Inoue struct filedesc *fdescp = p->p_fd; 11132bc21ed9SDavid Malone struct cmsghdr *cm = mtod(control, struct cmsghdr *); 11142bc21ed9SDavid Malone struct cmsgcred *cmcred; 11152bc21ed9SDavid Malone struct file **rp; 11162bc21ed9SDavid Malone struct file *fp; 11172bc21ed9SDavid Malone struct timeval *tv; 11182bc21ed9SDavid Malone int i, fd, *fdp; 11192bc21ed9SDavid Malone void *data; 11202bc21ed9SDavid Malone socklen_t clen = control->m_len, datalen; 11212bc21ed9SDavid Malone int error, oldfds; 11228692c025SYoshinobu Inoue u_int newlen; 1123df8bae1dSRodney W. Grimes 11242bc21ed9SDavid Malone error = 0; 11252bc21ed9SDavid Malone *controlp = NULL; 11260b788fa1SBill Paul 11272bc21ed9SDavid Malone while (cm != NULL) { 11282bc21ed9SDavid Malone if (sizeof(*cm) > clen || cm->cmsg_level != SOL_SOCKET 11292bc21ed9SDavid Malone || cm->cmsg_len > clen) { 11302bc21ed9SDavid Malone error = EINVAL; 11312bc21ed9SDavid Malone goto out; 11322bc21ed9SDavid Malone } 11332bc21ed9SDavid Malone 11342bc21ed9SDavid Malone data = CMSG_DATA(cm); 11352bc21ed9SDavid Malone datalen = (caddr_t)cm + cm->cmsg_len - (caddr_t)data; 11362bc21ed9SDavid Malone 11372bc21ed9SDavid Malone switch (cm->cmsg_type) { 11380b788fa1SBill Paul /* 11390b788fa1SBill Paul * Fill in credential information. 11400b788fa1SBill Paul */ 11412bc21ed9SDavid Malone case SCM_CREDS: 11422bc21ed9SDavid Malone *controlp = sbcreatecontrol(NULL, sizeof(*cmcred), 11432bc21ed9SDavid Malone SCM_CREDS, SOL_SOCKET); 11442bc21ed9SDavid Malone if (*controlp == NULL) { 11452bc21ed9SDavid Malone error = ENOBUFS; 11462bc21ed9SDavid Malone goto out; 11472bc21ed9SDavid Malone } 11482bc21ed9SDavid Malone 11492bc21ed9SDavid Malone cmcred = (struct cmsgcred *) 11502bc21ed9SDavid Malone CMSG_DATA(mtod(*controlp, struct cmsghdr *)); 11510b788fa1SBill Paul cmcred->cmcred_pid = p->p_pid; 1152a854ed98SJohn Baldwin cmcred->cmcred_uid = td->td_ucred->cr_ruid; 1153a854ed98SJohn Baldwin cmcred->cmcred_gid = td->td_ucred->cr_rgid; 1154a854ed98SJohn Baldwin cmcred->cmcred_euid = td->td_ucred->cr_uid; 1155a854ed98SJohn Baldwin cmcred->cmcred_ngroups = MIN(td->td_ucred->cr_ngroups, 11560b788fa1SBill Paul CMGROUP_MAX); 11570b788fa1SBill Paul for (i = 0; i < cmcred->cmcred_ngroups; i++) 11582bc21ed9SDavid Malone cmcred->cmcred_groups[i] = 1159a854ed98SJohn Baldwin td->td_ucred->cr_groups[i]; 11602bc21ed9SDavid Malone break; 11610b788fa1SBill Paul 11622bc21ed9SDavid Malone case SCM_RIGHTS: 11632bc21ed9SDavid Malone oldfds = datalen / sizeof (int); 1164ed5b7817SJulian Elischer /* 11652bc21ed9SDavid Malone * check that all the FDs passed in refer to legal files 1166ed5b7817SJulian Elischer * If not, reject the entire operation. 1167ed5b7817SJulian Elischer */ 11682bc21ed9SDavid Malone fdp = data; 1169426da3bcSAlfred Perlstein FILEDESC_LOCK(fdescp); 1170df8bae1dSRodney W. Grimes for (i = 0; i < oldfds; i++) { 11718692c025SYoshinobu Inoue fd = *fdp++; 11728692c025SYoshinobu Inoue if ((unsigned)fd >= fdescp->fd_nfiles || 11732bc21ed9SDavid Malone fdescp->fd_ofiles[fd] == NULL) { 1174426da3bcSAlfred Perlstein FILEDESC_UNLOCK(fdescp); 11752bc21ed9SDavid Malone error = EBADF; 11762bc21ed9SDavid Malone goto out; 11772bc21ed9SDavid Malone } 1178e7d6662fSAlfred Perlstein fp = fdescp->fd_ofiles[fd]; 1179e7d6662fSAlfred Perlstein if (!(fp->f_ops->fo_flags & DFLAG_PASSABLE)) { 1180e7d6662fSAlfred Perlstein FILEDESC_UNLOCK(fdescp); 1181e7d6662fSAlfred Perlstein error = EOPNOTSUPP; 1182e7d6662fSAlfred Perlstein goto out; 1183e7d6662fSAlfred Perlstein } 1184e7d6662fSAlfred Perlstein 1185df8bae1dSRodney W. Grimes } 1186ed5b7817SJulian Elischer /* 1187ed5b7817SJulian Elischer * Now replace the integer FDs with pointers to 1188ed5b7817SJulian Elischer * the associated global file table entry.. 1189ed5b7817SJulian Elischer */ 11902bc21ed9SDavid Malone newlen = oldfds * sizeof(struct file *); 11912bc21ed9SDavid Malone *controlp = sbcreatecontrol(NULL, newlen, 11922bc21ed9SDavid Malone SCM_RIGHTS, SOL_SOCKET); 11932bc21ed9SDavid Malone if (*controlp == NULL) { 1194426da3bcSAlfred Perlstein FILEDESC_UNLOCK(fdescp); 11952bc21ed9SDavid Malone error = E2BIG; 11962bc21ed9SDavid Malone goto out; 11978692c025SYoshinobu Inoue } 11988692c025SYoshinobu Inoue 11992bc21ed9SDavid Malone fdp = data; 12002bc21ed9SDavid Malone rp = (struct file **) 12012bc21ed9SDavid Malone CMSG_DATA(mtod(*controlp, struct cmsghdr *)); 12028692c025SYoshinobu Inoue for (i = 0; i < oldfds; i++) { 12038692c025SYoshinobu Inoue fp = fdescp->fd_ofiles[*fdp++]; 1204df8bae1dSRodney W. Grimes *rp++ = fp; 1205426da3bcSAlfred Perlstein FILE_LOCK(fp); 1206df8bae1dSRodney W. Grimes fp->f_count++; 1207df8bae1dSRodney W. Grimes fp->f_msgcount++; 1208426da3bcSAlfred Perlstein FILE_UNLOCK(fp); 1209df8bae1dSRodney W. Grimes unp_rights++; 1210df8bae1dSRodney W. Grimes } 1211426da3bcSAlfred Perlstein FILEDESC_UNLOCK(fdescp); 12122bc21ed9SDavid Malone break; 12132bc21ed9SDavid Malone 12142bc21ed9SDavid Malone case SCM_TIMESTAMP: 12152bc21ed9SDavid Malone *controlp = sbcreatecontrol(NULL, sizeof(*tv), 12162bc21ed9SDavid Malone SCM_TIMESTAMP, SOL_SOCKET); 12172bc21ed9SDavid Malone if (*controlp == NULL) { 12182bc21ed9SDavid Malone error = ENOBUFS; 12192bc21ed9SDavid Malone goto out; 12208692c025SYoshinobu Inoue } 12212bc21ed9SDavid Malone tv = (struct timeval *) 12222bc21ed9SDavid Malone CMSG_DATA(mtod(*controlp, struct cmsghdr *)); 12232bc21ed9SDavid Malone microtime(tv); 12242bc21ed9SDavid Malone break; 12252bc21ed9SDavid Malone 12262bc21ed9SDavid Malone default: 12272bc21ed9SDavid Malone error = EINVAL; 12282bc21ed9SDavid Malone goto out; 12292bc21ed9SDavid Malone } 12302bc21ed9SDavid Malone 12312bc21ed9SDavid Malone controlp = &(*controlp)->m_next; 12322bc21ed9SDavid Malone 12332bc21ed9SDavid Malone if (CMSG_SPACE(datalen) < clen) { 12342bc21ed9SDavid Malone clen -= CMSG_SPACE(datalen); 12352bc21ed9SDavid Malone cm = (struct cmsghdr *) 12362bc21ed9SDavid Malone ((caddr_t)cm + CMSG_SPACE(datalen)); 12372bc21ed9SDavid Malone } else { 12382bc21ed9SDavid Malone clen = 0; 12392bc21ed9SDavid Malone cm = NULL; 12402bc21ed9SDavid Malone } 12412bc21ed9SDavid Malone } 12422bc21ed9SDavid Malone 12432bc21ed9SDavid Malone out: 12442bc21ed9SDavid Malone m_freem(control); 12452bc21ed9SDavid Malone 12462bc21ed9SDavid Malone return (error); 1247df8bae1dSRodney W. Grimes } 1248df8bae1dSRodney W. Grimes 1249f708ef1bSPoul-Henning Kamp static int unp_defer, unp_gcing; 1250df8bae1dSRodney W. Grimes 1251f708ef1bSPoul-Henning Kamp static void 1252df8bae1dSRodney W. Grimes unp_gc() 1253df8bae1dSRodney W. Grimes { 1254df8bae1dSRodney W. Grimes register struct file *fp, *nextfp; 1255df8bae1dSRodney W. Grimes register struct socket *so; 1256df8bae1dSRodney W. Grimes struct file **extra_ref, **fpp; 1257df8bae1dSRodney W. Grimes int nunref, i; 1258df8bae1dSRodney W. Grimes 1259df8bae1dSRodney W. Grimes if (unp_gcing) 1260df8bae1dSRodney W. Grimes return; 1261df8bae1dSRodney W. Grimes unp_gcing = 1; 1262df8bae1dSRodney W. Grimes unp_defer = 0; 1263ed5b7817SJulian Elischer /* 1264ed5b7817SJulian Elischer * before going through all this, set all FDs to 1265ed5b7817SJulian Elischer * be NOT defered and NOT externally accessible 1266ed5b7817SJulian Elischer */ 1267426da3bcSAlfred Perlstein sx_slock(&filelist_lock); 12682e3c8fcbSPoul-Henning Kamp LIST_FOREACH(fp, &filehead, f_list) 1269426da3bcSAlfred Perlstein fp->f_gcflag &= ~(FMARK|FDEFER); 1270df8bae1dSRodney W. Grimes do { 12712e3c8fcbSPoul-Henning Kamp LIST_FOREACH(fp, &filehead, f_list) { 1272426da3bcSAlfred Perlstein FILE_LOCK(fp); 1273ed5b7817SJulian Elischer /* 1274ed5b7817SJulian Elischer * If the file is not open, skip it 1275ed5b7817SJulian Elischer */ 1276426da3bcSAlfred Perlstein if (fp->f_count == 0) { 1277426da3bcSAlfred Perlstein FILE_UNLOCK(fp); 1278df8bae1dSRodney W. Grimes continue; 1279426da3bcSAlfred Perlstein } 1280ed5b7817SJulian Elischer /* 1281ed5b7817SJulian Elischer * If we already marked it as 'defer' in a 1282ed5b7817SJulian Elischer * previous pass, then try process it this time 1283ed5b7817SJulian Elischer * and un-mark it 1284ed5b7817SJulian Elischer */ 1285426da3bcSAlfred Perlstein if (fp->f_gcflag & FDEFER) { 1286426da3bcSAlfred Perlstein fp->f_gcflag &= ~FDEFER; 1287df8bae1dSRodney W. Grimes unp_defer--; 1288df8bae1dSRodney W. Grimes } else { 1289ed5b7817SJulian Elischer /* 1290ed5b7817SJulian Elischer * if it's not defered, then check if it's 1291ed5b7817SJulian Elischer * already marked.. if so skip it 1292ed5b7817SJulian Elischer */ 1293426da3bcSAlfred Perlstein if (fp->f_gcflag & FMARK) { 1294426da3bcSAlfred Perlstein FILE_UNLOCK(fp); 1295df8bae1dSRodney W. Grimes continue; 1296426da3bcSAlfred Perlstein } 1297ed5b7817SJulian Elischer /* 1298ed5b7817SJulian Elischer * If all references are from messages 1299ed5b7817SJulian Elischer * in transit, then skip it. it's not 1300ed5b7817SJulian Elischer * externally accessible. 1301ed5b7817SJulian Elischer */ 1302426da3bcSAlfred Perlstein if (fp->f_count == fp->f_msgcount) { 1303426da3bcSAlfred Perlstein FILE_UNLOCK(fp); 1304df8bae1dSRodney W. Grimes continue; 1305426da3bcSAlfred Perlstein } 1306ed5b7817SJulian Elischer /* 1307ed5b7817SJulian Elischer * If it got this far then it must be 1308ed5b7817SJulian Elischer * externally accessible. 1309ed5b7817SJulian Elischer */ 1310426da3bcSAlfred Perlstein fp->f_gcflag |= FMARK; 1311df8bae1dSRodney W. Grimes } 1312ed5b7817SJulian Elischer /* 1313ed5b7817SJulian Elischer * either it was defered, or it is externally 1314ed5b7817SJulian Elischer * accessible and not already marked so. 1315ed5b7817SJulian Elischer * Now check if it is possibly one of OUR sockets. 1316ed5b7817SJulian Elischer */ 1317df8bae1dSRodney W. Grimes if (fp->f_type != DTYPE_SOCKET || 131848e3128bSMatthew Dillon (so = fp->f_data) == NULL) { 1319426da3bcSAlfred Perlstein FILE_UNLOCK(fp); 1320df8bae1dSRodney W. Grimes continue; 1321426da3bcSAlfred Perlstein } 1322426da3bcSAlfred Perlstein FILE_UNLOCK(fp); 1323748e0b0aSGarrett Wollman if (so->so_proto->pr_domain != &localdomain || 1324df8bae1dSRodney W. Grimes (so->so_proto->pr_flags&PR_RIGHTS) == 0) 1325df8bae1dSRodney W. Grimes continue; 1326df8bae1dSRodney W. Grimes #ifdef notdef 1327df8bae1dSRodney W. Grimes if (so->so_rcv.sb_flags & SB_LOCK) { 1328df8bae1dSRodney W. Grimes /* 1329df8bae1dSRodney W. Grimes * This is problematical; it's not clear 1330df8bae1dSRodney W. Grimes * we need to wait for the sockbuf to be 1331df8bae1dSRodney W. Grimes * unlocked (on a uniprocessor, at least), 1332df8bae1dSRodney W. Grimes * and it's also not clear what to do 1333df8bae1dSRodney W. Grimes * if sbwait returns an error due to receipt 1334df8bae1dSRodney W. Grimes * of a signal. If sbwait does return 1335df8bae1dSRodney W. Grimes * an error, we'll go into an infinite 1336df8bae1dSRodney W. Grimes * loop. Delete all of this for now. 1337df8bae1dSRodney W. Grimes */ 1338df8bae1dSRodney W. Grimes (void) sbwait(&so->so_rcv); 1339df8bae1dSRodney W. Grimes goto restart; 1340df8bae1dSRodney W. Grimes } 1341df8bae1dSRodney W. Grimes #endif 1342ed5b7817SJulian Elischer /* 1343ed5b7817SJulian Elischer * So, Ok, it's one of our sockets and it IS externally 1344ed5b7817SJulian Elischer * accessible (or was defered). Now we look 1345dc733423SDag-Erling Smørgrav * to see if we hold any file descriptors in its 1346ed5b7817SJulian Elischer * message buffers. Follow those links and mark them 1347ed5b7817SJulian Elischer * as accessible too. 1348ed5b7817SJulian Elischer */ 1349df8bae1dSRodney W. Grimes unp_scan(so->so_rcv.sb_mb, unp_mark); 1350df8bae1dSRodney W. Grimes } 1351df8bae1dSRodney W. Grimes } while (unp_defer); 1352426da3bcSAlfred Perlstein sx_sunlock(&filelist_lock); 1353df8bae1dSRodney W. Grimes /* 1354df8bae1dSRodney W. Grimes * We grab an extra reference to each of the file table entries 1355df8bae1dSRodney W. Grimes * that are not otherwise accessible and then free the rights 1356df8bae1dSRodney W. Grimes * that are stored in messages on them. 1357df8bae1dSRodney W. Grimes * 1358df8bae1dSRodney W. Grimes * The bug in the orginal code is a little tricky, so I'll describe 1359df8bae1dSRodney W. Grimes * what's wrong with it here. 1360df8bae1dSRodney W. Grimes * 1361df8bae1dSRodney W. Grimes * It is incorrect to simply unp_discard each entry for f_msgcount 1362df8bae1dSRodney W. Grimes * times -- consider the case of sockets A and B that contain 1363df8bae1dSRodney W. Grimes * references to each other. On a last close of some other socket, 1364df8bae1dSRodney W. Grimes * we trigger a gc since the number of outstanding rights (unp_rights) 1365df8bae1dSRodney W. Grimes * is non-zero. If during the sweep phase the gc code un_discards, 1366df8bae1dSRodney W. Grimes * we end up doing a (full) closef on the descriptor. A closef on A 1367df8bae1dSRodney W. Grimes * results in the following chain. Closef calls soo_close, which 1368df8bae1dSRodney W. Grimes * calls soclose. Soclose calls first (through the switch 1369df8bae1dSRodney W. Grimes * uipc_usrreq) unp_detach, which re-invokes unp_gc. Unp_gc simply 1370df8bae1dSRodney W. Grimes * returns because the previous instance had set unp_gcing, and 1371df8bae1dSRodney W. Grimes * we return all the way back to soclose, which marks the socket 1372df8bae1dSRodney W. Grimes * with SS_NOFDREF, and then calls sofree. Sofree calls sorflush 1373df8bae1dSRodney W. Grimes * to free up the rights that are queued in messages on the socket A, 1374df8bae1dSRodney W. Grimes * i.e., the reference on B. The sorflush calls via the dom_dispose 1375df8bae1dSRodney W. Grimes * switch unp_dispose, which unp_scans with unp_discard. This second 1376df8bae1dSRodney W. Grimes * instance of unp_discard just calls closef on B. 1377df8bae1dSRodney W. Grimes * 1378df8bae1dSRodney W. Grimes * Well, a similar chain occurs on B, resulting in a sorflush on B, 1379df8bae1dSRodney W. Grimes * which results in another closef on A. Unfortunately, A is already 1380df8bae1dSRodney W. Grimes * being closed, and the descriptor has already been marked with 1381df8bae1dSRodney W. Grimes * SS_NOFDREF, and soclose panics at this point. 1382df8bae1dSRodney W. Grimes * 1383df8bae1dSRodney W. Grimes * Here, we first take an extra reference to each inaccessible 1384df8bae1dSRodney W. Grimes * descriptor. Then, we call sorflush ourself, since we know 1385df8bae1dSRodney W. Grimes * it is a Unix domain socket anyhow. After we destroy all the 1386df8bae1dSRodney W. Grimes * rights carried in messages, we do a last closef to get rid 1387df8bae1dSRodney W. Grimes * of our extra reference. This is the last close, and the 1388df8bae1dSRodney W. Grimes * unp_detach etc will shut down the socket. 1389df8bae1dSRodney W. Grimes * 1390df8bae1dSRodney W. Grimes * 91/09/19, bsy@cs.cmu.edu 1391df8bae1dSRodney W. Grimes */ 1392a163d034SWarner Losh extra_ref = malloc(nfiles * sizeof(struct file *), M_TEMP, M_WAITOK); 1393426da3bcSAlfred Perlstein sx_slock(&filelist_lock); 13942e3c8fcbSPoul-Henning Kamp for (nunref = 0, fp = LIST_FIRST(&filehead), fpp = extra_ref; fp != 0; 1395bc6f0e79SJeffrey Hsu fp = nextfp) { 13962e3c8fcbSPoul-Henning Kamp nextfp = LIST_NEXT(fp, f_list); 1397426da3bcSAlfred Perlstein FILE_LOCK(fp); 1398ed5b7817SJulian Elischer /* 1399ed5b7817SJulian Elischer * If it's not open, skip it 1400ed5b7817SJulian Elischer */ 1401426da3bcSAlfred Perlstein if (fp->f_count == 0) { 1402426da3bcSAlfred Perlstein FILE_UNLOCK(fp); 1403df8bae1dSRodney W. Grimes continue; 1404426da3bcSAlfred Perlstein } 1405ed5b7817SJulian Elischer /* 1406ed5b7817SJulian Elischer * If all refs are from msgs, and it's not marked accessible 1407ed5b7817SJulian Elischer * then it must be referenced from some unreachable cycle 1408ed5b7817SJulian Elischer * of (shut-down) FDs, so include it in our 1409ed5b7817SJulian Elischer * list of FDs to remove 1410ed5b7817SJulian Elischer */ 1411426da3bcSAlfred Perlstein if (fp->f_count == fp->f_msgcount && !(fp->f_gcflag & FMARK)) { 1412df8bae1dSRodney W. Grimes *fpp++ = fp; 1413df8bae1dSRodney W. Grimes nunref++; 1414df8bae1dSRodney W. Grimes fp->f_count++; 1415df8bae1dSRodney W. Grimes } 1416426da3bcSAlfred Perlstein FILE_UNLOCK(fp); 1417df8bae1dSRodney W. Grimes } 1418426da3bcSAlfred Perlstein sx_sunlock(&filelist_lock); 1419ed5b7817SJulian Elischer /* 1420ed5b7817SJulian Elischer * for each FD on our hit list, do the following two things 1421ed5b7817SJulian Elischer */ 14221c7c3c6aSMatthew Dillon for (i = nunref, fpp = extra_ref; --i >= 0; ++fpp) { 14231c7c3c6aSMatthew Dillon struct file *tfp = *fpp; 1424426da3bcSAlfred Perlstein FILE_LOCK(tfp); 1425cd72f218SMatthew Dillon if (tfp->f_type == DTYPE_SOCKET && 142648e3128bSMatthew Dillon tfp->f_data != NULL) { 1427426da3bcSAlfred Perlstein FILE_UNLOCK(tfp); 142848e3128bSMatthew Dillon sorflush(tfp->f_data); 1429e5aeaa0cSDag-Erling Smørgrav } else { 1430426da3bcSAlfred Perlstein FILE_UNLOCK(tfp); 14311c7c3c6aSMatthew Dillon } 1432e5aeaa0cSDag-Erling Smørgrav } 1433df8bae1dSRodney W. Grimes for (i = nunref, fpp = extra_ref; --i >= 0; ++fpp) 1434b40ce416SJulian Elischer closef(*fpp, (struct thread *) NULL); 1435210a5a71SAlfred Perlstein free(extra_ref, M_TEMP); 1436df8bae1dSRodney W. Grimes unp_gcing = 0; 1437df8bae1dSRodney W. Grimes } 1438df8bae1dSRodney W. Grimes 143926f9a767SRodney W. Grimes void 1440df8bae1dSRodney W. Grimes unp_dispose(m) 1441df8bae1dSRodney W. Grimes struct mbuf *m; 1442df8bae1dSRodney W. Grimes { 1443996c772fSJohn Dyson 1444df8bae1dSRodney W. Grimes if (m) 1445df8bae1dSRodney W. Grimes unp_scan(m, unp_discard); 1446df8bae1dSRodney W. Grimes } 1447df8bae1dSRodney W. Grimes 14480c1bb4fbSDima Dorfman static int 14496f105b34SJohn Baldwin unp_listen(unp, td) 14500c1bb4fbSDima Dorfman struct unpcb *unp; 14516f105b34SJohn Baldwin struct thread *td; 14520c1bb4fbSDima Dorfman { 14530c1bb4fbSDima Dorfman 14546f105b34SJohn Baldwin cru2x(td->td_ucred, &unp->unp_peercred); 14550c1bb4fbSDima Dorfman unp->unp_flags |= UNP_HAVEPCCACHED; 14560c1bb4fbSDima Dorfman return (0); 14570c1bb4fbSDima Dorfman } 14580c1bb4fbSDima Dorfman 1459f708ef1bSPoul-Henning Kamp static void 1460df8bae1dSRodney W. Grimes unp_scan(m0, op) 1461df8bae1dSRodney W. Grimes register struct mbuf *m0; 14624d77a549SAlfred Perlstein void (*op)(struct file *); 1463df8bae1dSRodney W. Grimes { 14642bc21ed9SDavid Malone struct mbuf *m; 14652bc21ed9SDavid Malone struct file **rp; 14662bc21ed9SDavid Malone struct cmsghdr *cm; 14672bc21ed9SDavid Malone void *data; 14682bc21ed9SDavid Malone int i; 14692bc21ed9SDavid Malone socklen_t clen, datalen; 1470df8bae1dSRodney W. Grimes int qfds; 1471df8bae1dSRodney W. Grimes 1472df8bae1dSRodney W. Grimes while (m0) { 14732bc21ed9SDavid Malone for (m = m0; m; m = m->m_next) { 147412396bdcSDavid Malone if (m->m_type != MT_CONTROL) 1475df8bae1dSRodney W. Grimes continue; 14762bc21ed9SDavid Malone 14772bc21ed9SDavid Malone cm = mtod(m, struct cmsghdr *); 14782bc21ed9SDavid Malone clen = m->m_len; 14792bc21ed9SDavid Malone 14802bc21ed9SDavid Malone while (cm != NULL) { 14812bc21ed9SDavid Malone if (sizeof(*cm) > clen || cm->cmsg_len > clen) 14822bc21ed9SDavid Malone break; 14832bc21ed9SDavid Malone 14842bc21ed9SDavid Malone data = CMSG_DATA(cm); 14852bc21ed9SDavid Malone datalen = (caddr_t)cm + cm->cmsg_len 14862bc21ed9SDavid Malone - (caddr_t)data; 14872bc21ed9SDavid Malone 14882bc21ed9SDavid Malone if (cm->cmsg_level == SOL_SOCKET && 14892bc21ed9SDavid Malone cm->cmsg_type == SCM_RIGHTS) { 14902bc21ed9SDavid Malone qfds = datalen / sizeof (struct file *); 14912bc21ed9SDavid Malone rp = data; 1492df8bae1dSRodney W. Grimes for (i = 0; i < qfds; i++) 1493df8bae1dSRodney W. Grimes (*op)(*rp++); 14942bc21ed9SDavid Malone } 14952bc21ed9SDavid Malone 14962bc21ed9SDavid Malone if (CMSG_SPACE(datalen) < clen) { 14972bc21ed9SDavid Malone clen -= CMSG_SPACE(datalen); 14982bc21ed9SDavid Malone cm = (struct cmsghdr *) 14992bc21ed9SDavid Malone ((caddr_t)cm + CMSG_SPACE(datalen)); 15002bc21ed9SDavid Malone } else { 15012bc21ed9SDavid Malone clen = 0; 15022bc21ed9SDavid Malone cm = NULL; 15032bc21ed9SDavid Malone } 15042bc21ed9SDavid Malone } 1505df8bae1dSRodney W. Grimes } 1506df8bae1dSRodney W. Grimes m0 = m0->m_act; 1507df8bae1dSRodney W. Grimes } 1508df8bae1dSRodney W. Grimes } 1509df8bae1dSRodney W. Grimes 1510f708ef1bSPoul-Henning Kamp static void 1511df8bae1dSRodney W. Grimes unp_mark(fp) 1512df8bae1dSRodney W. Grimes struct file *fp; 1513df8bae1dSRodney W. Grimes { 1514426da3bcSAlfred Perlstein if (fp->f_gcflag & FMARK) 1515df8bae1dSRodney W. Grimes return; 1516df8bae1dSRodney W. Grimes unp_defer++; 1517426da3bcSAlfred Perlstein fp->f_gcflag |= (FMARK|FDEFER); 1518df8bae1dSRodney W. Grimes } 1519df8bae1dSRodney W. Grimes 1520f708ef1bSPoul-Henning Kamp static void 1521df8bae1dSRodney W. Grimes unp_discard(fp) 1522df8bae1dSRodney W. Grimes struct file *fp; 1523df8bae1dSRodney W. Grimes { 1524426da3bcSAlfred Perlstein FILE_LOCK(fp); 1525df8bae1dSRodney W. Grimes fp->f_msgcount--; 1526df8bae1dSRodney W. Grimes unp_rights--; 1527426da3bcSAlfred Perlstein FILE_UNLOCK(fp); 1528b40ce416SJulian Elischer (void) closef(fp, (struct thread *)NULL); 1529df8bae1dSRodney W. Grimes } 1530