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

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

1992/0411/sys/src/9/pc/devether.c:1,14 – 1992/0424/sys/src/9/pc/devether.c:1,3 (short | long | prev | next)
1992/0403    
/* 
 * Western Digital ethernet adapter 
 * BUGS:
1992/0404    
 *	no more than one controller
1992/0406    
 * TODO:
1992/0403    
 *	fix for different controller types
1992/0406    
 *	output 
 *	deal with stalling and restarting output on input overflow 
 *	fix magic ring constants
1992/0407    
 *	rewrite per SMC doc
1992/0403    
 */ 
#include "u.h" 
#include "../port/lib.h" 
#include "mem.h"
1992/0411/sys/src/9/pc/devether.c:18,97 – 1992/0424/sys/src/9/pc/devether.c:7,56
1992/0403    
#include "io.h" 
#include "devtab.h"
1992/0410    
static int debug; 
                 
1992/0403    
typedef struct Ctlr Ctlr;
1992/0424    
typedef struct Hw Hw; 
typedef struct Buffer Buffer;
1992/0410    
typedef struct Type Type;
1992/0404    
typedef struct Ring Ring;
1992/0424    
typedef struct Ctlr Ctlr;
1992/0403    
 
enum { 
	IObase		= 0x360,
1992/0411    
	RAMbase		= 0xC8000,
1992/0404    
	RAMsize		= 8*1024, 
	BUFsize		= 256,
1992/0403    
                 
1992/0410    
	RINGbase	= 6,		/* gak */ 
	RINGsize	= 32,		/* gak */ 
                 
1992/0404    
	Nctlr		= 1,
1992/0410    
	NType		= 9,		/* types/interface */
1992/0424    
struct Hw { 
	int	addr;			/* interface address */ 
	void	*ram;			/* interface shared memory address */ 
	int	ramsz;			/* interface shared memory size */ 
	void	(*reset)(Ctlr*); 
	void	(*init)(Ctlr*); 
	void	(*mode)(Ctlr*, int); 
	void	(*online)(Ctlr*, int); 
	void	(*receive)(Ctlr*); 
	void	(*transmit)(Ctlr*); 
	void	(*intr)(Ureg*);
1992/0404    
};
1992/0424    
static Hw wd8013;
1992/0404    
1992/0410    
#define NEXT(x, l)	((((x)+1)%(l)) == 0 ? RINGbase: (((x)+1)%(l))) 
#define PREV(x, l)	(((x)-1) < RINGbase ? (l-1): ((x)-1))
1992/0408    
                 
1992/0404    
/* 
 * register offsets from IObase 
 */ 
enum {
1992/0403    
	EA		= 0x08,		/* Ethernet Address in ROM */ 
	ID		= 0x0E,		/* interface type */
1992/0424    
	Nctlr		= 1,		/* even one of these is too many */ 
	NType		= 9,		/* types/interface */
1992/0403    
 
	NIC		= 0x10,		/* National DP8390 Chip */ 
	Cr		= NIC+0x00,	/* Page [01] */
1992/0424    
	Nrb		= 16,		/* software receive buffers */ 
	Ntb		= 4,		/* software transmit buffers */ 
};
1992/0403    
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 */
1992/0424    
#define NEXT(x, l)	(((x)+1)%(l)) 
#define OFFSETOF(t, m)	((unsigned)&(((t*)0)->m)) 
#define	HOWMANY(x, y)	(((x)+((y)-1))/(y)) 
#define ROUNDUP(x, y)	(HOWMANY((x), (y))*(y))
1992/0403    
 
	Par0		= NIC+0x01,	/* Page 1 */ 
	Curr		= NIC+0x07,
1992/0424    
struct Buffer { 
	uchar	owner; 
	uchar	busy; 
	ushort	len; 
	Etherpkt pkt;
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 */
1992/0424    
	Host		= 0,		/* buffer owned by host */ 
	Interface	= 1,		/* buffer owned by interface */
1992/0404    
};
1992/0403    
1992/0404    
struct Ring { 
	uchar	status; 
	uchar	next;
1992/0407    
	uchar	len0; 
	uchar	len1;
1992/0404    
	uchar	data[BUFsize-4];
1992/0403    
}; 
                 
/* 
 * one per ethernet packet type 
 */
1992/0411/sys/src/9/pc/devether.c:105,178 – 1992/0424/sys/src/9/pc/devether.c:64,185
1992/0403    
}; 
 
/* 
 *  per ethernet
1992/0424    
 * per ethernet
1992/0403    
 */ 
