-/* 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/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/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;
/*
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;
*/
tcp_slowtimo()
{
- register struct inpcb *ip;
+ register struct inpcb *ip, *ipnxt;
register struct tcpcb *tp;
int s = splnet();
register int i;
-COUNT(TCP_SLOWTIMO);
/*
* Search through tcb's and update active timers.
splx(s);
return;
}
- for (; ip != &tcb; ip = ip->inp_next) {
+ while (ip != &tcb) {
tp = intotcpcb(ip);
if (tp == 0)
continue;
+ ipnxt = ip->inp_next;
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);
+ if (ipnxt->inp_prev != ip)
+ goto tpgone;
+ }
}
tp->t_idle++;
if (tp->t_rtt)
tp->t_rtt++;
+tpgone:
+ ip = ipnxt;
}
tcp_iss += TCP_ISSINCR/PR_SLOWHZ; /* increment iss */
splx(s);
{
register int i;
-COUNT(TCP_CANCELTIMERS);
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.
*/
int timer;
{
-COUNT(TCP_TIMERS);
switch (timer) {
/*
*/
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;
}
+ 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! */
* 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;
- TCPT_RANGESET(tp->t_timer[TCPT_PERSIST],
- 2 * tp->t_srtt, TCPTV_PERSMIN, TCPTV_MAX);
return;
/*
* 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,
- 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;
-
-#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;
-#endif
}
}