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

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

1992/1015/sys/src/9/pc/devether.c:7,121992/1222/sys/src/9/pc/devether.c:7,14 (short | long | prev | next)
1992/0403    
#include "io.h" 
#include "devtab.h" 
 
1992/1222    
#include "ether.h" 
 
1992/0922    
/* 
 * Half-arsed attempt at a general top-level 
 * ethernet driver. Needs work: 
1992/1015/sys/src/9/pc/devether.c:14,481992/1222/sys/src/9/pc/devether.c:16,50
1992/0922    
 *	much tidying 
 *	set ethernet address 
 */ 
extern EtherHw ether509; 
extern EtherHw ether80x3; 
1992/1222    
extern Board ether8003; 
extern Board ether503; 
extern Board ether2000; 
extern Board ether509; 
1992/0403    
 
1992/0922    
static EtherHw *etherhw[] = { 
1992/1222    
/* 
 * The ordering here is important for those boards 
 * using the DP8390 (WD8003, 3COM503 and NE2000) as 
 * attempting to determine if a board is a NE2000 
 * cannot be done passively, so it must be last to 
 * prevent scrogging one of the others. 
 */ 
static Board *boards[] = { 
	ðer8003, 
	ðer503, 
	ðer2000, 
 
1992/0922    
	ðer509, 
	ðer80x3, 
	0 
1992/0404    
}; 
 
enum { 
1992/0922    
	Nctlr		= 1, 
1992/1222    
	NCtlr		= 1, 
1992/0424    
}; 
1992/0403    
 
1992/0922    
static struct EtherCtlr ctlr[Nctlr]; 
1992/1222    
static struct Ctlr *softctlr[NCtlr]; 
static int nctlr; 
1992/0922    
 
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    
                 
1992/0425    
Chan* 
etherattach(char *spec) 
1992/0424    
{ 
1992/0917    
	if(ctlr[0].present == 0) 
		error(Enodev); 
1992/0425    
	return devattach('l', spec); 
1992/0424    
} 
1992/0411    
                 
1992/0424    
Chan* 
etherclone(Chan *c, Chan *nc) 
1992/0411    
{ 
1992/0424    
	return devclone(c, nc); 
1992/1015/sys/src/9/pc/devether.c:51,691992/1222/sys/src/9/pc/devether.c:53,71
1992/0424    
int 
etherwalk(Chan *c, char *name) 
{ 
	return netwalk(c, name, &ctlr[0].net); 
1992/1222    
	return netwalk(c, name, &softctlr[0]->net); 
1992/0424    
} 
 
void 
etherstat(Chan *c, char *dp) 
{ 
	netstat(c, dp, &ctlr[0].net); 
1992/1222    
	netstat(c, dp, &softctlr[0]->net); 
1992/0424    
} 
 
Chan* 
etheropen(Chan *c, int omode) 
{ 
	return netopen(c, omode, &ctlr[0].net); 
1992/1222    
	return netopen(c, omode, &softctlr[0]->net); 
1992/0424    
} 
 
void 
1992/1015/sys/src/9/pc/devether.c:83,891992/1222/sys/src/9/pc/devether.c:85,91
1992/0424    
long 
etherread(Chan *c, void *a, long n, ulong offset) 
{ 
	return netread(c, a, n, offset, &ctlr[0].net); 
1992/1222    
	return netread(c, a, n, offset, &softctlr[0]->net); 
1992/0411    
} 
 
1992/0424    
long 
1992/1015/sys/src/9/pc/devether.c:103,2681992/1222/sys/src/9/pc/devether.c:105,297
1992/0424    
void 
etherwstat(Chan *c, char *dp) 
{ 
	netwstat(c, dp, &ctlr[0].net); 
1992/1222    
	netwstat(c, dp, &softctlr[0]->net); 
1992/0424    
} 
 
1992/0407    
static int 
1992/0424    
isobuf(void *arg) 
1992/0407    
{ 
1992/0922    
	EtherCtlr *cp = arg; 
1992/1222    
	Ctlr *ctlr = arg; 
1992/0407    
 
1992/0425    
	return cp->tb[cp->th].owner == Host; 
1992/1222    
	return ctlr->tb[ctlr->th].owner == Host; 
1992/0407    
} 
 
1992/0403    
static void 
etheroput(Queue *q, Block *bp) 
{ 
1992/0922    
	EtherCtlr *cp; 
	EtherType *tp; 
1992/0403    
	Etherpkt *p; 
1992/0922    
	EtherBuf *tb; 
1992/1222    
	Ctlr *ctlr; 
	Type *type; 
	Etherpkt *pkt; 
	RingBuf *ring; 
1992/0922    
	int len, n; 
1992/0403    
	Block *nbp; 
 
1992/1222    
	type = q->ptr; 
	ctlr = type->ctlr; 
1992/0403    
	if(bp->type == M_CTL){ 
1992/0410    
		tp = q->ptr; 
1992/0403    
		if(streamparse("connect", bp)) 
1992/0922    
			tp->type = strtol((char*)bp->rptr, 0, 0); 
1992/1222    
		qlock(ctlr); 
		if(streamparse("connect", bp)){ 
			if(type->type == -1) 
				ctlr->all--; 
			type->type = strtol((char*)bp->rptr, 0, 0); 
			if(type->type == -1) 
				ctlr->all++; 
		} 
1992/0403    
		else if(streamparse("promiscuous", bp)) { 
1992/0410    
			tp->prom = 1; 
1992/0424    
			(*tp->ctlr->hw->mode)(tp->ctlr, 1); 
1992/1222    
			type->prom = 1; 
			ctlr->prom++; 
			if(ctlr->prom == 1) 
				(*ctlr->board->mode)(ctlr, 1); 
1992/0403    
		} 
1992/1222    
		qunlock(ctlr); 
1992/0403    
		freeb(bp); 
		return; 
	} 
 
1992/0922    
	cp = ((EtherType*)q->ptr)->ctlr; 
1992/0424    
                 
1992/0403    
	/* 
	 * give packet a local address, return upstream if destined for 
1992/1222    
	 * Give packet a local address, return upstream if destined for 
1992/0403    
	 * this machine. 
	 */ 
1992/0406    
	if(BLEN(bp) < ETHERHDRSIZE && (bp = pullup(bp, ETHERHDRSIZE)) == 0) 
		return; 
1992/0922    
	p = (Etherpkt*)bp->rptr; 
1992/0406    
	memmove(p->s, cp->ea, sizeof(cp->ea)); 
	if(memcmp(cp->ea, p->d, sizeof(cp->ea)) == 0){ 
1992/1222    
	pkt = (Etherpkt*)bp->rptr; 
	memmove(pkt->s, ctlr->ea, sizeof(ctlr->ea)); 
	if(memcmp(ctlr->ea, pkt->d, sizeof(ctlr->ea)) == 0){ 
1992/0403    
		len = blen(bp); 
1992/0406    
		if (bp = expandb(bp, len >= ETHERMINTU ? len: ETHERMINTU)){ 
1992/0424    
			putq(&cp->lbq, bp); 
1992/0406    
			wakeup(&cp->rr); 
1992/1222    
		if(bp = expandb(bp, len >= ETHERMINTU ? len: ETHERMINTU)){ 
			putq(&ctlr->lbq, bp); 
			wakeup(&ctlr->rr); 
1992/0403    
		} 
		return; 
	} 
1992/0406    
	if(memcmp(cp->ba, p->d, sizeof(cp->ba)) == 0){ 
1992/1222    
	if(memcmp(ctlr->ba, pkt->d, sizeof(ctlr->ba)) == 0 || ctlr->prom || ctlr->all){ 
1992/0403    
		len = blen(bp); 
		nbp = copyb(bp, len); 
1992/0406    
		if(nbp = expandb(nbp, len >= ETHERMINTU ? len: ETHERMINTU)){ 
1992/0403    
			nbp->wptr = nbp->rptr+len; 
1992/0424    
			putq(&cp->lbq, nbp); 
1992/0406    
			wakeup(&cp->rr); 
1992/1222    
			putq(&ctlr->lbq, nbp); 
			wakeup(&ctlr->rr); 
1992/0403    
		} 
	} 
 
	/* 
	 * only one transmitter at a time 
1992/1222    
	 * Only one transmitter at a time. 
1992/0403    
	 */ 
1992/0424    
	qlock(&cp->tlock); 
1992/1222    
	qlock(&ctlr->tlock); 
1992/0403    
	if(waserror()){ 
1992/0411    
		freeb(bp); 
1992/0424    
		qunlock(&cp->tlock); 
1992/1222    
		qunlock(&ctlr->tlock); 
1992/0403    
		nexterror(); 
	} 
 
	/* 
1992/0424    
	 * wait till we get an output buffer. 
1992/1222    
	 * Wait till we get an output buffer. 
1992/0424    
	 * should try to restart. 
1992/0403    
	 */ 
1992/0424    
	sleep(&cp->tr, isobuf, cp); 
1992/1222    
	sleep(&ctlr->tr, isobuf, ctlr); 
1992/0403    
 
1992/0424    
	tb = &cp->tb[cp->th]; 
1992/1222    
	ring = &ctlr->tb[ctlr->th]; 
1992/0424    
 
1992/0403    
	/* 
	 * copy message into buffer 
1992/1222    
	 * Copy message into buffer. 
1992/0403    
	 */ 
	len = 0; 
	for(nbp = bp; nbp; nbp = nbp->next){ 
		if(sizeof(Etherpkt) - len >= (n = BLEN(nbp))){ 
1992/0501    
			memmove(tb->pkt+len, nbp->rptr, n); 
1992/1222    
			memmove(ring->pkt+len, nbp->rptr, n); 
1992/0403    
			len += n; 
		} else 
			print("no room damn it\n"); 
1992/1222    
		} 
1992/0403    
		if(bp->flags & S_DELIM) 
			break; 
	} 
 
	/* 
1992/0407    
	 * pad the packet (zero the pad) 
1992/1222    
	 * Pad the packet (zero the pad). 
1992/0403    
	 */ 
	if(len < ETHERMINTU){ 
1992/0501    
		memset(tb->pkt+len, 0, ETHERMINTU-len); 
1992/1222    
		memset(ring->pkt+len, 0, ETHERMINTU-len); 
1992/0403    
		len = ETHERMINTU; 
	} 
 
	/* 
1992/0424    
	 * set up the transmit buffer and  
1992/0407    
	 * start the transmission 
1992/1222    
	 * Set up the transmit buffer and  
	 * start the transmission. 
1992/0403    
	 */ 
1992/0424    
	cp->outpackets++; 
	tb->len = len; 
	tb->owner = Interface; 
	cp->th = NEXT(cp->th, cp->ntb); 
	(*cp->hw->transmit)(cp); 
1992/1222    
	ctlr->outpackets++; 
	ring->len = len; 
	ring->owner = Interface; 
	ctlr->th = NEXT(ctlr->th, ctlr->ntb); 
	(*ctlr->board->transmit)(ctlr); 
1992/0403    
 
	freeb(bp); 
1992/0424    
	qunlock(&cp->tlock); 
1992/1222    
	qunlock(&ctlr->tlock); 
1992/0403    
	poperror(); 
} 
 
/* 
 * open an ether line discipline 
 * 
 * the lock is to synchronize changing the ethertype with 
 * sending packets up the stream on interrupts. 
1992/1222    
 * Open an ether line discipline. 
1992/0403    
 */ 
static void 
etherstopen(Queue *q, Stream *s) 
{ 
1992/0922    
	EtherCtlr *cp = &ctlr[0]; 
	EtherType *tp; 
1992/1222    
	Ctlr *ctlr = softctlr[0]; 
	Type *type; 
1992/0403    
 
1992/0410    
	tp = &cp->type[s->id]; 
	qlock(tp); 
	RD(q)->ptr = WR(q)->ptr = tp; 
	tp->type = 0; 
	tp->q = RD(q); 
	tp->inuse = 1; 
	tp->ctlr = cp; 
	qunlock(tp); 
1992/1222    
	type = &ctlr->type[s->id]; 
	RD(q)->ptr = WR(q)->ptr = type; 
	type->type = 0; 
	type->q = RD(q); 
	type->inuse = 1; 
	type->ctlr = ctlr; 
1992/0403    
} 
 
/* 
 *  close ether line discipline 
1992/1222    
 * Close ether line discipline. 
1992/0403    
 * 
 *  the lock is to synchronize changing the ethertype with 
 *  sending packets up the stream on interrupts. 
1992/1222    
 * The locking is to synchronize changing the ethertype with 
 * sending packets up the stream on interrupts. 
1992/0403    
 */ 
1992/1222    
static int 
isclosed(void *arg) 
{ 
	return ((Type*)arg)->q == 0; 
} 
 
1992/0403    
static void 
etherstclose(Queue *q) 
{ 
1992/0922    
	EtherType *tp; 
1992/1222    
	Type *type = (Type*)(q->ptr); 
	Ctlr *ctlr = type->ctlr; 
1992/0403    
 
1992/0922    
	tp = (EtherType*)(q->ptr); 
1992/0424    
	if(tp->prom) 
		(*tp->ctlr->hw->mode)(tp->ctlr, 0); 
1992/0410    
	qlock(tp); 
	tp->type = 0; 
	tp->q = 0; 
	tp->prom = 0; 
	tp->inuse = 0; 
1992/0625    
	netdisown(tp); 
1992/0505    
	tp->ctlr = 0; 
1992/0410    
	qunlock(tp); 
1992/1222    
	if(type->prom){ 
		qlock(ctlr); 
		ctlr->prom--; 
		if(ctlr->prom == 0) 
			(*ctlr->board->mode)(ctlr, 0); 
		qunlock(ctlr); 
	} 
	if(type->type == -1){ 
		qlock(ctlr); 
		ctlr->all--; 
		qunlock(ctlr); 
	} 
 
	/* 
	 * Mark as closing and wait for kproc 
	 * to close us. 
	 */ 
	lock(&ctlr->clock); 
	type->clist = ctlr->clist; 
	ctlr->clist = type; 
	unlock(&ctlr->clock); 
	wakeup(&ctlr->rr); 
	sleep(&type->cr, isclosed, type); 
 
	type->type = 0; 
	type->prom = 0; 
	type->inuse = 0; 
	netdisown(type); 
	type->ctlr = 0; 
1992/0403    
} 
 
static Qinfo info = { 
1992/1015/sys/src/9/pc/devether.c:276,2951992/1222/sys/src/9/pc/devether.c:305,324
1992/0403    
static int 
1992/0404    
clonecon(Chan *c) 
1992/0403    
{ 
1992/0922    
	EtherCtlr *cp = &ctlr[0]; 
	EtherType *tp; 
1992/1222    
	Ctlr *ctlr = softctlr[0]; 
	Type *type; 
1992/0403    
 
1992/0711    
	USED(c); 
1992/0410    
	for(tp = cp->type; tp < &cp->type[NType]; tp++){ 
		qlock(tp); 
		if(tp->inuse || tp->q){ 
			qunlock(tp); 
1992/1222    
	for(type = ctlr->type; type < &ctlr->type[NType]; type++){ 
		qlock(type); 
		if(type->inuse || type->q){ 
			qunlock(type); 
1992/0403    
			continue; 
		} 
1992/0410    
		tp->inuse = 1; 
1992/0625    
		netown(tp, u->p->user, 0); 
1992/0410    
		qunlock(tp); 
		return tp - cp->type; 
1992/1222    
		type->inuse = 1; 
		netown(type, u->p->user, 0); 
		qunlock(type); 
		return type - ctlr->type; 
1992/0403    
	} 
	exhausted("ether channels"); 
1992/0711    
	return 0; 
1992/1015/sys/src/9/pc/devether.c:298,3111992/1222/sys/src/9/pc/devether.c:327,341
1992/0403    
static void 
1992/0404    
statsfill(Chan *c, char *p, int n) 
1992/0403    
{ 
1992/0922    
	EtherCtlr *cp = &ctlr[0]; 
1992/1222    
	Ctlr *ctlr = softctlr[0]; 
1992/0403    
	char buf[256]; 
 
1992/0711    
	USED(c); 
1992/0403    
	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/1222    
		ctlr->inpackets, ctlr->outpackets, ctlr->crcs, 
		ctlr->overflows, ctlr->frames, ctlr->buffs, ctlr->oerrs, 
		ctlr->ea[0], ctlr->ea[1], ctlr->ea[2], 
		ctlr->ea[3], ctlr->ea[4], ctlr->ea[5]); 
1992/0403    
	strncpy(p, buf, n); 
} 
 
1992/1015/sys/src/9/pc/devether.c:313,3671992/1222/sys/src/9/pc/devether.c:343,390
1992/0403    
typefill(Chan *c, char *p, int n) 
{ 
	char buf[16]; 
1992/0922    
	EtherType *tp; 
1992/1222    
	Type *type; 
1992/0403    
 
1992/0410    
	tp = &ctlr[0].type[STREAMID(c->qid.path)]; 
	sprint(buf, "%d", tp->type); 
1992/1222    
	type = &softctlr[0]->type[STREAMID(c->qid.path)]; 
	sprint(buf, "%d", type->type); 
1992/0403    
	strncpy(p, buf, n); 
} 
 
static void 
1992/0922    
etherup(EtherCtlr *cp, void *data, int len) 
1992/1222    
etherup(Ctlr *ctlr, Etherpkt *pkt, int len) 
1992/0403    
{ 
1992/0501    
	Etherpkt *p; 
1992/0404    
	int t; 
1992/0922    
	EtherType *tp; 
1992/1222    
	Type *type; 
1992/0501    
	Block *bp; 
1992/0404    
 
1992/0501    
	p = data; 
1992/0410    
	t = (p->type[0]<<8)|p->type[1]; 
	for(tp = &cp->type[0]; tp < &cp->type[NType]; tp++){ 
1992/0404    
		/* 
		 *  check before locking just to save a lock 
		 */ 
1992/0410    
		if(tp->q == 0 || (t != tp->type && tp->type != -1)) 
1992/0404    
			continue; 
1992/1222    
	t = (pkt->type[0]<<8)|pkt->type[1]; 
	for(type = &ctlr->type[0]; type < &ctlr->type[NType]; type++){ 
1992/0404    
 
		/* 
		 *  only a trace channel gets packets destined for other machines 
1992/1222    
		 * Check for open, the right type, and flow control. 
1992/0404    
		 */ 
1992/0410    
		if(tp->type != -1 && p->d[0] != 0xFF && memcmp(p->d, cp->ea, sizeof(p->d))) 
1992/1222    
		if(type->q == 0) 
1992/0404    
			continue; 
1992/1222    
		if(t != type->type && type->type != -1) 
			continue; 
		if(type->q->next->len > Streamhi) 
			continue; 
1992/0404    
 
		/* 
		 *  check after locking to make sure things didn't 
		 *  change under foot 
1992/1222    
		 * Only a trace channel gets packets destined for other machines. 
1992/0404    
		 */ 
1992/0410    
		if(canqlock(tp) == 0) 
1992/1222    
		if(type->type != -1 && pkt->d[0] != 0xFF 
		  && (*pkt->d != *ctlr->ea || memcmp(pkt->d, ctlr->ea, sizeof(pkt->d)))) 
1992/0404    
			continue; 
1992/0410    
		if(tp->q == 0 || tp->q->next->len > Streamhi || (t != tp->type && tp->type != -1)){ 
			qunlock(tp); 
1992/0404    
			continue; 
		} 
1992/1015    
		if(!waserror()){ 
1992/1222    
 
		if(waserror() == 0){ 
1992/0424    
			bp = allocb(len); 
			memmove(bp->rptr, p, len); 
1992/1222    
			memmove(bp->rptr, pkt, len); 
1992/0424    
			bp->wptr += len; 
1992/0404    
			bp->flags |= S_DELIM; 
1992/0410    
			PUTNEXT(tp->q, bp); 
1992/1222    
			PUTNEXT(type->q, bp); 
1992/1015    
			poperror(); 
1992/0404    
		} 
1992/0410    
		qunlock(tp); 
1992/0404    
	} 
} 
 
1992/1015/sys/src/9/pc/devether.c:368,4171992/1222/sys/src/9/pc/devether.c:391,456
1992/0403    
static int 
isinput(void *arg) 
{ 
1992/0922    
	EtherCtlr *cp = arg; 
1992/1222    
	Ctlr *ctlr = arg; 
1992/0403    
 
1992/0925    
	return cp->lbq.first || cp->rb[cp->rh].owner == Host; 
1992/1222    
	return ctlr->lbq.first || ctlr->rb[ctlr->rh].owner == Host || ctlr->clist; 
1992/0403    
} 
 
static void 
etherkproc(void *arg) 
{ 
1992/0922    
	EtherCtlr *cp = arg; 
	EtherBuf *rb; 
1992/1222    
	Ctlr *ctlr = arg; 
	RingBuf *ring; 
1992/0404    
	Block *bp; 
1992/1222    
	Type *type; 
1992/0403    
 
	if(waserror()){ 
1992/0404    
		print("%s noted\n", cp->name); 
1992/0922    
		if(cp->hw->init) 
			(*cp->hw->init)(cp); 
1992/0404    
		cp->kproc = 0; 
1992/1222    
		print("%s noted\n", ctlr->name); 
		/* fix 
		if(ctlr->board->reset) 
			(*ctlr->board->reset)(ctlr); 
		 */ 
		ctlr->kproc = 0; 
1992/0403    
		nexterror(); 
	} 
1992/0404    
	cp->kproc = 1; 
1992/1222    
 
1992/0403    
	for(;;){ 
1992/0915    
		tsleep(&cp->rr, isinput, cp, 500); 
1992/0922    
		if(cp->hw->tweak) 
			(*cp->hw->tweak)(cp); 
1992/1222    
		tsleep(&ctlr->rr, isinput, ctlr, 500); 
		if(ctlr->board->watch) 
			(*ctlr->board->watch)(ctlr); 
1992/0424    
 
1992/0406    
		/* 
		 * process any internal loopback packets 
1992/1222    
		 * Process any internal loopback packets. 
1992/0406    
		 */ 
1992/0424    
		while(bp = getq(&cp->lbq)){ 
1992/0404    
			cp->inpackets++; 
1992/0501    
			etherup(cp, bp->rptr, BLEN(bp)); 
1992/1222    
		while(bp = getq(&ctlr->lbq)){ 
			ctlr->inpackets++; 
			etherup(ctlr, (Etherpkt*)bp->rptr, BLEN(bp)); 
1992/0404    
			freeb(bp); 
		} 
1992/0408    
 
1992/0406    
		/* 
		 * process any received packets 
1992/1222    
		 * Process any received packets. 
1992/0406    
		 */ 
1992/0424    
		while(cp->rb[cp->rh].owner == Host){ 
1992/0406    
			cp->inpackets++; 
1992/0424    
			rb = &cp->rb[cp->rh]; 
1992/0501    
			etherup(cp, rb->pkt, rb->len); 
1992/0424    
			rb->owner = Interface; 
1992/0502    
			cp->rh = NEXT(cp->rh, cp->nrb); 
1992/1222    
		while(ctlr->rb[ctlr->rh].owner == Host){ 
			ctlr->inpackets++; 
			ring = &ctlr->rb[ctlr->rh]; 
			etherup(ctlr, (Etherpkt*)ring->pkt, ring->len); 
			ring->owner = Interface; 
			ctlr->rh = NEXT(ctlr->rh, ctlr->nrb); 
1992/0424    
		} 
1992/1222    
 
		/* 
		 * Close Types requesting it. 
		 */ 
		if(ctlr->clist){ 
			lock(&ctlr->clock); 
			for(type = ctlr->clist; type; type = type->clist){ 
				type->q = 0; 
				wakeup(&type->cr); 
			} 
			ctlr->clist = 0; 
			unlock(&ctlr->clock); 
		} 
1992/0424    
	} 
} 
1992/0410    
 
1992/1015/sys/src/9/pc/devether.c:418,4631992/1222/sys/src/9/pc/devether.c:457,520
1992/0922    
static void 
etherintr(Ureg *ur) 
{ 
	EtherCtlr *cp = &ctlr[0]; 
1992/1222    
	Ctlr *ctlr = softctlr[0]; 
1992/0922    
 
	USED(ur); 
	(*cp->hw->intr)(cp); 
1992/1222    
	(*ctlr->board->intr)(ctlr); 
1992/0922    
} 
 
1992/0424    
void 
etherreset(void) 
{ 
1992/0922    
	EtherCtlr *cp; 
	EtherHw **hw; 
1992/1222    
	Ctlr *ctlr; 
	Board **board; 
1992/0625    
	int i; 
1992/0410    
 
1992/0625    
	cp = &ctlr[0]; 
1992/0922    
	for(hw = etherhw; *hw; hw++){ 
		cp->hw = *hw; 
		if((*cp->hw->reset)(cp) == 0){ 
			cp->present = 1; 
			setvec(Int0vec + cp->hw->irq, etherintr); 
1992/1222    
	if(softctlr[nctlr] == 0) 
		softctlr[nctlr] = xalloc(sizeof(Ctlr)); 
	ctlr = softctlr[nctlr]; 
	for(board = boards; *board; board++){ 
		ctlr->board = *board; 
		if((*ctlr->board->reset)(ctlr) == 0){ 
			ctlr->present = 1; 
 
			/* 
			 * IRQ2 doesn't really exist, it's used to gang the interrupt 
			 * controllers together. A device set to IRQ2 will appear on 
			 * the second interrupt controller as IRQ9. 
			 */ 
			if(ctlr->board->irq == 2) 
				ctlr->board->irq = 9; 
			setvec(Int0vec + ctlr->board->irq, etherintr); 
1992/0922    
			break; 
		} 
1992/0917    
	} 
1992/0922    
	if(cp->present == 0) 
1992/1222    
	if(ctlr->present == 0) 
1992/0922    
		return; 
1992/1222    
	nctlr++; 
1992/0410    
 
1992/0424    
	memset(cp->ba, 0xFF, sizeof(cp->ba)); 
1992/1222    
	if(ctlr->nrb == 0) 
		ctlr->nrb = Nrb; 
	ctlr->rb = xalloc(sizeof(RingBuf)*ctlr->nrb); 
	if(ctlr->ntb == 0) 
		ctlr->ntb = Ntb; 
	ctlr->tb = xalloc(sizeof(RingBuf)*ctlr->ntb); 
1992/0410    
 
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.info[0].name = "stats"; 
	cp->net.info[0].fill = statsfill; 
	cp->net.info[1].name = "type"; 
	cp->net.info[1].fill = typefill; 
1992/1222    
	memset(ctlr->ba, 0xFF, sizeof(ctlr->ba)); 
 
	ctlr->net.name = "ether"; 
	ctlr->net.nconv = NType; 
	ctlr->net.devp = &info; 
	ctlr->net.protop = 0; 
	ctlr->net.listen = 0; 
	ctlr->net.clone = clonecon; 
	ctlr->net.ninfo = 2; 
	ctlr->net.info[0].name = "stats"; 
	ctlr->net.info[0].fill = statsfill; 
	ctlr->net.info[1].name = "type"; 
	ctlr->net.info[1].fill = typefill; 
1992/0625    
	for(i = 0; i < NType; i++) 
		netadd(&cp->net, &cp->type[i], i); 
1992/1222    
		netadd(&ctlr->net, &ctlr->type[i], i); 
1992/0403    
} 
 
1992/0425    
void 
1992/1015/sys/src/9/pc/devether.c:464,4921992/1222/sys/src/9/pc/devether.c:521,561
1992/0425    
etherinit(void) 
1992/0403    
{ 
	int ctlrno = 0; 
1992/0922    
	EtherCtlr *cp = &ctlr[ctlrno]; 
1992/1222    
	Ctlr *ctlr = softctlr[ctlrno]; 
1992/0424    
	int i; 
1992/0403    
 
1992/0917    
	if(cp->present == 0) 
1992/1222    
	if(ctlr->present == 0) 
1992/0917    
		return; 
 
1992/0424    
	cp->rh = 0; 
	cp->ri = 0; 
	for(i = 0; i < cp->nrb; i++) 
		cp->rb[i].owner = Interface; 
1992/1222    
	ctlr->rh = 0; 
	ctlr->ri = 0; 
	for(i = 0; i < ctlr->nrb; i++) 
		ctlr->rb[i].owner = Interface; 
1992/0424    
 
	cp->th = 0; 
	cp->ti = 0; 
	for(i = 0; i < cp->ntb; i++) 
		cp->tb[i].owner = Host; 
1992/1222    
	ctlr->th = 0; 
	ctlr->ti = 0; 
	for(i = 0; i < ctlr->ntb; i++) 
		ctlr->tb[i].owner = Host; 
} 
1992/0424    
 
1992/1222    
Chan* 
etherattach(char *spec) 
{ 
	int ctlrno = 0; 
	Ctlr *ctlr = softctlr[ctlrno]; 
 
	if(ctlr->present == 0) 
		error(Enodev); 
 
1992/0403    
	/* 
	 * put the receiver online 
	 * and start the kproc 
1992/1222    
	 * Enable the interface 
	 * and start the kproc. 
1992/0501    
	 */	 
1992/0424    
	(*cp->hw->online)(cp, 1); 
	if(cp->kproc == 0){ 
		sprint(cp->name, "ether%dkproc", ctlrno); 
		kproc(cp->name, etherkproc, cp); 
1992/1222    
	(*ctlr->board->attach)(ctlr); 
	if(ctlr->kproc == 0){ 
		sprint(ctlr->name, "ether%dkproc", ctlrno); 
		ctlr->kproc = 1; 
		kproc(ctlr->name, etherkproc, ctlr); 
1992/0403    
	} 
1992/1222    
	return devattach('l', spec); 
1992/0403    
} 


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