struct Ctlr { 
	QLock;
1992/0407    
	Ring	*ring;
1992/0403    
	Rendez	rr;			/* rendezvous for an input buffer */
1992/0407    
	Queue	rq;
1992/0404    
	uchar	bnry; 
	uchar	curr;
1992/0424    
	Hw	*hw;
1992/0403    
1992/0407    
	Etherpkt *xpkt;
1992/0404    
	QLock	xl;
1992/0403    
	Rendez	xr;
1992/0407    
	uchar	xbusy;
1992/0424    
	ushort	nrb;		/* number of software receive buffers */ 
	ushort	ntb;		/* number of software transmit buffers */ 
	Buffer	*rb;		/* software receive buffers */ 
	Buffer	*tb;		/* software transmit buffers */
1992/0403    
 
	int	iobase;			/* I/O base address */
1992/0424    
	uchar	ea[6];		/* ethernet address */ 
	uchar	ba[6];		/* broadcast address */
1992/0403    
1992/0410    
	Type	type[NType];
1992/0403    
	uchar	ea[6]; 
	uchar	ba[6];
1992/0424    
	Rendez	rr;		/* rendezvous for a receive buffer */ 
	QLock	rlock;		/* semaphore on rc */ 
	ushort	rh;		/* first receive buffer belonging to host */ 
	ushort	ri;		/* first receive buffer belonging to interface */
1992/0403    
 
	uchar	prom;			/* true if promiscuous mode */ 
	uchar	kproc;			/* true if kproc started */ 
	char	name[NAMELEN];		/* name of kproc */
1992/0424    
	Rendez	tr;		/* rendezvous for a transmit buffer */ 
	QLock	tlock;		/* semaphore on tc */ 
	ushort	th;		/* first transmit buffer belonging to host */	 
	ushort	ti;		/* first transmit buffer belonging to interface */	 
 
	Type	type[NType]; 
	uchar	prom;		/* true if promiscuous mode */ 
	uchar	kproc;		/* true if kproc started */ 
	char	name[NAMELEN];	/* name of kproc */
1992/0403    
	Network	net;
1992/0410    
	Netprot	prot[NType];
1992/0403    
1992/0424    
	Queue	lbq;		/* software loopback packet queue */
1992/0403    
	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 */
1992/0424    
	int	crcs;		/* input crc errors */ 
	int	oerrs;		/* output errors */ 
	int	frames;		/* framing errors */ 
	int	overflows;	/* packet overflows */ 
	int	buffs;		/* buffering errors */
1992/0403    
}; 
static Ctlr ctlr[Nctlr];
1992/0411    
static Etherpkt txpkt;
1992/0424    
void 
etherinit(void) 
{ 
}
1992/0411    
 
static void 
xmemmove(void *to, void *from, long len)
1992/0424    
Chan* 
etherclone(Chan *c, Chan *nc)
1992/0411    
{ 
	ushort *t, *f; 
	int s; 
	Ctlr *cp = &ctlr[0]; 
	uchar reg;
1992/0424    
	return devclone(c, nc); 
}
1992/0411    
 
	t = to; 
	f = from; 
	len = (len+1)/2; 
	s = splhi(); 
	reg = inb(cp->iobase+0x05); 
	outb(cp->iobase+Imr, 0); 
	outb(cp->iobase+0x05, 0x80|reg); 
	while(len--) 
		*t++ = *f++; 
	outb(cp->iobase+0x05, reg); 
	outb(cp->iobase+Imr, 0x1F); 
	splx(s);
1992/0424    
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 
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);
1992/0411    
}
1992/0424    
long 
etherwrite(Chan *c, char *a, long n, ulong offset) 
{ 
	return streamwrite(c, a, n, 0); 
} 
 
void 
etherremove(Chan *c) 
{ 
	error(Eperm); 
} 
 
void 
etherwstat(Chan *c, char *dp) 
{ 
	netwstat(c, dp, &ctlr[0].net); 
}
1992/0407    
static int 
isxfree(void *arg)
1992/0424    
isobuf(void *arg)
1992/0407    
{ 
	Ctlr *cp = arg;
1992/0409    
	return cp->xbusy == 0;
1992/0424    
	cp->tb[cp->th].owner == Host;
1992/0407    
}
1992/0403    
static void
1992/0411/sys/src/9/pc/devether.c:182,190 – 1992/0424/sys/src/9/pc/devether.c:189,197
1992/0403    
	int len, n;
1992/0410    
	Type *tp;
1992/0403    
	Etherpkt *p;
1992/0424    
	Buffer *tb;
1992/0403    
	Block *nbp;
1992/0410    
	cp = ((Type *)q->ptr)->ctlr;
