nasty little bug in packet reassembly
[unix-history] / usr / src / sys / netinet / tcp_input.c
index 7f119fc..d00ead0 100644 (file)
-/* tcp_input.c 1.29 81/11/24 */
+/*     tcp_input.c     1.71    82/06/30        */
 
 #include "../h/param.h"
 #include "../h/systm.h"
 #include "../h/mbuf.h"
 
 #include "../h/param.h"
 #include "../h/systm.h"
 #include "../h/mbuf.h"
+#include "../h/protosw.h"
 #include "../h/socket.h"
 #include "../h/socketvar.h"
 #include "../h/socket.h"
 #include "../h/socketvar.h"
-#include "../net/inet.h"
-#include "../net/inet_pcb.h"
-#include "../net/inet_systm.h"
-#include "../net/imp.h"
+#include "../net/in.h"
+#include "../net/route.h"
+#include "../net/in_pcb.h"
+#include "../net/in_systm.h"
+#include "../net/if.h"
 #include "../net/ip.h"
 #include "../net/ip_var.h"
 #include "../net/tcp.h"
 #include "../net/tcp_fsm.h"
 #include "../net/ip.h"
 #include "../net/ip_var.h"
 #include "../net/tcp.h"
 #include "../net/tcp_fsm.h"
+#include "../net/tcp_seq.h"
+#include "../net/tcp_timer.h"
 #include "../net/tcp_var.h"
 #include "../net/tcp_var.h"
-#include "/usr/include/errno.h"
+#include "../net/tcpip.h"
+#include "../net/tcp_debug.h"
+#include <errno.h>
 
 
+int    tcpprintfs = 0;
 int    tcpcksum = 1;
 int    tcpcksum = 1;
