bsd/netinet/mp_proto.c

   1 /*
   2  * Copyright (c) 2012 Apple Inc. All rights reserved.
   3  *
   4  * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
   5  *
   6  * This file contains Original Code and/or Modifications of Original Code
   7  * as defined in and that are subject to the Apple Public Source License
   8  * Version 2.0 (the 'License'). You may not use this file except in
   9  * compliance with the License. The rights granted to you under the License
  10  * may not be used to create, or enable the creation or redistribution of,
  11  * unlawful or unlicensed copies of an Apple operating system, or to
  12  * circumvent, violate, or enable the circumvention or violation of, any
  13  * terms of an Apple operating system software license agreement.
  14  *
  15  * Please obtain a copy of the License at
  16  * http://www.opensource.apple.com/apsl/ and read it before using this file.
  17  *
  18  * The Original Code and all software distributed under the License are
  19  * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
  20  * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
  21  * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
  22  * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
  23  * Please see the License for the specific language governing rights and
  24  * limitations under the License.
  25  *
  26  * @APPLE_OSREFERENCE_LICENSE_HEADER_END@
  27  */
  28
  29 #include <sys/param.h>
  30 #include <sys/kernel.h>
  31 #include <sys/socket.h>
  32 #include <sys/domain.h>
  33 #include <sys/protosw.h>
  34 #include <sys/mcache.h>
  35
  36 #include <kern/locks.h>
  37
  38 #include <netinet/in.h>
  39 #if MPTCP
  40 #include <netinet/mptcp_var.h>
  41 #endif /* MPTCP */
  42
  43 extern struct domain mpdomain_s;
  44 static struct domain *mpdomain = NULL;
  45
  46 static void mp_dinit(struct domain *);
  47 lck_mtx_t *mp_domain_mutex;
  48
  49 static struct protosw mpsw[] = {
  50 #if MPTCP
  51 {
  52         .pr_type =              SOCK_STREAM,
  53         .pr_protocol =          IPPROTO_TCP,
  54         .pr_flags =             PR_CONNREQUIRED|PR_MULTICONN|PR_EVCONNINFO|
  55                                 PR_WANTRCVD|PR_PCBLOCK|PR_PROTOLOCK|
  56                                 PR_PRECONN_WRITE|PR_DATA_IDEMPOTENT,
  57         .pr_ctloutput =         mptcp_ctloutput,
  58         .pr_init =              mptcp_init,
  59         .pr_usrreqs =           &mptcp_usrreqs,
  60         .pr_lock =              mptcp_lock,
  61         .pr_unlock =            mptcp_unlock,
  62         .pr_getlock =           mptcp_getlock,
  63 },
  64 #endif /* MPTCP */
  65 };
  66
  67 static int mp_proto_count = (sizeof (mpsw) / sizeof (struct protosw));
  68
  69 struct domain mpdomain_s = {
  70         .dom_family =           PF_MULTIPATH,
  71         .dom_flags =            DOM_REENTRANT,
  72         .dom_name =             "multipath",
  73         .dom_init =             mp_dinit,
  74 };
  75
  76 /* Initialize the PF_MULTIPATH domain, and add in the pre-defined protos */
  77 void
  78 mp_dinit(struct domain *dp)
  79 {
  80         struct protosw *pr;
  81         int i;
  82
  83         VERIFY(!(dp->dom_flags & DOM_INITIALIZED));
  84         VERIFY(mpdomain == NULL);
  85
  86         mpdomain = dp;
  87
  88         for (i = 0, pr = &mpsw[0]; i < mp_proto_count; i++, pr++)
  89                 net_add_proto(pr, dp, 1);
  90
  91         mp_domain_mutex = dp->dom_mtx;
  92 }