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