xref: /netbsd-src/sys/dev/bi/if_ni.c (revision 3b01aba77a7a698587faaae455bbfe740923c1f5)
1 /*	$NetBSD: if_ni.c,v 1.13 2001/07/18 16:53:52 thorpej Exp $ */
2 /*
3  * Copyright (c) 2000 Ludd, University of Lule}, Sweden. All rights reserved.
4  *
5  * Redistribution and use in source and binary forms, with or without
6  * modification, are permitted provided that the following conditions
7  * are met:
8  * 1. Redistributions of source code must retain the above copyright
9  *    notice, this list of conditions and the following disclaimer.
10  * 2. Redistributions in binary form must reproduce the above copyright
11  *    notice, this list of conditions and the following disclaimer in the
12  *    documentation and/or other materials provided with the distribution.
13  * 3. All advertising materials mentioning features or use of this software
14  *    must display the following acknowledgement:
15  *	This product includes software developed at Ludd, University of
16  *	Lule}, Sweden and its contributors.
17  * 4. The name of the author may not be used to endorse or promote products
18  *    derived from this software without specific prior written permission
19  *
20  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
21  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
22  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
23  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
24  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
25  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
26  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
27  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
28  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
29  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
30  */
31 
32 /*
33  * Driver for DEBNA/DEBNT/DEBNK ethernet cards.
34  * Things that is still to do:
35  *	Collect statistics.
36  */
37 
38 #include "opt_inet.h"
39 #include "bpfilter.h"
40 
41 #include <sys/param.h>
42 #include <sys/mbuf.h>
43 #include <sys/socket.h>
44 #include <sys/device.h>
45 #include <sys/systm.h>
46 #include <sys/sockio.h>
47 #include <sys/sched.h>
48 
49 #include <net/if.h>
50 #include <net/if_ether.h>
51 #include <net/if_dl.h>
52 
53 #include <netinet/in.h>
54 #include <netinet/if_inarp.h>
55 
56 #if NBPFILTER > 0
57 #include <net/bpf.h>
58 #include <net/bpfdesc.h>
59 #endif
60 
61 #include <machine/bus.h>
62 #ifdef __vax__
63 #include <machine/mtpr.h>
64 #include <machine/pte.h>
65 #endif
66 
67 #include <dev/bi/bireg.h>
68 #include <dev/bi/bivar.h>
69 
70 #include "ioconf.h"
71 #include "locators.h"
72 
73 /*
74  * Tunable buffer parameters. Good idea to have them as power of 8; then
75  * they will fit into a logical VAX page.
76  */
77 #define NMSGBUF		8	/* Message queue entries */
78 #define NTXBUF		16	/* Transmit queue entries */
79 #define NTXFRAGS	8	/* Number of transmit buffer fragments */
80 #define NRXBUF		24	/* Receive queue entries */
81 #define NBDESCS		(NTXBUF * NTXFRAGS + NRXBUF)
82 #define NQUEUES		3	/* RX + TX + MSG */
83 #define PKTHDR		18	/* Length of (control) packet header */
84 #define RXADD		18	/* Additional length of receive datagram */
85 #define TXADD		(10+NTXFRAGS*8) /*	""	transmit   ""	 */
86 #define MSGADD		134	/*		""	message	   ""	 */
87 
88 #include <dev/bi/if_nireg.h>	/* XXX include earlier */
89 
90 /*
91  * Macros for (most cases of) insqti/remqhi.
92  * Retry NRETRIES times to do the operation, if it still fails assume
93  * a lost lock and panic.
94  */
95 #define	NRETRIES	100
96 #define	INSQTI(e, h)	({						\
97 	int ret, i;							\
98 	for (i = 0; i < NRETRIES; i++) {				\
99 		if ((ret = insqti(e, h)) != ILCK_FAILED)		\
100 			break;						\
101 	}								\
102 	if (i == NRETRIES)						\
103 		panic("ni: insqti failed at %d", __LINE__);		\
104 	ret;								\
105 })
106 #define	REMQHI(h)	({						\
107 	int i;void *ret;						\
108 	for (i = 0; i < NRETRIES; i++) {				\
109 		if ((ret = remqhi(h)) != (void *)ILCK_FAILED)		\
110 			break;						\
111 	}								\
112 	if (i == NRETRIES)						\
113 		panic("ni: remqhi failed at %d", __LINE__);		\
114 	ret;								\
115 })
116 
117 
118 #define nipqb	(&sc->sc_gvppqb->nc_pqb)
119 #define gvp	sc->sc_gvppqb
120 #define fqb	sc->sc_fqb
121 #define bbd	sc->sc_bbd
122 
123 struct	ni_softc {
124 	struct device	sc_dev;		/* Configuration common part	*/
125 	struct evcnt	sc_intrcnt;	/* Interrupt coounting		*/
126 	struct ethercom sc_ec;		/* Ethernet common part		*/
127 #define sc_if	sc_ec.ec_if		/* network-visible interface	*/
128 	bus_space_tag_t sc_iot;
129 	bus_addr_t	sc_ioh;
130 	bus_dma_tag_t	sc_dmat;
131 	struct ni_gvppqb *sc_gvppqb;	/* Port queue block		*/
132 	struct ni_gvppqb *sc_pgvppqb;	/* Phys address of PQB		*/
133 	struct ni_fqb	*sc_fqb;	/* Free Queue block		*/
134 	struct ni_bbd	*sc_bbd;	/* Buffer descriptors		*/
135 	u_int8_t	sc_enaddr[ETHER_ADDR_LEN];
136 };
137 
138 static	int	nimatch __P((struct device *, struct cfdata *, void *));
139 static	void	niattach __P((struct device *, struct device *, void *));
140 static	void	niinit __P((struct ni_softc *));
141 static	void	nistart __P((struct ifnet *));
142 static	void	niintr __P((void *));
143 static	int	niioctl __P((struct ifnet *, u_long, caddr_t));
144 static	int	ni_add_rxbuf(struct ni_softc *, struct ni_dg *, int);
145 static	void	ni_setup __P((struct ni_softc *));
146 static	void	nitimeout __P((struct ifnet *));
147 static	void	ni_shutdown(void *);
148 static	void ni_getpgs(struct ni_softc *sc, int size, caddr_t *v, paddr_t *p);
149 static	int failtest(struct ni_softc *, int, int, int, char *);
150 
151 volatile int endwait, retry;	/* Used during autoconfig */
152 
153 struct	cfattach ni_ca = {
154 	sizeof(struct ni_softc), nimatch, niattach
155 };
156 
157 #define NI_WREG(csr, val) \
158 	bus_space_write_4(sc->sc_iot, sc->sc_ioh, csr, val)
159 #define NI_RREG(csr) \
160 	bus_space_read_4(sc->sc_iot, sc->sc_ioh, csr)
161 
162 #define WAITREG(csr,val) while (NI_RREG(csr) & val);
163 /*
164  * Check for present device.
165  */
166 int
167 nimatch(parent, cf, aux)
168 	struct	device *parent;
169 	struct	cfdata *cf;
170 	void	*aux;
171 {
172 	struct bi_attach_args *ba = aux;
173 	u_short type;
174 
175 	type = bus_space_read_2(ba->ba_iot, ba->ba_ioh, BIREG_DTYPE);
176 	if (type != BIDT_DEBNA && type != BIDT_DEBNT && type != BIDT_DEBNK)
177 		return 0;
178 
179 	if (cf->cf_loc[BICF_NODE] != BICF_NODE_DEFAULT &&
180 	    cf->cf_loc[BICF_NODE] != ba->ba_nodenr)
181 		return 0;
182 
183 	return 1;
184 }
185 
186 /*
187  * Allocate a bunch of descriptor-safe memory.
188  * We need to get the structures from the beginning of its own pages.
189  */
190 static void
191 ni_getpgs(struct ni_softc *sc, int size, caddr_t *v, paddr_t *p)
192 {
193 	bus_dma_segment_t seg;
194 	int nsegs, error;
195 
196 	if ((error = bus_dmamem_alloc(sc->sc_dmat, size, NBPG, 0, &seg, 1,
197 	    &nsegs, BUS_DMA_NOWAIT)) != 0)
198 		panic(" unable to allocate memory: error %d", error);
199 
200 	if ((error = bus_dmamem_map(sc->sc_dmat, &seg, nsegs, size, v,
201 	    BUS_DMA_NOWAIT|BUS_DMA_COHERENT)) != 0)
202 		panic(" unable to map memory: error %d", error);
203 
204 	if (p)
205 		*p = seg.ds_addr;
206 	memset(*v, 0, size);
207 }
208 
209 static int
210 failtest(struct ni_softc *sc, int reg, int mask, int test, char *str)
211 {
212 	int i = 100;
213 
214 	do {
215 		DELAY(100000);
216 	} while (((NI_RREG(reg) & mask) != test) && --i);
217 
218 	if (i == 0) {
219 		printf("%s: %s\n", sc->sc_dev.dv_xname, str);
220 		return 1;
221 	}
222 	return 0;
223 }
224 
225 
226 /*
227  * Interface exists: make available by filling in network interface
228  * record.  System will initialize the interface when it is ready
229  * to accept packets.
230  */
231 void
232 niattach(parent, self, aux)
233 	struct	device *parent, *self;
234 	void	*aux;
235 {
236 	struct bi_attach_args *ba = aux;
237 	struct ni_softc *sc = (struct ni_softc *)self;
238 	struct ifnet *ifp = (struct ifnet *)&sc->sc_if;
239 	struct ni_msg *msg;
240 	struct ni_ptdb *ptdb;
241 	caddr_t va;
242 	int i, j, s, res;
243 	u_short type;
244 
245 	type = bus_space_read_2(ba->ba_iot, ba->ba_ioh, BIREG_DTYPE);
246 	printf(": DEBN%c\n", type == BIDT_DEBNA ? 'A' : type == BIDT_DEBNT ?
247 	    'T' : 'K');
248 	sc->sc_iot = ba->ba_iot;
249 	sc->sc_ioh = ba->ba_ioh;
250 	sc->sc_dmat = ba->ba_dmat;
251 
252 	bi_intr_establish(ba->ba_icookie, ba->ba_ivec,
253 		niintr, sc, &sc->sc_intrcnt);
254 	evcnt_attach_dynamic(&sc->sc_intrcnt, EVCNT_TYPE_INTR, NULL,
255 		sc->sc_dev.dv_xname, "intr");
256 
257 	ni_getpgs(sc, sizeof(struct ni_gvppqb), (caddr_t *)&sc->sc_gvppqb,
258 	    (paddr_t *)&sc->sc_pgvppqb);
259 	ni_getpgs(sc, sizeof(struct ni_fqb), (caddr_t *)&sc->sc_fqb, 0);
260 	ni_getpgs(sc, NBDESCS * sizeof(struct ni_bbd),
261 	    (caddr_t *)&sc->sc_bbd, 0);
262 	/*
263 	 * Zero the newly allocated memory.
264 	 */
265 
266 	nipqb->np_veclvl = (ba->ba_ivec << 2) + 2;
267 	nipqb->np_node = ba->ba_intcpu;
268 	nipqb->np_vpqb = (u_int32_t)gvp;
269 #ifdef __vax__
270 	nipqb->np_spt = nipqb->np_gpt = mfpr(PR_SBR);
271 	nipqb->np_sptlen = nipqb->np_gptlen = mfpr(PR_SLR);
272 #else
273 #error Must fix support for non-vax.
274 #endif
275 	nipqb->np_bvplvl = 1;
276 	nipqb->np_vfqb = (u_int32_t)fqb;
277 	nipqb->np_vbdt = (u_int32_t)bbd;
278 	nipqb->np_nbdr = NBDESCS;
279 
280 	/* Free queue block */
281 	nipqb->np_freeq = NQUEUES;
282 	fqb->nf_mlen = PKTHDR+MSGADD;
283 	fqb->nf_dlen = PKTHDR+TXADD;
284 	fqb->nf_rlen = PKTHDR+RXADD;
285 
286 	strcpy(ifp->if_xname, sc->sc_dev.dv_xname);
287 	ifp->if_softc = sc;
288 	ifp->if_flags = IFF_BROADCAST | IFF_SIMPLEX | IFF_MULTICAST;
289 	ifp->if_start = nistart;
290 	ifp->if_ioctl = niioctl;
291 	ifp->if_watchdog = nitimeout;
292 	IFQ_SET_READY(&ifp->if_snd);
293 
294 	/*
295 	 * Start init sequence.
296 	 */
297 
298 	/* Reset the node */
299 	NI_WREG(BIREG_VAXBICSR, NI_RREG(BIREG_VAXBICSR) | BICSR_NRST);
300 	DELAY(500000);
301 	i = 20;
302 	while ((NI_RREG(BIREG_VAXBICSR) & BICSR_BROKE) && --i)
303 		DELAY(500000);
304 	if (i == 0) {
305 		printf("%s: BROKE bit set after reset\n", sc->sc_dev.dv_xname);
306 		return;
307 	}
308 
309 	/* Check state */
310 	if (failtest(sc, NI_PSR, PSR_STATE, PSR_UNDEF, "not undefined state"))
311 		return;
312 
313 	/* Clear owner bits */
314 	NI_WREG(NI_PSR, NI_RREG(NI_PSR) & ~PSR_OWN);
315 	NI_WREG(NI_PCR, NI_RREG(NI_PCR) & ~PCR_OWN);
316 
317 	/* kick off init */
318 	NI_WREG(NI_PCR, (u_int32_t)sc->sc_pgvppqb | PCR_INIT | PCR_OWN);
319 	while (NI_RREG(NI_PCR) & PCR_OWN)
320 		DELAY(100000);
321 
322 	/* Check state */
323 	if (failtest(sc, NI_PSR, PSR_INITED, PSR_INITED, "failed initialize"))
324 		return;
325 
326 	NI_WREG(NI_PSR, NI_RREG(NI_PSR) & ~PSR_OWN);
327 
328 	WAITREG(NI_PCR, PCR_OWN);
329 	NI_WREG(NI_PCR, PCR_OWN|PCR_ENABLE);
330 	WAITREG(NI_PCR, PCR_OWN);
331 	WAITREG(NI_PSR, PSR_OWN);
332 
333 	/* Check state */
334 	if (failtest(sc, NI_PSR, PSR_STATE, PSR_ENABLED, "failed enable"))
335 		return;
336 
337 	NI_WREG(NI_PSR, NI_RREG(NI_PSR) & ~PSR_OWN);
338 
339 	/*
340 	 * The message queue packets must be located on the beginning
341 	 * of a page. A VAX page is 512 bytes, but it clusters 8 pages.
342 	 * This knowledge is used here when allocating pages.
343 	 * !!! How should this be done on MIPS and Alpha??? !!!
344 	 */
345 #if NBPG < 4096
346 #error pagesize too small
347 #endif
348 	s = splvm();
349 	/* Set up message free queue */
350 	ni_getpgs(sc, NMSGBUF * 512, &va, 0);
351 	for (i = 0; i < NMSGBUF; i++) {
352 		struct ni_msg *msg;
353 
354 		msg = (void *)(va + i * 512);
355 
356 		res = INSQTI(msg, &fqb->nf_mforw);
357 	}
358 	WAITREG(NI_PCR, PCR_OWN);
359 	NI_WREG(NI_PCR, PCR_FREEQNE|PCR_MFREEQ|PCR_OWN);
360 	WAITREG(NI_PCR, PCR_OWN);
361 
362 	/* Set up xmit queue */
363 	ni_getpgs(sc, NTXBUF * 512, &va, 0);
364 	for (i = 0; i < NTXBUF; i++) {
365 		struct ni_dg *data;
366 
367 		data = (void *)(va + i * 512);
368 		data->nd_status = 0;
369 		data->nd_len = TXADD;
370 		data->nd_ptdbidx = 1;
371 		data->nd_opcode = BVP_DGRAM;
372 		for (j = 0; j < NTXFRAGS; j++) {
373 			data->bufs[j]._offset = 0;
374 			data->bufs[j]._key = 1;
375 			bbd[i * NTXFRAGS + j].nb_key = 1;
376 			bbd[i * NTXFRAGS + j].nb_status = 0;
377 			data->bufs[j]._index = i * NTXFRAGS + j;
378 		}
379 		res = INSQTI(data, &fqb->nf_dforw);
380 	}
381 	WAITREG(NI_PCR, PCR_OWN);
382 	NI_WREG(NI_PCR, PCR_FREEQNE|PCR_DFREEQ|PCR_OWN);
383 	WAITREG(NI_PCR, PCR_OWN);
384 
385 	/* recv buffers */
386 	ni_getpgs(sc, NRXBUF * 512, &va, 0);
387 	for (i = 0; i < NRXBUF; i++) {
388 		struct ni_dg *data;
389 		int idx;
390 
391 		data = (void *)(va + i * 512);
392 		data->nd_len = RXADD;
393 		data->nd_opcode = BVP_DGRAMRX;
394 		data->nd_ptdbidx = 2;
395 		data->bufs[0]._key = 1;
396 
397 		idx = NTXBUF * NTXFRAGS + i;
398 		if (ni_add_rxbuf(sc, data, idx))
399 			panic("niattach: ni_add_rxbuf: out of mbufs");
400 
401 		res = INSQTI(data, &fqb->nf_rforw);
402 	}
403 	WAITREG(NI_PCR, PCR_OWN);
404 	NI_WREG(NI_PCR, PCR_FREEQNE|PCR_RFREEQ|PCR_OWN);
405 	WAITREG(NI_PCR, PCR_OWN);
406 
407 	splx(s);
408 
409 	/* Set initial parameters */
410 	msg = REMQHI(&fqb->nf_mforw);
411 
412 	msg->nm_opcode = BVP_MSG;
413 	msg->nm_status = 0;
414 	msg->nm_len = sizeof(struct ni_param) + 6;
415 	msg->nm_opcode2 = NI_WPARAM;
416 	((struct ni_param *)&msg->nm_text[0])->np_flags = NP_PAD;
417 
418 	endwait = retry = 0;
419 	res = INSQTI(msg, &gvp->nc_forw0);
420 
421 retry:	WAITREG(NI_PCR, PCR_OWN);
422 	NI_WREG(NI_PCR, PCR_CMDQNE|PCR_CMDQ0|PCR_OWN);
423 	WAITREG(NI_PCR, PCR_OWN);
424 	i = 1000;
425 	while (endwait == 0 && --i)
426 		DELAY(10000);
427 
428 	if (endwait == 0) {
429 		if (++retry < 3)
430 			goto retry;
431 		printf("%s: no response to set params\n", sc->sc_dev.dv_xname);
432 		return;
433 	}
434 
435 	/* Clear counters */
436 	msg = REMQHI(&fqb->nf_mforw);
437 	msg->nm_opcode = BVP_MSG;
438 	msg->nm_status = 0;
439 	msg->nm_len = sizeof(struct ni_param) + 6;
440 	msg->nm_opcode2 = NI_RCCNTR;
441 
442 	res = INSQTI(msg, &gvp->nc_forw0);
443 
444 	WAITREG(NI_PCR, PCR_OWN);
445 	NI_WREG(NI_PCR, PCR_CMDQNE|PCR_CMDQ0|PCR_OWN);
446 	WAITREG(NI_PCR, PCR_OWN);
447 
448 	/* Enable transmit logic */
449 	msg = REMQHI(&fqb->nf_mforw);
450 
451 	msg->nm_opcode = BVP_MSG;
452 	msg->nm_status = 0;
453 	msg->nm_len = 18;
454 	msg->nm_opcode2 = NI_STPTDB;
455 	ptdb = (struct ni_ptdb *)&msg->nm_text[0];
456 	memset(ptdb, 0, sizeof(struct ni_ptdb));
457 	ptdb->np_index = 1;
458 	ptdb->np_fque = 1;
459 
460 	res = INSQTI(msg, &gvp->nc_forw0);
461 
462 	WAITREG(NI_PCR, PCR_OWN);
463 	NI_WREG(NI_PCR, PCR_CMDQNE|PCR_CMDQ0|PCR_OWN);
464 	WAITREG(NI_PCR, PCR_OWN);
465 
466 	/* Wait for everything to finish */
467 	WAITREG(NI_PSR, PSR_OWN);
468 
469 	printf("%s: hardware address %s\n", sc->sc_dev.dv_xname,
470 	    ether_sprintf(sc->sc_enaddr));
471 
472 	/*
473 	 * Attach the interface.
474 	 */
475 	if_attach(ifp);
476 	ether_ifattach(ifp, sc->sc_enaddr);
477 	if (shutdownhook_establish(ni_shutdown, sc) == 0)
478 		printf("%s: WARNING: unable to establish shutdown hook\n",
479 		    sc->sc_dev.dv_xname);
480 }
481 
482 /*
483  * Initialization of interface.
484  */
485 void
486 niinit(sc)
487 	struct ni_softc *sc;
488 {
489 	struct ifnet *ifp = (struct ifnet *)&sc->sc_if;
490 
491 	/*
492 	 * Set flags (so ni_setup() do the right thing).
493 	 */
494 	ifp->if_flags |= IFF_RUNNING;
495 	ifp->if_flags &= ~IFF_OACTIVE;
496 
497 	/*
498 	 * Send setup messages so that the rx/tx locic starts.
499 	 */
500 	ni_setup(sc);
501 
502 }
503 
504 /*
505  * Start output on interface.
506  */
507 void
508 nistart(ifp)
509 	struct ifnet *ifp;
510 {
511 	struct ni_softc *sc = ifp->if_softc;
512 	struct ni_dg *data;
513 	struct ni_bbd *bdp;
514 	struct mbuf *m, *m0;
515 	int i, cnt, res, mlen;
516 
517 	if (ifp->if_flags & IFF_OACTIVE)
518 		return;
519 #ifdef DEBUG
520 	if (ifp->if_flags & IFF_DEBUG)
521 		printf("%s: nistart\n", sc->sc_dev.dv_xname);
522 #endif
523 
524 	while (fqb->nf_dforw) {
525 		IFQ_POLL(&ifp->if_snd, m);
526 		if (m == 0)
527 			break;
528 
529 		data = REMQHI(&fqb->nf_dforw);
530 		if ((int)data == Q_EMPTY) {
531 			ifp->if_flags |= IFF_OACTIVE;
532 			break;
533 		}
534 
535 		IFQ_DEQUEUE(&ifp->if_snd, m);
536 
537 		/*
538 		 * Count number of mbufs in chain.
539 		 * Always do DMA directly from mbufs, therefore the transmit
540 		 * ring is really big.
541 		 */
542 		for (m0 = m, cnt = 0; m0; m0 = m0->m_next)
543 			if (m0->m_len)
544 				cnt++;
545 		if (cnt > NTXFRAGS)
546 			panic("nistart"); /* XXX */
547 
548 #if NBPFILTER > 0
549 		if (ifp->if_bpf)
550 			bpf_mtap(ifp->if_bpf, m);
551 #endif
552 		bdp = &bbd[(data->bufs[0]._index & 0x7fff)];
553 		for (m0 = m, i = 0, mlen = 0; m0; m0 = m0->m_next) {
554 			if (m0->m_len == 0)
555 				continue;
556 			bdp->nb_status = (mtod(m0, u_int32_t) & NIBD_OFFSET) |
557 			    NIBD_VALID;
558 			bdp->nb_pte = (u_int32_t)kvtopte(mtod(m0, void *));
559 			bdp->nb_len = m0->m_len;
560 			data->bufs[i]._offset = 0;
561 			data->bufs[i]._len = bdp->nb_len;
562 			data->bufs[i]._index |= NIDG_CHAIN;
563 			mlen += bdp->nb_len;
564 			bdp++;
565 			i++;
566 		}
567 		data->nd_opcode = BVP_DGRAM;
568 		data->nd_pad3 = 1;
569 		data->nd_ptdbidx = 1;
570 		data->nd_len = 10 + i * 8;
571 		data->bufs[i - 1]._index &= ~NIDG_CHAIN;
572 		if (mlen < 64)
573 			data->bufs[i - 1]._len = bdp[-1].nb_len += (64 - mlen);
574 		data->nd_cmdref = (u_int32_t)m;
575 #ifdef DEBUG
576 		if (ifp->if_flags & IFF_DEBUG)
577 			printf("%s: sending %d bytes (%d segments)\n",
578 			    sc->sc_dev.dv_xname, mlen, i);
579 #endif
580 
581 		res = INSQTI(data, &gvp->nc_forw0);
582 		if (res == Q_EMPTY) {
583 			WAITREG(NI_PCR, PCR_OWN);
584 			NI_WREG(NI_PCR, PCR_CMDQNE|PCR_CMDQ0|PCR_OWN);
585 		}
586 	}
587 }
588 
589 void
590 niintr(void *arg)
591 {
592 	struct ni_softc *sc = arg;
593 	struct ni_dg *data;
594 	struct ni_msg *msg;
595 	struct ifnet *ifp = &sc->sc_if;
596 	struct ni_bbd *bd;
597 	struct mbuf *m;
598 	int idx, res;
599 
600 	if ((NI_RREG(NI_PSR) & PSR_STATE) != PSR_ENABLED)
601 		return;
602 
603 	if ((NI_RREG(NI_PSR) & PSR_ERR))
604 		printf("%s: PSR %x\n", sc->sc_dev.dv_xname, NI_RREG(NI_PSR));
605 
606 	KERNEL_LOCK(LK_CANRECURSE|LK_EXCLUSIVE);
607 	/* Got any response packets?  */
608 	while ((NI_RREG(NI_PSR) & PSR_RSQ) && (data = REMQHI(&gvp->nc_forwr))) {
609 
610 		switch (data->nd_opcode) {
611 		case BVP_DGRAMRX: /* Receive datagram */
612 			idx = data->bufs[0]._index;
613 			bd = &bbd[idx];
614 			m = (void *)data->nd_cmdref;
615 			m->m_pkthdr.len = m->m_len =
616 			    data->bufs[0]._len - ETHER_CRC_LEN;
617 			m->m_pkthdr.rcvif = ifp;
618 			if (ni_add_rxbuf(sc, data, idx)) {
619 				bd->nb_len = (m->m_ext.ext_size - 2);
620 				bd->nb_pte =
621 				    (long)kvtopte(m->m_ext.ext_buf);
622 				bd->nb_status = 2 | NIBD_VALID;
623 				bd->nb_key = 1;
624 			}
625 			data->nd_len = RXADD;
626 			data->nd_status = 0;
627 			res = INSQTI(data, &fqb->nf_rforw);
628 			if (res == Q_EMPTY) {
629 				WAITREG(NI_PCR, PCR_OWN);
630 				NI_WREG(NI_PCR, PCR_FREEQNE|PCR_RFREEQ|PCR_OWN);
631 			}
632 			if (m == (void *)data->nd_cmdref)
633 				break; /* Out of mbufs */
634 
635 #if NBPFILTER > 0
636 			if (ifp->if_bpf)
637 				bpf_mtap(ifp->if_bpf, m);
638 #endif
639 			(*ifp->if_input)(ifp, m);
640 			break;
641 
642 		case BVP_DGRAM:
643 			m = (struct mbuf *)data->nd_cmdref;
644 			ifp->if_flags &= ~IFF_OACTIVE;
645 			m_freem(m);
646 			res = INSQTI(data, &fqb->nf_dforw);
647 			if (res == Q_EMPTY) {
648 				WAITREG(NI_PCR, PCR_OWN);
649 				NI_WREG(NI_PCR, PCR_FREEQNE|PCR_DFREEQ|PCR_OWN);
650 			}
651 			break;
652 
653 		case BVP_MSGRX:
654 			msg = (struct ni_msg *)data;
655 			switch (msg->nm_opcode2) {
656 				case NI_WPARAM:
657 					memcpy(sc->sc_enaddr, ((struct ni_param *)&msg->nm_text[0])->np_dpa, ETHER_ADDR_LEN);
658 					endwait = 1;
659 					break;
660 
661 				case NI_RCCNTR:
662 				case NI_CLPTDB:
663 				case NI_STPTDB:
664 					break;
665 
666 				default:
667 					printf("Unkn resp %d\n",
668 					    msg->nm_opcode2);
669 					break;
670 			}
671 			res = INSQTI(data, &fqb->nf_mforw);
672 			if (res == Q_EMPTY) {
673 				WAITREG(NI_PCR, PCR_OWN);
674 				NI_WREG(NI_PCR, PCR_FREEQNE|PCR_MFREEQ|PCR_OWN);
675 			}
676 			break;
677 
678 		default:
679 			printf("Unknown opcode %d\n", data->nd_opcode);
680 			res = INSQTI(data, &fqb->nf_mforw);
681 			if (res == Q_EMPTY) {
682 				WAITREG(NI_PCR, PCR_OWN);
683 				NI_WREG(NI_PCR, PCR_FREEQNE|PCR_MFREEQ|PCR_OWN);
684 			}
685 		}
686 	}
687 
688 	/* Try to kick on the start routine again */
689 	nistart(ifp);
690 
691 	NI_WREG(NI_PSR, NI_RREG(NI_PSR) & ~(PSR_OWN|PSR_RSQ));
692 	KERNEL_UNLOCK();
693 }
694 
695 /*
696  * Process an ioctl request.
697  */
698 int
699 niioctl(ifp, cmd, data)
700 	register struct ifnet *ifp;
701 	u_long cmd;
702 	caddr_t data;
703 {
704 	struct ni_softc *sc = ifp->if_softc;
705 	struct ifreq *ifr = (struct ifreq *)data;
706 	struct ifaddr *ifa = (struct ifaddr *)data;
707 	int s = splnet(), error = 0;
708 
709 	switch (cmd) {
710 
711 	case SIOCSIFADDR:
712 		ifp->if_flags |= IFF_UP;
713 		switch(ifa->ifa_addr->sa_family) {
714 #ifdef INET
715 		case AF_INET:
716 			niinit(sc);
717 			arp_ifinit(ifp, ifa);
718 			break;
719 #endif
720 		}
721 		break;
722 
723 	case SIOCSIFFLAGS:
724 		if ((ifp->if_flags & IFF_UP) == 0 &&
725 		    (ifp->if_flags & IFF_RUNNING) != 0) {
726 			/*
727 			 * If interface is marked down and it is running,
728 			 * stop it.
729 			 */
730 			ifp->if_flags &= ~IFF_RUNNING;
731 			ni_setup(sc);
732 		} else if ((ifp->if_flags & IFF_UP) != 0 &&
733 			   (ifp->if_flags & IFF_RUNNING) == 0) {
734 			/*
735 			 * If interface it marked up and it is stopped, then
736 			 * start it.
737 			 */
738 			niinit(sc);
739 		} else if ((ifp->if_flags & IFF_UP) != 0) {
740 			/*
741 			 * Send a new setup packet to match any new changes.
742 			 * (Like IFF_PROMISC etc)
743 			 */
744 			ni_setup(sc);
745 		}
746 		break;
747 
748 	case SIOCADDMULTI:
749 	case SIOCDELMULTI:
750 		/*
751 		 * Update our multicast list.
752 		 */
753 		error = (cmd == SIOCADDMULTI) ?
754 			ether_addmulti(ifr, &sc->sc_ec):
755 			ether_delmulti(ifr, &sc->sc_ec);
756 
757 		if (error == ENETRESET) {
758 			/*
759 			 * Multicast list has changed; set the hardware filter
760 			 * accordingly.
761 			 */
762 			ni_setup(sc);
763 			error = 0;
764 		}
765 		break;
766 
767 	default:
768 		error = EINVAL;
769 
770 	}
771 	splx(s);
772 	return (error);
773 }
774 
775 /*
776  * Add a receive buffer to the indicated descriptor.
777  */
778 int
779 ni_add_rxbuf(struct ni_softc *sc, struct ni_dg *data, int idx)
780 {
781 	struct ni_bbd *bd = &bbd[idx];
782 	struct mbuf *m;
783 
784 	MGETHDR(m, M_DONTWAIT, MT_DATA);
785 	if (m == NULL)
786 		return (ENOBUFS);
787 
788 	MCLGET(m, M_DONTWAIT);
789 	if ((m->m_flags & M_EXT) == 0) {
790 		m_freem(m);
791 		return (ENOBUFS);
792 	}
793 
794 	m->m_data += 2;
795 	bd->nb_len = (m->m_ext.ext_size - 2);
796 	bd->nb_pte = (long)kvtopte(m->m_ext.ext_buf);
797 	bd->nb_status = 2 | NIBD_VALID;
798 	bd->nb_key = 1;
799 
800 	data->bufs[0]._offset = 0;
801 	data->bufs[0]._len = bd->nb_len;
802 	data->bufs[0]._index = idx;
803 	data->nd_cmdref = (long)m;
804 
805 	return (0);
806 }
807 
808 /*
809  * Create setup packet and put in queue for sending.
810  */
811 void
812 ni_setup(struct ni_softc *sc)
813 {
814 	struct ifnet *ifp = &sc->sc_if;
815 	struct ni_msg *msg;
816 	struct ni_ptdb *ptdb;
817 	struct ether_multi *enm;
818 	struct ether_multistep step;
819 	int i, res;
820 
821 	msg = REMQHI(&fqb->nf_mforw);
822 	if ((int)msg == Q_EMPTY)
823 		return; /* What to do? */
824 
825 	ptdb = (struct ni_ptdb *)&msg->nm_text[0];
826 	memset(ptdb, 0, sizeof(struct ni_ptdb));
827 
828 	msg->nm_opcode = BVP_MSG;
829 	msg->nm_len = 18;
830 	ptdb->np_index = 2; /* definition type index */
831 	ptdb->np_fque = 2; /* Free queue */
832 	if (ifp->if_flags & IFF_RUNNING) {
833 		msg->nm_opcode2 = NI_STPTDB;
834 		ptdb->np_type = ETHERTYPE_IP;
835 		ptdb->np_flags = PTDB_UNKN|PTDB_BDC;
836 		if (ifp->if_flags & IFF_PROMISC)
837 			ptdb->np_flags |= PTDB_PROMISC;
838 		memset(ptdb->np_mcast[0], 0xff, ETHER_ADDR_LEN); /* Broadcast */
839 		ptdb->np_adrlen = 1;
840 		msg->nm_len += 8;
841 		ifp->if_flags &= ~IFF_ALLMULTI;
842 		if ((ifp->if_flags & IFF_PROMISC) == 0) {
843 			ETHER_FIRST_MULTI(step, &sc->sc_ec, enm);
844 			i = 1;
845 			while (enm != NULL) {
846 				if (bcmp(enm->enm_addrlo, enm->enm_addrhi, 6)) {
847 					ifp->if_flags |= IFF_ALLMULTI;
848 					ptdb->np_flags |= PTDB_AMC;
849 					break;
850 				}
851 				msg->nm_len += 8;
852 				ptdb->np_adrlen++;
853 				memcpy(ptdb->np_mcast[i++], enm->enm_addrlo,
854 				    ETHER_ADDR_LEN);
855 				ETHER_NEXT_MULTI(step, enm);
856 			}
857 		}
858 	} else
859 		msg->nm_opcode2 = NI_CLPTDB;
860 
861 	res = INSQTI(msg, &gvp->nc_forw0);
862 	if (res == Q_EMPTY) {
863 		WAITREG(NI_PCR, PCR_OWN);
864 		NI_WREG(NI_PCR, PCR_CMDQNE|PCR_CMDQ0|PCR_OWN);
865 	}
866 }
867 
868 /*
869  * Check for dead transmit logic. Not uncommon.
870  */
871 void
872 nitimeout(ifp)
873 	struct ifnet *ifp;
874 {
875 #if 0
876 	struct ni_softc *sc = ifp->if_softc;
877 
878 	if (sc->sc_inq == 0)
879 		return;
880 
881 	printf("%s: xmit logic died, resetting...\n", sc->sc_dev.dv_xname);
882 	/*
883 	 * Do a reset of interface, to get it going again.
884 	 * Will it work by just restart the transmit logic?
885 	 */
886 	niinit(sc);
887 #endif
888 }
889 
890 /*
891  * Shutdown hook.  Make sure the interface is stopped at reboot.
892  */
893 void
894 ni_shutdown(arg)
895 	void *arg;
896 {
897 	struct ni_softc *sc = arg;
898 
899         WAITREG(NI_PCR, PCR_OWN);
900         NI_WREG(NI_PCR, PCR_OWN|PCR_SHUTDOWN);
901         WAITREG(NI_PCR, PCR_OWN);
902         WAITREG(NI_PSR, PSR_OWN);
903 
904 }
905 
906