1992/0403    
	if(bp->type == M_CTL){
1992/0410    
		tp = q->ptr;
1992/0403    
		if(streamparse("connect", bp))
1992/0411/sys/src/9/pc/devether.c:191,206 – 1992/0424/sys/src/9/pc/devether.c:198,211
1992/0410    
			tp->type = strtol((char *)bp->rptr, 0, 0);
1992/0403    
		else if(streamparse("promiscuous", bp)) {
1992/0410    
			tp->prom = 1;
1992/0406    
			qlock(cp); 
			cp->prom++; 
			if(cp->prom == 1) 
				outb(cp->iobase+Rcr, 0x14);	/* PRO|AB */ 
			qunlock(cp);
1992/0424    
			(*tp->ctlr->hw->mode)(tp->ctlr, 1);
1992/0403    
		} 
		freeb(bp); 
		return; 
	}
1992/0424    
	cp = ((Type *)q->ptr)->ctlr;
1992/0403    
	/* 
	 * give packet a local address, return upstream if destined for 
	 * this machine.
1992/0411/sys/src/9/pc/devether.c:212,218 – 1992/0424/sys/src/9/pc/devether.c:217,223
1992/0406    
	if(memcmp(cp->ea, p->d, sizeof(cp->ea)) == 0){
1992/0403    
		len = blen(bp);
1992/0406    
		if (bp = expandb(bp, len >= ETHERMINTU ? len: ETHERMINTU)){ 
			putq(&cp->rq, bp);
1992/0424    
			putq(&cp->lbq, bp);
1992/0406    
			wakeup(&cp->rr);
1992/0403    
		} 
		return;
1992/0411/sys/src/9/pc/devether.c:222,228 – 1992/0424/sys/src/9/pc/devether.c:227,233
1992/0403    
		nbp = copyb(bp, len);
1992/0406    
		if(nbp = expandb(nbp, len >= ETHERMINTU ? len: ETHERMINTU)){
1992/0403    
			nbp->wptr = nbp->rptr+len;
1992/0406    
			putq(&cp->rq, nbp);
1992/0424    
			putq(&cp->lbq, nbp);
1992/0406    
			wakeup(&cp->rr);
1992/0403    
		} 
	}
1992/0411/sys/src/9/pc/devether.c:230,250 – 1992/0424/sys/src/9/pc/devether.c:235,257
1992/0403    
	/* 
	 * only one transmitter at a time 
	 */
1992/0407    
	qlock(&cp->xl);
1992/0424    
	qlock(&cp->tlock);
1992/0403    
	if(waserror()){
1992/0411    
		freeb(bp);
1992/0407    
		qunlock(&cp->xl);
1992/0424    
		qunlock(&cp->tlock);
1992/0403    
		nexterror(); 
	} 
 
	/*
1992/0407    
	 * Wait till we get an output buffer
1992/0424    
	 * wait till we get an output buffer. 
	 * should try to restart.
1992/0403    
	 */
1992/0411    
	tsleep(&cp->xr, isxfree, cp, 1000); 
	if(isxfree(cp) == 0) 
		print("Tx wedged\n"); 
	p = &txpkt;
1992/0424    
print("oput sleep\n"); 
	sleep(&cp->tr, isobuf, cp);
1992/0403    
1992/0424    
	tb = &cp->tb[cp->th]; 
	p = &tb->pkt;
1992/0403    
	/* 
	 * copy message into buffer 
	 */
1992/0411/sys/src/9/pc/devether.c:271,288 – 1992/0424/sys/src/9/pc/devether.c:278,297
1992/0407    
	 * give packet a local address
1992/0403    
	 */
1992/0407    
	memmove(p->s, cp->ea, sizeof(cp->ea));
1992/0411    
	xmemmove(cp->xpkt, p, len);
1992/0403    
 
	/*
1992/0424    
	 * set up the transmit buffer and
1992/0407    
	 * start the transmission
1992/0403    
	 */
1992/0407    
	outb(cp->iobase+Tbcr0, len & 0xFF); 
	outb(cp->iobase+Tbcr1, (len>>8) & 0xFF); 
	outb(cp->iobase+Cr, 0x26);			/* Page0|TXP|STA */ 
	cp->xbusy = 1;
1992/0424    
	cp->outpackets++; 
	tb->len = len; 
	tb->owner = Interface; 
	cp->th = NEXT(cp->th, cp->ntb); 
	(*cp->hw->transmit)(cp);
1992/0403    
 
	freeb(bp);
1992/0407    
	qunlock(&cp->xl);
1992/0424    
	qunlock(&cp->tlock); 
print("oput done\n");
1992/0403    
	poperror(); 
}
1992/0411/sys/src/9/pc/devether.c:320,332 – 1992/0424/sys/src/9/pc/devether.c:329,336
1992/0410    
	Type *tp;
1992/0403    
1992/0410    
	tp = (Type *)(q->ptr); 
	if(tp->prom){ 
		qlock(tp->ctlr); 
		tp->ctlr->prom--; 
		if(tp->ctlr->prom == 0) 
			outb(tp->ctlr->iobase+Rcr, 0x04);/* AB */ 
		qunlock(tp->ctlr);
1992/0403    
	}
1992/0424    
	if(tp->prom) 
		(*tp->ctlr->hw->mode)(tp->ctlr, 0);
1992/0410    
	qlock(tp); 
	tp->type = 0; 
	tp->q = 0;
1992/0411/sys/src/9/pc/devether.c:389,517 – 1992/0424/sys/src/9/pc/devether.c:393,404
1992/0403    
} 
 
static void 
intr(Ureg *ur)
1992/0424    
etherup(Ctlr *cp, Etherpkt *p, int len)
1992/0403    
{
1992/0404    
	Ctlr *cp = &ctlr[0];
1992/0410    
	uchar isr, bnry, curr;
1992/0404    
                 
	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);
1992/0410    
			cp->overflows += inb(cp->iobase+Cntr2);
1992/0404    
		} 
		if(isr & Ptx) 
			cp->outpackets++; 
		if(isr & (Txe|Ptx)){
1992/0407    
			cp->xbusy = 0; 
			wakeup(&cp->xr);
1992/0404    
		}
1992/0410    
		if(isr & Ovw){ 
			bnry = inb(cp->iobase+Bnry); 
			outb(cp->iobase+bnry, bnry); 
			cp->buffs++; 
		}
1992/0404    
		/* 
		 * we have received packets. 
		 * this is the only place, other than the init code, 
		 * where we set the controller to Page1.
1992/0405    
		 * we must be sure to reset it back to Page0 in case
1992/0404    
		 * we interrupted some other part of this driver. 
		 */
1992/0410    
		if(isr & (Rxe|Prx)){
1992/0404    
			outb(cp->iobase+Cr, 0x62);	/* Page1, RD2|STA */ 
			cp->curr = inb(cp->iobase+Curr); 
			outb(cp->iobase+Cr, 0x22);	/* Page0, RD2|STA */
1992/0410    
if(debug) 
    print("I%d/%d/%d|", isr, cp->curr, cp->bnry);
1992/0404    
			wakeup(&cp->rr); 
		} 
	}
1992/0403    
} 
                 
/* 
 * the following initialisation procedure
1992/0405    
 * is mandatory.
1992/0404    
 * we leave the chip idling on internal loopback
1992/0405    
 * and pointing to Page0.
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 */
1992/0410    
	cp->bnry = RINGbase;
1992/0408    
	outb(cp->iobase+Bnry, cp->bnry);
1992/0407    
	cp->ring = (Ring*)(KZERO|RAMbase);
1992/0410    
	outb(cp->iobase+Pstart, RINGbase); 
	outb(cp->iobase+Pstop, RINGsize);
1992/0404    
	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]);
1992/0408    
	cp->curr = cp->bnry+1; 
	outb(cp->iobase+Curr, cp->curr);
1992/0404    
                 
	outb(cp->iobase+Cr, 0x22);		/* Page0, RD2|STA */ 
	outb(cp->iobase+Tpsr, 0);
1992/0407    
	cp->xpkt = (Etherpkt*)(KZERO|RAMbase);
1992/0403    
} 
                 
void 
etherreset(void) 
{
1992/0404    
	Ctlr *cp = &ctlr[0];
1992/0403    
	int i;
1992/0411    
	uchar reg;
1992/0403    
                 
1992/0404    
	cp->iobase = IObase;
1992/0411    
	reg = 0x40|inb(cp->iobase); 
	outb(cp->iobase, reg); 
	reg = 0x40|inb(cp->iobase+0x05); 
	outb(cp->iobase+0x05, reg);
1992/0409    
for(i = 0; i < 0x10; i++) 
    print("#%2.2ux ", inb(cp->iobase+i)); 
print("\n");
1992/0404    
	for(i = 0; i < sizeof(cp->ea); i++) 
		cp->ea[i] = inb(cp->iobase+EA+i);
1992/0408    
	init(cp); 
	setvec(Ethervec, intr);
1992/0404    
	memset(cp->ba, 0xFF, sizeof(cp->ba));
1992/0403    
                 
1992/0404    
	cp->net.name = "ether";
1992/0410    
	cp->net.nconv = NType;
1992/0404    
	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
1992/0410    
etherup(Ctlr *cp, uchar *d0, int len0, uchar *d1, int len1)
1992/0404    
{
1992/0410    
	Etherpkt *p;
1992/0404    
	Block *bp;
1992/0410    
	Type *tp;
1992/0404    
	int t;
1992/0410    
	p = (Etherpkt*)d0; 
	t = (p->type[0]<<8)|p->type[1]; 
	for(tp = &cp->type[0]; tp < &cp->type[NType]; tp++){
1992/0404    
		/*
1992/0411/sys/src/9/pc/devether.c:537,547 – 1992/0424/sys/src/9/pc/devether.c:424,432
1992/0404    
			continue; 
		} 
		if(waserror() == 0){
1992/0410    
			bp = allocb(len0+len1);
1992/0411    
			xmemmove(bp->rptr, d0, len0);
1992/0410    
			if(len1)
1992/0411    
				xmemmove(bp->rptr+len0, d1, len1);
1992/0410    
			bp->wptr += len0+len1;
1992/0424    
			bp = allocb(len); 
			memmove(bp->rptr, p, len); 
			bp->wptr += len;
1992/0404    
			bp->flags |= S_DELIM;
1992/0410    
			PUTNEXT(tp->q, bp);
1992/0404    
		}
1992/0411/sys/src/9/pc/devether.c:550,573 – 1992/0424/sys/src/9/pc/devether.c:435,446
1992/0404    
	} 
}
1992/0406    
static void 
printpkt(uchar bnry, ushort len, Etherpkt *p) 
{ 
	int i; 
                 
	print("%.2ux: %.4d d(%.2ux%.2ux%.2ux%.2ux%.2ux%.2ux)s(%.2ux%.2ux%.2ux%.2ux%.2ux%.2ux)t(%.2ux %.2ux)\n", 
		bnry, len, 
		p->d[0], p->d[1], p->d[2], p->d[3], p->d[4], p->d[5], 
		p->s[0], p->s[1], p->s[2], p->s[3], p->s[4], p->s[5], 
		p->type[0], p->type[1]); 
} 
                 
1992/0403    
static int 
isinput(void *arg) 
{
1992/0404    
	Ctlr *cp = arg;
1992/0403    
1992/0410    
	return NEXT(cp->bnry, RINGsize) != cp->curr;
1992/0424    
	return cp->lbq.first || cp->rb[cp->ri].owner == Host;
1992/0403    
} 
 
static void
1992/0411/sys/src/9/pc/devether.c:574,599 – 1992/0424/sys/src/9/pc/devether.c:447,471
1992/0403    
etherkproc(void *arg) 
{
1992/0404    
	Ctlr *cp = arg;
1992/0424    
	Buffer *rb;
1992/0404    
	Block *bp; 
	uchar bnry, curr; 
	Ring *rp;
1992/0410    
	int len0, len1;
1992/0403    
 
	if(waserror()){
1992/0404    
		print("%s noted\n", cp->name); 
		init(cp);
1992/0424    
		(*cp->hw->init)(cp);
1992/0404    
		cp->kproc = 0;
1992/0403    
		nexterror(); 
	}
1992/0404    
	cp->kproc = 1;
1992/0403    
	for(;;){
1992/0404    
		sleep(&cp->rr, isinput, cp);
1992/0424    
		qlock(&cp->rlock);
1992/0406    
		/* 
		 * process any internal loopback packets 
		 */
1992/0404    
		while(bp = getq(&cp->rq)){
1992/0424    
		while(bp = getq(&cp->lbq)){
1992/0404    
			cp->inpackets++;
1992/0410    
			etherup(cp, bp->rptr, BLEN(bp), 0, 0);
1992/0424    
			etherup(cp, (Etherpkt*)bp->rptr, BLEN(bp));
1992/0404    
			freeb(bp); 
		}
1992/0408    
1992/0411/sys/src/9/pc/devether.c:600,730 – 1992/0424/sys/src/9/pc/devether.c:472,823
1992/0406    
		/* 
		 * process any received packets 
		 */
1992/0410    
		bnry = NEXT(cp->bnry, RINGsize);
1992/0408    
		while(bnry != cp->curr){ 
			rp = &cp->ring[bnry];
1992/0424    
		while(cp->rb[cp->rh].owner == Host){
1992/0406    
			cp->inpackets++;
1992/0410    
			len0 = ((rp->len1<<8)+rp->len0)-4; 
			len1 = 0;
1992/0424    
			rb = &cp->rb[cp->rh]; 
			etherup(cp, &rb->pkt, rb->len); 
			rb->owner = Interface; 
			cp->rh = NEXT(cp->rh, Nrb); 
		}
1992/0410    
 
			if(rp->data+len0 >= (uchar*)&cp->ring[RINGsize]){ 
				len1 = rp->data+len0 - (uchar*)&cp->ring[RINGsize]; 
				len0 = (uchar*)&cp->ring[RINGsize] - rp->data; 
			}
1992/0424    
		qunlock(&cp->rlock); 
		sleep(&cp->rr, isinput, cp); 
	} 
}
1992/0410    
 
			etherup(cp, rp->data, len0, (uchar*)&cp->ring[RINGbase], len1);
1992/0424    
void 
etherreset(void) 
{ 
	Ctlr *cp = &ctlr[0];
1992/0410    
1992/0424    
	cp->hw = &wd8013; 
	(*cp->hw->reset)(cp);
1992/0410    
1992/0424    
	memset(cp->ba, 0xFF, sizeof(cp->ba));
1992/0410    
 
if(debug) 
    print("K%d/%d/%d|", bnry, rp->next, PREV(rp->next, RINGsize));
1992/0408    
			bnry = rp->next;
1992/0410    
			cp->bnry = PREV(bnry, RINGsize);
1992/0407    
			outb(cp->iobase+Bnry, cp->bnry);
1992/0406    
		}
1992/0403    
	}
1992/0424    
	cp->net.name = "ether"; 
	cp->net.nconv = NType; 
	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    
} 
 
void 
etherinit(void)
1992/0424    
Chan* 
etherattach(char *spec)
1992/0403    
{ 
	int ctlrno = 0;
1992/0424    
	Ctlr *cp = &ctlr[ctlrno]; 
	int i;
1992/0403    
1992/0424    
	cp->rh = 0; 
	cp->ri = 0; 
	for(i = 0; i < cp->nrb; i++) 
		cp->rb[i].owner = Interface; 
 
	cp->th = 0; 
	cp->ti = 0; 
	for(i = 0; i < cp->ntb; i++) 
		cp->tb[i].owner = Host;
1992/0403    
	/* 
	 * 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]);
1992/0424    
	 
	(*cp->hw->online)(cp, 1); 
	if(cp->kproc == 0){ 
		sprint(cp->name, "ether%dkproc", ctlrno); 
		kproc(cp->name, etherkproc, cp);
1992/0403    
	} 
} 
                 
Chan * 
etherattach(char *spec) 
{ 
	return devattach('l', spec); 
} 
 
Chan * 
etherclone(Chan *c, Chan *nc) 
{ 
	return devclone(c, nc); 
}
1992/0424    
typedef struct { 
	uchar	msr;			/* 83C584 bus interface */ 
	uchar	icr; 
	uchar	iar; 
	uchar	bio; 
	uchar	irr; 
	uchar	laar; 
	uchar	ijr; 
	uchar	gp2; 
	uchar	lan[6]; 
	uchar	id; 
	uchar	cksum;
1992/0403    
 
int 
etherwalk(Chan *c, char *name) 
{ 
	return netwalk(c, name, &ctlr[0].net); 
}
1992/0424    
	union {				/* DP8390/83C690 LAN controller */ 
		struct {			/* Page0, read */ 
			uchar	cr; 
			uchar	clda0; 
			uchar	clda1; 
			uchar	bnry; 
			uchar	tsr; 
			uchar	ncr; 
			uchar	fifo; 
			uchar	isr; 
			uchar	crda0; 
			uchar	crda1; 
			uchar	pad0x0A; 
			uchar	pad0x0B; 
			uchar	rsr; 
			uchar	cntr0; 
			uchar	cntr1; 
			uchar	cntr2; 
		} r; 
		struct {			/* Page0, write */ 
			uchar	cr; 
			uchar	pstart; 
			uchar	pstop; 
			uchar	bnry; 
			uchar	tpsr; 
			uchar	tbcr0; 
			uchar	tbcr1; 
			uchar	isr; 
			uchar	rsar0; 
			uchar	rsar1; 
			uchar	rbcr0; 
			uchar	rbcr1; 
			uchar	rcr; 
			uchar	tcr; 
			uchar	dcr; 
			uchar	imr; 
		} w; 
		struct {			/* Page1, read/write */ 
			uchar	cr; 
			uchar	par[6]; 
			uchar	curr; 
			uchar	mar[8]; 
		}; 
	}; 
} Wd8013;
1992/0403    
 
void 
etherstat(Chan *c, char *dp)
1992/0424    
#define IN(hw, m)	inb((hw)->addr+OFFSETOF(Wd8013, m)) 
#define OUT(hw, m, x)	outb((hw)->addr+OFFSETOF(Wd8013, m), (x)) 
 
/* 
 */ 
static void 
wd8013reset(Ctlr *cp)
1992/0403    
{ 
	netstat(c, dp, &ctlr[0].net); 
}
1992/0424    
	Hw *hw = cp->hw; 
	int i; 
	uchar msr;
1992/0403    
 
Chan * 
etheropen(Chan *c, int omode)
1992/0424    
print("reset\n"); 
	cp->rb = ialloc(sizeof(Buffer)*Nrb, 0); 
	cp->nrb = Nrb; 
	cp->tb = ialloc(sizeof(Buffer)*Ntb, 0); 
	cp->ntb = Ntb; 
 
	msr = IN(hw, msr); 
	OUT(hw, msr, 0x40|msr);
1992/0403    
{ 
	return netopen(c, omode, &ctlr[0].net);
1992/0424    
int addr = hw->addr; 
 
for(i = 0; i < 16; i++){ 
    print("#%2.2ux ", inb(addr)); 
    addr++;
1992/0403    
}
1992/0424    
print("\n"); 
} 
	for(i = 0; i < sizeof(cp->ea); i++) 
		cp->ea[i] = IN(hw, lan[i]); 
	(*hw->init)(cp); 
	setvec(Ethervec, hw->intr); 
}
1992/0403    
 
