Home | History | Annotate | Line # | Download | only in net
if_sl.c revision 1.12.2.1
      1       1.1      cgd /*
      2       1.1      cgd  * Copyright (c) 1987, 1989 Regents of the University of California.
      3       1.1      cgd  * All rights reserved.
      4       1.1      cgd  *
      5       1.1      cgd  * Redistribution and use in source and binary forms, with or without
      6       1.1      cgd  * modification, are permitted provided that the following conditions
      7       1.1      cgd  * are met:
      8       1.1      cgd  * 1. Redistributions of source code must retain the above copyright
      9       1.1      cgd  *    notice, this list of conditions and the following disclaimer.
     10       1.1      cgd  * 2. Redistributions in binary form must reproduce the above copyright
     11       1.1      cgd  *    notice, this list of conditions and the following disclaimer in the
     12       1.1      cgd  *    documentation and/or other materials provided with the distribution.
     13       1.1      cgd  * 3. All advertising materials mentioning features or use of this software
     14       1.1      cgd  *    must display the following acknowledgement:
     15       1.1      cgd  *	This product includes software developed by the University of
     16       1.1      cgd  *	California, Berkeley and its contributors.
     17       1.1      cgd  * 4. Neither the name of the University nor the names of its contributors
     18       1.1      cgd  *    may be used to endorse or promote products derived from this software
     19       1.1      cgd  *    without specific prior written permission.
     20       1.1      cgd  *
     21       1.1      cgd  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
     22       1.1      cgd  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
     23       1.1      cgd  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
     24       1.1      cgd  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
     25       1.1      cgd  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
     26       1.1      cgd  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
     27       1.1      cgd  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
     28       1.1      cgd  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     29       1.1      cgd  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     30       1.1      cgd  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     31       1.1      cgd  * SUCH DAMAGE.
     32       1.1      cgd  *
     33      1.11  mycroft  *	from: if_sl.c,v 1.11 84/10/04 12:54:47 rick Exp
     34       1.7      cgd  *	from: @(#)if_sl.c	7.22 (Berkeley) 4/20/91
     35       1.9   andrew  *	if_sl.c,v 1.8 1993/05/22 11:42:11 cgd Exp
     36       1.1      cgd  */
     37       1.1      cgd 
     38       1.1      cgd /*
     39       1.1      cgd  * Serial Line interface
     40       1.1      cgd  *
     41       1.1      cgd  * Rick Adams
     42       1.1      cgd  * Center for Seismic Studies
     43       1.1      cgd  * 1300 N 17th Street, Suite 1450
     44       1.1      cgd  * Arlington, Virginia 22209
     45       1.1      cgd  * (703)276-7900
     46       1.1      cgd  * rick (at) seismo.ARPA
     47       1.1      cgd  * seismo!rick
     48       1.1      cgd  *
     49       1.1      cgd  * Pounded on heavily by Chris Torek (chris (at) mimsy.umd.edu, umcp-cs!chris).
     50       1.1      cgd  * N.B.: this belongs in netinet, not net, the way it stands now.
     51       1.1      cgd  * Should have a link-layer type designation, but wouldn't be
     52       1.1      cgd  * backwards-compatible.
     53       1.1      cgd  *
     54       1.1      cgd  * Converted to 4.3BSD Beta by Chris Torek.
     55       1.1      cgd  * Other changes made at Berkeley, based in part on code by Kirk Smith.
     56       1.1      cgd  * W. Jolitz added slip abort.
     57       1.1      cgd  *
     58       1.1      cgd  * Hacked almost beyond recognition by Van Jacobson (van (at) helios.ee.lbl.gov).
     59       1.1      cgd  * Added priority queuing for "interactive" traffic; hooks for TCP
     60       1.1      cgd  * header compression; ICMP filtering (at 2400 baud, some cretin
     61       1.1      cgd  * pinging you can use up all your bandwidth).  Made low clist behavior
     62       1.1      cgd  * more robust and slightly less likely to hang serial line.
     63       1.1      cgd  * Sped up a bunch of things.
     64       1.1      cgd  *
     65       1.1      cgd  * Note that splimp() is used throughout to block both (tty) input
     66       1.1      cgd  * interrupts and network activity; thus, splimp must be >= spltty.
     67       1.1      cgd  */
     68       1.1      cgd 
     69       1.1      cgd #include "sl.h"
     70       1.1      cgd #if NSL > 0
     71       1.1      cgd 
     72       1.1      cgd #include "param.h"
     73       1.1      cgd #include "proc.h"
     74       1.1      cgd #include "mbuf.h"
     75       1.1      cgd #include "buf.h"
     76       1.1      cgd #include "dkstat.h"
     77       1.1      cgd #include "socket.h"
     78       1.1      cgd #include "ioctl.h"
     79       1.1      cgd #include "file.h"
     80       1.1      cgd #include "tty.h"
     81       1.1      cgd #include "kernel.h"
     82       1.1      cgd #include "conf.h"
     83       1.1      cgd 
     84       1.1      cgd #include "if.h"
     85       1.1      cgd #include "if_types.h"
     86       1.1      cgd #include "netisr.h"
     87       1.1      cgd #include "route.h"
     88       1.1      cgd #if INET
     89       1.1      cgd #include "netinet/in.h"
     90       1.1      cgd #include "netinet/in_systm.h"
     91       1.1      cgd #include "netinet/in_var.h"
     92       1.1      cgd #include "netinet/ip.h"
     93       1.1      cgd #else
     94       1.1      cgd Huh? Slip without inet?
     95       1.1      cgd #endif
     96       1.1      cgd 
     97       1.1      cgd #include "machine/mtpr.h"
     98       1.1      cgd 
     99       1.1      cgd #include "slcompress.h"
    100       1.1      cgd #include "if_slvar.h"
    101       1.3      cgd #include "slip.h"
    102       1.3      cgd 
    103       1.3      cgd #include "bpfilter.h"
    104       1.3      cgd #if NBPFILTER > 0
    105       1.3      cgd #include <sys/time.h>
    106       1.3      cgd #include <net/bpf.h>
    107       1.3      cgd #endif
    108       1.1      cgd 
    109       1.1      cgd /*
    110       1.1      cgd  * SLMAX is a hard limit on input packet size.  To simplify the code
    111       1.1      cgd  * and improve performance, we require that packets fit in an mbuf
    112       1.1      cgd  * cluster, and if we get a compressed packet, there's enough extra
    113       1.1      cgd  * room to expand the header into a max length tcp/ip header (128
    114       1.1      cgd  * bytes).  So, SLMAX can be at most
    115       1.1      cgd  *	MCLBYTES - 128
    116       1.1      cgd  *
    117       1.1      cgd  * SLMTU is a hard limit on output packet size.  To insure good
    118       1.1      cgd  * interactive response, SLMTU wants to be the smallest size that
    119       1.1      cgd  * amortizes the header cost.  (Remember that even with
    120       1.1      cgd  * type-of-service queuing, we have to wait for any in-progress
    121       1.1      cgd  * packet to finish.  I.e., we wait, on the average, 1/2 * mtu /
    122       1.1      cgd  * cps, where cps is the line speed in characters per second.
    123       1.1      cgd  * E.g., 533ms wait for a 1024 byte MTU on a 9600 baud line.  The
    124       1.1      cgd  * average compressed header size is 6-8 bytes so any MTU > 90
    125       1.1      cgd  * bytes will give us 90% of the line bandwidth.  A 100ms wait is
    126       1.1      cgd  * tolerable (500ms is not), so want an MTU around 296.  (Since TCP
    127       1.1      cgd  * will send 256 byte segments (to allow for 40 byte headers), the
    128       1.1      cgd  * typical packet size on the wire will be around 260 bytes).  In
    129       1.1      cgd  * 4.3tahoe+ systems, we can set an MTU in a route so we do that &
    130       1.1      cgd  * leave the interface MTU relatively high (so we don't IP fragment
    131       1.1      cgd  * when acting as a gateway to someone using a stupid MTU).
    132       1.1      cgd  *
    133       1.1      cgd  * Similar considerations apply to SLIP_HIWAT:  It's the amount of
    134       1.1      cgd  * data that will be queued 'downstream' of us (i.e., in clists
    135       1.1      cgd  * waiting to be picked up by the tty output interrupt).  If we
    136       1.1      cgd  * queue a lot of data downstream, it's immune to our t.o.s. queuing.
    137       1.1      cgd  * E.g., if SLIP_HIWAT is 1024, the interactive traffic in mixed
    138       1.1      cgd  * telnet/ftp will see a 1 sec wait, independent of the mtu (the
    139       1.1      cgd  * wait is dependent on the ftp window size but that's typically
    140       1.1      cgd  * 1k - 4k).  So, we want SLIP_HIWAT just big enough to amortize
    141       1.1      cgd  * the cost (in idle time on the wire) of the tty driver running
    142       1.1      cgd  * off the end of its clists & having to call back slstart for a
    143       1.1      cgd  * new packet.  For a tty interface with any buffering at all, this
    144       1.1      cgd  * cost will be zero.  Even with a totally brain dead interface (like
    145       1.1      cgd  * the one on a typical workstation), the cost will be <= 1 character
    146       1.1      cgd  * time.  So, setting SLIP_HIWAT to ~100 guarantees that we'll lose
    147       1.1      cgd  * at most 1% while maintaining good interactive response.
    148       1.1      cgd  */
    149       1.3      cgd #if NBPFILTER > 0
    150       1.3      cgd #define BUFOFFSET (128+sizeof(struct ifnet **)+SLIP_HDRLEN)
    151       1.3      cgd #else
    152       1.3      cgd #define BUFOFFSET (128+sizeof(struct ifnet **))
    153       1.3      cgd #endif
    154       1.1      cgd #define	SLMAX		(MCLBYTES - BUFOFFSET)
    155       1.1      cgd #define	SLBUFSIZE	(SLMAX + BUFOFFSET)
    156       1.5      cgd #define	SLMTU		296	/* try 1006 later */
    157       1.1      cgd #define	SLIP_HIWAT	roundup(50,CBSIZE)
    158       1.1      cgd 
    159       1.1      cgd /*
    160       1.1      cgd  * SLIP ABORT ESCAPE MECHANISM:
    161       1.1      cgd  *	(inspired by HAYES modem escape arrangement)
    162       1.1      cgd  *	1sec escape 1sec escape 1sec escape { 1sec escape 1sec escape }
    163       1.1      cgd  *	signals a "soft" exit from slip mode by usermode process
    164       1.1      cgd  */
    165       1.1      cgd 
    166       1.3      cgd #ifdef ABT_ESC
    167       1.3      cgd #undef ABT_ESC
    168       1.1      cgd #define	ABT_ESC		'\033'	/* can't be t_intr - distant host must know it*/
    169       1.1      cgd #define ABT_WAIT	1	/* in seconds - idle before an escape & after */
    170       1.1      cgd #define ABT_RECYCLE	(5*2+2)	/* in seconds - time window processing abort */
    171       1.1      cgd #define ABT_SOFT	3	/* count of escapes */
    172       1.3      cgd #endif	/* ABT_ESC */
    173       1.1      cgd 
    174       1.1      cgd /*
    175       1.1      cgd  * The following disgusting hack gets around the problem that IP TOS
    176       1.1      cgd  * can't be set yet.  We want to put "interactive" traffic on a high
    177       1.1      cgd  * priority queue.  To decide if traffic is interactive, we check that
    178       1.1      cgd  * a) it is TCP and b) one of its ports is telnet, rlogin or ftp control.
    179       1.1      cgd  */
    180       1.1      cgd static u_short interactive_ports[8] = {
    181       1.1      cgd 	0,	513,	0,	0,
    182       1.1      cgd 	0,	21,	0,	23,
    183       1.1      cgd };
    184       1.1      cgd #define INTERACTIVE(p) (interactive_ports[(p) & 7] == (p))
    185       1.1      cgd 
    186       1.1      cgd struct sl_softc sl_softc[NSL];
    187       1.1      cgd 
    188       1.1      cgd #define FRAME_END	 	0xc0		/* Frame End */
    189       1.1      cgd #define FRAME_ESCAPE		0xdb		/* Frame Esc */
    190       1.1      cgd #define TRANS_FRAME_END	 	0xdc		/* transposed frame end */
    191       1.1      cgd #define TRANS_FRAME_ESCAPE 	0xdd		/* transposed frame esc */
    192       1.1      cgd 
    193       1.1      cgd #define t_sc T_LINEP
    194       1.1      cgd 
    195       1.1      cgd int sloutput(), slioctl(), ttrstrt();
    196       1.1      cgd extern struct timeval time;
    197       1.1      cgd 
    198       1.1      cgd /*
    199       1.1      cgd  * Called from boot code to establish sl interfaces.
    200       1.1      cgd  */
    201       1.1      cgd slattach()
    202       1.1      cgd {
    203       1.1      cgd 	register struct sl_softc *sc;
    204       1.1      cgd 	register int i = 0;
    205       1.1      cgd 
    206       1.1      cgd 	for (sc = sl_softc; i < NSL; sc++) {
    207       1.1      cgd 		sc->sc_if.if_name = "sl";
    208       1.1      cgd 		sc->sc_if.if_unit = i++;
    209       1.1      cgd 		sc->sc_if.if_mtu = SLMTU;
    210       1.1      cgd 		sc->sc_if.if_flags = IFF_POINTOPOINT;
    211       1.1      cgd 		sc->sc_if.if_type = IFT_SLIP;
    212       1.1      cgd 		sc->sc_if.if_ioctl = slioctl;
    213       1.1      cgd 		sc->sc_if.if_output = sloutput;
    214       1.1      cgd 		sc->sc_if.if_snd.ifq_maxlen = 50;
    215       1.1      cgd 		sc->sc_fastq.ifq_maxlen = 32;
    216       1.1      cgd 		if_attach(&sc->sc_if);
    217       1.3      cgd #if NBPFILTER > 0
    218       1.3      cgd 		bpfattach(&sc->sc_bpf, &sc->sc_if, DLT_SLIP,
    219       1.3      cgd 			SLIP_HDRLEN);
    220       1.3      cgd #endif
    221       1.1      cgd 	}
    222       1.1      cgd }
    223       1.1      cgd 
    224       1.1      cgd static int
    225       1.1      cgd slinit(sc)
    226       1.1      cgd 	register struct sl_softc *sc;
    227       1.1      cgd {
    228       1.1      cgd 	register caddr_t p;
    229       1.1      cgd 
    230       1.1      cgd 	if (sc->sc_ep == (u_char *) 0) {
    231       1.1      cgd 		MCLALLOC(p, M_WAIT);
    232       1.1      cgd 		if (p)
    233       1.1      cgd 			sc->sc_ep = (u_char *)p + SLBUFSIZE;
    234       1.1      cgd 		else {
    235       1.1      cgd 			printf("sl%d: can't allocate buffer\n", sc - sl_softc);
    236       1.1      cgd 			sc->sc_if.if_flags &= ~IFF_UP;
    237       1.1      cgd 			return (0);
    238       1.1      cgd 		}
    239       1.1      cgd 	}
    240       1.1      cgd 	sc->sc_buf = sc->sc_ep - SLMAX;
    241       1.1      cgd 	sc->sc_mp = sc->sc_buf;
    242       1.1      cgd 	sl_compress_init(&sc->sc_comp);
    243       1.1      cgd 	return (1);
    244       1.1      cgd }
    245       1.1      cgd 
    246       1.1      cgd /*
    247       1.1      cgd  * Line specific open routine.
    248       1.1      cgd  * Attach the given tty to the first available sl unit.
    249       1.1      cgd  */
    250       1.1      cgd /* ARGSUSED */
    251       1.9   andrew int
    252       1.9   andrew slopen(dev_t dev, struct tty *tp)
    253       1.1      cgd {
    254       1.1      cgd 	struct proc *p = curproc;		/* XXX */
    255       1.1      cgd 	register struct sl_softc *sc;
    256       1.1      cgd 	register int nsl;
    257       1.1      cgd 	int error;
    258       1.1      cgd 
    259       1.1      cgd 	if (error = suser(p->p_ucred, &p->p_acflag))
    260       1.1      cgd 		return (error);
    261       1.1      cgd 
    262       1.1      cgd 	if (tp->t_line == SLIPDISC)
    263       1.1      cgd 		return (0);
    264       1.1      cgd 
    265       1.1      cgd 	for (nsl = NSL, sc = sl_softc; --nsl >= 0; sc++)
    266       1.1      cgd 		if (sc->sc_ttyp == NULL) {
    267       1.1      cgd 			if (slinit(sc) == 0)
    268       1.1      cgd 				return (ENOBUFS);
    269       1.1      cgd 			tp->t_sc = (caddr_t)sc;
    270       1.1      cgd 			sc->sc_ttyp = tp;
    271       1.1      cgd 			sc->sc_if.if_baudrate = tp->t_ospeed;
    272       1.1      cgd 			ttyflush(tp, FREAD | FWRITE);
    273       1.1      cgd 			return (0);
    274       1.1      cgd 		}
    275       1.1      cgd 	return (ENXIO);
    276       1.1      cgd }
    277       1.1      cgd 
    278       1.1      cgd /*
    279       1.1      cgd  * Line specific close routine.
    280       1.1      cgd  * Detach the tty from the sl unit.
    281       1.1      cgd  * Mimics part of ttyclose().
    282       1.1      cgd  */
    283       1.9   andrew void
    284       1.9   andrew slclose(tp, flag)
    285       1.1      cgd 	struct tty *tp;
    286       1.9   andrew 	int flag;
    287       1.1      cgd {
    288       1.1      cgd 	register struct sl_softc *sc;
    289       1.1      cgd 	int s;
    290       1.1      cgd 
    291       1.1      cgd 	ttywflush(tp);
    292       1.1      cgd 	s = splimp();		/* actually, max(spltty, splnet) */
    293       1.1      cgd 	tp->t_line = 0;
    294       1.1      cgd 	sc = (struct sl_softc *)tp->t_sc;
    295       1.1      cgd 	if (sc != NULL) {
    296       1.1      cgd 		if_down(&sc->sc_if);
    297       1.1      cgd 		sc->sc_ttyp = NULL;
    298       1.1      cgd 		tp->t_sc = NULL;
    299       1.1      cgd 		MCLFREE((caddr_t)(sc->sc_ep - SLBUFSIZE));
    300       1.1      cgd 		sc->sc_ep = 0;
    301       1.1      cgd 		sc->sc_mp = 0;
    302       1.1      cgd 		sc->sc_buf = 0;
    303       1.1      cgd 	}
    304       1.1      cgd 	splx(s);
    305       1.1      cgd }
    306       1.1      cgd 
    307       1.1      cgd /*
    308       1.1      cgd  * Line specific (tty) ioctl routine.
    309       1.1      cgd  * Provide a way to get the sl unit number.
    310       1.1      cgd  */
    311       1.1      cgd /* ARGSUSED */
    312       1.1      cgd sltioctl(tp, cmd, data, flag)
    313       1.1      cgd 	struct tty *tp;
    314       1.1      cgd 	caddr_t data;
    315       1.1      cgd {
    316       1.1      cgd 	struct sl_softc *sc = (struct sl_softc *)tp->t_sc;
    317      1.12  deraadt 	struct proc *p = curproc;		/* XXX */
    318      1.12  deraadt 	int error;
    319       1.1      cgd 	int s;
    320       1.1      cgd 
    321       1.1      cgd 	switch (cmd) {
    322       1.1      cgd 	case SLIOCGUNIT:
    323       1.1      cgd 		*(int *)data = sc->sc_if.if_unit;
    324       1.1      cgd 		break;
    325       1.1      cgd 
    326       1.1      cgd 	case SLIOCGFLAGS:
    327       1.1      cgd 		*(int *)data = sc->sc_flags;
    328       1.1      cgd 		break;
    329       1.1      cgd 
    330       1.1      cgd 	case SLIOCSFLAGS:
    331      1.12  deraadt 		if (error = suser(p->p_ucred, &p->p_acflag))
    332      1.12  deraadt 			return (error);
    333       1.1      cgd #define	SC_MASK	0xffff
    334       1.1      cgd 		s = splimp();
    335       1.1      cgd 		sc->sc_flags =
    336       1.1      cgd 		    (sc->sc_flags &~ SC_MASK) | ((*(int *)data) & SC_MASK);
    337       1.1      cgd 		splx(s);
    338       1.1      cgd 		break;
    339       1.1      cgd 
    340       1.1      cgd 	default:
    341       1.1      cgd 		return (-1);
    342       1.1      cgd 	}
    343       1.1      cgd 	return (0);
    344       1.1      cgd }
    345       1.1      cgd 
    346       1.1      cgd /*
    347       1.1      cgd  * Queue a packet.  Start transmission if not active.
    348       1.1      cgd  */
    349       1.1      cgd sloutput(ifp, m, dst)
    350       1.1      cgd 	struct ifnet *ifp;
    351       1.1      cgd 	register struct mbuf *m;
    352       1.1      cgd 	struct sockaddr *dst;
    353       1.1      cgd {
    354       1.1      cgd 	register struct sl_softc *sc = &sl_softc[ifp->if_unit];
    355       1.1      cgd 	register struct ip *ip;
    356       1.1      cgd 	register struct ifqueue *ifq;
    357       1.1      cgd 	int s;
    358       1.1      cgd 
    359       1.1      cgd 	/*
    360       1.1      cgd 	 * `Cannot happen' (see slioctl).  Someday we will extend
    361       1.1      cgd 	 * the line protocol to support other address families.
    362       1.1      cgd 	 */
    363       1.1      cgd 	if (dst->sa_family != AF_INET) {
    364       1.1      cgd 		printf("sl%d: af%d not supported\n", sc->sc_if.if_unit,
    365       1.1      cgd 			dst->sa_family);
    366       1.1      cgd 		m_freem(m);
    367       1.1      cgd 		return (EAFNOSUPPORT);
    368       1.1      cgd 	}
    369       1.1      cgd 
    370       1.1      cgd 	if (sc->sc_ttyp == NULL) {
    371       1.1      cgd 		m_freem(m);
    372       1.1      cgd 		return (ENETDOWN);	/* sort of */
    373       1.1      cgd 	}
    374       1.1      cgd 	if ((sc->sc_ttyp->t_state & TS_CARR_ON) == 0) {
    375       1.1      cgd 		m_freem(m);
    376       1.1      cgd 		return (EHOSTUNREACH);
    377       1.1      cgd 	}
    378       1.1      cgd 	ifq = &sc->sc_if.if_snd;
    379       1.1      cgd 	if ((ip = mtod(m, struct ip *))->ip_p == IPPROTO_TCP) {
    380       1.3      cgd 		u_short srcport = ntohs(((short *)ip)[ip->ip_hl << 1]);
    381       1.3      cgd 		u_short dstport = ntohs(((short *)ip)[(ip->ip_hl << 1) + 1]);
    382       1.1      cgd 
    383       1.3      cgd 		if (INTERACTIVE(srcport) || INTERACTIVE(dstport)) {
    384       1.1      cgd 			ifq = &sc->sc_fastq;
    385       1.3      cgd 		}
    386       1.1      cgd 
    387       1.1      cgd 	} else if (sc->sc_flags & SC_NOICMP && ip->ip_p == IPPROTO_ICMP) {
    388       1.1      cgd 		m_freem(m);
    389       1.1      cgd 		return (0);
    390       1.1      cgd 	}
    391       1.1      cgd 	s = splimp();
    392       1.1      cgd 	if (IF_QFULL(ifq)) {
    393       1.1      cgd 		IF_DROP(ifq);
    394       1.1      cgd 		m_freem(m);
    395       1.1      cgd 		splx(s);
    396       1.1      cgd 		sc->sc_if.if_oerrors++;
    397       1.1      cgd 		return (ENOBUFS);
    398       1.1      cgd 	}
    399       1.1      cgd 	IF_ENQUEUE(ifq, m);
    400       1.1      cgd 	sc->sc_if.if_lastchange = time;
    401      1.10  mycroft 	if (sc->sc_ttyp->t_outq.c_cc == 0)
    402       1.1      cgd 		slstart(sc->sc_ttyp);
    403       1.1      cgd 	splx(s);
    404       1.1      cgd 	return (0);
    405       1.1      cgd }
    406       1.1      cgd 
    407       1.1      cgd /*
    408       1.1      cgd  * Start output on interface.  Get another datagram
    409       1.1      cgd  * to send from the interface queue and map it to
    410       1.1      cgd  * the interface before starting output.
    411       1.1      cgd  */
    412       1.9   andrew void
    413       1.1      cgd slstart(tp)
    414       1.1      cgd 	register struct tty *tp;
    415       1.1      cgd {
    416       1.1      cgd 	register struct sl_softc *sc = (struct sl_softc *)tp->t_sc;
    417       1.1      cgd 	register struct mbuf *m;
    418       1.1      cgd 	register u_char *cp;
    419       1.3      cgd 	register struct ip *ip;
    420       1.1      cgd 	int s;
    421       1.1      cgd 	struct mbuf *m2;
    422       1.3      cgd #if NBPFILTER > 0
    423       1.3      cgd 	u_char bpfbuf[SLMTU + SLIP_HDRLEN];
    424       1.3      cgd 	register int len;
    425       1.3      cgd #endif
    426       1.1      cgd 
    427       1.1      cgd 	for (;;) {
    428       1.1      cgd 		/*
    429       1.1      cgd 		 * If there is more in the output queue, just send it now.
    430       1.1      cgd 		 * We are being called in lieu of ttstart and must do what
    431       1.1      cgd 		 * it would.
    432       1.1      cgd 		 */
    433      1.10  mycroft 		if (tp->t_outq.c_cc != 0) {
    434       1.1      cgd 			(*tp->t_oproc)(tp);
    435      1.10  mycroft 			if (tp->t_outq.c_cc > SLIP_HIWAT)
    436       1.1      cgd 				return;
    437       1.1      cgd 		}
    438       1.1      cgd 		/*
    439       1.1      cgd 		 * This happens briefly when the line shuts down.
    440       1.1      cgd 		 */
    441       1.1      cgd 		if (sc == NULL)
    442       1.1      cgd 			return;
    443       1.1      cgd 
    444       1.1      cgd 		/*
    445       1.3      cgd 		 * Do not remove the packet from the IP queue if it
    446       1.3      cgd 		 * doesn't look like the packet will fit into the
    447       1.3      cgd 		 * current COM output queue, with a packet full of
    448      1.10  mycroft 		 * escapes this could be as bad as SLMTU*2.  The size
    449      1.10  mycroft 		 * of the ring buffer must be at least SLMTU*2 to
    450      1.10  mycroft 		 * avoid deadlock.
    451       1.3      cgd 		 */
    452      1.10  mycroft 		if (tp->t_outq.c_cn - tp->t_outq.c_cc < 2 * SLMTU)
    453       1.3      cgd 			return;
    454       1.3      cgd 
    455       1.3      cgd 		/*
    456       1.1      cgd 		 * Get a packet and send it to the interface.
    457       1.1      cgd 		 */
    458       1.1      cgd 		s = splimp();
    459       1.1      cgd 		IF_DEQUEUE(&sc->sc_fastq, m);
    460       1.1      cgd 		if (m == NULL)
    461       1.1      cgd 			IF_DEQUEUE(&sc->sc_if.if_snd, m);
    462       1.1      cgd 		splx(s);
    463       1.1      cgd 		if (m == NULL)
    464       1.1      cgd 			return;
    465       1.1      cgd 		/*
    466       1.3      cgd 		 * We do the header compression here rather than in sl_output
    467       1.3      cgd 		 * because the packets will be out of order if we are using TOS
    468       1.3      cgd 		 * queueing, and the connection id compression will get messed
    469       1.3      cgd 		 * up when this happens.
    470       1.1      cgd 		 */
    471       1.3      cgd #if NBPFILTER > 0
    472       1.3      cgd 		if (sc->sc_bpf) {
    473       1.3      cgd 		/*
    474       1.3      cgd 		 * We need to save the TCP/IP header before it's compressed.
    475       1.3      cgd 		 * To avoid complicated code, we just copy the entire packet
    476       1.3      cgd 		 * into a stack buffer (since this is a serial line, packets
    477       1.3      cgd 		 * should be short and/or the copy should be negligible cost
    478       1.3      cgd 		 * compared to the packet transmission time).
    479       1.3      cgd 		*/
    480       1.3      cgd 			register struct mbuf *m1 = m;
    481       1.3      cgd 			register u_char *cp = bpfbuf + SLIP_HDRLEN;
    482       1.3      cgd 			len = 0;
    483       1.3      cgd 			do {
    484       1.3      cgd 				register int mlen = m1->m_len;
    485       1.3      cgd 
    486       1.3      cgd 				bcopy(mtod(m1, caddr_t), cp, mlen);
    487       1.3      cgd 				cp += mlen;
    488       1.3      cgd 				len += mlen;
    489       1.3      cgd 			} while (m1 = m1->m_next);
    490       1.3      cgd 		}
    491       1.3      cgd #endif
    492       1.3      cgd 	        if ((ip = mtod(m, struct ip *))->ip_p == IPPROTO_TCP) {
    493       1.3      cgd 			if (sc->sc_flags & SC_COMPRESS)
    494       1.3      cgd 				*mtod(m, u_char *) |= sl_compress_tcp(m, ip, &sc->sc_comp, 1);
    495       1.3      cgd 		}
    496       1.3      cgd #if NBPFILTER > 0
    497       1.3      cgd 		if (sc->sc_bpf) {
    498       1.3      cgd                 /*
    499       1.3      cgd                  * Put the SLIP pseudo-"link header" in place.  The compressed
    500       1.3      cgd                  * header is now at the beginning of the mbuf.
    501       1.3      cgd                  */
    502       1.3      cgd 			bpfbuf[SLX_DIR] = SLIPDIR_OUT;
    503       1.3      cgd 			bcopy(mtod(m, caddr_t), &bpfbuf[SLX_CHDR], CHDR_LEN);
    504       1.3      cgd 			bpf_tap(sc->sc_bpf, bpfbuf, len + SLIP_HDRLEN);
    505       1.1      cgd 		}
    506       1.3      cgd #endif
    507       1.3      cgd 
    508       1.3      cgd 		sc->sc_if.if_lastchange = time;
    509       1.1      cgd 
    510       1.1      cgd 		/*
    511       1.1      cgd 		 * The extra FRAME_END will start up a new packet, and thus
    512       1.1      cgd 		 * will flush any accumulated garbage.  We do this whenever
    513       1.1      cgd 		 * the line may have been idle for some time.
    514       1.1      cgd 		 */
    515      1.10  mycroft 		if (tp->t_outq.c_cc == 0) {
    516       1.1      cgd 			++sc->sc_bytessent;
    517      1.10  mycroft 			(void) putc(FRAME_END, &tp->t_outq);
    518       1.1      cgd 		}
    519       1.1      cgd 
    520       1.1      cgd 		while (m) {
    521       1.1      cgd 			register u_char *ep;
    522       1.1      cgd 
    523       1.1      cgd 			cp = mtod(m, u_char *); ep = cp + m->m_len;
    524       1.1      cgd 			while (cp < ep) {
    525       1.1      cgd 				/*
    526       1.1      cgd 				 * Find out how many bytes in the string we can
    527       1.1      cgd 				 * handle without doing something special.
    528       1.1      cgd 				 */
    529       1.1      cgd 				register u_char *bp = cp;
    530       1.1      cgd 
    531       1.1      cgd 				while (cp < ep) {
    532       1.1      cgd 					switch (*cp++) {
    533       1.1      cgd 					case FRAME_ESCAPE:
    534       1.1      cgd 					case FRAME_END:
    535       1.1      cgd 						--cp;
    536       1.1      cgd 						goto out;
    537       1.1      cgd 					}
    538       1.1      cgd 				}
    539       1.1      cgd 				out:
    540       1.1      cgd 				if (cp > bp) {
    541       1.1      cgd 					/*
    542      1.10  mycroft 					 * Put n characters at once
    543       1.1      cgd 					 * into the tty output queue.
    544       1.1      cgd 					 */
    545      1.10  mycroft 					if (b_to_q((u_char *)bp, cp - bp, &tp->t_outq))
    546      1.10  mycroft 						break;
    547      1.10  mycroft 					sc->sc_bytessent += cp - bp;
    548       1.1      cgd 				}
    549       1.1      cgd 				/*
    550       1.1      cgd 				 * If there are characters left in the mbuf,
    551       1.1      cgd 				 * the first one must be special..
    552       1.1      cgd 				 * Put it out in a different form.
    553       1.1      cgd 				 */
    554       1.1      cgd 				if (cp < ep) {
    555      1.10  mycroft 					if (putc(FRAME_ESCAPE, &tp->t_outq))
    556       1.1      cgd 						break;
    557       1.1      cgd 					if (putc(*cp++ == FRAME_ESCAPE ?
    558       1.1      cgd 					   TRANS_FRAME_ESCAPE : TRANS_FRAME_END,
    559      1.10  mycroft 					   &tp->t_outq)) {
    560      1.10  mycroft 						(void) unputc(&tp->t_outq);
    561       1.1      cgd 						break;
    562       1.1      cgd 					}
    563       1.1      cgd 					sc->sc_bytessent += 2;
    564       1.1      cgd 				}
    565       1.1      cgd 			}
    566       1.1      cgd 			MFREE(m, m2);
    567       1.1      cgd 			m = m2;
    568       1.1      cgd 		}
    569       1.1      cgd 
    570      1.10  mycroft 		if (putc(FRAME_END, &tp->t_outq)) {
    571       1.1      cgd 			/*
    572       1.1      cgd 			 * Not enough room.  Remove a char to make room
    573       1.1      cgd 			 * and end the packet normally.
    574       1.1      cgd 			 * If you get many collisions (more than one or two
    575       1.1      cgd 			 * a day) you probably do not have enough clists
    576       1.1      cgd 			 * and you should increase "nclist" in param.c.
    577       1.1      cgd 			 */
    578      1.10  mycroft 			(void) unputc(&tp->t_outq);
    579      1.10  mycroft 			(void) putc(FRAME_END, &tp->t_outq);
    580       1.1      cgd 			sc->sc_if.if_collisions++;
    581       1.1      cgd 		} else {
    582       1.1      cgd 			++sc->sc_bytessent;
    583       1.1      cgd 			sc->sc_if.if_opackets++;
    584       1.1      cgd 		}
    585       1.1      cgd 		sc->sc_if.if_obytes = sc->sc_bytessent;
    586       1.1      cgd 	}
    587       1.1      cgd }
    588       1.1      cgd 
    589       1.1      cgd /*
    590       1.1      cgd  * Copy data buffer to mbuf chain; add ifnet pointer.
    591       1.1      cgd  */
    592       1.1      cgd static struct mbuf *
    593       1.1      cgd sl_btom(sc, len)
    594       1.1      cgd 	register struct sl_softc *sc;
    595       1.1      cgd 	register int len;
    596       1.1      cgd {
    597       1.1      cgd 	register struct mbuf *m;
    598       1.1      cgd 
    599       1.1      cgd 	MGETHDR(m, M_DONTWAIT, MT_DATA);
    600       1.1      cgd 	if (m == NULL)
    601       1.1      cgd 		return (NULL);
    602       1.1      cgd 
    603       1.1      cgd 	/*
    604       1.1      cgd 	 * If we have more than MHLEN bytes, it's cheaper to
    605       1.1      cgd 	 * queue the cluster we just filled & allocate a new one
    606       1.1      cgd 	 * for the input buffer.  Otherwise, fill the mbuf we
    607       1.1      cgd 	 * allocated above.  Note that code in the input routine
    608       1.1      cgd 	 * guarantees that packet will fit in a cluster.
    609       1.1      cgd 	 */
    610       1.1      cgd 	if (len >= MHLEN) {
    611       1.1      cgd 		MCLGET(m, M_DONTWAIT);
    612       1.1      cgd 		if ((m->m_flags & M_EXT) == 0) {
    613       1.1      cgd 			/*
    614       1.1      cgd 			 * we couldn't get a cluster - if memory's this
    615       1.1      cgd 			 * low, it's time to start dropping packets.
    616       1.1      cgd 			 */
    617       1.1      cgd 			(void) m_free(m);
    618       1.1      cgd 			return (NULL);
    619       1.1      cgd 		}
    620       1.1      cgd 		sc->sc_ep = mtod(m, u_char *) + SLBUFSIZE;
    621       1.1      cgd 		m->m_data = (caddr_t)sc->sc_buf;
    622       1.1      cgd 		m->m_ext.ext_buf = (caddr_t)((int)sc->sc_buf &~ MCLOFSET);
    623       1.1      cgd 	} else
    624       1.1      cgd 		bcopy((caddr_t)sc->sc_buf, mtod(m, caddr_t), len);
    625       1.1      cgd 
    626       1.1      cgd 	m->m_len = len;
    627       1.1      cgd 	m->m_pkthdr.len = len;
    628       1.1      cgd 	m->m_pkthdr.rcvif = &sc->sc_if;
    629       1.1      cgd 	return (m);
    630       1.1      cgd }
    631       1.1      cgd 
    632       1.1      cgd /*
    633       1.1      cgd  * tty interface receiver interrupt.
    634       1.1      cgd  */
    635       1.9   andrew void
    636       1.1      cgd slinput(c, tp)
    637       1.1      cgd 	register int c;
    638       1.1      cgd 	register struct tty *tp;
    639       1.1      cgd {
    640       1.1      cgd 	register struct sl_softc *sc;
    641       1.1      cgd 	register struct mbuf *m;
    642       1.1      cgd 	register int len;
    643       1.1      cgd 	int s;
    644       1.3      cgd #if NBPFILTER > 0
    645       1.3      cgd 	u_char chdr[CHDR_LEN];
    646       1.3      cgd #endif
    647       1.1      cgd 	tk_nin++;
    648       1.1      cgd 	sc = (struct sl_softc *)tp->t_sc;
    649       1.1      cgd 	if (sc == NULL)
    650       1.1      cgd 		return;
    651  1.12.2.1  mycroft 	if (c & TTY_ERRORMASK || ((tp->t_state & TS_CARR_ON) == 0 &&
    652  1.12.2.1  mycroft 				  (tp->t_cflag & CLOCAL) == 0)) {
    653       1.2      cgd 		sc->sc_flags |= SC_ERROR;
    654       1.1      cgd 		return;
    655       1.2      cgd 	}
    656       1.1      cgd 
    657       1.1      cgd 	++sc->sc_bytesrcvd;
    658       1.1      cgd 	++sc->sc_if.if_ibytes;
    659       1.1      cgd 
    660       1.1      cgd #ifdef ABT_ESC
    661       1.1      cgd 	if (sc->sc_flags & SC_ABORT) {
    662       1.1      cgd 		/* if we see an abort after "idle" time, count it */
    663       1.1      cgd 		if (c == ABT_ESC && time.tv_sec >= sc->sc_lasttime + ABT_WAIT) {
    664       1.1      cgd 			sc->sc_abortcount++;
    665       1.1      cgd 			/* record when the first abort escape arrived */
    666       1.1      cgd 			if (sc->sc_abortcount == 1)
    667       1.1      cgd 				sc->sc_starttime = time.tv_sec;
    668       1.1      cgd 		}
    669       1.1      cgd 		/*
    670       1.1      cgd 		 * if we have an abort, see that we have not run out of time,
    671       1.1      cgd 		 * or that we have an "idle" time after the complete escape
    672       1.1      cgd 		 * sequence
    673       1.1      cgd 		 */
    674       1.1      cgd 		if (sc->sc_abortcount) {
    675       1.1      cgd 			if (time.tv_sec >= sc->sc_starttime + ABT_RECYCLE)
    676       1.1      cgd 				sc->sc_abortcount = 0;
    677       1.1      cgd 			if (sc->sc_abortcount >= ABT_SOFT &&
    678       1.1      cgd 			    time.tv_sec >= sc->sc_lasttime + ABT_WAIT) {
    679       1.1      cgd 				slclose(tp);
    680       1.1      cgd 				return;
    681       1.1      cgd 			}
    682       1.1      cgd 		}
    683       1.1      cgd 		sc->sc_lasttime = time.tv_sec;
    684       1.1      cgd 	}
    685       1.1      cgd #endif
    686       1.1      cgd 
    687       1.1      cgd 	switch (c) {
    688       1.1      cgd 
    689       1.1      cgd 	case TRANS_FRAME_ESCAPE:
    690       1.1      cgd 		if (sc->sc_escape)
    691       1.1      cgd 			c = FRAME_ESCAPE;
    692       1.1      cgd 		break;
    693       1.1      cgd 
    694       1.1      cgd 	case TRANS_FRAME_END:
    695       1.1      cgd 		if (sc->sc_escape)
    696       1.1      cgd 			c = FRAME_END;
    697       1.1      cgd 		break;
    698       1.1      cgd 
    699       1.1      cgd 	case FRAME_ESCAPE:
    700       1.1      cgd 		sc->sc_escape = 1;
    701       1.1      cgd 		return;
    702       1.1      cgd 
    703       1.1      cgd 	case FRAME_END:
    704       1.3      cgd 		if(sc->sc_flags & SC_ERROR) {
    705       1.2      cgd 			sc->sc_flags &= ~SC_ERROR;
    706       1.2      cgd 			goto newpack;
    707       1.2      cgd 		}
    708       1.1      cgd 		len = sc->sc_mp - sc->sc_buf;
    709       1.2      cgd 
    710       1.1      cgd 		if (len < 3)
    711       1.1      cgd 			/* less than min length packet - ignore */
    712       1.1      cgd 			goto newpack;
    713       1.1      cgd 
    714       1.3      cgd #if NBPFILTER > 0
    715       1.3      cgd 		if (sc->sc_bpf)
    716       1.3      cgd 			/*
    717       1.3      cgd 			 * Save the compressed header, so we can
    718       1.3      cgd 			 * tack it on later.  Note that we just
    719       1.3      cgd 			 * we will end up copying garbage in some
    720       1.3      cgd 			 * cases but this is okay.  We remember
    721       1.3      cgd 			 * where the buffer started so we can
    722       1.3      cgd 			 * compute the new header length.
    723       1.3      cgd 			 */
    724       1.3      cgd 			bcopy(sc->sc_buf, chdr, CHDR_LEN);
    725       1.3      cgd #endif
    726       1.1      cgd 		if ((c = (*sc->sc_buf & 0xf0)) != (IPVERSION << 4)) {
    727       1.1      cgd 			if (c & 0x80)
    728       1.1      cgd 				c = TYPE_COMPRESSED_TCP;
    729       1.1      cgd 			else if (c == TYPE_UNCOMPRESSED_TCP)
    730       1.1      cgd 				*sc->sc_buf &= 0x4f; /* XXX */
    731       1.1      cgd 			/*
    732       1.1      cgd 			 * We've got something that's not an IP packet.
    733       1.1      cgd 			 * If compression is enabled, try to decompress it.
    734       1.1      cgd 			 * Otherwise, if `auto-enable' compression is on and
    735       1.1      cgd 			 * it's a reasonable packet, decompress it and then
    736       1.1      cgd 			 * enable compression.  Otherwise, drop it.
    737       1.1      cgd 			 */
    738       1.1      cgd 			if (sc->sc_flags & SC_COMPRESS) {
    739       1.1      cgd 				len = sl_uncompress_tcp(&sc->sc_buf, len,
    740       1.1      cgd 							(u_int)c, &sc->sc_comp);
    741       1.1      cgd 				if (len <= 0)
    742       1.1      cgd 					goto error;
    743       1.1      cgd 			} else if ((sc->sc_flags & SC_AUTOCOMP) &&
    744       1.1      cgd 			    c == TYPE_UNCOMPRESSED_TCP && len >= 40) {
    745       1.1      cgd 				len = sl_uncompress_tcp(&sc->sc_buf, len,
    746       1.1      cgd 							(u_int)c, &sc->sc_comp);
    747       1.1      cgd 				if (len <= 0)
    748       1.1      cgd 					goto error;
    749       1.1      cgd 				sc->sc_flags |= SC_COMPRESS;
    750       1.1      cgd 			} else
    751       1.1      cgd 				goto error;
    752       1.1      cgd 		}
    753       1.3      cgd #if NBPFILTER > 0
    754       1.3      cgd 		if (sc->sc_bpf) {
    755       1.3      cgd 			/*
    756       1.3      cgd 			 * Put the SLIP pseudo-"link header" in place.
    757       1.3      cgd 			 * We couldn't do this any earlier since
    758       1.3      cgd 			 * decompression probably moved the buffer
    759       1.3      cgd 			 * pointer.  Then, invoke BPF.
    760       1.3      cgd 			 */
    761       1.3      cgd 			register u_char *hp = sc->sc_buf - SLIP_HDRLEN;
    762       1.3      cgd 
    763       1.3      cgd 			hp[SLX_DIR] = SLIPDIR_IN;
    764       1.3      cgd 			bcopy(chdr, &hp[SLX_CHDR], CHDR_LEN);
    765       1.3      cgd 			bpf_tap(sc->sc_bpf, hp, len + SLIP_HDRLEN);
    766       1.3      cgd 		}
    767       1.3      cgd #endif
    768       1.1      cgd 		m = sl_btom(sc, len);
    769       1.1      cgd 		if (m == NULL)
    770       1.1      cgd 			goto error;
    771       1.1      cgd 
    772       1.1      cgd 		sc->sc_if.if_ipackets++;
    773       1.1      cgd 		sc->sc_if.if_lastchange = time;
    774       1.1      cgd 		s = splimp();
    775       1.1      cgd 		if (IF_QFULL(&ipintrq)) {
    776       1.1      cgd 			IF_DROP(&ipintrq);
    777       1.1      cgd 			sc->sc_if.if_ierrors++;
    778       1.1      cgd 			sc->sc_if.if_iqdrops++;
    779       1.1      cgd 			m_freem(m);
    780       1.1      cgd 		} else {
    781       1.1      cgd 			IF_ENQUEUE(&ipintrq, m);
    782       1.1      cgd 			schednetisr(NETISR_IP);
    783       1.1      cgd 		}
    784       1.1      cgd 		splx(s);
    785       1.1      cgd 		goto newpack;
    786       1.1      cgd 	}
    787       1.1      cgd 	if (sc->sc_mp < sc->sc_ep) {
    788       1.1      cgd 		*sc->sc_mp++ = c;
    789       1.1      cgd 		sc->sc_escape = 0;
    790       1.1      cgd 		return;
    791       1.1      cgd 	}
    792       1.3      cgd 	sc->sc_flags |= SC_ERROR;
    793       1.1      cgd error:
    794       1.1      cgd 	sc->sc_if.if_ierrors++;
    795       1.1      cgd newpack:
    796       1.1      cgd 	sc->sc_mp = sc->sc_buf = sc->sc_ep - SLMAX;
    797       1.1      cgd 	sc->sc_escape = 0;
    798       1.1      cgd }
    799       1.1      cgd 
    800       1.1      cgd /*
    801       1.1      cgd  * Process an ioctl request.
    802       1.1      cgd  */
    803       1.1      cgd slioctl(ifp, cmd, data)
    804       1.1      cgd 	register struct ifnet *ifp;
    805       1.1      cgd 	int cmd;
    806       1.1      cgd 	caddr_t data;
    807       1.1      cgd {
    808       1.1      cgd 	register struct ifaddr *ifa = (struct ifaddr *)data;
    809       1.1      cgd 	int s = splimp(), error = 0;
    810       1.1      cgd 
    811       1.1      cgd 	switch (cmd) {
    812       1.1      cgd 
    813       1.1      cgd 	case SIOCSIFADDR:
    814       1.1      cgd 		if (ifa->ifa_addr->sa_family == AF_INET)
    815       1.1      cgd 			ifp->if_flags |= IFF_UP;
    816       1.1      cgd 		else
    817       1.1      cgd 			error = EAFNOSUPPORT;
    818       1.1      cgd 		break;
    819       1.1      cgd 
    820       1.1      cgd 	case SIOCSIFDSTADDR:
    821       1.1      cgd 		if (ifa->ifa_addr->sa_family != AF_INET)
    822       1.1      cgd 			error = EAFNOSUPPORT;
    823       1.1      cgd 		break;
    824       1.1      cgd 
    825       1.1      cgd 	default:
    826       1.1      cgd 		error = EINVAL;
    827       1.1      cgd 	}
    828       1.1      cgd 	splx(s);
    829       1.1      cgd 	return (error);
    830       1.1      cgd }
    831       1.1      cgd #endif
    832