projects / unix-history / blobdiff
? search:
summary | tags | clone url | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
localize header files
[unix-history] / usr / src / sys / netinet / tcp_timer.c
diff --git a/usr/src/sys/netinet/tcp_timer.c b/usr/src/sys/netinet/tcp_timer.c
index 94fdc9f..90b0a46 100644 (file)
--- a/usr/src/sys/netinet/tcp_timer.c
+++ b/usr/src/sys/netinet/tcp_timer.c
@@ -1,4 +1,4 @@
-/* tcp_timer.c 4.12 82/01/17 */
+/*     tcp_timer.c     4.26    82/10/09        */
 
 #include "../h/param.h"
 #include "../h/systm.h"
 
 #include "../h/param.h"
 #include "../h/systm.h"
@@ -6,19 +6,20 @@
 #include "../h/socket.h"
 #include "../h/socketvar.h"
 #include "../h/protosw.h"
 #include "../h/socket.h"
 #include "../h/socketvar.h"
 #include "../h/protosw.h"
-#include "../net/in.h"
-#include "../net/in_pcb.h"
-#include "../net/in_systm.h"
+#include "../netinet/in.h"
+#include "../net/route.h"
+#include "../netinet/in_pcb.h"
+#include "../netinet/in_systm.h"
 #include "../net/if.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/tcp_seq.h"