void 
ethercreate(Chan *c, char *name, int omode, ulong perm)
1992/0424    
/* 
 * we leave the chip idling on internal loopback 
 * and pointing to Page0. 
 */ 
static void 
wd8013init(Ctlr *cp)
1992/0403    
{ 
	error(Eperm);
1992/0424    
	Hw *hw = cp->hw; 
	int i; 
	uchar bnry; 
 
print("init %d %d\n", HOWMANY(sizeof(Etherpkt), 256), HOWMANY(hw->ramsz, 256)); 
	OUT(hw, w.cr, 0x21);			/* Page0|RD2|STP */ 
	OUT(hw, w.dcr, 0x48);			/* FT1|LS */ 
	OUT(hw, w.rbcr0, 0); 
	OUT(hw, w.rbcr1, 0); 
	OUT(hw, w.rcr, 0x04);			/* AB */ 
	OUT(hw, w.tcr, 0x20);			/* LB0 */ 
 
	bnry = HOWMANY(sizeof(Etherpkt), 256); 
	OUT(hw, w.bnry, bnry); 
	OUT(hw, w.pstart, bnry); 
	OUT(hw, w.pstop, HOWMANY(hw->ramsz, 256)); 
	OUT(hw, w.isr, 0xFF); 
	OUT(hw, w.imr, 0x1F);			/* OVWE|TXEE|RXEE|PTXE|PRXE */ 
 
	OUT(hw, w.cr, 0x61);			/* Page1|RD2|STP */ 
	for(i = 0; i < sizeof(cp->ea); i++) 
		OUT(hw, par[i], cp->ea[i]); 
	OUT(hw, curr, bnry+1); 
 
	OUT(hw, w.cr, 0x22);			/* Page0|RD2|STA */ 
	OUT(hw, w.tpsr, 0);
1992/0403    
} 
 
