V9/sys/dev.old/spipe.c

/*
 * stream pipe
 */
#include "sp.h"

#include "../h/param.h"
#include "../h/systm.h"
#include "../h/stream.h"
#include "../h/conf.h"

struct	queue	*spipes[256];

int	spsrv(), spopen(), spclose();
static struct qinit sprinit = { putq, spsrv, spopen, spclose, 128, 65 };
struct streamtab spinfo = { &sprinit, &sprinit };

spopen(q, dev)
register struct queue *q;
{
	register d = minor(dev);
	register struct queue *oq;

	if (q->ptr) {			/* already open */
		if (d&01)
			return(0);	/* reopening master */
		else
			return(1);	/* reopening slave */
	}
	q->flag |= QDELIM;
	if (oq = spipes[d^01]) {
		if (d&01)
			return(0);	/* master with old lingering slave */
		WR(q)->ptr = (caddr_t)oq;
		WR(oq)->ptr = (caddr_t)q;
	} else if ((d&01) == 0)
		return(0);		/* slave opened first */
	q->ptr = (caddr_t)dev;
	spipes[d] = q;
	return(1);
}

spclose(q)
register struct queue *q;
{
	register struct queue *oq;
	register struct block *bp;

	if (oq = (struct queue *)WR(q)->ptr) {
		while (bp = getq(WR(q)))
			(*oq->next->qinfo->putp)(oq->next, bp);
		putctl(oq->next, M_HANGUP);
		WR(oq)->ptr = NULL;
	}
	spipes[minor((int)q->ptr)] = NULL;
}

spsrv(q)
register struct queue *q;
{
	register struct block *bp;
	register struct queue *oq;

	if (q->flag&QREADR) {
		oq = (struct queue *)WR(q)->ptr;
		if (oq && (q->next->flag & QFULL) == 0)
			qenable(WR(oq));
		return;
	}
	oq = (struct queue *)q->ptr;
	while (bp = getq(q)) {
		if (oq == NULL) {
			freeb(bp);
			continue;
		}
		if (oq->next->flag & QFULL && bp->type < QPCTL) {
			putbq(q, bp);
			return;
		}
		(*oq->next->qinfo->putp)(oq->next, bp);
	}
}