sys/netipx/ipx_pcb.c

   1 /*-
   2  * Copyright (c) 2004-2005 Robert N. M. Watson
   3  * Copyright (c) 1995, Mike Mitchell
   4  * Copyright (c) 1984, 1985, 1986, 1987, 1993
   5  *      The Regents of the University of California.  All rights reserved.
   6  *
   7  * Redistribution and use in source and binary forms, with or without
   8  * modification, are permitted provided that the following conditions
   9  * are met:
  10  * 1. Redistributions of source code must retain the above copyright
  11  *    notice, this list of conditions and the following disclaimer.
  12  * 2. Redistributions in binary form must reproduce the above copyright
  13  *    notice, this list of conditions and the following disclaimer in the
  14  *    documentation and/or other materials provided with the distribution.
  15  * 3. All advertising materials mentioning features or use of this software
  16  *    must display the following acknowledgement:
  17  *      This product includes software developed by the University of
  18  *      California, Berkeley and its contributors.
  19  * 4. Neither the name of the University nor the names of its contributors
  20  *    may be used to endorse or promote products derived from this software
  21  *    without specific prior written permission.
  22  *
  23  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  24  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  25  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  26  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  27  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  28  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  29  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  30  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  31  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  32  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  33  * SUCH DAMAGE.
  34  *
  35  *      @(#)ipx_pcb.c
  36  */
  37
  38 #include <sys/cdefs.h>
  39 __FBSDID("$FreeBSD$");
  40
  41 #include <sys/param.h>
  42 #include <sys/systm.h>
  43 #include <sys/malloc.h>
  44 #include <sys/socket.h>
  45 #include <sys/socketvar.h>
  46
  47 #include <net/if.h>
  48 #include <net/route.h>
  49
  50 #include <netipx/ipx.h>
  51 #include <netipx/ipx_if.h>
  52 #include <netipx/ipx_pcb.h>
  53 #include <netipx/ipx_var.h>
  54
  55 static struct   ipx_addr zeroipx_addr;
  56 static u_short  ipxpcb_lport_cache;
  57
  58 int
  59 ipx_pcballoc(so, head, td)
  60         struct socket *so;
  61         struct ipxpcbhead *head;
  62         struct thread *td;
  63 {
  64         register struct ipxpcb *ipxp;
  65
  66         IPX_LIST_LOCK_ASSERT();
  67
  68         MALLOC(ipxp, struct ipxpcb *, sizeof *ipxp, M_PCB, M_NOWAIT | M_ZERO);
  69         if (ipxp == NULL)
  70                 return (ENOBUFS);
  71         IPX_LOCK_INIT(ipxp);
  72         ipxp->ipxp_socket = so;
  73         if (ipxcksum)
  74                 ipxp->ipxp_flags |= IPXP_CHECKSUM;
  75         LIST_INSERT_HEAD(head, ipxp, ipxp_list);
  76         so->so_pcb = (caddr_t)ipxp;
  77         return (0);
  78 }
  79
  80 int
  81 ipx_pcbbind(ipxp, nam, td)
  82         register struct ipxpcb *ipxp;
  83         struct sockaddr *nam;
  84         struct thread *td;
  85 {
  86         register struct sockaddr_ipx *sipx;
  87         u_short lport = 0;
  88
  89         IPX_LIST_LOCK_ASSERT();
  90         IPX_LOCK_ASSERT(ipxp);
  91
  92         if (ipxp->ipxp_lport || !ipx_nullhost(ipxp->ipxp_laddr))
  93                 return (EINVAL);
  94         if (nam == NULL)
  95                 goto noname;
  96         sipx = (struct sockaddr_ipx *)nam;
  97         if (!ipx_nullhost(sipx->sipx_addr)) {
  98                 int tport = sipx->sipx_port;
  99
 100                 sipx->sipx_port = 0;            /* yech... */
 101                 if (ifa_ifwithaddr((struct sockaddr *)sipx) == NULL)
 102                         return (EADDRNOTAVAIL);
 103                 sipx->sipx_port = tport;
 104         }
 105         lport = sipx->sipx_port;
 106         if (lport) {
 107                 u_short aport = ntohs(lport);
 108                 int error;
 109
 110                 if (aport < IPXPORT_RESERVED &&
 111                     td != NULL && (error = suser(td)) != 0)
 112                         return (error);
 113                 if (ipx_pcblookup(&zeroipx_addr, lport, 0))
 114                         return (EADDRINUSE);
 115         }
 116         ipxp->ipxp_laddr = sipx->sipx_addr;
 117 noname:
 118         if (lport == 0)
 119                 do {
 120                         ipxpcb_lport_cache++;
 121                         if ((ipxpcb_lport_cache < IPXPORT_RESERVED) ||
 122                             (ipxpcb_lport_cache >= IPXPORT_WELLKNOWN))
 123                                 ipxpcb_lport_cache = IPXPORT_RESERVED;
 124                         lport = htons(ipxpcb_lport_cache);
 125                 } while (ipx_pcblookup(&zeroipx_addr, lport, 0));
 126         ipxp->ipxp_lport = lport;
 127         return (0);
 128 }
 129
 130 /*
 131  * Connect from a socket to a specified address.
 132  * Both address and port must be specified in argument sipx.
 133  * If don't have a local address for this socket yet,
 134  * then pick one.
 135  */
 136 int
 137 ipx_pcbconnect(ipxp, nam, td)
 138         struct ipxpcb *ipxp;
 139         struct sockaddr *nam;
 140         struct thread *td;
 141 {
 142         struct ipx_ifaddr *ia;
 143         register struct sockaddr_ipx *sipx = (struct sockaddr_ipx *)nam;
 144         register struct ipx_addr *dst;
 145         register struct route *ro;
 146         struct ifnet *ifp;
 147
 148         IPX_LIST_LOCK_ASSERT();
 149         IPX_LOCK_ASSERT(ipxp);
 150
 151         ia = NULL;
 152
 153         if (sipx->sipx_family != AF_IPX)
 154                 return (EAFNOSUPPORT);
 155         if (sipx->sipx_port == 0 || ipx_nullhost(sipx->sipx_addr))
 156                 return (EADDRNOTAVAIL);
 157         /*
 158          * If we haven't bound which network number to use as ours,
 159          * we will use the number of the outgoing interface.
 160          * This depends on having done a routing lookup, which
 161          * we will probably have to do anyway, so we might
 162          * as well do it now.  On the other hand if we are
 163          * sending to multiple destinations we may have already
 164          * done the lookup, so see if we can use the route
 165          * from before.  In any case, we only
 166          * chose a port number once, even if sending to multiple
 167          * destinations.
 168          */
 169         ro = &ipxp->ipxp_route;
 170         dst = &satoipx_addr(ro->ro_dst);
 171         if (ipxp->ipxp_socket->so_options & SO_DONTROUTE)
 172                 goto flush;
 173         if (!ipx_neteq(ipxp->ipxp_lastdst, sipx->sipx_addr))
 174                 goto flush;
 175         if (!ipx_hosteq(ipxp->ipxp_lastdst, sipx->sipx_addr)) {
 176                 if (ro->ro_rt != NULL && !(ro->ro_rt->rt_flags & RTF_HOST)) {
 177                         /* can patch route to avoid rtalloc */
 178                         *dst = sipx->sipx_addr;
 179                 } else {
 180         flush:
 181                         if (ro->ro_rt != NULL)
 182                                 RTFREE(ro->ro_rt);
 183                         ro->ro_rt = NULL;
 184                 }
 185         }/* else cached route is ok; do nothing */
 186         ipxp->ipxp_lastdst = sipx->sipx_addr;
 187         if ((ipxp->ipxp_socket->so_options & SO_DONTROUTE) == 0 && /*XXX*/
 188             (ro->ro_rt == NULL || ro->ro_rt->rt_ifp == NULL)) {
 189                     /* No route yet, so try to acquire one */
 190                     ro->ro_dst.sa_family = AF_IPX;
 191                     ro->ro_dst.sa_len = sizeof(ro->ro_dst);
 192                     *dst = sipx->sipx_addr;
 193                     dst->x_port = 0;
 194                     rtalloc_ign(ro, 0);
 195         }
 196         if (ipx_neteqnn(ipxp->ipxp_laddr.x_net, ipx_zeronet)) {
 197                 /*
 198                  * If route is known or can be allocated now,
 199                  * our src addr is taken from the i/f, else punt.
 200                  */
 201
 202                 /*
 203                  * If we found a route, use the address
 204                  * corresponding to the outgoing interface
 205                  */
 206                 if (ro->ro_rt != NULL && (ifp = ro->ro_rt->rt_ifp) != NULL)
 207                         for (ia = ipx_ifaddr; ia != NULL; ia = ia->ia_next)
 208                                 if (ia->ia_ifp == ifp)
 209                                         break;
 210                 if (ia == NULL) {
 211                         u_short fport = sipx->sipx_addr.x_port;
 212                         sipx->sipx_addr.x_port = 0;
 213                         ia = (struct ipx_ifaddr *)
 214                                 ifa_ifwithdstaddr((struct sockaddr *)sipx);
 215                         sipx->sipx_addr.x_port = fport;
 216                         if (ia == NULL)
 217                                 ia = ipx_iaonnetof(&sipx->sipx_addr);
 218                         if (ia == NULL)
 219                                 ia = ipx_ifaddr;
 220                         if (ia == NULL)
 221                                 return (EADDRNOTAVAIL);
 222                 }
 223                 ipxp->ipxp_laddr.x_net = satoipx_addr(ia->ia_addr).x_net;
 224         }
 225         if (ipx_nullhost(ipxp->ipxp_laddr)) {
 226                 /*
 227                  * If route is known or can be allocated now,
 228                  * our src addr is taken from the i/f, else punt.
 229                  */
 230
 231                 /*
 232                  * If we found a route, use the address
 233                  * corresponding to the outgoing interface
 234                  */
 235                 if (ro->ro_rt != NULL && (ifp = ro->ro_rt->rt_ifp) != NULL)
 236                         for (ia = ipx_ifaddr; ia != NULL; ia = ia->ia_next)
 237                                 if (ia->ia_ifp == ifp)
 238                                         break;
 239                 if (ia == NULL) {
 240                         u_short fport = sipx->sipx_addr.x_port;
 241                         sipx->sipx_addr.x_port = 0;
 242                         ia = (struct ipx_ifaddr *)
 243                                 ifa_ifwithdstaddr((struct sockaddr *)sipx);
 244                         sipx->sipx_addr.x_port = fport;
 245                         if (ia == NULL)
 246                                 ia = ipx_iaonnetof(&sipx->sipx_addr);
 247                         if (ia == NULL)
 248                                 ia = ipx_ifaddr;
 249                         if (ia == NULL)
 250                                 return (EADDRNOTAVAIL);
 251                 }
 252                 ipxp->ipxp_laddr.x_host = satoipx_addr(ia->ia_addr).x_host;
 253         }
 254         if (ipx_pcblookup(&sipx->sipx_addr, ipxp->ipxp_lport, 0))
 255                 return (EADDRINUSE);
 256         if (ipxp->ipxp_lport == 0)
 257                 ipx_pcbbind(ipxp, (struct sockaddr *)NULL, td);
 258
 259         /* XXX just leave it zero if we can't find a route */
 260
 261         ipxp->ipxp_faddr = sipx->sipx_addr;
 262         /* Includes ipxp->ipxp_fport = sipx->sipx_port; */
 263         return (0);
 264 }
 265
 266 void
 267 ipx_pcbdisconnect(ipxp)
 268         struct ipxpcb *ipxp;
 269 {
 270
 271         IPX_LIST_LOCK_ASSERT();
 272         IPX_LOCK_ASSERT(ipxp);
 273
 274         ipxp->ipxp_faddr = zeroipx_addr;
 275         if (ipxp->ipxp_socket->so_state & SS_NOFDREF)
 276                 ipx_pcbdetach(ipxp);
 277 }
 278
 279 void
 280 ipx_pcbdetach(ipxp)
 281         struct ipxpcb *ipxp;
 282 {
 283         struct socket *so = ipxp->ipxp_socket;
 284
 285         IPX_LIST_LOCK_ASSERT();
 286         IPX_LOCK_ASSERT(ipxp);
 287
 288         ACCEPT_LOCK();
 289         SOCK_LOCK(so);
 290         so->so_pcb = NULL;
 291         sotryfree(so);
 292         if (ipxp->ipxp_route.ro_rt != NULL)
 293                 RTFREE(ipxp->ipxp_route.ro_rt);
 294         LIST_REMOVE(ipxp, ipxp_list);
 295         IPX_LOCK_DESTROY(ipxp);
 296         FREE(ipxp, M_PCB);
 297 }
 298
 299 void
 300 ipx_setsockaddr(ipxp, nam)
 301         register struct ipxpcb *ipxp;
 302         struct sockaddr **nam;
 303 {
 304         struct sockaddr_ipx *sipx, ssipx;
 305
 306         sipx = &ssipx;
 307         bzero((caddr_t)sipx, sizeof(*sipx));
 308         sipx->sipx_len = sizeof(*sipx);
 309         sipx->sipx_family = AF_IPX;
 310         IPX_LOCK(ipxp);
 311         sipx->sipx_addr = ipxp->ipxp_laddr;
 312         IPX_UNLOCK(ipxp);
 313         *nam = sodupsockaddr((struct sockaddr *)sipx, M_WAITOK);
 314 }
 315
 316 void
 317 ipx_setpeeraddr(ipxp, nam)
 318         register struct ipxpcb *ipxp;
 319         struct sockaddr **nam;
 320 {
 321         struct sockaddr_ipx *sipx, ssipx;
 322
 323         sipx = &ssipx;
 324         bzero(sipx, sizeof(*sipx));
 325         sipx->sipx_len = sizeof(*sipx);
 326         sipx->sipx_family = AF_IPX;
 327         IPX_LOCK(ipxp);
 328         sipx->sipx_addr = ipxp->ipxp_faddr;
 329         IPX_UNLOCK(ipxp);
 330         *nam = sodupsockaddr((struct sockaddr *)sipx, M_WAITOK);
 331 }
 332
 333 struct ipxpcb *
 334 ipx_pcblookup(faddr, lport, wildp)
 335         struct ipx_addr *faddr;
 336         u_short lport;
 337         int wildp;
 338 {
 339         register struct ipxpcb *ipxp, *match = NULL;
 340         int matchwild = 3, wildcard;
 341         u_short fport;
 342
 343         IPX_LIST_LOCK_ASSERT();
 344
 345         fport = faddr->x_port;
 346         LIST_FOREACH(ipxp, &ipxpcb_list, ipxp_list) {
 347                 if (ipxp->ipxp_lport != lport)
 348                         continue;
 349                 wildcard = 0;
 350                 if (ipx_nullhost(ipxp->ipxp_faddr)) {
 351                         if (!ipx_nullhost(*faddr))
 352                                 wildcard++;
 353                 } else {
 354                         if (ipx_nullhost(*faddr))
 355                                 wildcard++;
 356                         else {
 357                                 if (!ipx_hosteq(ipxp->ipxp_faddr, *faddr))
 358                                         continue;
 359                                 if (ipxp->ipxp_fport != fport) {
 360                                         if (ipxp->ipxp_fport != 0)
 361                                                 continue;
 362                                         else
 363                                                 wildcard++;
 364                                 }
 365                         }
 366                 }
 367                 if (wildcard && wildp == 0)
 368                         continue;
 369                 if (wildcard < matchwild) {
 370                         match = ipxp;
 371                         matchwild = wildcard;
 372                         if (wildcard == 0)
 373                                 break;
 374                 }
 375         }
 376         return (match);
 377 }