convert trailer format; fix backoff to back off more slowly

[unix-history] / usr / src / sys / netinet / tcp_subr.c

diff --git a/usr/src/sys/netinet/tcp_subr.c b/usr/src/sys/netinet/tcp_subr.c
index e5304b7..3df967c 100644 (file)
--- a/usr/src/sys/netinet/tcp_subr.c
+++ b/usr/src/sys/netinet/tcp_subr.c
@@ -1,4 +1,4 @@
-/*     tcp_subr.c      4.14    82/01/19        */
+/*     tcp_subr.c      4.22    82/04/04        */

 
 #include "../h/param.h"
 #include "../h/systm.h"
 
 #include "../h/param.h"
 #include "../h/systm.h"


@@ -7,6 +7,7 @@
 #include "../h/socketvar.h"
 #include "../h/protosw.h"
 #include "../net/in.h"
 #include "../h/socketvar.h"
 #include "../h/protosw.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/in_pcb.h"
 #include "../net/in_systm.h"
 #include "../net/if.h"


@@ -48,7 +49,7 @@ tcp_template(tp)
        register struct tcpiphdr *n;
 
 COUNT(TCP_TEMPLATE);
        register struct tcpiphdr *n;
 
 COUNT(TCP_TEMPLATE);

-       m = m_get(1);
+       m = m_get(M_WAIT);

        if (m == 0)
                return (0);
        m->m_off = MMAXOFF - sizeof (struct tcpiphdr);
        if (m == 0)
                return (0);
        m->m_off = MMAXOFF - sizeof (struct tcpiphdr);


@@ -93,37 +94,43 @@ tcp_respond(tp, ti, ack, seq, flags)
        int flags;
 {
        struct mbuf *m;
        int flags;
 {
        struct mbuf *m;

-       int win = 0;
+       int win = 0, tlen;
+       struct route *ro = 0;

 
 COUNT(TCP_RESPOND);
 
 COUNT(TCP_RESPOND);

-       if (tp)
+       if (tp) {

                win = sbspace(&tp->t_inpcb->inp_socket->so_rcv);
                win = sbspace(&tp->t_inpcb->inp_socket->so_rcv);

+               ro = &tp->t_inpcb->inp_route;
+       }

        if (flags == 0) {
                m = m_get(M_DONTWAIT);
                if (m == 0)
                        return;
                m->m_off = MMINOFF;
        if (flags == 0) {
                m = m_get(M_DONTWAIT);
                if (m == 0)
                        return;
                m->m_off = MMINOFF;

-               m->m_len = sizeof (struct tcpiphdr);
+               m->m_len = sizeof (struct tcpiphdr) + 1;

                *mtod(m, struct tcpiphdr *) = *ti;
                ti = mtod(m, struct tcpiphdr *);
                flags = TH_ACK;
                *mtod(m, struct tcpiphdr *) = *ti;
                ti = mtod(m, struct tcpiphdr *);
                flags = TH_ACK;

+               tlen = 1;

        } else {
                m = dtom(ti);
                m_freem(m->m_next);
                m->m_next = 0;
        } else {
                m = dtom(ti);
                m_freem(m->m_next);
                m->m_next = 0;

+               m->m_off = (int)ti - (int)m;

                m->m_len = sizeof (struct tcpiphdr);
 #define xchg(a,b,type) { type t; t=a; a=b; b=t; }
                xchg(ti->ti_dst.s_addr, ti->ti_src.s_addr, u_long);
                xchg(ti->ti_dport, ti->ti_sport, u_short);
 #undef xchg
                m->m_len = sizeof (struct tcpiphdr);
 #define xchg(a,b,type) { type t; t=a; a=b; b=t; }
                xchg(ti->ti_dst.s_addr, ti->ti_src.s_addr, u_long);
                xchg(ti->ti_dport, ti->ti_sport, u_short);
 #undef xchg

+               tlen = 0;

        }
        ti->ti_next = ti->ti_prev = 0;
        ti->ti_x1 = 0;
        }
        ti->ti_next = ti->ti_prev = 0;
        ti->ti_x1 = 0;

-       ti->ti_len = sizeof (struct tcphdr);
+       ti->ti_len = sizeof (struct tcphdr) + tlen;

        ti->ti_seq = seq;
        ti->ti_ack = ack;
 #if vax
        ti->ti_seq = seq;
        ti->ti_ack = ack;
 #if vax

-       ti->ti_len = htons(ti->ti_len);
+       ti->ti_len = htons((u_short)ti->ti_len);

        ti->ti_seq = htonl(ti->ti_seq);
        ti->ti_ack = htonl(ti->ti_ack);
 #endif
        ti->ti_seq = htonl(ti->ti_seq);
        ti->ti_ack = htonl(ti->ti_ack);
 #endif


@@ -135,10 +142,10 @@ COUNT(TCP_RESPOND);
        ti->ti_win = htons(ti->ti_win);
 #endif
        ti->ti_urp = 0;
        ti->ti_win = htons(ti->ti_win);
 #endif
        ti->ti_urp = 0;

-       ti->ti_sum = in_cksum(m, sizeof(struct tcpiphdr));
-       ((struct ip *)ti)->ip_len = sizeof(struct tcpiphdr);
+       ti->ti_sum = in_cksum(m, sizeof (struct tcpiphdr) + tlen);
+       ((struct ip *)ti)->ip_len = sizeof (struct tcpiphdr) + tlen;

        ((struct ip *)ti)->ip_ttl = TCP_TTL;
        ((struct ip *)ti)->ip_ttl = TCP_TTL;

-       (void) ip_output(m, (struct mbuf *)0);
+       (void) ip_output(m, (struct mbuf *)0, ro, 0);

 }
 
 /*
 }
 
 /*


@@ -150,7 +157,7 @@ struct tcpcb *
 tcp_newtcpcb(inp)
        struct inpcb *inp;
 {
 tcp_newtcpcb(inp)
        struct inpcb *inp;
 {

-       struct mbuf *m = m_getclr(0);
+       struct mbuf *m = m_getclr(M_DONTWAIT);

        register struct tcpcb *tp;
 COUNT(TCP_NEWTCPCB);
 
        register struct tcpcb *tp;
 COUNT(TCP_NEWTCPCB);
 


@@ -159,7 +166,7 @@ COUNT(TCP_NEWTCPCB);
        tp = mtod(m, struct tcpcb *);
        tp->seg_next = tp->seg_prev = (struct tcpiphdr *)tp;
        tp->t_maxseg = 1024;
        tp = mtod(m, struct tcpcb *);
        tp->seg_next = tp->seg_prev = (struct tcpiphdr *)tp;
        tp->t_maxseg = 1024;

-       tp->t_flags = TF_NOOPT;         /* until all TCP's take options */
+       tp->t_flags = 0;                /* sends options! */

        tp->t_inpcb = inp;
        inp->inp_ppcb = (caddr_t)tp;
        return (tp);
        tp->t_inpcb = inp;
        inp->inp_ppcb = (caddr_t)tp;
        return (tp);