1990/0406/gnot/stream.c (diff list | history)

1990/0403/sys/src/9/gnot/stream.c:372,377 – 1990/0406/sys/src/9/gnot/stream.c:372,378 (short | long | prev | next)
1990/03091		q->last = bp; q->first = bp;
1990/0312		q->len += BLEN(bp);
1990/0406		q->nb++;
1990/03091		unlock(q); }
1990/0403/sys/src/9/gnot/stream.c:391,397 – 1990/0406/sys/src/9/gnot/stream.c:392,398
1990/03091		q->last = 0;
1990/0312		q->len -= BLEN(bp);
1990/0403		q->nb--; if((q->flag&QHIWAT) && q->len < Streamhi/2 && q->nb < Streambhi){
1990/0406		if((q->flag&QHIWAT) && q->len<Streamhi/2 && q->nb<Streambhi/2){
1990/03091		wakeup(&q->other->next->other->r); q->flag &= ~QHIWAT; }
1990/0403/sys/src/9/gnot/stream.c:941,950 – 1990/0406/sys/src/9/gnot/stream.c:942,948
1990/03091		static int notfull(void *arg) { Queue *q;                  q = (Queue *)arg;
1990/0403		return !QFULL(q->next);
1990/0406		return !QFULL((Queue *)arg);
1990/03091		} void flowctl(Queue *q)