From d0087ac030df7fecb075dba604e2f5f594f9bc4f Mon Sep 17 00:00:00 2001
From: David du Colombier <0intro@gmail.com>
Date: Sat, 26 Oct 1991 00:00:00 +0000
Subject: [PATCH] Plan 9 from Bell Labs 1991-10-26

---
 port/devarp.c   |  1 -
 port/devlance.c | 16 ++++++++-----
 port/ipdat.h    |  1 +
 port/stil.c     | 60 +++++++++++++++++++++++++++++++++++++++++--------
 4 files changed, 62 insertions(+), 16 deletions(-)

diff --git a/port/devarp.c b/port/devarp.c
index a990d40e85dee96899b861ee2fd32611c701b089..0601e51ec5445d11ad3167a94107c54428962124 100644
--- a/port/devarp.c
+++ b/port/devarp.c
@@ -17,7 +17,6 @@ Queue		*Servq;
 #define ARP_ENTRYLEN	50
 char *padstr = "                                           ";
 
-
 extern Arpcache *arplruhead;
 extern Arpcache *arplrutail;
 
diff --git a/port/devlance.c b/port/devlance.c
index b357e7a1c684f639deaa68c5fc7d61ec0b34540b..458e921fb75e6146d11bbffc6050f3c056bd020e 100644
--- a/port/devlance.c
+++ b/port/devlance.c
@@ -679,18 +679,20 @@ lanceup(Ethertype *e, Etherpkt *p, int len)
 	/*
 	 *  only a trace channel gets packets destined for other machines
 	 */
-	if(e->type != -1){
-		if(p->d[0]!=0xff && memcmp(p->d, l.ea, sizeof(p->d))!=0)
-			return;
-	}
-	if(e->q && e->q->next->len<=Streamhi && !waserror()){
+	if(e->type != -1 && p->d[0]!=0xff && memcmp(p->d, l.ea, sizeof(p->d))!=0)
+		return;
+
+	if(waserror())
+		return;
+
+	if(e->q && e->q->next->len<=Streamhi){
 		bp = allocb(len);
 		memmove(bp->rptr, (uchar *)p, len);
 		bp->wptr += len;
 		bp->flags |= S_DELIM;
 		PUTNEXT(e->q, bp);
-		poperror();
 	}
+	poperror();
 }
 
 /*
@@ -738,6 +740,7 @@ lancekproc(void *arg)
 			len = MPus(m->cntflags) - 4;
 			for(e = &l.e[0]; e < &l.e[Ntypes]; e++){
 				if(e->q!=0 && (t==e->type||e->type==-1) && canqlock(e)){
+if(p->type[0] == 0x80 || p->type[0] == 0x8) print("*");
 					if(t==e->type||e->type==-1)
 						lanceup(e, p, len);
 					qunlock(e);
@@ -758,6 +761,7 @@ stage:
 		}
 		qunlock(&l.rlock);
 		sleep(&l.rr, isinput, 0);
+print("!");
 	}
 }
 
diff --git a/port/ipdat.h b/port/ipdat.h
index 9aeec925ee24f84e6b0aa74a5529ee4deb07997f..661befccbeece6434bd0a56060f593606084de02 100644
--- a/port/ipdat.h
+++ b/port/ipdat.h
@@ -104,6 +104,7 @@ struct Ilcb				/* Control block */
 	Block	*outoforder;
 	ulong	sent;
 	ulong	recvd;
+	ulong	start;
 	ulong	lastack;
 	int	window;
 };
diff --git a/port/stil.c b/port/stil.c
index 5fe3d7f0ae7660a59053ae4369e2e879162ddebd..ebc5f71b47f709d0cc10fd0375d9e2603956b95e 100644
--- a/port/stil.c
+++ b/port/stil.c
@@ -220,6 +220,8 @@ print("got packet from %d.%d.%d.%d %d %d\n", fmtaddr(dst), sp, dp);
 			new->psrc = sp;
 			new->pdst = dp;
 			new->ilctl.state = Ilsyncee;
+			initseq += TK2MS(MACHP(0)->ticks);
+			new->ilctl.sent = initseq;
 			new->dst = nhgetl(ih->src);
 			ilprocess(new, ih, bp);
 