-#include "../net/tcp_timer.h"
-#include "../net/tcp_var.h"
-#include "../net/tcpip.h"
-#include "../errno.h"
+#include "../netinet/ip.h"
+#include "../netinet/ip_var.h"
+#include "../netinet/tcp.h"
+#include "../netinet/tcp_fsm.h"
+#include "../netinet/tcp_seq.h"
+#include "../netinet/tcp_timer.h"
+#include "../netinet/tcp_var.h"
+#include "../netinet/tcpip.h"
+#include <errno.h>
 
 int    tcpnodelack = 0;
 /*
 
 int    tcpnodelack = 0;
 /*
@@ -29,9 +30,10 @@ tcp_fasttimo()
        register struct inpcb *inp;
        register struct tcpcb *tp;
        int s = splnet();
        register struct inpcb *inp;
        register struct tcpcb *tp;
        int s = splnet();
-COUNT(TCP_FASTTIMO);
 
 
-       for (inp = tcb.inp_next; inp != &tcb; inp = inp->inp_next)
+       inp = tcb.inp_next;
+       if (inp)
+       for (; inp != &tcb; inp = inp->inp_next)
                if ((tp = (struct tcpcb *)inp->inp_ppcb) &&
                    (tp->t_flags & TF_DELACK)) {
                        tp->t_flags &= ~TF_DELACK;
                if ((tp = (struct tcpcb *)inp->inp_ppcb) &&
                    (tp->t_flags & TF_DELACK)) {
                        tp->t_flags &= ~TF_DELACK;
@@ -48,11 +50,10 @@ COUNT(TCP_FASTTIMO);
  */
 tcp_slowtimo()
 {
  */
 tcp_slowtimo()
 {
-       register struct inpcb *ip;
+       register struct inpcb *ip, *ipnxt;
        register struct tcpcb *tp;
        int s = splnet();
        register int i;
        register struct tcpcb *tp;
        int s = splnet();
        register int i;
-COUNT(TCP_SLOWTIMO);
 
        /*
         * Search through tcb's and update active timers.
 
        /*
         * Search through tcb's and update active timers.
@@ -62,19 +63,25 @@ COUNT(TCP_SLOWTIMO);
                splx(s);
                return;
        }
                splx(s);
                return;
        }
-       for (; ip != &tcb; ip = ip->inp_next) {
+       while (ip != &tcb) {
                tp = intotcpcb(ip);
                if (tp == 0)
                        continue;
                tp = intotcpcb(ip);
                if (tp == 0)
                        continue;
+               ipnxt = ip->inp_next;
                for (i = 0; i < TCPT_NTIMERS; i++) {
                for (i = 0; i < TCPT_NTIMERS; i++) {
-                       if (tp->t_timer[i] && --tp->t_timer[i] == 0)
+                       if (tp->t_timer[i] && --tp->t_timer[i] == 0) {
                                (void) tcp_usrreq(tp->t_inpcb->inp_socket,
                                    PRU_SLOWTIMO, (struct mbuf *)0,
                                    (caddr_t)i);
                                (void) tcp_usrreq(tp->t_inpcb->inp_socket,
                                    PRU_SLOWTIMO, (struct mbuf *)0,
                                    (caddr_t)i);
+                               if (ipnxt->inp_prev != ip)
+                                       goto tpgone;
+                       }
                }
                tp->t_idle++;
                if (tp->t_rtt)
                        tp->t_rtt++;
                }
                tp->t_idle++;
                if (tp->t_rtt)
                        tp->t_rtt++;
+tpgone:
+               ip = ipnxt;
        }
        tcp_iss += TCP_ISSINCR/PR_SLOWHZ;               /* increment iss */
        splx(s);
        }
        tcp_iss += TCP_ISSINCR/PR_SLOWHZ;               /* increment iss */
        splx(s);
@@ -88,11 +95,14 @@ tcp_canceltimers(tp)
 {
        register int i;
 
 {
        register int i;
 
-COUNT(TCP_CANCELTIMERS);
        for (i = 0; i < TCPT_NTIMERS; i++)
                tp->t_timer[i] = 0;
 }
 
        for (i = 0; i < TCPT_NTIMERS; i++)
                tp->t_timer[i] = 0;
 }
 
+float  tcp_backoff[TCP_MAXRXTSHIFT] =
+    { 1.0, 1.2, 1.4, 1.7, 2.0, 3.0, 5.0, 8.0, 16.0, 32.0 };
+int    tcprexmtprint = 0;
+int    tcpexprexmtbackoff = 0;
 /*
  * TCP timer processing.
  */
 /*
  * TCP timer processing.
  */
@@ -101,7 +111,6 @@ tcp_timers(tp, timer)
        int timer;
 {
 
        int timer;
 {
 
-COUNT(TCP_TIMERS);
        switch (timer) {
 
        /*
        switch (timer) {
 
        /*
@@ -120,16 +129,23 @@ COUNT(TCP_TIMERS);
         */
        case TCPT_REXMT:
                tp->t_rxtshift++;
         */
        case TCPT_REXMT:
                tp->t_rxtshift++;
-               TCPT_RANGESET(tp->t_timer[TCPT_REXMT],
-                   ((int)(2 * tp->t_srtt)),
-                   TCPTV_MIN, TCPTV_MAX);
-               TCPT_RANGESET(tp->t_timer[TCPT_REXMT],
-                   tp->t_timer[TCPT_REXMT] << tp->t_rxtshift,
-                   TCPTV_MIN, TCPTV_MAX);
-               if (tp->t_timer[TCPT_REXMT] > TCPTV_MAXIDLE / 2) {
+               if (tp->t_rxtshift > TCP_MAXRXTSHIFT) {
                        tcp_drop(tp, ETIMEDOUT);
                        return;
                }
                        tcp_drop(tp, ETIMEDOUT);
                        return;
                }
+               TCPT_RANGESET(tp->t_timer[TCPT_REXMT],
+                   (int)tp->t_srtt, TCPTV_MIN, TCPTV_MAX);
+               if (tcpexprexmtbackoff) {
+                       TCPT_RANGESET(tp->t_timer[TCPT_REXMT],
+                           tp->t_timer[TCPT_REXMT] << tp->t_rxtshift,
+                           TCPTV_MIN, TCPTV_MAX);
+               } else {
+                       TCPT_RANGESET(tp->t_timer[TCPT_REXMT],
+                           tp->t_timer[TCPT_REXMT] *
+                               tcp_backoff[tp->t_rxtshift - 1],
+                           TCPTV_MIN, TCPTV_MAX);
+               }
+if (tcprexmtprint)
 printf("rexmt set to %d\n", tp->t_timer[TCPT_REXMT]);
                tp->snd_nxt = tp->snd_una;
                /* this only transmits one segment! */
 printf("rexmt set to %d\n", tp->t_timer[TCPT_REXMT]);
                tp->snd_nxt = tp->snd_una;
                /* this only transmits one segment! */
@@ -141,11 +157,10 @@ printf("rexmt set to %d\n", tp->t_timer[TCPT_REXMT]);
         * Force a byte to be output, if possible.
         */
        case TCPT_PERSIST:
         * Force a byte to be output, if possible.
         */
        case TCPT_PERSIST:
+               tcp_setpersist(tp);
                tp->t_force = 1;
                (void) tcp_output(tp);
                tp->t_force = 0;
                tp->t_force = 1;
                (void) tcp_output(tp);
                tp->t_force = 0;
-               TCPT_RANGESET(tp->t_timer[TCPT_PERSIST],
-                   2 * tp->t_srtt, TCPTV_PERSMIN, TCPTV_MAX);
                return;
 
        /*
                return;
 
        /*
@@ -153,30 +168,29 @@ printf("rexmt set to %d\n", tp->t_timer[TCPT_REXMT]);
         * or drop connection if idle for too long.
         */
        case TCPT_KEEP:
         * or drop connection if idle for too long.
         */
        case TCPT_KEEP:
-               if (tp->t_state < TCPS_ESTABLISHED ||
-                   tp->t_idle >= TCPTV_MAXIDLE) {
-                       tcp_drop(tp, ETIMEDOUT);
-                       return;
-               }
-               if (tp->t_inpcb->inp_socket->so_options & SO_NOKEEPALIVE)
-                       tp->t_idle = 0;
-               else
+               if (tp->t_state < TCPS_ESTABLISHED)
+                       goto dropit;
+               if (tp->t_inpcb->inp_socket->so_options & SO_KEEPALIVE) {
+                       if (tp->t_idle >= TCPTV_MAXIDLE)
+                               goto dropit;
+                       /*
+                        * Saying tp->rcv_nxt-1 lies about what
+                        * we have received, and by the protocol spec
+                        * requires the correspondent TCP to respond.
+                        * Saying tp->snd_una-1 causes the transmitted
+                        * byte to lie outside the receive window; this
+                        * is important because we don't necessarily
+                        * have a byte in the window to send (consider
+                        * a one-way stream!)
+                        */
                        tcp_respond(tp,
                        tcp_respond(tp,
-                           tp->t_template, tp->rcv_nxt, tp->snd_una-1, 0);
+                           tp->t_template, tp->rcv_nxt-1, tp->snd_una-1, 0);
+               } else
+                       tp->t_idle = 0;
                tp->t_timer[TCPT_KEEP] = TCPTV_KEEP;
                return;
                tp->t_timer[TCPT_KEEP] = TCPTV_KEEP;
                return;
-
-#ifdef TCPTRUEOOB
-       /*
-        * Out-of-band data retransmit timer.
-        */
-       case TCPT_OOBREXMT:
-               if (tp->t_flags & TF_NOOPT)
-                       return;
-               (void) tcp_output(tp);
-               TCPT_RANGESET(tp->t_timer[TCPT_OOBREXMT],
-                   2 * tp->t_srtt, TCPTV_MIN, TCPTV_MAX);
+       dropit:
+               tcp_drop(tp, ETIMEDOUT);
                return;
                return;
-#endif
        }
 }
        }
 }
Continuous source code history from original PDP-7 UNIX to FreeBSD 2, the first fully unencumbered FreeBSD release.