The Design and Implementation of the FreeBSD Operating System, Second Edition
Now available: The Design and Implementation of the FreeBSD Operating System (Second Edition)


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

FreeBSD/Linux Kernel Cross Reference
sys/netipx/ipx_input.c

Version: -  FREEBSD  -  FREEBSD-12-STABLE  -  FREEBSD-12-0  -  FREEBSD-11-STABLE  -  FREEBSD-11-2  -  FREEBSD-11-1  -  FREEBSD-11-0  -  FREEBSD-10-STABLE  -  FREEBSD-10-4  -  FREEBSD-10-3  -  FREEBSD-10-2  -  FREEBSD-10-1  -  FREEBSD-10-0  -  FREEBSD-9-STABLE  -  FREEBSD-9-3  -  FREEBSD-9-2  -  FREEBSD-9-1  -  FREEBSD-9-0  -  FREEBSD-8-STABLE  -  FREEBSD-8-4  -  FREEBSD-8-3  -  FREEBSD-8-2  -  FREEBSD-8-1  -  FREEBSD-8-0  -  FREEBSD-7-STABLE  -  FREEBSD-7-4  -  FREEBSD-7-3  -  FREEBSD-7-2  -  FREEBSD-7-1  -  FREEBSD-7-0  -  FREEBSD-6-STABLE  -  FREEBSD-6-4  -  FREEBSD-6-3  -  FREEBSD-6-2  -  FREEBSD-6-1  -  FREEBSD-6-0  -  FREEBSD-5-STABLE  -  FREEBSD-5-5  -  FREEBSD-5-4  -  FREEBSD-5-3  -  FREEBSD-5-2  -  FREEBSD-5-1  -  FREEBSD-5-0  -  FREEBSD-4-STABLE  -  FREEBSD-3-STABLE  -  FREEBSD22  -  linux-2.6  -  linux-2.4.22  -  MK83  -  MK84  -  PLAN9  -  DFBSD  -  NETBSD  -  NETBSD5  -  NETBSD4  -  NETBSD3  -  NETBSD20  -  OPENBSD  -  xnu-517  -  xnu-792  -  xnu-792.6.70  -  xnu-1228  -  xnu-1456.1.26  -  xnu-1699.24.8  -  xnu-2050.18.24  -  OPENSOLARIS  -  minix-3-1-1 
SearchContext: -  none  -  3  -  10 

    1 /*
    2  * Copyright (c) 1995, Mike Mitchell
    3  * Copyright (c) 1984, 1985, 1986, 1987, 1993
    4  *      The Regents of the University of California.  All rights reserved.
    5  *
    6  * Redistribution and use in source and binary forms, with or without
    7  * modification, are permitted provided that the following conditions
    8  * are met:
    9  * 1. Redistributions of source code must retain the above copyright
   10  *    notice, this list of conditions and the following disclaimer.
   11  * 2. Redistributions in binary form must reproduce the above copyright
   12  *    notice, this list of conditions and the following disclaimer in the
   13  *    documentation and/or other materials provided with the distribution.
   14  * 3. All advertising materials mentioning features or use of this software
   15  *    must display the following acknowledgement:
   16  *      This product includes software developed by the University of
   17  *      California, Berkeley and its contributors.
   18  * 4. Neither the name of the University nor the names of its contributors
   19  *    may be used to endorse or promote products derived from this software
   20  *    without specific prior written permission.
   21  *
   22  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
   23  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
   24  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
   25  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
   26  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
   27  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
   28  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
   29  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
   30  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
   31  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
   32  * SUCH DAMAGE.
   33  *
   34  *      @(#)ipx_input.c
   35  *
   36  * $FreeBSD: releng/5.0/sys/netipx/ipx_input.c 93818 2002-04-04 21:03:38Z jhb $
   37  */
   38 
   39 #include <sys/param.h>
   40 #include <sys/systm.h>
   41 #include <sys/mbuf.h>
   42 #include <sys/protosw.h>
   43 #include <sys/socket.h>
   44 #include <sys/kernel.h>
   45 #include <sys/random.h>
   46 #include <sys/sysctl.h>
   47 
   48 #include <net/if.h>
   49 #include <net/route.h>
   50 #include <net/netisr.h>
   51 #include <net/intrq.h>
   52 
   53 #include <netipx/ipx.h>
   54 #include <netipx/spx.h>
   55 #include <netipx/ipx_if.h>
   56 #include <netipx/ipx_pcb.h>
   57 #include <netipx/ipx_var.h>
   58 
   59 int     ipxcksum = 0;
   60 SYSCTL_INT(_net_ipx_ipx, OID_AUTO, checksum, CTLFLAG_RW,
   61            &ipxcksum, 0, "");
   62 
   63 static int      ipxprintfs = 0;         /* printing forwarding information */
   64 SYSCTL_INT(_net_ipx_ipx, OID_AUTO, ipxprintfs, CTLFLAG_RW,
   65            &ipxprintfs, 0, "");
   66 
   67 static int      ipxforwarding = 0;
   68 SYSCTL_INT(_net_ipx_ipx, OID_AUTO, ipxforwarding, CTLFLAG_RW,
   69             &ipxforwarding, 0, "");
   70 
   71 static int      ipxnetbios = 0;
   72 SYSCTL_INT(_net_ipx, OID_AUTO, ipxnetbios, CTLFLAG_RW,
   73            &ipxnetbios, 0, "");
   74 
   75 union   ipx_net ipx_zeronet;
   76 union   ipx_host ipx_zerohost;
   77 
   78 union   ipx_net ipx_broadnet;
   79 union   ipx_host ipx_broadhost;
   80 
   81 struct  ipxstat ipxstat;
   82 struct  sockaddr_ipx ipx_netmask, ipx_hostmask;
   83 
   84 static  u_short allones[] = {-1, -1, -1};
   85 
   86 struct  ipxpcb ipxpcb;
   87 struct  ipxpcb ipxrawpcb;
   88 
   89 static int ipxqmaxlen = IFQ_MAXLEN;
   90 
   91 long    ipx_pexseq;
   92 
   93 static  int ipx_do_route(struct ipx_addr *src, struct route *ro);
   94 static  void ipx_undo_route(struct route *ro);
   95 static  void ipx_forward(struct mbuf *m);
   96 
   97 /*
   98  * IPX initialization.
   99  */
  100 
  101 void
  102 ipx_init()
  103 {
  104         ipx_broadnet = *(union ipx_net *)allones;
  105         ipx_broadhost = *(union ipx_host *)allones;
  106 
  107         read_random(&ipx_pexseq, sizeof ipx_pexseq);
  108         ipxintrq.ifq_maxlen = ipxqmaxlen;
  109         mtx_init(&ipxintrq.ifq_mtx, "ipx_inq", NULL, MTX_DEF);
  110         ipxintrq_present = 1;
  111         ipxpcb.ipxp_next = ipxpcb.ipxp_prev = &ipxpcb;
  112         ipxrawpcb.ipxp_next = ipxrawpcb.ipxp_prev = &ipxrawpcb;
  113 
  114         ipx_netmask.sipx_len = 6;
  115         ipx_netmask.sipx_addr.x_net = ipx_broadnet;
  116 
  117         ipx_hostmask.sipx_len = 12;
  118         ipx_hostmask.sipx_addr.x_net = ipx_broadnet;
  119         ipx_hostmask.sipx_addr.x_host = ipx_broadhost;
  120 
  121         register_netisr(NETISR_IPX, ipxintr);
  122 }
  123 
  124 /*
  125  * IPX input routine.  Pass to next level.
  126  */
  127 void
  128 ipxintr()
  129 {
  130         register struct ipx *ipx;
  131         register struct mbuf *m;
  132         register struct ipxpcb *ipxp;
  133         struct ipx_ifaddr *ia;
  134         int len, s;
  135 
  136 next:
  137         /*
  138          * Get next datagram off input queue and get IPX header
  139          * in first mbuf.
  140          */
  141         s = splimp();
  142         IF_DEQUEUE(&ipxintrq, m);
  143         splx(s);
  144         if (m == NULL)
  145                 return;
  146         /*
  147          * If no IPX addresses have been set yet but the interfaces
  148          * are receiving, can't do anything with incoming packets yet.
  149          */
  150         if (ipx_ifaddr == NULL)
  151                 goto bad;
  152 
  153         ipxstat.ipxs_total++;
  154 
  155         if ((m->m_flags & M_EXT || m->m_len < sizeof(struct ipx)) &&
  156             (m = m_pullup(m, sizeof(struct ipx))) == 0) {
  157                 ipxstat.ipxs_toosmall++;
  158                 goto next;
  159         }
  160 
  161         /*
  162          * Give any raw listeners a crack at the packet
  163          */
  164         for (ipxp = ipxrawpcb.ipxp_next; ipxp != &ipxrawpcb;
  165              ipxp = ipxp->ipxp_next) {
  166                 struct mbuf *m1 = m_copy(m, 0, (int)M_COPYALL);
  167                 if (m1 != NULL)
  168                         ipx_input(m1, ipxp);
  169         }
  170 
  171         ipx = mtod(m, struct ipx *);
  172         len = ntohs(ipx->ipx_len);
  173         /*
  174          * Check that the amount of data in the buffers
  175          * is as at least much as the IPX header would have us expect.
  176          * Trim mbufs if longer than we expect.
  177          * Drop packet if shorter than we expect.
  178          */
  179         if (m->m_pkthdr.len < len) {
  180                 ipxstat.ipxs_tooshort++;
  181                 goto bad;
  182         }
  183         if (m->m_pkthdr.len > len) {
  184                 if (m->m_len == m->m_pkthdr.len) {
  185                         m->m_len = len;
  186                         m->m_pkthdr.len = len;
  187                 } else
  188                         m_adj(m, len - m->m_pkthdr.len);
  189         }
  190         if (ipxcksum && ipx->ipx_sum != 0xffff) {
  191                 if (ipx->ipx_sum != ipx_cksum(m, len)) {
  192                         ipxstat.ipxs_badsum++;
  193                         goto bad;
  194                 }
  195         }
  196 
  197         /*
  198          * Propagated (Netbios) packets (type 20) has to be handled
  199          * different. :-(
  200          */
  201         if (ipx->ipx_pt == IPXPROTO_NETBIOS) {
  202                 if (ipxnetbios) {
  203                         ipx_output_type20(m);
  204                         goto next;
  205                 } else
  206                         goto bad;
  207         }
  208 
  209         /*
  210          * Is this a directed broadcast?
  211          */
  212         if (ipx_hosteqnh(ipx_broadhost,ipx->ipx_dna.x_host)) {
  213                 if ((!ipx_neteq(ipx->ipx_dna, ipx->ipx_sna)) &&
  214                     (!ipx_neteqnn(ipx->ipx_dna.x_net, ipx_broadnet)) &&
  215                     (!ipx_neteqnn(ipx->ipx_sna.x_net, ipx_zeronet)) &&
  216                     (!ipx_neteqnn(ipx->ipx_dna.x_net, ipx_zeronet)) ) {
  217                         /*
  218                          * If it is a broadcast to the net where it was
  219                          * received from, treat it as ours.
  220                          */
  221                         for (ia = ipx_ifaddr; ia != NULL; ia = ia->ia_next)
  222                                 if((ia->ia_ifa.ifa_ifp == m->m_pkthdr.rcvif) &&
  223                                    ipx_neteq(ia->ia_addr.sipx_addr, 
  224                                              ipx->ipx_dna))
  225                                         goto ours;
  226 
  227                         /*
  228                          * Look to see if I need to eat this packet.
  229                          * Algorithm is to forward all young packets
  230                          * and prematurely age any packets which will
  231                          * by physically broadcasted.
  232                          * Any very old packets eaten without forwarding
  233                          * would die anyway.
  234                          *
  235                          * Suggestion of Bill Nesheim, Cornell U.
  236                          */
  237                         if (ipx->ipx_tc < IPX_MAXHOPS) {
  238                                 ipx_forward(m);
  239                                 goto next;
  240                         }
  241                 }
  242         /*
  243          * Is this our packet? If not, forward.
  244          */
  245         } else {
  246                 for (ia = ipx_ifaddr; ia != NULL; ia = ia->ia_next)
  247                         if (ipx_hosteq(ipx->ipx_dna, ia->ia_addr.sipx_addr) &&
  248                             (ipx_neteq(ipx->ipx_dna, ia->ia_addr.sipx_addr) ||
  249                              ipx_neteqnn(ipx->ipx_dna.x_net, ipx_zeronet)))
  250                                 break;
  251 
  252                 if (ia == NULL) {
  253                         ipx_forward(m);
  254                         goto next;
  255                 }
  256         }
  257 ours:
  258         /*
  259          * Locate pcb for datagram.
  260          */
  261         ipxp = ipx_pcblookup(&ipx->ipx_sna, ipx->ipx_dna.x_port, IPX_WILDCARD);
  262         /*
  263          * Switch out to protocol's input routine.
  264          */
  265         if (ipxp != NULL) {
  266                 ipxstat.ipxs_delivered++;
  267                 if ((ipxp->ipxp_flags & IPXP_ALL_PACKETS) == 0)
  268                         switch (ipx->ipx_pt) {
  269 
  270                             case IPXPROTO_SPX:
  271                                     spx_input(m, ipxp);
  272                                     goto next;
  273                         }
  274                 ipx_input(m, ipxp);
  275         } else
  276                 goto bad;
  277 
  278         goto next;
  279 
  280 bad:
  281         m_freem(m);
  282         goto next;
  283 }
  284 
  285 void
  286 ipx_ctlinput(cmd, arg_as_sa, dummy)
  287         int cmd;
  288         struct sockaddr *arg_as_sa;     /* XXX should be swapped with dummy */
  289         void *dummy;
  290 {
  291         caddr_t arg = (/* XXX */ caddr_t)arg_as_sa;
  292         struct ipx_addr *ipx;
  293 
  294         if (cmd < 0 || cmd > PRC_NCMDS)
  295                 return;
  296         switch (cmd) {
  297                 struct sockaddr_ipx *sipx;
  298 
  299         case PRC_IFDOWN:
  300         case PRC_HOSTDEAD:
  301         case PRC_HOSTUNREACH:
  302                 sipx = (struct sockaddr_ipx *)arg;
  303                 if (sipx->sipx_family != AF_IPX)
  304                         return;
  305                 ipx = &sipx->sipx_addr;
  306                 break;
  307 
  308         default:
  309                 if (ipxprintfs)
  310                         printf("ipx_ctlinput: cmd %d.\n", cmd);
  311                 break;
  312         }
  313 }
  314 
  315 /*
  316  * Forward a packet. If some error occurs drop the packet. IPX don't
  317  * have a way to return errors to the sender.
  318  */
  319 
  320 static struct route ipx_droute;
  321 static struct route ipx_sroute;
  322 
  323 static void
  324 ipx_forward(m)
  325 struct mbuf *m;
  326 {
  327         register struct ipx *ipx = mtod(m, struct ipx *);
  328         register int error;
  329         struct mbuf *mcopy = NULL;
  330         int agedelta = 1;
  331         int flags = IPX_FORWARDING;
  332         int ok_there = 0;
  333         int ok_back = 0;
  334 
  335         if (ipxforwarding == 0) {
  336                 /* can't tell difference between net and host */
  337                 ipxstat.ipxs_cantforward++;
  338                 m_freem(m);
  339                 goto cleanup;
  340         }
  341         ipx->ipx_tc++;
  342         if (ipx->ipx_tc > IPX_MAXHOPS) {
  343                 ipxstat.ipxs_cantforward++;
  344                 m_freem(m);
  345                 goto cleanup;
  346         }
  347 
  348         if ((ok_there = ipx_do_route(&ipx->ipx_dna,&ipx_droute)) == 0) {
  349                 ipxstat.ipxs_noroute++;
  350                 m_freem(m);
  351                 goto cleanup;
  352         }
  353         /*
  354          * Here we think about  forwarding  broadcast packets,
  355          * so we try to insure that it doesn't go back out
  356          * on the interface it came in on.  Also, if we
  357          * are going to physically broadcast this, let us
  358          * age the packet so we can eat it safely the second time around.
  359          */
  360         if (ipx->ipx_dna.x_host.c_host[0] & 0x1) {
  361                 struct ipx_ifaddr *ia = ipx_iaonnetof(&ipx->ipx_dna);
  362                 struct ifnet *ifp;
  363                 if (ia != NULL) {
  364                         /* I'm gonna hafta eat this packet */
  365                         agedelta += IPX_MAXHOPS - ipx->ipx_tc;
  366                         ipx->ipx_tc = IPX_MAXHOPS;
  367                 }
  368                 if ((ok_back = ipx_do_route(&ipx->ipx_sna,&ipx_sroute)) == 0) {
  369                         /* error = ENETUNREACH; He'll never get it! */
  370                         ipxstat.ipxs_noroute++;
  371                         m_freem(m);
  372                         goto cleanup;
  373                 }
  374                 if (ipx_droute.ro_rt &&
  375                     (ifp = ipx_droute.ro_rt->rt_ifp) &&
  376                     ipx_sroute.ro_rt &&
  377                     (ifp != ipx_sroute.ro_rt->rt_ifp)) {
  378                         flags |= IPX_ALLOWBROADCAST;
  379                 } else {
  380                         ipxstat.ipxs_noroute++;
  381                         m_freem(m);
  382                         goto cleanup;
  383                 }
  384         }
  385         /*
  386          * We don't need to recompute checksum because ipx_tc field
  387          * is ignored by checksum calculation routine, however
  388          * it may be desirable to reset checksum if ipxcksum == 0
  389          */
  390 #if 0
  391         if (!ipxcksum)
  392                 ipx->ipx_sum = 0xffff;
  393 #endif
  394 
  395         error = ipx_outputfl(m, &ipx_droute, flags);
  396         if (error == 0) {
  397                 ipxstat.ipxs_forward++;
  398 
  399                 if (ipxprintfs) {
  400                         printf("forward: ");
  401                         ipx_printhost(&ipx->ipx_sna);
  402                         printf(" to ");
  403                         ipx_printhost(&ipx->ipx_dna);
  404                         printf(" hops %d\n", ipx->ipx_tc);
  405                 }
  406         } else if (mcopy != NULL) {
  407                 ipx = mtod(mcopy, struct ipx *);
  408                 switch (error) {
  409 
  410                 case ENETUNREACH:
  411                 case EHOSTDOWN:
  412                 case EHOSTUNREACH:
  413                 case ENETDOWN:
  414                 case EPERM:
  415                         ipxstat.ipxs_noroute++;
  416                         break;
  417 
  418                 case EMSGSIZE:
  419                         ipxstat.ipxs_mtutoosmall++;
  420                         break;
  421 
  422                 case ENOBUFS:
  423                         ipxstat.ipxs_odropped++;
  424                         break;
  425                 }
  426                 mcopy = NULL;
  427                 m_freem(m);
  428         }
  429 cleanup:
  430         if (ok_there)
  431                 ipx_undo_route(&ipx_droute);
  432         if (ok_back)
  433                 ipx_undo_route(&ipx_sroute);
  434         if (mcopy != NULL)
  435                 m_freem(mcopy);
  436 }
  437 
  438 static int
  439 ipx_do_route(src, ro)
  440 struct ipx_addr *src;
  441 struct route *ro;
  442 {
  443         struct sockaddr_ipx *dst;
  444 
  445         bzero((caddr_t)ro, sizeof(*ro));
  446         dst = (struct sockaddr_ipx *)&ro->ro_dst;
  447 
  448         dst->sipx_len = sizeof(*dst);
  449         dst->sipx_family = AF_IPX;
  450         dst->sipx_addr = *src;
  451         dst->sipx_addr.x_port = 0;
  452         rtalloc(ro);
  453         if (ro->ro_rt == NULL || ro->ro_rt->rt_ifp == NULL) {
  454                 return (0);
  455         }
  456         ro->ro_rt->rt_use++;
  457         return (1);
  458 }
  459 
  460 static void
  461 ipx_undo_route(ro)
  462 register struct route *ro;
  463 {
  464         if (ro->ro_rt != NULL) {
  465                 RTFREE(ro->ro_rt);
  466         }
  467 }
  468 
  469 void
  470 ipx_watch_output(m, ifp)
  471 struct mbuf *m;
  472 struct ifnet *ifp;
  473 {
  474         register struct ipxpcb *ipxp;
  475         register struct ifaddr *ifa;
  476         register struct ipx_ifaddr *ia;
  477         /*
  478          * Give any raw listeners a crack at the packet
  479          */
  480         for (ipxp = ipxrawpcb.ipxp_next; ipxp != &ipxrawpcb;
  481              ipxp = ipxp->ipxp_next) {
  482                 struct mbuf *m0 = m_copy(m, 0, (int)M_COPYALL);
  483                 if (m0 != NULL) {
  484                         register struct ipx *ipx;
  485 
  486                         M_PREPEND(m0, sizeof(*ipx), M_DONTWAIT);
  487                         if (m0 == NULL)
  488                                 continue;
  489                         ipx = mtod(m0, struct ipx *);
  490                         ipx->ipx_sna.x_net = ipx_zeronet;
  491                         for (ia = ipx_ifaddr; ia != NULL; ia = ia->ia_next)
  492                                 if (ifp == ia->ia_ifp)
  493                                         break;
  494                         if (ia == NULL)
  495                                 ipx->ipx_sna.x_host = ipx_zerohost;  
  496                         else 
  497                                 ipx->ipx_sna.x_host =
  498                                     ia->ia_addr.sipx_addr.x_host;
  499 
  500                         if (ifp != NULL && (ifp->if_flags & IFF_POINTOPOINT))
  501                             TAILQ_FOREACH(ifa, &ifp->if_addrhead, ifa_link) {
  502                                 if (ifa->ifa_addr->sa_family == AF_IPX) {
  503                                     ipx->ipx_sna = IA_SIPX(ifa)->sipx_addr;
  504                                     break;
  505                                 }
  506                             }
  507                         ipx->ipx_len = ntohl(m0->m_pkthdr.len);
  508                         ipx_input(m0, ipxp);
  509                 }
  510         }
  511 }

Cache object: 0d2dae3c8ee814ceae06e0e971fc76d9


[ 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.