+struct sockaddr_in tcp_in = { AF_INET };
+struct tcpiphdr tcp_saveti;
+extern tcpnodelack;
 
 
-tcp_drain()
-{
-       register struct inpcb *ip;
-
-COUNT(TCP_DRAIN);
-       for (ip = tcb.inp_next; ip != &tcb; ip = ip->inp_next)
-               tcp_drainunack(intotcpcb(ip));
-}
-
-tcp_drainunack(tp)
-       register struct tcpcb *tp;
-{
-       register struct mbuf *m;
-
-COUNT(TCP_DRAINUNACK);
-       for (m = tp->seg_unack; m; m = m->m_act)
-               m_freem(m);
-       tp->seg_unack = 0;
-}
-       
-tcp_ctlinput(m)
-       struct mbuf *m;
-{
-
-COUNT(TCP_CTLINPUT);
-       m_freem(m);
-}
-
-struct sockaddr_in tcp_sockaddr = { AF_INET };
-
+struct tcpcb *tcp_newtcpcb();
+/*
+ * TCP input routine, follows pages 65-76 of the
+ * protocol specification dated September, 1981 very closely.
+ */
 tcp_input(m0)
        struct mbuf *m0;
 {
        register struct tcpiphdr *ti;
        struct inpcb *inp;
        register struct mbuf *m;
 tcp_input(m0)
        struct mbuf *m0;
 {
        register struct tcpiphdr *ti;
        struct inpcb *inp;
        register struct mbuf *m;
+       struct mbuf *om = 0;
        int len, tlen, off;
        int len, tlen, off;
-
-       register struct tcpcb *tp;
-       register int j;
+       register struct tcpcb *tp = 0;
        register int tiflags;
        register int tiflags;
-       int nstate;
        struct socket *so;
        struct socket *so;
-#ifdef TCPDEBUG
-       struct tcp_debug tdb;
-#endif
+       int todrop, acked;
+       short ostate;
+       struct in_addr laddr;
 
 
-COUNT(TCP_INPUT);
        /*
        /*
-        * Get ip and tcp header together in first mbuf.
+        * Get IP and TCP header together in first mbuf.
+        * Note: IP leaves IP header in first mbuf.
         */
        m = m0;
         */
        m = m0;
-       if (m->m_len < sizeof (struct tcpiphdr) &&
-           m_pullup(m, sizeof (struct tcpiphdr)) == 0) {
-               tcpstat.tcps_hdrops++;
-               goto bad;
-       }
        ti = mtod(m, struct tcpiphdr *);
        ti = mtod(m, struct tcpiphdr *);
-       if (ti->ti_len > sizeof (struct ip))
-               ip_stripoptions((struct ip *)ti, (char *)0);
+       if (((struct ip *)ti)->ip_hl > (sizeof (struct ip) >> 2))
+               ip_stripoptions((struct ip *)ti, (struct mbuf *)0);
+       if (m->m_off > MMAXOFF || m->m_len < sizeof (struct tcpiphdr)) {
+               if ((m = m_pullup(m, sizeof (struct tcpiphdr))) == 0) {
+                       tcpstat.tcps_hdrops++;
+                       return;
+               }
+               ti = mtod(m, struct tcpiphdr *);
+       }
 
        /*
 
        /*
-        * Checksum extended tcp header and data.
+        * Checksum extended TCP header and data.
         */
        tlen = ((struct ip *)ti)->ip_len;
        len = sizeof (struct ip) + tlen;
        if (tcpcksum) {
                ti->ti_next = ti->ti_prev = 0;
                ti->ti_x1 = 0;
         */
        tlen = ((struct ip *)ti)->ip_len;
        len = sizeof (struct ip) + tlen;
        if (tcpcksum) {
                ti->ti_next = ti->ti_prev = 0;
                ti->ti_x1 = 0;
-               ti->ti_len = htons((u_short)tlen);
-               if ((ti->ti_sum = inet_cksum(m, len)) != 0xffff) {
+               ti->ti_len = (u_short)tlen;
+#if vax || pdp11
+               ti->ti_len = htons((u_short)ti->ti_len);
+#endif
+               if (ti->ti_sum = in_cksum(m, len)) {
                        tcpstat.tcps_badsum++;
                        tcpstat.tcps_badsum++;
-                       printf("tcp cksum %x\ti", ti->ti_sum);
-                       goto bad;
+                       if (tcpprintfs)
+                               printf("tcp cksum %x\n", ti->ti_sum);
+                       goto drop;
                }
        }
 
        /*
                }
        }
 
        /*
-        * Check that tcp offset makes sense,
-        * process tcp options and adjust length.
+        * Check that TCP offset makes sense,
+        * pull out TCP options and adjust length.
         */
        off = ti->ti_off << 2;
         */
        off = ti->ti_off << 2;
-       if (off < sizeof (struct tcphdr) || off > ti->ti_len) {
+       if (off < sizeof (struct tcphdr) || off > tlen) {
                tcpstat.tcps_badoff++;
                tcpstat.tcps_badoff++;
-               goto bad;
+               goto drop;
+       }
+       tlen -= off;
+       ti->ti_len = tlen;
+       if (off > sizeof (struct tcphdr)) {
+               if ((m = m_pullup(m, sizeof (struct ip) + off)) == 0) {
+                       tcpstat.tcps_hdrops++;
+                       goto drop;
+               }
+               ti = mtod(m, struct tcpiphdr *);
+               om = m_get(M_DONTWAIT);
+               if (om == 0)
+                       goto drop;
+               om->m_off = MMINOFF;
+               om->m_len = off - sizeof (struct tcphdr);
+               { caddr_t op = mtod(m, caddr_t) + sizeof (struct tcpiphdr);
+                 bcopy(op, mtod(om, caddr_t), (unsigned)om->m_len);
+                 m->m_len -= om->m_len;
+                 bcopy(op+om->m_len, op,
+                  (unsigned)(m->m_len-sizeof (struct tcpiphdr)));
+               }
        }
        }
-       ti->ti_len = tlen - off;
-       /* PROCESS OPTIONS */
+       tiflags = ti->ti_flags;
 
        /*
 
        /*
-        * Locate pcb for segment.
+        * Drop TCP and IP headers.
         */
         */
-       inp = in_pcblookup(&tcb, ti->ti_src, ti->ti_sport, ti->ti_dst, ti->ti_dport);
-       if (inp == 0)
-               goto notwanted;
-       tp = intotcpcb(inp);            /* ??? */
-       if (tp == 0)                    /* ??? */
-               goto notwanted;         /* ??? */
+       off += sizeof (struct ip);
+       m->m_off += off;
+       m->m_len -= off;
 
 
+#if vax || pdp11
        /*
        /*
-        * Convert tcp protocol specific fields to host format.
+        * Convert TCP protocol specific fields to host format.
         */
        ti->ti_seq = ntohl(ti->ti_seq);
         */
        ti->ti_seq = ntohl(ti->ti_seq);
-       ti->ti_ackno = ntohl((n_long)ti->ti_ackno);
+       ti->ti_ack = ntohl(ti->ti_ack);
        ti->ti_win = ntohs(ti->ti_win);
        ti->ti_urp = ntohs(ti->ti_urp);
        ti->ti_win = ntohs(ti->ti_win);
        ti->ti_urp = ntohs(ti->ti_urp);
+#endif
 
        /*
 
        /*
-        * Check segment seq # and do rst processing
+        * Locate pcb for segment.  On match, update the local
+        * address stored in the block to reflect anchoring.
         */
         */
-       tiflags = ti->ti_flags;
-       switch (tp->t_state) {
-
-       case LISTEN:
-               if ((tiflags&TH_ACK) || (tiflags&TH_SYN) == 0) {
-                       tcp_sndrst(tp, ti);
-                       goto bad;
-               }
-               if (tiflags&TH_RST)
-                       goto bad;
-               goto good;
-
-       case SYN_SENT:
-               if (!ack_ok(tp, ti) || (tiflags&TH_SYN) == 0) {
-                       tcp_sndrst(tp, ti);                     /* 71,72,75 */
-                       goto bad;
-               }
-               if (tiflags&TH_RST) {
-                       tcp_drop(tp, ENETRESET);
-                       goto bad;
-               }
-               goto good;
-
-       default:
-               if ((tiflags&TH_RST) == 0)
-                       goto common;
-               if (ti->ti_seq < tp->rcv_nxt)           /* bad rst */
-                       goto bad;                               /* 69 */
-               switch (tp->t_state) {
-
-               case L_SYN_RCVD:
-                       if (ack_ok(tp, ti) == 0)
-                               goto bad;                       /* 69 */
-                       tp->t_rexmt = 0;
-                       tp->t_rexmttl = 0;
-                       tp->t_persist = 0;
-                       inp->inp_faddr.s_addr = 0;
-                       tp->t_state = LISTEN;
-                       goto bad;
+       inp = in_pcblookup
+               (&tcb, ti->ti_src, ti->ti_sport, ti->ti_dst, ti->ti_dport,
+               INPLOOKUP_WILDCARD);
 
 
-               default:
-                       tcp_drop(tp, ENETRESET);
-                       goto bad;
-               }
-               /*NOTREACHED*/
-
-       case SYN_RCVD:
-common:
-               if (ack_ok(tp, ti) == 0) {
-                       tcp_sndrst(tp, ti);                     /* 74 */
-                       goto bad;
-               }
-               if ((tiflags&TH_SYN) == 0 && ti->ti_seq != tp->irs) {
-                       tcp_sndnull(tp);                        /* 74 */
-                       goto bad;
-               }
-               goto good;
+       /*
+        * If the state is CLOSED (i.e., TCB does not exist) then
+        * all data in the incoming segment is discarded.
+        */
+       if (inp == 0)
+               goto dropwithreset;
+       tp = intotcpcb(inp);
+       if (tp == 0)
+               goto dropwithreset;
+       so = inp->inp_socket;
+       if (so->so_options & SO_DEBUG) {
+               ostate = tp->t_state;
+               tcp_saveti = *ti;
        }
        }
-bad:
-       m_freem(m);
-       return;
 
 
-good:
        /*
        /*
-        * Defer processing if no buffer space for this connection.
+        * Segment received on connection.
+        * Reset idle time and keep-alive timer.
         */
         */
-       so = inp->inp_socket;
-       if (so->so_rcv.sb_cc >= so->so_rcv.sb_hiwat &&
-            ti->ti_len != 0 && mbstat.m_bufs < mbstat.m_lowat) {
-/*
-               m->m_act = (struct mbuf *)0;
-               if ((m = tp->seg_unack) != NULL) {
-                       while (m->m_act != NULL)
-                               m = m->m_act;
-                       m->m_act = m0;
-               } else
-                       tp->seg_unack = m0;
-*/
-               m_freem(m0);
-               return;
+       tp->t_idle = 0;
+       tp->t_timer[TCPT_KEEP] = TCPTV_KEEP;
+
+       /*
+        * Process options.
+        */
+       if (om) {
+               tcp_dooptions(tp, om);
+               om = 0;
        }
 
        /*
        }
 
        /*
-        * Discard ip header, and do tcp input processing.
+        * Calculate amount of space in receive window,
+        * and then do TCP input processing.
         */
         */
-       off += sizeof (struct ip);
-       m->m_off += off;
-       m->m_len -= off;
-       nstate = tp->t_state;
-       tp->tc_flags &= ~TC_NET_KEEP;
-#ifdef KPROF
-       acounts[tp->t_state][INRECV]++;
-#endif
-#ifdef TCPDEBUG
-       if ((tp->t_socket->so_options & SO_DEBUG) || tcpconsdebug) {
-               tdb_setup(tp, ti, INRECV, &tdb);
-       } else
-               tdb.td_tod = 0;
-#endif
+       tp->rcv_wnd = sbspace(&so->so_rcv);
+       if (tp->rcv_wnd < 0)
+               tp->rcv_wnd = 0;
+
        switch (tp->t_state) {
 
        switch (tp->t_state) {
 
-       case LISTEN:
-               tcp_sockaddr.sin_addr = ti->ti_src;
-               tcp_sockaddr.sin_port = ti->ti_sport;
-               if ((tiflags&TH_SYN) == 0 || in_pcbsetpeer(inp, &tcp_sockaddr)) {
-                       nstate = EFAILEC;
-                       goto done;
+       /*
+        * If the state is LISTEN then ignore segment if it contains an RST.
+        * If the segment contains an ACK then it is bad and send a RST.
+        * If it does not contain a SYN then it is not interesting; drop it.
+        * Otherwise initialize tp->rcv_nxt, and tp->irs, select an initial
+        * tp->iss, and send a segment:
+        *     <SEQ=ISS><ACK=RCV_NXT><CTL=SYN,ACK>
+        * Also initialize tp->snd_nxt to tp->iss+1 and tp->snd_una to tp->iss.
+        * Fill in remote peer address fields if not previously specified.
+        * Enter SYN_RECEIVED state, and process any other fields of this
+        * segment in this state.
+        */
+       case TCPS_LISTEN:
+               if (tiflags & TH_RST)
+                       goto drop;
+               if (tiflags & TH_ACK)
+                       goto dropwithreset;
+               if ((tiflags & TH_SYN) == 0)
+                       goto drop;
+               tcp_in.sin_addr = ti->ti_src;
+               tcp_in.sin_port = ti->ti_sport;
+               laddr = inp->inp_laddr;
+               if (inp->inp_laddr.s_addr == 0)
+                       inp->inp_laddr = ti->ti_dst;
+               if (in_pcbconnect(inp, (struct sockaddr_in *)&tcp_in)) {
+                       inp->inp_laddr = laddr;
+                       goto drop;
                }
                tp->t_template = tcp_template(tp);
                }
                tp->t_template = tcp_template(tp);
-               tcp_ctldat(tp, ti, 1);
-               if (tp->tc_flags&TC_FIN_RCVD) {
-                       tp->t_finack = T_2ML;                   /* 3 */
-                       nstate = CLOSE_WAIT;
-               } else {
-                       tp->t_init = T_INIT / 2;                /* 4 */
-                       nstate = L_SYN_RCVD;
+               if (tp->t_template == 0) {
+                       in_pcbdisconnect(inp);
+                       inp->inp_laddr = laddr;
+                       tp = 0;
+                       goto drop;
                }
                }
-               goto done;
+               tp->iss = tcp_iss; tcp_iss += TCP_ISSINCR/2;
+               tp->irs = ti->ti_seq;
+               tcp_sendseqinit(tp);
+               tcp_rcvseqinit(tp);
+               tp->t_state = TCPS_SYN_RECEIVED;
+               tp->t_timer[TCPT_KEEP] = TCPTV_KEEP;
+               goto trimthenstep6;
 
 
-       case SYN_SENT:
-               if (!syn_ok(tp, ti)) {
-                       nstate = EFAILEC;
-                       goto done;
-               }
-               tcp_ctldat(tp, ti, 1);
-               if (tp->tc_flags&TC_FIN_RCVD) {
-                       if ((tiflags&TH_ACK) == 0)
-                               tp->t_finack = T_2ML;           /* 9 */
-                       nstate = CLOSE_WAIT;
-                       goto done;
-               }
-               nstate = (tiflags&TH_ACK) ? ESTAB : SYN_RCVD; /* 11:8 */
-               goto done;
-
-       case SYN_RCVD:
-       case L_SYN_RCVD:
-               if ((tiflags&TH_ACK) == 0 ||
-                   (tiflags&TH_ACK) && ti->ti_ackno <= tp->iss) {
-                       nstate = EFAILEC;
-                       goto done;
+       /*
+        * If the state is SYN_SENT:
+        *      if seg contains an ACK, but not for our SYN, drop the input.
+        *      if seg contains a RST, then drop the connection.
+        *      if seg does not contain SYN, then drop it.
+        * Otherwise this is an acceptable SYN segment
+        *      initialize tp->rcv_nxt and tp->irs
+        *      if seg contains ack then advance tp->snd_una
+        *      if SYN has been acked change to ESTABLISHED else SYN_RCVD state
+        *      arrange for segment to be acked (eventually)
+        *      continue processing rest of data/controls, beginning with URG
+        */
+       case TCPS_SYN_SENT:
+               if ((tiflags & TH_ACK) &&
+/* this should be SEQ_LT; is SEQ_LEQ for BBN vax TCP only */
+                   (SEQ_LT(ti->ti_ack, tp->iss) ||
+                    SEQ_GT(ti->ti_ack, tp->snd_max)))
+                       goto dropwithreset;
+               if (tiflags & TH_RST) {
+                       if (tiflags & TH_ACK) {
+                               tcp_drop(tp, ECONNREFUSED);
+                               tp = 0;
+                       }
+                       goto drop;
                }
                }
-               goto input;
-
-       case ESTAB:
-       case FIN_W1:
-       case FIN_W2:
-       case TIME_WAIT:
-input:
-               tcp_ctldat(tp, ti, 1);                          /* 39 */
-               switch (tp->t_state) {
-
-               case ESTAB:
-                       if (tp->tc_flags&TC_FIN_RCVD)
-                               nstate = CLOSE_WAIT;
-                       break;
+               if ((tiflags & TH_SYN) == 0)
+                       goto drop;
+               tp->snd_una = ti->ti_ack;
+               if (SEQ_LT(tp->snd_nxt, tp->snd_una))
+                       tp->snd_nxt = tp->snd_una;
+               tp->t_timer[TCPT_REXMT] = 0;
+               tp->irs = ti->ti_seq;
+               tcp_rcvseqinit(tp);
+               tp->t_flags |= TF_ACKNOW;
+               if (SEQ_GT(tp->snd_una, tp->iss)) {
+                       if (so->so_options & SO_ACCEPTCONN)
+                               so->so_state |= SS_CONNAWAITING;
+                       soisconnected(so);
+                       tp->t_state = TCPS_ESTABLISHED;
+                       (void) tcp_reass(tp, (struct tcpiphdr *)0);
+               } else
+                       tp->t_state = TCPS_SYN_RECEIVED;
+               goto trimthenstep6;
 
 
-               case SYN_RCVD:
-               case L_SYN_RCVD:
-                       nstate = (tp->tc_flags&TC_FIN_RCVD) ?
-                           CLOSE_WAIT : ESTAB;                  /* 33:5 */
-                       break;
+trimthenstep6:
+               /*
+                * Advance ti->ti_seq to correspond to first data byte.
+                * If data, trim to stay within window,
+                * dropping FIN if necessary.
+                */
+               ti->ti_seq++;
+               if (ti->ti_len > tp->rcv_wnd) {
+                       todrop = ti->ti_len - tp->rcv_wnd;
+                       m_adj(m, -todrop);
+                       ti->ti_len = tp->rcv_wnd;
+                       ti->ti_flags &= ~TH_FIN;
+               }
+               tp->snd_wl1 = ti->ti_seq - 1;
+               goto step6;
+       }
 
 
-               case FIN_W1:
-                       j = ack_fin(tp, ti);
-                       if ((tp->tc_flags & TC_FIN_RCVD) == 0) {
-                               if (j)
-                                       nstate = FIN_W2;        /* 27 */
-                               break;
+       /*
+        * States other than LISTEN or SYN_SENT.
+        * First check that at least some bytes of segment are within 
+        * receive window.
+        */
+       if (tp->rcv_wnd == 0) {
+               /*
+                * If window is closed can only take segments at
+                * window edge, and have to drop data and PUSH from
+                * incoming segments.
+                */
+               if (tp->rcv_nxt != ti->ti_seq)
+                       goto dropafterack;
+               if (ti->ti_len > 0) {
+                       m_adj(m, ti->ti_len);
+                       ti->ti_len = 0;
+                       ti->ti_flags &= ~(TH_PUSH|TH_FIN);
+               }
+       } else {
+               /*
+                * If segment begins before rcv_nxt, drop leading
+                * data (and SYN); if nothing left, just ack.
+                */
+               todrop = tp->rcv_nxt - ti->ti_seq;
+               if (todrop > 0) {
+                       if (tiflags & TH_SYN) {
+                               tiflags &= ~TH_SYN;
+                               ti->ti_flags &= ~TH_SYN;
+                               ti->ti_seq++;
+                               if (ti->ti_urp > 1) 
+                                       ti->ti_urp--;
+                               else
+                                       tiflags &= ~TH_URG;
+                               todrop--;
                        }
                        }
-                       tp->t_finack = T_2ML;
-                       nstate = j ? TIME_WAIT : CLOSING;       /* 28:26 */
-                       break;
-
-               case FIN_W2:
-                       if (tp->tc_flags&TC_FIN_RCVD) {
-                               tp->t_finack = T_2ML;           /* 29 */
-                               nstate = TIME_WAIT;
-                               break;
+                       if (todrop > ti->ti_len ||
+                           todrop == ti->ti_len && (tiflags&TH_FIN) == 0)
+                               goto dropafterack;
+                       m_adj(m, todrop);
+                       ti->ti_seq += todrop;
+                       ti->ti_len -= todrop;
+                       if (ti->ti_urp > todrop)
+                               ti->ti_urp -= todrop;
+                       else {
+                               tiflags &= ~TH_URG;
+                               ti->ti_flags &= ~TH_URG;
+                               ti->ti_urp = 0;
                        }
                        }
-                       break;
-               }
-               goto done;
-
-       case CLOSE_WAIT:
-               if (tiflags&TH_FIN) {
-                       if ((tiflags&TH_ACK) &&
-                           ti->ti_ackno <= tp->seq_fin) {
-                               tcp_ctldat(tp, ti, 0);          /* 30 */
-                               tp->t_finack = T_2ML;
-                       } else
-                               (void) tcp_sndctl(tp);          /* 31 */
-                       goto done;
-               }
-               goto input;
-
-       case CLOSING:
-               j = ack_fin(tp, ti);
-               if (tiflags&TH_FIN) {
-                       tcp_ctldat(tp, ti, 0);
-                       tp->t_finack = T_2ML;
-                       if (j)
-                               nstate = TIME_WAIT;             /* 23 */
-                       goto done;
-               }
-               if (j) {
-                       if (tp->t_finack == 0)
-                               if (rcv_empty(tp)) {
-                                       sorwakeup(inp->inp_socket);
-                                       nstate = CLOSED;        /* 15 */
-                               } else
-                                       nstate = RCV_WAIT;      /* 18 */
-                       else
-                               nstate = TIME_WAIT;
-                       goto done;
                }
                }
-               goto input;
-
-       case LAST_ACK:
-               if (ack_fin(tp, ti)) {
-                       if (rcv_empty(tp)) {            /* 16 */
-                               sorwakeup(inp->inp_socket);
-                               nstate = CLOSED;
-                       } else
-                               nstate = RCV_WAIT;              /* 19 */
-                       goto done;
-               }
-               if (tiflags&TH_FIN) {
-                       (void) tcp_sndctl(tp);                  /* 31 */
-                       goto done;
+               /*
+                * If segment ends after window, drop trailing data
+                * (and PUSH and FIN); if nothing left, just ACK.
+                */
+               todrop = (ti->ti_seq+ti->ti_len) - (tp->rcv_nxt+tp->rcv_wnd);
+               if (todrop > 0) {
+                       if (todrop >= ti->ti_len)
+                               goto dropafterack;
+                       m_adj(m, -todrop);
+                       ti->ti_len -= todrop;
+                       ti->ti_flags &= ~(TH_PUSH|TH_FIN);
                }
                }
-               goto input;
+       }
 
 
-       case RCV_WAIT:
-               if ((tiflags&TH_FIN) && (tiflags&TH_ACK) &&
-                   ti->ti_ackno <= tp->seq_fin) {
-                       tcp_ctldat(tp, ti, 0);
-                       tp->t_finack = T_2ML;                   /* 30 */
+       /*
+        * If a segment is received on a connection after the
+        * user processes are gone, then RST the other end.
+        */
+       if (so->so_state & SS_USERGONE) {
+               tcp_close(tp);
+               tp = 0;
+               goto dropwithreset;
+       }
+
+       /*
+        * If the RST bit is set examine the state:
+        *    SYN_RECEIVED STATE:
+        *      If passive open, return to LISTEN state.
+        *      If active open, inform user that connection was refused.
+        *    ESTABLISHED, FIN_WAIT_1, FIN_WAIT2, CLOSE_WAIT STATES:
+        *      Inform user that connection was reset, and close tcb.
+        *    CLOSING, LAST_ACK, TIME_WAIT STATES
+        *      Close the tcb.
+        */
+       if (tiflags&TH_RST) switch (tp->t_state) {
+
+       case TCPS_SYN_RECEIVED:
+               if (inp->inp_socket->so_options & SO_ACCEPTCONN) {
+                       /* a miniature tcp_close, but invisible to user */
+                       (void) m_free(dtom(tp->t_template));
+                       (void) m_free(dtom(tp));
+                       inp->inp_ppcb = 0;
+                       tp = tcp_newtcpcb(inp);
+                       tp->t_state = TCPS_LISTEN;
+                       inp->inp_faddr.s_addr = 0;
+                       inp->inp_fport = 0;
+                       inp->inp_laddr.s_addr = 0;      /* not quite right */
+                       tp = 0;
+                       goto drop;
                }
                }
-               goto done;
+               tcp_drop(tp, ECONNREFUSED);
+               tp = 0;
+               goto drop;
+
+       case TCPS_ESTABLISHED:
+       case TCPS_FIN_WAIT_1:
+       case TCPS_FIN_WAIT_2:
+       case TCPS_CLOSE_WAIT:
+               tcp_drop(tp, ECONNRESET);
+               tp = 0;
+               goto drop;
+
+       case TCPS_CLOSING:
+       case TCPS_LAST_ACK:
+       case TCPS_TIME_WAIT:
+               tcp_close(tp);
+               tp = 0;
+               goto drop;
        }
        }
-       panic("tcp_input");
-done:
 
        /*
 
        /*
-        * Done with state*input specific processing.
-        * Form trace records, free input if not needed,
-        * and enter new state.
+        * If a SYN is in the window, then this is an
+        * error and we send an RST and drop the connection.
         */
         */
-#ifdef TCPDEBUG
-       if (tdb.td_tod)
-               tdb_stuff(&tdb, nstate);
-#endif
-       switch (nstate) {
+       if (tiflags & TH_SYN) {
+               tcp_drop(tp, ECONNRESET);
+               tp = 0;
+               goto dropwithreset;
+       }
 
 
-       case EFAILEC:
-               m_freem(m);
-               return;
+       /*
+        * If the ACK bit is off we drop the segment and return.
+        */
+       if ((tiflags & TH_ACK) == 0)
+               goto drop;
+       
+       /*
+        * Ack processing.
+        */
+       switch (tp->t_state) {
 
 
-       default:
-               tp->t_state = nstate;
+       /*
+        * In SYN_RECEIVED state if the ack ACKs our SYN then enter
+        * ESTABLISHED state and continue processing, othewise
+        * send an RST.
+        */
+       case TCPS_SYN_RECEIVED:
+               if (SEQ_GT(tp->snd_una, ti->ti_ack) ||
+                   SEQ_GT(ti->ti_ack, tp->snd_max))
+                       goto dropwithreset;
+               tp->snd_una++;                  /* SYN acked */
+               if (SEQ_LT(tp->snd_nxt, tp->snd_una))
+                       tp->snd_nxt = tp->snd_una;
+               tp->t_timer[TCPT_REXMT] = 0;
+               if (so->so_options & SO_ACCEPTCONN)
+                       so->so_state |= SS_CONNAWAITING;
+               soisconnected(so);
+               tp->t_state = TCPS_ESTABLISHED;
+               (void) tcp_reass(tp, (struct tcpiphdr *)0);
+               tp->snd_wl1 = ti->ti_seq - 1;
                /* fall into ... */
 
                /* fall into ... */
 
-       case CLOSED:
-               /* IF CLOSED CANT LOOK AT tc_flags */
-               if ((tp->tc_flags&TC_NET_KEEP) == 0) {
-                       register struct mbuf *n;
-                       /* inline expansion of m_freem */
-                       while (m) {
-                               MFREE(m, n);
-                               m = n;
-                       }
-               }
-               return;
-       }
-       /* NOTREACHED */
-
-       /*
-        * Unwanted packed; free everything
-        * but the header and return an rst.
-        */
-notwanted:
-       m_freem(m->m_next);
-       m->m_next = NULL;
-       m->m_len = sizeof(struct tcpiphdr);
-#define xchg(a,b) j=a; a=b; b=j
-       xchg(ti->ti_dst.s_addr, ti->ti_src.s_addr);
-       xchg(ti->ti_dport, ti->ti_sport);
-#undef xchg
-       if (tiflags&TH_ACK)
-               ti->ti_seq = ti->ti_ackno;
-       else {
-               ti->ti_ackno = htonl((unsigned)(ntohl(ti->ti_seq) + ti->ti_len));
-               ti->ti_seq = 0;
-       }
-       ti->ti_flags = ((tiflags & TH_ACK) ? 0 : TH_ACK) | TH_RST;
-       ti->ti_len = htons(TCPSIZE);
-       ti->ti_off = 5;
-       ti->ti_sum = inet_cksum(m, sizeof(struct tcpiphdr));
-       ((struct ip *)ti)->ip_len = sizeof(struct tcpiphdr);
-       ((struct ip *)ti)->ip_ttl = MAXTTL;
-       ip_output(m);
-       tcpstat.tcps_badsegs++;
-}
+       /*
+        * In ESTABLISHED state: drop duplicate ACKs; ACK out of range
+        * ACKs.  If the ack is in the range
+        *      tp->snd_una < ti->ti_ack <= tp->snd_max
+        * then advance tp->snd_una to ti->ti_ack and drop
+        * data from the retransmission queue.  If this ACK reflects
+        * more up to date window information we update our window information.
+        */
+       case TCPS_ESTABLISHED:
+       case TCPS_FIN_WAIT_1:
+       case TCPS_FIN_WAIT_2:
+       case TCPS_CLOSE_WAIT:
+       case TCPS_CLOSING:
+       case TCPS_LAST_ACK:
+       case TCPS_TIME_WAIT:
+#define        ourfinisacked   (acked > 0)
+
+               if (SEQ_LEQ(ti->ti_ack, tp->snd_una))
+                       break;
+               if (SEQ_GT(ti->ti_ack, tp->snd_max))
+                       goto dropafterack;
+               acked = ti->ti_ack - tp->snd_una;
 
 
-tcp_ctldat(tp, n0, dataok)
-       register struct tcpcb *tp;
-       struct tcpiphdr *n0;
-       int dataok;
-{
-       register struct tcpiphdr *ti = n0;
-       register int tiflags = ti->ti_flags;
-       struct socket *so = tp->t_inpcb->inp_socket;
-       seq_t past = ti->ti_seq + ti->ti_len;
-       seq_t urgent;
-       int sent;
-COUNT(TCP_CTLDAT);
-
-       if (tiflags & TH_URG)
-               urgent = ti->ti_seq + ti->ti_urp;
-       tp->tc_flags &= ~(TC_ACK_DUE|TC_NEW_WINDOW);
-/* syn */
-       if ((tp->tc_flags&TC_SYN_RCVD) == 0 && (tiflags&TH_SYN)) {
-               tp->irs = ti->ti_seq;
-               tp->rcv_nxt = ti->ti_seq + 1;
-               tp->snd_wl = tp->rcv_urp = tp->irs;
-               tp->tc_flags |= (TC_SYN_RCVD|TC_ACK_DUE);
-       }
-/* ack */
-       if ((tiflags&TH_ACK) && (tp->tc_flags&TC_SYN_RCVD) &&
-           ti->ti_ackno > tp->snd_una) {
                /*
                /*
-                * Reflect newly acknowledged data.
+                * If transmit timer is running and timed sequence
+                * number was acked, update smoothed round trip time.
                 */
                 */
-               tp->snd_una = ti->ti_ackno;
-               if (tp->snd_una > tp->snd_nxt)
+               if (tp->t_rtt && SEQ_GT(ti->ti_ack, tp->t_rtseq)) {
+                       if (tp->t_srtt == 0)
+                               tp->t_srtt = tp->t_rtt;
+                       else
+                               tp->t_srtt =
+                                   tcp_alpha * tp->t_srtt +
+                                   (1 - tcp_alpha) * tp->t_rtt;
+/* printf("rtt %d srtt*100 now %d\n", tp->t_rtt, (int)(tp->t_srtt*100)); */
+                       tp->t_rtt = 0;
+               }
+
+               if (ti->ti_ack == tp->snd_max)
+                       tp->t_timer[TCPT_REXMT] = 0;
+               else {
+                       TCPT_RANGESET(tp->t_timer[TCPT_REXMT],
+                           tcp_beta * tp->t_srtt, TCPTV_MIN, TCPTV_MAX);
+                       tp->t_rtt = 1;
+                       tp->t_rxtshift = 0;
+               }
+               if (acked > so->so_snd.sb_cc) {
+                       sbdrop(&so->so_snd, so->so_snd.sb_cc);
+                       tp->snd_wnd -= so->so_snd.sb_cc;
+               } else {
+                       sbdrop(&so->so_snd, acked);
+                       tp->snd_wnd -= acked;
+                       acked = 0;
+               }
+               if ((so->so_snd.sb_flags & SB_WAIT) || so->so_snd.sb_sel)
+                       sowwakeup(so);
+               tp->snd_una = ti->ti_ack;
+               if (SEQ_LT(tp->snd_nxt, tp->snd_una))
                        tp->snd_nxt = tp->snd_una;
 
                        tp->snd_nxt = tp->snd_una;
 
+               switch (tp->t_state) {
+
                /*
                /*
-                * If timed msg acked, update retransmit time value.
+                * In FIN_WAIT_1 STATE in addition to the processing
+                * for the ESTABLISHED state if our FIN is now acknowledged
+                * then enter FIN_WAIT_2.
                 */
                 */
-               if ((tp->tc_flags&TC_SYN_ACKED) &&
-                   tp->snd_una > tp->t_xmt_val) {
-                       /* NEED SMOOTHING HERE */
-                       tp->t_xmtime = (tp->t_xmt != 0 ? tp->t_xmt : T_REXMT);
-                       if (tp->t_xmtime > T_REMAX)
-                               tp->t_xmtime = T_REMAX;
-               }
+               case TCPS_FIN_WAIT_1:
+                       if (ourfinisacked) {
+                               /*
+                                * If we can't receive any more
+                                * data, then closing user can proceed.
+                                */
+                               if (so->so_state & SS_CANTRCVMORE)
+                                       soisdisconnected(so);
+                               tp->t_state = TCPS_FIN_WAIT_2;
+                       }
+                       break;
+
+               /*
+                * In CLOSING STATE in addition to the processing for
+                * the ESTABLISHED state if the ACK acknowledges our FIN
+                * then enter the TIME-WAIT state, otherwise ignore
+                * the segment.
+                */
+               case TCPS_CLOSING:
+                       if (ourfinisacked) {
+                               tp->t_state = TCPS_TIME_WAIT;
+                               tcp_canceltimers(tp);
+                               tp->t_timer[TCPT_2MSL] = 2 * TCPTV_MSL;
+                               soisdisconnected(so);
+                       }
+                       break;
 
                /*
 
                /*
-                * Remove acked data from send buf
+                * The only thing that can arrive in  LAST_ACK state
+                * is an acknowledgment of our FIN.  If our FIN is now
+                * acknowledged, delete the TCB, enter the closed state
+                * and return.
                 */
                 */
-               sbdrop(&so->so_snd, (int)(tp->snd_una - tp->snd_off));
-               tp->snd_off = tp->snd_una;
-               if ((tp->tc_flags&TC_SYN_ACKED) == 0 &&
-                   (tp->snd_una > tp->iss)) {
-                       tp->tc_flags |= TC_SYN_ACKED;
-                       tp->t_init = 0;
+               case TCPS_LAST_ACK:
+                       if (ourfinisacked) {
+                               tcp_close(tp);
+                               tp = 0;
+                       }
+                       goto drop;
+
+               /*
+                * In TIME_WAIT state the only thing that should arrive
+                * is a retransmission of the remote FIN.  Acknowledge
+                * it and restart the finack timer.
+                */
+               case TCPS_TIME_WAIT:
+                       tp->t_timer[TCPT_2MSL] = 2 * TCPTV_MSL;
+                       goto dropafterack;
                }
                }
-               if (tp->seq_fin != tp->iss && tp->snd_una > tp->seq_fin)
-                       tp->tc_flags &= ~TC_SND_FIN;
-               tp->t_rexmt = 0;
-               tp->t_rexmttl = 0;
-               tp->tc_flags |= TC_CANCELLED;
-               sowwakeup(tp->t_inpcb->inp_socket);
+#undef ourfinisacked
        }
        }
-/* win */
-       if ((tp->tc_flags & TC_SYN_RCVD) && ti->ti_seq >= tp->snd_wl) {
-               tp->snd_wl = ti->ti_seq;
+
+step6:
+       /*
+        * Update window information.
+        */
+       if (SEQ_LT(tp->snd_wl1, ti->ti_seq) || tp->snd_wl1 == ti->ti_seq &&
+           (SEQ_LT(tp->snd_wl2, ti->ti_ack) ||
+            tp->snd_wl2 == ti->ti_ack && ti->ti_win > tp->snd_wnd)) {
                tp->snd_wnd = ti->ti_win;
                tp->snd_wnd = ti->ti_win;
-               tp->tc_flags |= TC_NEW_WINDOW;
-               tp->t_persist = 0;
+               tp->snd_wl1 = ti->ti_seq;
+               tp->snd_wl2 = ti->ti_ack;
+               if (tp->snd_wnd > 0)
+                       tp->t_timer[TCPT_PERSIST] = 0;
        }
        }
-/* text */
-       if (dataok && ti->ti_len) {
-               register struct tcpiphdr *q;
-               int overage;
-
-/* eol */
-               if ((tiflags&TH_EOL)) {
-                       register struct mbuf *m;
-                       for (m = dtom(ti); m->m_next; m = m->m_next)
-                               ;
-                       m->m_act = (struct mbuf *)(mtod(m, caddr_t) - 1);
-               }
 
 
-/* text */
+       /*
+        * Process segments with URG.
+        */
+       if ((tiflags & TH_URG) && ti->ti_urp &&
+           TCPS_HAVERCVDFIN(tp->t_state) == 0) {
                /*
                /*
-                * Discard duplicate data already passed to user.
+                * If this segment advances the known urgent pointer,
+                * then mark the data stream.  This should not happen
+                * in CLOSE_WAIT, CLOSING, LAST_ACK or TIME_WAIT STATES since
+                * a FIN has been received from the remote side. 
+                * In these states we ignore the URG.
                 */
                 */
-               if (SEQ_LT(ti->ti_seq, tp->rcv_nxt)) {
-                       register int i = tp->rcv_nxt - ti->ti_seq;
-                       if (i >= ti->ti_len)
-                               goto notext;
-                       ti->ti_seq += i;
-                       ti->ti_len -= i;
-                       m_adj(dtom(ti), i);
+               if (SEQ_GT(ti->ti_seq+ti->ti_urp, tp->rcv_up)) {
+                       tp->rcv_up = ti->ti_seq + ti->ti_urp;
+                       so->so_oobmark = so->so_rcv.sb_cc +
+                           (tp->rcv_up - tp->rcv_nxt) - 1;
+                       if (so->so_oobmark == 0)
+                               so->so_state |= SS_RCVATMARK;
+#ifdef TCPTRUEOOB
+                       if ((tp->t_flags & TF_DOOOB) == 0)
+#endif
+                               sohasoutofband(so);
+                       tp->t_oobflags &= ~TCPOOB_HAVEDATA;
                }
                }
-
                /*
                /*
-                * Find a segment which begins after this one does.
+                * Remove out of band data so doesn't get presented to user.
+                * This can happen independent of advancing the URG pointer,
+                * but if two URG's are pending at once, some out-of-band
+                * data may creep in... ick.
                 */
                 */
-               for (q = tp->seg_next; q != (struct tcpiphdr *)tp;
-                   q = (struct tcpiphdr *)q->ti_next)
-                       if (SEQ_GT(q->ti_seq, ti->ti_seq))
-                               break;
+               if (ti->ti_urp <= ti->ti_len) {
+                       tcp_pulloutofband(so, ti);
+               }
+       }
 
 
-               /*
-                * If there is a preceding segment, it may provide some of
-                * our data already.  If so, drop the data from the incoming
-                * segment.  If it provides all of our data, drop us.
-                */
-               if ((struct tcpiphdr *)q->ti_prev != (struct tcpiphdr *)tp) {
-                       register int i;
-                       q = (struct tcpiphdr *)(q->ti_prev);
-                       /* conversion to int (in i) handles seq wraparound */
-                       i = q->ti_seq + q->ti_len - ti->ti_seq;
-                       if (i > 0) {
-                               if (i >= ti->ti_len)
-                                       goto notext;
-                                               /* w/o setting TC_NET_KEEP */
-                               m_adj(dtom(tp), i);
-                               ti->ti_len -= i;
-                               ti->ti_seq += i;
-                       }
-                       q = (struct tcpiphdr *)(q->ti_next);
+       /*
+        * Process the segment text, merging it into the TCP sequencing queue,
+        * and arranging for acknowledgment of receipt if necessary.
+        * This process logically involves adjusting tp->rcv_wnd as data
+        * is presented to the user (this happens in tcp_usrreq.c,
+        * case PRU_RCVD).  If a FIN has already been received on this
+        * connection then we just ignore the text.
+        */
+       if ((ti->ti_len || (tiflags&TH_FIN)) &&
+           TCPS_HAVERCVDFIN(tp->t_state) == 0) {
+               tiflags = tcp_reass(tp, ti);
+               if (tcpnodelack == 0)
+                       tp->t_flags |= TF_DELACK;
+               else
+                       tp->t_flags |= TF_ACKNOW;
+       } else {
+               m_freem(m);
+               tiflags &= ~TH_FIN;
+       }
+
+       /*
+        * If FIN is received ACK the FIN and let the user know
+        * that the connection is closing.
+        */
+       if (tiflags & TH_FIN) {
+               if (TCPS_HAVERCVDFIN(tp->t_state) == 0) {
+                       socantrcvmore(so);
+                       tp->t_flags |= TF_ACKNOW;
+                       tp->rcv_nxt++;
                }
                }
+               switch (tp->t_state) {
 
 
-               /*
-                * While we overlap succeeding segments trim them or,
-                * if they are completely covered, dequeue them.
+               /*
+                * In SYN_RECEIVED and ESTABLISHED STATES
+                * enter the CLOSE_WAIT state.
                 */
                 */
-               while (q != (struct tcpiphdr *)tp &&
-                   SEQ_GT(ti->ti_seq + ti->ti_len, q->ti_seq)) {
-                       register int i = (ti->ti_seq + ti->ti_len) - q->ti_seq;
-                       if (i < q->ti_len) {
-                               q->ti_len -= i;
-                               m_adj(dtom(q), i);
-                               break;
-                       }
-                       q = (struct tcpiphdr *)q->ti_next;
-                       m_freem(dtom(q->ti_prev));
-                       remque(q->ti_prev);
-               }
+               case TCPS_SYN_RECEIVED:
+               case TCPS_ESTABLISHED:
+                       tp->t_state = TCPS_CLOSE_WAIT;
+                       break;
 
 
-               /*
-                * Stick new segment in its place.
+               /*
+                * If still in FIN_WAIT_1 STATE FIN has not been acked so
+                * enter the CLOSING state.
                 */
                 */
-               insque(ti, q->ti_prev);
-               tp->seqcnt += ti->ti_len;
+               case TCPS_FIN_WAIT_1:
+                       tp->t_state = TCPS_CLOSING;
+                       break;
+
+               /*
+                * In FIN_WAIT_2 state enter the TIME_WAIT state,
+                * starting the time-wait timer, turning off the other 
+                * standard timers.
+                */
+               case TCPS_FIN_WAIT_2:
+                       tp->t_state = TCPS_TIME_WAIT;
+                       tcp_canceltimers(tp);
+                       tp->t_timer[TCPT_2MSL] = 2 * TCPTV_MSL;
+                       soisdisconnected(so);
+                       break;
 
                /*
 
                /*
-                * Calculate available space and discard segments for
-                * which there is too much.
+                * In TIME_WAIT state restart the 2 MSL time_wait timer.
                 */
                 */
-               overage = 
-                   (so->so_rcv.sb_cc /*XXX+tp->rcv_seqcnt*/) - so->so_rcv.sb_hiwat;
-               if (overage > 0) {
-                       q = tp->seg_prev;
-                       for (;;) {
-                               register int i = MIN(q->ti_len, overage);
-                               overage -= i;
-                               q->ti_len -= i;
-                               m_adj(dtom(q), -i);
-                               if (q->ti_len)
-                                       break;
-                               if (q == ti)
-                                       panic("tcp_text dropall");
-                               q = (struct tcpiphdr *)q->ti_prev;
-                               remque(q->ti_next);
+               case TCPS_TIME_WAIT:
+                       tp->t_timer[TCPT_2MSL] = 2 * TCPTV_MSL;
+                       break;
+               }
+       }
+       if (so->so_options & SO_DEBUG)
+               tcp_trace(TA_INPUT, ostate, tp, &tcp_saveti, 0);
+
+       /*
+        * Return any desired output.
+        */
+       (void) tcp_output(tp);
+       return;
+
+dropafterack:
+       /*
+        * Generate an ACK dropping incoming segment if it occupies
+        * sequence space, where the ACK reflects our state.
+        */
+       if ((tiflags&TH_RST) ||
+           tlen == 0 && (tiflags&(TH_SYN|TH_FIN)) == 0)
+               goto drop;
+       if (tp->t_inpcb->inp_socket->so_options & SO_DEBUG)
+               tcp_trace(TA_RESPOND, ostate, tp, &tcp_saveti, 0);
+       tcp_respond(tp, ti, tp->rcv_nxt, tp->snd_nxt, TH_ACK);
+       return;
+
+dropwithreset:
+       if (om)
+               (void) m_free(om);
+       /*
+        * Generate a RST, dropping incoming segment.
+        * Make ACK acceptable to originator of segment.
+        */
+       if (tiflags & TH_RST)
+               goto drop;
+       if (tiflags & TH_ACK)
+               tcp_respond(tp, ti, (tcp_seq)0, ti->ti_ack, TH_RST);
+       else {
+               if (tiflags & TH_SYN)
+                       ti->ti_len++;
+               tcp_respond(tp, ti, ti->ti_seq+ti->ti_len, (tcp_seq)0,
+                   TH_RST|TH_ACK);
+       }
+       return;
+
+drop:
+       /*
+        * Drop space held by incoming segment and return.
+        */
+       if (tp && (tp->t_inpcb->inp_socket->so_options & SO_DEBUG))
+               tcp_trace(TA_DROP, ostate, tp, &tcp_saveti, 0);
+       m_freem(m);
+       return;
+}
+
+tcp_dooptions(tp, om)
+       struct tcpcb *tp;
+       struct mbuf *om;
+{
+       register u_char *cp;
+       int opt, optlen, cnt;
+
+       cp = mtod(om, u_char *);
+       cnt = om->m_len;
+       for (; cnt > 0; cnt -= optlen, cp += optlen) {
+               opt = cp[0];
+               if (opt == TCPOPT_EOL)
+                       break;
+               if (opt == TCPOPT_NOP)
+                       optlen = 1;
+               else
+                       optlen = cp[1];
+               switch (opt) {
+
+               default:
+                       break;
+
+               case TCPOPT_MAXSEG:
+                       if (optlen != 4)
+                               continue;
+                       tp->t_maxseg = *(u_short *)(cp + 2);
+#if vax || pdp11
+                       tp->t_maxseg = ntohs((u_short)tp->t_maxseg);
+#endif
+                       break;
+                       
+#ifdef TCPTRUEOOB
+               case TCPOPT_WILLOOB:
+                       tp->t_flags |= TF_DOOOB;
+printf("tp %x dooob\n", tp);
+                       break;
+
+               case TCPOPT_OOBDATA: {
+                       int seq;
+                       register struct socket *so = tp->t_inpcb->inp_socket;
+                       tcp_seq mark;
+
+                       if (optlen != 8)
+                               continue;
+                       seq = cp[2];
+                       if (seq < tp->t_iobseq)
+                               seq += 256;
+printf("oobdata cp[2] %d iobseq %d seq %d\n", cp[2], tp->t_iobseq, seq);
+                       if (seq - tp->t_iobseq > 128) {
+printf("bad seq\n");
+                               tp->t_oobflags |= TCPOOB_OWEACK;
+                               break;
                        }
                        }
+                       tp->t_iobseq = cp[2];
+                       tp->t_iobc = cp[3];
+                       mark = *(tcp_seq *)(cp + 4);
+#if vax || pdp11
+                       mark = ntohl(mark);
+#endif
+                       so->so_oobmark = so->so_rcv.sb_cc + (mark-tp->rcv_nxt);
+                       if (so->so_oobmark == 0)
+                               so->so_state |= SS_RCVATMARK;
+printf("take oob data %x input iobseq now %x\n", tp->t_iobc, tp->t_iobseq);
+                       sohasoutofband(so);
+                       break;
                }
 
                }
 
-               /*
-                * Advance rcv_next through newly completed sequence space.
-                */
-               while (ti->ti_seq == tp->rcv_nxt) {
-                       tp->rcv_nxt += ti->ti_len;
-                       ti = (struct tcpiphdr *)ti->ti_next;
-                       if (ti == (struct tcpiphdr *)tp)
+               case TCPOPT_OOBACK: {
+                       int seq;
+
+                       if (optlen != 4)
+                               continue;
+                       if (tp->t_oobseq != cp[2]) {
+printf("wrong ack\n");
                                break;
                                break;
+                       }
+printf("take oob ack %x and cancel rexmt\n", cp[2]);
+                       tp->t_oobflags &= ~TCPOOB_NEEDACK;
+                       tp->t_timer[TCPT_OOBREXMT] = 0;
+                       break;
                }
                }
-/* urg */
-               if (tiflags&TH_URG) {
-                       /* ... */
-                       if (SEQ_GT(urgent, tp->rcv_urp))
-                               tp->rcv_urp = urgent;
+#endif TCPTRUEOOB
                }
                }
-               tp->tc_flags |= (TC_ACK_DUE|TC_NET_KEEP);
        }
        }
-notext:
-/* fin */
-       if ((tiflags&TH_FIN) && past == tp->rcv_nxt) {
-               if ((tp->tc_flags&TC_FIN_RCVD) == 0) {
-                       tp->tc_flags |= TC_FIN_RCVD;
-                       sorwakeup(so);
-                       tp->rcv_nxt++;
+       (void) m_free(om);
+}
+
+/*
+ * Pull out of band byte out of a segment so
+ * it doesn't appear in the user's data queue.
+ * It is still reflected in the segment length for
+ * sequencing purposes.
+ */
+tcp_pulloutofband(so, ti)
+       struct socket *so;
+       struct tcpiphdr *ti;
+{
+       register struct mbuf *m;
+       int cnt = ti->ti_urp - 1;
+       
+       m = dtom(ti);
+       while (cnt >= 0) {
+               if (m->m_len > cnt) {
+                       char *cp = mtod(m, caddr_t) + cnt;
+                       struct tcpcb *tp = sototcpcb(so);
+
+                       tp->t_iobc = *cp;
+                       tp->t_oobflags |= TCPOOB_HAVEDATA;
+                       bcopy(cp+1, cp, (unsigned)(m->m_len - cnt - 1));
+                       m->m_len--;
+                       return;
                }
                }
-               tp->tc_flags |= TC_ACK_DUE;
+               cnt -= m->m_len;
+               m = m->m_next;
+               if (m == 0)
+                       break;
        }
        }
-/* respond */
-       sent = 0;
-       if (tp->tc_flags&TC_ACK_DUE)
-               sent = tcp_sndctl(tp);
-       else if ((tp->tc_flags&TC_NEW_WINDOW))
-               if (tp->snd_nxt <= tp->snd_off + so->so_snd.sb_cc ||
-                   (tp->tc_flags&TC_SND_FIN))
-                       sent = tcp_send(tp);
-
-/* set for retrans */
-       if (!sent && tp->snd_una < tp->snd_nxt &&
-           (tp->tc_flags&TC_CANCELLED)) {
-               tp->t_rexmt = tp->t_xmtime;
-               tp->t_rexmttl = T_REXMTTL;
-               tp->t_rexmt_val = tp->t_rtl_val = tp->snd_lst;
-               tp->tc_flags &= ~TC_CANCELLED;
+       panic("tcp_pulloutofband");
+}
+
+/*
+ * Insert segment ti into reassembly queue of tcp with
+ * control block tp.  Return TH_FIN if reassembly now includes
+ * a segment with FIN.
+ */
+tcp_reass(tp, ti)
+       register struct tcpcb *tp;
+       register struct tcpiphdr *ti;
+{
+       register struct tcpiphdr *q;
+       struct socket *so = tp->t_inpcb->inp_socket;
+       struct mbuf *m;
+       int flags;
+
+       /*
+        * Call with ti==0 after become established to
+        * force pre-ESTABLISHED data up to user socket.
+        */
+       if (ti == 0)
+               goto present;
+
+       /*
+        * Find a segment which begins after this one does.
+        */
+       for (q = tp->seg_next; q != (struct tcpiphdr *)tp;
+           q = (struct tcpiphdr *)q->ti_next)
+               if (SEQ_GT(q->ti_seq, ti->ti_seq))
+                       break;
+
+       /*
+        * If there is a preceding segment, it may provide some of
+        * our data already.  If so, drop the data from the incoming
+        * segment.  If it provides all of our data, drop us.
+        */
+       if ((struct tcpiphdr *)q->ti_prev != (struct tcpiphdr *)tp) {
+               register int i;
+               q = (struct tcpiphdr *)q->ti_prev;
+               /* conversion to int (in i) handles seq wraparound */
+               i = q->ti_seq + q->ti_len - ti->ti_seq;
+               if (i > 0) {
+                       if (i >= ti->ti_len)
+                               goto drop;
+                       m_adj(dtom(ti), i);
+                       ti->ti_len -= i;
+                       ti->ti_seq += i;
+               }
+               q = (struct tcpiphdr *)(q->ti_next);
        }
        }
-/* present data to user */
-       if ((tp->tc_flags&TC_SYN_ACKED) == 0)
-               return;
+
+       /*
+        * While we overlap succeeding segments trim them or,
+        * if they are completely covered, dequeue them.
+        */
+       while (q != (struct tcpiphdr *)tp) {
+               register int i = (ti->ti_seq + ti->ti_len) - q->ti_seq;
+               if (i <= 0)
+                       break;
+               if (i < q->ti_len) {
+                       q->ti_seq += i;
+                       q->ti_len -= i;
+                       m_adj(dtom(q), i);
+                       break;
+               }
+               q = (struct tcpiphdr *)q->ti_next;
+               m = dtom(q->ti_prev);
+               remque(q->ti_prev);
+               m_freem(m);
+       }
+
+       /*
+        * Stick new segment in its place.
+        */
+       insque(ti, q->ti_prev);
+
+present:
+       /*
+        * Present data to user, advancing rcv_nxt through
+        * completed sequence space.
+        */
+       if (TCPS_HAVERCVDSYN(tp->t_state) == 0)
+               return (0);
        ti = tp->seg_next;
        ti = tp->seg_next;
-       while (ti != (struct tcpiphdr *)tp && ti->ti_seq < tp->rcv_nxt) {
+       if (ti == (struct tcpiphdr *)tp || ti->ti_seq != tp->rcv_nxt)
+               return (0);
+       if (tp->t_state == TCPS_SYN_RECEIVED && ti->ti_len)
+               return (0);
+       do {
+               tp->rcv_nxt += ti->ti_len;
+               flags = ti->ti_flags & TH_FIN;
                remque(ti);
                remque(ti);
-               sbappend(&so->so_rcv, dtom(ti));
-               tp->seqcnt -= ti->ti_len;
-               if (tp->seqcnt < 0)
-                       panic("tcp_input present");
+               m = dtom(ti);
                ti = (struct tcpiphdr *)ti->ti_next;
                ti = (struct tcpiphdr *)ti->ti_next;
-       }
+               if (so->so_state & SS_CANTRCVMORE)
+                       m_freem(m);
+               else
+                       sbappend(&so->so_rcv, m);
+       } while (ti != (struct tcpiphdr *)tp && ti->ti_seq == tp->rcv_nxt);
        sorwakeup(so);
        sorwakeup(so);
+       return (flags);
+drop:
+       m_freem(dtom(ti));
+       return (0);
 }
 }