14a5d661aSToomas Soome /* $NetBSD: net.c,v 1.20 1997/12/26 22:41:30 scottr Exp $ */
24a5d661aSToomas Soome
34a5d661aSToomas Soome /*
44a5d661aSToomas Soome * Copyright (c) 1992 Regents of the University of California.
54a5d661aSToomas Soome * All rights reserved.
64a5d661aSToomas Soome *
74a5d661aSToomas Soome * This software was developed by the Computer Systems Engineering group
84a5d661aSToomas Soome * at Lawrence Berkeley Laboratory under DARPA contract BG 91-66 and
94a5d661aSToomas Soome * contributed to Berkeley.
104a5d661aSToomas Soome *
114a5d661aSToomas Soome * Redistribution and use in source and binary forms, with or without
124a5d661aSToomas Soome * modification, are permitted provided that the following conditions
134a5d661aSToomas Soome * are met:
144a5d661aSToomas Soome * 1. Redistributions of source code must retain the above copyright
154a5d661aSToomas Soome * notice, this list of conditions and the following disclaimer.
164a5d661aSToomas Soome * 2. Redistributions in binary form must reproduce the above copyright
174a5d661aSToomas Soome * notice, this list of conditions and the following disclaimer in the
184a5d661aSToomas Soome * documentation and/or other materials provided with the distribution.
194a5d661aSToomas Soome * 4. Neither the name of the University nor the names of its contributors
204a5d661aSToomas Soome * may be used to endorse or promote products derived from this software
214a5d661aSToomas Soome * without specific prior written permission.
224a5d661aSToomas Soome *
234a5d661aSToomas Soome * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
244a5d661aSToomas Soome * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
254a5d661aSToomas Soome * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
264a5d661aSToomas Soome * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
274a5d661aSToomas Soome * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
284a5d661aSToomas Soome * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
294a5d661aSToomas Soome * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
304a5d661aSToomas Soome * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
314a5d661aSToomas Soome * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
324a5d661aSToomas Soome * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
334a5d661aSToomas Soome * SUCH DAMAGE.
344a5d661aSToomas Soome *
354a5d661aSToomas Soome * @(#) Header: net.c,v 1.9 93/08/06 19:32:15 leres Exp (LBL)
364a5d661aSToomas Soome */
374a5d661aSToomas Soome
384a5d661aSToomas Soome #include <sys/cdefs.h>
394a5d661aSToomas Soome
404a5d661aSToomas Soome #include <sys/param.h>
414a5d661aSToomas Soome #include <sys/socket.h>
424a5d661aSToomas Soome
434a5d661aSToomas Soome #include <string.h>
444a5d661aSToomas Soome
454a5d661aSToomas Soome #include <net/if.h>
464a5d661aSToomas Soome #include <netinet/in.h>
474a5d661aSToomas Soome #include <netinet/if_ether.h>
484a5d661aSToomas Soome #include <netinet/in_systm.h>
494a5d661aSToomas Soome
504a5d661aSToomas Soome #include <netinet/in_pcb.h>
514a5d661aSToomas Soome #include <netinet/ip.h>
524a5d661aSToomas Soome #include <netinet/ip_var.h>
534a5d661aSToomas Soome #include <netinet/udp.h>
544a5d661aSToomas Soome #include <netinet/udp_var.h>
554a5d661aSToomas Soome
564a5d661aSToomas Soome #include "stand.h"
574a5d661aSToomas Soome #include "net.h"
584a5d661aSToomas Soome
594a5d661aSToomas Soome /*
604a5d661aSToomas Soome * Send a packet and wait for a reply, with exponential backoff.
614a5d661aSToomas Soome *
624a5d661aSToomas Soome * The send routine must return the actual number of bytes written,
634a5d661aSToomas Soome * or -1 on error.
644a5d661aSToomas Soome *
654a5d661aSToomas Soome * The receive routine can indicate success by returning the number of
664a5d661aSToomas Soome * bytes read; it can return 0 to indicate EOF; it can return -1 with a
674a5d661aSToomas Soome * non-zero errno to indicate failure; finally, it can return -1 with a
684a5d661aSToomas Soome * zero errno to indicate it isn't done yet.
694a5d661aSToomas Soome */
704a5d661aSToomas Soome ssize_t
sendrecv(struct iodesc * d,ssize_t (* sproc)(struct iodesc *,void *,size_t),void * sbuf,size_t ssize,ssize_t (* rproc)(struct iodesc *,void **,void **,time_t),void ** pkt,void ** payload)714a5d661aSToomas Soome sendrecv(struct iodesc *d,
724a5d661aSToomas Soome ssize_t (*sproc)(struct iodesc *, void *, size_t),
734a5d661aSToomas Soome void *sbuf, size_t ssize,
747b2a1233SToomas Soome ssize_t (*rproc)(struct iodesc *, void **, void**, time_t),
757b2a1233SToomas Soome void **pkt, void **payload)
764a5d661aSToomas Soome {
774a5d661aSToomas Soome ssize_t cc;
784a5d661aSToomas Soome time_t t, tmo, tlast;
794a5d661aSToomas Soome long tleft;
804a5d661aSToomas Soome
814a5d661aSToomas Soome #ifdef NET_DEBUG
824a5d661aSToomas Soome if (debug)
834a5d661aSToomas Soome printf("sendrecv: called\n");
844a5d661aSToomas Soome #endif
854a5d661aSToomas Soome
864a5d661aSToomas Soome tmo = MINTMO;
874a5d661aSToomas Soome tlast = 0;
884a5d661aSToomas Soome tleft = 0;
894a5d661aSToomas Soome t = getsecs();
904a5d661aSToomas Soome for (;;) {
914a5d661aSToomas Soome if (tleft <= 0) {
924a5d661aSToomas Soome if (tmo >= MAXTMO) {
934a5d661aSToomas Soome errno = ETIMEDOUT;
944a5d661aSToomas Soome return -1;
954a5d661aSToomas Soome }
964a5d661aSToomas Soome cc = (*sproc)(d, sbuf, ssize);
974a5d661aSToomas Soome if (cc != -1 && cc < ssize)
984a5d661aSToomas Soome panic("sendrecv: short write! (%zd < %zd)",
994a5d661aSToomas Soome cc, ssize);
1004a5d661aSToomas Soome
1014a5d661aSToomas Soome tleft = tmo;
1024a5d661aSToomas Soome tmo += MINTMO;
1034a5d661aSToomas Soome if (tmo > MAXTMO)
1044a5d661aSToomas Soome tmo = MAXTMO;
1054a5d661aSToomas Soome
1064a5d661aSToomas Soome if (cc == -1) {
1074a5d661aSToomas Soome /* Error on transmit; wait before retrying */
1084a5d661aSToomas Soome while ((getsecs() - t) < tmo)
1094a5d661aSToomas Soome ;
1104a5d661aSToomas Soome tleft = 0;
1114a5d661aSToomas Soome continue;
1124a5d661aSToomas Soome }
1134a5d661aSToomas Soome
1144a5d661aSToomas Soome tlast = t;
1154a5d661aSToomas Soome }
1164a5d661aSToomas Soome
1174a5d661aSToomas Soome /* Try to get a packet and process it. */
1187b2a1233SToomas Soome cc = (*rproc)(d, pkt, payload, tleft);
1194a5d661aSToomas Soome /* Return on data, EOF or real error. */
120*a01cd540SToomas Soome if (cc != -1 || (errno != 0 && errno != ETIMEDOUT))
1214a5d661aSToomas Soome return (cc);
1224a5d661aSToomas Soome
1234a5d661aSToomas Soome /* Timed out or didn't get the packet we're waiting for */
1244a5d661aSToomas Soome t = getsecs();
1254a5d661aSToomas Soome tleft -= t - tlast;
1264a5d661aSToomas Soome tlast = t;
1274a5d661aSToomas Soome }
1284a5d661aSToomas Soome }
1294a5d661aSToomas Soome
1304a5d661aSToomas Soome /*
1314a5d661aSToomas Soome * Like inet_addr() in the C library, but we only accept base-10.
1324a5d661aSToomas Soome * Return values are in network order.
1334a5d661aSToomas Soome */
1344a5d661aSToomas Soome n_long
inet_addr(char * cp)1354a5d661aSToomas Soome inet_addr(char *cp)
1364a5d661aSToomas Soome {
1374a5d661aSToomas Soome u_long val;
1384a5d661aSToomas Soome int n;
1394a5d661aSToomas Soome char c;
1404a5d661aSToomas Soome u_int parts[4];
1414a5d661aSToomas Soome u_int *pp = parts;
1424a5d661aSToomas Soome
1434a5d661aSToomas Soome for (;;) {
1444a5d661aSToomas Soome /*
1454a5d661aSToomas Soome * Collect number up to ``.''.
1464a5d661aSToomas Soome * Values are specified as for C:
1474a5d661aSToomas Soome * 0x=hex, 0=octal, other=decimal.
1484a5d661aSToomas Soome */
1494a5d661aSToomas Soome val = 0;
1504a5d661aSToomas Soome while ((c = *cp) != '\0') {
1514a5d661aSToomas Soome if (c >= '0' && c <= '9') {
1524a5d661aSToomas Soome val = (val * 10) + (c - '0');
1534a5d661aSToomas Soome cp++;
1544a5d661aSToomas Soome continue;
1554a5d661aSToomas Soome }
1564a5d661aSToomas Soome break;
1574a5d661aSToomas Soome }
1584a5d661aSToomas Soome if (*cp == '.') {
1594a5d661aSToomas Soome /*
1604a5d661aSToomas Soome * Internet format:
1614a5d661aSToomas Soome * a.b.c.d
1624a5d661aSToomas Soome * a.b.c (with c treated as 16-bits)
1634a5d661aSToomas Soome * a.b (with b treated as 24 bits)
1644a5d661aSToomas Soome */
1654a5d661aSToomas Soome if (pp >= parts + 3 || val > 0xff)
1664a5d661aSToomas Soome goto bad;
1674a5d661aSToomas Soome *pp++ = val, cp++;
1684a5d661aSToomas Soome } else
1694a5d661aSToomas Soome break;
1704a5d661aSToomas Soome }
1714a5d661aSToomas Soome /*
1724a5d661aSToomas Soome * Check for trailing characters.
1734a5d661aSToomas Soome */
1744a5d661aSToomas Soome if (*cp != '\0')
1754a5d661aSToomas Soome goto bad;
1764a5d661aSToomas Soome
1774a5d661aSToomas Soome /*
1784a5d661aSToomas Soome * Concoct the address according to
1794a5d661aSToomas Soome * the number of parts specified.
1804a5d661aSToomas Soome */
1814a5d661aSToomas Soome n = pp - parts + 1;
1824a5d661aSToomas Soome switch (n) {
1834a5d661aSToomas Soome
1844a5d661aSToomas Soome case 1: /* a -- 32 bits */
1854a5d661aSToomas Soome break;
1864a5d661aSToomas Soome
1874a5d661aSToomas Soome case 2: /* a.b -- 8.24 bits */
1884a5d661aSToomas Soome if (val > 0xffffff)
1894a5d661aSToomas Soome goto bad;
1904a5d661aSToomas Soome val |= parts[0] << 24;
1914a5d661aSToomas Soome break;
1924a5d661aSToomas Soome
1934a5d661aSToomas Soome case 3: /* a.b.c -- 8.8.16 bits */
1944a5d661aSToomas Soome if (val > 0xffff)
1954a5d661aSToomas Soome goto bad;
1964a5d661aSToomas Soome val |= (parts[0] << 24) | (parts[1] << 16);
1974a5d661aSToomas Soome break;
1984a5d661aSToomas Soome
1994a5d661aSToomas Soome case 4: /* a.b.c.d -- 8.8.8.8 bits */
2004a5d661aSToomas Soome if (val > 0xff)
2014a5d661aSToomas Soome goto bad;
2024a5d661aSToomas Soome val |= (parts[0] << 24) | (parts[1] << 16) | (parts[2] << 8);
2034a5d661aSToomas Soome break;
2044a5d661aSToomas Soome }
2054a5d661aSToomas Soome
2064a5d661aSToomas Soome return (htonl(val));
2074a5d661aSToomas Soome bad:
2084a5d661aSToomas Soome return (htonl(INADDR_NONE));
2094a5d661aSToomas Soome }
2104a5d661aSToomas Soome
2114a5d661aSToomas Soome char *
inet_ntoa(struct in_addr ia)2124a5d661aSToomas Soome inet_ntoa(struct in_addr ia)
2134a5d661aSToomas Soome {
2144a5d661aSToomas Soome return (intoa(ia.s_addr));
2154a5d661aSToomas Soome }
2164a5d661aSToomas Soome
2174a5d661aSToomas Soome /* Similar to inet_ntoa() */
2184a5d661aSToomas Soome char *
intoa(n_long addr)2194a5d661aSToomas Soome intoa(n_long addr)
2204a5d661aSToomas Soome {
2214a5d661aSToomas Soome char *cp;
2224a5d661aSToomas Soome u_int byte;
2234a5d661aSToomas Soome int n;
2244a5d661aSToomas Soome static char buf[17]; /* strlen(".255.255.255.255") + 1 */
2254a5d661aSToomas Soome
2264a5d661aSToomas Soome addr = ntohl(addr);
2274a5d661aSToomas Soome cp = &buf[sizeof buf];
2284a5d661aSToomas Soome *--cp = '\0';
2294a5d661aSToomas Soome
2304a5d661aSToomas Soome n = 4;
2314a5d661aSToomas Soome do {
2324a5d661aSToomas Soome byte = addr & 0xff;
2334a5d661aSToomas Soome *--cp = byte % 10 + '0';
2344a5d661aSToomas Soome byte /= 10;
2354a5d661aSToomas Soome if (byte > 0) {
2364a5d661aSToomas Soome *--cp = byte % 10 + '0';
2374a5d661aSToomas Soome byte /= 10;
2384a5d661aSToomas Soome if (byte > 0)
2394a5d661aSToomas Soome *--cp = byte + '0';
2404a5d661aSToomas Soome }
2414a5d661aSToomas Soome *--cp = '.';
2424a5d661aSToomas Soome addr >>= 8;
2434a5d661aSToomas Soome } while (--n > 0);
2444a5d661aSToomas Soome
2454a5d661aSToomas Soome return (cp+1);
2464a5d661aSToomas Soome }
2474a5d661aSToomas Soome
2484a5d661aSToomas Soome static char *
number(char * s,int * n)2494a5d661aSToomas Soome number(char *s, int *n)
2504a5d661aSToomas Soome {
2514a5d661aSToomas Soome for (*n = 0; isdigit(*s); s++)
2524a5d661aSToomas Soome *n = (*n * 10) + *s - '0';
2534a5d661aSToomas Soome return s;
2544a5d661aSToomas Soome }
2554a5d661aSToomas Soome
2564a5d661aSToomas Soome n_long
ip_convertaddr(char * p)2574a5d661aSToomas Soome ip_convertaddr(char *p)
2584a5d661aSToomas Soome {
2594a5d661aSToomas Soome #define IP_ANYADDR 0
2604a5d661aSToomas Soome n_long addr = 0, n;
2614a5d661aSToomas Soome
2624a5d661aSToomas Soome if (p == (char *)0 || *p == '\0')
2634a5d661aSToomas Soome return IP_ANYADDR;
2644a5d661aSToomas Soome p = number(p, &n);
2654a5d661aSToomas Soome addr |= (n << 24) & 0xff000000;
2664a5d661aSToomas Soome if (*p == '\0' || *p++ != '.')
2674a5d661aSToomas Soome return IP_ANYADDR;
2684a5d661aSToomas Soome p = number(p, &n);
2694a5d661aSToomas Soome addr |= (n << 16) & 0xff0000;
2704a5d661aSToomas Soome if (*p == '\0' || *p++ != '.')
2714a5d661aSToomas Soome return IP_ANYADDR;
2724a5d661aSToomas Soome p = number(p, &n);
2734a5d661aSToomas Soome addr |= (n << 8) & 0xff00;
2744a5d661aSToomas Soome if (*p == '\0' || *p++ != '.')
2754a5d661aSToomas Soome return IP_ANYADDR;
2764a5d661aSToomas Soome p = number(p, &n);
2774a5d661aSToomas Soome addr |= n & 0xff;
2784a5d661aSToomas Soome if (*p != '\0')
2794a5d661aSToomas Soome return IP_ANYADDR;
2804a5d661aSToomas Soome
2814a5d661aSToomas Soome return htonl(addr);
2824a5d661aSToomas Soome }
283