From 0aad96a0ab4cc734bbe34b6e8a37bffdd7c85965 Mon Sep 17 00:00:00 2001
From: David du Colombier <0intro@gmail.com>
Date: Fri, 25 Sep 1998 00:00:00 +0000
Subject: [PATCH] Plan 9 from Bell Labs 1998-09-25

---
 ip/il.c  |  3 +++
 ip/tcp.c | 34 ++++++++++++++++++++++------------
 2 files changed, 25 insertions(+), 12 deletions(-)

diff --git a/ip/il.c b/ip/il.c
index 91f6f6542d2e2327f0c323678ba371b6e41dff60..ca81e5065a50c3858c0a21f08a55e5185a327008 100644
--- a/ip/il.c
+++ b/ip/il.c
@@ -597,6 +597,7 @@ iliput(Proto *il, uchar*, Block *bp)
 	ic->querytime = Keepalivetime;
 	ic->deathtime = Deathtime;
 	ic->window = Defaultwin;
+	ic->unackeduchars = 0;
 
 	ilprocess(new, ih, bp);
 	return;
@@ -1078,6 +1079,8 @@ void
 ilbackoff(Ilcb *ic)
 {
 	ic->fasttime += ic->fasttime>>1;
+	if(ic->fasttime > Fasttime)
+		ic->fasttime = Fasttime;
 }
 
 char*
diff --git a/ip/tcp.c b/ip/tcp.c
index 1daeb26da4a597257ad17ab51677803c38bafae5..519ab2b42328a3aab1df4ec3dca737e226176a47 100644
--- a/ip/tcp.c
+++ b/ip/tcp.c
@@ -76,6 +76,7 @@ struct Timer
 {
 	Timer	*next;
 	Timer	*prev;
+	Timer	*readynext;
 	int	state;
 	int	start;
 	int	count;
@@ -262,19 +263,20 @@ tcpsetstate(Conv *s, uchar newstate)
 		tcpstates[oldstate], tcpstates[newstate], tpriv->tstats.tcpCurrEstab );
 	**/
 
-	tcb->state = newstate;
-
 	switch(newstate) {
 	case Closed:
 		qclose(s->rq);
 		qclose(s->wq);
 		qclose(s->eq);
+		break;
 
 	case Close_wait:		/* Remote closes */
 		qhangup(s->rq, nil);
 		break;
 	}
 
+	tcb->state = newstate;
+
 	if(oldstate == Syn_sent && newstate != Closed)
 		Fsconnected(s, nil);
 }
@@ -419,6 +421,7 @@ deltimer(Tcppriv *tpriv, Timer *t)
 		t->next->prev = t->prev;
 	if(t->prev)
 		t->prev->next = t->next;
+	t->next = t->prev = nil;
 }
 
 void
@@ -463,6 +466,7 @@ tcpackproc(void *a)
 	Timer *t, *tp, *timeo;
 	Proto *tcp;
 	Tcppriv *tpriv;
+	int loop;
 
 	tcp = a;
 	tpriv = tcp->priv;
@@ -472,26 +476,27 @@ tcpackproc(void *a)
 
 		qlock(&tpriv->tl);
 		timeo = nil;
+		loop = 0;
 		for(t = tpriv->timers; t != nil; t = tp) {
+			if(loop++ > 10000)
+				panic("tcpackproc1");
 			tp = t->next;
  			if(t->state == TimerON) {
 				t->count--;
 				if(t->count == 0) {
 					deltimer(tpriv, t);
 					t->state = TimerDONE;
-					t->next = timeo;
+					t->readynext = timeo;
 					timeo = t;
 				}
 			}
 		}
 		qunlock(&tpriv->tl);
 
-		for(;;) {
-			t = timeo;
-			if(t == nil)
-				break;
-
-			timeo = t->next;
+		loop = 0;
+		for(t = timeo; t != nil; t = t->readynext) {
+			if(loop++ > 10000)
+				panic("tcpackproc2");
 			if(t->state == TimerDONE && t->func != nil)
 				(*t->func)(t->arg);
 		}
@@ -551,6 +556,7 @@ localclose(Conv *s, char *reason)	 /*  called with tcb locked */
 
 	tcphalt(tpriv, &tcb->timer);
 	tcphalt(tpriv, &tcb->rtt_timer);
+	tcphalt(tpriv, &tcb->acktimer);
 
 	/* Flush reassembly queue; nothing more can arrive */
 	for(rp = tcb->reseq; rp != nil; rp = rp1) {
@@ -1412,10 +1418,14 @@ tcpiput(Proto *tcp, uchar*, Block *bp)
 				 *  and the user isn't backing up
 				 */
 				if(tcb->rcv.nxt - tcb->last_ack >= 2*tcb->mss &&
-				   qlen(s->rq) < 8*tcb->mss)
+				   qlen(s->rq) < 8*tcb->mss){
 					tcb->flags |= FORCE;
-				else if(tcb->acktimer.state != TimerON)
-					tcpgo(tpriv, &tcb->acktimer);
+					if(tcb->acktimer.state == TimerON)
+						tcphalt(tpriv, &tcb->acktimer);
+				} else {
+					if(tcb->acktimer.state != TimerON)
+						tcpgo(tpriv, &tcb->acktimer);
+				}
 
 				break;
 			case Finwait2: