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