Home | History | Annotate | Line # | Download | only in qbus
if_qe.c revision 1.69
      1  1.69    cegger /*      $NetBSD: if_qe.c,v 1.69 2009/03/18 16:00:20 cegger Exp $ */
      2   1.1     ragge /*
      3  1.37     ragge  * Copyright (c) 1999 Ludd, University of Lule}, Sweden. All rights reserved.
      4   1.1     ragge  *
      5   1.1     ragge  * Redistribution and use in source and binary forms, with or without
      6   1.1     ragge  * modification, are permitted provided that the following conditions
      7   1.1     ragge  * are met:
      8   1.1     ragge  * 1. Redistributions of source code must retain the above copyright
      9   1.1     ragge  *    notice, this list of conditions and the following disclaimer.
     10   1.1     ragge  * 2. Redistributions in binary form must reproduce the above copyright
     11   1.1     ragge  *    notice, this list of conditions and the following disclaimer in the
     12   1.1     ragge  *    documentation and/or other materials provided with the distribution.
     13   1.1     ragge  * 3. All advertising materials mentioning features or use of this software
     14   1.1     ragge  *    must display the following acknowledgement:
     15  1.59    simonb  *      This product includes software developed at Ludd, University of
     16  1.37     ragge  *      Lule}, Sweden and its contributors.
     17  1.37     ragge  * 4. The name of the author may not be used to endorse or promote products
     18  1.37     ragge  *    derived from this software without specific prior written permission
     19  1.37     ragge  *
     20  1.37     ragge  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
     21  1.37     ragge  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
     22  1.37     ragge  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
     23  1.37     ragge  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
     24  1.37     ragge  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
     25  1.37     ragge  * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
     26  1.37     ragge  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
     27  1.37     ragge  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
     28  1.37     ragge  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
     29  1.37     ragge  * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
     30   1.1     ragge  */
     31   1.1     ragge 
     32   1.1     ragge /*
     33  1.37     ragge  * Driver for DEQNA/DELQA ethernet cards.
     34  1.37     ragge  * Things that is still to do:
     35  1.37     ragge  *	Handle ubaresets. Does not work at all right now.
     36  1.37     ragge  *	Fix ALLMULTI reception. But someone must tell me how...
     37  1.37     ragge  *	Collect statistics.
     38   1.1     ragge  */
     39  1.49     lukem 
     40  1.49     lukem #include <sys/cdefs.h>
     41  1.69    cegger __KERNEL_RCSID(0, "$NetBSD: if_qe.c,v 1.69 2009/03/18 16:00:20 cegger Exp $");
     42  1.22     ragge 
     43  1.27  jonathan #include "opt_inet.h"
     44  1.22     ragge #include "bpfilter.h"
     45  1.22     ragge 
     46   1.9   mycroft #include <sys/param.h>
     47   1.9   mycroft #include <sys/mbuf.h>
     48   1.9   mycroft #include <sys/socket.h>
     49   1.9   mycroft #include <sys/device.h>
     50  1.37     ragge #include <sys/systm.h>
     51  1.37     ragge #include <sys/sockio.h>
     52   1.9   mycroft 
     53   1.9   mycroft #include <net/if.h>
     54  1.20        is #include <net/if_ether.h>
     55  1.21     ragge #include <net/if_dl.h>
     56   1.1     ragge 
     57   1.9   mycroft #include <netinet/in.h>
     58  1.20        is #include <netinet/if_inarp.h>
     59  1.22     ragge 
     60  1.22     ragge #if NBPFILTER > 0
     61  1.22     ragge #include <net/bpf.h>
     62  1.22     ragge #include <net/bpfdesc.h>
     63  1.22     ragge #endif
     64  1.22     ragge 
     65  1.65        ad #include <sys/bus.h>
     66   1.1     ragge 
     67  1.37     ragge #include <dev/qbus/ubavar.h>
     68  1.37     ragge #include <dev/qbus/if_qereg.h>
     69   1.1     ragge 
     70  1.37     ragge #include "ioconf.h"
     71  1.37     ragge 
     72  1.37     ragge #define RXDESCS	30	/* # of receive descriptors */
     73  1.37     ragge #define TXDESCS	60	/* # transmit descs */
     74   1.6       jtc 
     75   1.1     ragge /*
     76  1.37     ragge  * Structure containing the elements that must be in DMA-safe memory.
     77   1.1     ragge  */
     78  1.37     ragge struct qe_cdata {
     79  1.37     ragge 	struct qe_ring	qc_recv[RXDESCS+1];	/* Receive descriptors */
     80  1.37     ragge 	struct qe_ring	qc_xmit[TXDESCS+1];	/* Transmit descriptors */
     81  1.37     ragge 	u_int8_t	qc_setup[128];		/* Setup packet layout */
     82  1.37     ragge };
     83  1.37     ragge 
     84   1.1     ragge struct	qe_softc {
     85  1.67      matt 	device_t	sc_dev;		/* Configuration common part	*/
     86  1.67      matt 	struct uba_softc *sc_uh;	/* our parent */
     87  1.41      matt 	struct evcnt	sc_intrcnt;	/* Interrupt counting		*/
     88  1.37     ragge 	struct ethercom sc_ec;		/* Ethernet common part		*/
     89  1.37     ragge #define sc_if	sc_ec.ec_if		/* network-visible interface	*/
     90  1.37     ragge 	bus_space_tag_t sc_iot;
     91  1.37     ragge 	bus_addr_t	sc_ioh;
     92  1.37     ragge 	bus_dma_tag_t	sc_dmat;
     93  1.37     ragge 	struct qe_cdata *sc_qedata;	/* Descriptor struct		*/
     94  1.37     ragge 	struct qe_cdata *sc_pqedata;	/* Unibus address of above	*/
     95  1.37     ragge 	struct mbuf*	sc_txmbuf[TXDESCS];
     96  1.37     ragge 	struct mbuf*	sc_rxmbuf[RXDESCS];
     97  1.37     ragge 	bus_dmamap_t	sc_xmtmap[TXDESCS];
     98  1.37     ragge 	bus_dmamap_t	sc_rcvmap[RXDESCS];
     99  1.57    bouyer 	bus_dmamap_t	sc_nulldmamap;	/* ethernet padding buffer	*/
    100  1.48     ragge 	struct ubinfo	sc_ui;
    101  1.37     ragge 	int		sc_intvec;	/* Interrupt vector		*/
    102  1.37     ragge 	int		sc_nexttx;
    103  1.37     ragge 	int		sc_inq;
    104  1.37     ragge 	int		sc_lastack;
    105  1.37     ragge 	int		sc_nextrx;
    106  1.37     ragge 	int		sc_setup;	/* Setup packet in queue	*/
    107   1.7     ragge };
    108   1.1     ragge 
    109  1.67      matt static	int	qematch(device_t, cfdata_t, void *);
    110  1.67      matt static	void	qeattach(device_t, device_t, void *);
    111  1.46     ragge static	void	qeinit(struct qe_softc *);
    112  1.46     ragge static	void	qestart(struct ifnet *);
    113  1.46     ragge static	void	qeintr(void *);
    114  1.62  christos static	int	qeioctl(struct ifnet *, u_long, void *);
    115  1.46     ragge static	int	qe_add_rxbuf(struct qe_softc *, int);
    116  1.46     ragge static	void	qe_setup(struct qe_softc *);
    117  1.46     ragge static	void	qetimeout(struct ifnet *);
    118   1.1     ragge 
    119  1.67      matt CFATTACH_DECL_NEW(qe, sizeof(struct qe_softc),
    120  1.55   thorpej     qematch, qeattach, NULL, NULL);
    121  1.23   thorpej 
    122  1.37     ragge #define	QE_WCSR(csr, val) \
    123  1.37     ragge 	bus_space_write_2(sc->sc_iot, sc->sc_ioh, csr, val)
    124  1.37     ragge #define	QE_RCSR(csr) \
    125  1.37     ragge 	bus_space_read_2(sc->sc_iot, sc->sc_ioh, csr)
    126   1.1     ragge 
    127  1.37     ragge #define	LOWORD(x)	((int)(x) & 0xffff)
    128  1.37     ragge #define	HIWORD(x)	(((int)(x) >> 16) & 0x3f)
    129   1.7     ragge 
    130  1.57    bouyer #define	ETHER_PAD_LEN (ETHER_MIN_LEN - ETHER_CRC_LEN)
    131  1.57    bouyer 
    132   1.1     ragge /*
    133  1.37     ragge  * Check for present DEQNA. Done by sending a fake setup packet
    134  1.37     ragge  * and wait for interrupt.
    135   1.1     ragge  */
    136   1.7     ragge int
    137  1.67      matt qematch(device_t parent, cfdata_t cf, void *aux)
    138   1.7     ragge {
    139  1.37     ragge 	struct	qe_softc ssc;
    140  1.37     ragge 	struct	qe_softc *sc = &ssc;
    141   1.7     ragge 	struct	uba_attach_args *ua = aux;
    142  1.67      matt 	struct	uba_softc *uh = device_private(parent);
    143  1.48     ragge 	struct ubinfo ui;
    144  1.37     ragge 
    145  1.51     ragge #define	PROBESIZE	4096
    146  1.51     ragge 	struct qe_ring *ring;
    147  1.21     ragge 	struct	qe_ring *rp;
    148  1.37     ragge 	int error;
    149   1.1     ragge 
    150  1.67      matt 	ring = malloc(PROBESIZE, M_TEMP, M_WAITOK|M_ZERO);
    151  1.69    cegger 	memset(sc, 0, sizeof(*sc));
    152  1.37     ragge 	sc->sc_iot = ua->ua_iot;
    153  1.37     ragge 	sc->sc_ioh = ua->ua_ioh;
    154  1.37     ragge 	sc->sc_dmat = ua->ua_dmat;
    155   1.7     ragge 
    156  1.67      matt 	uh->uh_lastiv -= 4;
    157  1.37     ragge 	QE_WCSR(QE_CSR_CSR, QE_RESET);
    158  1.67      matt 	QE_WCSR(QE_CSR_VECTOR, uh->uh_lastiv);
    159   1.1     ragge 
    160   1.1     ragge 	/*
    161  1.59    simonb 	 * Map the ring area. Actually this is done only to be able to
    162  1.37     ragge 	 * send and receive a internal packet; some junk is loopbacked
    163  1.37     ragge 	 * so that the DEQNA has a reason to interrupt.
    164   1.1     ragge 	 */
    165  1.48     ragge 	ui.ui_size = PROBESIZE;
    166  1.62  christos 	ui.ui_vaddr = (void *)&ring[0];
    167  1.67      matt 	if ((error = uballoc(uh, &ui, UBA_CANTWAIT)))
    168  1.37     ragge 		return 0;
    169   1.1     ragge 
    170   1.1     ragge 	/*
    171  1.37     ragge 	 * Init a simple "fake" receive and transmit descriptor that
    172  1.37     ragge 	 * points to some unused area. Send a fake setup packet.
    173   1.1     ragge 	 */
    174  1.48     ragge 	rp = (void *)ui.ui_baddr;
    175  1.37     ragge 	ring[0].qe_flag = ring[0].qe_status1 = QE_NOTYET;
    176  1.37     ragge 	ring[0].qe_addr_lo = LOWORD(&rp[4]);
    177  1.37     ragge 	ring[0].qe_addr_hi = HIWORD(&rp[4]) | QE_VALID | QE_EOMSG | QE_SETUP;
    178  1.51     ragge 	ring[0].qe_buf_len = -64;
    179   1.1     ragge 
    180  1.37     ragge 	ring[2].qe_flag = ring[2].qe_status1 = QE_NOTYET;
    181  1.37     ragge 	ring[2].qe_addr_lo = LOWORD(&rp[4]);
    182  1.37     ragge 	ring[2].qe_addr_hi = HIWORD(&rp[4]) | QE_VALID;
    183  1.51     ragge 	ring[2].qe_buf_len = -(1500/2);
    184   1.1     ragge 
    185  1.37     ragge 	QE_WCSR(QE_CSR_CSR, QE_RCSR(QE_CSR_CSR) & ~QE_RESET);
    186  1.37     ragge 	DELAY(1000);
    187   1.1     ragge 
    188   1.1     ragge 	/*
    189   1.1     ragge 	 * Start the interface and wait for the packet.
    190   1.1     ragge 	 */
    191  1.37     ragge 	QE_WCSR(QE_CSR_CSR, QE_INT_ENABLE|QE_XMIT_INT|QE_RCV_INT);
    192  1.37     ragge 	QE_WCSR(QE_CSR_RCLL, LOWORD(&rp[2]));
    193  1.37     ragge 	QE_WCSR(QE_CSR_RCLH, HIWORD(&rp[2]));
    194  1.37     ragge 	QE_WCSR(QE_CSR_XMTL, LOWORD(rp));
    195  1.37     ragge 	QE_WCSR(QE_CSR_XMTH, HIWORD(rp));
    196   1.1     ragge 	DELAY(10000);
    197  1.37     ragge 
    198   1.1     ragge 	/*
    199   1.1     ragge 	 * All done with the bus resources.
    200   1.1     ragge 	 */
    201  1.67      matt 	ubfree(uh, &ui);
    202  1.51     ragge 	free(ring, M_TEMP);
    203   1.7     ragge 	return 1;
    204   1.1     ragge }
    205   1.1     ragge 
    206   1.1     ragge /*
    207   1.1     ragge  * Interface exists: make available by filling in network interface
    208   1.1     ragge  * record.  System will initialize the interface when it is ready
    209   1.1     ragge  * to accept packets.
    210   1.1     ragge  */
    211   1.7     ragge void
    212  1.67      matt qeattach(device_t parent, device_t self, void *aux)
    213   1.7     ragge {
    214  1.67      matt 	struct uba_attach_args *ua = aux;
    215  1.67      matt 	struct qe_softc *sc = device_private(self);
    216  1.67      matt 	struct ifnet *ifp = &sc->sc_if;
    217  1.67      matt 	struct qe_ring *rp;
    218  1.37     ragge 	u_int8_t enaddr[ETHER_ADDR_LEN];
    219  1.48     ragge 	int i, error;
    220  1.57    bouyer 	char *nullbuf;
    221  1.37     ragge 
    222  1.67      matt 	sc->sc_dev = self;
    223  1.67      matt 	sc->sc_uh = device_private(parent);
    224  1.37     ragge 	sc->sc_iot = ua->ua_iot;
    225  1.37     ragge 	sc->sc_ioh = ua->ua_ioh;
    226  1.37     ragge 	sc->sc_dmat = ua->ua_dmat;
    227  1.37     ragge 
    228  1.59    simonb 	/*
    229  1.59    simonb 	 * Allocate DMA safe memory for descriptors and setup memory.
    230  1.59    simonb 	 */
    231  1.37     ragge 
    232  1.57    bouyer 	sc->sc_ui.ui_size = sizeof(struct qe_cdata) + ETHER_PAD_LEN;
    233  1.67      matt 	if ((error = ubmemalloc(sc->sc_uh, &sc->sc_ui, 0))) {
    234  1.67      matt 		aprint_error(": unable to ubmemalloc(), error = %d\n", error);
    235  1.48     ragge 		return;
    236  1.37     ragge 	}
    237  1.48     ragge 	sc->sc_pqedata = (struct qe_cdata *)sc->sc_ui.ui_baddr;
    238  1.48     ragge 	sc->sc_qedata = (struct qe_cdata *)sc->sc_ui.ui_vaddr;
    239  1.37     ragge 
    240  1.37     ragge 	/*
    241  1.37     ragge 	 * Zero the newly allocated memory.
    242  1.37     ragge 	 */
    243  1.69    cegger 	memset(sc->sc_qedata, 0, sizeof(struct qe_cdata) + ETHER_PAD_LEN);
    244  1.57    bouyer 	nullbuf = ((char*)sc->sc_qedata) + sizeof(struct qe_cdata);
    245  1.37     ragge 	/*
    246  1.37     ragge 	 * Create the transmit descriptor DMA maps. We take advantage
    247  1.59    simonb 	 * of the fact that the Qbus address space is big, and therefore
    248  1.37     ragge 	 * allocate map registers for all transmit descriptors also,
    249  1.37     ragge 	 * so that we can avoid this each time we send a packet.
    250  1.37     ragge 	 */
    251  1.37     ragge 	for (i = 0; i < TXDESCS; i++) {
    252  1.37     ragge 		if ((error = bus_dmamap_create(sc->sc_dmat, MCLBYTES,
    253  1.37     ragge 		    1, MCLBYTES, 0, BUS_DMA_NOWAIT|BUS_DMA_ALLOCNOW,
    254  1.37     ragge 		    &sc->sc_xmtmap[i]))) {
    255  1.67      matt 			aprint_error(
    256  1.67      matt 			    ": unable to create tx DMA map %d, error = %d\n",
    257  1.37     ragge 			    i, error);
    258  1.37     ragge 			goto fail_4;
    259  1.37     ragge 		}
    260  1.37     ragge 	}
    261  1.37     ragge 
    262  1.37     ragge 	/*
    263  1.37     ragge 	 * Create receive buffer DMA maps.
    264  1.37     ragge 	 */
    265  1.37     ragge 	for (i = 0; i < RXDESCS; i++) {
    266  1.37     ragge 		if ((error = bus_dmamap_create(sc->sc_dmat, MCLBYTES, 1,
    267  1.37     ragge 		    MCLBYTES, 0, BUS_DMA_NOWAIT,
    268  1.37     ragge 		    &sc->sc_rcvmap[i]))) {
    269  1.67      matt 			aprint_error(
    270  1.67      matt 			    ": unable to create rx DMA map %d, error = %d\n",
    271  1.37     ragge 			    i, error);
    272  1.37     ragge 			goto fail_5;
    273  1.37     ragge 		}
    274  1.37     ragge 	}
    275  1.37     ragge 	/*
    276  1.37     ragge 	 * Pre-allocate the receive buffers.
    277  1.37     ragge 	 */
    278  1.37     ragge 	for (i = 0; i < RXDESCS; i++) {
    279  1.37     ragge 		if ((error = qe_add_rxbuf(sc, i)) != 0) {
    280  1.67      matt 			aprint_error(
    281  1.67      matt 			    ": unable to allocate or map rx buffer %d,"
    282  1.37     ragge 			    " error = %d\n", i, error);
    283  1.37     ragge 			goto fail_6;
    284  1.37     ragge 		}
    285  1.37     ragge 	}
    286   1.1     ragge 
    287  1.57    bouyer 	if ((error = bus_dmamap_create(sc->sc_dmat, ETHER_PAD_LEN, 1,
    288  1.57    bouyer 	    ETHER_PAD_LEN, 0, BUS_DMA_NOWAIT,&sc->sc_nulldmamap)) != 0) {
    289  1.67      matt 		aprint_error(
    290  1.67      matt 		    ": unable to create pad buffer DMA map, error = %d\n",
    291  1.67      matt 		    error);
    292  1.57    bouyer 		goto fail_6;
    293  1.57    bouyer 	}
    294  1.57    bouyer 	if ((error = bus_dmamap_load(sc->sc_dmat, sc->sc_nulldmamap,
    295  1.57    bouyer 	    nullbuf, ETHER_PAD_LEN, NULL, BUS_DMA_NOWAIT)) != 0) {
    296  1.67      matt 		aprint_error(
    297  1.67      matt 		    ": unable to load pad buffer DMA map, error = %d\n",
    298  1.67      matt 		    error);
    299  1.57    bouyer 		goto fail_7;
    300  1.57    bouyer 	}
    301  1.57    bouyer 	bus_dmamap_sync(sc->sc_dmat, sc->sc_nulldmamap, 0, ETHER_PAD_LEN,
    302  1.57    bouyer 	    BUS_DMASYNC_PREWRITE);
    303  1.57    bouyer 
    304   1.1     ragge 	/*
    305  1.37     ragge 	 * Create ring loops of the buffer chains.
    306  1.37     ragge 	 * This is only done once.
    307   1.1     ragge 	 */
    308  1.37     ragge 
    309  1.37     ragge 	rp = sc->sc_qedata->qc_recv;
    310  1.37     ragge 	rp[RXDESCS].qe_addr_lo = LOWORD(&sc->sc_pqedata->qc_recv[0]);
    311  1.37     ragge 	rp[RXDESCS].qe_addr_hi = HIWORD(&sc->sc_pqedata->qc_recv[0]) |
    312  1.37     ragge 	    QE_VALID | QE_CHAIN;
    313  1.37     ragge 	rp[RXDESCS].qe_flag = rp[RXDESCS].qe_status1 = QE_NOTYET;
    314  1.37     ragge 
    315  1.37     ragge 	rp = sc->sc_qedata->qc_xmit;
    316  1.37     ragge 	rp[TXDESCS].qe_addr_lo = LOWORD(&sc->sc_pqedata->qc_xmit[0]);
    317  1.37     ragge 	rp[TXDESCS].qe_addr_hi = HIWORD(&sc->sc_pqedata->qc_xmit[0]) |
    318  1.37     ragge 	    QE_VALID | QE_CHAIN;
    319  1.37     ragge 	rp[TXDESCS].qe_flag = rp[TXDESCS].qe_status1 = QE_NOTYET;
    320   1.1     ragge 
    321   1.1     ragge 	/*
    322  1.37     ragge 	 * Get the vector that were set at match time, and remember it.
    323   1.1     ragge 	 */
    324  1.67      matt 	sc->sc_intvec = sc->sc_uh->uh_lastiv;
    325  1.37     ragge 	QE_WCSR(QE_CSR_CSR, QE_RESET);
    326  1.37     ragge 	DELAY(1000);
    327  1.37     ragge 	QE_WCSR(QE_CSR_CSR, QE_RCSR(QE_CSR_CSR) & ~QE_RESET);
    328   1.1     ragge 
    329   1.1     ragge 	/*
    330  1.37     ragge 	 * Read out ethernet address and tell which type this card is.
    331   1.1     ragge 	 */
    332  1.37     ragge 	for (i = 0; i < 6; i++)
    333  1.37     ragge 		enaddr[i] = QE_RCSR(i * 2) & 0xff;
    334   1.1     ragge 
    335  1.37     ragge 	QE_WCSR(QE_CSR_VECTOR, sc->sc_intvec | 1);
    336  1.67      matt 	aprint_normal(": %s, hardware address %s\n",
    337  1.37     ragge 		QE_RCSR(QE_CSR_VECTOR) & 1 ? "delqa":"deqna",
    338  1.37     ragge 		ether_sprintf(enaddr));
    339  1.37     ragge 
    340  1.37     ragge 	QE_WCSR(QE_CSR_VECTOR, QE_RCSR(QE_CSR_VECTOR) & ~1); /* ??? */
    341  1.37     ragge 
    342  1.41      matt 	uba_intr_establish(ua->ua_icookie, ua->ua_cvec, qeintr,
    343  1.41      matt 		sc, &sc->sc_intrcnt);
    344  1.42      matt 	evcnt_attach_dynamic(&sc->sc_intrcnt, EVCNT_TYPE_INTR, ua->ua_evcnt,
    345  1.67      matt 		device_xname(sc->sc_dev), "intr");
    346  1.39      matt 
    347  1.67      matt 	strcpy(ifp->if_xname, device_xname(sc->sc_dev));
    348  1.37     ragge 	ifp->if_softc = sc;
    349  1.37     ragge 	ifp->if_flags = IFF_BROADCAST | IFF_SIMPLEX | IFF_MULTICAST;
    350   1.1     ragge 	ifp->if_start = qestart;
    351   1.1     ragge 	ifp->if_ioctl = qeioctl;
    352  1.38     ragge 	ifp->if_watchdog = qetimeout;
    353  1.45   thorpej 	IFQ_SET_READY(&ifp->if_snd);
    354  1.37     ragge 
    355  1.37     ragge 	/*
    356  1.37     ragge 	 * Attach the interface.
    357  1.37     ragge 	 */
    358   1.1     ragge 	if_attach(ifp);
    359  1.37     ragge 	ether_ifattach(ifp, enaddr);
    360  1.22     ragge 
    361  1.37     ragge 	return;
    362   1.1     ragge 
    363  1.37     ragge 	/*
    364  1.37     ragge 	 * Free any resources we've allocated during the failed attach
    365  1.37     ragge 	 * attempt.  Do this in reverse order and fall through.
    366  1.37     ragge 	 */
    367  1.57    bouyer  fail_7:
    368  1.57    bouyer 	bus_dmamap_destroy(sc->sc_dmat, sc->sc_nulldmamap);
    369  1.37     ragge  fail_6:
    370  1.37     ragge 	for (i = 0; i < RXDESCS; i++) {
    371  1.37     ragge 		if (sc->sc_rxmbuf[i] != NULL) {
    372  1.57    bouyer 			bus_dmamap_unload(sc->sc_dmat, sc->sc_rcvmap[i]);
    373  1.37     ragge 			m_freem(sc->sc_rxmbuf[i]);
    374  1.37     ragge 		}
    375  1.37     ragge 	}
    376  1.37     ragge  fail_5:
    377  1.37     ragge 	for (i = 0; i < RXDESCS; i++) {
    378  1.37     ragge 		if (sc->sc_xmtmap[i] != NULL)
    379  1.37     ragge 			bus_dmamap_destroy(sc->sc_dmat, sc->sc_xmtmap[i]);
    380  1.37     ragge 	}
    381  1.37     ragge  fail_4:
    382  1.37     ragge 	for (i = 0; i < TXDESCS; i++) {
    383  1.37     ragge 		if (sc->sc_rcvmap[i] != NULL)
    384  1.37     ragge 			bus_dmamap_destroy(sc->sc_dmat, sc->sc_rcvmap[i]);
    385  1.37     ragge 	}
    386   1.1     ragge }
    387   1.1     ragge 
    388   1.1     ragge /*
    389   1.1     ragge  * Initialization of interface.
    390   1.1     ragge  */
    391   1.7     ragge void
    392  1.46     ragge qeinit(struct qe_softc *sc)
    393   1.1     ragge {
    394  1.37     ragge 	struct ifnet *ifp = (struct ifnet *)&sc->sc_if;
    395  1.37     ragge 	struct qe_cdata *qc = sc->sc_qedata;
    396   1.4     ragge 	int i;
    397   1.1     ragge 
    398   1.1     ragge 
    399  1.37     ragge 	/*
    400  1.37     ragge 	 * Reset the interface.
    401  1.37     ragge 	 */
    402  1.37     ragge 	QE_WCSR(QE_CSR_CSR, QE_RESET);
    403  1.37     ragge 	DELAY(1000);
    404  1.37     ragge 	QE_WCSR(QE_CSR_CSR, QE_RCSR(QE_CSR_CSR) & ~QE_RESET);
    405  1.37     ragge 	QE_WCSR(QE_CSR_VECTOR, sc->sc_intvec);
    406  1.37     ragge 
    407  1.37     ragge 	sc->sc_nexttx = sc->sc_inq = sc->sc_lastack = 0;
    408  1.37     ragge 	/*
    409  1.37     ragge 	 * Release and init transmit descriptors.
    410  1.37     ragge 	 */
    411  1.37     ragge 	for (i = 0; i < TXDESCS; i++) {
    412  1.37     ragge 		if (sc->sc_txmbuf[i]) {
    413  1.37     ragge 			bus_dmamap_unload(sc->sc_dmat, sc->sc_xmtmap[i]);
    414  1.37     ragge 			m_freem(sc->sc_txmbuf[i]);
    415  1.37     ragge 			sc->sc_txmbuf[i] = 0;
    416   1.1     ragge 		}
    417  1.37     ragge 		qc->qc_xmit[i].qe_addr_hi = 0; /* Clear valid bit */
    418  1.37     ragge 		qc->qc_xmit[i].qe_status1 = qc->qc_xmit[i].qe_flag = QE_NOTYET;
    419   1.1     ragge 	}
    420  1.37     ragge 
    421  1.37     ragge 
    422  1.37     ragge 	/*
    423  1.37     ragge 	 * Init receive descriptors.
    424  1.37     ragge 	 */
    425  1.37     ragge 	for (i = 0; i < RXDESCS; i++)
    426  1.37     ragge 		qc->qc_recv[i].qe_status1 = qc->qc_recv[i].qe_flag = QE_NOTYET;
    427  1.37     ragge 	sc->sc_nextrx = 0;
    428  1.37     ragge 
    429  1.37     ragge 	/*
    430  1.37     ragge 	 * Write the descriptor addresses to the device.
    431  1.37     ragge 	 * Receiving packets will be enabled in the interrupt routine.
    432  1.37     ragge 	 */
    433  1.37     ragge 	QE_WCSR(QE_CSR_CSR, QE_INT_ENABLE|QE_XMIT_INT|QE_RCV_INT);
    434  1.37     ragge 	QE_WCSR(QE_CSR_RCLL, LOWORD(sc->sc_pqedata->qc_recv));
    435  1.37     ragge 	QE_WCSR(QE_CSR_RCLH, HIWORD(sc->sc_pqedata->qc_recv));
    436  1.37     ragge 
    437  1.37     ragge 	ifp->if_flags |= IFF_RUNNING;
    438  1.37     ragge 	ifp->if_flags &= ~IFF_OACTIVE;
    439  1.37     ragge 
    440   1.1     ragge 	/*
    441  1.37     ragge 	 * Send a setup frame.
    442  1.37     ragge 	 * This will start the transmit machinery as well.
    443   1.1     ragge 	 */
    444  1.37     ragge 	qe_setup(sc);
    445  1.37     ragge 
    446   1.1     ragge }
    447   1.1     ragge 
    448   1.1     ragge /*
    449   1.1     ragge  * Start output on interface.
    450   1.1     ragge  */
    451   1.2   mycroft void
    452  1.46     ragge qestart(struct ifnet *ifp)
    453   1.1     ragge {
    454  1.37     ragge 	struct qe_softc *sc = ifp->if_softc;
    455  1.37     ragge 	struct qe_cdata *qc = sc->sc_qedata;
    456  1.37     ragge 	paddr_t	buffer;
    457  1.37     ragge 	struct mbuf *m, *m0;
    458  1.57    bouyer 	int idx, len, s, i, totlen, buflen, error;
    459  1.46     ragge 	short orword, csr;
    460  1.37     ragge 
    461  1.37     ragge 	if ((QE_RCSR(QE_CSR_CSR) & QE_RCV_ENABLE) == 0)
    462  1.37     ragge 		return;
    463   1.1     ragge 
    464  1.47   thorpej 	s = splnet();
    465  1.37     ragge 	while (sc->sc_inq < (TXDESCS - 1)) {
    466   1.1     ragge 
    467  1.37     ragge 		if (sc->sc_setup) {
    468  1.37     ragge 			qe_setup(sc);
    469  1.37     ragge 			continue;
    470  1.37     ragge 		}
    471  1.37     ragge 		idx = sc->sc_nexttx;
    472  1.45   thorpej 		IFQ_POLL(&ifp->if_snd, m);
    473  1.37     ragge 		if (m == 0)
    474  1.37     ragge 			goto out;
    475  1.37     ragge 		/*
    476  1.37     ragge 		 * Count number of mbufs in chain.
    477  1.37     ragge 		 * Always do DMA directly from mbufs, therefore the transmit
    478  1.37     ragge 		 * ring is really big.
    479  1.37     ragge 		 */
    480  1.37     ragge 		for (m0 = m, i = 0; m0; m0 = m0->m_next)
    481  1.38     ragge 			if (m0->m_len)
    482  1.38     ragge 				i++;
    483  1.57    bouyer 		if (m->m_pkthdr.len < ETHER_PAD_LEN) {
    484  1.57    bouyer 			buflen = ETHER_PAD_LEN;
    485  1.57    bouyer 			i++;
    486  1.57    bouyer 		} else
    487  1.57    bouyer 			buflen = m->m_pkthdr.len;
    488  1.37     ragge 		if (i >= TXDESCS)
    489  1.37     ragge 			panic("qestart");
    490  1.37     ragge 
    491  1.37     ragge 		if ((i + sc->sc_inq) >= (TXDESCS - 1)) {
    492  1.38     ragge 			ifp->if_flags |= IFF_OACTIVE;
    493  1.37     ragge 			goto out;
    494  1.37     ragge 		}
    495  1.45   thorpej 
    496  1.45   thorpej 		IFQ_DEQUEUE(&ifp->if_snd, m);
    497  1.45   thorpej 
    498  1.22     ragge #if NBPFILTER > 0
    499  1.37     ragge 		if (ifp->if_bpf)
    500  1.37     ragge 			bpf_mtap(ifp->if_bpf, m);
    501  1.22     ragge #endif
    502   1.1     ragge 		/*
    503  1.37     ragge 		 * m now points to a mbuf chain that can be loaded.
    504  1.37     ragge 		 * Loop around and set it.
    505   1.1     ragge 		 */
    506  1.38     ragge 		totlen = 0;
    507  1.57    bouyer 		for (m0 = m; ; m0 = m0->m_next) {
    508  1.57    bouyer 			if (m0) {
    509  1.57    bouyer 				if (m0->m_len == 0)
    510  1.57    bouyer 					continue;
    511  1.57    bouyer 				error = bus_dmamap_load(sc->sc_dmat,
    512  1.57    bouyer 				    sc->sc_xmtmap[idx], mtod(m0, void *),
    513  1.57    bouyer 				    m0->m_len, 0, 0);
    514  1.57    bouyer 				buffer = sc->sc_xmtmap[idx]->dm_segs[0].ds_addr;
    515  1.57    bouyer 				len = m0->m_len;
    516  1.57    bouyer 			} else if (totlen < ETHER_PAD_LEN) {
    517  1.57    bouyer 				buffer = sc->sc_nulldmamap->dm_segs[0].ds_addr;
    518  1.57    bouyer 				len = ETHER_PAD_LEN - totlen;
    519  1.57    bouyer 			} else {
    520  1.57    bouyer 				break;
    521  1.57    bouyer 			}
    522  1.37     ragge 
    523  1.38     ragge 			totlen += len;
    524  1.37     ragge 			/* Word alignment calc */
    525  1.37     ragge 			orword = 0;
    526  1.57    bouyer 			if (totlen == buflen) {
    527  1.37     ragge 				orword |= QE_EOMSG;
    528  1.38     ragge 				sc->sc_txmbuf[idx] = m;
    529  1.37     ragge 			}
    530  1.37     ragge 			if ((buffer & 1) || (len & 1))
    531  1.37     ragge 				len += 2;
    532  1.37     ragge 			if (buffer & 1)
    533  1.37     ragge 				orword |= QE_ODDBEGIN;
    534  1.37     ragge 			if ((buffer + len) & 1)
    535  1.37     ragge 				orword |= QE_ODDEND;
    536  1.37     ragge 			qc->qc_xmit[idx].qe_buf_len = -(len/2);
    537  1.37     ragge 			qc->qc_xmit[idx].qe_addr_lo = LOWORD(buffer);
    538  1.37     ragge 			qc->qc_xmit[idx].qe_addr_hi = HIWORD(buffer);
    539  1.37     ragge 			qc->qc_xmit[idx].qe_flag =
    540  1.37     ragge 			    qc->qc_xmit[idx].qe_status1 = QE_NOTYET;
    541  1.37     ragge 			qc->qc_xmit[idx].qe_addr_hi |= (QE_VALID | orword);
    542  1.37     ragge 			if (++idx == TXDESCS)
    543  1.37     ragge 				idx = 0;
    544  1.37     ragge 			sc->sc_inq++;
    545  1.57    bouyer 			if (m0 == NULL)
    546  1.57    bouyer 				break;
    547  1.37     ragge 		}
    548  1.38     ragge #ifdef DIAGNOSTIC
    549  1.57    bouyer 		if (totlen != buflen)
    550  1.38     ragge 			panic("qestart: len fault");
    551  1.38     ragge #endif
    552  1.37     ragge 
    553  1.37     ragge 		/*
    554  1.37     ragge 		 * Kick off the transmit logic, if it is stopped.
    555  1.37     ragge 		 */
    556  1.46     ragge 		csr = QE_RCSR(QE_CSR_CSR);
    557  1.46     ragge 		if (csr & QE_XL_INVALID) {
    558  1.37     ragge 			QE_WCSR(QE_CSR_XMTL,
    559  1.37     ragge 			    LOWORD(&sc->sc_pqedata->qc_xmit[sc->sc_nexttx]));
    560  1.37     ragge 			QE_WCSR(QE_CSR_XMTH,
    561  1.37     ragge 			    HIWORD(&sc->sc_pqedata->qc_xmit[sc->sc_nexttx]));
    562  1.37     ragge 		}
    563  1.37     ragge 		sc->sc_nexttx = idx;
    564  1.37     ragge 	}
    565  1.37     ragge 	if (sc->sc_inq == (TXDESCS - 1))
    566  1.37     ragge 		ifp->if_flags |= IFF_OACTIVE;
    567  1.38     ragge 
    568  1.38     ragge out:	if (sc->sc_inq)
    569  1.38     ragge 		ifp->if_timer = 5; /* If transmit logic dies */
    570  1.38     ragge 	splx(s);
    571   1.1     ragge }
    572   1.1     ragge 
    573  1.39      matt static void
    574  1.46     ragge qeintr(void *arg)
    575   1.1     ragge {
    576  1.39      matt 	struct qe_softc *sc = arg;
    577  1.37     ragge 	struct qe_cdata *qc = sc->sc_qedata;
    578  1.37     ragge 	struct ifnet *ifp = &sc->sc_if;
    579  1.37     ragge 	struct mbuf *m;
    580  1.37     ragge 	int csr, status1, status2, len;
    581   1.1     ragge 
    582  1.37     ragge 	csr = QE_RCSR(QE_CSR_CSR);
    583   1.1     ragge 
    584  1.37     ragge 	QE_WCSR(QE_CSR_CSR, QE_RCV_ENABLE | QE_INT_ENABLE | QE_XMIT_INT |
    585  1.37     ragge 	    QE_RCV_INT | QE_ILOOP);
    586   1.1     ragge 
    587  1.37     ragge 	if (csr & QE_RCV_INT)
    588  1.37     ragge 		while (qc->qc_recv[sc->sc_nextrx].qe_status1 != QE_NOTYET) {
    589  1.37     ragge 			status1 = qc->qc_recv[sc->sc_nextrx].qe_status1;
    590  1.37     ragge 			status2 = qc->qc_recv[sc->sc_nextrx].qe_status2;
    591  1.46     ragge 
    592  1.37     ragge 			m = sc->sc_rxmbuf[sc->sc_nextrx];
    593  1.37     ragge 			len = ((status1 & QE_RBL_HI) |
    594  1.37     ragge 			    (status2 & QE_RBL_LO)) + 60;
    595  1.37     ragge 			qe_add_rxbuf(sc, sc->sc_nextrx);
    596  1.37     ragge 			m->m_pkthdr.rcvif = ifp;
    597  1.37     ragge 			m->m_pkthdr.len = m->m_len = len;
    598  1.37     ragge 			if (++sc->sc_nextrx == RXDESCS)
    599  1.37     ragge 				sc->sc_nextrx = 0;
    600  1.37     ragge #if NBPFILTER > 0
    601  1.43   thorpej 			if (ifp->if_bpf)
    602  1.37     ragge 				bpf_mtap(ifp->if_bpf, m);
    603  1.37     ragge #endif
    604  1.46     ragge 			if ((status1 & QE_ESETUP) == 0)
    605  1.46     ragge 				(*ifp->if_input)(ifp, m);
    606  1.46     ragge 			else
    607  1.46     ragge 				m_freem(m);
    608   1.1     ragge 		}
    609  1.37     ragge 
    610  1.46     ragge 	if (csr & (QE_XMIT_INT|QE_XL_INVALID)) {
    611  1.37     ragge 		while (qc->qc_xmit[sc->sc_lastack].qe_status1 != QE_NOTYET) {
    612  1.37     ragge 			int idx = sc->sc_lastack;
    613  1.37     ragge 
    614  1.37     ragge 			sc->sc_inq--;
    615  1.37     ragge 			if (++sc->sc_lastack == TXDESCS)
    616  1.37     ragge 				sc->sc_lastack = 0;
    617  1.37     ragge 
    618  1.37     ragge 			/* XXX collect statistics */
    619  1.37     ragge 			qc->qc_xmit[idx].qe_addr_hi &= ~QE_VALID;
    620  1.37     ragge 			qc->qc_xmit[idx].qe_status1 =
    621  1.37     ragge 			    qc->qc_xmit[idx].qe_flag = QE_NOTYET;
    622  1.37     ragge 
    623  1.37     ragge 			if (qc->qc_xmit[idx].qe_addr_hi & QE_SETUP)
    624  1.37     ragge 				continue;
    625  1.57    bouyer 			if (sc->sc_txmbuf[idx] == NULL ||
    626  1.57    bouyer 			    sc->sc_txmbuf[idx]->m_pkthdr.len < ETHER_PAD_LEN)
    627  1.57    bouyer 				bus_dmamap_unload(sc->sc_dmat,
    628  1.57    bouyer 				    sc->sc_xmtmap[idx]);
    629  1.37     ragge 			if (sc->sc_txmbuf[idx]) {
    630  1.37     ragge 				m_freem(sc->sc_txmbuf[idx]);
    631  1.57    bouyer 				sc->sc_txmbuf[idx] = NULL;
    632  1.37     ragge 			}
    633  1.37     ragge 		}
    634  1.38     ragge 		ifp->if_timer = 0;
    635  1.37     ragge 		ifp->if_flags &= ~IFF_OACTIVE;
    636  1.37     ragge 		qestart(ifp); /* Put in more in queue */
    637   1.1     ragge 	}
    638  1.37     ragge 	/*
    639  1.37     ragge 	 * How can the receive list get invalid???
    640  1.37     ragge 	 * Verified that it happens anyway.
    641   1.1     ragge 	 */
    642  1.37     ragge 	if ((qc->qc_recv[sc->sc_nextrx].qe_status1 == QE_NOTYET) &&
    643  1.37     ragge 	    (QE_RCSR(QE_CSR_CSR) & QE_RL_INVALID)) {
    644  1.37     ragge 		QE_WCSR(QE_CSR_RCLL,
    645  1.37     ragge 		    LOWORD(&sc->sc_pqedata->qc_recv[sc->sc_nextrx]));
    646  1.37     ragge 		QE_WCSR(QE_CSR_RCLH,
    647  1.37     ragge 		    HIWORD(&sc->sc_pqedata->qc_recv[sc->sc_nextrx]));
    648   1.1     ragge 	}
    649   1.1     ragge }
    650   1.1     ragge 
    651   1.1     ragge /*
    652   1.1     ragge  * Process an ioctl request.
    653   1.1     ragge  */
    654   1.7     ragge int
    655  1.62  christos qeioctl(struct ifnet *ifp, u_long cmd, void *data)
    656   1.1     ragge {
    657  1.14   thorpej 	struct qe_softc *sc = ifp->if_softc;
    658   1.1     ragge 	struct ifaddr *ifa = (struct ifaddr *)data;
    659   1.8   mycroft 	int s = splnet(), error = 0;
    660   1.1     ragge 
    661   1.1     ragge 	switch (cmd) {
    662   1.1     ragge 
    663  1.68    dyoung 	case SIOCINITIFADDR:
    664   1.1     ragge 		ifp->if_flags |= IFF_UP;
    665   1.1     ragge 		switch(ifa->ifa_addr->sa_family) {
    666   1.1     ragge #ifdef INET
    667   1.1     ragge 		case AF_INET:
    668  1.37     ragge 			qeinit(sc);
    669  1.20        is 			arp_ifinit(ifp, ifa);
    670   1.1     ragge 			break;
    671   1.1     ragge #endif
    672   1.1     ragge 		}
    673   1.1     ragge 		break;
    674   1.1     ragge 
    675   1.1     ragge 	case SIOCSIFFLAGS:
    676  1.68    dyoung 		if ((error = ifioctl_common(ifp, cmd, data)) != 0)
    677  1.68    dyoung 			break;
    678  1.68    dyoung 		/* XXX re-use ether_ioctl() */
    679  1.68    dyoung 		switch (ifp->if_flags & (IFF_UP|IFF_RUNNING)) {
    680  1.68    dyoung 		case IFF_RUNNING:
    681  1.37     ragge 			/*
    682  1.37     ragge 			 * If interface is marked down and it is running,
    683  1.37     ragge 			 * stop it. (by disabling receive mechanism).
    684  1.37     ragge 			 */
    685  1.37     ragge 			QE_WCSR(QE_CSR_CSR,
    686  1.37     ragge 			    QE_RCSR(QE_CSR_CSR) & ~QE_RCV_ENABLE);
    687  1.37     ragge 			ifp->if_flags &= ~IFF_RUNNING;
    688  1.68    dyoung 			break;
    689  1.68    dyoung 		case IFF_UP:
    690  1.37     ragge 			/*
    691  1.37     ragge 			 * If interface it marked up and it is stopped, then
    692  1.37     ragge 			 * start it.
    693  1.37     ragge 			 */
    694  1.19     ragge 			qeinit(sc);
    695  1.68    dyoung 			break;
    696  1.68    dyoung 		case IFF_UP|IFF_RUNNING:
    697  1.37     ragge 			/*
    698  1.37     ragge 			 * Send a new setup packet to match any new changes.
    699  1.37     ragge 			 * (Like IFF_PROMISC etc)
    700  1.37     ragge 			 */
    701  1.37     ragge 			qe_setup(sc);
    702  1.68    dyoung 			break;
    703  1.68    dyoung 		case 0:
    704  1.68    dyoung 			break;
    705  1.37     ragge 		}
    706   1.1     ragge 		break;
    707   1.1     ragge 
    708  1.22     ragge 	case SIOCADDMULTI:
    709  1.22     ragge 	case SIOCDELMULTI:
    710  1.22     ragge 		/*
    711  1.22     ragge 		 * Update our multicast list.
    712  1.22     ragge 		 */
    713  1.63    dyoung 		if ((error = ether_ioctl(ifp, cmd, data)) == ENETRESET) {
    714  1.22     ragge 			/*
    715  1.22     ragge 			 * Multicast list has changed; set the hardware filter
    716  1.22     ragge 			 * accordingly.
    717  1.22     ragge 			 */
    718  1.58   thorpej 			if (ifp->if_flags & IFF_RUNNING)
    719  1.58   thorpej 				qe_setup(sc);
    720  1.22     ragge 			error = 0;
    721  1.22     ragge 		}
    722  1.22     ragge 		break;
    723  1.22     ragge 
    724   1.1     ragge 	default:
    725  1.68    dyoung 		error = ether_ioctl(ifp, cmd, data);
    726   1.1     ragge 	}
    727   1.1     ragge 	splx(s);
    728   1.1     ragge 	return (error);
    729   1.1     ragge }
    730   1.1     ragge 
    731   1.1     ragge /*
    732  1.37     ragge  * Add a receive buffer to the indicated descriptor.
    733   1.1     ragge  */
    734  1.37     ragge int
    735  1.59    simonb qe_add_rxbuf(struct qe_softc *sc, int i)
    736   1.1     ragge {
    737  1.37     ragge 	struct mbuf *m;
    738  1.37     ragge 	struct qe_ring *rp;
    739  1.37     ragge 	vaddr_t addr;
    740  1.37     ragge 	int error;
    741  1.37     ragge 
    742  1.37     ragge 	MGETHDR(m, M_DONTWAIT, MT_DATA);
    743  1.37     ragge 	if (m == NULL)
    744  1.37     ragge 		return (ENOBUFS);
    745  1.37     ragge 
    746  1.37     ragge 	MCLGET(m, M_DONTWAIT);
    747  1.37     ragge 	if ((m->m_flags & M_EXT) == 0) {
    748  1.37     ragge 		m_freem(m);
    749  1.37     ragge 		return (ENOBUFS);
    750  1.37     ragge 	}
    751  1.37     ragge 
    752  1.37     ragge 	if (sc->sc_rxmbuf[i] != NULL)
    753  1.37     ragge 		bus_dmamap_unload(sc->sc_dmat, sc->sc_rcvmap[i]);
    754   1.1     ragge 
    755  1.37     ragge 	error = bus_dmamap_load(sc->sc_dmat, sc->sc_rcvmap[i],
    756  1.37     ragge 	    m->m_ext.ext_buf, m->m_ext.ext_size, NULL, BUS_DMA_NOWAIT);
    757  1.37     ragge 	if (error)
    758  1.52    provos 		panic("%s: can't load rx DMA map %d, error = %d",
    759  1.67      matt 		    device_xname(sc->sc_dev), i, error);
    760  1.37     ragge 	sc->sc_rxmbuf[i] = m;
    761   1.1     ragge 
    762  1.37     ragge 	bus_dmamap_sync(sc->sc_dmat, sc->sc_rcvmap[i], 0,
    763  1.37     ragge 	    sc->sc_rcvmap[i]->dm_mapsize, BUS_DMASYNC_PREREAD);
    764   1.1     ragge 
    765   1.1     ragge 	/*
    766  1.37     ragge 	 * We know that the mbuf cluster is page aligned. Also, be sure
    767  1.37     ragge 	 * that the IP header will be longword aligned.
    768   1.1     ragge 	 */
    769  1.37     ragge 	m->m_data += 2;
    770  1.37     ragge 	addr = sc->sc_rcvmap[i]->dm_segs[0].ds_addr + 2;
    771  1.37     ragge 	rp = &sc->sc_qedata->qc_recv[i];
    772  1.37     ragge 	rp->qe_flag = rp->qe_status1 = QE_NOTYET;
    773  1.37     ragge 	rp->qe_addr_lo = LOWORD(addr);
    774  1.37     ragge 	rp->qe_addr_hi = HIWORD(addr) | QE_VALID;
    775  1.37     ragge 	rp->qe_buf_len = -(m->m_ext.ext_size - 2)/2;
    776   1.1     ragge 
    777  1.37     ragge 	return (0);
    778   1.1     ragge }
    779  1.37     ragge 
    780   1.1     ragge /*
    781  1.37     ragge  * Create a setup packet and put in queue for sending.
    782   1.1     ragge  */
    783   1.7     ragge void
    784  1.46     ragge qe_setup(struct qe_softc *sc)
    785   1.1     ragge {
    786  1.37     ragge 	struct ether_multi *enm;
    787  1.37     ragge 	struct ether_multistep step;
    788  1.37     ragge 	struct qe_cdata *qc = sc->sc_qedata;
    789  1.37     ragge 	struct ifnet *ifp = &sc->sc_if;
    790  1.66   tsutsui 	u_int8_t enaddr[ETHER_ADDR_LEN];
    791  1.37     ragge 	int i, j, k, idx, s;
    792  1.37     ragge 
    793  1.47   thorpej 	s = splnet();
    794  1.37     ragge 	if (sc->sc_inq == (TXDESCS - 1)) {
    795  1.37     ragge 		sc->sc_setup = 1;
    796  1.37     ragge 		splx(s);
    797  1.37     ragge 		return;
    798  1.37     ragge 	}
    799  1.37     ragge 	sc->sc_setup = 0;
    800   1.1     ragge 	/*
    801  1.37     ragge 	 * Init the setup packet with valid info.
    802   1.1     ragge 	 */
    803  1.37     ragge 	memset(qc->qc_setup, 0xff, sizeof(qc->qc_setup)); /* Broadcast */
    804  1.66   tsutsui 	memcpy(enaddr, CLLADDR(ifp->if_sadl), sizeof(enaddr));
    805  1.37     ragge 	for (i = 0; i < ETHER_ADDR_LEN; i++)
    806  1.37     ragge 		qc->qc_setup[i * 8 + 1] = enaddr[i]; /* Own address */
    807  1.37     ragge 
    808   1.1     ragge 	/*
    809  1.59    simonb 	 * Multicast handling. The DEQNA can handle up to 12 direct
    810  1.37     ragge 	 * ethernet addresses.
    811   1.1     ragge 	 */
    812  1.37     ragge 	j = 3; k = 0;
    813  1.37     ragge 	ifp->if_flags &= ~IFF_ALLMULTI;
    814  1.37     ragge 	ETHER_FIRST_MULTI(step, &sc->sc_ec, enm);
    815  1.37     ragge 	while (enm != NULL) {
    816  1.50       wiz 		if (memcmp(enm->enm_addrlo, enm->enm_addrhi, 6)) {
    817  1.37     ragge 			ifp->if_flags |= IFF_ALLMULTI;
    818  1.37     ragge 			break;
    819  1.37     ragge 		}
    820  1.37     ragge 		for (i = 0; i < ETHER_ADDR_LEN; i++)
    821  1.37     ragge 			qc->qc_setup[i * 8 + j + k] = enm->enm_addrlo[i];
    822  1.37     ragge 		j++;
    823  1.37     ragge 		if (j == 8) {
    824  1.37     ragge 			j = 1; k += 64;
    825  1.37     ragge 		}
    826  1.37     ragge 		if (k > 64) {
    827  1.37     ragge 			ifp->if_flags |= IFF_ALLMULTI;
    828  1.37     ragge 			break;
    829  1.22     ragge 		}
    830  1.37     ragge 		ETHER_NEXT_MULTI(step, enm);
    831  1.22     ragge 	}
    832  1.37     ragge 	idx = sc->sc_nexttx;
    833  1.37     ragge 	qc->qc_xmit[idx].qe_buf_len = -64;
    834   1.1     ragge 
    835   1.1     ragge 	/*
    836  1.37     ragge 	 * How is the DEQNA turned in ALLMULTI mode???
    837  1.37     ragge 	 * Until someone tells me, fall back to PROMISC when more than
    838  1.37     ragge 	 * 12 ethernet addresses.
    839   1.1     ragge 	 */
    840  1.43   thorpej 	if (ifp->if_flags & IFF_ALLMULTI)
    841  1.43   thorpej 		ifp->if_flags |= IFF_PROMISC;
    842  1.43   thorpej 	else if (ifp->if_pcount == 0)
    843  1.43   thorpej 		ifp->if_flags &= ~IFF_PROMISC;
    844  1.43   thorpej 	if (ifp->if_flags & IFF_PROMISC)
    845  1.37     ragge 		qc->qc_xmit[idx].qe_buf_len = -65;
    846   1.1     ragge 
    847  1.37     ragge 	qc->qc_xmit[idx].qe_addr_lo = LOWORD(sc->sc_pqedata->qc_setup);
    848  1.37     ragge 	qc->qc_xmit[idx].qe_addr_hi =
    849  1.37     ragge 	    HIWORD(sc->sc_pqedata->qc_setup) | QE_SETUP | QE_EOMSG;
    850  1.37     ragge 	qc->qc_xmit[idx].qe_status1 = qc->qc_xmit[idx].qe_flag = QE_NOTYET;
    851  1.37     ragge 	qc->qc_xmit[idx].qe_addr_hi |= QE_VALID;
    852   1.1     ragge 
    853  1.37     ragge 	if (QE_RCSR(QE_CSR_CSR) & QE_XL_INVALID) {
    854  1.37     ragge 		QE_WCSR(QE_CSR_XMTL,
    855  1.37     ragge 		    LOWORD(&sc->sc_pqedata->qc_xmit[idx]));
    856  1.37     ragge 		QE_WCSR(QE_CSR_XMTH,
    857  1.37     ragge 		    HIWORD(&sc->sc_pqedata->qc_xmit[idx]));
    858  1.22     ragge 	}
    859   1.1     ragge 
    860  1.37     ragge 	sc->sc_inq++;
    861  1.37     ragge 	if (++sc->sc_nexttx == TXDESCS)
    862  1.37     ragge 		sc->sc_nexttx = 0;
    863  1.37     ragge 	splx(s);
    864  1.38     ragge }
    865  1.38     ragge 
    866  1.38     ragge /*
    867  1.38     ragge  * Check for dead transmit logic. Not uncommon.
    868  1.38     ragge  */
    869  1.38     ragge void
    870  1.46     ragge qetimeout(struct ifnet *ifp)
    871  1.38     ragge {
    872  1.38     ragge 	struct qe_softc *sc = ifp->if_softc;
    873  1.38     ragge 
    874  1.38     ragge 	if (sc->sc_inq == 0)
    875  1.38     ragge 		return;
    876  1.38     ragge 
    877  1.67      matt 	aprint_error_dev(sc->sc_dev, "xmit logic died, resetting...\n");
    878  1.38     ragge 	/*
    879  1.38     ragge 	 * Do a reset of interface, to get it going again.
    880  1.38     ragge 	 * Will it work by just restart the transmit logic?
    881  1.38     ragge 	 */
    882  1.38     ragge 	qeinit(sc);
    883   1.1     ragge }
    884