Home | History | Annotate | Line # | Download | only in netatalk
ddp_output.c revision 1.2.22.1
      1  1.2.22.1   thorpej /*	$NetBSD: ddp_output.c,v 1.2.22.1 2002/01/10 20:02:25 thorpej Exp $	 */
      2       1.1  christos 
      3       1.1  christos /*
      4       1.1  christos  * Copyright (c) 1990,1991 Regents of The University of Michigan.
      5       1.1  christos  * All Rights Reserved.
      6       1.1  christos  *
      7       1.1  christos  * Permission to use, copy, modify, and distribute this software and
      8       1.1  christos  * its documentation for any purpose and without fee is hereby granted,
      9       1.1  christos  * provided that the above copyright notice appears in all copies and
     10       1.1  christos  * that both that copyright notice and this permission notice appear
     11       1.1  christos  * in supporting documentation, and that the name of The University
     12       1.1  christos  * of Michigan not be used in advertising or publicity pertaining to
     13       1.1  christos  * distribution of the software without specific, written prior
     14       1.1  christos  * permission. This software is supplied as is without expressed or
     15       1.1  christos  * implied warranties of any kind.
     16       1.1  christos  *
     17       1.1  christos  * This product includes software developed by the University of
     18       1.1  christos  * California, Berkeley and its contributors.
     19       1.1  christos  *
     20       1.1  christos  *	Research Systems Unix Group
     21       1.1  christos  *	The University of Michigan
     22       1.1  christos  *	c/o Wesley Craig
     23       1.1  christos  *	535 W. William Street
     24       1.1  christos  *	Ann Arbor, Michigan
     25       1.1  christos  *	+1-313-764-2278
     26       1.1  christos  *	netatalk (at) umich.edu
     27       1.1  christos  */
     28       1.1  christos 
     29  1.2.22.1   thorpej #include <sys/cdefs.h>
     30  1.2.22.1   thorpej __KERNEL_RCSID(0, "$NetBSD: ddp_output.c,v 1.2.22.1 2002/01/10 20:02:25 thorpej Exp $");
     31  1.2.22.1   thorpej 
     32       1.1  christos #include <sys/param.h>
     33       1.1  christos #include <sys/systm.h>
     34       1.1  christos #include <sys/mbuf.h>
     35       1.1  christos #include <sys/socket.h>
     36       1.1  christos #include <sys/errno.h>
     37       1.1  christos #include <sys/syslog.h>
     38       1.1  christos 
     39       1.1  christos #include <net/if.h>
     40       1.1  christos #include <net/route.h>
     41       1.1  christos #include <net/if_ether.h>
     42       1.1  christos 
     43       1.1  christos #include <netinet/in.h>
     44       1.1  christos #undef s_net
     45       1.1  christos 
     46       1.1  christos #include <netatalk/at.h>
     47       1.1  christos #include <netatalk/at_var.h>
     48       1.1  christos #include <netatalk/ddp.h>
     49       1.1  christos #include <netatalk/ddp_var.h>
     50       1.1  christos #include <netatalk/at_extern.h>
     51       1.1  christos 
     52       1.1  christos #include <machine/stdarg.h>
     53       1.1  christos 
     54       1.1  christos int ddp_cksum = 1;
     55       1.1  christos 
     56       1.1  christos int
     57       1.1  christos #if __STDC__
     58       1.1  christos ddp_output(struct mbuf *m,...)
     59       1.1  christos #else
     60       1.1  christos ddp_output(va_alist)
     61       1.1  christos 	va_dcl
     62       1.1  christos #endif
     63       1.1  christos {
     64       1.1  christos 	struct ddpcb   *ddp;
     65       1.1  christos 	struct ddpehdr *deh;
     66       1.1  christos 	va_list         ap;
     67       1.1  christos 
     68       1.1  christos #if __STDC__
     69       1.1  christos 	va_start(ap, m);
     70       1.1  christos #else
     71       1.1  christos 	struct mbuf    *m;
     72       1.1  christos 
     73       1.1  christos 	va_start(ap);
     74       1.1  christos 	m = va_arg(ap, struct mbuf *);
     75       1.1  christos #endif
     76       1.1  christos 	ddp = va_arg(ap, struct ddpcb *);
     77       1.1  christos 	va_end(ap);
     78       1.1  christos 
     79       1.1  christos 	M_PREPEND(m, sizeof(struct ddpehdr), M_WAIT);
     80       1.1  christos 
     81       1.1  christos 	deh = mtod(m, struct ddpehdr *);
     82       1.1  christos 	deh->deh_pad = 0;
     83       1.1  christos 	deh->deh_hops = 0;
     84       1.1  christos 
     85       1.1  christos 	deh->deh_len = m->m_pkthdr.len;
     86       1.1  christos 
     87       1.1  christos 	deh->deh_dnet = ddp->ddp_fsat.sat_addr.s_net;
     88       1.1  christos 	deh->deh_dnode = ddp->ddp_fsat.sat_addr.s_node;
     89       1.1  christos 	deh->deh_dport = ddp->ddp_fsat.sat_port;
     90       1.1  christos 	deh->deh_snet = ddp->ddp_lsat.sat_addr.s_net;
     91       1.1  christos 	deh->deh_snode = ddp->ddp_lsat.sat_addr.s_node;
     92       1.1  christos 	deh->deh_sport = ddp->ddp_lsat.sat_port;
     93       1.1  christos 
     94       1.1  christos 	/*
     95       1.1  christos          * The checksum calculation is done after all of the other bytes have
     96       1.1  christos          * been filled in.
     97       1.1  christos          */
     98       1.1  christos 	if (ddp_cksum) {
     99       1.1  christos 		deh->deh_sum = at_cksum(m, sizeof(int));
    100       1.1  christos 	} else {
    101       1.1  christos 		deh->deh_sum = 0;
    102       1.1  christos 	}
    103       1.1  christos 	deh->deh_bytes = htonl(deh->deh_bytes);
    104       1.1  christos 
    105       1.1  christos 	return (ddp_route(m, &ddp->ddp_route));
    106       1.1  christos }
    107       1.1  christos 
    108       1.1  christos u_short
    109       1.1  christos at_cksum(m, skip)
    110       1.1  christos 	struct mbuf *m;
    111       1.1  christos 	int skip;
    112       1.1  christos {
    113       1.1  christos 	u_char         *data, *end;
    114       1.1  christos 	u_long          cksum = 0;
    115       1.1  christos 
    116       1.1  christos 	for (; m; m = m->m_next) {
    117       1.1  christos 		for (data = mtod(m, u_char *), end = data + m->m_len;
    118       1.1  christos 		    data < end; data++) {
    119       1.1  christos 			if (skip) {
    120       1.1  christos 				skip--;
    121       1.1  christos 				continue;
    122       1.1  christos 			}
    123       1.1  christos 			cksum = (cksum + *data) << 1;
    124       1.1  christos 			if (cksum & 0x00010000) {
    125       1.1  christos 				cksum++;
    126       1.1  christos 			}
    127       1.1  christos 			cksum &= 0x0000ffff;
    128       1.1  christos 		}
    129       1.1  christos 	}
    130       1.1  christos 
    131       1.1  christos 	if (cksum == 0) {
    132       1.1  christos 		cksum = 0x0000ffff;
    133       1.1  christos 	}
    134       1.1  christos 	return ((u_short) cksum);
    135       1.1  christos }
    136       1.1  christos 
    137       1.1  christos int
    138       1.1  christos ddp_route(m, ro)
    139       1.1  christos 	struct mbuf *m;
    140       1.1  christos 	struct route *ro;
    141       1.1  christos {
    142       1.1  christos 	struct sockaddr_at gate;
    143       1.1  christos 	struct elaphdr *elh;
    144       1.1  christos 	struct mbuf    *m0;
    145       1.1  christos 	struct at_ifaddr *aa = NULL;
    146       1.1  christos 	struct ifnet   *ifp = NULL;
    147       1.1  christos 	u_short         net;
    148       1.1  christos 
    149       1.1  christos 	if (ro->ro_rt && (ifp = ro->ro_rt->rt_ifp)) {
    150       1.1  christos 		net = satosat(ro->ro_rt->rt_gateway)->sat_addr.s_net;
    151       1.1  christos 		for (aa = at_ifaddr.tqh_first; aa; aa = aa->aa_list.tqe_next) {
    152       1.1  christos 			if (aa->aa_ifp == ifp &&
    153       1.1  christos 			    ntohs(net) >= ntohs(aa->aa_firstnet) &&
    154       1.1  christos 			    ntohs(net) <= ntohs(aa->aa_lastnet)) {
    155       1.1  christos 				break;
    156       1.1  christos 			}
    157       1.1  christos 		}
    158       1.1  christos 	}
    159       1.1  christos 	if (aa == NULL) {
    160       1.1  christos 		printf("ddp_route: oops\n");
    161       1.1  christos 		m_freem(m);
    162       1.1  christos 		return (EINVAL);
    163       1.1  christos 	}
    164       1.1  christos 	/*
    165       1.1  christos          * There are several places in the kernel where data is added to
    166       1.1  christos          * an mbuf without ensuring that the mbuf pointer is aligned.
    167       1.1  christos          * This is bad for transition routing, since phase 1 and phase 2
    168       1.1  christos          * packets end up poorly aligned due to the three byte elap header.
    169       1.1  christos          */
    170       1.1  christos 	if (!(aa->aa_flags & AFA_PHASE2)) {
    171       1.1  christos 		MGET(m0, M_WAIT, MT_HEADER);
    172       1.1  christos 		if (m0 == 0) {
    173       1.1  christos 			m_freem(m);
    174       1.1  christos 			printf("ddp_route: no buffers\n");
    175       1.1  christos 			return (ENOBUFS);
    176       1.1  christos 		}
    177       1.1  christos 		m0->m_next = m;
    178       1.1  christos 		/* XXX perhaps we ought to align the header? */
    179       1.1  christos 		m0->m_len = SZ_ELAPHDR;
    180       1.1  christos 		m = m0;
    181       1.1  christos 
    182       1.1  christos 		elh = mtod(m, struct elaphdr *);
    183       1.1  christos 		elh->el_snode = satosat(&aa->aa_addr)->sat_addr.s_node;
    184       1.1  christos 		elh->el_type = ELAP_DDPEXTEND;
    185       1.1  christos 		if (ntohs(satosat(&ro->ro_dst)->sat_addr.s_net) >=
    186       1.1  christos 		    ntohs(aa->aa_firstnet) &&
    187       1.1  christos 		    ntohs(satosat(&ro->ro_dst)->sat_addr.s_net) <=
    188       1.1  christos 		    ntohs(aa->aa_lastnet)) {
    189       1.1  christos 			elh->el_dnode = satosat(&ro->ro_dst)->sat_addr.s_node;
    190       1.1  christos 		} else {
    191       1.1  christos 			elh->el_dnode =
    192       1.1  christos 			    satosat(ro->ro_rt->rt_gateway)->sat_addr.s_node;
    193       1.1  christos 		}
    194       1.1  christos 	}
    195       1.1  christos 	if (ntohs(satosat(&ro->ro_dst)->sat_addr.s_net) >=
    196       1.1  christos 	    ntohs(aa->aa_firstnet) &&
    197       1.1  christos 	    ntohs(satosat(&ro->ro_dst)->sat_addr.s_net) <=
    198       1.1  christos 	    ntohs(aa->aa_lastnet)) {
    199       1.1  christos 		gate = *satosat(&ro->ro_dst);
    200       1.1  christos 	} else {
    201       1.1  christos 		gate = *satosat(ro->ro_rt->rt_gateway);
    202       1.1  christos 	}
    203       1.1  christos 	ro->ro_rt->rt_use++;
    204       1.2     aidan 
    205       1.2     aidan #if IFA_STATS
    206       1.2     aidan 	aa->aa_ifa.ifa_data.ifad_outbytes += m->m_pkthdr.len;
    207       1.2     aidan #endif
    208       1.1  christos 
    209       1.1  christos 	/* XXX */
    210       1.1  christos 	return ((*ifp->if_output) (ifp, m, (struct sockaddr *) &gate, NULL));
    211       1.1  christos }
    212