void 
etherremove(Chan *c)
1992/0424    
wd8013mode(Ctlr *cp, int on)
1992/0403    
{ 
	error(Eperm);
1992/0424    
	qlock(cp); 
	if(on){ 
		cp->prom++; 
		if(cp->prom == 1) 
			OUT(cp->hw, w.rcr, 0x14);/* PRO|AB */ 
	} 
	else { 
		cp->prom--; 
		if(cp->prom == 0) 
			OUT(cp->hw, w.rcr, 0x04);/* AB */ 
	} 
	qunlock(cp);
1992/0403    
} 
 
void 
etherwstat(Chan *c, char *dp)
1992/0424    
static void 
wd8013online(Ctlr *cp, int on)
1992/0403    
{ 
	netwstat(c, dp, &ctlr[0].net);
1992/0424    
	OUT(cp->hw, w.tcr, 0);
1992/0403    
} 
 
void 
etherclose(Chan *c)
1992/0424    
static void 
wd8013receive(Ctlr *cp)
1992/0403    
{ 
	if(c->stream) 
		streamclose(c);
1992/0424    
	Hw *hw = cp->hw; 
	Buffer *rb; 
	uchar bnry, curr, next; 
	typedef struct Ring { 
		uchar	status; 
		uchar	next; 
		uchar	len0; 
		uchar	len1; 
		uchar	data[256-4]; 
	} Ring; 
	Ring *p; 
	int len; 
 
	bnry = IN(hw, r.bnry); 
	next = NEXT(bnry, HOWMANY(hw->ramsz, 256)); 
	if(next == 0) 
		next = HOWMANY(sizeof(Etherpkt), 256); 
	for(;;){ 
		OUT(hw, w.cr, 0x62);		/* Page1|RD2|STA */ 
		curr = IN(hw, curr); 
		OUT(hw, w.cr, 0x22);		/* Page0|RD2|STA */ 
		if(next == curr) 
			break; 
		cp->inpackets++; 
		p = &((Ring*)hw->ram)[next]; 
		len = (p->len1<<8)|p->len0; 
 
		rb = &cp->rb[cp->ri]; 
		if(rb->owner == Interface){ 
			rb->len = len; 
			/*copy in packet*/ 
			rb->owner = Host; 
			cp->ri = NEXT(cp->ri, Nrb); 
		} 
 
		next = p->next; 
		bnry = next-1; 
		if(bnry < HOWMANY(sizeof(Etherpkt), 256)) 
			bnry = HOWMANY(hw->ramsz, 256)-1; 
		OUT(hw, w.bnry, bnry); 
	}
1992/0403    
} 
 
