Home | History | Annotate | Line # | Download | only in netatalk
ddp_output.c revision 1.7.2.3
      1  1.7.2.3     skrll /*	$NetBSD: ddp_output.c,v 1.7.2.3 2004/09/21 13:36:56 skrll 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.3     lukem 
     29      1.3     lukem #include <sys/cdefs.h>
     30  1.7.2.3     skrll __KERNEL_RCSID(0, "$NetBSD: ddp_output.c,v 1.7.2.3 2004/09/21 13:36:56 skrll Exp $");
     31      1.1  christos 
     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 ddp_output(struct mbuf *m,...)
     58      1.1  christos {
     59      1.1  christos 	struct ddpcb   *ddp;
     60      1.1  christos 	struct ddpehdr *deh;
     61      1.1  christos 	va_list         ap;
     62      1.1  christos 
     63      1.1  christos 	va_start(ap, m);
     64      1.1  christos 	ddp = va_arg(ap, struct ddpcb *);
     65      1.1  christos 	va_end(ap);
     66      1.1  christos 
     67      1.7    itojun 	M_PREPEND(m, sizeof(struct ddpehdr), M_DONTWAIT);
     68      1.7    itojun 	if (!m)
     69      1.7    itojun 		return (ENOBUFS);
     70      1.1  christos 
     71      1.1  christos 	deh = mtod(m, struct ddpehdr *);
     72      1.1  christos 	deh->deh_pad = 0;
     73      1.1  christos 	deh->deh_hops = 0;
     74      1.1  christos 
     75      1.1  christos 	deh->deh_len = m->m_pkthdr.len;
     76      1.1  christos 
     77      1.1  christos 	deh->deh_dnet = ddp->ddp_fsat.sat_addr.s_net;
     78      1.1  christos 	deh->deh_dnode = ddp->ddp_fsat.sat_addr.s_node;
     79      1.1  christos 	deh->deh_dport = ddp->ddp_fsat.sat_port;
     80      1.1  christos 	deh->deh_snet = ddp->ddp_lsat.sat_addr.s_net;
     81      1.1  christos 	deh->deh_snode = ddp->ddp_lsat.sat_addr.s_node;
     82      1.1  christos 	deh->deh_sport = ddp->ddp_lsat.sat_port;
     83      1.1  christos 
     84      1.1  christos 	/*
     85      1.1  christos          * The checksum calculation is done after all of the other bytes have
     86      1.1  christos          * been filled in.
     87      1.1  christos          */
     88      1.1  christos 	if (ddp_cksum) {
     89      1.1  christos 		deh->deh_sum = at_cksum(m, sizeof(int));
     90      1.1  christos 	} else {
     91      1.1  christos 		deh->deh_sum = 0;
     92      1.1  christos 	}
     93      1.1  christos 	deh->deh_bytes = htonl(deh->deh_bytes);
     94      1.1  christos 
     95      1.1  christos 	return (ddp_route(m, &ddp->ddp_route));
     96      1.1  christos }
     97      1.1  christos 
     98      1.1  christos u_short
     99      1.1  christos at_cksum(m, skip)
    100      1.1  christos 	struct mbuf *m;
    101      1.1  christos 	int skip;
    102      1.1  christos {
    103      1.1  christos 	u_char         *data, *end;
    104      1.1  christos 	u_long          cksum = 0;
    105      1.1  christos 
    106      1.1  christos 	for (; m; m = m->m_next) {
    107      1.1  christos 		for (data = mtod(m, u_char *), end = data + m->m_len;
    108      1.1  christos 		    data < end; data++) {
    109      1.1  christos 			if (skip) {
    110      1.1  christos 				skip--;
    111      1.1  christos 				continue;
    112      1.1  christos 			}
    113      1.1  christos 			cksum = (cksum + *data) << 1;
    114      1.1  christos 			if (cksum & 0x00010000) {
    115      1.1  christos 				cksum++;
    116      1.1  christos 			}
    117      1.1  christos 			cksum &= 0x0000ffff;
    118      1.1  christos 		}
    119      1.1  christos 	}
    120      1.1  christos 
    121      1.1  christos 	if (cksum == 0) {
    122      1.1  christos 		cksum = 0x0000ffff;
    123      1.1  christos 	}
    124      1.1  christos 	return ((u_short) cksum);
    125      1.1  christos }
    126      1.1  christos 
    127      1.1  christos int
    128      1.1  christos ddp_route(m, ro)
    129      1.1  christos 	struct mbuf *m;
    130      1.1  christos 	struct route *ro;
    131      1.1  christos {
    132      1.1  christos 	struct sockaddr_at gate;
    133      1.1  christos 	struct elaphdr *elh;
    134      1.1  christos 	struct at_ifaddr *aa = NULL;
    135      1.1  christos 	struct ifnet   *ifp = NULL;
    136      1.1  christos 	u_short         net;
    137      1.1  christos 
    138      1.1  christos 	if (ro->ro_rt && (ifp = ro->ro_rt->rt_ifp)) {
    139      1.1  christos 		net = satosat(ro->ro_rt->rt_gateway)->sat_addr.s_net;
    140      1.1  christos 		for (aa = at_ifaddr.tqh_first; aa; aa = aa->aa_list.tqe_next) {
    141      1.1  christos 			if (aa->aa_ifp == ifp &&
    142      1.1  christos 			    ntohs(net) >= ntohs(aa->aa_firstnet) &&
    143      1.1  christos 			    ntohs(net) <= ntohs(aa->aa_lastnet)) {
    144      1.1  christos 				break;
    145      1.1  christos 			}
    146      1.1  christos 		}
    147      1.1  christos 	}
    148      1.1  christos 	if (aa == NULL) {
    149      1.1  christos 		printf("ddp_route: oops\n");
    150      1.1  christos 		m_freem(m);
    151      1.1  christos 		return (EINVAL);
    152      1.1  christos 	}
    153      1.1  christos 	/*
    154      1.1  christos          * There are several places in the kernel where data is added to
    155      1.1  christos          * an mbuf without ensuring that the mbuf pointer is aligned.
    156      1.1  christos          * This is bad for transition routing, since phase 1 and phase 2
    157      1.1  christos          * packets end up poorly aligned due to the three byte elap header.
    158      1.1  christos          */
    159      1.1  christos 	if (!(aa->aa_flags & AFA_PHASE2)) {
    160      1.7    itojun 		M_PREPEND(m, SZ_ELAPHDR, M_DONTWAIT);
    161      1.7    itojun 		if (!m)
    162      1.7    itojun 			return (ENOBUFS);
    163      1.1  christos 
    164      1.1  christos 		elh = mtod(m, struct elaphdr *);
    165      1.1  christos 		elh->el_snode = satosat(&aa->aa_addr)->sat_addr.s_node;
    166      1.1  christos 		elh->el_type = ELAP_DDPEXTEND;
    167      1.1  christos 		if (ntohs(satosat(&ro->ro_dst)->sat_addr.s_net) >=
    168      1.1  christos 		    ntohs(aa->aa_firstnet) &&
    169      1.1  christos 		    ntohs(satosat(&ro->ro_dst)->sat_addr.s_net) <=
    170      1.1  christos 		    ntohs(aa->aa_lastnet)) {
    171      1.1  christos 			elh->el_dnode = satosat(&ro->ro_dst)->sat_addr.s_node;
    172      1.1  christos 		} else {
    173      1.1  christos 			elh->el_dnode =
    174      1.1  christos 			    satosat(ro->ro_rt->rt_gateway)->sat_addr.s_node;
    175      1.1  christos 		}
    176      1.1  christos 	}
    177      1.1  christos 	if (ntohs(satosat(&ro->ro_dst)->sat_addr.s_net) >=
    178      1.1  christos 	    ntohs(aa->aa_firstnet) &&
    179      1.1  christos 	    ntohs(satosat(&ro->ro_dst)->sat_addr.s_net) <=
    180      1.1  christos 	    ntohs(aa->aa_lastnet)) {
    181      1.1  christos 		gate = *satosat(&ro->ro_dst);
    182      1.1  christos 	} else {
    183      1.1  christos 		gate = *satosat(ro->ro_rt->rt_gateway);
    184      1.1  christos 	}
    185      1.1  christos 	ro->ro_rt->rt_use++;
    186      1.2     aidan 
    187      1.2     aidan #if IFA_STATS
    188      1.2     aidan 	aa->aa_ifa.ifa_data.ifad_outbytes += m->m_pkthdr.len;
    189      1.2     aidan #endif
    190      1.1  christos 
    191      1.1  christos 	/* XXX */
    192      1.1  christos 	return ((*ifp->if_output) (ifp, m, (struct sockaddr *) &gate, NULL));
    193      1.1  christos }
    194