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