plan 9 kernel history: overview | file list | diff list

1992/0404/pc/devether.c (diff list | history)

pc/devether.c on 1992/0403
1992/0403    
/* 
 * Western Digital ethernet adapter 
 * BUGS:
1992/0404    
 *	no more than one controller
1992/0403    
 *	fix for different controller types 
 */ 
#include "u.h" 
#include "../port/lib.h" 
#include "mem.h" 
#include "dat.h" 
#include "fns.h" 
#include "../port/error.h" 
#include "io.h" 
#include "devtab.h" 
 
typedef struct Ctlr Ctlr; 
typedef struct Pktype Pktype;
1992/0404    
typedef struct Ring Ring;
1992/0403    
 
enum { 
	IObase		= 0x360,
1992/0404    
	RAMbase		= 0xC8000, 
	RAMsize		= 8*1024, 
	BUFsize		= 256,
1992/0403    
1992/0404    
	Nctlr		= 1, 
	NPktype		= 9,		/* types/interface */ 
}; 
 
/* 
 * register offsets from IObase 
 */ 
enum {
1992/0403    
	EA		= 0x08,		/* Ethernet Address in ROM */ 
	ID		= 0x0E,		/* interface type */ 
 
	NIC		= 0x10,		/* National DP8390 Chip */ 
	Cr		= NIC+0x00,	/* Page [01] */
1992/0404    
	Pstart		= NIC+0x01,	/* write */ 
	Pstop		= NIC+0x02,	/* write */ 
	Bnry		= NIC+0x03,
1992/0403    
	Tsr		= NIC+0x04,	/* read */ 
	Tpsr		= Tsr,		/* write */
1992/0404    
	Tbcr0		= NIC+0x05,	/* write */ 
	Tbcr1		= NIC+0x06,	/* write */
1992/0403    
	Isr		= NIC+0x07, 
	Rbcr0		= NIC+0x0A, 
	Rbcr1		= NIC+0x0B, 
	Rsr		= NIC+0x0C,	/* read */ 
	Rcr		= Rsr,		/* write */ 
	Cntr0		= NIC+0x0D,	/* read */ 
	Tcr		= Cntr0,	/* write */ 
	Cntr1		= NIC+0x0E,	/* read */ 
	Dcr		= Cntr1,	/* write */ 
	Cntr2		= NIC+0x0F,	/* read */ 
	Imr		= Cntr2,	/* write */ 
 
	Par0		= NIC+0x01,	/* Page 1 */ 
	Curr		= NIC+0x07,
1992/0404    
};
1992/0403    
1992/0404    
/* 
 * some register bits 
 */ 
enum { 
	Prx		= 0x01,		/* Isr:	packet received */ 
	Ptx		= 0x02,		/*	packet transmitted */ 
	Rxe		= 0x04,		/*	receive error */ 
	Txe		= 0x08,		/*	transmit error */ 
	Ovw		= 0x10,		/*	overwrite warning */ 
	Rst		= 0x80,		/*	reset status */ 
};
1992/0403    
1992/0404    
struct Ring { 
	uchar	status; 
	uchar	next; 
	ushort	len; 
	uchar	data[BUFsize-4];
1992/0403    
}; 
 
/* 
 * one per ethernet packet type 
 */ 
struct Pktype { 
	QLock; 
	int	type;			/* ethernet type */ 
	int	prom;			/* promiscuous mode */ 
	Queue	*q; 
	int	inuse; 
	Ctlr	*ctlr; 
}; 
 
/* 
 *  per ethernet 
 */ 
struct Ctlr { 
	QLock; 
 
	Rendez	rr;			/* rendezvous for an input buffer */
1992/0404    
	uchar	bnry; 
	uchar	curr; 
	uchar	ovw;
1992/0403    
	Queue	rq;
1992/0404    
	QLock	xl;
1992/0403    
	Rendez	xr; 
 
	int	iobase;			/* I/O base address */ 
 
	Pktype	pktype[NPktype]; 
	uchar	ea[6]; 
	uchar	ba[6]; 
 
	uchar	prom;			/* true if promiscuous mode */ 
	uchar	kproc;			/* true if kproc started */ 
	char	name[NAMELEN];		/* name of kproc */ 
	Network	net; 
	Netprot	prot[NPktype]; 
 
