Home | History | Annotate | Line # | Download | only in net
if_sl.c revision 1.11
      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.1      cgd 	int s;
    318   1.1      cgd 
    319   1.1      cgd 	switch (cmd) {
    320   1.1      cgd 	case SLIOCGUNIT:
    321   1.1      cgd 		*(int *)data = sc->sc_if.if_unit;
    322   1.1      cgd 		break;
    323   1.1      cgd 
    324   1.1      cgd 	case SLIOCGFLAGS:
    325   1.1      cgd 		*(int *)data = sc->sc_flags;
    326   1.1      cgd 		break;
    327   1.1      cgd 
    328   1.1      cgd 	case SLIOCSFLAGS:
    329   1.1      cgd #define	SC_MASK	0xffff
    330   1.1      cgd 		s = splimp();
    331   1.1      cgd 		sc->sc_flags =
    332   1.1      cgd 		    (sc->sc_flags &~ SC_MASK) | ((*(int *)data) & SC_MASK);
    333   1.1      cgd 		splx(s);
    334   1.1      cgd 		break;
    335   1.1      cgd 
    336   1.1      cgd 	default:
    337   1.1      cgd 		return (-1);
    338   1.1      cgd 	}
    339   1.1      cgd 	return (0);
    340   1.1      cgd }
    341   1.1      cgd 
    342   1.1      cgd /*
    343   1.1      cgd  * Queue a packet.  Start transmission if not active.
    344   1.1      cgd  */
    345   1.1      cgd sloutput(ifp, m, dst)
    346   1.1      cgd 	struct ifnet *ifp;
    347   1.1      cgd 	register struct mbuf *m;
    348   1.1      cgd 	struct sockaddr *dst;
    349   1.1      cgd {
    350   1.1      cgd 	register struct sl_softc *sc = &sl_softc[ifp->if_unit];
    351   1.1      cgd 	register struct ip *ip;
    352   1.1      cgd 	register struct ifqueue *ifq;
    353   1.1      cgd 	int s;
    354   1.1      cgd 
    355   1.1      cgd 	/*
    356   1.1      cgd 	 * `Cannot happen' (see slioctl).  Someday we will extend
    357   1.1      cgd 	 * the line protocol to support other address families.
    358   1.1      cgd 	 */
    359   1.1      cgd 	if (dst->sa_family != AF_INET) {
    360   1.1      cgd 		printf("sl%d: af%d not supported\n", sc->sc_if.if_unit,
    361   1.1      cgd 			dst->sa_family);
    362   1.1      cgd 		m_freem(m);
    363   1.1      cgd 		return (EAFNOSUPPORT);
    364   1.1      cgd 	}
    365   1.1      cgd 
    366   1.1      cgd 	if (sc->sc_ttyp == NULL) {
    367   1.1      cgd 		m_freem(m);
    368   1.1      cgd 		return (ENETDOWN);	/* sort of */
    369   1.1      cgd 	}
    370   1.1      cgd 	if ((sc->sc_ttyp->t_state & TS_CARR_ON) == 0) {
    371   1.1      cgd 		m_freem(m);
    372   1.1      cgd 		return (EHOSTUNREACH);
    373   1.1      cgd 	}
    374   1.1      cgd 	ifq = &sc->sc_if.if_snd;
    375   1.1      cgd 	if ((ip = mtod(m, struct ip *))->ip_p == IPPROTO_TCP) {
    376   1.3      cgd 		u_short srcport = ntohs(((short *)ip)[ip->ip_hl << 1]);
    377   1.3      cgd 		u_short dstport = ntohs(((short *)ip)[(ip->ip_hl << 1) + 1]);
    378   1.1      cgd 
    379   1.3      cgd 		if (INTERACTIVE(srcport) || INTERACTIVE(dstport)) {
    380   1.1      cgd 			ifq = &sc->sc_fastq;
    381   1.3      cgd 		}
    382   1.1      cgd 
    383   1.1      cgd 	} else if (sc->sc_flags & SC_NOICMP && ip->ip_p == IPPROTO_ICMP) {
    384   1.1      cgd 		m_freem(m);
    385   1.1      cgd 		return (0);
    386   1.1      cgd 	}
    387   1.1      cgd 	s = splimp();
    388   1.1      cgd 	if (IF_QFULL(ifq)) {
    389   1.1      cgd 		IF_DROP(ifq);
    390   1.1      cgd 		m_freem(m);
    391   1.1      cgd 		splx(s);
    392   1.1      cgd 		sc->sc_if.if_oerrors++;
    393   1.1      cgd 		return (ENOBUFS);
    394   1.1      cgd 	}
    395   1.1      cgd 	IF_ENQUEUE(ifq, m);
    396   1.1      cgd 	sc->sc_if.if_lastchange = time;
    397  1.10  mycroft 	if (sc->sc_ttyp->t_outq.c_cc == 0)
    398   1.1      cgd 		slstart(sc->sc_ttyp);
    399   1.1      cgd 	splx(s);
    400   1.1      cgd 	return (0);
    401   1.1      cgd }
    402   1.1      cgd 
    403   1.1      cgd /*
    404   1.1      cgd  * Start output on interface.  Get another datagram
    405   1.1      cgd  * to send from the interface queue and map it to
    406   1.1      cgd  * the interface before starting output.
    407   1.1      cgd  */
    408   1.9   andrew void
    409   1.1      cgd slstart(tp)
    410   1.1      cgd 	register struct tty *tp;
    411   1.1      cgd {
    412   1.1      cgd 	register struct sl_softc *sc = (struct sl_softc *)tp->t_sc;
    413   1.1      cgd 	register struct mbuf *m;
    414   1.1      cgd 	register u_char *cp;
    415   1.3      cgd 	register struct ip *ip;
    416   1.1      cgd 	int s;
    417   1.1      cgd 	struct mbuf *m2;
    418   1.3      cgd #if NBPFILTER > 0
    419   1.3      cgd 	u_char bpfbuf[SLMTU + SLIP_HDRLEN];
    420   1.3      cgd 	register int len;
    421   1.3      cgd #endif
    422   1.1      cgd 
    423   1.1      cgd 	for (;;) {
    424   1.1      cgd 		/*
    425   1.1      cgd 		 * If there is more in the output queue, just send it now.
    426   1.1      cgd 		 * We are being called in lieu of ttstart and must do what
    427   1.1      cgd 		 * it would.
    428   1.1      cgd 		 */
    429  1.10  mycroft 		if (tp->t_outq.c_cc != 0) {
    430   1.1      cgd 			(*tp->t_oproc)(tp);
    431  1.10  mycroft 			if (tp->t_outq.c_cc > SLIP_HIWAT)
    432   1.1      cgd 				return;
    433   1.1      cgd 		}
    434   1.1      cgd 		/*
    435   1.1      cgd 		 * This happens briefly when the line shuts down.
    436   1.1      cgd 		 */
    437   1.1      cgd 		if (sc == NULL)
    438   1.1      cgd 			return;
    439   1.1      cgd 
    440   1.1      cgd 		/*
    441   1.3      cgd 		 * Do not remove the packet from the IP queue if it
    442   1.3      cgd 		 * doesn't look like the packet will fit into the
    443   1.3      cgd 		 * current COM output queue, with a packet full of
    444  1.10  mycroft 		 * escapes this could be as bad as SLMTU*2.  The size
    445  1.10  mycroft 		 * of the ring buffer must be at least SLMTU*2 to
    446  1.10  mycroft 		 * avoid deadlock.
    447   1.3      cgd 		 */
    448  1.10  mycroft 		if (tp->t_outq.c_cn - tp->t_outq.c_cc < 2 * SLMTU)
    449   1.3      cgd 			return;
    450   1.3      cgd 
    451   1.3      cgd 		/*
    452   1.1      cgd 		 * Get a packet and send it to the interface.
    453   1.1      cgd 		 */
    454   1.1      cgd 		s = splimp();
    455   1.1      cgd 		IF_DEQUEUE(&sc->sc_fastq, m);
    456   1.1      cgd 		if (m == NULL)
    457   1.1      cgd 			IF_DEQUEUE(&sc->sc_if.if_snd, m);
    458   1.1      cgd 		splx(s);
    459   1.1      cgd 		if (m == NULL)
    460   1.1      cgd 			return;
    461   1.1      cgd 		/*
    462   1.3      cgd 		 * We do the header compression here rather than in sl_output
    463   1.3      cgd 		 * because the packets will be out of order if we are using TOS
    464   1.3      cgd 		 * queueing, and the connection id compression will get messed
    465   1.3      cgd 		 * up when this happens.
    466   1.1      cgd 		 */
    467   1.3      cgd #if NBPFILTER > 0
    468   1.3      cgd 		if (sc->sc_bpf) {
    469   1.3      cgd 		/*
    470   1.3      cgd 		 * We need to save the TCP/IP header before it's compressed.
    471   1.3      cgd 		 * To avoid complicated code, we just copy the entire packet
    472   1.3      cgd 		 * into a stack buffer (since this is a serial line, packets
    473   1.3      cgd 		 * should be short and/or the copy should be negligible cost
    474   1.3      cgd 		 * compared to the packet transmission time).
    475   1.3      cgd 		*/
    476   1.3      cgd 			register struct mbuf *m1 = m;
    477   1.3      cgd 			register u_char *cp = bpfbuf + SLIP_HDRLEN;
    478   1.3      cgd 			len = 0;
    479   1.3      cgd 			do {
    480   1.3      cgd 				register int mlen = m1->m_len;
    481   1.3      cgd 
    482   1.3      cgd 				bcopy(mtod(m1, caddr_t), cp, mlen);
    483   1.3      cgd 				cp += mlen;
    484   1.3      cgd 				len += mlen;
    485   1.3      cgd 			} while (m1 = m1->m_next);
    486   1.3      cgd 		}
    487   1.3      cgd #endif
    488   1.3      cgd 	        if ((ip = mtod(m, struct ip *))->ip_p == IPPROTO_TCP) {
    489   1.3      cgd 			if (sc->sc_flags & SC_COMPRESS)
    490   1.3      cgd 				*mtod(m, u_char *) |= sl_compress_tcp(m, ip, &sc->sc_comp, 1);
    491   1.3      cgd 		}
    492   1.3      cgd #if NBPFILTER > 0
    493   1.3      cgd 		if (sc->sc_bpf) {
    494   1.3      cgd                 /*
    495   1.3      cgd                  * Put the SLIP pseudo-"link header" in place.  The compressed
    496   1.3      cgd                  * header is now at the beginning of the mbuf.
    497   1.3      cgd                  */
    498   1.3      cgd 			bpfbuf[SLX_DIR] = SLIPDIR_OUT;
    499   1.3      cgd 			bcopy(mtod(m, caddr_t), &bpfbuf[SLX_CHDR], CHDR_LEN);
    500   1.3      cgd 			bpf_tap(sc->sc_bpf, bpfbuf, len + SLIP_HDRLEN);
    501   1.1      cgd 		}
    502   1.3      cgd #endif
    503   1.3      cgd 
    504   1.3      cgd 		sc->sc_if.if_lastchange = time;
    505   1.1      cgd 
    506   1.1      cgd 		/*
    507   1.1      cgd 		 * The extra FRAME_END will start up a new packet, and thus
    508   1.1      cgd 		 * will flush any accumulated garbage.  We do this whenever
    509   1.1      cgd 		 * the line may have been idle for some time.
    510   1.1      cgd 		 */
    511  1.10  mycroft 		if (tp->t_outq.c_cc == 0) {
    512   1.1      cgd 			++sc->sc_bytessent;
    513  1.10  mycroft 			(void) putc(FRAME_END, &tp->t_outq);
    514   1.1      cgd 		}
    515   1.1      cgd 
    516   1.1      cgd 		while (m) {
    517   1.1      cgd 			register u_char *ep;
    518   1.1      cgd 
    519   1.1      cgd 			cp = mtod(m, u_char *); ep = cp + m->m_len;
    520   1.1      cgd 			while (cp < ep) {
    521   1.1      cgd 				/*
    522   1.1      cgd 				 * Find out how many bytes in the string we can
    523   1.1      cgd 				 * handle without doing something special.
    524   1.1      cgd 				 */
    525   1.1      cgd 				register u_char *bp = cp;
    526   1.1      cgd 
    527   1.1      cgd 				while (cp < ep) {
    528   1.1      cgd 					switch (*cp++) {
    529   1.1      cgd 					case FRAME_ESCAPE:
    530   1.1      cgd 					case FRAME_END:
    531   1.1      cgd 						--cp;
    532   1.1      cgd 						goto out;
    533   1.1      cgd 					}
    534   1.1      cgd 				}
    535   1.1      cgd 				out:
    536   1.1      cgd 				if (cp > bp) {
    537   1.1      cgd 					/*
    538  1.10  mycroft 					 * Put n characters at once
    539   1.1      cgd 					 * into the tty output queue.
    540   1.1      cgd 					 */
    541  1.10  mycroft 					if (b_to_q((u_char *)bp, cp - bp, &tp->t_outq))
    542  1.10  mycroft 						break;
    543  1.10  mycroft 					sc->sc_bytessent += cp - bp;
    544   1.1      cgd 				}
    545   1.1      cgd 				/*
    546   1.1      cgd 				 * If there are characters left in the mbuf,
    547   1.1      cgd 				 * the first one must be special..
    548   1.1      cgd 				 * Put it out in a different form.
    549   1.1      cgd 				 */
    550   1.1      cgd 				if (cp < ep) {
    551  1.10  mycroft 					if (putc(FRAME_ESCAPE, &tp->t_outq))
    552   1.1      cgd 						break;
    553   1.1      cgd 					if (putc(*cp++ == FRAME_ESCAPE ?
    554   1.1      cgd 					   TRANS_FRAME_ESCAPE : TRANS_FRAME_END,
    555  1.10  mycroft 					   &tp->t_outq)) {
    556  1.10  mycroft 						(void) unputc(&tp->t_outq);
    557   1.1      cgd 						break;
    558   1.1      cgd 					}
    559   1.1      cgd 					sc->sc_bytessent += 2;
    560   1.1      cgd 				}
    561   1.1      cgd 			}
    562   1.1      cgd 			MFREE(m, m2);
    563   1.1      cgd 			m = m2;
    564   1.1      cgd 		}
    565   1.1      cgd 
    566  1.10  mycroft 		if (putc(FRAME_END, &tp->t_outq)) {
    567   1.1      cgd 			/*
    568   1.1      cgd 			 * Not enough room.  Remove a char to make room
    569   1.1      cgd 			 * and end the packet normally.
    570   1.1      cgd 			 * If you get many collisions (more than one or two
    571   1.1      cgd 			 * a day) you probably do not have enough clists
    572   1.1      cgd 			 * and you should increase "nclist" in param.c.
    573   1.1      cgd 			 */
    574  1.10  mycroft 			(void) unputc(&tp->t_outq);
    575  1.10  mycroft 			(void) putc(FRAME_END, &tp->t_outq);
    576   1.1      cgd 			sc->sc_if.if_collisions++;
    577   1.1      cgd 		} else {
    578   1.1      cgd 			++sc->sc_bytessent;
    579   1.1      cgd 			sc->sc_if.if_opackets++;
    580   1.1      cgd 		}
    581   1.1      cgd 		sc->sc_if.if_obytes = sc->sc_bytessent;
    582   1.1      cgd 	}
    583   1.1      cgd }
    584   1.1      cgd 
    585   1.1      cgd /*
    586   1.1      cgd  * Copy data buffer to mbuf chain; add ifnet pointer.
    587   1.1      cgd  */
    588   1.1      cgd static struct mbuf *
    589   1.1      cgd sl_btom(sc, len)
    590   1.1      cgd 	register struct sl_softc *sc;
    591   1.1      cgd 	register int len;
    592   1.1      cgd {
    593   1.1      cgd 	register struct mbuf *m;
    594   1.1      cgd 
    595   1.1      cgd 	MGETHDR(m, M_DONTWAIT, MT_DATA);
    596   1.1      cgd 	if (m == NULL)
    597   1.1      cgd 		return (NULL);
    598   1.1      cgd 
    599   1.1      cgd 	/*
    600   1.1      cgd 	 * If we have more than MHLEN bytes, it's cheaper to
    601   1.1      cgd 	 * queue the cluster we just filled & allocate a new one
    602   1.1      cgd 	 * for the input buffer.  Otherwise, fill the mbuf we
    603   1.1      cgd 	 * allocated above.  Note that code in the input routine
    604   1.1      cgd 	 * guarantees that packet will fit in a cluster.
    605   1.1      cgd 	 */
    606   1.1      cgd 	if (len >= MHLEN) {
    607   1.1      cgd 		MCLGET(m, M_DONTWAIT);
    608   1.1      cgd 		if ((m->m_flags & M_EXT) == 0) {
    609   1.1      cgd 			/*
    610   1.1      cgd 			 * we couldn't get a cluster - if memory's this
    611   1.1      cgd 			 * low, it's time to start dropping packets.
    612   1.1      cgd 			 */
    613   1.1      cgd 			(void) m_free(m);
    614   1.1      cgd 			return (NULL);
    615   1.1      cgd 		}
    616   1.1      cgd 		sc->sc_ep = mtod(m, u_char *) + SLBUFSIZE;
    617   1.1      cgd 		m->m_data = (caddr_t)sc->sc_buf;
    618   1.1      cgd 		m->m_ext.ext_buf = (caddr_t)((int)sc->sc_buf &~ MCLOFSET);
    619   1.1      cgd 	} else
    620   1.1      cgd 		bcopy((caddr_t)sc->sc_buf, mtod(m, caddr_t), len);
    621   1.1      cgd 
    622   1.1      cgd 	m->m_len = len;
    623   1.1      cgd 	m->m_pkthdr.len = len;
    624   1.1      cgd 	m->m_pkthdr.rcvif = &sc->sc_if;
    625   1.1      cgd 	return (m);
    626   1.1      cgd }
    627   1.1      cgd 
    628   1.1      cgd /*
    629   1.1      cgd  * tty interface receiver interrupt.
    630   1.1      cgd  */
    631   1.9   andrew void
    632   1.1      cgd slinput(c, tp)
    633   1.1      cgd 	register int c;
    634   1.1      cgd 	register struct tty *tp;
    635   1.1      cgd {
    636   1.1      cgd 	register struct sl_softc *sc;
    637   1.1      cgd 	register struct mbuf *m;
    638   1.1      cgd 	register int len;
    639   1.1      cgd 	int s;
    640   1.3      cgd #if NBPFILTER > 0
    641   1.3      cgd 	u_char chdr[CHDR_LEN];
    642   1.3      cgd #endif
    643   1.1      cgd 	tk_nin++;
    644   1.1      cgd 	sc = (struct sl_softc *)tp->t_sc;
    645   1.1      cgd 	if (sc == NULL)
    646   1.1      cgd 		return;
    647   1.3      cgd 	if (c & TTY_ERRORMASK|| !(tp->t_state&TS_CARR_ON)) {
    648   1.2      cgd 		sc->sc_flags |= SC_ERROR;
    649   1.1      cgd 		return;
    650   1.2      cgd 	}
    651   1.1      cgd 
    652   1.1      cgd 	++sc->sc_bytesrcvd;
    653   1.1      cgd 	++sc->sc_if.if_ibytes;
    654   1.1      cgd 
    655   1.1      cgd #ifdef ABT_ESC
    656   1.1      cgd 	if (sc->sc_flags & SC_ABORT) {
    657   1.1      cgd 		/* if we see an abort after "idle" time, count it */
    658   1.1      cgd 		if (c == ABT_ESC && time.tv_sec >= sc->sc_lasttime + ABT_WAIT) {
    659   1.1      cgd 			sc->sc_abortcount++;
    660   1.1      cgd 			/* record when the first abort escape arrived */
    661   1.1      cgd 			if (sc->sc_abortcount == 1)
    662   1.1      cgd 				sc->sc_starttime = time.tv_sec;
    663   1.1      cgd 		}
    664   1.1      cgd 		/*
    665   1.1      cgd 		 * if we have an abort, see that we have not run out of time,
    666   1.1      cgd 		 * or that we have an "idle" time after the complete escape
    667   1.1      cgd 		 * sequence
    668   1.1      cgd 		 */
    669   1.1      cgd 		if (sc->sc_abortcount) {
    670   1.1      cgd 			if (time.tv_sec >= sc->sc_starttime + ABT_RECYCLE)
    671   1.1      cgd 				sc->sc_abortcount = 0;
    672   1.1      cgd 			if (sc->sc_abortcount >= ABT_SOFT &&
    673   1.1      cgd 			    time.tv_sec >= sc->sc_lasttime + ABT_WAIT) {
    674   1.1      cgd 				slclose(tp);
    675   1.1      cgd 				return;
    676   1.1      cgd 			}
    677   1.1      cgd 		}
    678   1.1      cgd 		sc->sc_lasttime = time.tv_sec;
    679   1.1      cgd 	}
    680   1.1      cgd #endif
    681   1.1      cgd 
    682   1.1      cgd 	switch (c) {
    683   1.1      cgd 
    684   1.1      cgd 	case TRANS_FRAME_ESCAPE:
    685   1.1      cgd 		if (sc->sc_escape)
    686   1.1      cgd 			c = FRAME_ESCAPE;
    687   1.1      cgd 		break;
    688   1.1      cgd 
    689   1.1      cgd 	case TRANS_FRAME_END:
    690   1.1      cgd 		if (sc->sc_escape)
    691   1.1      cgd 			c = FRAME_END;
    692   1.1      cgd 		break;
    693   1.1      cgd 
    694   1.1      cgd 	case FRAME_ESCAPE:
    695   1.1      cgd 		sc->sc_escape = 1;
    696   1.1      cgd 		return;
    697   1.1      cgd 
    698   1.1      cgd 	case FRAME_END:
    699   1.3      cgd 		if(sc->sc_flags & SC_ERROR) {
    700   1.2      cgd 			sc->sc_flags &= ~SC_ERROR;
    701   1.2      cgd 			goto newpack;
    702   1.2      cgd 		}
    703   1.1      cgd 		len = sc->sc_mp - sc->sc_buf;
    704   1.2      cgd 
    705   1.1      cgd 		if (len < 3)
    706   1.1      cgd 			/* less than min length packet - ignore */
    707   1.1      cgd 			goto newpack;
    708   1.1      cgd 
    709   1.3      cgd #if NBPFILTER > 0
    710   1.3      cgd 		if (sc->sc_bpf)
    711   1.3      cgd 			/*
    712   1.3      cgd 			 * Save the compressed header, so we can
    713   1.3      cgd 			 * tack it on later.  Note that we just
    714   1.3      cgd 			 * we will end up copying garbage in some
    715   1.3      cgd 			 * cases but this is okay.  We remember
    716   1.3      cgd 			 * where the buffer started so we can
    717   1.3      cgd 			 * compute the new header length.
    718   1.3      cgd 			 */
    719   1.3      cgd 			bcopy(sc->sc_buf, chdr, CHDR_LEN);
    720   1.3      cgd #endif
    721   1.1      cgd 		if ((c = (*sc->sc_buf & 0xf0)) != (IPVERSION << 4)) {
    722   1.1      cgd 			if (c & 0x80)
    723   1.1      cgd 				c = TYPE_COMPRESSED_TCP;
    724   1.1      cgd 			else if (c == TYPE_UNCOMPRESSED_TCP)
    725   1.1      cgd 				*sc->sc_buf &= 0x4f; /* XXX */
    726   1.1      cgd 			/*
    727   1.1      cgd 			 * We've got something that's not an IP packet.
    728   1.1      cgd 			 * If compression is enabled, try to decompress it.
    729   1.1      cgd 			 * Otherwise, if `auto-enable' compression is on and
    730   1.1      cgd 			 * it's a reasonable packet, decompress it and then
    731   1.1      cgd 			 * enable compression.  Otherwise, drop it.
    732   1.1      cgd 			 */
    733   1.1      cgd 			if (sc->sc_flags & SC_COMPRESS) {
    734   1.1      cgd 				len = sl_uncompress_tcp(&sc->sc_buf, len,
    735   1.1      cgd 							(u_int)c, &sc->sc_comp);
    736   1.1      cgd 				if (len <= 0)
    737   1.1      cgd 					goto error;
    738   1.1      cgd 			} else if ((sc->sc_flags & SC_AUTOCOMP) &&
    739   1.1      cgd 			    c == TYPE_UNCOMPRESSED_TCP && len >= 40) {
    740   1.1      cgd 				len = sl_uncompress_tcp(&sc->sc_buf, len,
    741   1.1      cgd 							(u_int)c, &sc->sc_comp);
    742   1.1      cgd 				if (len <= 0)
    743   1.1      cgd 					goto error;
    744   1.1      cgd 				sc->sc_flags |= SC_COMPRESS;
    745   1.1      cgd 			} else
    746   1.1      cgd 				goto error;
    747   1.1      cgd 		}
    748   1.3      cgd #if NBPFILTER > 0
    749   1.3      cgd 		if (sc->sc_bpf) {
    750   1.3      cgd 			/*
    751   1.3      cgd 			 * Put the SLIP pseudo-"link header" in place.
    752   1.3      cgd 			 * We couldn't do this any earlier since
    753   1.3      cgd 			 * decompression probably moved the buffer
    754   1.3      cgd 			 * pointer.  Then, invoke BPF.
    755   1.3      cgd 			 */
    756   1.3      cgd 			register u_char *hp = sc->sc_buf - SLIP_HDRLEN;
    757   1.3      cgd 
    758   1.3      cgd 			hp[SLX_DIR] = SLIPDIR_IN;
    759   1.3      cgd 			bcopy(chdr, &hp[SLX_CHDR], CHDR_LEN);
    760   1.3      cgd 			bpf_tap(sc->sc_bpf, hp, len + SLIP_HDRLEN);
    761   1.3      cgd 		}
    762   1.3      cgd #endif
    763   1.1      cgd 		m = sl_btom(sc, len);
    764   1.1      cgd 		if (m == NULL)
    765   1.1      cgd 			goto error;
    766   1.1      cgd 
    767   1.1      cgd 		sc->sc_if.if_ipackets++;
    768   1.1      cgd 		sc->sc_if.if_lastchange = time;
    769   1.1      cgd 		s = splimp();
    770   1.1      cgd 		if (IF_QFULL(&ipintrq)) {
    771   1.1      cgd 			IF_DROP(&ipintrq);
    772   1.1      cgd 			sc->sc_if.if_ierrors++;
    773   1.1      cgd 			sc->sc_if.if_iqdrops++;
    774   1.1      cgd 			m_freem(m);
    775   1.1      cgd 		} else {
    776   1.1      cgd 			IF_ENQUEUE(&ipintrq, m);
    777   1.1      cgd 			schednetisr(NETISR_IP);
    778   1.1      cgd 		}
    779   1.1      cgd 		splx(s);
    780   1.1      cgd 		goto newpack;
    781   1.1      cgd 	}
    782   1.1      cgd 	if (sc->sc_mp < sc->sc_ep) {
    783   1.1      cgd 		*sc->sc_mp++ = c;
    784   1.1      cgd 		sc->sc_escape = 0;
    785   1.1      cgd 		return;
    786   1.1      cgd 	}
    787   1.3      cgd 	sc->sc_flags |= SC_ERROR;
    788   1.1      cgd error:
    789   1.1      cgd 	sc->sc_if.if_ierrors++;
    790   1.1      cgd newpack:
    791   1.1      cgd 	sc->sc_mp = sc->sc_buf = sc->sc_ep - SLMAX;
    792   1.1      cgd 	sc->sc_escape = 0;
    793   1.1      cgd }
    794   1.1      cgd 
    795   1.1      cgd /*
    796   1.1      cgd  * Process an ioctl request.
    797   1.1      cgd  */
    798   1.1      cgd slioctl(ifp, cmd, data)
    799   1.1      cgd 	register struct ifnet *ifp;
    800   1.1      cgd 	int cmd;
    801   1.1      cgd 	caddr_t data;
    802   1.1      cgd {
    803   1.1      cgd 	register struct ifaddr *ifa = (struct ifaddr *)data;
    804   1.1      cgd 	int s = splimp(), error = 0;
    805   1.1      cgd 
    806   1.1      cgd 	switch (cmd) {
    807   1.1      cgd 
    808   1.1      cgd 	case SIOCSIFADDR:
    809   1.1      cgd 		if (ifa->ifa_addr->sa_family == AF_INET)
    810   1.1      cgd 			ifp->if_flags |= IFF_UP;
    811   1.1      cgd 		else
    812   1.1      cgd 			error = EAFNOSUPPORT;
    813   1.1      cgd 		break;
    814   1.1      cgd 
    815   1.1      cgd 	case SIOCSIFDSTADDR:
    816   1.1      cgd 		if (ifa->ifa_addr->sa_family != AF_INET)
    817   1.1      cgd 			error = EAFNOSUPPORT;
    818   1.1      cgd 		break;
    819   1.1      cgd 
    820   1.1      cgd 	default:
    821   1.1      cgd 		error = EINVAL;
    822   1.1      cgd 	}
    823   1.1      cgd 	splx(s);
    824   1.1      cgd 	return (error);
    825   1.1      cgd }
    826   1.1      cgd #endif
    827