X-Git-Url: https://git.saurik.com/apple/xnu.git/blobdiff_plain/1c79356b52d46aa6b508fb032f5ae709b1f2897b..5ba3f43ea354af8ad55bea84372a2bc834d8757c:/bsd/net/raw_usrreq.c diff --git a/bsd/net/raw_usrreq.c b/bsd/net/raw_usrreq.c index b2f44395a..462842129 100644 --- a/bsd/net/raw_usrreq.c +++ b/bsd/net/raw_usrreq.c @@ -1,23 +1,29 @@ /* - * Copyright (c) 2000 Apple Computer, Inc. All rights reserved. + * Copyright (c) 2000-2012 Apple Inc. All rights reserved. * - * @APPLE_LICENSE_HEADER_START@ + * @APPLE_OSREFERENCE_LICENSE_HEADER_START@ * - * The contents of this file constitute Original Code as defined in and - * are subject to the Apple Public Source License Version 1.1 (the - * "License"). You may not use this file except in compliance with the - * License. Please obtain a copy of the License at - * http://www.apple.com/publicsource and read it before using this file. + * This file contains Original Code and/or Modifications of Original Code + * as defined in and that are subject to the Apple Public Source License + * Version 2.0 (the 'License'). You may not use this file except in + * compliance with the License. The rights granted to you under the License + * may not be used to create, or enable the creation or redistribution of, + * unlawful or unlicensed copies of an Apple operating system, or to + * circumvent, violate, or enable the circumvention or violation of, any + * terms of an Apple operating system software license agreement. * - * This Original Code and all software distributed under the License are - * distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, EITHER + * Please obtain a copy of the License at + * http://www.opensource.apple.com/apsl/ and read it before using this file. + * + * The Original Code and all software distributed under the License are + * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES, * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, - * FITNESS FOR A PARTICULAR PURPOSE OR NON-INFRINGEMENT. Please see the - * License for the specific language governing rights and limitations - * under the License. + * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. + * Please see the License for the specific language governing rights and + * limitations under the License. * - * @APPLE_LICENSE_HEADER_END@ + * @APPLE_OSREFERENCE_LICENSE_HEADER_END@ */ /* * Copyright (c) 1980, 1986, 1993 @@ -52,25 +58,46 @@ * SUCH DAMAGE. * * @(#)raw_usrreq.c 8.1 (Berkeley) 6/10/93 + * $FreeBSD: src/sys/net/raw_usrreq.c,v 1.18 1999/08/28 00:48:28 peter Exp $ */ #include #include #include #include +#include #include #include #include +#include #include +decl_lck_mtx_data(,raw_mtx_data); /*### global raw cb mutex for now */ +lck_mtx_t *raw_mtx = &raw_mtx_data; +lck_attr_t *raw_mtx_attr; +lck_grp_t *raw_mtx_grp; +lck_grp_attr_t *raw_mtx_grp_attr; /* * Initialize raw connection block q. */ void -raw_init() +raw_init(struct protosw *pp, struct domain *dp) { - LIST_INIT(&rawcb_list); +#pragma unused(pp, dp) + static int raw_initialized = 0; + + /* This is called by key_init as well, so do it only once */ + if (!raw_initialized) { + raw_initialized = 1; + + raw_mtx_grp_attr = lck_grp_attr_alloc_init(); + raw_mtx_grp = lck_grp_alloc_init("rawcb", raw_mtx_grp_attr); + raw_mtx_attr = lck_attr_alloc_init(); + + lck_mtx_init(raw_mtx, raw_mtx_grp, raw_mtx_attr); + LIST_INIT(&rawcb_list); + } } @@ -83,17 +110,21 @@ raw_init() * Raw protocol interface. */ void -raw_input(m0, proto, src, dst) - struct mbuf *m0; - register struct sockproto *proto; - struct sockaddr *src, *dst; +raw_input(struct mbuf *m0, struct sockproto *proto, struct sockaddr *src, + struct sockaddr *dst) { - register struct rawcb *rp; - register struct mbuf *m = m0; - register int sockets = 0; + struct rawcb *rp; + struct mbuf *m = m0; + int sockets = 0; struct socket *last; + int error; - last = 0; +//####LD raw_input is called from many places, input & output path. We have to assume the +//####LD socket we'll find and need to append to is unlocked. +//####LD calls from the output (locked) path need to make sure the socket is not locked when +//####LD we call in raw_input + last = NULL; + lck_mtx_lock(raw_mtx); LIST_FOREACH(rp, &rawcb_list, list) { if (rp->rcb_proto.sp_family != proto->sp_family) continue; @@ -118,39 +149,37 @@ raw_input(m0, proto, src, dst) struct mbuf *n; n = m_copy(m, 0, (int)M_COPYALL); if (n) { + socket_lock(last, 1); if (sbappendaddr(&last->so_rcv, src, - n, (struct mbuf *)0) == 0) - /* should notify about lost packet */ - m_freem(n); - else { + n, (struct mbuf *)0, &error) != 0) { sorwakeup(last); sockets++; } + socket_unlock(last, 1); } } last = rp->rcb_socket; } if (last) { + socket_lock(last, 1); if (sbappendaddr(&last->so_rcv, src, - m, (struct mbuf *)0) == 0) - m_freem(m); - else { + m, (struct mbuf *)0, &error) != 0) { sorwakeup(last); sockets++; } + socket_unlock(last, 1); } else m_freem(m); + lck_mtx_unlock(raw_mtx); } /*ARGSUSED*/ void -raw_ctlinput(cmd, arg, dummy) - int cmd; - struct sockaddr *arg; - void *dummy; +raw_ctlinput(int cmd, __unused struct sockaddr *arg, __unused void *dummy, + __unused struct ifnet *ifp) { - if (cmd < 0 || cmd > PRC_NCMDS) + if (cmd < 0 || cmd >= PRC_NCMDS) return; /* INCOMPLETE */ } @@ -160,6 +189,13 @@ raw_uabort(struct socket *so) { struct rawcb *rp = sotorawcb(so); + lck_mtx_t * mutex_held; + if (so->so_proto->pr_getlock != NULL) + mutex_held = (*so->so_proto->pr_getlock)(so, 0); + else + mutex_held = so->so_proto->pr_domain->dom_mtx; + LCK_MTX_ASSERT(mutex_held, LCK_MTX_ASSERT_OWNED); + if (rp == 0) return EINVAL; raw_disconnect(rp); @@ -171,32 +207,25 @@ raw_uabort(struct socket *so) /* pru_accept is EOPNOTSUPP */ static int -raw_uattach(struct socket *so, int proto, struct proc *p) +raw_uattach(struct socket *so, int proto, __unused struct proc *p) { struct rawcb *rp = sotorawcb(so); - int error; if (rp == 0) return EINVAL; -#if ISFB31 - if (p && (error = suser(p->p_ucred, &p->p_acflag)) != 0) - return error; -#else if ((so->so_state & SS_PRIV) == 0) return (EPERM); -#endif - return raw_attach(so, proto); } static int -raw_ubind(struct socket *so, struct sockaddr *nam, struct proc *p) +raw_ubind(__unused struct socket *so, __unused struct sockaddr *nam, __unused struct proc *p) { return EINVAL; } static int -raw_uconnect(struct socket *so, struct sockaddr *nam, struct proc *p) +raw_uconnect(__unused struct socket *so, __unused struct sockaddr *nam, __unused struct proc *p) { return EINVAL; } @@ -209,6 +238,12 @@ raw_udetach(struct socket *so) { struct rawcb *rp = sotorawcb(so); + lck_mtx_t * mutex_held; + if (so->so_proto->pr_getlock != NULL) + mutex_held = (*so->so_proto->pr_getlock)(so, 0); + else + mutex_held = so->so_proto->pr_domain->dom_mtx; + LCK_MTX_ASSERT(mutex_held, LCK_MTX_ASSERT_OWNED); if (rp == 0) return EINVAL; @@ -252,11 +287,18 @@ raw_upeeraddr(struct socket *so, struct sockaddr **nam) static int raw_usend(struct socket *so, int flags, struct mbuf *m, - struct sockaddr *nam, struct mbuf *control, struct proc *p) + struct sockaddr *nam, struct mbuf *control, __unused struct proc *p) { int error; struct rawcb *rp = sotorawcb(so); + lck_mtx_t * mutex_held; + if (so->so_proto->pr_getlock != NULL) + mutex_held = (*so->so_proto->pr_getlock)(so, 0); + else + mutex_held = so->so_proto->pr_domain->dom_mtx; + LCK_MTX_ASSERT(mutex_held, LCK_MTX_ASSERT_OWNED); + if (rp == 0) { error = EINVAL; goto release; @@ -267,6 +309,11 @@ raw_usend(struct socket *so, int flags, struct mbuf *m, goto release; } + if (so->so_proto->pr_output == NULL) { + error = EOPNOTSUPP; + goto release; + } + if (control && control->m_len) { error = EOPNOTSUPP; goto release; @@ -284,7 +331,7 @@ raw_usend(struct socket *so, int flags, struct mbuf *m, error = (*so->so_proto->pr_output)(m, so); m = NULL; if (nam) - rp->rcb_faddr = 0; + rp->rcb_faddr = NULL; release: if (m != NULL) m_freem(m); @@ -297,6 +344,12 @@ static int raw_ushutdown(struct socket *so) { struct rawcb *rp = sotorawcb(so); + lck_mtx_t * mutex_held; + if (so->so_proto->pr_getlock != NULL) + mutex_held = (*so->so_proto->pr_getlock)(so, 0); + else + mutex_held = so->so_proto->pr_domain->dom_mtx; + LCK_MTX_ASSERT(mutex_held, LCK_MTX_ASSERT_OWNED); if (rp == 0) return EINVAL; @@ -318,9 +371,16 @@ raw_usockaddr(struct socket *so, struct sockaddr **nam) } struct pr_usrreqs raw_usrreqs = { - raw_uabort, pru_accept_notsupp, raw_uattach, raw_ubind, raw_uconnect, - pru_connect2_notsupp, pru_control_notsupp, raw_udetach, - raw_udisconnect, pru_listen_notsupp, raw_upeeraddr, pru_rcvd_notsupp, - pru_rcvoob_notsupp, raw_usend, pru_sense_null, raw_ushutdown, - raw_usockaddr, sosend, soreceive, sopoll + .pru_abort = raw_uabort, + .pru_attach = raw_uattach, + .pru_bind = raw_ubind, + .pru_connect = raw_uconnect, + .pru_detach = raw_udetach, + .pru_disconnect = raw_udisconnect, + .pru_peeraddr = raw_upeeraddr, + .pru_send = raw_usend, + .pru_shutdown = raw_ushutdown, + .pru_sockaddr = raw_usockaddr, + .pru_sosend = sosend, + .pru_soreceive = soreceive, };