	int	inpackets; 
	int	outpackets; 
	int	crcs;			/* input crc errors */ 
	int	oerrs;			/* output errors */ 
	int	frames;			/* framing errors */ 
	int	overflows;		/* packet overflows */ 
	int	buffs;			/* buffering errors */ 
}; 
static Ctlr ctlr[Nctlr]; 
 
static void 
etheroput(Queue *q, Block *bp) 
{ 
	Ctlr *c; 
	int len, n; 
	Pktype *t; 
	Etherpkt *p; 
	Block *nbp;
1992/0404    
panic("etheroput\n"); 
#ifdef notdef
1992/0403    
	c = ((Pktype *)q->ptr)->ctlr; 
	if(bp->type == M_CTL){ 
		t = q->ptr; 
		if(streamparse("connect", bp)) 
			t->type = strtol((char *)bp->rptr, 0, 0); 
		else if(streamparse("promiscuous", bp)) { 
			t->prom = 1; 
			qlock(c); 
			c->prom++;
1992/0404    
			if(c->prom == 1){ 
				outb(t->ctlr->iobase+Cr, 0x22);	/* Page0, RD2|STA */
1992/0403    
				outb(c->iobase+Rcr, 0x14);	/* PRO|AB */
1992/0404    
			}
1992/0403    
			qunlock(c); 
		} 
		freeb(bp); 
		return; 
	} 
 
	/* 
	 * give packet a local address, return upstream if destined for 
	 * this machine. 
	 */ 
	if(BLEN(bp) < ETHERHDRSIZE){ 
		bp = pullup(bp, ETHERHDRSIZE); 
		if(bp == 0) 
			return; 
	} 
	p = (Etherpkt *)bp->rptr; 
	memmove(p->s, c->ea, sizeof(c->ea)); 
	if(memcmp(c->ea, p->d, sizeof(c->ea)) == 0){ 
		len = blen(bp); 
		bp = expandb(bp, len >= ETHERMINTU ? len: ETHERMINTU); 
		if(bp){ 
			putq(&c->rq, bp); 
			wakeup(&c->rr); 
		} 
		return; 
	} 
	if(memcmp(c->ba, p->d, sizeof(c->ba)) == 0){ 
		len = blen(bp); 
		nbp = copyb(bp, len); 
		nbp = expandb(nbp, len >= ETHERMINTU ? len: ETHERMINTU); 
		if(nbp){ 
			nbp->wptr = nbp->rptr+len; 
			putq(&c->rq, nbp); 
			wakeup(&c->rr); 
		} 
	} 
 
	/* 
	 * only one transmitter at a time 
	 */ 
	qlock(&c->xl); 
	if(waserror()){ 
		qunlock(&c->xl); 
		nexterror(); 
	} 
 
	/* 
	 *  Wait till we get an output buffer 
	 */ 
	sleep(&c->xr, isobuf, c); 
	p = enet.xn; 
 
	/* 
	 * copy message into buffer 
	 */ 
	len = 0; 
	for(nbp = bp; nbp; nbp = nbp->next){ 
		if(sizeof(Etherpkt) - len >= (n = BLEN(nbp))){ 
			memmove(((uchar *)p)+len, nbp->rptr, n); 
			len += n; 
		} else 
			print("no room damn it\n"); 
		if(bp->flags & S_DELIM) 
			break; 
	} 
 
	/* 
	 *  pad the packet (zero the pad) 
	 */ 
	if(len < ETHERMINTU){ 
		memset(((char*)p)+len, 0, ETHERMINTU-len); 
		len = ETHERMINTU; 
	} 
	enet.xn->len = len; 
 
	/* 
	 *  give packet a local address 
	 */ 
	memmove(p->s, enet.ea, sizeof(enet.ea)); 
 
	/* 
	 *  give to Chip 
	 */ 
	splhi();		/* sync with interrupt routine */ 
	enet.xn->owner = Chip; 
	if(enet.xmting == 0) 
		ethersend(enet.xn); 
	spllo(); 
 
	/* 
	 *  send 
	 */ 
	enet.xn = XSUCC(enet.xn); 
	freeb(bp); 
	qunlock(&enet.xl); 
	poperror(); 
 
	enet.outpackets++;
1992/0404    
#endif
1992/0403    
} 
 
/* 
 * open an ether line discipline 
 * 
 * the lock is to synchronize changing the ethertype with 
 * sending packets up the stream on interrupts. 
 */ 
