From 2f6c11624bd48a08f6cab385d8e84fac9afd8923 Mon Sep 17 00:00:00 2001 From: David du Colombier <0intro@gmail.com> Date: Sun, 27 Sep 1998 00:00:00 +0000 Subject: [PATCH] Plan 9 from Bell Labs 1998-09-27 --- ip/tcp.c | 41 +++++++++++++++++++---------------------- 1 file changed, 19 insertions(+), 22 deletions(-) diff --git a/ip/tcp.c b/ip/tcp.c index 519ab2b42328a3aab1df4ec3dca737e226176a47..cbc658c206d8d1c9065f2bf02d7128d485b9a33b 100644 --- a/ip/tcp.c +++ b/ip/tcp.c @@ -409,14 +409,11 @@ tcpkick(Conv *s, int len) } } -/* - * get remote sender going if it was flow controlled due to a closed window - */ static void -deltimer(Tcppriv *tpriv, Timer *t) +deltimer(Tcppriv *priv, Timer *t) { - if(tpriv->timers == t) - tpriv->timers = t->next; + if(priv->timers == t) + priv->timers = t->next; if(t->next) t->next->prev = t->prev; if(t->prev) @@ -465,33 +462,33 @@ tcpackproc(void *a) { Timer *t, *tp, *timeo; Proto *tcp; - Tcppriv *tpriv; + Tcppriv *priv; int loop; tcp = a; - tpriv = tcp->priv; + priv = tcp->priv; for(;;) { - tsleep(&tpriv->tcpr, return0, 0, MSPTICK); + tsleep(&priv->tcpr, return0, 0, MSPTICK); - qlock(&tpriv->tl); + qlock(&priv->tl); timeo = nil; loop = 0; - for(t = tpriv->timers; t != nil; t = tp) { + for(t = priv->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); + deltimer(priv, t); t->state = TimerDONE; t->readynext = timeo; timeo = t; } } } - qunlock(&tpriv->tl); + qunlock(&priv->tl); loop = 0; for(t = timeo; t != nil; t = t->readynext) { @@ -504,35 +501,35 @@ tcpackproc(void *a) } void -tcpgo(Tcppriv *tpriv, Timer *t) +tcpgo(Tcppriv *priv, Timer *t) { if(t == nil || t->start == 0) return; - qlock(&tpriv->tl); + qlock(&priv->tl); t->count = t->start; if(t->state != TimerON) { t->state = TimerON; t->prev = nil; - t->next = tpriv->timers; + t->next = priv->timers; if(t->next) t->next->prev = t; - tpriv->timers = t; + priv->timers = t; } - qunlock(&tpriv->tl); + qunlock(&priv->tl); } void -tcphalt(Tcppriv *tpriv, Timer *t) +tcphalt(Tcppriv *priv, Timer *t) { if(t == nil) return; - qlock(&tpriv->tl); + qlock(&priv->tl); if(t->state == TimerON) - deltimer(tpriv, t); + deltimer(priv, t); t->state = TimerOFF; - qunlock(&tpriv->tl); + qunlock(&priv->tl); } int