1990/0804/port/sturp.c (diff list | history)

1990/0731/sys/src/9/port/sturp.c:943,949 – 1990/0804/sys/src/9/port/sturp.c:943,953 (short | long | prev | next)
1990/0312		Urp *up; up = (Urp *)arg; return (WINDOW(up)>0 && up->wq->len>0 && !(up->state&INITING));
1990/0804		return (up->state&INITING) ? NOW>up->timer /* time to INIT1 */ : ((up->unacked!=up->next && NOW>up->timer) /* time to ENQ */ || (!QFULL(up->rq->next) && up->iseq!=(up->lastecho&7))); /* time to ECHO */
1990/0312		} static void urpkproc(void *arg)
1990/0731/sys/src/9/port/sturp.c:970,976 – 1990/0804/sys/src/9/port/sturp.c:974,979
1990/0403		up->kstarted = 0;
1990/0728		wakeup(&up->r); poperror();
1990/0511		DPRINT("urpkproc %ux\n", up);
1990/0725		} /*
1990/0731/sys/src/9/port/sturp.c:988,998 – 1990/0804/sys/src/9/port/sturp.c:991,998
1990/0725		for(up = urp, last = &urp[conf.nurp]; up < last; up++){ if(up->state==0) continue;
1990/0731		if((up->unacked!=up->next || (up->state&INITING)) && NOW>up->timer){
1990/0725		q = up->rq; if(q) wakeup(&q->r); }
1990/0804		if(up->rq && todo(up)) wakeup(&up->rq->r);
1990/0725		}
1990/0629		}