static void 
etherstopen(Queue *q, Stream *s) 
{
1992/0404    
	Ctlr *cp = &ctlr[0]; 
	Pktype *pp;
1992/0403    
1992/0404    
	pp = &cp->pktype[s->id]; 
	qlock(pp); 
	RD(q)->ptr = WR(q)->ptr = pp; 
	pp->type = 0; 
	pp->q = RD(q); 
	pp->inuse = 1; 
	pp->ctlr = cp; 
	qunlock(pp);
1992/0403    
} 
 
/* 
 *  close ether line discipline 
 * 
 *  the lock is to synchronize changing the ethertype with 
 *  sending packets up the stream on interrupts. 
 */ 
static void 
etherstclose(Queue *q) 
{
1992/0404    
	Pktype *pp;
1992/0403    
1992/0404    
	pp = (Pktype *)(q->ptr); 
	if(pp->prom){ 
		qlock(pp->ctlr); 
		pp->ctlr->prom--; 
		if(pp->ctlr->prom == 0){ 
			outb(pp->ctlr->iobase+Cr, 0x22);/* Page0, RD2|STA */ 
			outb(pp->ctlr->iobase+Rcr, 0x04);/* AB */ 
		} 
		qunlock(pp->ctlr);
1992/0403    
	}
1992/0404    
	qlock(pp); 
	pp->type = 0; 
	pp->q = 0; 
	pp->prom = 0; 
	pp->inuse = 0; 
	netdisown(&pp->ctlr->net, pp - pp->ctlr->pktype); 
	qunlock(pp);
1992/0403    
} 
 
static Qinfo info = { 
	nullput, 
	etheroput, 
	etherstopen, 
	etherstclose, 
	"ether" 
}; 
 
static int
1992/0404    
clonecon(Chan *c)
1992/0403    
{
1992/0404    
	Ctlr *cp = &ctlr[0]; 
	Pktype *pp;
1992/0403    
1992/0404    
	for(pp = cp->pktype; pp < &cp->pktype[NPktype]; pp++){ 
		qlock(pp); 
		if(pp->inuse || pp->q){ 
			qunlock(pp);
1992/0403    
			continue; 
		}
1992/0404    
		pp->inuse = 1; 
		netown(&cp->net, pp - cp->pktype, u->p->user, 0); 
		qunlock(pp); 
		return pp - cp->pktype;
1992/0403    
	} 
	exhausted("ether channels"); 
} 
 
static void
1992/0404    
statsfill(Chan *c, char *p, int n)
1992/0403    
{
1992/0404    
	Ctlr *cp = &ctlr[0];
1992/0403    
	char buf[256]; 
 
	sprint(buf, "in: %d\nout: %d\ncrc errs %d\noverflows: %d\nframe errs %d\nbuff errs: %d\noerrs %d\naddr: %.02x:%.02x:%.02x:%.02x:%.02x:%.02x\n",
1992/0404    
		cp->inpackets, cp->outpackets, cp->crcs, 
		cp->overflows, cp->frames, cp->buffs, cp->oerrs, 
		cp->ea[0], cp->ea[1], cp->ea[2], cp->ea[3], cp->ea[4], cp->ea[5]);
1992/0403    
	strncpy(p, buf, n); 
} 
 
static void 
typefill(Chan *c, char *p, int n) 
{ 
	char buf[16];
1992/0404    
	Pktype *pp;
1992/0403    
1992/0404    
	pp = &ctlr[0].pktype[STREAMID(c->qid.path)]; 
	sprint(buf, "%d", pp->type);
1992/0403    
	strncpy(p, buf, n); 
} 
 
