Home | History | Annotate | Line # | Download | only in rarpd
mkarp.c revision 1.3
      1 /*	$NetBSD: mkarp.c,v 1.3 2000/02/11 11:27:20 abs Exp $ */
      2 
      3 /*
      4  * Copyright (c) 1984, 1993
      5  *	The Regents of the University of California.  All rights reserved.
      6  *
      7  * This code is derived from software contributed to Berkeley by
      8  * Sun Microsystems, Inc.
      9  *
     10  * Redistribution and use in source and binary forms, with or without
     11  * modification, are permitted provided that the following conditions
     12  * are met:
     13  * 1. Redistributions of source code must retain the above copyright
     14  *    notice, this list of conditions and the following disclaimer.
     15  * 2. Redistributions in binary form must reproduce the above copyright
     16  *    notice, this list of conditions and the following disclaimer in the
     17  *    documentation and/or other materials provided with the distribution.
     18  * 3. All advertising materials mentioning features or use of this software
     19  *    must display the following acknowledgement:
     20  *	This product includes software developed by the University of
     21  *	California, Berkeley and its contributors.
     22  * 4. Neither the name of the University nor the names of its contributors
     23  *    may be used to endorse or promote products derived from this software
     24  *    without specific prior written permission.
     25  *
     26  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     27  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     28  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     29  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     30  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     31  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     32  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     33  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     34  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     35  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     36  * SUCH DAMAGE.
     37  */
     38 
     39 #include <sys/cdefs.h>
     40 #ifndef lint
     41 __COPYRIGHT("@(#) Copyright (c) 1984, 1993\n\
     42 	The Regents of the University of California.  All rights reserved.\n");
     43 #endif /* not lint */
     44 
     45 #ifndef lint
     46 #if 0
     47 static char sccsid[] = "@(#)arp.c	8.3 (Berkeley) 4/28/95";
     48 #else
     49 __RCSID("$NetBSD: mkarp.c,v 1.3 2000/02/11 11:27:20 abs Exp $");
     50 #endif
     51 #endif /* not lint */
     52 
     53 /*
     54  * mkarp - set an arp table entry
     55  */
     56 
     57 #include <sys/param.h>
     58 #include <sys/file.h>
     59 #include <sys/socket.h>
     60 #include <sys/sysctl.h>
     61 
     62 #include <net/if.h>
     63 #include <net/if_dl.h>
     64 #include <net/if_ether.h>
     65 #include <net/if_types.h>
     66 #include <net/route.h>
     67 #include <netinet/in.h>
     68 #include <netinet/if_inarp.h>
     69 #include <arpa/inet.h>
     70 
     71 #include <err.h>
     72 #include <errno.h>
     73 #include <netdb.h>
     74 #include <nlist.h>
     75 #include <paths.h>
     76 #include <stdio.h>
     77 #include <stdlib.h>
     78 #include <string.h>
     79 #include <unistd.h>
     80 
     81 #include "mkarp.h"
     82 
     83 int	rtmsg __P((int, int, struct rt_msghdr *, struct sockaddr_inarp *,
     84 		   struct sockaddr_dl *));
     85 struct	{
     86 	struct	rt_msghdr m_rtm;
     87 	char	m_space[512];
     88 }	m_rtmsg;
     89 
     90 /*
     91  * Set an individual arp entry
     92  */
     93 int
     94 mkarp(haddr, ipaddr)
     95 	u_char *haddr;
     96 	u_int32_t ipaddr;
     97 {
     98 	static struct sockaddr_inarp blank_sin = {sizeof(blank_sin), AF_INET };
     99 	static struct sockaddr_dl blank_sdl = {sizeof(blank_sdl), AF_LINK };
    100 
    101 	struct sockaddr_inarp *sin;
    102 	struct sockaddr_dl *sdl;
    103 	struct rt_msghdr *rtm;
    104 	u_int8_t *p, *endp;
    105 	int result;
    106 	int s;
    107 
    108 	struct sockaddr_inarp sin_m;
    109 	struct sockaddr_dl sdl_m;
    110 
    111 	sin = &sin_m;
    112 	rtm = &(m_rtmsg.m_rtm);
    113 
    114 	sdl_m = blank_sdl;		/* struct copy */
    115 	sin_m = blank_sin;		/* struct copy */
    116 
    117 	sin->sin_addr.s_addr = ipaddr;
    118 
    119 	p = LLADDR(&sdl_m);
    120 	endp = ((caddr_t)&sdl_m) + sdl_m.sdl_len;
    121 	if (endp > (p + ETHER_ADDR_LEN))
    122 		endp = p + ETHER_ADDR_LEN;
    123 
    124 	while (p < endp) {
    125 		*p++ = *haddr++;
    126 	}
    127 	sdl_m.sdl_alen = ETHER_ADDR_LEN;
    128 
    129 	/*
    130 	 * We need to close and open the socket to prevent routing updates
    131 	 * building up such that when we send our message we never see our
    132 	 * reply (and hang)
    133 	 */
    134 	s = socket(PF_ROUTE, SOCK_RAW, 0);
    135 	if (s < 0)
    136 		err(1, "socket");
    137 
    138 	rtm->rtm_flags = 0;
    139 
    140 	if (rtmsg(RTM_GET, s, rtm, &sin_m, &sdl_m) < 0) {
    141 #if 0
    142 		warn("%s", host);
    143 #endif
    144 		close(s);
    145 		return (1);
    146 	}
    147 	sin = (struct sockaddr_inarp *)(rtm + 1);
    148 	sdl = (struct sockaddr_dl *)(sin->sin_len + (char *)sin);
    149 	if (sin->sin_addr.s_addr == sin_m.sin_addr.s_addr) {
    150 		if (sdl->sdl_family == AF_LINK &&
    151 		    (rtm->rtm_flags & RTF_LLINFO) &&
    152 		    !(rtm->rtm_flags & RTF_GATEWAY)) switch (sdl->sdl_type) {
    153 		case IFT_ETHER: case IFT_FDDI: case IFT_ISO88023:
    154 		case IFT_ISO88024: case IFT_ISO88025: case IFT_ARCNET:
    155 			goto overwrite;
    156 		}
    157 #if 0
    158 		(void)printf("set: can only proxy for %s\n", host);
    159 #endif
    160 		close(s);
    161 		return (1);
    162 	}
    163 overwrite:
    164 	if (sdl->sdl_family != AF_LINK) {
    165 #if 0
    166 		(void)printf("cannot intuit interface index and type for %s\n",
    167 		    host);
    168 #endif
    169 		close(s);
    170 		return (1);
    171 	}
    172 	sdl_m.sdl_type = sdl->sdl_type;
    173 	sdl_m.sdl_index = sdl->sdl_index;
    174 	result = rtmsg(RTM_ADD, s, rtm, &sin_m, &sdl_m);
    175 	close(s);
    176 	return (result);
    177 }
    178 
    179 int
    180 rtmsg(cmd, s, rtm, sin_m, sdl_m)
    181 	int cmd;
    182 	int s;
    183 	struct rt_msghdr *rtm;
    184 	struct sockaddr_inarp *sin_m;
    185 	struct sockaddr_dl *sdl_m;
    186 {
    187 	static int seq;
    188 	int rlen;
    189 	char *cp;
    190 	int l;
    191 	pid_t pid;
    192 	struct timeval time;
    193 
    194 	rtm = &m_rtmsg.m_rtm;
    195 	cp = m_rtmsg.m_space;
    196 	errno = 0;
    197 
    198 	pid = getpid();
    199 
    200 	(void)memset(&m_rtmsg, 0, sizeof(m_rtmsg));
    201 	rtm->rtm_version = RTM_VERSION;
    202 
    203 	switch (cmd) {
    204 	default:
    205 		errx(1, "internal wrong cmd");
    206 		/*NOTREACHED*/
    207 	case RTM_ADD:
    208 		rtm->rtm_addrs |= RTA_GATEWAY;
    209 		(void)gettimeofday(&time, 0);
    210 		rtm->rtm_rmx.rmx_expire = time.tv_sec + 20 * 60;
    211 		rtm->rtm_inits = RTV_EXPIRE;
    212 		rtm->rtm_flags |= (RTF_HOST | RTF_STATIC);
    213 		sin_m->sin_other = 0;
    214 
    215 		/* FALLTHROUGH */
    216 	case RTM_GET:
    217 		rtm->rtm_addrs |= RTA_DST;
    218 	}
    219 #define NEXTADDR(w, s) \
    220 	if (rtm->rtm_addrs & (w)) { \
    221 		(void)memcpy(cp, s, ((struct sockaddr *)s)->sa_len); \
    222 		cp += ((struct sockaddr *)s)->sa_len;}
    223 
    224 	NEXTADDR(RTA_DST, sin_m);
    225 	NEXTADDR(RTA_GATEWAY, sdl_m);
    226 
    227 	rtm->rtm_msglen = cp - (char *)&m_rtmsg;
    228 
    229 	l = rtm->rtm_msglen;
    230 	rtm->rtm_seq = ++seq;
    231 	rtm->rtm_type = cmd;
    232 	if ((rlen = write(s, (char *)&m_rtmsg, l)) < 0) {
    233 		if (errno != ESRCH && errno != EEXIST) {
    234 			warn("writing to routing socket");
    235 			return (-1);
    236 		}
    237 	}
    238 	do {
    239 		l = read(s, (char *)&m_rtmsg, sizeof(m_rtmsg));
    240 	} while (l > 0 && (rtm->rtm_seq != seq || rtm->rtm_pid != pid));
    241 	if (l < 0)
    242 		warn("read from routing socket");
    243 	return (0);
    244 }
    245