uipc_domain.c

Version: - FREEBSD - FREEBSD-13-STABLE - FREEBSD-13-0 - FREEBSD-12-STABLE - FREEBSD-12-0 - FREEBSD-11-STABLE - FREEBSD-11-0 - FREEBSD-10-STABLE - FREEBSD-10-0 - FREEBSD-9-STABLE - FREEBSD-9-0 - FREEBSD-8-STABLE - FREEBSD-8-0 - FREEBSD-7-STABLE - FREEBSD-7-0 - FREEBSD-6-STABLE - FREEBSD-6-0 - FREEBSD-5-STABLE - FREEBSD-5-0 - FREEBSD-4-STABLE - FREEBSD-3-STABLE - FREEBSD22 - l41 - OPENBSD - linux-2.6 - MK84 - PLAN9 - xnu-8792
SearchContext: - none - 3 - 10

    1 /*
    2  * Copyright (c) 1982, 1986, 1993
    3  *      The Regents of the University of California.  All rights reserved.
    4  *
    5  * Redistribution and use in source and binary forms, with or without
    6  * modification, are permitted provided that the following conditions
    7  * are met:
    8  * 1. Redistributions of source code must retain the above copyright
    9  *    notice, this list of conditions and the following disclaimer.
   10  * 2. Redistributions in binary form must reproduce the above copyright
   11  *    notice, this list of conditions and the following disclaimer in the
   12  *    documentation and/or other materials provided with the distribution.
   13  * 3. All advertising materials mentioning features or use of this software
   14  *    must display the following acknowledgement:
   15  *      This product includes software developed by the University of
   16  *      California, Berkeley and its contributors.
   17  * 4. Neither the name of the University nor the names of its contributors
   18  *    may be used to endorse or promote products derived from this software
   19  *    without specific prior written permission.
   20  *
   21  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
   22  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
   23  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
   24  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
   25  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
   26  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
   27  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
   28  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
   29  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
   30  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
   31  * SUCH DAMAGE.
   32  *
   33  *      @(#)uipc_domain.c       8.2 (Berkeley) 10/18/93
   34  * $FreeBSD$
   35  */
   36 
   37 #include <sys/param.h>
   38 #include <sys/socket.h>
   39 #include <sys/protosw.h>
   40 #include <sys/domain.h>
   41 #include <sys/mbuf.h>
   42 #include <sys/kernel.h>
   43 #include <sys/socketvar.h>
   44 #include <sys/systm.h>
   45 #include <vm/vm_zone.h>
   46 
   47 /*
   48  * System initialization
   49  *
   50  * Note: domain initialization wants to take place on a per domain basis
   51  * as a result of traversing a linker set.  Most likely, each domain
   52  * want to call a registration function rather than being handled here
   53  * in domaininit().  Probably this will look like:
   54  *
   55  * SYSINIT(unique, SI_SUB_PROTO_DOMAIN, SI_ORDER_ANY, domain_add, xxx)
   56  *
   57  * Where 'xxx' is replaced by the address of a parameter struct to be
   58  * passed to the doamin_add() function.
   59  */
   60 
   61 static void domaininit __P((void *));
   62 SYSINIT(domain, SI_SUB_PROTO_DOMAIN, SI_ORDER_FIRST, domaininit, NULL)
   63 
   64 static void     pffasttimo __P((void *));
   65 static void     pfslowtimo __P((void *));
   66 
   67 struct domain *domains;
   68 
   69 /*
   70  * Add a new protocol domain to the list of supported domains
   71  * Note: you cant unload it again because  a socket may be using it.
   72  * XXX can't fail at this time.
   73  */
   74 static void
   75 net_init_domain(struct domain *dp)
   76 {
   77         register struct protosw *pr;
   78         int     s;
   79 
   80         s = splnet();
   81         if (dp->dom_init)
   82                 (*dp->dom_init)();
   83         for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++){
   84                 if (pr->pr_usrreqs == 0)
   85                         panic("domaininit: %ssw[%d] has no usrreqs!",
   86                               dp->dom_name, 
   87                               (int)(pr - dp->dom_protosw));
   88                 if (pr->pr_init)
   89                         (*pr->pr_init)();
   90         }
   91         /*
   92          * update global informatio about maximums
   93          */
   94         max_hdr = max_linkhdr + max_protohdr;
   95         max_datalen = MHLEN - max_hdr;
   96         splx(s);
   97 }
   98 
   99 /*
  100  * Add a new protocol domain to the list of supported domains
  101  * Note: you cant unload it again because  a socket may be using it.
  102  * XXX can't fail at this time.
  103  */
  104 void
  105 net_add_domain(void *data)
  106 {
  107         int     s;
  108         struct domain *dp;
  109 
  110         dp = (struct domain *)data;
  111         s = splnet();
  112         dp->dom_next = domains;
  113         domains = dp;
  114         splx(s);
  115         net_init_domain(dp);
  116 }
  117 
  118 /* ARGSUSED*/
  119 static void
  120 domaininit(void *dummy)
  121 {
  122         /*
  123          * Before we do any setup, make sure to initialize the
  124          * zone allocator we get struct sockets from.  The obvious
  125          * maximum number of sockets is `maxfiles', but it is possible
  126          * to have a socket without an open file (e.g., a connection waiting
  127          * to be accept(2)ed).  Rather than think up and define a
  128          * better value, we just use nmbclusters, since that's what people
  129          * are told to increase first when the network runs out of memory.
  130          * Perhaps we should have two pools, one of unlimited size
  131          * for use during socreate(), and one ZONE_INTERRUPT pool for
  132          * use in sonewconn().
  133          */
  134         socket_zone = zinit("socket", sizeof(struct socket), maxsockets,
  135                             ZONE_INTERRUPT, 0);
  136 
  137         if (max_linkhdr < 16)           /* XXX */
  138                 max_linkhdr = 16;
  139 
  140         timeout(pffasttimo, (void *)0, 1);
  141         timeout(pfslowtimo, (void *)0, 1);
  142 }
  143 
  144 
  145 struct protosw *
  146 pffindtype(family, type)
  147         int family;
  148         int type;
  149 {
  150         register struct domain *dp;
  151         register struct protosw *pr;
  152 
  153         for (dp = domains; dp; dp = dp->dom_next)
  154                 if (dp->dom_family == family)
  155                         goto found;
  156         return (0);
  157 found:
  158         for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++)
  159                 if (pr->pr_type && pr->pr_type == type)
  160                         return (pr);
  161         return (0);
  162 }
  163 
  164 struct protosw *
  165 pffindproto(family, protocol, type)
  166         int family;
  167         int protocol;
  168         int type;
  169 {
  170         register struct domain *dp;
  171         register struct protosw *pr;
  172         struct protosw *maybe = 0;
  173 
  174         if (family == 0)
  175                 return (0);
  176         for (dp = domains; dp; dp = dp->dom_next)
  177                 if (dp->dom_family == family)
  178                         goto found;
  179         return (0);
  180 found:
  181         for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++) {
  182                 if ((pr->pr_protocol == protocol) && (pr->pr_type == type))
  183                         return (pr);
  184 
  185                 if (type == SOCK_RAW && pr->pr_type == SOCK_RAW &&
  186                     pr->pr_protocol == 0 && maybe == (struct protosw *)0)
  187                         maybe = pr;
  188         }
  189         return (maybe);
  190 }
  191 
  192 void
  193 pfctlinput(cmd, sa)
  194         int cmd;
  195         struct sockaddr *sa;
  196 {
  197         register struct domain *dp;
  198         register struct protosw *pr;
  199 
  200         for (dp = domains; dp; dp = dp->dom_next)
  201                 for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++)
  202                         if (pr->pr_ctlinput)
  203                                 (*pr->pr_ctlinput)(cmd, sa, (void *)0);
  204 }
  205 
  206 void
  207 pfctlinput2(cmd, sa, ctlparam)
  208         int cmd;
  209         struct sockaddr *sa;
  210         void *ctlparam;
  211 {
  212         struct domain *dp;
  213         struct protosw *pr;
  214 
  215         if (!sa)
  216                 return;
  217         for (dp = domains; dp; dp = dp->dom_next) {
  218                 /*
  219                  * the check must be made by xx_ctlinput() anyways, to
  220                  * make sure we use data item pointed to by ctlparam in
  221                  * correct way.  the following check is made just for safety.
  222                  */
  223                 if (dp->dom_family != sa->sa_family)
  224                         continue;
  225 
  226                 for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++)
  227                         if (pr->pr_ctlinput)
  228                                 (*pr->pr_ctlinput)(cmd, sa, ctlparam);
  229         }
  230 }
  231 
  232 static void
  233 pfslowtimo(arg)
  234         void *arg;
  235 {
  236         register struct domain *dp;
  237         register struct protosw *pr;
  238 
  239         for (dp = domains; dp; dp = dp->dom_next)
  240                 for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++)
  241                         if (pr->pr_slowtimo)
  242                                 (*pr->pr_slowtimo)();
  243         timeout(pfslowtimo, (void *)0, hz/2);
  244 }
  245 
  246 static void
  247 pffasttimo(arg)
  248         void *arg;
  249 {
  250         register struct domain *dp;
  251         register struct protosw *pr;
  252 
  253         for (dp = domains; dp; dp = dp->dom_next)
  254                 for (pr = dp->dom_protosw; pr < dp->dom_protoswNPROTOSW; pr++)
  255                         if (pr->pr_fasttimo)
  256                                 (*pr->pr_fasttimo)();
  257         timeout(pffasttimo, (void *)0, hz/5);
  258 }

Cache object: 011b2faa3790ef2f0529e05327074d98

[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]

This page is part of the FreeBSD/Linux Linux Kernel Cross-Reference, and was automatically generated using a modified version of the LXR engine.

FreeBSD/Linux Kernel Cross Reference sys/kern/uipc_domain.c

FreeBSD/Linux Kernel Cross Reference
sys/kern/uipc_domain.c