static void 
intr(Ureg *ur) 
{
1992/0404    
	Ctlr *cp = &ctlr[0]; 
	uchar isr, curr; 
 
	outb(cp->iobase+Cr, 0x22);			/* Page0, RD2|STA */ 
	while(isr = inb(cp->iobase+Isr)){ 
		outb(cp->iobase+Isr, isr); 
		if(isr & Txe) 
			cp->oerrs++; 
		if(isr & Rxe){ 
			cp->frames += inb(cp->iobase+Cntr0); 
			cp->crcs += inb(cp->iobase+Cntr1); 
			cp->buffs += inb(cp->iobase+Cntr2); 
		} 
		if(isr & Ptx) 
			cp->outpackets++; 
		if(isr & (Txe|Ptx)){ 
			panic("tx intr\n"); 
		} 
		/* 
		 * the receive ring is full. 
		 * put the NIC into loopback mode to give 
		 * kproc a chance to process some packets. 
		 */ 
		if(isr & Ovw){ 
			outb(cp->iobase+Cr, 0x21);	/* Page0, RD2|STP */ 
			outb(cp->iobase+Rbcr0, 0); 
			outb(cp->iobase+Rbcr1, 0); 
			while((inb(cp->iobase+Isr) & Rst) == 0) 
				delay(1); 
			outb(cp->iobase+Tcr, 0x20);	/* LB0 */ 
			outb(cp->iobase+Cr, 0x22);	/* Page0, RD2|STA */ 
			cp->ovw = 1; 
		} 
		/* 
		 * we have received packets. 
		 * this is the only place, other than the init code, 
		 * where we set the controller to Page1. 
		 * we must be careful to reset it back to Page0 in case 
		 * we interrupted some other part of this driver. 
		 */ 
		if(isr & (Ovw|Prx)){ 
			outb(cp->iobase+Cr, 0x62);	/* Page1, RD2|STA */ 
			cp->curr = inb(cp->iobase+Curr); 
			outb(cp->iobase+Cr, 0x22);	/* Page0, RD2|STA */ 
			wakeup(&cp->rr); 
		} 
	}
1992/0403    
} 
 
/* 
 * the following initialisation procedure 
 * is mandatory
1992/0404    
 * we leave the chip idling on internal loopback
1992/0403    
 */ 
static void
1992/0404    
init(Ctlr *cp)
1992/0403    
{ 
	int i;
1992/0404    
	outb(cp->iobase+Cr, 0x21);		/* Page0, RD2|STP */ 
	outb(cp->iobase+Dcr, 0x48);		/* FT1|LS */ 
	outb(cp->iobase+Rbcr0, 0); 
	outb(cp->iobase+Rbcr1, 0); 
	outb(cp->iobase+Rcr, 0x04);		/* AB */ 
	outb(cp->iobase+Tcr, 0x20);		/* LB0 */ 
	outb(cp->iobase+Bnry, 6); 
	cp->bnry = 6; 
	outb(cp->iobase+Pstart, 6);		/* 6*256 */ 
	outb(cp->iobase+Pstop, 32);		/* 8*1024/256 */ 
	outb(cp->iobase+Isr, 0xFF); 
	outb(cp->iobase+Imr, 0x1F);		/* OVWE|TXEE|RXEE|PTXE|PRXE */
1992/0403    
1992/0404    
	outb(cp->iobase+Cr, 0x61);		/* Page1, RD2|STP */ 
	for(i = 0; i < sizeof(cp->ea); i++) 
		outb(cp->iobase+Par0+i, cp->ea[i]); 
	outb(cp->iobase+Curr, 6);		/* 6*256 */ 
	cp->curr = 6; 
 
	outb(cp->iobase+Cr, 0x22);		/* Page0, RD2|STA */ 
	outb(cp->iobase+Tpsr, 0);
1992/0403    
} 
 
