1991/0502/port/stream.c (diff list | history)

1991/0501/sys/src/9/port/stream.c:1010,1015 – 1991/0502/sys/src/9/port/stream.c:1010,1018 (short | long | prev | next)
1990/1212		wakeup(q->other->rp);
1990/0321		delim = 1;
1990/0227		} else {
1991/0502		if(BLEN(bp) == 1 && *(bp->rptr) == 1) print("stputq u->p->pid %d %s\n", u->p->pid, u->p->text);
1990/0227		lock(q); if(q->first) q->last->next = bp;
1991/0501/sys/src/9/port/stream.c:1268,1273 – 1991/0502/sys/src/9/port/stream.c:1271,1279
1990/0227
1990/0911		s = c->stream;
1991/0502		if(n == 1 && *((char*)a) == 1) print("u->p->pid %d %s\n", u->p->pid, u->p->text);
1990/0227		/* * decode the qid */
1991/0501/sys/src/9/port/stream.c:1285,1291 – 1991/0502/sys/src/9/port/stream.c:1291,1314
1991/0411		error(Ehungup); }
1990/0227
1991/0404		if(!docopy && isphys(a)){
1991/0502		/* * if an error occurs during write n, * force a delim before write n+1 */ if(waserror()){ s->forcedelim = 1; nexterror(); } if(s->forcedelim){ FLOWCTL(q); bp = allocb(0); bp->flags |= S_DELIM; bp->type = M_DATA; PUTNEXT(q, bp); s->forcedelim = 0; } if(0 && !docopy && isphys(a)){
1990/0227		/* * `a' is global to the whole system, just create a * pointer to it and pass it on.
1991/0501/sys/src/9/port/stream.c:1322,1327 – 1991/0502/sys/src/9/port/stream.c:1345,1351
1990/0227		} } }
1991/0502		poperror();
1990/0227		return n;
1990/0312		}