NetBSD-1.1 files
authorPaul Mackerras <paulus@samba.org>
Mon, 11 Dec 1995 05:17:12 +0000 (05:17 +0000)
committerPaul Mackerras <paulus@samba.org>
Mon, 11 Dec 1995 05:17:12 +0000 (05:17 +0000)
netbsd-1.1/Makefile.top [new file with mode: 0644]
netbsd-1.1/bsd-comp.c [new file with mode: 0644]
netbsd-1.1/if_ppp.c [new file with mode: 0644]
netbsd-1.1/if_pppvar.h [new file with mode: 0644]
netbsd-1.1/kinstall.sh [new file with mode: 0755]
netbsd-1.1/ppp_tty.c [new file with mode: 0644]
netbsd-1.1/slcompress.c [new file with mode: 0644]
netbsd-1.1/slcompress.h [new file with mode: 0644]

diff --git a/netbsd-1.1/Makefile.top b/netbsd-1.1/Makefile.top
new file mode 100644 (file)
index 0000000..a9b1e44
--- /dev/null
@@ -0,0 +1,13 @@
+#
+# ppp top level makefile for *bsd systems
+#
+
+BINDIR?= /usr/sbin
+
+SUBDIR=        chat pppd pppstats
+MAKE+=  BINDIR=$(BINDIR)
+
+kernel:
+       @sh -e netbsd/kinstall.sh
+
+.include <bsd.subdir.mk>
diff --git a/netbsd-1.1/bsd-comp.c b/netbsd-1.1/bsd-comp.c
new file mode 100644 (file)
index 0000000..a86183b
--- /dev/null
@@ -0,0 +1,1116 @@
+/*     $Id: bsd-comp.c,v 1.1 1995/12/11 05:17:05 paulus Exp $  */
+
+/* Because this code is derived from the 4.3BSD compress source:
+ *
+ *
+ * Copyright (c) 1985, 1986 The Regents of the University of California.
+ * All rights reserved.
+ *
+ * This code is derived from software contributed to Berkeley by
+ * James A. Woods, derived from original work by Spencer Thomas
+ * and Joseph Orost.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ *    notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ *    notice, this list of conditions and the following disclaimer in the
+ *    documentation and/or other materials provided with the distribution.
+ * 3. All advertising materials mentioning features or use of this software
+ *    must display the following acknowledgement:
+ *     This product includes software developed by the University of
+ *     California, Berkeley and its contributors.
+ * 4. Neither the name of the University nor the names of its contributors
+ *    may be used to endorse or promote products derived from this software
+ *    without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ */
+
+/*
+ * This version is for use with mbufs on BSD-derived systems.
+ *
+ * $Id: bsd-comp.c,v 1.1 1995/12/11 05:17:05 paulus Exp $
+ */
+
+#include <sys/param.h>
+#include <sys/types.h>
+#include <sys/mbuf.h>
+#include <sys/socket.h>
+#include <net/if.h>
+#include <net/if_types.h>
+#include <net/ppp_defs.h>
+#include <net/if_ppp.h>
+
+#define PACKETPTR      struct mbuf *
+#include <net/ppp-comp.h>
+
+#if DO_BSD_COMPRESS
+/*
+ * PPP "BSD compress" compression
+ *  The differences between this compression and the classic BSD LZW
+ *  source are obvious from the requirement that the classic code worked
+ *  with files while this handles arbitrarily long streams that
+ *  are broken into packets.  They are:
+ *
+ *     When the code size expands, a block of junk is not emitted by
+ *         the compressor and not expected by the decompressor.
+ *
+ *     New codes are not necessarily assigned every time an old
+ *         code is output by the compressor.  This is because a packet
+ *         end forces a code to be emitted, but does not imply that a
+ *         new sequence has been seen.
+ *
+ *     The compression ratio is checked at the first end of a packet
+ *         after the appropriate gap.  Besides simplifying and speeding
+ *         things up, this makes it more likely that the transmitter
+ *         and receiver will agree when the dictionary is cleared when
+ *         compression is not going well.
+ */
+
+/*
+ * A dictionary for doing BSD compress.
+ */
+struct bsd_db {
+    int            totlen;                     /* length of this structure */
+    u_int   hsize;                     /* size of the hash table */
+    u_char  hshift;                    /* used in hash function */
+    u_char  n_bits;                    /* current bits/code */
+    u_char  maxbits;
+    u_char  debug;
+    u_char  unit;
+    u_int16_t seqno;                   /* sequence # of next packet */
+    u_int   hdrlen;                    /* header length to preallocate */
+    u_int   mru;
+    u_int   maxmaxcode;                        /* largest valid code */
+    u_int   max_ent;                   /* largest code in use */
+    u_int   in_count;                  /* uncompressed bytes, aged */
+    u_int   bytes_out;                 /* compressed bytes, aged */
+    u_int   ratio;                     /* recent compression ratio */
+    u_int   checkpoint;                        /* when to next check the ratio */
+    u_int   clear_count;               /* times dictionary cleared */
+    u_int   incomp_count;              /* incompressible packets */
+    u_int   incomp_bytes;              /* incompressible bytes */
+    u_int   uncomp_count;              /* uncompressed packets */
+    u_int   uncomp_bytes;              /* uncompressed bytes */
+    u_int   comp_count;                        /* compressed packets */
+    u_int   comp_bytes;                        /* compressed bytes */
+    u_int16_t *lens;                   /* array of lengths of codes */
+    struct bsd_dict {
+       union {                         /* hash value */
+           u_int32_t   fcode;
+           struct {
+#if BYTE_ORDER == LITTLE_ENDIAN
+               u_int16_t prefix;       /* preceding code */
+               u_char  suffix;         /* last character of new code */
+               u_char  pad;
+#else
+               u_char  pad;
+               u_char  suffix;         /* last character of new code */
+               u_int16_t prefix;       /* preceding code */
+#endif
+           } hs;
+       } f;
+       u_int16_t codem1;               /* output of hash table -1 */
+       u_int16_t cptr;                 /* map code to hash table entry */
+    } dict[1];
+};
+
+#define BSD_OVHD       2               /* BSD compress overhead/packet */
+#define BSD_INIT_BITS  BSD_MIN_BITS
+
+static void    *bsd_comp_alloc __P((u_char *options, int opt_len));
+static void    *bsd_decomp_alloc __P((u_char *options, int opt_len));
+static void    bsd_free __P((void *state));
+static int     bsd_comp_init __P((void *state, u_char *options, int opt_len,
+                                  int unit, int hdrlen, int debug));
+static int     bsd_decomp_init __P((void *state, u_char *options, int opt_len,
+                                    int unit, int hdrlen, int mru, int debug));
+static int     bsd_compress __P((void *state, struct mbuf **mret,
+                                 struct mbuf *mp, int slen, int maxolen));
+static void    bsd_incomp __P((void *state, struct mbuf *dmsg));
+static int     bsd_decompress __P((void *state, struct mbuf *cmp,
+                                   struct mbuf **dmpp));
+static void    bsd_reset __P((void *state));
+static void    bsd_comp_stats __P((void *state, struct compstat *stats));
+
+/*
+ * Procedures exported to if_ppp.c.
+ */
+struct compressor ppp_bsd_compress = {
+    CI_BSD_COMPRESS,           /* compress_proto */
+    bsd_comp_alloc,            /* comp_alloc */
+    bsd_free,                  /* comp_free */
+    bsd_comp_init,             /* comp_init */
+    bsd_reset,                 /* comp_reset */
+    bsd_compress,              /* compress */
+    bsd_comp_stats,            /* comp_stat */
+    bsd_decomp_alloc,          /* decomp_alloc */
+    bsd_free,                  /* decomp_free */
+    bsd_decomp_init,           /* decomp_init */
+    bsd_reset,                 /* decomp_reset */
+    bsd_decompress,            /* decompress */
+    bsd_incomp,                        /* incomp */
+    bsd_comp_stats,            /* decomp_stat */
+};
+
+/*
+ * the next two codes should not be changed lightly, as they must not
+ * lie within the contiguous general code space.
+ */
+#define CLEAR  256                     /* table clear output code */
+#define FIRST  257                     /* first free entry */
+#define LAST   255
+
+#define MAXCODE(b)     ((1 << (b)) - 1)
+#define BADCODEM1      MAXCODE(BSD_MAX_BITS)
+
+#define BSD_HASH(prefix,suffix,hshift) ((((u_int32_t)(suffix)) << (hshift)) \
+                                        ^ (u_int32_t)(prefix))
+#define BSD_KEY(prefix,suffix)         ((((u_int32_t)(suffix)) << 16) \
+                                        + (u_int32_t)(prefix))
+
+#define CHECK_GAP      10000           /* Ratio check interval */
+
+#define RATIO_SCALE_LOG        8
+#define RATIO_SCALE    (1<<RATIO_SCALE_LOG)
+#define RATIO_MAX      (0x7fffffff>>RATIO_SCALE_LOG)
+
+/*
+ * clear the dictionary
+ */
+static void
+bsd_clear(db)
+    struct bsd_db *db;
+{
+    db->clear_count++;
+    db->max_ent = FIRST-1;
+    db->n_bits = BSD_INIT_BITS;
+    db->ratio = 0;
+    db->bytes_out = 0;
+    db->in_count = 0;
+    db->incomp_count = 0;
+    db->checkpoint = CHECK_GAP;
+}
+
+/*
+ * If the dictionary is full, then see if it is time to reset it.
+ *
+ * Compute the compression ratio using fixed-point arithmetic
+ * with 8 fractional bits.
+ *
+ * Since we have an infinite stream instead of a single file,
+ * watch only the local compression ratio.
+ *
+ * Since both peers must reset the dictionary at the same time even in
+ * the absence of CLEAR codes (while packets are incompressible), they
+ * must compute the same ratio.
+ */
+static int                             /* 1=output CLEAR */
+bsd_check(db)
+    struct bsd_db *db;
+{
+    u_int new_ratio;
+
+    if (db->in_count >= db->checkpoint) {
+       /* age the ratio by limiting the size of the counts */
+       if (db->in_count >= RATIO_MAX
+           || db->bytes_out >= RATIO_MAX) {
+           db->in_count -= db->in_count/4;
+           db->bytes_out -= db->bytes_out/4;
+       }
+
+       db->checkpoint = db->in_count + CHECK_GAP;
+
+       if (db->max_ent >= db->maxmaxcode) {
+           /* Reset the dictionary only if the ratio is worse,
+            * or if it looks as if it has been poisoned
+            * by incompressible data.
+            *
+            * This does not overflow, because
+            *  db->in_count <= RATIO_MAX.
+            */
+           new_ratio = db->in_count << RATIO_SCALE_LOG;
+           if (db->bytes_out != 0)
+               new_ratio /= db->bytes_out;
+
+           if (new_ratio < db->ratio || new_ratio < 1 * RATIO_SCALE) {
+               bsd_clear(db);
+               return 1;
+           }
+           db->ratio = new_ratio;
+       }
+    }
+    return 0;
+}
+
+/*
+ * Return statistics.
+ */
+static void
+bsd_comp_stats(state, stats)
+    void *state;
+    struct compstat *stats;
+{
+    struct bsd_db *db = (struct bsd_db *) state;
+    u_int out;
+
+    stats->unc_bytes = db->uncomp_bytes;
+    stats->unc_packets = db->uncomp_count;
+    stats->comp_bytes = db->comp_bytes;
+    stats->comp_packets = db->comp_count;
+    stats->inc_bytes = db->incomp_bytes;
+    stats->inc_packets = db->incomp_count;
+    stats->ratio = db->in_count;
+    out = db->bytes_out;
+    if (stats->ratio <= 0x7fffff)
+       stats->ratio <<= 8;
+    else
+       out >>= 8;
+    if (out != 0)
+       stats->ratio /= out;
+}
+
+/*
+ * Reset state, as on a CCP ResetReq.
+ */
+static void
+bsd_reset(state)
+    void *state;
+{
+    struct bsd_db *db = (struct bsd_db *) state;
+
+    db->seqno = 0;
+    bsd_clear(db);
+    db->clear_count = 0;
+}
+
+/*
+ * Allocate space for a (de) compressor.
+ */
+static void *
+bsd_alloc(options, opt_len, decomp)
+    u_char *options;
+    int opt_len, decomp;
+{
+    int bits;
+    u_int newlen, hsize, hshift, maxmaxcode;
+    struct bsd_db *db;
+
+    if (opt_len != CILEN_BSD_COMPRESS || options[0] != CI_BSD_COMPRESS
+       || options[1] != CILEN_BSD_COMPRESS
+       || BSD_VERSION(options[2]) != BSD_CURRENT_VERSION)
+       return NULL;
+    bits = BSD_NBITS(options[2]);
+    switch (bits) {
+    case 9:                    /* needs 82152 for both directions */
+    case 10:                   /* needs 84144 */
+    case 11:                   /* needs 88240 */
+    case 12:                   /* needs 96432 */
+       hsize = 5003;
+       hshift = 4;
+       break;
+    case 13:                   /* needs 176784 */
+       hsize = 9001;
+       hshift = 5;
+       break;
+    case 14:                   /* needs 353744 */
+       hsize = 18013;
+       hshift = 6;
+       break;
+    case 15:                   /* needs 691440 */
+       hsize = 35023;
+       hshift = 7;
+       break;
+    case 16:                   /* needs 1366160--far too much, */
+       /* hsize = 69001; */    /* and 69001 is too big for cptr */
+       /* hshift = 8; */       /* in struct bsd_db */
+       /* break; */
+    default:
+       return NULL;
+    }
+
+    maxmaxcode = MAXCODE(bits);
+    newlen = sizeof(*db) + (hsize-1) * (sizeof(db->dict[0]));
+    MALLOC(db, struct bsd_db *, newlen, M_DEVBUF, M_NOWAIT);
+    if (!db)
+       return NULL;
+    bzero(db, sizeof(*db) - sizeof(db->dict));
+
+    if (!decomp) {
+       db->lens = NULL;
+    } else {
+       MALLOC(db->lens, u_int16_t *, (maxmaxcode+1) * sizeof(db->lens[0]),
+              M_DEVBUF, M_NOWAIT);
+       if (!db->lens) {
+           FREE(db, M_DEVBUF);
+           return NULL;
+       }
+    }
+
+    db->totlen = newlen;
+    db->hsize = hsize;
+    db->hshift = hshift;
+    db->maxmaxcode = maxmaxcode;
+    db->maxbits = bits;
+
+    return (void *) db;
+}
+
+static void
+bsd_free(state)
+    void *state;
+{
+    struct bsd_db *db = (struct bsd_db *) state;
+
+    if (db->lens)
+       FREE(db->lens, M_DEVBUF);
+    FREE(db, M_DEVBUF);
+}
+
+static void *
+bsd_comp_alloc(options, opt_len)
+    u_char *options;
+    int opt_len;
+{
+    return bsd_alloc(options, opt_len, 0);
+}
+
+static void *
+bsd_decomp_alloc(options, opt_len)
+    u_char *options;
+    int opt_len;
+{
+    return bsd_alloc(options, opt_len, 1);
+}
+
+/*
+ * Initialize the database.
+ */
+static int
+bsd_init(db, options, opt_len, unit, hdrlen, mru, debug, decomp)
+    struct bsd_db *db;
+    u_char *options;
+    int opt_len, unit, hdrlen, mru, debug, decomp;
+{
+    int i;
+
+    if (opt_len != CILEN_BSD_COMPRESS || options[0] != CI_BSD_COMPRESS
+       || options[1] != CILEN_BSD_COMPRESS
+       || BSD_VERSION(options[2]) != BSD_CURRENT_VERSION
+       || BSD_NBITS(options[2]) != db->maxbits
+       || decomp && db->lens == NULL)
+       return 0;
+
+    if (decomp) {
+       i = LAST+1;
+       while (i != 0)
+           db->lens[--i] = 1;
+    }
+    i = db->hsize;
+    while (i != 0) {
+       db->dict[--i].codem1 = BADCODEM1;
+       db->dict[i].cptr = 0;
+    }
+
+    db->unit = unit;
+    db->hdrlen = hdrlen;
+    db->mru = mru;
+#ifndef DEBUG
+    if (debug)
+#endif
+       db->debug = 1;
+
+    bsd_reset(db);
+
+    return 1;
+}
+
+static int
+bsd_comp_init(state, options, opt_len, unit, hdrlen, debug)
+    void *state;
+    u_char *options;
+    int opt_len, unit, hdrlen, debug;
+{
+    return bsd_init((struct bsd_db *) state, options, opt_len,
+                   unit, hdrlen, 0, debug, 0);
+}
+
+static int
+bsd_decomp_init(state, options, opt_len, unit, hdrlen, mru, debug)
+    void *state;
+    u_char *options;
+    int opt_len, unit, hdrlen, mru, debug;
+{
+    return bsd_init((struct bsd_db *) state, options, opt_len,
+                   unit, hdrlen, mru, debug, 1);
+}
+
+
+/*
+ * compress a packet
+ *     One change from the BSD compress command is that when the
+ *     code size expands, we do not output a bunch of padding.
+ */
+int                                    /* new slen */
+bsd_compress(state, mret, mp, slen, maxolen)
+    void *state;
+    struct mbuf **mret;                /* return compressed mbuf chain here */
+    struct mbuf *mp;           /* from here */
+    int slen;                  /* uncompressed length */
+    int maxolen;               /* max compressed length */
+{
+    struct bsd_db *db = (struct bsd_db *) state;
+    int hshift = db->hshift;
+    u_int max_ent = db->max_ent;
+    u_int n_bits = db->n_bits;
+    u_int bitno = 32;
+    u_int32_t accm = 0, fcode;
+    struct bsd_dict *dictp;
+    u_char c;
+    int hval, disp, ent, ilen;
+    struct mbuf *np;
+    u_char *rptr, *wptr;
+    u_char *cp_end;
+    int olen;
+    struct mbuf *m, **mnp;
+
+#define PUTBYTE(v) {                                   \
+    ++olen;                                            \
+    if (wptr) {                                                \
+       *wptr++ = (v);                                  \
+       if (wptr >= cp_end) {                           \
+           m->m_len = wptr - mtod(m, u_char *);        \
+           MGET(m->m_next, M_DONTWAIT, MT_DATA);       \
+           m = m->m_next;                              \
+           if (m) {                                    \
+               m->m_len = 0;                           \
+               if (maxolen - olen > MLEN)              \
+                   MCLGET(m, M_DONTWAIT);              \
+               wptr = mtod(m, u_char *);               \
+               cp_end = wptr + M_TRAILINGSPACE(m);     \
+           } else                                      \
+               wptr = NULL;                            \
+       }                                               \
+    }                                                  \
+}
+
+#define OUTPUT(ent) {                                  \
+    bitno -= n_bits;                                   \
+    accm |= ((ent) << bitno);                          \
+    do {                                               \
+       PUTBYTE(accm >> 24);                            \
+       accm <<= 8;                                     \
+       bitno += 8;                                     \
+    } while (bitno <= 24);                             \
+}
+
+    /*
+     * If the protocol is not in the range we're interested in,
+     * just return without compressing the packet.  If it is,
+     * the protocol becomes the first byte to compress.
+     */
+    rptr = mtod(mp, u_char *);
+    ent = PPP_PROTOCOL(rptr);
+    if (ent < 0x21 || ent > 0xf9) {
+       *mret = NULL;
+       return slen;
+    }
+
+    /* Don't generate compressed packets which are larger than
+       the uncompressed packet. */
+    if (maxolen > slen)
+       maxolen = slen;
+
+    /* Allocate one mbuf to start with. */
+    MGET(m, M_DONTWAIT, MT_DATA);
+    *mret = m;
+    if (m != NULL) {
+       m->m_len = 0;
+       if (maxolen + db->hdrlen > MLEN)
+           MCLGET(m, M_DONTWAIT);
+       m->m_data += db->hdrlen;
+       wptr = mtod(m, u_char *);
+       cp_end = wptr + M_TRAILINGSPACE(m);
+    } else
+       wptr = cp_end = NULL;
+
+    /*
+     * Copy the PPP header over, changing the protocol,
+     * and install the 2-byte packet sequence number.
+     */
+    if (wptr) {
+       *wptr++ = PPP_ADDRESS(rptr);    /* assumes the ppp header is */
+       *wptr++ = PPP_CONTROL(rptr);    /* all in one mbuf */
+       *wptr++ = 0;                    /* change the protocol */
+       *wptr++ = PPP_COMP;
+       *wptr++ = db->seqno >> 8;
+       *wptr++ = db->seqno;
+    }
+    ++db->seqno;
+
+    olen = 0;
+    rptr += PPP_HDRLEN;
+    slen = mp->m_len - PPP_HDRLEN;
+    ilen = slen + 1;
+    for (;;) {
+       if (slen <= 0) {
+           mp = mp->m_next;
+           if (!mp)
+               break;
+           rptr = mtod(mp, u_char *);
+           slen = mp->m_len;
+           if (!slen)
+               continue;   /* handle 0-length buffers */
+           ilen += slen;
+       }
+
+       slen--;
+       c = *rptr++;
+       fcode = BSD_KEY(ent, c);
+       hval = BSD_HASH(ent, c, hshift);
+       dictp = &db->dict[hval];
+
+       /* Validate and then check the entry. */
+       if (dictp->codem1 >= max_ent)
+           goto nomatch;
+       if (dictp->f.fcode == fcode) {
+           ent = dictp->codem1+1;
+           continue;   /* found (prefix,suffix) */
+       }
+
+       /* continue probing until a match or invalid entry */
+       disp = (hval == 0) ? 1 : hval;
+       do {
+           hval += disp;
+           if (hval >= db->hsize)
+               hval -= db->hsize;
+           dictp = &db->dict[hval];
+           if (dictp->codem1 >= max_ent)
+               goto nomatch;
+       } while (dictp->f.fcode != fcode);
+       ent = dictp->codem1 + 1;        /* finally found (prefix,suffix) */
+       continue;
+
+    nomatch:
+       OUTPUT(ent);            /* output the prefix */
+
+       /* code -> hashtable */
+       if (max_ent < db->maxmaxcode) {
+           struct bsd_dict *dictp2;
+           /* expand code size if needed */
+           if (max_ent >= MAXCODE(n_bits))
+               db->n_bits = ++n_bits;
+
+           /* Invalidate old hash table entry using
+            * this code, and then take it over.
+            */
+           dictp2 = &db->dict[max_ent+1];
+           if (db->dict[dictp2->cptr].codem1 == max_ent)
+               db->dict[dictp2->cptr].codem1 = BADCODEM1;
+           dictp2->cptr = hval;
+           dictp->codem1 = max_ent;
+           dictp->f.fcode = fcode;
+
+           db->max_ent = ++max_ent;
+       }
+       ent = c;
+    }
+
+    OUTPUT(ent);               /* output the last code */
+    db->bytes_out += olen;
+    db->in_count += ilen;
+    if (bitno < 32)
+       ++db->bytes_out;        /* count complete bytes */
+
+    if (bsd_check(db))
+       OUTPUT(CLEAR);          /* do not count the CLEAR */
+
+    /*
+     * Pad dribble bits of last code with ones.
+     * Do not emit a completely useless byte of ones.
+     */
+    if (bitno != 32)
+       PUTBYTE((accm | (0xff << (bitno-8))) >> 24);
+
+    if (m != NULL) {
+       m->m_len = wptr - mtod(m, u_char *);
+       m->m_next = NULL;
+    }
+
+    /*
+     * Increase code size if we would have without the packet
+     * boundary and as the decompressor will.
+     */
+    if (max_ent >= MAXCODE(n_bits) && max_ent < db->maxmaxcode)
+       db->n_bits++;
+
+    db->uncomp_bytes += ilen;
+    ++db->uncomp_count;
+    if (olen + PPP_HDRLEN + BSD_OVHD > maxolen) {
+       /* throw away the compressed stuff if it is longer than uncompressed */
+       if (*mret != NULL) {
+           m_freem(*mret);
+           *mret = NULL;
+       }
+       ++db->incomp_count;
+       db->incomp_bytes += ilen;
+    } else {
+       ++db->comp_count;
+       db->comp_bytes += olen + BSD_OVHD;
+    }
+
+    return olen + PPP_HDRLEN + BSD_OVHD;
+#undef OUTPUT
+#undef PUTBYTE
+}
+
+
+/*
+ * Update the "BSD Compress" dictionary on the receiver for
+ * incompressible data by pretending to compress the incoming data.
+ */
+static void
+bsd_incomp(state, dmsg)
+    void *state;
+    struct mbuf *dmsg;
+{
+    struct bsd_db *db = (struct bsd_db *) state;
+    u_int hshift = db->hshift;
+    u_int max_ent = db->max_ent;
+    u_int n_bits = db->n_bits;
+    struct bsd_dict *dictp;
+    u_int32_t fcode;
+    u_char c;
+    u_int32_t hval, disp;
+    int slen, ilen;
+    u_int bitno = 7;
+    u_char *rptr;
+    u_int ent;
+
+    /*
+     * If the protocol is not in the range we're interested in,
+     * just return without looking at the packet.  If it is,
+     * the protocol becomes the first byte to "compress".
+     */
+    rptr = mtod(dmsg, u_char *);
+    ent = PPP_PROTOCOL(rptr);
+    if (ent < 0x21 || ent > 0xf9)
+       return;
+
+    db->incomp_count++;
+    db->seqno++;
+    ilen = 1;          /* count the protocol as 1 byte */
+    rptr += PPP_HDRLEN;
+    slen = dmsg->m_len - PPP_HDRLEN;
+    for (;;) {
+       if (slen <= 0) {
+           dmsg = dmsg->m_next;
+           if (!dmsg)
+               break;
+           rptr = mtod(dmsg, u_char *);
+           slen = dmsg->m_len;
+           continue;
+       }
+       ilen += slen;
+
+       do {
+           c = *rptr++;
+           fcode = BSD_KEY(ent, c);
+           hval = BSD_HASH(ent, c, hshift);
+           dictp = &db->dict[hval];
+
+           /* validate and then check the entry */
+           if (dictp->codem1 >= max_ent)
+               goto nomatch;
+           if (dictp->f.fcode == fcode) {
+               ent = dictp->codem1+1;
+               continue;   /* found (prefix,suffix) */
+           }
+
+           /* continue probing until a match or invalid entry */
+           disp = (hval == 0) ? 1 : hval;
+           do {
+               hval += disp;
+               if (hval >= db->hsize)
+                   hval -= db->hsize;
+               dictp = &db->dict[hval];
+               if (dictp->codem1 >= max_ent)
+                   goto nomatch;
+           } while (dictp->f.fcode != fcode);
+           ent = dictp->codem1+1;
+           continue;   /* finally found (prefix,suffix) */
+
+       nomatch:                /* output (count) the prefix */
+           bitno += n_bits;
+
+           /* code -> hashtable */
+           if (max_ent < db->maxmaxcode) {
+               struct bsd_dict *dictp2;
+               /* expand code size if needed */
+               if (max_ent >= MAXCODE(n_bits))
+                   db->n_bits = ++n_bits;
+
+               /* Invalidate previous hash table entry
+                * assigned this code, and then take it over.
+                */
+               dictp2 = &db->dict[max_ent+1];
+               if (db->dict[dictp2->cptr].codem1 == max_ent)
+                   db->dict[dictp2->cptr].codem1 = BADCODEM1;
+               dictp2->cptr = hval;
+               dictp->codem1 = max_ent;
+               dictp->f.fcode = fcode;
+
+               db->max_ent = ++max_ent;
+               db->lens[max_ent] = db->lens[ent]+1;
+           }
+           ent = c;
+       } while (--slen != 0);
+    }
+    bitno += n_bits;           /* output (count) the last code */
+    db->bytes_out += bitno/8;
+    db->in_count += ilen;
+    (void)bsd_check(db);
+
+    ++db->incomp_count;
+    db->incomp_bytes += ilen;
+    ++db->uncomp_count;
+    db->uncomp_bytes += ilen;
+
+    /* Increase code size if we would have without the packet
+     * boundary and as the decompressor will.
+     */
+    if (max_ent >= MAXCODE(n_bits) && max_ent < db->maxmaxcode)
+       db->n_bits++;
+}
+
+
+/*
+ * Decompress "BSD Compress".
+ *
+ * Because of patent problems, we return DECOMP_ERROR for errors
+ * found by inspecting the input data and for system problems, but
+ * DECOMP_FATALERROR for any errors which could possibly be said to
+ * be being detected "after" decompression.  For DECOMP_ERROR,
+ * we can issue a CCP reset-request; for DECOMP_FATALERROR, we may be
+ * infringing a patent of Motorola's if we do, so we take CCP down
+ * instead.
+ *
+ * Given that the frame has the correct sequence number and a good FCS,
+ * errors such as invalid codes in the input most likely indicate a
+ * bug, so we return DECOMP_FATALERROR for them in order to turn off
+ * compression, even though they are detected by inspecting the input.
+ */
+int
+bsd_decompress(state, cmp, dmpp)
+    void *state;
+    struct mbuf *cmp, **dmpp;
+{
+    struct bsd_db *db = (struct bsd_db *) state;
+    u_int max_ent = db->max_ent;
+    u_int32_t accm = 0;
+    u_int bitno = 32;          /* 1st valid bit in accm */
+    u_int n_bits = db->n_bits;
+    u_int tgtbitno = 32-n_bits;        /* bitno when we have a code */
+    struct bsd_dict *dictp;
+    int explen, i, seq, len;
+    u_int incode, oldcode, finchar;
+    u_char *p, *rptr, *wptr;
+    struct mbuf *m, *dmp, *mret;
+    int adrs, ctrl, ilen;
+    int space, codelen, extra;
+    struct mbuf *last;
+
+    /*
+     * Save the address/control from the PPP header
+     * and then get the sequence number.
+     */
+    *dmpp = NULL;
+    rptr = mtod(cmp, u_char *);
+    adrs = PPP_ADDRESS(rptr);
+    ctrl = PPP_CONTROL(rptr);
+    rptr += PPP_HDRLEN;
+    len = cmp->m_len - PPP_HDRLEN;
+    seq = 0;
+    for (i = 0; i < 2; ++i) {
+       while (len <= 0) {
+           cmp = cmp->m_next;
+           if (cmp == NULL)
+               return DECOMP_ERROR;
+           rptr = mtod(cmp, u_char *);
+           len = cmp->m_len;
+       }
+       seq = (seq << 8) + *rptr++;
+       --len;
+    }
+
+    /*
+     * Check the sequence number and give up if it differs from
+     * the value we're expecting.
+     */
+    if (seq != db->seqno) {
+       if (db->debug)
+           printf("bsd_decomp%d: bad sequence # %d, expected %d\n",
+                  db->unit, seq, db->seqno - 1);
+       return DECOMP_ERROR;
+    }
+    ++db->seqno;
+
+    /*
+     * Allocate one mbuf to start with.
+     */
+    MGETHDR(dmp, M_DONTWAIT, MT_DATA);
+    if (dmp == NULL)
+       return DECOMP_ERROR;
+    mret = dmp;
+    dmp->m_len = 0;
+    dmp->m_next = NULL;
+    MCLGET(dmp, M_DONTWAIT);
+    dmp->m_data += db->hdrlen;
+    wptr = mtod(dmp, u_char *);
+    space = M_TRAILINGSPACE(dmp) - PPP_HDRLEN + 1;
+
+    /*
+     * Fill in the ppp header, but not the last byte of the protocol
+     * (that comes from the decompressed data).
+     */
+    wptr[0] = adrs;
+    wptr[1] = ctrl;
+    wptr[2] = 0;
+    wptr += PPP_HDRLEN - 1;
+
+    ilen = len;
+    oldcode = CLEAR;
+    explen = 0;
+    for (;;) {
+       if (len == 0) {
+           cmp = cmp->m_next;
+           if (!cmp)           /* quit at end of message */
+               break;
+           rptr = mtod(cmp, u_char *);
+           len = cmp->m_len;
+           ilen += len;
+           continue;           /* handle 0-length buffers */
+       }
+
+       /*
+        * Accumulate bytes until we have a complete code.
+        * Then get the next code, relying on the 32-bit,
+        * unsigned accm to mask the result.
+        */
+       bitno -= 8;
+       accm |= *rptr++ << bitno;
+       --len;
+       if (tgtbitno < bitno)
+           continue;
+       incode = accm >> tgtbitno;
+       accm <<= n_bits;
+       bitno += n_bits;
+
+       if (incode == CLEAR) {
+           /*
+            * The dictionary must only be cleared at
+            * the end of a packet.  But there could be an
+            * empty mbuf at the end.
+            */
+           if (len > 0 || cmp->m_next != NULL) {
+               while ((cmp = cmp->m_next) != NULL)
+                   len += cmp->m_len;
+               if (len > 0) {
+                   m_freem(mret);
+                   if (db->debug)
+                       printf("bsd_decomp%d: bad CLEAR\n", db->unit);
+                   return DECOMP_FATALERROR;   /* probably a bug */
+               }
+           }
+           bsd_clear(db);
+           explen = ilen = 0;
+           break;
+       }
+
+       if (incode > max_ent + 2 || incode > db->maxmaxcode
+           || incode > max_ent && oldcode == CLEAR) {
+           m_freem(mret);
+           if (db->debug) {
+               printf("bsd_decomp%d: bad code 0x%x oldcode=0x%x ",
+                      db->unit, incode, oldcode);
+               printf("max_ent=0x%x explen=%d seqno=%d\n",
+                      max_ent, explen, db->seqno);
+           }
+           return DECOMP_FATALERROR;   /* probably a bug */
+       }
+
+       /* Special case for KwKwK string. */
+       if (incode > max_ent) {
+           finchar = oldcode;
+           extra = 1;
+       } else {
+           finchar = incode;
+           extra = 0;
+       }
+
+       codelen = db->lens[finchar];
+       explen += codelen + extra;
+       if (explen > db->mru + 1) {
+           m_freem(mret);
+           if (db->debug) {
+               printf("bsd_decomp%d: ran out of mru\n", db->unit);
+#ifdef DEBUG
+               while ((cmp = cmp->m_next) != NULL)
+                   len += cmp->m_len;
+               printf("  len=%d, finchar=0x%x, codelen=%d, explen=%d\n",
+                      len, finchar, codelen, explen);
+#endif
+           }
+           return DECOMP_FATALERROR;
+       }
+
+       /*
+        * For simplicity, the decoded characters go in a single mbuf,
+        * so we allocate a single extra cluster mbuf if necessary.
+        */
+       if ((space -= codelen + extra) < 0) {
+           dmp->m_len = wptr - mtod(dmp, u_char *);
+           MGET(m, M_DONTWAIT, MT_DATA);
+           if (m == NULL) {
+               m_freem(mret);
+               return DECOMP_ERROR;
+           }
+           m->m_len = 0;
+           m->m_next = NULL;
+           dmp->m_next = m;
+           MCLGET(m, M_DONTWAIT);
+           space = M_TRAILINGSPACE(m) - (codelen + extra);
+           if (space < 0) {
+               /* now that's what I call *compression*. */
+               m_freem(mret);
+               return DECOMP_ERROR;
+           }
+           dmp = m;
+           wptr = mtod(dmp, u_char *);
+       }
+
+       /*
+        * Decode this code and install it in the decompressed buffer.
+        */
+       p = (wptr += codelen);
+       while (finchar > LAST) {
+           dictp = &db->dict[db->dict[finchar].cptr];
+#ifdef DEBUG
+           if (--codelen <= 0 || dictp->codem1 != finchar-1)
+               goto bad;
+#endif
+           *--p = dictp->f.hs.suffix;
+           finchar = dictp->f.hs.prefix;
+       }
+       *--p = finchar;
+
+#ifdef DEBUG
+       if (--codelen != 0)
+           printf("bsd_decomp%d: short by %d after code 0x%x, max_ent=0x%x\n",
+                  db->unit, codelen, incode, max_ent);
+#endif
+
+       if (extra)              /* the KwKwK case again */
+           *wptr++ = finchar;
+
+       /*
+        * If not first code in a packet, and
+        * if not out of code space, then allocate a new code.
+        *
+        * Keep the hash table correct so it can be used
+        * with uncompressed packets.
+        */
+       if (oldcode != CLEAR && max_ent < db->maxmaxcode) {
+           struct bsd_dict *dictp2;
+           u_int32_t fcode;
+           u_int32_t hval, disp;
+
+           fcode = BSD_KEY(oldcode,finchar);
+           hval = BSD_HASH(oldcode,finchar,db->hshift);
+           dictp = &db->dict[hval];
+
+           /* look for a free hash table entry */
+           if (dictp->codem1 < max_ent) {
+               disp = (hval == 0) ? 1 : hval;
+               do {
+                   hval += disp;
+                   if (hval >= db->hsize)
+                       hval -= db->hsize;
+                   dictp = &db->dict[hval];
+               } while (dictp->codem1 < max_ent);
+           }
+
+           /*
+            * Invalidate previous hash table entry
+            * assigned this code, and then take it over
+            */
+           dictp2 = &db->dict[max_ent+1];
+           if (db->dict[dictp2->cptr].codem1 == max_ent) {
+               db->dict[dictp2->cptr].codem1 = BADCODEM1;
+           }
+           dictp2->cptr = hval;
+           dictp->codem1 = max_ent;
+           dictp->f.fcode = fcode;
+
+           db->max_ent = ++max_ent;
+           db->lens[max_ent] = db->lens[oldcode]+1;
+
+           /* Expand code size if needed. */
+           if (max_ent >= MAXCODE(n_bits) && max_ent < db->maxmaxcode) {
+               db->n_bits = ++n_bits;
+               tgtbitno = 32-n_bits;
+           }
+       }
+       oldcode = incode;
+    }
+    dmp->m_len = wptr - mtod(dmp, u_char *);
+
+    /*
+     * Keep the checkpoint right so that incompressible packets
+     * clear the dictionary at the right times.
+     */
+    db->bytes_out += ilen;
+    db->in_count += explen;
+    if (bsd_check(db) && db->debug) {
+       printf("bsd_decomp%d: peer should have cleared dictionary\n",
+              db->unit);
+    }
+
+    ++db->comp_count;
+    db->comp_bytes += ilen + BSD_OVHD;
+    ++db->uncomp_count;
+    db->uncomp_bytes += explen;
+
+    *dmpp = mret;
+    return DECOMP_OK;
+
+#ifdef DEBUG
+ bad:
+    if (codelen <= 0) {
+       printf("bsd_decomp%d: fell off end of chain ", db->unit);
+       printf("0x%x at 0x%x by 0x%x, max_ent=0x%x\n",
+              incode, finchar, db->dict[finchar].cptr, max_ent);
+    } else if (dictp->codem1 != finchar-1) {
+       printf("bsd_decomp%d: bad code chain 0x%x finchar=0x%x ",
+              db->unit, incode, finchar);
+       printf("oldcode=0x%x cptr=0x%x codem1=0x%x\n", oldcode,
+              db->dict[finchar].cptr, dictp->codem1);
+    }
+    m_freem(mret);
+    return DECOMP_FATALERROR;
+#endif /* DEBUG */
+}
+#endif /* DO_BSD_COMPRESS */
diff --git a/netbsd-1.1/if_ppp.c b/netbsd-1.1/if_ppp.c
new file mode 100644 (file)
index 0000000..f17a09d
--- /dev/null
@@ -0,0 +1,1375 @@
+/*     $Id: if_ppp.c,v 1.1 1995/12/11 05:17:06 paulus Exp $    */
+
+/*
+ * if_ppp.c - Point-to-Point Protocol (PPP) Asynchronous driver.
+ *
+ * Copyright (c) 1989 Carnegie Mellon University.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms are permitted
+ * provided that the above copyright notice and this paragraph are
+ * duplicated in all such forms and that any documentation,
+ * advertising materials, and other materials related to such
+ * distribution and use acknowledge that the software was developed
+ * by Carnegie Mellon University.  The name of the
+ * University may not be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
+ * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
+ * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * Drew D. Perkins
+ * Carnegie Mellon University
+ * 4910 Forbes Ave.
+ * Pittsburgh, PA 15213
+ * (412) 268-8576
+ * ddp@andrew.cmu.edu
+ *
+ * Based on:
+ *     @(#)if_sl.c     7.6.1.2 (Berkeley) 2/15/89
+ *
+ * Copyright (c) 1987 Regents of the University of California.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms are permitted
+ * provided that the above copyright notice and this paragraph are
+ * duplicated in all such forms and that any documentation,
+ * advertising materials, and other materials related to such
+ * distribution and use acknowledge that the software was developed
+ * by the University of California, Berkeley.  The name of the
+ * University may not be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
+ * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
+ * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * Serial Line interface
+ *
+ * Rick Adams
+ * Center for Seismic Studies
+ * 1300 N 17th Street, Suite 1450
+ * Arlington, Virginia 22209
+ * (703)276-7900
+ * rick@seismo.ARPA
+ * seismo!rick
+ *
+ * Pounded on heavily by Chris Torek (chris@mimsy.umd.edu, umcp-cs!chris).
+ * Converted to 4.3BSD Beta by Chris Torek.
+ * Other changes made at Berkeley, based in part on code by Kirk Smith.
+ *
+ * Converted to 4.3BSD+ 386BSD by Brad Parker (brad@cayman.com)
+ * Added VJ tcp header compression; more unified ioctls
+ *
+ * Extensively modified by Paul Mackerras (paulus@cs.anu.edu.au).
+ * Cleaned up a lot of the mbuf-related code to fix bugs that
+ * caused system crashes and packet corruption.  Changed pppstart
+ * so that it doesn't just give up with a collision if the whole
+ * packet doesn't fit in the output ring buffer.
+ *
+ * Added priority queueing for interactive IP packets, following
+ * the model of if_sl.c, plus hooks for bpf.
+ * Paul Mackerras (paulus@cs.anu.edu.au).
+ */
+
+/* from if_sl.c,v 1.11 84/10/04 12:54:47 rick Exp */
+/* from NetBSD: if_ppp.c,v 1.15.2.2 1994/07/28 05:17:58 cgd Exp */
+
+#include "ppp.h"
+#if NPPP > 0
+
+#define VJC
+#define PPP_COMPRESS
+
+#include <sys/param.h>
+#include <sys/proc.h>
+#include <sys/mbuf.h>
+#include <sys/socket.h>
+#include <sys/ioctl.h>
+#include <sys/kernel.h>
+
+#ifdef i386
+#include <machine/psl.h>
+#endif
+
+#include <net/if.h>
+#include <net/if_types.h>
+#include <net/netisr.h>
+#include <net/route.h>
+
+#if INET
+#include <netinet/in.h>
+#include <netinet/in_systm.h>
+#include <netinet/in_var.h>
+#include <netinet/ip.h>
+#endif
+
+#include "bpfilter.h"
+#if NBPFILTER > 0
+#include <sys/time.h>
+#include <net/bpf.h>
+#endif
+
+#ifdef VJC
+#include <net/slcompress.h>
+#endif
+
+#include <net/ppp_defs.h>
+#include <net/if_ppp.h>
+#include <net/if_pppvar.h>
+#include <machine/cpu.h>
+
+#ifdef PPP_COMPRESS
+#define PACKETPTR      struct mbuf *
+#include <net/ppp-comp.h>
+#endif
+
+void   pppattach __P((void));
+int    pppioctl __P((struct ppp_softc *sc, u_long cmd, caddr_t data, int flag,
+                     struct proc *));
+int    pppoutput __P((struct ifnet *ifp, struct mbuf *m0,
+                      struct sockaddr *dst, struct rtentry *rtp));
+int    pppsioctl __P((struct ifnet *ifp, u_long cmd, caddr_t data));
+void   pppintr __P((void));
+
+static void    ppp_requeue __P((struct ppp_softc *));
+static void    ppp_outpkt __P((struct ppp_softc *));
+static int     ppp_ccp __P((struct ppp_softc *, struct mbuf *m, int rcvd));
+static void    ppp_ccp_closed __P((struct ppp_softc *));
+static void    ppp_inproc __P((struct ppp_softc *, struct mbuf *));
+static void    pppdumpm __P((struct mbuf *m0));
+
+/*
+ * Some useful mbuf macros not in mbuf.h.
+ */
+#define M_IS_CLUSTER(m)        ((m)->m_flags & M_EXT)
+
+#define M_DATASTART(m) \
+       (M_IS_CLUSTER(m) ? (m)->m_ext.ext_buf : \
+           (m)->m_flags & M_PKTHDR ? (m)->m_pktdat : (m)->m_dat)
+
+#define M_DATASIZE(m)  \
+       (M_IS_CLUSTER(m) ? (m)->m_ext.ext_size : \
+           (m)->m_flags & M_PKTHDR ? MHLEN: MLEN)
+
+/*
+ * We steal two bits in the mbuf m_flags, to mark high-priority packets
+ * for output, and received packets following lost/corrupted packets.
+ */
+#define M_HIGHPRI      0x2000  /* output packet for sc_fastq */
+#define M_ERRMARK      0x4000  /* steal a bit in mbuf m_flags */
+
+
+#ifdef PPP_COMPRESS
+/*
+ * List of compressors we know about.
+ * We leave some space so maybe we can modload compressors.
+ */
+
+extern struct compressor ppp_bsd_compress;
+
+struct compressor *ppp_compressors[8] = {
+#if DO_BSD_COMPRESS
+    &ppp_bsd_compress,
+#endif
+    NULL
+};
+#endif /* PPP_COMPRESS */
+
+/*
+ * Called from boot code to establish ppp interfaces.
+ */
+void
+pppattach()
+{
+    register struct ppp_softc *sc;
+    register int i = 0;
+
+    for (sc = ppp_softc; i < NPPP; sc++) {
+       sc->sc_if.if_name = "ppp";
+       sc->sc_if.if_unit = i++;
+       sc->sc_if.if_mtu = PPP_MTU;
+       sc->sc_if.if_flags = IFF_POINTOPOINT | IFF_MULTICAST;
+       sc->sc_if.if_type = IFT_PPP;
+       sc->sc_if.if_hdrlen = PPP_HDRLEN;
+       sc->sc_if.if_ioctl = pppsioctl;
+       sc->sc_if.if_output = pppoutput;
+       sc->sc_if.if_snd.ifq_maxlen = IFQ_MAXLEN;
+       sc->sc_inq.ifq_maxlen = IFQ_MAXLEN;
+       sc->sc_fastq.ifq_maxlen = IFQ_MAXLEN;
+       sc->sc_rawq.ifq_maxlen = IFQ_MAXLEN;
+       if_attach(&sc->sc_if);
+#if NBPFILTER > 0
+       bpfattach(&sc->sc_bpf, &sc->sc_if, DLT_PPP, PPP_HDRLEN);
+#endif
+    }
+
+}
+
+/*
+ * Allocate a ppp interface unit and initialize it.
+ */
+struct ppp_softc *
+pppalloc(pid)
+    pid_t pid;
+{
+    int nppp, i;
+    struct ppp_softc *sc;
+
+    for (nppp = 0, sc = ppp_softc; nppp < NPPP; nppp++, sc++)
+       if (sc->sc_xfer == pid) {
+           sc->sc_xfer = 0;
+           return sc;
+       }
+    for (nppp = 0, sc = ppp_softc; nppp < NPPP; nppp++, sc++)
+       if (sc->sc_devp == NULL)
+           break;
+    if (nppp >= NPPP)
+       return NULL;
+
+    sc->sc_flags = 0;
+    sc->sc_mru = PPP_MRU;
+    sc->sc_relinq = NULL;
+#ifdef VJC
+    sl_compress_init(&sc->sc_comp, -1);
+#endif
+#ifdef PPP_COMPRESS
+    sc->sc_xc_state = NULL;
+    sc->sc_rc_state = NULL;
+#endif /* PPP_COMPRESS */
+    for (i = 0; i < NUM_NP; ++i)
+       sc->sc_npmode[i] = NPMODE_ERROR;
+    sc->sc_npqueue = NULL;
+    sc->sc_npqtail = &sc->sc_npqueue;
+    sc->sc_last_sent = sc->sc_last_recv = time.tv_sec;
+
+    return sc;
+}
+
+/*
+ * Deallocate a ppp unit.  Must be called at splsoftnet or higher.
+ */
+void
+pppdealloc(sc)
+    struct ppp_softc *sc;
+{
+    struct mbuf *m;
+
+    if_down(&sc->sc_if);
+    sc->sc_if.if_flags &= ~(IFF_UP|IFF_RUNNING);
+    sc->sc_devp = NULL;
+    sc->sc_xfer = 0;
+    for (;;) {
+       IF_DEQUEUE(&sc->sc_rawq, m);
+       if (m == NULL)
+           break;
+       m_freem(m);
+    }
+    for (;;) {
+       IF_DEQUEUE(&sc->sc_inq, m);
+       if (m == NULL)
+           break;
+       m_freem(m);
+    }
+    for (;;) {
+       IF_DEQUEUE(&sc->sc_fastq, m);
+       if (m == NULL)
+           break;
+       m_freem(m);
+    }
+    while ((m = sc->sc_npqueue) != NULL) {
+       sc->sc_npqueue = m->m_nextpkt;
+       m_freem(m);
+    }
+    if (sc->sc_togo != NULL) {
+       m_freem(sc->sc_togo);
+       sc->sc_togo = NULL;
+    }
+#ifdef PPP_COMPRESS
+    ppp_ccp_closed(sc);
+    sc->sc_xc_state = NULL;
+    sc->sc_rc_state = NULL;
+#endif /* PPP_COMPRESS */
+}
+
+/*
+ * Ioctl routine for generic ppp devices.
+ */
+int
+pppioctl(sc, cmd, data, flag, p)
+    struct ppp_softc *sc;
+    u_long cmd;
+    caddr_t data;
+    int flag;
+    struct proc *p;
+{
+    int s, error, flags, mru, nb, npx;
+    struct ppp_option_data *odp;
+    struct compressor **cp;
+    struct npioctl *npi;
+    time_t t;
+#ifdef PPP_COMPRESS
+    u_char ccp_option[CCP_MAX_OPTION_LENGTH];
+#endif
+
+    switch (cmd) {
+    case FIONREAD:
+       *(int *)data = sc->sc_inq.ifq_len;
+       break;
+
+    case PPPIOCGUNIT:
+       *(int *)data = sc->sc_if.if_unit;
+       break;
+
+    case PPPIOCGFLAGS:
+       *(u_int *)data = sc->sc_flags;
+       break;
+
+    case PPPIOCSFLAGS:
+       if (error = suser(p->p_ucred, &p->p_acflag))
+           return (error);
+       flags = *(int *)data & SC_MASK;
+       s = splsoftnet();
+#ifdef PPP_COMPRESS
+       if (sc->sc_flags & SC_CCP_OPEN && !(flags & SC_CCP_OPEN))
+           ppp_ccp_closed(sc);
+#endif
+       splhigh();
+       sc->sc_flags = (sc->sc_flags & ~SC_MASK) | flags;
+       splx(s);
+       break;
+
+    case PPPIOCSMRU:
+       if (error = suser(p->p_ucred, &p->p_acflag))
+           return (error);
+       mru = *(int *)data;
+       if (mru >= PPP_MRU && mru <= PPP_MAXMRU)
+           sc->sc_mru = mru;
+       break;
+
+    case PPPIOCGMRU:
+       *(int *)data = sc->sc_mru;
+       break;
+
+#ifdef VJC
+    case PPPIOCSMAXCID:
+       if (error = suser(p->p_ucred, &p->p_acflag))
+           return (error);
+       s = splsoftnet();
+       sl_compress_init(&sc->sc_comp, *(int *)data);
+       splx(s);
+       break;
+#endif
+
+    case PPPIOCXFERUNIT:
+       if (error = suser(p->p_ucred, &p->p_acflag))
+           return (error);
+       sc->sc_xfer = p->p_pid;
+       break;
+
+#ifdef PPP_COMPRESS
+    case PPPIOCSCOMPRESS:
+       if (error = suser(p->p_ucred, &p->p_acflag))
+           return (error);
+       odp = (struct ppp_option_data *) data;
+       nb = odp->length;
+       if (nb > sizeof(ccp_option))
+           nb = sizeof(ccp_option);
+       if (error = copyin(odp->ptr, ccp_option, nb))
+           return (error);
+       if (ccp_option[1] < 2)  /* preliminary check on the length byte */
+           return (EINVAL);
+       for (cp = ppp_compressors; *cp != NULL; ++cp)
+           if ((*cp)->compress_proto == ccp_option[0]) {
+               /*
+                * Found a handler for the protocol - try to allocate
+                * a compressor or decompressor.
+                */
+               error = 0;
+               if (odp->transmit) {
+                   s = splsoftnet();
+                   if (sc->sc_xc_state != NULL)
+                       (*sc->sc_xcomp->comp_free)(sc->sc_xc_state);
+                   sc->sc_xcomp = *cp;
+                   sc->sc_xc_state = (*cp)->comp_alloc(ccp_option, nb);
+                   if (sc->sc_xc_state == NULL) {
+                       if (sc->sc_flags & SC_DEBUG)
+                           printf("ppp%d: comp_alloc failed\n",
+                              sc->sc_if.if_unit);
+                       error = ENOBUFS;
+                   }
+                   splhigh();
+                   sc->sc_flags &= ~SC_COMP_RUN;
+                   splx(s);
+               } else {
+                   s = splsoftnet();
+                   if (sc->sc_rc_state != NULL)
+                       (*sc->sc_rcomp->decomp_free)(sc->sc_rc_state);
+                   sc->sc_rcomp = *cp;
+                   sc->sc_rc_state = (*cp)->decomp_alloc(ccp_option, nb);
+                   if (sc->sc_rc_state == NULL) {
+                       if (sc->sc_flags & SC_DEBUG)
+                           printf("ppp%d: decomp_alloc failed\n",
+                              sc->sc_if.if_unit);
+                       error = ENOBUFS;
+                   }
+                   splhigh();
+                   sc->sc_flags &= ~SC_DECOMP_RUN;
+                   splx(s);
+               }
+               return (error);
+           }
+       if (sc->sc_flags & SC_DEBUG)
+           printf("ppp%d: no compressor for [%x %x %x], %x\n",
+                  sc->sc_if.if_unit, ccp_option[0], ccp_option[1],
+                  ccp_option[2], nb);
+       return (EINVAL);        /* no handler found */
+#endif /* PPP_COMPRESS */
+
+    case PPPIOCGNPMODE:
+    case PPPIOCSNPMODE:
+       npi = (struct npioctl *) data;
+       switch (npi->protocol) {
+       case PPP_IP:
+           npx = NP_IP;
+           break;
+       default:
+           return EINVAL;
+       }
+       if (cmd == PPPIOCGNPMODE) {
+           npi->mode = sc->sc_npmode[npx];
+       } else {
+           if (error = suser(p->p_ucred, &p->p_acflag))
+               return (error);
+           if (npi->mode != sc->sc_npmode[npx]) {
+               s = splsoftnet();
+               sc->sc_npmode[npx] = npi->mode;
+               if (npi->mode != NPMODE_QUEUE) {
+                   ppp_requeue(sc);
+                   (*sc->sc_start)(sc);
+               }
+               splx(s);
+           }
+       }
+       break;
+
+    case PPPIOCGIDLE:
+       s = splsoftnet();
+       t = time.tv_sec;
+       ((struct ppp_idle *)data)->xmit_idle = t - sc->sc_last_sent;
+       ((struct ppp_idle *)data)->recv_idle = t - sc->sc_last_recv;
+       splx(s);
+       break;
+
+    default:
+       return (-1);
+    }
+    return (0);
+}
+
+/*
+ * Process an ioctl request to the ppp network interface.
+ */
+int
+pppsioctl(ifp, cmd, data)
+    register struct ifnet *ifp;
+    u_long cmd;
+    caddr_t data;
+{
+    struct proc *p = curproc;  /* XXX */
+    register struct ppp_softc *sc = &ppp_softc[ifp->if_unit];
+    register struct ifaddr *ifa = (struct ifaddr *)data;
+    register struct ifreq *ifr = (struct ifreq *)data;
+    struct ppp_stats *psp;
+#ifdef PPP_COMPRESS
+    struct ppp_comp_stats *pcp;
+#endif
+    int s = splimp(), error = 0;
+
+    switch (cmd) {
+    case SIOCSIFFLAGS:
+       if ((ifp->if_flags & IFF_RUNNING) == 0)
+           ifp->if_flags &= ~IFF_UP;
+       break;
+
+    case SIOCSIFADDR:
+       if (ifa->ifa_addr->sa_family != AF_INET)
+           error = EAFNOSUPPORT;
+       break;
+
+    case SIOCSIFDSTADDR:
+       if (ifa->ifa_addr->sa_family != AF_INET)
+           error = EAFNOSUPPORT;
+       break;
+
+    case SIOCSIFMTU:
+       if (error = suser(p->p_ucred, &p->p_acflag))
+           break;
+       sc->sc_if.if_mtu = ifr->ifr_mtu;
+       break;
+
+    case SIOCGIFMTU:
+       ifr->ifr_mtu = sc->sc_if.if_mtu;
+       break;
+
+    case SIOCADDMULTI:
+    case SIOCDELMULTI:
+       switch(ifr->ifr_addr.sa_family) {
+#ifdef INET
+       case AF_INET:
+           break;
+#endif
+       default:
+           error = EAFNOSUPPORT;
+           break;
+       }
+       break;
+
+    case SIOCGPPPSTATS:
+       psp = &((struct ifpppstatsreq *) data)->stats;
+       bzero(psp, sizeof(*psp));
+       psp->p.ppp_ibytes = sc->sc_bytesrcvd;
+       psp->p.ppp_ipackets = ifp->if_ipackets;
+       psp->p.ppp_ierrors = ifp->if_ierrors;
+       psp->p.ppp_obytes = sc->sc_bytessent;
+       psp->p.ppp_opackets = ifp->if_opackets;
+       psp->p.ppp_oerrors = ifp->if_oerrors;
+#ifdef VJC
+       psp->vj.vjs_packets = sc->sc_comp.sls_packets;
+       psp->vj.vjs_compressed = sc->sc_comp.sls_compressed;
+       psp->vj.vjs_searches = sc->sc_comp.sls_searches;
+       psp->vj.vjs_misses = sc->sc_comp.sls_misses;
+       psp->vj.vjs_uncompressedin = sc->sc_comp.sls_uncompressedin;
+       psp->vj.vjs_compressedin = sc->sc_comp.sls_compressedin;
+       psp->vj.vjs_errorin = sc->sc_comp.sls_errorin;
+       psp->vj.vjs_tossed = sc->sc_comp.sls_tossed;
+#endif /* VJC */
+       break;
+
+#ifdef PPP_COMPRESS
+    case SIOCGPPPCSTATS:
+       pcp = &((struct ifpppcstatsreq *) data)->stats;
+       bzero(pcp, sizeof(*pcp));
+       if (sc->sc_xc_state != NULL)
+           (*sc->sc_xcomp->comp_stat)(sc->sc_xc_state, &pcp->c);
+       if (sc->sc_rc_state != NULL)
+           (*sc->sc_rcomp->decomp_stat)(sc->sc_rc_state, &pcp->d);
+       break;
+#endif /* PPP_COMPRESS */
+
+    default:
+       error = EINVAL;
+    }
+    splx(s);
+    return (error);
+}
+
+/*
+ * Queue a packet.  Start transmission if not active.
+ * Packet is placed in Information field of PPP frame.
+ */
+int
+pppoutput(ifp, m0, dst, rtp)
+    struct ifnet *ifp;
+    struct mbuf *m0;
+    struct sockaddr *dst;
+    struct rtentry *rtp;
+{
+    register struct ppp_softc *sc = &ppp_softc[ifp->if_unit];
+    struct ppp_header *ph;
+    int protocol, address, control;
+    u_char *cp;
+    int s, error;
+    struct ip *ip;
+    struct ifqueue *ifq;
+    enum NPmode mode;
+
+    if (sc->sc_devp == NULL || (ifp->if_flags & IFF_RUNNING) == 0
+       || (ifp->if_flags & IFF_UP) == 0 && dst->sa_family != AF_UNSPEC) {
+       error = ENETDOWN;       /* sort of */
+       goto bad;
+    }
+
+    /*
+     * Compute PPP header.
+     */
+    m0->m_flags &= ~M_HIGHPRI;
+    switch (dst->sa_family) {
+#ifdef INET
+    case AF_INET:
+       address = PPP_ALLSTATIONS;
+       control = PPP_UI;
+       protocol = PPP_IP;
+       mode = sc->sc_npmode[NP_IP];
+
+       /*
+        * If this packet has the "low delay" bit set in the IP header,
+        * put it on the fastq instead.
+        */
+       ip = mtod(m0, struct ip *);
+       if (ip->ip_tos & IPTOS_LOWDELAY)
+           m0->m_flags |= M_HIGHPRI;
+       break;
+#endif
+    case AF_UNSPEC:
+       address = PPP_ADDRESS(dst->sa_data);
+       control = PPP_CONTROL(dst->sa_data);
+       protocol = PPP_PROTOCOL(dst->sa_data);
+       mode = NPMODE_PASS;
+       break;
+    default:
+       printf("ppp%d: af%d not supported\n", ifp->if_unit, dst->sa_family);
+       error = EAFNOSUPPORT;
+       goto bad;
+    }
+
+    /*
+     * Drop this packet, or return an error, if necessary.
+     */
+    if (mode == NPMODE_ERROR) {
+       error = ENETDOWN;
+       goto bad;
+    }
+    if (mode == NPMODE_DROP) {
+       error = 0;
+       goto bad;
+    }
+
+    /*
+     * Add PPP header.  If no space in first mbuf, allocate another.
+     * (This assumes M_LEADINGSPACE is always 0 for a cluster mbuf.)
+     */
+    if (M_LEADINGSPACE(m0) < PPP_HDRLEN) {
+       m0 = m_prepend(m0, PPP_HDRLEN, M_DONTWAIT);
+       if (m0 == 0) {
+           error = ENOBUFS;
+           goto bad;
+       }
+       m0->m_len = 0;
+    } else
+       m0->m_data -= PPP_HDRLEN;
+
+    cp = mtod(m0, u_char *);
+    *cp++ = address;
+    *cp++ = control;
+    *cp++ = protocol >> 8;
+    *cp++ = protocol & 0xff;
+    m0->m_len += PPP_HDRLEN;
+
+    if (sc->sc_flags & SC_LOG_OUTPKT) {
+       printf("ppp%d output: ", ifp->if_unit);
+       pppdumpm(m0);
+    }
+
+#if NBPFILTER > 0
+    /*
+     * See if bpf wants to look at the packet.
+     */
+    if (sc->sc_bpf)
+       bpf_mtap(sc->sc_bpf, m0);
+#endif
+
+    /*
+     * Put the packet on the appropriate queue.
+     */
+    s = splsoftnet();
+    if (mode == NPMODE_QUEUE) {
+       /* XXX we should limit the number of packets on this queue */
+       *sc->sc_npqtail = m0;
+       m0->m_nextpkt = NULL;
+       sc->sc_npqtail = &m0->m_nextpkt;
+    } else {
+       ifq = (m0->m_flags & M_HIGHPRI)? &sc->sc_fastq: &ifp->if_snd;
+       if (IF_QFULL(ifq) && dst->sa_family != AF_UNSPEC) {
+           IF_DROP(ifq);
+           splx(s);
+           sc->sc_if.if_oerrors++;
+           error = ENOBUFS;
+           goto bad;
+       }
+       IF_ENQUEUE(ifq, m0);
+       (*sc->sc_start)(sc);
+    }
+    ifp->if_lastchange = time;
+
+    splx(s);
+    return (0);
+
+bad:
+    m_freem(m0);
+    return (error);
+}
+
+/*
+ * After a change in the NPmode for some NP, move packets from the
+ * npqueue to the send queue or the fast queue as appropriate.
+ * Should be called at splsoftnet.
+ */
+static void
+ppp_requeue(sc)
+    struct ppp_softc *sc;
+{
+    struct mbuf *m, **mpp;
+    struct ifqueue *ifq;
+    enum NPmode mode;
+
+    for (mpp = &sc->sc_npqueue; (m = *mpp) != NULL; ) {
+       switch (PPP_PROTOCOL(mtod(m, u_char *))) {
+       case PPP_IP:
+           mode = sc->sc_npmode[NP_IP];
+           break;
+       default:
+           mode = NPMODE_PASS;
+       }
+
+       switch (mode) {
+       case NPMODE_PASS:
+           /*
+            * This packet can now go on one of the queues to be sent.
+            */
+           *mpp = m->m_nextpkt;
+           m->m_nextpkt = NULL;
+           ifq = (m->m_flags & M_HIGHPRI)? &sc->sc_fastq: &sc->sc_if.if_snd;
+           if (IF_QFULL(ifq)) {
+               IF_DROP(ifq);
+               sc->sc_if.if_oerrors++;
+           } else
+               IF_ENQUEUE(ifq, m);
+           break;
+
+       case NPMODE_DROP:
+       case NPMODE_ERROR:
+           *mpp = m->m_nextpkt;
+           m_freem(m);
+           break;
+
+       case NPMODE_QUEUE:
+           mpp = &m->m_nextpkt;
+           break;
+       }
+    }
+    sc->sc_npqtail = mpp;
+}
+
+/*
+ * Get a packet to send.  This procedure is intended to be called at
+ * spltty or splimp, so it takes little time.  If there isn't a packet
+ * waiting to go out, it schedules a software interrupt to prepare a
+ * new packet; the device start routine gets called again when a
+ * packet is ready.
+ */
+struct mbuf *
+ppp_dequeue(sc)
+    struct ppp_softc *sc;
+{
+    struct mbuf *m;
+    int s = splhigh();
+
+    m = sc->sc_togo;
+    if (m) {
+       /*
+        * Had a packet waiting - send it.
+        */
+       sc->sc_togo = NULL;
+       sc->sc_flags |= SC_TBUSY;
+       splx(s);
+       return m;
+    }
+    /*
+     * Remember we wanted a packet and schedule a software interrupt.
+     */
+    sc->sc_flags &= ~SC_TBUSY;
+    schednetisr(NETISR_PPP);
+    splx(s);
+    return NULL;
+}
+
+/*
+ * Software interrupt routine, called at splsoftnet.
+ */
+void
+pppintr()
+{
+    struct ppp_softc *sc;
+    int i, s;
+    struct mbuf *m;
+
+    sc = ppp_softc;
+    for (i = 0; i < NPPP; ++i, ++sc) {
+       if (!(sc->sc_flags & SC_TBUSY) && sc->sc_togo == NULL
+           && (sc->sc_if.if_snd.ifq_head || sc->sc_fastq.ifq_head))
+           ppp_outpkt(sc);
+       for (;;) {
+           s = splhigh();
+           IF_DEQUEUE(&sc->sc_rawq, m);
+           splx(s);
+           if (m == NULL)
+               break;
+           ppp_inproc(sc, m);
+       }
+    }
+}
+
+/*
+ * Grab another packet off a queue and apply VJ compression,
+ * packet compression, address/control and/or protocol compression
+ * if enabled.  Should be called at splsoftnet.
+ */
+static void
+ppp_outpkt(sc)
+    struct ppp_softc *sc;
+{
+    int s;
+    struct mbuf *m, *mp;
+    u_char *cp;
+    int address, control, protocol;
+    enum NPmode mode;
+
+    /*
+     * Grab a packet to send: first try the fast queue, then the
+     * normal queue.
+     */
+    IF_DEQUEUE(&sc->sc_fastq, m);
+    if (m == NULL)
+       IF_DEQUEUE(&sc->sc_if.if_snd, m);
+    if (m == NULL)
+       return;
+
+    /*
+     * Extract the ppp header of the new packet.
+     * The ppp header will be in one mbuf.
+     */
+    cp = mtod(m, u_char *);
+    address = PPP_ADDRESS(cp);
+    control = PPP_CONTROL(cp);
+    protocol = PPP_PROTOCOL(cp);
+
+    switch (protocol) {
+    case PPP_IP:
+       /*
+        * Update the time we sent the most recent packet.
+        */
+       sc->sc_last_sent = time.tv_sec;
+
+#ifdef VJC
+       /*
+        * If the packet is a TCP/IP packet, see if we can compress it.
+        */
+       if (sc->sc_flags & SC_COMP_TCP) {
+           struct ip *ip;
+           int type;
+
+           mp = m;
+           ip = (struct ip *) (cp + PPP_HDRLEN);
+           if (mp->m_len <= PPP_HDRLEN) {
+               mp = mp->m_next;
+               if (mp == NULL)
+                   break;
+               ip = mtod(mp, struct ip *);
+           }
+           /* this code assumes the IP/TCP header is in one non-shared mbuf */
+           if (ip->ip_p == IPPROTO_TCP) {
+               type = sl_compress_tcp(mp, ip, &sc->sc_comp,
+                                      !(sc->sc_flags & SC_NO_TCP_CCID));
+               switch (type) {
+               case TYPE_UNCOMPRESSED_TCP:
+                   protocol = PPP_VJC_UNCOMP;
+                   break;
+               case TYPE_COMPRESSED_TCP:
+                   protocol = PPP_VJC_COMP;
+                   cp = mtod(m, u_char *);
+                   cp[0] = address;    /* header has moved */
+                   cp[1] = control;
+                   cp[2] = 0;
+                   break;
+               }
+               cp[3] = protocol;       /* update protocol in PPP header */
+           }
+       }
+#endif /* VJC */
+       break;
+
+#ifdef PPP_COMPRESS
+    case PPP_CCP:
+       ppp_ccp(sc, m, 0);
+       break;
+#endif /* PPP_COMPRESS */
+    }
+
+#ifdef PPP_COMPRESS
+    if (protocol != PPP_LCP && protocol != PPP_CCP
+       && sc->sc_xc_state && (sc->sc_flags & SC_COMP_RUN)) {
+       struct mbuf *mcomp = NULL;
+       int slen, clen;
+
+       slen = 0;
+       for (mp = m; mp != NULL; mp = mp->m_next)
+           slen += mp->m_len;
+       clen = (*sc->sc_xcomp->compress)
+           (sc->sc_xc_state, &mcomp, m, slen,
+            (sc->sc_flags & SC_CCP_UP? sc->sc_if.if_mtu: 0));
+       if (mcomp != NULL) {
+           m_freem(m);
+           m = mcomp;
+           cp = mtod(m, u_char *);
+           protocol = cp[3];
+       }
+    }
+#endif /* PPP_COMPRESS */
+
+    /*
+     * Compress the address/control and protocol, if possible.
+     */
+    if (sc->sc_flags & SC_COMP_AC && address == PPP_ALLSTATIONS &&
+       control == PPP_UI && protocol != PPP_ALLSTATIONS &&
+       protocol != PPP_LCP) {
+       /* can compress address/control */
+       m->m_data += 2;
+       m->m_len -= 2;
+    }
+    if (sc->sc_flags & SC_COMP_PROT && protocol < 0xFF) {
+       /* can compress protocol */
+       if (mtod(m, u_char *) == cp) {
+           cp[2] = cp[1];      /* move address/control up */
+           cp[1] = cp[0];
+       }
+       ++m->m_data;
+       --m->m_len;
+    }
+
+    sc->sc_togo = m;
+    (*sc->sc_start)(sc);
+}
+
+#ifdef PPP_COMPRESS
+/*
+ * Handle a CCP packet.  `rcvd' is 1 if the packet was received,
+ * 0 if it is about to be transmitted.
+ */
+static int
+ppp_ccp(sc, m, rcvd)
+    struct ppp_softc *sc;
+    struct mbuf *m;
+    int rcvd;
+{
+    u_char *dp, *ep;
+    struct mbuf *mp;
+    int slen, s;
+
+    /*
+     * Get a pointer to the data after the PPP header.
+     */
+    if (m->m_len <= PPP_HDRLEN) {
+       mp = m->m_next;
+       if (mp == NULL)
+           return;
+       dp = (mp != NULL)? mtod(mp, u_char *): NULL;
+    } else {
+       mp = m;
+       dp = mtod(mp, u_char *) + PPP_HDRLEN;
+    }
+
+    ep = mtod(mp, u_char *) + mp->m_len;
+    if (dp + CCP_HDRLEN > ep)
+       return;
+    slen = CCP_LENGTH(dp);
+    if (dp + slen > ep) {
+       if (sc->sc_flags & SC_DEBUG)
+           printf("if_ppp/ccp: not enough data in mbuf (%x+%x > %x+%x)\n",
+                  dp, slen, mtod(mp, u_char *), mp->m_len);
+       return;
+    }
+
+    switch (CCP_CODE(dp)) {
+    case CCP_CONFREQ:
+    case CCP_TERMREQ:
+    case CCP_TERMACK:
+       /* CCP must be going down - disable compression */
+       if (sc->sc_flags & SC_CCP_UP) {
+           s = splhigh();
+           sc->sc_flags &= ~(SC_CCP_UP | SC_COMP_RUN | SC_DECOMP_RUN);
+           splx(s);
+       }
+       break;
+
+    case CCP_CONFACK:
+       if (sc->sc_flags & SC_CCP_OPEN && !(sc->sc_flags & SC_CCP_UP)
+           && slen >= CCP_HDRLEN + CCP_OPT_MINLEN
+           && slen >= CCP_OPT_LENGTH(dp + CCP_HDRLEN) + CCP_HDRLEN) {
+           if (!rcvd) {
+               /* we're agreeing to send compressed packets. */
+               if (sc->sc_xc_state != NULL
+                   && (*sc->sc_xcomp->comp_init)
+                       (sc->sc_xc_state, dp + CCP_HDRLEN, slen - CCP_HDRLEN,
+                        sc->sc_if.if_unit, 0, sc->sc_flags & SC_DEBUG)) {
+                   s = splhigh();
+                   sc->sc_flags |= SC_COMP_RUN;
+                   splx(s);
+               }
+           } else {
+               /* peer is agreeing to send compressed packets. */
+               if (sc->sc_rc_state != NULL
+                   && (*sc->sc_rcomp->decomp_init)
+                       (sc->sc_rc_state, dp + CCP_HDRLEN, slen - CCP_HDRLEN,
+                        sc->sc_if.if_unit, 0, sc->sc_mru,
+                        sc->sc_flags & SC_DEBUG)) {
+                   s = splhigh();
+                   sc->sc_flags |= SC_DECOMP_RUN;
+                   sc->sc_flags &= ~(SC_DC_ERROR | SC_DC_FERROR);
+                   splx(s);
+               }
+           }
+       }
+       break;
+
+    case CCP_RESETACK:
+       if (sc->sc_flags & SC_CCP_UP) {
+           if (!rcvd) {
+               if (sc->sc_xc_state && (sc->sc_flags & SC_COMP_RUN))
+                   (*sc->sc_xcomp->comp_reset)(sc->sc_xc_state);
+           } else {
+               if (sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)) {
+                   (*sc->sc_rcomp->decomp_reset)(sc->sc_rc_state);
+                   s = splhigh();
+                   sc->sc_flags &= ~SC_DC_ERROR;
+                   splx(s);
+               }
+           }
+       }
+       break;
+    }
+}
+
+/*
+ * CCP is down; free (de)compressor state if necessary.
+ */
+static void
+ppp_ccp_closed(sc)
+    struct ppp_softc *sc;
+{
+    if (sc->sc_xc_state) {
+       (*sc->sc_xcomp->comp_free)(sc->sc_xc_state);
+       sc->sc_xc_state = NULL;
+    }
+    if (sc->sc_rc_state) {
+       (*sc->sc_rcomp->decomp_free)(sc->sc_rc_state);
+       sc->sc_rc_state = NULL;
+    }
+}
+#endif /* PPP_COMPRESS */
+
+/*
+ * PPP packet input routine.
+ * The caller has checked and removed the FCS and has inserted
+ * the address/control bytes and the protocol high byte if they
+ * were omitted.
+ */
+void
+ppppktin(sc, m, lost)
+    struct ppp_softc *sc;
+    struct mbuf *m;
+    int lost;
+{
+    int s = splhigh();
+
+    if (lost)
+       m->m_flags |= M_ERRMARK;
+    IF_ENQUEUE(&sc->sc_rawq, m);
+    schednetisr(NETISR_PPP);
+    splx(s);
+}
+
+/*
+ * Process a received PPP packet, doing decompression as necessary.
+ * Should be called at splsoftnet.
+ */
+#define COMPTYPE(proto)        ((proto) == PPP_VJC_COMP? TYPE_COMPRESSED_TCP: \
+                        TYPE_UNCOMPRESSED_TCP)
+
+static void
+ppp_inproc(sc, m)
+    struct ppp_softc *sc;
+    struct mbuf *m;
+{
+    struct ifnet *ifp = &sc->sc_if;
+    struct ifqueue *inq;
+    int s, ilen, xlen, proto, rv;
+    u_char *cp, adrs, ctrl;
+    struct mbuf *mp, *dmp = NULL;
+    u_char *iphdr;
+    u_int hlen;
+
+    ifp->if_ipackets++;
+    ifp->if_lastchange = time;
+
+    if (sc->sc_flags & SC_LOG_INPKT) {
+       ilen = 0;
+       for (mp = m; mp != NULL; mp = mp->m_next)
+           ilen += mp->m_len;
+       printf("ppp%d: got %d bytes\n", ifp->if_unit, ilen);
+       pppdumpm(m);
+    }
+
+    cp = mtod(m, u_char *);
+    adrs = PPP_ADDRESS(cp);
+    ctrl = PPP_CONTROL(cp);
+    proto = PPP_PROTOCOL(cp);
+
+    if (m->m_flags & M_ERRMARK) {
+       m->m_flags &= ~M_ERRMARK;
+       s = splhigh();
+       sc->sc_flags |= SC_VJ_RESET;
+       splx(s);
+    }
+
+#ifdef PPP_COMPRESS
+    /*
+     * Decompress this packet if necessary, update the receiver's
+     * dictionary, or take appropriate action on a CCP packet.
+     */
+    if (proto == PPP_COMP && sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)
+       && !(sc->sc_flags & SC_DC_ERROR) && !(sc->sc_flags & SC_DC_FERROR)) {
+       /* decompress this packet */
+       rv = (*sc->sc_rcomp->decompress)(sc->sc_rc_state, m, &dmp);
+       if (rv == DECOMP_OK) {
+           m_freem(m);
+           if (dmp == NULL) {
+               /* no error, but no decompressed packet produced */
+               return;
+           }
+           m = dmp;
+           cp = mtod(m, u_char *);
+           proto = PPP_PROTOCOL(cp);
+
+       } else {
+           /*
+            * An error has occurred in decompression.
+            * Pass the compressed packet up to pppd, which may take
+            * CCP down or issue a Reset-Req.
+            */
+           if (sc->sc_flags & SC_DEBUG)
+               printf("ppp%d: decompress failed %d\n", ifp->if_unit, rv);
+           s = splhigh();
+           sc->sc_flags |= SC_VJ_RESET;
+           if (rv == DECOMP_ERROR)
+               sc->sc_flags |= SC_DC_ERROR;
+           else
+               sc->sc_flags |= SC_DC_FERROR;
+           splx(s);
+       }
+
+    } else {
+       if (sc->sc_rc_state && (sc->sc_flags & SC_DECOMP_RUN)) {
+           (*sc->sc_rcomp->incomp)(sc->sc_rc_state, m);
+       }
+       if (proto == PPP_CCP) {
+           ppp_ccp(sc, m, 1);
+       }
+    }
+#endif
+
+    ilen = 0;
+    for (mp = m; mp != NULL; mp = mp->m_next)
+       ilen += mp->m_len;
+
+#ifdef VJC
+    if (sc->sc_flags & SC_VJ_RESET) {
+       /*
+        * If we've missed a packet, we must toss subsequent compressed
+        * packets which don't have an explicit connection ID.
+        */
+       sl_uncompress_tcp(NULL, 0, TYPE_ERROR, &sc->sc_comp);
+       s = splhigh();
+       sc->sc_flags &= ~SC_VJ_RESET;
+       splx(s);
+    }
+
+    /*
+     * See if we have a VJ-compressed packet to uncompress.
+     */
+    if (proto == PPP_VJC_COMP) {
+       if (sc->sc_flags & SC_REJ_COMP_TCP)
+           goto bad;
+
+       xlen = sl_uncompress_tcp_core(cp + PPP_HDRLEN, m->m_len - PPP_HDRLEN,
+                                     ilen - PPP_HDRLEN, TYPE_COMPRESSED_TCP,
+                                     &sc->sc_comp, &iphdr, &hlen);
+
+       if (xlen <= 0) {
+           if (sc->sc_flags & SC_DEBUG)
+               printf("ppp%d: VJ uncompress failed on type comp\n",
+                       ifp->if_unit);
+           goto bad;
+       }
+
+       /* Copy the PPP and IP headers into a new mbuf. */
+       MGETHDR(mp, M_DONTWAIT, MT_DATA);
+       if (mp == NULL)
+           goto bad;
+       mp->m_len = 0;
+       mp->m_next = NULL;
+       if (hlen + PPP_HDRLEN > MHLEN) {
+           MCLGET(mp, M_DONTWAIT);
+           if (M_TRAILINGSPACE(mp) < hlen + PPP_HDRLEN) {
+               m_freem(mp);
+               goto bad;       /* lose if big headers and no clusters */
+           }
+       }
+       cp = mtod(mp, u_char *);
+       cp[0] = adrs;
+       cp[1] = ctrl;
+       cp[2] = 0;
+       cp[3] = PPP_IP;
+       proto = PPP_IP;
+       bcopy(iphdr, cp + PPP_HDRLEN, hlen);
+       mp->m_len = hlen + PPP_HDRLEN;
+
+       /*
+        * Trim the PPP and VJ headers off the old mbuf
+        * and stick the new and old mbufs together.
+        */
+       m->m_data += PPP_HDRLEN + xlen;
+       m->m_len -= PPP_HDRLEN + xlen;
+       if (m->m_len <= M_TRAILINGSPACE(mp)) {
+           bcopy(mtod(m, u_char *), mtod(mp, u_char *) + mp->m_len, m->m_len);
+           mp->m_len += m->m_len;
+           MFREE(m, mp->m_next);
+       } else
+           mp->m_next = m;
+       m = mp;
+       ilen += hlen - xlen;
+
+    } else if (proto == PPP_VJC_UNCOMP) {
+       if (sc->sc_flags & SC_REJ_COMP_TCP)
+           goto bad;
+
+       xlen = sl_uncompress_tcp_core(cp + PPP_HDRLEN, m->m_len - PPP_HDRLEN,
+                                     ilen - PPP_HDRLEN, TYPE_UNCOMPRESSED_TCP,
+                                     &sc->sc_comp, &iphdr, &hlen);
+
+       if (xlen < 0) {
+           if (sc->sc_flags & SC_DEBUG)
+               printf("ppp%d: VJ uncompress failed on type uncomp\n",
+                       ifp->if_unit);
+           goto bad;
+       }
+
+       proto = PPP_IP;
+       cp[3] = PPP_IP;
+    }
+#endif /* VJC */
+
+    /*
+     * If the packet will fit in a header mbuf, don't waste a
+     * whole cluster on it.
+     */
+    if (ilen <= MHLEN && M_IS_CLUSTER(m)) {
+       MGETHDR(mp, M_DONTWAIT, MT_DATA);
+       if (mp != NULL) {
+           m_copydata(m, 0, ilen, mtod(mp, caddr_t));
+           m_freem(m);
+           m = mp;
+           m->m_len = ilen;
+       }
+    }
+    m->m_pkthdr.len = ilen;
+    m->m_pkthdr.rcvif = ifp;
+
+#if NBPFILTER > 0
+    /* See if bpf wants to look at the packet. */
+    if (sc->sc_bpf)
+       bpf_mtap(sc->sc_bpf, m);
+#endif
+
+    rv = 0;
+    switch (proto) {
+#ifdef INET
+    case PPP_IP:
+       /*
+        * IP packet - take off the ppp header and pass it up to IP.
+        */
+       if ((ifp->if_flags & IFF_UP) == 0
+           || sc->sc_npmode[NP_IP] != NPMODE_PASS) {
+           /* interface is down - drop the packet. */
+           m_freem(m);
+           return;
+       }
+       m->m_pkthdr.len -= PPP_HDRLEN;
+       m->m_data += PPP_HDRLEN;
+       m->m_len -= PPP_HDRLEN;
+       schednetisr(NETISR_IP);
+       inq = &ipintrq;
+       sc->sc_last_recv = time.tv_sec; /* update time of last pkt rcvd */
+       break;
+#endif
+
+    default:
+       /*
+        * Some other protocol - place on input queue for read().
+        */
+       inq = &sc->sc_inq;
+       rv = 1;
+       break;
+    }
+
+    /*
+     * Put the packet on the appropriate input queue.
+     */
+    s = splhigh();
+    if (IF_QFULL(inq)) {
+       IF_DROP(inq);
+       splx(s);
+       if (sc->sc_flags & SC_DEBUG)
+           printf("ppp%d: input queue full\n", ifp->if_unit);
+       ifp->if_iqdrops++;
+       goto bad;
+    }
+    IF_ENQUEUE(inq, m);
+    splx(s);
+
+    if (rv)
+       (*sc->sc_ctlp)(sc);
+
+    return;
+
+ bad:
+    m_freem(m);
+    sc->sc_if.if_ierrors++;
+}
+
+#define MAX_DUMP_BYTES 128
+
+static void
+pppdumpm(m0)
+    struct mbuf *m0;
+{
+    char buf[3*MAX_DUMP_BYTES+4];
+    char *bp = buf;
+    struct mbuf *m;
+    static char digits[] = "0123456789abcdef";
+
+    for (m = m0; m; m = m->m_next) {
+       int l = m->m_len;
+       u_char *rptr = (u_char *)m->m_data;
+
+       while (l--) {
+           if (bp > buf + sizeof(buf) - 4)
+               goto done;
+           *bp++ = digits[*rptr >> 4]; /* convert byte to ascii hex */
+           *bp++ = digits[*rptr++ & 0xf];
+       }
+
+       if (m->m_next) {
+           if (bp > buf + sizeof(buf) - 3)
+               goto done;
+           *bp++ = '|';
+       } else
+           *bp++ = ' ';
+    }
+done:
+    if (m)
+       *bp++ = '>';
+    *bp = 0;
+    printf("%s\n", buf);
+}
+
+#endif /* NPPP > 0 */
diff --git a/netbsd-1.1/if_pppvar.h b/netbsd-1.1/if_pppvar.h
new file mode 100644 (file)
index 0000000..5038dfa
--- /dev/null
@@ -0,0 +1,104 @@
+/*     $Id: if_pppvar.h,v 1.1 1995/12/11 05:17:07 paulus Exp $ */
+/*
+ * if_pppvar.h - private structures and declarations for PPP.
+ *
+ * Copyright (c) 1994 The Australian National University.
+ * All rights reserved.
+ *
+ * Permission to use, copy, modify, and distribute this software and its
+ * documentation is hereby granted, provided that the above copyright
+ * notice appears in all copies.  This software is provided without any
+ * warranty, express or implied. The Australian National University
+ * makes no representations about the suitability of this software for
+ * any purpose.
+ *
+ * IN NO EVENT SHALL THE AUSTRALIAN NATIONAL UNIVERSITY BE LIABLE TO ANY
+ * PARTY FOR DIRECT, INDIRECT, SPECIAL, INCIDENTAL, OR CONSEQUENTIAL DAMAGES
+ * ARISING OUT OF THE USE OF THIS SOFTWARE AND ITS DOCUMENTATION, EVEN IF
+ * THE AUSTRALIAN NATIONAL UNIVERSITY HAVE BEEN ADVISED OF THE POSSIBILITY
+ * OF SUCH DAMAGE.
+ *
+ * THE AUSTRALIAN NATIONAL UNIVERSITY SPECIFICALLY DISCLAIMS ANY WARRANTIES,
+ * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY
+ * AND FITNESS FOR A PARTICULAR PURPOSE.  THE SOFTWARE PROVIDED HEREUNDER IS
+ * ON AN "AS IS" BASIS, AND THE AUSTRALIAN NATIONAL UNIVERSITY HAS NO
+ * OBLIGATION TO PROVIDE MAINTENANCE, SUPPORT, UPDATES, ENHANCEMENTS,
+ * OR MODIFICATIONS.
+ *
+ * Copyright (c) 1989 Carnegie Mellon University.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms are permitted
+ * provided that the above copyright notice and this paragraph are
+ * duplicated in all such forms and that any documentation,
+ * advertising materials, and other materials related to such
+ * distribution and use acknowledge that the software was developed
+ * by Carnegie Mellon University.  The name of the
+ * University may not be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
+ * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
+ * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
+ */
+
+/*
+ * Supported network protocols.  These values are used for
+ * indexing sc_npmode.
+ */
+#define NP_IP  0               /* Internet Protocol */
+#define NUM_NP 1               /* Number of NPs. */
+
+/*
+ * Structure describing each ppp unit.
+ */
+struct ppp_softc {
+       struct  ifnet sc_if;            /* network-visible interface */
+       u_int   sc_flags;               /* control/status bits; see if_ppp.h */
+       void    *sc_devp;               /* pointer to device-dep structure */
+       void    (*sc_start) __P((struct ppp_softc *));  /* start output proc */
+       void    (*sc_ctlp) __P((struct ppp_softc *)); /* rcvd control pkt */
+       void    (*sc_relinq) __P((struct ppp_softc *)); /* relinquish ifunit */
+       u_int16_t sc_mru;               /* max receive unit */
+       pid_t   sc_xfer;                /* used in transferring unit */
+       struct  ifqueue sc_rawq;        /* received packets */
+       struct  ifqueue sc_inq;         /* queue of input packets for daemon */
+       struct  ifqueue sc_fastq;       /* interactive output packet q */
+       struct  mbuf *sc_togo;          /* output packet ready to go */
+       struct  mbuf *sc_npqueue;       /* output packets not to be sent yet */
+       struct  mbuf **sc_npqtail;      /* ptr to last next ptr in npqueue */
+#ifdef VJC
+       struct  slcompress sc_comp;     /* vjc control buffer */
+#endif
+       u_int   sc_bytessent;           /* count of octets sent */
+       u_int   sc_bytesrcvd;           /* count of octets received */
+       caddr_t sc_bpf;                 /* hook for BPF */
+       enum    NPmode sc_npmode[NUM_NP]; /* what to do with each NP */
+       struct  compressor *sc_xcomp;   /* transmit compressor */
+       void    *sc_xc_state;           /* transmit compressor state */
+       struct  compressor *sc_rcomp;   /* receive decompressor */
+       void    *sc_rc_state;           /* receive decompressor state */
+       time_t  sc_last_sent;           /* time (secs) last NP pkt sent */
+       time_t  sc_last_recv;           /* time (secs) last NP pkt rcvd */
+       
+       /* Device-dependent part for async lines. */
+       ext_accm sc_asyncmap;           /* async control character map */
+       u_int32_t sc_rasyncmap;         /* receive async control char map */
+       struct  mbuf *sc_outm;          /* mbuf chain currently being output */
+       struct  mbuf *sc_m;             /* pointer to input mbuf chain */
+       struct  mbuf *sc_mc;            /* pointer to current input mbuf */
+       char    *sc_mp;                 /* ptr to next char in input mbuf */
+       u_int16_t sc_ilen;              /* length of input packet so far */
+       u_int16_t sc_fcs;               /* FCS so far (input) */
+       u_int16_t sc_outfcs;            /* FCS so far for output packet */
+       u_char  sc_rawin[16];           /* chars as received */
+       int     sc_rawin_count;         /* # in sc_rawin */
+};
+
+struct ppp_softc ppp_softc[NPPP];
+
+struct ppp_softc *pppalloc __P((pid_t pid));
+void   pppdealloc __P((struct ppp_softc *sc));
+int    pppioctl __P((struct ppp_softc *sc, u_long cmd, caddr_t data,
+                     int flag, struct proc *p));
+void   ppppktin __P((struct ppp_softc *sc, struct mbuf *m, int lost));
+struct mbuf *ppp_dequeue __P((struct ppp_softc *sc));
diff --git a/netbsd-1.1/kinstall.sh b/netbsd-1.1/kinstall.sh
new file mode 100755 (executable)
index 0000000..41beb85
--- /dev/null
@@ -0,0 +1,83 @@
+#!/bin/sh
+
+# This script modifies the kernel sources in /sys to install
+# ppp-2.2.  It is intended to be run in the ppp-2.2 directory.
+#
+# Paul Mackerras       11-Dec-95
+
+ARCH=$(uname -m)
+CONF=$(uname -v | sed 's/.*(\(.*\)).*/\1/')
+SYS=/sys
+ARCHDIR=$SYS/arch/$ARCH
+CFILE=$ARCHDIR/conf/$CONF
+SRC=netbsd-1.1
+DOCONF=
+DOMAKE=
+
+# Work out whether to use config or config.old
+if grep -q timezone $CFILE; then
+  CONFIG=config.old
+else
+  CONFIG=config
+fi
+
+# Copy new versions of files into /sys/net
+
+for f in net/if_ppp.h net/ppp-comp.h net/ppp_defs.h $SRC/bsd-comp.c \
+        $SRC/if_ppp.c $SRC/if_pppvar.h $SRC/ppp_tty.c \
+        $SRC/slcompress.c $SRC/slcompress.h; do
+  dest=$SYS/net/$(basename $f)
+  if [ -f $dest ]; then
+    if ! cmp -s $f $dest; then
+      echo "Copying $f to $dest"
+      mv -f $dest $dest.orig
+      echo " (old version saved in $dest.orig)"
+      cp $f $dest
+      DOMAKE=yes
+    fi
+  else
+    echo "Copying $f to $dest"
+    cp $f $dest
+    DOMAKE=yes
+  fi
+done
+
+# Tell the user to add a pseudo-device line to the configuration file
+# and remake the kernel, if necessary.
+
+if [ -f $CFILE ]; then
+  if ! grep -q '^[     ]*pseudo-device[        ][      ]*ppp' $CFILE; then
+    echo
+    echo "The currently-running kernel was built from configuration file"
+    echo "$CFILE, which does not include PPP."
+    echo "You need either to add a line like 'pseudo-device ppp 2' to"
+    echo "this file, or use another configuration file which includes"
+    echo "a line like this."
+    DOCONF=yes
+  fi
+fi
+
+if [ $DOCONF ]; then
+  echo
+  echo "You need to configure and build a new kernel."
+  echo "The procedure for doing this involves the following commands."
+  echo "(\"$CONF\" may be replaced by the name of another config file.)"
+  echo
+  echo "       cd $ARCHDIR/conf"
+  echo "       /usr/sbin/$CONFIG $CONF"
+  echo "       cd ../compile/$CONF"
+  echo "       make depend"
+  DOMAKE=yes
+elif [ $DOMAKE ]; then
+  echo "You need to build a new kernel."
+  echo "The procedure for doing this involves the following commands."
+  echo
+  echo "       cd $ARCHDIR/compile/$CONF"
+fi
+if [ $DOMAKE ]; then
+  echo "       make"
+  echo
+  echo "Then copy the new kernel ($ARCHDIR/compile/$CONF/netbsd)"
+  echo "to /netbsd and reboot.  (Keep a copy of the old /netbsd,"
+  echo "just in case.)"
+fi
diff --git a/netbsd-1.1/ppp_tty.c b/netbsd-1.1/ppp_tty.c
new file mode 100644 (file)
index 0000000..97f0094
--- /dev/null
@@ -0,0 +1,1044 @@
+/*     $Id: ppp_tty.c,v 1.1 1995/12/11 05:17:10 paulus Exp $   */
+
+/*
+ * ppp_tty.c - Point-to-Point Protocol (PPP) driver for asynchronous
+ *            tty devices.
+ *
+ * Copyright (c) 1989 Carnegie Mellon University.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms are permitted
+ * provided that the above copyright notice and this paragraph are
+ * duplicated in all such forms and that any documentation,
+ * advertising materials, and other materials related to such
+ * distribution and use acknowledge that the software was developed
+ * by Carnegie Mellon University.  The name of the
+ * University may not be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
+ * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
+ * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * Drew D. Perkins
+ * Carnegie Mellon University
+ * 4910 Forbes Ave.
+ * Pittsburgh, PA 15213
+ * (412) 268-8576
+ * ddp@andrew.cmu.edu
+ *
+ * Based on:
+ *     @(#)if_sl.c     7.6.1.2 (Berkeley) 2/15/89
+ *
+ * Copyright (c) 1987 Regents of the University of California.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms are permitted
+ * provided that the above copyright notice and this paragraph are
+ * duplicated in all such forms and that any documentation,
+ * advertising materials, and other materials related to such
+ * distribution and use acknowledge that the software was developed
+ * by the University of California, Berkeley.  The name of the
+ * University may not be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ * THIS SOFTWARE IS PROVIDED ``AS IS'' AND WITHOUT ANY EXPRESS OR
+ * IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION, THE IMPLIED
+ * WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.
+ *
+ * Serial Line interface
+ *
+ * Rick Adams
+ * Center for Seismic Studies
+ * 1300 N 17th Street, Suite 1450
+ * Arlington, Virginia 22209
+ * (703)276-7900
+ * rick@seismo.ARPA
+ * seismo!rick
+ *
+ * Pounded on heavily by Chris Torek (chris@mimsy.umd.edu, umcp-cs!chris).
+ * Converted to 4.3BSD Beta by Chris Torek.
+ * Other changes made at Berkeley, based in part on code by Kirk Smith.
+ *
+ * Converted to 4.3BSD+ 386BSD by Brad Parker (brad@cayman.com)
+ * Added VJ tcp header compression; more unified ioctls
+ *
+ * Extensively modified by Paul Mackerras (paulus@cs.anu.edu.au).
+ * Cleaned up a lot of the mbuf-related code to fix bugs that
+ * caused system crashes and packet corruption.  Changed pppstart
+ * so that it doesn't just give up with a collision if the whole
+ * packet doesn't fit in the output ring buffer.
+ *
+ * Added priority queueing for interactive IP packets, following
+ * the model of if_sl.c, plus hooks for bpf.
+ * Paul Mackerras (paulus@cs.anu.edu.au).
+ */
+
+/* from if_sl.c,v 1.11 84/10/04 12:54:47 rick Exp */
+/* from NetBSD: if_ppp.c,v 1.15.2.2 1994/07/28 05:17:58 cgd Exp */
+
+#include "ppp.h"
+#if NPPP > 0
+
+#define VJC
+#define PPP_COMPRESS
+
+#include <sys/param.h>
+#include <sys/proc.h>
+#include <sys/mbuf.h>
+#include <sys/dkstat.h>
+#include <sys/socket.h>
+#include <sys/ioctl.h>
+#include <sys/file.h>
+#include <sys/tty.h>
+#include <sys/kernel.h>
+#include <sys/conf.h>
+#include <sys/vnode.h>
+
+#include <net/if.h>
+#include <net/if_types.h>
+
+#ifdef VJC
+#include <netinet/in.h>
+#include <netinet/in_systm.h>
+#include <netinet/ip.h>
+#include <net/slcompress.h>
+#endif
+
+#include <net/ppp_defs.h>
+#include <net/if_ppp.h>
+#include <net/if_pppvar.h>
+
+int    pppopen __P((dev_t dev, struct tty *tp));
+int    pppclose __P((struct tty *tp, int flag));
+int    pppread __P((struct tty *tp, struct uio *uio, int flag));
+int    pppwrite __P((struct tty *tp, struct uio *uio, int flag));
+int    ppptioctl __P((struct tty *tp, u_long cmd, caddr_t data, int flag,
+                      struct proc *));
+int    pppinput __P((int c, struct tty *tp));
+int    pppstart __P((struct tty *tp));
+
+static u_int16_t pppfcs __P((u_int16_t fcs, u_char *cp, int len));
+static void    pppasyncstart __P((struct ppp_softc *));
+static void    pppasyncctlp __P((struct ppp_softc *));
+static void    pppasyncrelinq __P((struct ppp_softc *));
+static void    ppp_timeout __P((void *));
+static void    pppgetm __P((struct ppp_softc *sc));
+static void    pppdumpb __P((u_char *b, int l));
+static void    ppplogchar __P((struct ppp_softc *, int));
+
+/*
+ * Some useful mbuf macros not in mbuf.h.
+ */
+#define M_IS_CLUSTER(m)        ((m)->m_flags & M_EXT)
+
+#define M_DATASTART(m) \
+       (M_IS_CLUSTER(m) ? (m)->m_ext.ext_buf : \
+           (m)->m_flags & M_PKTHDR ? (m)->m_pktdat : (m)->m_dat)
+
+#define M_DATASIZE(m)  \
+       (M_IS_CLUSTER(m) ? (m)->m_ext.ext_size : \
+           (m)->m_flags & M_PKTHDR ? MHLEN: MLEN)
+
+/*
+ * Does c need to be escaped?
+ */
+#define ESCAPE_P(c)    (sc->sc_asyncmap[(c) >> 5] & (1 << ((c) & 0x1F)))
+
+/*
+ * Procedures for using an async tty interface for PPP.
+ */
+
+/* This is a NetBSD-1.0 or later kernel. */
+#define CCOUNT(q)      ((q)->c_cc)
+
+#define        PPP_HIWAT       400     /* Don't start a new packet if HIWAT on que */
+
+/*
+ * Line specific open routine for async tty devices.
+ * Attach the given tty to the first available ppp unit.
+ * Called from device open routine or ttioctl.
+ */
+/* ARGSUSED */
+int
+pppopen(dev, tp)
+    dev_t dev;
+    register struct tty *tp;
+{
+    struct proc *p = curproc;          /* XXX */
+    register struct ppp_softc *sc;
+    int error, s, i;
+
+    if (error = suser(p->p_ucred, &p->p_acflag))
+       return (error);
+
+    s = spltty();
+
+    if (tp->t_line == PPPDISC) {
+       sc = (struct ppp_softc *) tp->t_sc;
+       if (sc != NULL && sc->sc_devp == (void *) tp) {
+           splx(s);
+           return (0);
+       }
+    }
+
+    if ((sc = pppalloc(p->p_pid)) == NULL) {
+       splx(s);
+       return ENXIO;
+    }
+
+    if (sc->sc_relinq)
+       (*sc->sc_relinq)(sc);   /* get previous owner to relinquish the unit */
+
+    sc->sc_ilen = 0;
+    sc->sc_m = NULL;
+    bzero(sc->sc_asyncmap, sizeof(sc->sc_asyncmap));
+    sc->sc_asyncmap[0] = 0xffffffff;
+    sc->sc_asyncmap[3] = 0x60000000;
+    sc->sc_rasyncmap = 0;
+    sc->sc_devp = (void *) tp;
+    sc->sc_start = pppasyncstart;
+    sc->sc_ctlp = pppasyncctlp;
+    sc->sc_relinq = pppasyncrelinq;
+    sc->sc_outm = NULL;
+    pppgetm(sc);
+    sc->sc_if.if_flags |= IFF_RUNNING;
+    sc->sc_if.if_baudrate = tp->t_ospeed;
+
+    tp->t_sc = (caddr_t) sc;
+    ttyflush(tp, FREAD | FWRITE);
+
+    splx(s);
+    return (0);
+}
+
+/*
+ * Line specific close routine, called from device close routine
+ * and from ttioctl.
+ * Detach the tty from the ppp unit.
+ * Mimics part of ttyclose().
+ */
+int
+pppclose(tp, flag)
+    struct tty *tp;
+    int flag;
+{
+    register struct ppp_softc *sc;
+    struct mbuf *m;
+    int s;
+
+    s = spltty();
+    ttyflush(tp, FREAD|FWRITE);
+    tp->t_line = 0;
+    sc = (struct ppp_softc *) tp->t_sc;
+    if (sc != NULL) {
+       tp->t_sc = NULL;
+       if (tp == (struct tty *) sc->sc_devp) {
+           pppasyncrelinq(sc);
+           pppdealloc(sc);
+       }
+    }
+    splx(s);
+    return 0;
+}
+
+/*
+ * Relinquish the interface unit to another device.
+ */
+static void
+pppasyncrelinq(sc)
+    struct ppp_softc *sc;
+{
+    int s;
+
+    s = spltty();
+    if (sc->sc_outm) {
+       m_freem(sc->sc_outm);
+       sc->sc_outm = NULL;
+    }
+    if (sc->sc_m) {
+       m_freem(sc->sc_m);
+       sc->sc_m = NULL;
+    }
+    if (sc->sc_flags & SC_TIMEOUT) {
+       untimeout(ppp_timeout, (void *) sc);
+       sc->sc_flags &= ~SC_TIMEOUT;
+    }
+    splx(s);
+}
+
+/*
+ * Line specific (tty) read routine.
+ */
+int
+pppread(tp, uio, flag)
+    register struct tty *tp;
+    struct uio *uio;
+    int flag;
+{
+    register struct ppp_softc *sc = (struct ppp_softc *)tp->t_sc;
+    struct mbuf *m, *m0;
+    register int s;
+    int error = 0;
+
+    if (sc == NULL)
+       return 0;
+    /*
+     * Loop waiting for input, checking that nothing disasterous
+     * happens in the meantime.
+     */
+    s = spltty();
+    for (;;) {
+       if (tp != (struct tty *) sc->sc_devp || tp->t_line != PPPDISC) {
+           splx(s);
+           return 0;
+       }
+       if (sc->sc_inq.ifq_head != NULL)
+           break;
+       if ((tp->t_state & TS_CARR_ON) == 0 && (tp->t_cflag & CLOCAL) == 0
+           && (tp->t_state & TS_ISOPEN)) {
+           splx(s);
+           return 0;           /* end of file */
+       }
+       if (tp->t_state & TS_ASYNC || flag & IO_NDELAY) {
+           splx(s);
+           return (EWOULDBLOCK);
+       }
+       error = ttysleep(tp, (caddr_t)&tp->t_rawq, TTIPRI|PCATCH, ttyin, 0);
+       if (error) {
+           splx(s);
+           return error;
+       }
+    }
+
+    /* Pull place-holder byte out of canonical queue */
+    getc(&tp->t_canq);
+
+    /* Get the packet from the input queue */
+    IF_DEQUEUE(&sc->sc_inq, m0);
+    splx(s);
+
+    for (m = m0; m && uio->uio_resid; m = m->m_next)
+       if (error = uiomove(mtod(m, u_char *), m->m_len, uio))
+           break;
+    m_freem(m0);
+    return (error);
+}
+
+/*
+ * Line specific (tty) write routine.
+ */
+int
+pppwrite(tp, uio, flag)
+    register struct tty *tp;
+    struct uio *uio;
+    int flag;
+{
+    register struct ppp_softc *sc = (struct ppp_softc *)tp->t_sc;
+    struct mbuf *m, *m0, **mp;
+    struct sockaddr dst;
+    int len, error;
+
+    if ((tp->t_state & TS_CARR_ON) == 0 && (tp->t_cflag & CLOCAL) == 0)
+       return 0;               /* wrote 0 bytes */
+    if (tp->t_line != PPPDISC)
+       return (EINVAL);
+    if (sc == NULL || tp != (struct tty *) sc->sc_devp)
+       return EIO;
+    if (uio->uio_resid > sc->sc_if.if_mtu + PPP_HDRLEN ||
+       uio->uio_resid < PPP_HDRLEN)
+       return (EMSGSIZE);
+    for (mp = &m0; uio->uio_resid; mp = &m->m_next) {
+       MGET(m, M_WAIT, MT_DATA);
+       if ((*mp = m) == NULL) {
+           m_freem(m0);
+           return (ENOBUFS);
+       }
+       m->m_len = 0;
+       if (uio->uio_resid >= MCLBYTES / 2)
+           MCLGET(m, M_DONTWAIT);
+       len = M_TRAILINGSPACE(m);
+       if (len > uio->uio_resid)
+           len = uio->uio_resid;
+       if (error = uiomove(mtod(m, u_char *), len, uio)) {
+           m_freem(m0);
+           return (error);
+       }
+       m->m_len = len;
+    }
+    dst.sa_family = AF_UNSPEC;
+    bcopy(mtod(m0, u_char *), dst.sa_data, PPP_HDRLEN);
+    m0->m_data += PPP_HDRLEN;
+    m0->m_len -= PPP_HDRLEN;
+    return (pppoutput(&sc->sc_if, m0, &dst, (struct rtentry *)0));
+}
+
+/*
+ * Line specific (tty) ioctl routine.
+ * This discipline requires that tty device drivers call
+ * the line specific l_ioctl routine from their ioctl routines.
+ */
+/* ARGSUSED */
+int
+ppptioctl(tp, cmd, data, flag, p)
+    struct tty *tp;
+    u_long cmd;
+    caddr_t data;
+    int flag;
+    struct proc *p;
+{
+    struct ppp_softc *sc = (struct ppp_softc *) tp->t_sc;
+    int error, s;
+
+    if (sc == NULL || tp != (struct tty *) sc->sc_devp)
+       return -1;
+
+    error = 0;
+    switch (cmd) {
+    case PPPIOCSASYNCMAP:
+       if (error = suser(p->p_ucred, &p->p_acflag))
+           break;
+       sc->sc_asyncmap[0] = *(u_int *)data;
+       break;
+
+    case PPPIOCGASYNCMAP:
+       *(u_int *)data = sc->sc_asyncmap[0];
+       break;
+
+    case PPPIOCSRASYNCMAP:
+       if (error = suser(p->p_ucred, &p->p_acflag))
+           break;
+       sc->sc_rasyncmap = *(u_int *)data;
+       break;
+
+    case PPPIOCGRASYNCMAP:
+       *(u_int *)data = sc->sc_rasyncmap;
+       break;
+
+    case PPPIOCSXASYNCMAP:
+       if (error = suser(p->p_ucred, &p->p_acflag))
+           break;
+       s = spltty();
+       bcopy(data, sc->sc_asyncmap, sizeof(sc->sc_asyncmap));
+       sc->sc_asyncmap[1] = 0;             /* mustn't escape 0x20 - 0x3f */
+       sc->sc_asyncmap[2] &= ~0x40000000;  /* mustn't escape 0x5e */
+       sc->sc_asyncmap[3] |= 0x60000000;   /* must escape 0x7d, 0x7e */
+       splx(s);
+       break;
+
+    case PPPIOCGXASYNCMAP:
+       bcopy(sc->sc_asyncmap, data, sizeof(sc->sc_asyncmap));
+       break;
+
+    default:
+       error = pppioctl(sc, cmd, data, flag, p);
+       if (error == 0 && cmd == PPPIOCSMRU)
+           pppgetm(sc);
+    }
+
+    return error;
+}
+
+/*
+ * FCS lookup table as calculated by genfcstab.
+ */
+static u_int16_t fcstab[256] = {
+       0x0000, 0x1189, 0x2312, 0x329b, 0x4624, 0x57ad, 0x6536, 0x74bf,
+       0x8c48, 0x9dc1, 0xaf5a, 0xbed3, 0xca6c, 0xdbe5, 0xe97e, 0xf8f7,
+       0x1081, 0x0108, 0x3393, 0x221a, 0x56a5, 0x472c, 0x75b7, 0x643e,
+       0x9cc9, 0x8d40, 0xbfdb, 0xae52, 0xdaed, 0xcb64, 0xf9ff, 0xe876,
+       0x2102, 0x308b, 0x0210, 0x1399, 0x6726, 0x76af, 0x4434, 0x55bd,
+       0xad4a, 0xbcc3, 0x8e58, 0x9fd1, 0xeb6e, 0xfae7, 0xc87c, 0xd9f5,
+       0x3183, 0x200a, 0x1291, 0x0318, 0x77a7, 0x662e, 0x54b5, 0x453c,
+       0xbdcb, 0xac42, 0x9ed9, 0x8f50, 0xfbef, 0xea66, 0xd8fd, 0xc974,
+       0x4204, 0x538d, 0x6116, 0x709f, 0x0420, 0x15a9, 0x2732, 0x36bb,
+       0xce4c, 0xdfc5, 0xed5e, 0xfcd7, 0x8868, 0x99e1, 0xab7a, 0xbaf3,
+       0x5285, 0x430c, 0x7197, 0x601e, 0x14a1, 0x0528, 0x37b3, 0x263a,
+       0xdecd, 0xcf44, 0xfddf, 0xec56, 0x98e9, 0x8960, 0xbbfb, 0xaa72,
+       0x6306, 0x728f, 0x4014, 0x519d, 0x2522, 0x34ab, 0x0630, 0x17b9,
+       0xef4e, 0xfec7, 0xcc5c, 0xddd5, 0xa96a, 0xb8e3, 0x8a78, 0x9bf1,
+       0x7387, 0x620e, 0x5095, 0x411c, 0x35a3, 0x242a, 0x16b1, 0x0738,
+       0xffcf, 0xee46, 0xdcdd, 0xcd54, 0xb9eb, 0xa862, 0x9af9, 0x8b70,
+       0x8408, 0x9581, 0xa71a, 0xb693, 0xc22c, 0xd3a5, 0xe13e, 0xf0b7,
+       0x0840, 0x19c9, 0x2b52, 0x3adb, 0x4e64, 0x5fed, 0x6d76, 0x7cff,
+       0x9489, 0x8500, 0xb79b, 0xa612, 0xd2ad, 0xc324, 0xf1bf, 0xe036,
+       0x18c1, 0x0948, 0x3bd3, 0x2a5a, 0x5ee5, 0x4f6c, 0x7df7, 0x6c7e,
+       0xa50a, 0xb483, 0x8618, 0x9791, 0xe32e, 0xf2a7, 0xc03c, 0xd1b5,
+       0x2942, 0x38cb, 0x0a50, 0x1bd9, 0x6f66, 0x7eef, 0x4c74, 0x5dfd,
+       0xb58b, 0xa402, 0x9699, 0x8710, 0xf3af, 0xe226, 0xd0bd, 0xc134,
+       0x39c3, 0x284a, 0x1ad1, 0x0b58, 0x7fe7, 0x6e6e, 0x5cf5, 0x4d7c,
+       0xc60c, 0xd785, 0xe51e, 0xf497, 0x8028, 0x91a1, 0xa33a, 0xb2b3,
+       0x4a44, 0x5bcd, 0x6956, 0x78df, 0x0c60, 0x1de9, 0x2f72, 0x3efb,
+       0xd68d, 0xc704, 0xf59f, 0xe416, 0x90a9, 0x8120, 0xb3bb, 0xa232,
+       0x5ac5, 0x4b4c, 0x79d7, 0x685e, 0x1ce1, 0x0d68, 0x3ff3, 0x2e7a,
+       0xe70e, 0xf687, 0xc41c, 0xd595, 0xa12a, 0xb0a3, 0x8238, 0x93b1,
+       0x6b46, 0x7acf, 0x4854, 0x59dd, 0x2d62, 0x3ceb, 0x0e70, 0x1ff9,
+       0xf78f, 0xe606, 0xd49d, 0xc514, 0xb1ab, 0xa022, 0x92b9, 0x8330,
+       0x7bc7, 0x6a4e, 0x58d5, 0x495c, 0x3de3, 0x2c6a, 0x1ef1, 0x0f78
+};
+
+/*
+ * Calculate a new FCS given the current FCS and the new data.
+ */
+static u_int16_t
+pppfcs(fcs, cp, len)
+    register u_int16_t fcs;
+    register u_char *cp;
+    register int len;
+{
+    while (len--)
+       fcs = PPP_FCS(fcs, *cp++);
+    return (fcs);
+}
+
+/*
+ * This gets called from pppoutput when a new packet is
+ * put on a queue, at splsoftnet.
+ */
+static void
+pppasyncstart(sc)
+    register struct ppp_softc *sc;
+{
+    register struct tty *tp = (struct tty *) sc->sc_devp;
+    int s;
+
+    s = spltty();
+    pppstart(tp);
+    splx(s);
+}
+
+/*
+ * This gets called when a received packet is placed on
+ * the inq, at splsoftnet.
+ */
+static void
+pppasyncctlp(sc)
+    struct ppp_softc *sc;
+{
+    struct tty *tp;
+    int s;
+
+    /* Put a placeholder byte in canq for ttselect()/ttnread(). */
+    s = spltty();
+    tp = (struct tty *) sc->sc_devp;
+    putc(0, &tp->t_canq);
+    ttwakeup(tp);
+    splx(s);
+}
+
+/*
+ * Start output on async tty interface.  Get another datagram
+ * to send from the interface queue and start sending it.
+ * Called at spltty or higher.
+ */
+int
+pppstart(tp)
+    register struct tty *tp;
+{
+    register struct ppp_softc *sc = (struct ppp_softc *) tp->t_sc;
+    register struct mbuf *m;
+    register int len;
+    register u_char *start, *stop, *cp;
+    int n, s, ndone, done, idle;
+    struct mbuf *m2;
+
+    if ((tp->t_state & TS_CARR_ON) == 0 && (tp->t_cflag & CLOCAL) == 0
+       || sc == NULL || tp != (struct tty *) sc->sc_devp) {
+       if (tp->t_oproc != NULL)
+           (*tp->t_oproc)(tp);
+       return 0;
+    }
+
+    idle = 0;
+    while (CCOUNT(&tp->t_outq) < PPP_HIWAT) {
+       /*
+        * See if we have an existing packet partly sent.
+        * If not, get a new packet and start sending it.
+        */
+       m = sc->sc_outm;
+       if (m == NULL) {
+           /*
+            * Get another packet to be sent.
+            */
+           m = ppp_dequeue(sc);
+           if (m == NULL) {
+               idle = 1;
+               break;
+           }
+
+           /*
+            * The extra PPP_FLAG will start up a new packet, and thus
+            * will flush any accumulated garbage.  We do this whenever
+            * the line may have been idle for some time.
+            */
+           if (CCOUNT(&tp->t_outq) == 0) {
+               ++sc->sc_bytessent;
+               (void) putc(PPP_FLAG, &tp->t_outq);
+           }
+
+           /* Calculate the FCS for the first mbuf's worth. */
+           sc->sc_outfcs = pppfcs(PPP_INITFCS, mtod(m, u_char *), m->m_len);
+           sc->sc_if.if_lastchange = time;
+       }
+
+       for (;;) {
+           start = mtod(m, u_char *);
+           len = m->m_len;
+           stop = start + len;
+           while (len > 0) {
+               /*
+                * Find out how many bytes in the string we can
+                * handle without doing something special.
+                */
+               for (cp = start; cp < stop; cp++)
+                   if (ESCAPE_P(*cp))
+                       break;
+               n = cp - start;
+               if (n) {
+                   /* NetBSD (0.9 or later), 4.3-Reno or similar. */
+                   ndone = n - b_to_q(start, n, &tp->t_outq);
+                   len -= ndone;
+                   start += ndone;
+                   sc->sc_bytessent += ndone;
+
+                   if (ndone < n)
+                       break;  /* packet doesn't fit */
+               }
+               /*
+                * If there are characters left in the mbuf,
+                * the first one must be special..
+                * Put it out in a different form.
+                */
+               if (len) {
+                   if (putc(PPP_ESCAPE, &tp->t_outq))
+                       break;
+                   if (putc(*start ^ PPP_TRANS, &tp->t_outq)) {
+                       (void) unputc(&tp->t_outq);
+                       break;
+                   }
+                   sc->sc_bytessent += 2;
+                   start++;
+                   len--;
+               }
+           }
+
+           /*
+            * If we didn't empty this mbuf, remember where we're up to.
+            * If we emptied the last mbuf, try to add the FCS and closing
+            * flag, and if we can't, leave sc_outm pointing to m, but with
+            * m->m_len == 0, to remind us to output the FCS and flag later.
+            */
+           done = len == 0;
+           if (done && m->m_next == NULL) {
+               u_char *p, *q;
+               int c;
+               u_char endseq[8];
+
+               /*
+                * We may have to escape the bytes in the FCS.
+                */
+               p = endseq;
+               c = ~sc->sc_outfcs & 0xFF;
+               if (ESCAPE_P(c)) {
+                   *p++ = PPP_ESCAPE;
+                   *p++ = c ^ PPP_TRANS;
+               } else
+                   *p++ = c;
+               c = (~sc->sc_outfcs >> 8) & 0xFF;
+               if (ESCAPE_P(c)) {
+                   *p++ = PPP_ESCAPE;
+                   *p++ = c ^ PPP_TRANS;
+               } else
+                   *p++ = c;
+               *p++ = PPP_FLAG;
+
+               /*
+                * Try to output the FCS and flag.  If the bytes
+                * don't all fit, back out.
+                */
+               for (q = endseq; q < p; ++q)
+                   if (putc(*q, &tp->t_outq)) {
+                       done = 0;
+                       for (; q > endseq; --q)
+                           unputc(&tp->t_outq);
+                       break;
+                   }
+               sc->sc_bytessent += q - endseq;
+           }
+
+           if (!done) {
+               /* remember where we got to */
+               m->m_data = start;
+               m->m_len = len;
+               break;
+           }
+
+           /* Finished with this mbuf; free it and move on. */
+           MFREE(m, m2);
+           m = m2;
+           if (m == NULL) {
+               /* Finished a packet */
+               sc->sc_if.if_opackets++;
+               sc->sc_if.if_obytes = sc->sc_bytessent;
+               break;
+           }
+           sc->sc_outfcs = pppfcs(sc->sc_outfcs, mtod(m, u_char *), m->m_len);
+       }
+
+       /*
+        * Here we have either finished a packet (m == NULL)
+        * or filled up the output queue (m != NULL).
+        */
+       sc->sc_outm = m;
+       if (m)
+           break;
+    }
+
+    /*
+     * If there is stuff in the output queue, send it now.
+     * We are being called in lieu of ttstart and must do what it would.
+     */
+    if (tp->t_oproc != NULL)
+       (*tp->t_oproc)(tp);
+
+    /*
+     * This timeout is needed for operation on a pseudo-tty,
+     * because the pty code doesn't call pppstart after it has
+     * drained the t_outq.
+     */
+    if (!idle && (sc->sc_flags & SC_TIMEOUT) == 0) {
+       timeout(ppp_timeout, (void *) sc, 1);
+       sc->sc_flags |= SC_TIMEOUT;
+    }
+
+    return 0;
+}
+
+/*
+ * Timeout routine - try to start some more output.
+ */
+static void
+ppp_timeout(x)
+    void *x;
+{
+    struct ppp_softc *sc = (struct ppp_softc *) x;
+    struct tty *tp = (struct tty *) sc->sc_devp;
+    int s;
+
+    s = spltty();
+    sc->sc_flags &= ~SC_TIMEOUT;
+    pppstart(tp);
+    splx(s);
+}
+
+/*
+ * Allocate enough mbuf to handle current MRU.
+ */
+static void
+pppgetm(sc)
+    register struct ppp_softc *sc;
+{
+    struct mbuf *m, **mp;
+    int len;
+    int s;
+
+    s = spltty();
+    mp = &sc->sc_m;
+    for (len = sc->sc_mru + PPP_HDRLEN + PPP_FCSLEN; len > 0; ){
+       if ((m = *mp) == NULL) {
+           MGETHDR(m, M_DONTWAIT, MT_DATA);
+           if (m == NULL)
+               break;
+           *mp = m;
+           MCLGET(m, M_DONTWAIT);
+       }
+       len -= M_DATASIZE(m);
+       mp = &m->m_next;
+    }
+    splx(s);
+}
+
+/*
+ * tty interface receiver interrupt.
+ */
+static unsigned paritytab[8] = {
+    0x96696996, 0x69969669, 0x69969669, 0x96696996,
+    0x69969669, 0x96696996, 0x96696996, 0x69969669
+};
+
+int
+pppinput(c, tp)
+    int c;
+    register struct tty *tp;
+{
+    register struct ppp_softc *sc;
+    struct mbuf *m;
+    int ilen, s;
+
+    sc = (struct ppp_softc *) tp->t_sc;
+    if (sc == NULL || tp != (struct tty *) sc->sc_devp)
+       return 0;
+
+    s = spltty();              /* should be unnecessary */
+    ++tk_nin;
+    ++sc->sc_bytesrcvd;
+
+    if (c & TTY_FE) {
+       /* framing error or overrun on this char - abort packet */
+       if (sc->sc_flags & SC_DEBUG)
+           printf("ppp%d: bad char %x\n", sc->sc_if.if_unit, c);
+       goto flush;
+    }
+
+    c &= 0xff;
+
+    /*
+     * Handle software flow control of output.
+     */
+    if (tp->t_iflag & IXON) {
+       if (c == tp->t_cc[VSTOP] && tp->t_cc[VSTOP] != _POSIX_VDISABLE) {
+           if ((tp->t_state & TS_TTSTOP) == 0) {
+               tp->t_state |= TS_TTSTOP;
+               (*cdevsw[major(tp->t_dev)].d_stop)(tp, 0);
+           }
+           return 0;
+       }
+       if (c == tp->t_cc[VSTART] && tp->t_cc[VSTART] != _POSIX_VDISABLE) {
+           tp->t_state &= ~TS_TTSTOP;
+           if (tp->t_oproc != NULL)
+               (*tp->t_oproc)(tp);
+           return 0;
+       }
+    }
+
+    if (c & 0x80)
+       sc->sc_flags |= SC_RCV_B7_1;
+    else
+       sc->sc_flags |= SC_RCV_B7_0;
+    if (paritytab[c >> 5] & (1 << (c & 0x1F)))
+       sc->sc_flags |= SC_RCV_ODDP;
+    else
+       sc->sc_flags |= SC_RCV_EVNP;
+
+    if (sc->sc_flags & SC_LOG_RAWIN)
+       ppplogchar(sc, c);
+
+    if (c == PPP_FLAG) {
+       ilen = sc->sc_ilen;
+       sc->sc_ilen = 0;
+       sc->sc_if.if_ibytes = sc->sc_bytesrcvd;
+
+       if (sc->sc_rawin_count > 0) 
+           ppplogchar(sc, -1);
+
+       /*
+        * If SC_ESCAPED is set, then we've seen the packet
+        * abort sequence "}~".
+        */
+       if (sc->sc_flags & (SC_FLUSH | SC_ESCAPED)
+           || ilen > 0 && sc->sc_fcs != PPP_GOODFCS) {
+           sc->sc_flags |= SC_PKTLOST; /* note the dropped packet */
+           if ((sc->sc_flags & (SC_FLUSH | SC_ESCAPED)) == 0){
+               if (sc->sc_flags & SC_DEBUG)
+                   printf("ppp%d: bad fcs %x\n", sc->sc_if.if_unit,
+                          sc->sc_fcs);
+               sc->sc_if.if_ierrors++;
+           } else
+               sc->sc_flags &= ~(SC_FLUSH | SC_ESCAPED);
+           splx(s);
+           return 0;
+       }
+
+       if (ilen < PPP_HDRLEN + PPP_FCSLEN) {
+           if (ilen) {
+               if (sc->sc_flags & SC_DEBUG)
+                   printf("ppp%d: too short (%d)\n", sc->sc_if.if_unit, ilen);
+               sc->sc_if.if_ierrors++;
+               sc->sc_flags |= SC_PKTLOST;
+           }
+           splx(s);
+           return 0;
+       }
+
+       /*
+        * Remove FCS trailer.  Somewhat painful...
+        */
+       ilen -= 2;
+       if (--sc->sc_mc->m_len == 0) {
+           for (m = sc->sc_m; m->m_next != sc->sc_mc; m = m->m_next)
+               ;
+           sc->sc_mc = m;
+       }
+       sc->sc_mc->m_len--;
+
+       /* excise this mbuf chain */
+       m = sc->sc_m;
+       sc->sc_m = sc->sc_mc->m_next;
+       sc->sc_mc->m_next = NULL;
+
+       ppppktin(sc, m, sc->sc_flags & SC_PKTLOST);
+       sc->sc_flags &= ~SC_PKTLOST;
+
+       pppgetm(sc);
+       splx(s);
+       return 0;
+    }
+
+    if (sc->sc_flags & SC_FLUSH) {
+       if (sc->sc_flags & SC_LOG_FLUSH)
+           ppplogchar(sc, c);
+       splx(s);
+       return 0;
+    }
+
+    if (c < 0x20 && (sc->sc_rasyncmap & (1 << c))) {
+       splx(s);
+       return 0;
+    }
+
+    if (sc->sc_flags & SC_ESCAPED) {
+       sc->sc_flags &= ~SC_ESCAPED;
+       c ^= PPP_TRANS;
+    } else if (c == PPP_ESCAPE) {
+       sc->sc_flags |= SC_ESCAPED;
+       splx(s);
+       return 0;
+    }
+
+    /*
+     * Initialize buffer on first octet received.
+     * First octet could be address or protocol (when compressing
+     * address/control).
+     * Second octet is control.
+     * Third octet is first or second (when compressing protocol)
+     * octet of protocol.
+     * Fourth octet is second octet of protocol.
+     */
+    if (sc->sc_ilen == 0) {
+       /* reset the first input mbuf */
+       if (sc->sc_m == NULL) {
+           pppgetm(sc);
+           if (sc->sc_m == NULL) {
+               if (sc->sc_flags & SC_DEBUG)
+                   printf("ppp%d: no input mbufs!\n", sc->sc_if.if_unit);
+               goto flush;
+           }
+       }
+       m = sc->sc_m;
+       m->m_len = 0;
+       m->m_data = M_DATASTART(sc->sc_m);
+       sc->sc_mc = m;
+       sc->sc_mp = mtod(m, char *);
+       sc->sc_fcs = PPP_INITFCS;
+       if (c != PPP_ALLSTATIONS) {
+           if (sc->sc_flags & SC_REJ_COMP_AC) {
+               if (sc->sc_flags & SC_DEBUG)
+                   printf("ppp%d: garbage received: 0x%x (need 0xFF)\n",
+                          sc->sc_if.if_unit, c);
+               goto flush;
+           }
+           *sc->sc_mp++ = PPP_ALLSTATIONS;
+           *sc->sc_mp++ = PPP_UI;
+           sc->sc_ilen += 2;
+           m->m_len += 2;
+       }
+    }
+    if (sc->sc_ilen == 1 && c != PPP_UI) {
+       if (sc->sc_flags & SC_DEBUG)
+           printf("ppp%d: missing UI (0x3), got 0x%x\n",
+                  sc->sc_if.if_unit, c);
+       goto flush;
+    }
+    if (sc->sc_ilen == 2 && (c & 1) == 1) {
+       /* a compressed protocol */
+       *sc->sc_mp++ = 0;
+       sc->sc_ilen++;
+       sc->sc_mc->m_len++;
+    }
+    if (sc->sc_ilen == 3 && (c & 1) == 0) {
+       if (sc->sc_flags & SC_DEBUG)
+           printf("ppp%d: bad protocol %x\n", sc->sc_if.if_unit,
+                  (sc->sc_mp[-1] << 8) + c);
+       goto flush;
+    }
+
+    /* packet beyond configured mru? */
+    if (++sc->sc_ilen > sc->sc_mru + PPP_HDRLEN + PPP_FCSLEN) {
+       if (sc->sc_flags & SC_DEBUG)
+           printf("ppp%d: packet too big\n", sc->sc_if.if_unit);
+       goto flush;
+    }
+
+    /* is this mbuf full? */
+    m = sc->sc_mc;
+    if (M_TRAILINGSPACE(m) <= 0) {
+       if (m->m_next == NULL) {
+           pppgetm(sc);
+           if (m->m_next == NULL) {
+               if (sc->sc_flags & SC_DEBUG)
+                   printf("ppp%d: too few input mbufs!\n", sc->sc_if.if_unit);
+               goto flush;
+           }
+       }
+       sc->sc_mc = m = m->m_next;
+       m->m_len = 0;
+       m->m_data = M_DATASTART(m);
+       sc->sc_mp = mtod(m, char *);
+    }
+
+    ++m->m_len;
+    *sc->sc_mp++ = c;
+    sc->sc_fcs = PPP_FCS(sc->sc_fcs, c);
+    splx(s);
+    return 0;
+
+ flush:
+    if (!(sc->sc_flags & SC_FLUSH)) {
+       sc->sc_if.if_ierrors++;
+       sc->sc_flags |= SC_FLUSH;
+       if (sc->sc_flags & SC_LOG_FLUSH)
+           ppplogchar(sc, c);
+    }
+    splx(s);
+    return 0;
+}
+
+#define MAX_DUMP_BYTES 128
+
+static void
+ppplogchar(sc, c)
+    struct ppp_softc *sc;
+    int c;
+{
+    if (c >= 0)
+       sc->sc_rawin[sc->sc_rawin_count++] = c;
+    if (sc->sc_rawin_count >= sizeof(sc->sc_rawin)
+       || c < 0 && sc->sc_rawin_count > 0) {
+       printf("ppp%d input: ", sc->sc_if.if_unit);
+       pppdumpb(sc->sc_rawin, sc->sc_rawin_count);
+       sc->sc_rawin_count = 0;
+    }
+}
+
+static void
+pppdumpb(b, l)
+    u_char *b;
+    int l;
+{
+    char buf[3*MAX_DUMP_BYTES+4];
+    char *bp = buf;
+    static char digits[] = "0123456789abcdef";
+
+    while (l--) {
+       if (bp >= buf + sizeof(buf) - 3) {
+           *bp++ = '>';
+           break;
+       }
+       *bp++ = digits[*b >> 4]; /* convert byte to ascii hex */
+       *bp++ = digits[*b++ & 0xf];
+       *bp++ = ' ';
+    }
+
+    *bp = 0;
+    printf("%s\n", buf);
+}
+
+#endif /* NPPP > 0 */
diff --git a/netbsd-1.1/slcompress.c b/netbsd-1.1/slcompress.c
new file mode 100644 (file)
index 0000000..2029a13
--- /dev/null
@@ -0,0 +1,583 @@
+/*     $Id: slcompress.c,v 1.1 1995/12/11 05:17:11 paulus Exp $        */
+
+/*
+ * Copyright (c) 1989, 1993, 1994
+ *     The Regents of the University of California.  All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ *    notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ *    notice, this list of conditions and the following disclaimer in the
+ *    documentation and/or other materials provided with the distribution.
+ * 3. All advertising materials mentioning features or use of this software
+ *    must display the following acknowledgement:
+ *     This product includes software developed by the University of
+ *     California, Berkeley and its contributors.
+ * 4. Neither the name of the University nor the names of its contributors
+ *    may be used to endorse or promote products derived from this software
+ *    without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ *
+ *     @(#)slcompress.c        8.2 (Berkeley) 4/16/94
+ */
+
+/*
+ * Routines to compress and uncompess tcp packets (for transmission
+ * over low speed serial lines.
+ *
+ * Van Jacobson (van@helios.ee.lbl.gov), Dec 31, 1989:
+ *     - Initial distribution.
+ */
+
+#include <sys/param.h>
+#include <sys/mbuf.h>
+
+#include <netinet/in.h>
+#include <netinet/in_systm.h>
+#include <netinet/ip.h>
+#include <netinet/tcp.h>
+
+#include <net/slcompress.h>
+
+#ifndef SL_NO_STATS
+#define INCR(counter) ++comp->counter;
+#else
+#define INCR(counter)
+#endif
+
+#define BCMP(p1, p2, n) bcmp((char *)(p1), (char *)(p2), (int)(n))
+#define BCOPY(p1, p2, n) bcopy((char *)(p1), (char *)(p2), (int)(n))
+#ifndef _KERNEL
+#define ovbcopy bcopy
+#endif
+
+void
+sl_compress_init(comp, max_state)
+       struct slcompress *comp;
+       int max_state;
+{
+       register u_int i;
+       register struct cstate *tstate = comp->tstate;
+
+       if (max_state == -1)
+               max_state = MAX_STATES - 1;
+       bzero((char *)comp, sizeof(*comp));
+       for (i = max_state; i > 0; --i) {
+               tstate[i].cs_id = i;
+               tstate[i].cs_next = &tstate[i - 1];
+       }
+       tstate[0].cs_next = &tstate[max_state];
+       tstate[0].cs_id = 0;
+       comp->last_cs = &tstate[0];
+       comp->last_recv = 255;
+       comp->last_xmit = 255;
+       comp->flags = SLF_TOSS;
+}
+
+
+/* ENCODE encodes a number that is known to be non-zero.  ENCODEZ
+ * checks for zero (since zero has to be encoded in the long, 3 byte
+ * form).
+ */
+#define ENCODE(n) { \
+       if ((u_int16_t)(n) >= 256) { \
+               *cp++ = 0; \
+               cp[1] = (n); \
+               cp[0] = (n) >> 8; \
+               cp += 2; \
+       } else { \
+               *cp++ = (n); \
+       } \
+}
+#define ENCODEZ(n) { \
+       if ((u_int16_t)(n) >= 256 || (u_int16_t)(n) == 0) { \
+               *cp++ = 0; \
+               cp[1] = (n); \
+               cp[0] = (n) >> 8; \
+               cp += 2; \
+       } else { \
+               *cp++ = (n); \
+       } \
+}
+
+#define DECODEL(f) { \
+       if (*cp == 0) {\
+               (f) = htonl(ntohl(f) + ((cp[1] << 8) | cp[2])); \
+               cp += 3; \
+       } else { \
+               (f) = htonl(ntohl(f) + (u_int32_t)*cp++); \
+       } \
+}
+
+#define DECODES(f) { \
+       if (*cp == 0) {\
+               (f) = htons(ntohs(f) + ((cp[1] << 8) | cp[2])); \
+               cp += 3; \
+       } else { \
+               (f) = htons(ntohs(f) + (u_int32_t)*cp++); \
+       } \
+}
+
+#define DECODEU(f) { \
+       if (*cp == 0) {\
+               (f) = htons((cp[1] << 8) | cp[2]); \
+               cp += 3; \
+       } else { \
+               (f) = htons((u_int32_t)*cp++); \
+       } \
+}
+
+u_int
+sl_compress_tcp(m, ip, comp, compress_cid)
+       struct mbuf *m;
+       register struct ip *ip;
+       struct slcompress *comp;
+       int compress_cid;
+{
+       register struct cstate *cs = comp->last_cs->cs_next;
+       register u_int hlen = ip->ip_hl;
+       register struct tcphdr *oth;
+       register struct tcphdr *th;
+       register u_int deltaS, deltaA;
+       register u_int changes = 0;
+       u_char new_seq[16];
+       register u_char *cp = new_seq;
+
+       /*
+        * Bail if this is an IP fragment or if the TCP packet isn't
+        * `compressible' (i.e., ACK isn't set or some other control bit is
+        * set).  (We assume that the caller has already made sure the
+        * packet is IP proto TCP).
+        */
+       if ((ip->ip_off & htons(0x3fff)) || m->m_len < 40)
+               return (TYPE_IP);
+
+       th = (struct tcphdr *)&((int32_t *)ip)[hlen];
+       if ((th->th_flags & (TH_SYN|TH_FIN|TH_RST|TH_ACK)) != TH_ACK)
+               return (TYPE_IP);
+       /*
+        * Packet is compressible -- we're going to send either a
+        * COMPRESSED_TCP or UNCOMPRESSED_TCP packet.  Either way we need
+        * to locate (or create) the connection state.  Special case the
+        * most recently used connection since it's most likely to be used
+        * again & we don't have to do any reordering if it's used.
+        */
+       INCR(sls_packets)
+       if (ip->ip_src.s_addr != cs->cs_ip.ip_src.s_addr ||
+           ip->ip_dst.s_addr != cs->cs_ip.ip_dst.s_addr ||
+           *(int32_t *)th != ((int32_t *)&cs->cs_ip)[cs->cs_ip.ip_hl]) {
+               /*
+                * Wasn't the first -- search for it.
+                *
+                * States are kept in a circularly linked list with
+                * last_cs pointing to the end of the list.  The
+                * list is kept in lru order by moving a state to the
+                * head of the list whenever it is referenced.  Since
+                * the list is short and, empirically, the connection
+                * we want is almost always near the front, we locate
+                * states via linear search.  If we don't find a state
+                * for the datagram, the oldest state is (re-)used.
+                */
+               register struct cstate *lcs;
+               register struct cstate *lastcs = comp->last_cs;
+
+               do {
+                       lcs = cs; cs = cs->cs_next;
+                       INCR(sls_searches)
+                       if (ip->ip_src.s_addr == cs->cs_ip.ip_src.s_addr
+                           && ip->ip_dst.s_addr == cs->cs_ip.ip_dst.s_addr
+                           && *(int32_t *)th ==
+                           ((int32_t *)&cs->cs_ip)[cs->cs_ip.ip_hl])
+                               goto found;
+               } while (cs != lastcs);
+
+               /*
+                * Didn't find it -- re-use oldest cstate.  Send an
+                * uncompressed packet that tells the other side what
+                * connection number we're using for this conversation.
+                * Note that since the state list is circular, the oldest
+                * state points to the newest and we only need to set
+                * last_cs to update the lru linkage.
+                */
+               INCR(sls_misses)
+               comp->last_cs = lcs;
+               hlen += th->th_off;
+               hlen <<= 2;
+               goto uncompressed;
+
+       found:
+               /*
+                * Found it -- move to the front on the connection list.
+                */
+               if (cs == lastcs)
+                       comp->last_cs = lcs;
+               else {
+                       lcs->cs_next = cs->cs_next;
+                       cs->cs_next = lastcs->cs_next;
+                       lastcs->cs_next = cs;
+               }
+       }
+
+       /*
+        * Make sure that only what we expect to change changed. The first
+        * line of the `if' checks the IP protocol version, header length &
+        * type of service.  The 2nd line checks the "Don't fragment" bit.
+        * The 3rd line checks the time-to-live and protocol (the protocol
+        * check is unnecessary but costless).  The 4th line checks the TCP
+        * header length.  The 5th line checks IP options, if any.  The 6th
+        * line checks TCP options, if any.  If any of these things are
+        * different between the previous & current datagram, we send the
+        * current datagram `uncompressed'.
+        */
+       oth = (struct tcphdr *)&((int32_t *)&cs->cs_ip)[hlen];
+       deltaS = hlen;
+       hlen += th->th_off;
+       hlen <<= 2;
+
+       if (((u_int16_t *)ip)[0] != ((u_int16_t *)&cs->cs_ip)[0] ||
+           ((u_int16_t *)ip)[3] != ((u_int16_t *)&cs->cs_ip)[3] ||
+           ((u_int16_t *)ip)[4] != ((u_int16_t *)&cs->cs_ip)[4] ||
+           th->th_off != oth->th_off ||
+           (deltaS > 5 &&
+            BCMP(ip + 1, &cs->cs_ip + 1, (deltaS - 5) << 2)) ||
+           (th->th_off > 5 &&
+            BCMP(th + 1, oth + 1, (th->th_off - 5) << 2)))
+               goto uncompressed;
+
+       /*
+        * Figure out which of the changing fields changed.  The
+        * receiver expects changes in the order: urgent, window,
+        * ack, seq (the order minimizes the number of temporaries
+        * needed in this section of code).
+        */
+       if (th->th_flags & TH_URG) {
+               deltaS = ntohs(th->th_urp);
+               ENCODEZ(deltaS);
+               changes |= NEW_U;
+       } else if (th->th_urp != oth->th_urp)
+               /* argh! URG not set but urp changed -- a sensible
+                * implementation should never do this but RFC793
+                * doesn't prohibit the change so we have to deal
+                * with it. */
+                goto uncompressed;
+
+       if (deltaS = (u_int16_t)(ntohs(th->th_win) - ntohs(oth->th_win))) {
+               ENCODE(deltaS);
+               changes |= NEW_W;
+       }
+
+       if (deltaA = ntohl(th->th_ack) - ntohl(oth->th_ack)) {
+               if (deltaA > 0xffff)
+                       goto uncompressed;
+               ENCODE(deltaA);
+               changes |= NEW_A;
+       }
+
+       if (deltaS = ntohl(th->th_seq) - ntohl(oth->th_seq)) {
+               if (deltaS > 0xffff)
+                       goto uncompressed;
+               ENCODE(deltaS);
+               changes |= NEW_S;
+       }
+
+       switch(changes) {
+
+       case 0:
+               /*
+                * Nothing changed. If this packet contains data and the
+                * last one didn't, this is probably a data packet following
+                * an ack (normal on an interactive connection) and we send
+                * it compressed.  Otherwise it's probably a retransmit,
+                * retransmitted ack or window probe.  Send it uncompressed
+                * in case the other side missed the compressed version.
+                */
+               if (ip->ip_len != cs->cs_ip.ip_len &&
+                   ntohs(cs->cs_ip.ip_len) == hlen)
+                       break;
+
+               /* (fall through) */
+
+       case SPECIAL_I:
+       case SPECIAL_D:
+               /*
+                * actual changes match one of our special case encodings --
+                * send packet uncompressed.
+                */
+               goto uncompressed;
+
+       case NEW_S|NEW_A:
+               if (deltaS == deltaA &&
+                   deltaS == ntohs(cs->cs_ip.ip_len) - hlen) {
+                       /* special case for echoed terminal traffic */
+                       changes = SPECIAL_I;
+                       cp = new_seq;
+               }
+               break;
+
+       case NEW_S:
+               if (deltaS == ntohs(cs->cs_ip.ip_len) - hlen) {
+                       /* special case for data xfer */
+                       changes = SPECIAL_D;
+                       cp = new_seq;
+               }
+               break;
+       }
+
+       deltaS = ntohs(ip->ip_id) - ntohs(cs->cs_ip.ip_id);
+       if (deltaS != 1) {
+               ENCODEZ(deltaS);
+               changes |= NEW_I;
+       }
+       if (th->th_flags & TH_PUSH)
+               changes |= TCP_PUSH_BIT;
+       /*
+        * Grab the cksum before we overwrite it below.  Then update our
+        * state with this packet's header.
+        */
+       deltaA = ntohs(th->th_sum);
+       BCOPY(ip, &cs->cs_ip, hlen);
+
+       /*
+        * We want to use the original packet as our compressed packet.
+        * (cp - new_seq) is the number of bytes we need for compressed
+        * sequence numbers.  In addition we need one byte for the change
+        * mask, one for the connection id and two for the tcp checksum.
+        * So, (cp - new_seq) + 4 bytes of header are needed.  hlen is how
+        * many bytes of the original packet to toss so subtract the two to
+        * get the new packet size.
+        */
+       deltaS = cp - new_seq;
+       cp = (u_char *)ip;
+       if (compress_cid == 0 || comp->last_xmit != cs->cs_id) {
+               comp->last_xmit = cs->cs_id;
+               hlen -= deltaS + 4;
+               cp += hlen;
+               *cp++ = changes | NEW_C;
+               *cp++ = cs->cs_id;
+       } else {
+               hlen -= deltaS + 3;
+               cp += hlen;
+               *cp++ = changes;
+       }
+       m->m_len -= hlen;
+       m->m_data += hlen;
+       *cp++ = deltaA >> 8;
+       *cp++ = deltaA;
+       BCOPY(new_seq, cp, deltaS);
+       INCR(sls_compressed)
+       return (TYPE_COMPRESSED_TCP);
+
+       /*
+        * Update connection state cs & send uncompressed packet ('uncompressed'
+        * means a regular ip/tcp packet but with the 'conversation id' we hope
+        * to use on future compressed packets in the protocol field).
+        */
+uncompressed:
+       BCOPY(ip, &cs->cs_ip, hlen);
+       ip->ip_p = cs->cs_id;
+       comp->last_xmit = cs->cs_id;
+       return (TYPE_UNCOMPRESSED_TCP);
+}
+
+
+int
+sl_uncompress_tcp(bufp, len, type, comp)
+       u_char **bufp;
+       int len;
+       u_int type;
+       struct slcompress *comp;
+{
+       u_char *hdr, *cp;
+       int hlen, vjlen;
+
+       cp = bufp? *bufp: NULL;
+       vjlen = sl_uncompress_tcp_core(cp, len, len, type, comp, &hdr, &hlen);
+       if (vjlen < 0)
+               return (0);     /* error */
+       if (vjlen == 0)
+               return (len);   /* was uncompressed already */
+
+       cp += vjlen;
+       len -= vjlen;
+
+       /*
+        * At this point, cp points to the first byte of data in the
+        * packet.  If we're not aligned on a 4-byte boundary, copy the
+        * data down so the ip & tcp headers will be aligned.  Then back up
+        * cp by the tcp/ip header length to make room for the reconstructed
+        * header (we assume the packet we were handed has enough space to
+        * prepend 128 bytes of header).
+        */
+       if ((int)cp & 3) {
+               if (len > 0)
+                       (void) ovbcopy(cp, (caddr_t)((int)cp &~ 3), len);
+               cp = (u_char *)((int)cp &~ 3);
+       }
+       cp -= hlen;
+       len += hlen;
+       BCOPY(hdr, cp, hlen);
+
+       *bufp = cp;
+       return (len);
+}
+
+/*
+ * Uncompress a packet of total length total_len.  The first buflen
+ * bytes are at buf; this must include the entire (compressed or
+ * uncompressed) TCP/IP header.  This procedure returns the length
+ * of the VJ header, with a pointer to the uncompressed IP header
+ * in *hdrp and its length in *hlenp.
+ */
+int
+sl_uncompress_tcp_core(buf, buflen, total_len, type, comp, hdrp, hlenp)
+       u_char *buf;
+       int buflen, total_len;
+       u_int type;
+       struct slcompress *comp;
+       u_char **hdrp;
+       u_int *hlenp;
+{
+       register u_char *cp;
+       register u_int hlen, changes;
+       register struct tcphdr *th;
+       register struct cstate *cs;
+       register struct ip *ip;
+       register u_int16_t *bp;
+       register u_int vjlen;
+
+       switch (type) {
+
+       case TYPE_UNCOMPRESSED_TCP:
+               ip = (struct ip *) buf;
+               if (ip->ip_p >= MAX_STATES)
+                       goto bad;
+               cs = &comp->rstate[comp->last_recv = ip->ip_p];
+               comp->flags &=~ SLF_TOSS;
+               ip->ip_p = IPPROTO_TCP;
+               hlen = ip->ip_hl;
+               hlen += ((struct tcphdr *)&((int32_t *)ip)[hlen])->th_off;
+               hlen <<= 2;
+               BCOPY(ip, &cs->cs_ip, hlen);
+               cs->cs_hlen = hlen;
+               INCR(sls_uncompressedin)
+               *hdrp = (u_char *) &cs->cs_ip;
+               *hlenp = hlen;
+               return (0);
+
+       default:
+               goto bad;
+
+       case TYPE_COMPRESSED_TCP:
+               break;
+       }
+       /* We've got a compressed packet. */
+       INCR(sls_compressedin)
+       cp = buf;
+       changes = *cp++;
+       if (changes & NEW_C) {
+               /* Make sure the state index is in range, then grab the state.
+                * If we have a good state index, clear the 'discard' flag. */
+               if (*cp >= MAX_STATES)
+                       goto bad;
+
+               comp->flags &=~ SLF_TOSS;
+               comp->last_recv = *cp++;
+       } else {
+               /* this packet has an implicit state index.  If we've
+                * had a line error since the last time we got an
+                * explicit state index, we have to toss the packet. */
+               if (comp->flags & SLF_TOSS) {
+                       INCR(sls_tossed)
+                       return (-1);
+               }
+       }
+       cs = &comp->rstate[comp->last_recv];
+       hlen = cs->cs_ip.ip_hl << 2;
+       th = (struct tcphdr *)&((u_char *)&cs->cs_ip)[hlen];
+       th->th_sum = htons((*cp << 8) | cp[1]);
+       cp += 2;
+       if (changes & TCP_PUSH_BIT)
+               th->th_flags |= TH_PUSH;
+       else
+               th->th_flags &=~ TH_PUSH;
+
+       switch (changes & SPECIALS_MASK) {
+       case SPECIAL_I:
+               {
+               register u_int i = ntohs(cs->cs_ip.ip_len) - cs->cs_hlen;
+               th->th_ack = htonl(ntohl(th->th_ack) + i);
+               th->th_seq = htonl(ntohl(th->th_seq) + i);
+               }
+               break;
+
+       case SPECIAL_D:
+               th->th_seq = htonl(ntohl(th->th_seq) + ntohs(cs->cs_ip.ip_len)
+                                  - cs->cs_hlen);
+               break;
+
+       default:
+               if (changes & NEW_U) {
+                       th->th_flags |= TH_URG;
+                       DECODEU(th->th_urp)
+               } else
+                       th->th_flags &=~ TH_URG;
+               if (changes & NEW_W)
+                       DECODES(th->th_win)
+               if (changes & NEW_A)
+                       DECODEL(th->th_ack)
+               if (changes & NEW_S)
+                       DECODEL(th->th_seq)
+               break;
+       }
+       if (changes & NEW_I) {
+               DECODES(cs->cs_ip.ip_id)
+       } else
+               cs->cs_ip.ip_id = htons(ntohs(cs->cs_ip.ip_id) + 1);
+
+       /*
+        * At this point, cp points to the first byte of data in the
+        * packet.  Fill in the IP total length and update the IP
+        * header checksum.
+        */
+       vjlen = cp - buf;
+       buflen -= vjlen;
+       if (buflen < 0)
+               /* we must have dropped some characters (crc should detect
+                * this but the old slip framing won't) */
+               goto bad;
+
+       total_len += cs->cs_hlen - vjlen;
+       cs->cs_ip.ip_len = htons(total_len);
+
+       /* recompute the ip header checksum */
+       bp = (u_int16_t *) &cs->cs_ip;
+       cs->cs_ip.ip_sum = 0;
+       for (changes = 0; hlen > 0; hlen -= 2)
+               changes += *bp++;
+       changes = (changes & 0xffff) + (changes >> 16);
+       changes = (changes & 0xffff) + (changes >> 16);
+       cs->cs_ip.ip_sum = ~ changes;
+
+       *hdrp = (u_char *) &cs->cs_ip;
+       *hlenp = cs->cs_hlen;
+       return vjlen;
+
+bad:
+       comp->flags |= SLF_TOSS;
+       INCR(sls_errorin)
+       return (-1);
+}
diff --git a/netbsd-1.1/slcompress.h b/netbsd-1.1/slcompress.h
new file mode 100644 (file)
index 0000000..5ce0946
--- /dev/null
@@ -0,0 +1,162 @@
+/*     $Id: slcompress.h,v 1.1 1995/12/11 05:17:12 paulus Exp $        */
+
+/*
+ * Copyright (c) 1989, 1993
+ *     The Regents of the University of California.  All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ * 1. Redistributions of source code must retain the above copyright
+ *    notice, this list of conditions and the following disclaimer.
+ * 2. Redistributions in binary form must reproduce the above copyright
+ *    notice, this list of conditions and the following disclaimer in the
+ *    documentation and/or other materials provided with the distribution.
+ * 3. All advertising materials mentioning features or use of this software
+ *    must display the following acknowledgement:
+ *     This product includes software developed by the University of
+ *     California, Berkeley and its contributors.
+ * 4. Neither the name of the University nor the names of its contributors
+ *    may be used to endorse or promote products derived from this software
+ *    without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
+ * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
+ * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
+ * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
+ * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
+ * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
+ * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
+ * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
+ * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
+ * SUCH DAMAGE.
+ *
+ *     @(#)slcompress.h        8.1 (Berkeley) 6/10/93
+ */
+
+/*
+ * Definitions for tcp compression routines.
+ *
+ * Van Jacobson (van@helios.ee.lbl.gov), Dec 31, 1989:
+ *     - Initial distribution.
+ */
+
+#define MAX_STATES 16          /* must be > 2 and < 256 */
+#define MAX_HDR MLEN           /* XXX 4bsd-ism: should really be 128 */
+
+/*
+ * Compressed packet format:
+ *
+ * The first octet contains the packet type (top 3 bits), TCP
+ * 'push' bit, and flags that indicate which of the 4 TCP sequence
+ * numbers have changed (bottom 5 bits).  The next octet is a
+ * conversation number that associates a saved IP/TCP header with
+ * the compressed packet.  The next two octets are the TCP checksum
+ * from the original datagram.  The next 0 to 15 octets are
+ * sequence number changes, one change per bit set in the header
+ * (there may be no changes and there are two special cases where
+ * the receiver implicitly knows what changed -- see below).
+ * 
+ * There are 5 numbers which can change (they are always inserted
+ * in the following order): TCP urgent pointer, window,
+ * acknowlegement, sequence number and IP ID.  (The urgent pointer
+ * is different from the others in that its value is sent, not the
+ * change in value.)  Since typical use of SLIP links is biased
+ * toward small packets (see comments on MTU/MSS below), changes
+ * use a variable length coding with one octet for numbers in the
+ * range 1 - 255 and 3 octets (0, MSB, LSB) for numbers in the
+ * range 256 - 65535 or 0.  (If the change in sequence number or
+ * ack is more than 65535, an uncompressed packet is sent.)
+ */
+
+/*
+ * Packet types (must not conflict with IP protocol version)
+ *
+ * The top nibble of the first octet is the packet type.  There are
+ * three possible types: IP (not proto TCP or tcp with one of the
+ * control flags set); uncompressed TCP (a normal IP/TCP packet but
+ * with the 8-bit protocol field replaced by an 8-bit connection id --
+ * this type of packet syncs the sender & receiver); and compressed
+ * TCP (described above).
+ *
+ * LSB of 4-bit field is TCP "PUSH" bit (a worthless anachronism) and
+ * is logically part of the 4-bit "changes" field that follows.  Top
+ * three bits are actual packet type.  For backward compatibility
+ * and in the interest of conserving bits, numbers are chosen so the
+ * IP protocol version number (4) which normally appears in this nibble
+ * means "IP packet".
+ */
+
+/* packet types */
+#define TYPE_IP 0x40
+#define TYPE_UNCOMPRESSED_TCP 0x70
+#define TYPE_COMPRESSED_TCP 0x80
+#define TYPE_ERROR 0x00
+
+/* Bits in first octet of compressed packet */
+#define NEW_C  0x40    /* flag bits for what changed in a packet */
+#define NEW_I  0x20
+#define NEW_S  0x08
+#define NEW_A  0x04
+#define NEW_W  0x02
+#define NEW_U  0x01
+
+/* reserved, special-case values of above */
+#define SPECIAL_I (NEW_S|NEW_W|NEW_U)          /* echoed interactive traffic */
+#define SPECIAL_D (NEW_S|NEW_A|NEW_W|NEW_U)    /* unidirectional data */
+#define SPECIALS_MASK (NEW_S|NEW_A|NEW_W|NEW_U)
+
+#define TCP_PUSH_BIT 0x10
+
+
+/*
+ * "state" data for each active tcp conversation on the wire.  This is
+ * basically a copy of the entire IP/TCP header from the last packet
+ * we saw from the conversation together with a small identifier
+ * the transmit & receive ends of the line use to locate saved header.
+ */
+struct cstate {
+       struct cstate *cs_next; /* next most recently used cstate (xmit only) */
+       u_int16_t cs_hlen;      /* size of hdr (receive only) */
+       u_char cs_id;           /* connection # associated with this state */
+       u_char cs_filler;
+       union {
+               char csu_hdr[MAX_HDR];
+               struct ip csu_ip;       /* ip/tcp hdr from most recent packet */
+       } slcs_u;
+};
+#define cs_ip slcs_u.csu_ip
+#define cs_hdr slcs_u.csu_hdr
+
+/*
+ * all the state data for one serial line (we need one of these
+ * per line).
+ */
+struct slcompress {
+       struct cstate *last_cs; /* most recently used tstate */
+       u_char last_recv;       /* last rcvd conn. id */
+       u_char last_xmit;       /* last sent conn. id */
+       u_int16_t flags;
+#ifndef SL_NO_STATS
+       int sls_packets;        /* outbound packets */
+       int sls_compressed;     /* outbound compressed packets */
+       int sls_searches;       /* searches for connection state */
+       int sls_misses;         /* times couldn't find conn. state */
+       int sls_uncompressedin; /* inbound uncompressed packets */
+       int sls_compressedin;   /* inbound compressed packets */
+       int sls_errorin;        /* inbound unknown type packets */
+       int sls_tossed;         /* inbound packets tossed because of error */
+#endif
+       struct cstate tstate[MAX_STATES];       /* xmit connection states */
+       struct cstate rstate[MAX_STATES];       /* receive connection states */
+};
+/* flag values */
+#define SLF_TOSS 1             /* tossing rcvd frames because of input err */
+
+void    sl_compress_init __P((struct slcompress *, int));
+u_int   sl_compress_tcp __P((struct mbuf *,
+           struct ip *, struct slcompress *, int));
+int     sl_uncompress_tcp __P((u_char **, int, u_int, struct slcompress *));
+int     sl_uncompress_tcp_core __P((u_char *, int, int, u_int,
+           struct slcompress *, u_char **, u_int *));