void 
etherreset(void) 
{
1992/0404    
	Ctlr *cp = &ctlr[0];
1992/0403    
	int i;
1992/0404    
	cp->iobase = IObase; 
	init(cp);
1992/0403    
	setvec(Ethervec, intr);
1992/0404    
	for(i = 0; i < sizeof(cp->ea); i++) 
		cp->ea[i] = inb(cp->iobase+EA+i); 
	memset(cp->ba, 0xFF, sizeof(cp->ba));
1992/0403    
1992/0404    
	cp->net.name = "ether"; 
	cp->net.nconv = NPktype; 
	cp->net.devp = &info; 
	cp->net.protop = 0; 
	cp->net.listen = 0; 
	cp->net.clone = clonecon; 
	cp->net.ninfo = 2; 
	cp->net.prot = cp->prot; 
	cp->net.info[0].name = "stats"; 
	cp->net.info[0].fill = statsfill; 
	cp->net.info[1].name = "type"; 
	cp->net.info[1].fill = typefill;
1992/0403    
}
1992/0404    
static void 
etherup(Ctlr *cp, Etherpkt *p, int len) 
{ 
	Block *bp; 
	Pktype *pp; 
	int t; 
 
	t = (p->type[0]<<8) | p->type[1]; 
	for(pp = &cp->pktype[0]; pp < &cp->pktype[NPktype]; pp++){ 
		/* 
		 *  check before locking just to save a lock 
		 */ 
		if(pp->q == 0 || (t != pp->type && pp->type != -1)) 
			continue; 
 
		/* 
		 *  only a trace channel gets packets destined for other machines 
		 */ 
		if(pp->type != -1 && p->d[0] != 0xFF && memcmp(p->d, cp->ea, sizeof(p->d))) 
			continue; 
 
		/* 
		 *  check after locking to make sure things didn't 
		 *  change under foot 
		 */ 
		if(canqlock(pp) == 0) 
			continue; 
		if(pp->q == 0 || pp->q->next->len > Streamhi || (t != pp->type && pp->type != -1)){ 
			qunlock(pp); 
			continue; 
		} 
		if(waserror() == 0){ 
			bp = allocb(len); 
			memmove(bp->rptr, (uchar *)p, len); 
			bp->wptr += len; 
			bp->flags |= S_DELIM; 
			PUTNEXT(pp->q, bp); 
		} 
		poperror(); 
		qunlock(pp); 
	} 
}
1992/0403    
static int 
isinput(void *arg) 
{
1992/0404    
	Ctlr *cp = arg;
1992/0403    
1992/0404    
	return cp->bnry != cp->curr;
1992/0403    
} 
 
static void 
etherkproc(void *arg) 
{
1992/0404    
	Ctlr *cp = arg; 
	Block *bp; 
	uchar bnry, curr; 
	Ring *rp;
1992/0403    
 
	if(waserror()){
1992/0404    
		print("%s noted\n", cp->name); 
		init(cp); 
		cp->kproc = 0;
1992/0403    
		nexterror(); 
	}
1992/0404    
	cp->kproc = 1;
1992/0403    
	for(;;){
1992/0404    
		sleep(&cp->rr, isinput, cp); 
		while(bp = getq(&cp->rq)){ 
			cp->inpackets++; 
			etherup(cp, (Etherpkt*)bp->rptr, BLEN(bp)); 
			freeb(bp); 
		} 
#ifdef foo 
			bnry = inb(cp->iobase+Bnry); 
			while(bnry != cp->curr){ 
				rp = &((Ring *)RAMbase)[bnry]; 
			} 
#endif
1992/0403    
	} 
} 
 
void 
etherinit(void) 
{ 
	int ctlrno = 0; 
 
	/* 
	 * put the receiver online 
	 * and start the kproc 
	 */
1992/0404    
	outb(ctlr[ctlrno].iobase+Tcr, 0);
1992/0403    
	if(ctlr[ctlrno].kproc == 0){ 
		sprint(ctlr[ctlrno].name, "ether%dkproc", ctlrno); 
		kproc(ctlr[ctlrno].name, etherkproc, &ctlr[ctlrno]); 
	} 
} 
 
Chan * 
etherattach(char *spec) 
{ 
	return devattach('l', spec); 
} 
 
Chan * 
etherclone(Chan *c, Chan *nc) 
{ 
	return devclone(c, nc); 
} 
 
int 
etherwalk(Chan *c, char *name) 
{ 
	return netwalk(c, name, &ctlr[0].net); 
} 
 
void 
etherstat(Chan *c, char *dp) 
{ 
	netstat(c, dp, &ctlr[0].net); 
} 
 
Chan * 
etheropen(Chan *c, int omode) 
{ 
	return netopen(c, omode, &ctlr[0].net); 
} 
 
void 
ethercreate(Chan *c, char *name, int omode, ulong perm) 
{ 
	error(Eperm); 
} 
 
void 
etherremove(Chan *c) 
{ 
	error(Eperm); 
} 
 
void 
etherwstat(Chan *c, char *dp) 
{ 
	netwstat(c, dp, &ctlr[0].net); 
} 
 
void 
etherclose(Chan *c) 
{ 
	if(c->stream) 
		streamclose(c); 
} 
 
long 
etherread(Chan *c, void *a, long n, ulong offset) 
{ 
	return netread(c, a, n, offset, &ctlr[0].net); 
} 
 
long 
etherwrite(Chan *c, char *a, long n, ulong offset) 
{ 
	return streamwrite(c, a, n, 0); 
}


source code copyright © 1990-2005 Lucent Technologies; see license
Plan 9 distribution
comments to russ cox (rsc@swtch.com)