long 
etherread(Chan *c, void *a, long n, ulong offset)
1992/0424    
static void 
wd8013transmit(Ctlr *cp)
1992/0403    
{ 
	return netread(c, a, n, offset, &ctlr[0].net);
1992/0424    
	Hw *hw; 
	Buffer *tb; 
	int s; 
 
print("transmit\n"); 
	s = splhi(); 
	tb = &cp->tb[cp->ti]; 
	if(tb->busy == 0 && tb->owner == Interface){ 
		hw = cp->hw; 
print("transmit memove %lux %lux, %d\n", hw->ram, &tb->pkt, tb->len); 
		memmove(hw->ram, &tb->pkt, tb->len); 
		OUT(hw, w.tbcr0, tb->len & 0xFF); 
		OUT(hw, w.tbcr1, (tb->len>>8) & 0xFF); 
		OUT(hw, w.cr, 0x26);		/* Page0|RD2|TXP|STA */ 
		tb->busy = 1; 
	} 
	splx(s); 
print("transmit done\n");
1992/0403    
} 
 
long 
etherwrite(Chan *c, char *a, long n, ulong offset)
1992/0424    
static void 
wd8013intr(Ureg *ur)
1992/0403    
{ 
	return streamwrite(c, a, n, 0);
1992/0424    
	Ctlr *cp = &ctlr[0]; 
	Hw *hw = cp->hw; 
	Buffer *tb; 
	uchar isr; 
 
	while(isr = IN(hw, r.isr)){ 
		OUT(hw, w.isr, isr); 
		if(isr & 0x08)			/* Txe - transmit error */ 
			cp->oerrs++; 
		if(isr & 0x04){			/* Rxe - receive error */ 
			cp->frames += IN(hw, r.cntr0); 
			cp->crcs += IN(hw, r.cntr1); 
			cp->buffs += IN(hw, r.cntr2); 
		} 
		if(isr & 0x02)			/* Ptx - packet transmitted */ 
			cp->outpackets++; 
		/* 
		 * a packet completed transmission, successfully or 
		 * not. start transmission on the next buffered packet, 
		 * and wake the output routine. 
		 */ 
		if(isr & (0x08|0x02)){ 
			tb = &cp->tb[cp->ti]; 
			tb->owner = Host; 
			tb->busy = 0; 
			cp->ti = NEXT(cp->ti, Ntb); 
			(*cp->hw->transmit)(cp); 
			wakeup(&cp->tr); 
		} 
		if(isr & 0x10)			/* Ovw - overwrite warning */ 
			cp->overflows++; 
		/* 
		 * we have received packets. 
		 */ 
		if(isr & (0x04|0x01)){		/* Rxe|Prx - packet received */ 
			(*cp->hw->receive)(cp); 
			wakeup(&cp->rr); 
		} 
	}
1992/0409    
}
1992/0424    
static Hw wd8013 = { 
	0x360,					/* I/O base address */ 
	KZERO|0xC8000,				/* shared memory address */ 
	8*1024,					/* shared memory size */ 
	wd8013reset, 
	wd8013init, 
	wd8013mode, 
	wd8013online, 
	wd8013receive, 
	wd8013transmit, 
	wd8013intr, 
};
1992/0409    
void
1992/0411    
consdebug(void)
1992/0409    
{ 
	Ctlr *cp = &ctlr[0]; 
	uchar bnry, curr, isr; 
	int s; 
                 
	s = splhi();
1992/0410    
debug++;
1992/0409    
	bnry = inb(cp->iobase+Bnry); 
	outb(cp->iobase+Cr, 0x62);			/* Page1, RD2|STA */ 
	curr = inb(cp->iobase+Curr); 
	outb(cp->iobase+Cr, 0x22);			/* Page0, RD2|STA */ 
	isr = inb(cp->iobase+Isr); 
	print("b%d c%d x%d B%d C%d I%ux", 
	    cp->bnry, cp->curr, cp->xbusy, bnry, curr, isr);
1992/0410    
	print("\t%d %d %d %d %d %d %d\n", cp->inpackets, cp->outpackets,
1992/0409    
	    cp->crcs, cp->oerrs, cp->frames, cp->overflows, cp->buffs); 
	splx(s);
1992/0403    
}


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