@@ -239,20 +241,34 @@ void
 ilprocess(Ipconv *s, Ilhdr *h, Block *bp)
 {
 	Block *nb;
-	ulong id, ack;
+	Ilcb *ic;
+	Ilhdr *oh;
+	ulong id, ack, oid;
+
+	id = nhgetl(h->ilid);
+	ack = nhgetl(h->ilack);
+	ic = &s->ilctl;
 
 	/* Active transition machine - this tracks connection state */
-	switch(s->ilctl.state) {
+	switch(ic->state) {
 	case Ilsyncee:	
 		switch(h->iltype) {
 		case Ilsync:
+			ic->recvd = id;
 			ilsendctl(s, 0, Ilsync, 0);
 			break;
 		case Ilack:
-			s->ilctl.state = Ilestablished;
+			ic->state = Ilestablished;
 			break;
 		}
 		break;
+	case Ilsyncer:
+		if(h->iltype == Ilsync && ic->start == ack) {
+			ic->recvd = id;
+			ilsendctl(s, 0, Ilack, 0);
+			ic->state = Ilestablished;
+		}
+		break;
 	case Ilclosed:
 	case Ilclosing:
 		goto hungup;
@@ -260,10 +276,10 @@ ilprocess(Ipconv *s, Ilhdr *h, Block *bp)
 
 	/* Passive actions based on packet type */
 	switch(h->iltype) {
+	default:
+		freeb(bp);
+		break;
 	case Ilack:
-		ack = nhgetl(h->ilack);
-		if(s->ilctl.recvd+1 == ack)
-			s->ilctl.recvd = ack;
 		ilackto(&s->ilctl, ack);
 		freeb(bp);
 		break;
@@ -273,18 +289,18 @@ ilprocess(Ipconv *s, Ilhdr *h, Block *bp)
 		break;
 	case Ildataquery:
 	case Ildata:
-		ilackto(&s->ilctl, nhgetl(h->ilack));
+		ilackto(&s->ilctl, ack);
 		switch(s->ilctl.state) {
 		default:
 			iloutoforder(s, h, bp);
 			break;
 		case Ilestablished:
-			id = nhgetl(h->ilid);
 			if(id < s->ilctl.recvd)
 				freeb(bp);
 			else if(id > s->ilctl.recvd)
 				iloutoforder(s, h, bp);
 			else {
+				s->ilctl.recvd++;
 				bp->rptr += IL_EHSIZE+IL_HDRSIZE;
 				PUTNEXT(s->readq, bp);
 			}
@@ -296,12 +312,35 @@ ilprocess(Ipconv *s, Ilhdr *h, Block *bp)
 		if(s->readq) {
 			nb = allocb(0);
 			nb->type = M_HANGUP;
+			nb->flags |= S_DELIM;
 			PUTNEXT(s->readq, nb);
 		}
 		freeb(bp);
 	}
+
+	/* Process out of order packets */
+	if(ic->state == Ilestablished) {
+		while(ic->outoforder) {
+			bp = ic->outoforder;
+			oh = (Ilhdr*)bp->rptr;
+			oid = nhgetl(oh->ilid);
+print("recvd = %d outoforder = %d\n", ic->recvd, oid);
+			if(oid < ic->recvd) {
+				ic->outoforder = bp->next;
+				freeb(bp);
+			}
+			if(oid == ic->recvd) {
+print("outoforder %d\n", oid);
+				ic->recvd++;
+				ic->outoforder = bp->next;
+				bp->rptr += IL_EHSIZE+IL_HDRSIZE;
+				PUTNEXT(s->readq, bp);
+			}
+		}
+	}
 }
 
+
 void
 iloutoforder(Ipconv *s, Ilhdr *h, Block *bp)
 {
@@ -339,6 +378,7 @@ ilsendctl(Ipconv *ipc, Ilhdr *inih, int type, int ack)
 
 	bp = allocb(IL_EHSIZE+IL_HDRSIZE);
 	bp->wptr += IL_EHSIZE+IL_HDRSIZE;
+	bp->flags |= S_DELIM;
 
 	ih = (Ilhdr *)(bp->rptr);
 	ic = &ipc->ilctl;
@@ -360,6 +400,7 @@ ilsendctl(Ipconv *ipc, Ilhdr *inih, int type, int ack)
 		hnputs(ih->ildst, ipc->pdst);
 		hnputl(ih->ilid, ic->sent);
 		hnputl(ih->ilack, ic->recvd);
+		print("sendctl: id %d ack %d\n", ic->sent, ic->recvd);
 	}
 	ih->iltype = type;
 	ih->ilspec = 0;
@@ -393,7 +434,8 @@ ilstart(Ipconv *ipc, int type, int window)
 	ic->outoforder = 0;
 	initseq += TK2MS(MACHP(0)->ticks);
 	ic->sent = initseq;
-	ic->recvd = ic->sent;
+	ic->start = ic->sent;
+	ic->recvd = 0;
 	ic->lastack = ic->sent;
 	ic->window = window;