Home | History | Annotate | Line # | Download | only in usb
usbnet.c revision 1.43
      1  1.43       mrg /*	$NetBSD: usbnet.c,v 1.43 2021/12/11 19:24:21 mrg Exp $	*/
      2   1.1       mrg 
      3   1.1       mrg /*
      4   1.1       mrg  * Copyright (c) 2019 Matthew R. Green
      5   1.1       mrg  * All rights reserved.
      6   1.1       mrg  *
      7   1.1       mrg  * Redistribution and use in source and binary forms, with or without
      8   1.1       mrg  * modification, are permitted provided that the following conditions
      9   1.1       mrg  * are met:
     10   1.1       mrg  * 1. Redistributions of source code must retain the above copyright
     11   1.1       mrg  *    notice, this list of conditions and the following disclaimer.
     12   1.1       mrg  * 2. Redistributions in binary form must reproduce the above copyright
     13   1.1       mrg  *    notice, this list of conditions and the following disclaimer in the
     14   1.1       mrg  *    documentation and/or other materials provided with the distribution.
     15   1.1       mrg  *
     16   1.1       mrg  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
     17   1.1       mrg  * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
     18   1.1       mrg  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
     19   1.1       mrg  * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
     20   1.1       mrg  * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
     21   1.1       mrg  * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
     22   1.1       mrg  * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
     23   1.1       mrg  * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
     24   1.1       mrg  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
     25   1.1       mrg  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
     26   1.1       mrg  * SUCH DAMAGE.
     27   1.1       mrg  */
     28   1.1       mrg 
     29   1.1       mrg /*
     30  1.13       mrg  * Common code shared between USB network drivers.
     31   1.1       mrg  */
     32   1.1       mrg 
     33   1.1       mrg #include <sys/cdefs.h>
     34  1.43       mrg __KERNEL_RCSID(0, "$NetBSD: usbnet.c,v 1.43 2021/12/11 19:24:21 mrg Exp $");
     35   1.1       mrg 
     36   1.1       mrg #include <sys/param.h>
     37   1.1       mrg #include <sys/kernel.h>
     38   1.1       mrg #include <sys/kmem.h>
     39   1.1       mrg #include <sys/module.h>
     40  1.23       mrg #include <sys/atomic.h>
     41   1.1       mrg 
     42   1.1       mrg #include <dev/usb/usbnet.h>
     43   1.4       mrg #include <dev/usb/usbhist.h>
     44   1.1       mrg 
     45  1.11       mrg struct usbnet_cdata {
     46  1.11       mrg 	struct usbnet_chain	*uncd_tx_chain;
     47  1.11       mrg 	struct usbnet_chain	*uncd_rx_chain;
     48  1.11       mrg 
     49  1.11       mrg 	int			uncd_tx_prod;
     50  1.11       mrg 	int			uncd_tx_cnt;
     51  1.11       mrg };
     52  1.11       mrg 
     53  1.11       mrg struct usbnet_private {
     54  1.11       mrg 	/*
     55  1.38   thorpej 	 * - unp_core_lock protects most of this structure, the public one,
     56  1.38   thorpej 	 *   and the MII / media data.
     57  1.11       mrg 	 * - unp_rxlock protects the rx path and its data
     58  1.11       mrg 	 * - unp_txlock protects the tx path and its data
     59  1.11       mrg 	 * - unp_detachcv handles detach vs open references
     60  1.28       mrg 	 *
     61  1.28       mrg 	 * the lock ordering is:
     62  1.38   thorpej 	 *	ifnet lock -> unp_core_lock -> unp_rxlock -> unp_txlock
     63  1.38   thorpej 	 * - ifnet lock is not needed for unp_core_lock, but if ifnet lock is
     64  1.30       mrg 	 *   involved, it must be taken first
     65  1.11       mrg 	 */
     66  1.38   thorpej 	kmutex_t		unp_core_lock;
     67  1.11       mrg 	kmutex_t		unp_rxlock;
     68  1.11       mrg 	kmutex_t		unp_txlock;
     69  1.11       mrg 	kcondvar_t		unp_detachcv;
     70  1.11       mrg 
     71  1.11       mrg 	struct usbnet_cdata	unp_cdata;
     72  1.11       mrg 
     73  1.11       mrg 	struct ethercom		unp_ec;
     74  1.11       mrg 	struct mii_data		unp_mii;
     75  1.11       mrg 	struct usb_task		unp_ticktask;
     76  1.11       mrg 	struct callout		unp_stat_ch;
     77  1.11       mrg 	struct usbd_pipe	*unp_ep[USBNET_ENDPT_MAX];
     78  1.11       mrg 
     79  1.11       mrg 	bool			unp_dying;
     80  1.11       mrg 	bool			unp_stopping;
     81  1.11       mrg 	bool			unp_attached;
     82  1.11       mrg 	bool			unp_link;
     83  1.11       mrg 
     84  1.11       mrg 	int			unp_refcnt;
     85  1.11       mrg 	int			unp_timer;
     86  1.29   msaitoh 	unsigned short		unp_if_flags;
     87  1.23       mrg 	unsigned		unp_number;
     88  1.11       mrg 
     89  1.11       mrg 	krndsource_t		unp_rndsrc;
     90  1.11       mrg 
     91  1.11       mrg 	struct timeval		unp_rx_notice;
     92  1.11       mrg 	struct timeval		unp_tx_notice;
     93  1.11       mrg 	struct timeval		unp_intr_notice;
     94  1.11       mrg };
     95  1.11       mrg 
     96  1.11       mrg #define un_cdata(un)	(&(un)->un_pri->unp_cdata)
     97  1.11       mrg 
     98  1.23       mrg volatile unsigned usbnet_number;
     99  1.23       mrg 
    100   1.1       mrg static int usbnet_modcmd(modcmd_t, void *);
    101   1.1       mrg 
    102   1.2       mrg #ifdef USB_DEBUG
    103   1.2       mrg #ifndef USBNET_DEBUG
    104   1.2       mrg #define usbnetdebug 0
    105   1.2       mrg #else
    106  1.26       mrg static int usbnetdebug = 0;
    107   1.4       mrg 
    108   1.2       mrg SYSCTL_SETUP(sysctl_hw_usbnet_setup, "sysctl hw.usbnet setup")
    109   1.2       mrg {
    110   1.2       mrg 	int err;
    111   1.2       mrg 	const struct sysctlnode *rnode;
    112   1.2       mrg 	const struct sysctlnode *cnode;
    113   1.2       mrg 
    114   1.2       mrg 	err = sysctl_createv(clog, 0, NULL, &rnode,
    115   1.2       mrg 	    CTLFLAG_PERMANENT, CTLTYPE_NODE, "usbnet",
    116   1.2       mrg 	    SYSCTL_DESCR("usbnet global controls"),
    117   1.2       mrg 	    NULL, 0, NULL, 0, CTL_HW, CTL_CREATE, CTL_EOL);
    118   1.2       mrg 
    119   1.2       mrg 	if (err)
    120   1.2       mrg 		goto fail;
    121   1.2       mrg 
    122   1.2       mrg 	/* control debugging printfs */
    123   1.2       mrg 	err = sysctl_createv(clog, 0, &rnode, &cnode,
    124   1.2       mrg 	    CTLFLAG_PERMANENT | CTLFLAG_READWRITE, CTLTYPE_INT,
    125   1.2       mrg 	    "debug", SYSCTL_DESCR("Enable debugging output"),
    126   1.2       mrg 	    NULL, 0, &usbnetdebug, sizeof(usbnetdebug), CTL_CREATE, CTL_EOL);
    127   1.2       mrg 	if (err)
    128   1.2       mrg 		goto fail;
    129   1.2       mrg 
    130   1.2       mrg 	return;
    131   1.2       mrg fail:
    132   1.2       mrg 	aprint_error("%s: sysctl_createv failed (err = %d)\n", __func__, err);
    133   1.2       mrg }
    134   1.2       mrg 
    135   1.2       mrg #endif /* USBNET_DEBUG */
    136   1.2       mrg #endif /* USB_DEBUG */
    137   1.2       mrg 
    138   1.2       mrg #define DPRINTF(FMT,A,B,C,D)	USBHIST_LOGN(usbnetdebug,1,FMT,A,B,C,D)
    139   1.2       mrg #define DPRINTFN(N,FMT,A,B,C,D)	USBHIST_LOGN(usbnetdebug,N,FMT,A,B,C,D)
    140   1.2       mrg #define USBNETHIST_FUNC()	USBHIST_FUNC()
    141   1.2       mrg #define USBNETHIST_CALLED(name)	USBHIST_CALLED(usbnetdebug)
    142  1.19       mrg #define USBNETHIST_CALLARGS(FMT,A,B,C,D) \
    143  1.19       mrg 				USBHIST_CALLARGS(usbnetdebug,FMT,A,B,C,D)
    144  1.23       mrg #define USBNETHIST_CALLARGSN(N,FMT,A,B,C,D) \
    145  1.23       mrg 				USBHIST_CALLARGSN(usbnetdebug,N,FMT,A,B,C,D)
    146   1.1       mrg 
    147  1.10       mrg /* Callback vectors. */
    148  1.10       mrg 
    149  1.10       mrg static void
    150  1.10       mrg uno_stop(struct usbnet *un, struct ifnet *ifp, int disable)
    151  1.10       mrg {
    152  1.38   thorpej 	usbnet_isowned_core(un);
    153  1.10       mrg 	if (un->un_ops->uno_stop)
    154  1.10       mrg 		(*un->un_ops->uno_stop)(ifp, disable);
    155  1.10       mrg }
    156  1.10       mrg 
    157  1.10       mrg static int
    158  1.10       mrg uno_ioctl(struct usbnet *un, struct ifnet *ifp, u_long cmd, void *data)
    159  1.10       mrg {
    160  1.38   thorpej 	/*
    161  1.38   thorpej 	 * There are cases where IFNET_LOCK will not be held when we
    162  1.38   thorpej 	 * are called (e.g. add/delete multicast address), so we can't
    163  1.38   thorpej 	 * assert it.
    164  1.38   thorpej 	 */
    165  1.10       mrg 	if (un->un_ops->uno_ioctl)
    166  1.10       mrg 		return (*un->un_ops->uno_ioctl)(ifp, cmd, data);
    167  1.10       mrg 	return 0;
    168  1.10       mrg }
    169  1.10       mrg 
    170  1.10       mrg static int
    171  1.10       mrg uno_override_ioctl(struct usbnet *un, struct ifnet *ifp, u_long cmd, void *data)
    172  1.10       mrg {
    173  1.38   thorpej 	/* See above. */
    174  1.10       mrg 	return (*un->un_ops->uno_override_ioctl)(ifp, cmd, data);
    175  1.10       mrg }
    176  1.10       mrg 
    177  1.10       mrg static int
    178  1.10       mrg uno_init(struct usbnet *un, struct ifnet *ifp)
    179  1.10       mrg {
    180  1.38   thorpej 	KASSERT(IFNET_LOCKED(ifp));
    181  1.10       mrg 	return (*un->un_ops->uno_init)(ifp);
    182  1.10       mrg }
    183  1.10       mrg 
    184  1.10       mrg static int
    185  1.10       mrg uno_read_reg(struct usbnet *un, int phy, int reg, uint16_t *val)
    186  1.10       mrg {
    187  1.38   thorpej 	usbnet_isowned_core(un);
    188  1.10       mrg 	return (*un->un_ops->uno_read_reg)(un, phy, reg, val);
    189  1.10       mrg }
    190  1.10       mrg 
    191  1.10       mrg static int
    192  1.10       mrg uno_write_reg(struct usbnet *un, int phy, int reg, uint16_t val)
    193  1.10       mrg {
    194  1.38   thorpej 	usbnet_isowned_core(un);
    195  1.10       mrg 	return (*un->un_ops->uno_write_reg)(un, phy, reg, val);
    196  1.10       mrg }
    197  1.10       mrg 
    198  1.10       mrg static void
    199  1.10       mrg uno_mii_statchg(struct usbnet *un, struct ifnet *ifp)
    200  1.10       mrg {
    201  1.38   thorpej 	usbnet_isowned_core(un);
    202  1.10       mrg 	(*un->un_ops->uno_statchg)(ifp);
    203  1.10       mrg }
    204  1.10       mrg 
    205  1.10       mrg static unsigned
    206  1.10       mrg uno_tx_prepare(struct usbnet *un, struct mbuf *m, struct usbnet_chain *c)
    207  1.10       mrg {
    208  1.38   thorpej 	usbnet_isowned_tx(un);
    209  1.10       mrg 	return (*un->un_ops->uno_tx_prepare)(un, m, c);
    210  1.10       mrg }
    211  1.10       mrg 
    212  1.10       mrg static void
    213  1.15       mrg uno_rx_loop(struct usbnet *un, struct usbnet_chain *c, uint32_t total_len)
    214  1.15       mrg {
    215  1.38   thorpej 	usbnet_isowned_rx(un);
    216  1.15       mrg 	(*un->un_ops->uno_rx_loop)(un, c, total_len);
    217  1.15       mrg }
    218  1.15       mrg 
    219  1.15       mrg static void
    220  1.15       mrg uno_tick(struct usbnet *un)
    221  1.10       mrg {
    222  1.15       mrg 	if (un->un_ops->uno_tick)
    223  1.15       mrg 		(*un->un_ops->uno_tick)(un);
    224  1.10       mrg }
    225  1.10       mrg 
    226  1.10       mrg static void
    227  1.10       mrg uno_intr(struct usbnet *un, usbd_status status)
    228  1.10       mrg {
    229  1.10       mrg 	if (un->un_ops->uno_intr)
    230  1.10       mrg 		(*un->un_ops->uno_intr)(un, status);
    231  1.10       mrg }
    232  1.10       mrg 
    233   1.1       mrg /* Interrupt handling. */
    234   1.1       mrg 
    235   1.1       mrg static struct mbuf *
    236  1.16       mrg usbnet_newbuf(size_t buflen)
    237   1.1       mrg {
    238   1.1       mrg 	struct mbuf *m;
    239   1.1       mrg 
    240  1.39  riastrad 	if (buflen > MCLBYTES)
    241  1.39  riastrad 		return NULL;
    242  1.39  riastrad 
    243   1.1       mrg 	MGETHDR(m, M_DONTWAIT, MT_DATA);
    244   1.1       mrg 	if (m == NULL)
    245   1.1       mrg 		return NULL;
    246   1.1       mrg 
    247  1.16       mrg 	if (buflen > MHLEN - ETHER_ALIGN) {
    248  1.16       mrg 		MCLGET(m, M_DONTWAIT);
    249  1.16       mrg 		if (!(m->m_flags & M_EXT)) {
    250  1.16       mrg 			m_freem(m);
    251  1.16       mrg 			return NULL;
    252  1.16       mrg 		}
    253   1.1       mrg 	}
    254   1.1       mrg 
    255   1.1       mrg 	m_adj(m, ETHER_ALIGN);
    256  1.16       mrg 	m->m_len = m->m_pkthdr.len = buflen;
    257   1.1       mrg 
    258   1.1       mrg 	return m;
    259   1.1       mrg }
    260   1.1       mrg 
    261   1.1       mrg /*
    262   1.1       mrg  * usbnet_rxeof() is designed to be the done callback for rx completion.
    263   1.1       mrg  * it provides generic setup and finalisation, calls a different usbnet
    264   1.1       mrg  * rx_loop callback in the middle, which can use usbnet_enqueue() to
    265   1.5       mrg  * enqueue a packet for higher levels (or usbnet_input() if previously
    266   1.5       mrg  * using if_input() path.)
    267   1.1       mrg  */
    268   1.1       mrg void
    269   1.1       mrg usbnet_enqueue(struct usbnet * const un, uint8_t *buf, size_t buflen,
    270   1.5       mrg 	       int csum_flags, uint32_t csum_data, int mbuf_flags)
    271   1.1       mrg {
    272  1.23       mrg 	USBNETHIST_FUNC();
    273  1.11       mrg 	struct ifnet * const ifp = usbnet_ifp(un);
    274  1.23       mrg 	struct usbnet_private * const unp __unused = un->un_pri;
    275   1.1       mrg 	struct mbuf *m;
    276   1.1       mrg 
    277  1.36  christos 	USBNETHIST_CALLARGSN(5, "%jd: enter: len=%ju csf %#jx mbf %#jx",
    278  1.23       mrg 	    unp->unp_number, buflen, csum_flags, mbuf_flags);
    279  1.23       mrg 
    280  1.12       mrg 	usbnet_isowned_rx(un);
    281   1.1       mrg 
    282  1.16       mrg 	m = usbnet_newbuf(buflen);
    283   1.1       mrg 	if (m == NULL) {
    284  1.36  christos 		DPRINTF("%jd: no memory", unp->unp_number, 0, 0, 0);
    285  1.34   thorpej 		if_statinc(ifp, if_ierrors);
    286   1.1       mrg 		return;
    287   1.1       mrg 	}
    288   1.1       mrg 
    289   1.1       mrg 	m_set_rcvif(m, ifp);
    290   1.5       mrg 	m->m_pkthdr.csum_flags = csum_flags;
    291   1.5       mrg 	m->m_pkthdr.csum_data = csum_data;
    292   1.5       mrg 	m->m_flags |= mbuf_flags;
    293  1.16       mrg 	memcpy(mtod(m, uint8_t *), buf, buflen);
    294   1.1       mrg 
    295   1.1       mrg 	/* push the packet up */
    296   1.1       mrg 	if_percpuq_enqueue(ifp->if_percpuq, m);
    297   1.1       mrg }
    298   1.1       mrg 
    299   1.5       mrg void
    300   1.5       mrg usbnet_input(struct usbnet * const un, uint8_t *buf, size_t buflen)
    301   1.5       mrg {
    302  1.23       mrg 	USBNETHIST_FUNC();
    303   1.5       mrg 	struct ifnet * const ifp = usbnet_ifp(un);
    304  1.23       mrg 	struct usbnet_private * const unp __unused = un->un_pri;
    305   1.5       mrg 	struct mbuf *m;
    306   1.5       mrg 
    307  1.36  christos 	USBNETHIST_CALLARGSN(5, "%jd: enter: buf %#jx len %ju",
    308  1.23       mrg 	    unp->unp_number, (uintptr_t)buf, buflen, 0);
    309  1.23       mrg 
    310  1.12       mrg 	usbnet_isowned_rx(un);
    311   1.5       mrg 
    312  1.16       mrg 	m = usbnet_newbuf(buflen);
    313   1.5       mrg 	if (m == NULL) {
    314  1.34   thorpej 		if_statinc(ifp, if_ierrors);
    315   1.5       mrg 		return;
    316   1.5       mrg 	}
    317   1.5       mrg 
    318   1.5       mrg 	m_set_rcvif(m, ifp);
    319   1.5       mrg 	memcpy(mtod(m, char *), buf, buflen);
    320   1.5       mrg 
    321   1.5       mrg 	/* push the packet up */
    322   1.5       mrg 	if_input(ifp, m);
    323   1.5       mrg }
    324   1.5       mrg 
    325   1.1       mrg /*
    326   1.1       mrg  * A frame has been uploaded: pass the resulting mbuf chain up to
    327   1.1       mrg  * the higher level protocols.
    328   1.1       mrg  */
    329   1.1       mrg static void
    330   1.4       mrg usbnet_rxeof(struct usbd_xfer *xfer, void *priv, usbd_status status)
    331   1.1       mrg {
    332  1.23       mrg 	USBNETHIST_FUNC();
    333  1.11       mrg 	struct usbnet_chain * const c = priv;
    334   1.1       mrg 	struct usbnet * const un = c->unc_un;
    335  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    336   1.5       mrg 	struct ifnet * const ifp = usbnet_ifp(un);
    337   1.1       mrg 	uint32_t total_len;
    338   1.1       mrg 
    339  1.36  christos 	USBNETHIST_CALLARGSN(5, "%jd: enter: status %#jx xfer %#jx",
    340  1.23       mrg 	    unp->unp_number, status, (uintptr_t)xfer, 0);
    341  1.23       mrg 
    342  1.11       mrg 	mutex_enter(&unp->unp_rxlock);
    343   1.1       mrg 
    344  1.11       mrg 	if (unp->unp_dying || unp->unp_stopping ||
    345   1.1       mrg 	    status == USBD_INVAL || status == USBD_NOT_STARTED ||
    346   1.1       mrg 	    status == USBD_CANCELLED || !(ifp->if_flags & IFF_RUNNING))
    347   1.1       mrg 		goto out;
    348   1.1       mrg 
    349   1.1       mrg 	if (status != USBD_NORMAL_COMPLETION) {
    350  1.11       mrg 		if (usbd_ratecheck(&unp->unp_rx_notice))
    351  1.40  jakllsch 			device_printf(un->un_dev, "usb errors on rx: %s\n",
    352   1.1       mrg 			    usbd_errstr(status));
    353   1.1       mrg 		if (status == USBD_STALLED)
    354  1.11       mrg 			usbd_clear_endpoint_stall_async(unp->unp_ep[USBNET_ENDPT_RX]);
    355   1.1       mrg 		goto done;
    356   1.1       mrg 	}
    357   1.1       mrg 
    358   1.1       mrg 	usbd_get_xfer_status(xfer, NULL, NULL, &total_len, NULL);
    359   1.1       mrg 
    360  1.11       mrg 	if (total_len > un->un_rx_bufsz) {
    361   1.1       mrg 		aprint_error_dev(un->un_dev,
    362   1.1       mrg 		    "rxeof: too large transfer (%u > %u)\n",
    363  1.11       mrg 		    total_len, un->un_rx_bufsz);
    364   1.1       mrg 		goto done;
    365   1.1       mrg 	}
    366   1.1       mrg 
    367  1.15       mrg 	uno_rx_loop(un, c, total_len);
    368  1.12       mrg 	usbnet_isowned_rx(un);
    369   1.1       mrg 
    370   1.1       mrg done:
    371  1.11       mrg 	if (unp->unp_dying || unp->unp_stopping)
    372   1.1       mrg 		goto out;
    373   1.1       mrg 
    374  1.11       mrg 	mutex_exit(&unp->unp_rxlock);
    375   1.1       mrg 
    376   1.1       mrg 	/* Setup new transfer. */
    377  1.11       mrg 	usbd_setup_xfer(xfer, c, c->unc_buf, un->un_rx_bufsz,
    378  1.11       mrg 	    un->un_rx_xfer_flags, USBD_NO_TIMEOUT, usbnet_rxeof);
    379   1.1       mrg 	usbd_transfer(xfer);
    380   1.1       mrg 	return;
    381   1.1       mrg 
    382   1.1       mrg out:
    383  1.11       mrg 	mutex_exit(&unp->unp_rxlock);
    384   1.1       mrg }
    385   1.1       mrg 
    386   1.1       mrg static void
    387   1.4       mrg usbnet_txeof(struct usbd_xfer *xfer, void *priv, usbd_status status)
    388   1.1       mrg {
    389   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
    390  1.11       mrg 	struct usbnet_chain * const c = priv;
    391   1.1       mrg 	struct usbnet * const un = c->unc_un;
    392  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
    393  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    394   1.1       mrg 	struct ifnet * const ifp = usbnet_ifp(un);
    395   1.1       mrg 
    396  1.36  christos 	USBNETHIST_CALLARGSN(5, "%jd: enter: status %#jx xfer %#jx",
    397  1.23       mrg 	    unp->unp_number, status, (uintptr_t)xfer, 0);
    398  1.23       mrg 
    399  1.11       mrg 	mutex_enter(&unp->unp_txlock);
    400  1.11       mrg 	if (unp->unp_stopping || unp->unp_dying) {
    401  1.11       mrg 		mutex_exit(&unp->unp_txlock);
    402   1.1       mrg 		return;
    403   1.1       mrg 	}
    404   1.1       mrg 
    405   1.1       mrg 	KASSERT(cd->uncd_tx_cnt > 0);
    406   1.1       mrg 	cd->uncd_tx_cnt--;
    407   1.1       mrg 
    408  1.11       mrg 	unp->unp_timer = 0;
    409   1.1       mrg 
    410   1.1       mrg 	switch (status) {
    411   1.1       mrg 	case USBD_NOT_STARTED:
    412   1.1       mrg 	case USBD_CANCELLED:
    413   1.1       mrg 		break;
    414   1.1       mrg 
    415   1.1       mrg 	case USBD_NORMAL_COMPLETION:
    416  1.34   thorpej 		if_statinc(ifp, if_opackets);
    417   1.1       mrg 		break;
    418   1.1       mrg 
    419   1.1       mrg 	default:
    420   1.1       mrg 
    421  1.34   thorpej 		if_statinc(ifp, if_oerrors);
    422  1.11       mrg 		if (usbd_ratecheck(&unp->unp_tx_notice))
    423  1.40  jakllsch 			device_printf(un->un_dev, "usb error on tx: %s\n",
    424   1.1       mrg 			    usbd_errstr(status));
    425   1.1       mrg 		if (status == USBD_STALLED)
    426  1.11       mrg 			usbd_clear_endpoint_stall_async(unp->unp_ep[USBNET_ENDPT_TX]);
    427   1.1       mrg 		break;
    428   1.1       mrg 	}
    429   1.1       mrg 
    430  1.11       mrg 	mutex_exit(&unp->unp_txlock);
    431   1.1       mrg 
    432   1.1       mrg 	if (status == USBD_NORMAL_COMPLETION && !IFQ_IS_EMPTY(&ifp->if_snd))
    433   1.1       mrg 		(*ifp->if_start)(ifp);
    434   1.1       mrg }
    435   1.1       mrg 
    436   1.1       mrg static void
    437  1.11       mrg usbnet_pipe_intr(struct usbd_xfer *xfer, void *priv, usbd_status status)
    438   1.4       mrg {
    439  1.26       mrg 	USBNETHIST_FUNC();
    440  1.11       mrg 	struct usbnet * const un = priv;
    441  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    442  1.11       mrg 	struct usbnet_intr * const uni = un->un_intr;
    443  1.11       mrg 	struct ifnet * const ifp = usbnet_ifp(un);
    444   1.4       mrg 
    445  1.11       mrg 	if (uni == NULL || unp->unp_dying || unp->unp_stopping ||
    446   1.4       mrg 	    status == USBD_INVAL || status == USBD_NOT_STARTED ||
    447  1.26       mrg 	    status == USBD_CANCELLED || !(ifp->if_flags & IFF_RUNNING)) {
    448  1.36  christos 		USBNETHIST_CALLARGS("%jd: uni %#jx d/s %#jx status %#jx",
    449  1.26       mrg 		    unp->unp_number, (uintptr_t)uni,
    450  1.26       mrg 		    (unp->unp_dying << 8) | unp->unp_stopping, status);
    451   1.4       mrg 		return;
    452  1.26       mrg 	}
    453   1.4       mrg 
    454   1.4       mrg 	if (status != USBD_NORMAL_COMPLETION) {
    455  1.11       mrg 		if (usbd_ratecheck(&unp->unp_intr_notice)) {
    456   1.4       mrg 			aprint_error_dev(un->un_dev, "usb error on intr: %s\n",
    457   1.4       mrg 			    usbd_errstr(status));
    458   1.4       mrg 		}
    459   1.4       mrg 		if (status == USBD_STALLED)
    460  1.11       mrg 			usbd_clear_endpoint_stall_async(unp->unp_ep[USBNET_ENDPT_INTR]);
    461  1.36  christos 		USBNETHIST_CALLARGS("%jd: not normal status %#jx",
    462  1.26       mrg 		    unp->unp_number, status, 0, 0);
    463   1.4       mrg 		return;
    464   1.4       mrg 	}
    465   1.4       mrg 
    466  1.10       mrg 	uno_intr(un, status);
    467   1.4       mrg }
    468   1.4       mrg 
    469   1.4       mrg static void
    470   1.1       mrg usbnet_start_locked(struct ifnet *ifp)
    471   1.1       mrg {
    472  1.26       mrg 	USBNETHIST_FUNC();
    473   1.1       mrg 	struct usbnet * const un = ifp->if_softc;
    474  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
    475  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    476   1.1       mrg 	struct mbuf *m;
    477   1.1       mrg 	unsigned length;
    478  1.26       mrg 	bool done_transmit = false;
    479  1.41       rin 	int idx, count;
    480   1.1       mrg 
    481  1.36  christos 	USBNETHIST_CALLARGS("%jd: tx_cnt %jd list_cnt %jd link %jd",
    482  1.26       mrg 	    unp->unp_number, cd->uncd_tx_cnt, un->un_tx_list_cnt,
    483  1.26       mrg 	    unp->unp_link);
    484  1.26       mrg 
    485  1.12       mrg 	usbnet_isowned_tx(un);
    486  1.11       mrg 	KASSERT(cd->uncd_tx_cnt <= un->un_tx_list_cnt);
    487   1.1       mrg 
    488  1.15       mrg 	if (!unp->unp_link || (ifp->if_flags & IFF_RUNNING) == 0) {
    489  1.37  christos 		DPRINTF("start called no link (%jx) or running (flags %jx)",
    490  1.15       mrg 		    unp->unp_link, ifp->if_flags, 0, 0);
    491   1.1       mrg 		return;
    492  1.15       mrg 	}
    493   1.1       mrg 
    494  1.23       mrg 	if (cd->uncd_tx_cnt == un->un_tx_list_cnt) {
    495  1.36  christos 		DPRINTF("start called, tx busy (%#jx == %#jx)",
    496  1.23       mrg 		    cd->uncd_tx_cnt, un->un_tx_list_cnt, 0, 0);
    497  1.23       mrg 		return;
    498  1.23       mrg 	}
    499  1.23       mrg 
    500   1.1       mrg 	idx = cd->uncd_tx_prod;
    501  1.41       rin 	count = 0;
    502  1.11       mrg 	while (cd->uncd_tx_cnt < un->un_tx_list_cnt) {
    503   1.1       mrg 		IFQ_POLL(&ifp->if_snd, m);
    504  1.23       mrg 		if (m == NULL) {
    505  1.23       mrg 			DPRINTF("start called, queue empty", 0, 0, 0, 0);
    506   1.1       mrg 			break;
    507  1.23       mrg 		}
    508  1.13       mrg 		KASSERT(m->m_pkthdr.len <= un->un_tx_bufsz);
    509   1.1       mrg 
    510  1.10       mrg 		struct usbnet_chain *c = &cd->uncd_tx_chain[idx];
    511   1.1       mrg 
    512  1.10       mrg 		length = uno_tx_prepare(un, m, c);
    513   1.1       mrg 		if (length == 0) {
    514  1.23       mrg 			DPRINTF("uno_tx_prepare gave zero length", 0, 0, 0, 0);
    515  1.34   thorpej 			if_statinc(ifp, if_oerrors);
    516   1.1       mrg 			break;
    517   1.1       mrg 		}
    518   1.1       mrg 
    519   1.1       mrg 		if (__predict_false(c->unc_xfer == NULL)) {
    520  1.23       mrg 			DPRINTF("unc_xfer is NULL", 0, 0, 0, 0);
    521  1.34   thorpej 			if_statinc(ifp, if_oerrors);
    522   1.1       mrg 			break;
    523   1.1       mrg 		}
    524   1.1       mrg 
    525   1.1       mrg 		usbd_setup_xfer(c->unc_xfer, c, c->unc_buf, length,
    526  1.11       mrg 		    un->un_tx_xfer_flags, 10000, usbnet_txeof);
    527   1.1       mrg 
    528   1.1       mrg 		/* Transmit */
    529   1.1       mrg 		usbd_status err = usbd_transfer(c->unc_xfer);
    530   1.1       mrg 		if (err != USBD_IN_PROGRESS) {
    531  1.37  christos 			DPRINTF("usbd_transfer on %#jx for %ju bytes: %jd",
    532  1.23       mrg 			    (uintptr_t)c->unc_buf, length, err, 0);
    533  1.34   thorpej 			if_statinc(ifp, if_oerrors);
    534   1.1       mrg 			break;
    535   1.1       mrg 		}
    536  1.26       mrg 		done_transmit = true;
    537   1.1       mrg 
    538   1.1       mrg 		IFQ_DEQUEUE(&ifp->if_snd, m);
    539   1.1       mrg 
    540   1.1       mrg 		/*
    541   1.1       mrg 		 * If there's a BPF listener, bounce a copy of this frame
    542   1.1       mrg 		 * to him.
    543   1.1       mrg 		 */
    544   1.1       mrg 		bpf_mtap(ifp, m, BPF_D_OUT);
    545   1.1       mrg 		m_freem(m);
    546   1.1       mrg 
    547  1.11       mrg 		idx = (idx + 1) % un->un_tx_list_cnt;
    548   1.1       mrg 		cd->uncd_tx_cnt++;
    549  1.41       rin 		count++;
    550   1.1       mrg 	}
    551   1.1       mrg 	cd->uncd_tx_prod = idx;
    552   1.1       mrg 
    553  1.37  christos 	DPRINTF("finished with start; tx_cnt %jd list_cnt %jd link %jd",
    554  1.26       mrg 	    cd->uncd_tx_cnt, un->un_tx_list_cnt, unp->unp_link, 0);
    555  1.26       mrg 
    556   1.1       mrg 	/*
    557   1.1       mrg 	 * Set a timeout in case the chip goes out to lunch.
    558   1.1       mrg 	 */
    559  1.26       mrg 	if (done_transmit)
    560  1.26       mrg 		unp->unp_timer = 5;
    561  1.41       rin 
    562  1.41       rin 	if (count != 0)
    563  1.41       rin 		rnd_add_uint32(&unp->unp_rndsrc, count);
    564   1.1       mrg }
    565   1.1       mrg 
    566   1.1       mrg static void
    567  1.38   thorpej usbnet_if_start(struct ifnet *ifp)
    568   1.1       mrg {
    569   1.1       mrg 	struct usbnet * const un = ifp->if_softc;
    570  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    571   1.1       mrg 
    572  1.26       mrg 	USBNETHIST_FUNC();
    573  1.36  christos 	USBNETHIST_CALLARGS("%jd: stopping %jd",
    574  1.26       mrg 	    unp->unp_number, unp->unp_stopping, 0, 0);
    575  1.26       mrg 
    576  1.11       mrg 	mutex_enter(&unp->unp_txlock);
    577  1.11       mrg 	if (!unp->unp_stopping)
    578   1.1       mrg 		usbnet_start_locked(ifp);
    579  1.11       mrg 	mutex_exit(&unp->unp_txlock);
    580   1.1       mrg }
    581   1.1       mrg 
    582   1.1       mrg /*
    583   1.1       mrg  * Chain management.
    584   1.1       mrg  *
    585   1.1       mrg  * RX and TX are identical. Keep them that way.
    586   1.1       mrg  */
    587   1.1       mrg 
    588   1.1       mrg /* Start of common RX functions */
    589   1.1       mrg 
    590   1.1       mrg static size_t
    591  1.12       mrg usbnet_rx_list_size(struct usbnet_cdata * const cd, struct usbnet * const un)
    592   1.1       mrg {
    593  1.11       mrg 	return sizeof(*cd->uncd_rx_chain) * un->un_rx_list_cnt;
    594   1.1       mrg }
    595   1.1       mrg 
    596   1.1       mrg static void
    597  1.12       mrg usbnet_rx_list_alloc(struct usbnet * const un)
    598   1.1       mrg {
    599  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
    600   1.1       mrg 
    601  1.11       mrg 	cd->uncd_rx_chain = kmem_zalloc(usbnet_rx_list_size(cd, un), KM_SLEEP);
    602   1.1       mrg }
    603   1.1       mrg 
    604   1.1       mrg static void
    605  1.12       mrg usbnet_rx_list_free(struct usbnet * const un)
    606   1.1       mrg {
    607  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
    608   1.1       mrg 
    609   1.1       mrg 	if (cd->uncd_rx_chain) {
    610  1.11       mrg 		kmem_free(cd->uncd_rx_chain, usbnet_rx_list_size(cd, un));
    611   1.1       mrg 		cd->uncd_rx_chain = NULL;
    612   1.1       mrg 	}
    613   1.1       mrg }
    614   1.1       mrg 
    615   1.1       mrg static int
    616  1.12       mrg usbnet_rx_list_init(struct usbnet * const un)
    617   1.1       mrg {
    618  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
    619  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    620   1.1       mrg 
    621  1.11       mrg 	for (size_t i = 0; i < un->un_rx_list_cnt; i++) {
    622   1.1       mrg 		struct usbnet_chain *c = &cd->uncd_rx_chain[i];
    623   1.1       mrg 
    624   1.1       mrg 		c->unc_un = un;
    625   1.1       mrg 		if (c->unc_xfer == NULL) {
    626  1.11       mrg 			int err = usbd_create_xfer(unp->unp_ep[USBNET_ENDPT_RX],
    627  1.11       mrg 			    un->un_rx_bufsz, un->un_rx_xfer_flags, 0,
    628  1.10       mrg 			    &c->unc_xfer);
    629   1.1       mrg 			if (err)
    630   1.1       mrg 				return err;
    631   1.1       mrg 			c->unc_buf = usbd_get_buffer(c->unc_xfer);
    632   1.1       mrg 		}
    633   1.1       mrg 	}
    634   1.1       mrg 
    635   1.1       mrg 	return 0;
    636   1.1       mrg }
    637   1.1       mrg 
    638   1.1       mrg static void
    639  1.12       mrg usbnet_rx_list_fini(struct usbnet * const un)
    640   1.1       mrg {
    641  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
    642   1.1       mrg 
    643  1.11       mrg 	for (size_t i = 0; i < un->un_rx_list_cnt; i++) {
    644   1.1       mrg 		struct usbnet_chain *c = &cd->uncd_rx_chain[i];
    645   1.1       mrg 
    646   1.1       mrg 		if (c->unc_xfer != NULL) {
    647   1.1       mrg 			usbd_destroy_xfer(c->unc_xfer);
    648   1.1       mrg 			c->unc_xfer = NULL;
    649   1.1       mrg 			c->unc_buf = NULL;
    650   1.1       mrg 		}
    651   1.1       mrg 	}
    652   1.1       mrg }
    653   1.1       mrg 
    654   1.1       mrg /* End of common RX functions */
    655   1.1       mrg 
    656   1.1       mrg static void
    657  1.16       mrg usbnet_rx_start_pipes(struct usbnet * const un)
    658   1.1       mrg {
    659  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
    660  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    661   1.1       mrg 
    662  1.11       mrg 	mutex_enter(&unp->unp_rxlock);
    663  1.11       mrg 	mutex_enter(&unp->unp_txlock);
    664  1.11       mrg 	unp->unp_stopping = false;
    665   1.1       mrg 
    666  1.11       mrg 	for (size_t i = 0; i < un->un_rx_list_cnt; i++) {
    667   1.1       mrg 		struct usbnet_chain *c = &cd->uncd_rx_chain[i];
    668   1.1       mrg 
    669  1.11       mrg 		usbd_setup_xfer(c->unc_xfer, c, c->unc_buf, un->un_rx_bufsz,
    670  1.16       mrg 		    un->un_rx_xfer_flags, USBD_NO_TIMEOUT, usbnet_rxeof);
    671   1.1       mrg 		usbd_transfer(c->unc_xfer);
    672   1.3     skrll 	}
    673   1.1       mrg 
    674  1.11       mrg 	mutex_exit(&unp->unp_txlock);
    675  1.11       mrg 	mutex_exit(&unp->unp_rxlock);
    676   1.1       mrg }
    677   1.1       mrg 
    678   1.1       mrg /* Start of common TX functions */
    679   1.1       mrg 
    680   1.1       mrg static size_t
    681  1.12       mrg usbnet_tx_list_size(struct usbnet_cdata * const cd, struct usbnet * const un)
    682   1.1       mrg {
    683  1.11       mrg 	return sizeof(*cd->uncd_tx_chain) * un->un_tx_list_cnt;
    684   1.1       mrg }
    685   1.1       mrg 
    686   1.1       mrg static void
    687  1.12       mrg usbnet_tx_list_alloc(struct usbnet * const un)
    688   1.1       mrg {
    689  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
    690   1.1       mrg 
    691  1.11       mrg 	cd->uncd_tx_chain = kmem_zalloc(usbnet_tx_list_size(cd, un), KM_SLEEP);
    692   1.1       mrg }
    693   1.1       mrg 
    694   1.1       mrg static void
    695  1.12       mrg usbnet_tx_list_free(struct usbnet * const un)
    696   1.1       mrg {
    697  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
    698   1.1       mrg 
    699   1.1       mrg 	if (cd->uncd_tx_chain) {
    700  1.11       mrg 		kmem_free(cd->uncd_tx_chain, usbnet_tx_list_size(cd, un));
    701   1.1       mrg 		cd->uncd_tx_chain = NULL;
    702   1.1       mrg 	}
    703   1.1       mrg }
    704   1.1       mrg 
    705   1.1       mrg static int
    706  1.12       mrg usbnet_tx_list_init(struct usbnet * const un)
    707   1.1       mrg {
    708  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
    709  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    710   1.1       mrg 
    711  1.11       mrg 	for (size_t i = 0; i < un->un_tx_list_cnt; i++) {
    712   1.1       mrg 		struct usbnet_chain *c = &cd->uncd_tx_chain[i];
    713   1.1       mrg 
    714   1.1       mrg 		c->unc_un = un;
    715   1.1       mrg 		if (c->unc_xfer == NULL) {
    716  1.11       mrg 			int err = usbd_create_xfer(unp->unp_ep[USBNET_ENDPT_TX],
    717  1.11       mrg 			    un->un_tx_bufsz, un->un_tx_xfer_flags, 0,
    718  1.10       mrg 			    &c->unc_xfer);
    719   1.1       mrg 			if (err)
    720   1.1       mrg 				return err;
    721   1.1       mrg 			c->unc_buf = usbd_get_buffer(c->unc_xfer);
    722   1.1       mrg 		}
    723   1.1       mrg 	}
    724   1.1       mrg 
    725   1.1       mrg 	return 0;
    726   1.1       mrg }
    727   1.1       mrg 
    728   1.1       mrg static void
    729  1.12       mrg usbnet_tx_list_fini(struct usbnet * const un)
    730   1.1       mrg {
    731  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
    732   1.1       mrg 
    733  1.11       mrg 	for (size_t i = 0; i < un->un_tx_list_cnt; i++) {
    734   1.1       mrg 		struct usbnet_chain *c = &cd->uncd_tx_chain[i];
    735   1.1       mrg 
    736   1.1       mrg 		if (c->unc_xfer != NULL) {
    737   1.1       mrg 			usbd_destroy_xfer(c->unc_xfer);
    738   1.1       mrg 			c->unc_xfer = NULL;
    739   1.1       mrg 			c->unc_buf = NULL;
    740   1.1       mrg 		}
    741   1.1       mrg 	}
    742  1.23       mrg 	cd->uncd_tx_prod = cd->uncd_tx_cnt = 0;
    743   1.1       mrg }
    744   1.1       mrg 
    745   1.1       mrg /* End of common TX functions */
    746   1.1       mrg 
    747   1.1       mrg /* Endpoint pipe management. */
    748   1.1       mrg 
    749   1.1       mrg static void
    750  1.12       mrg usbnet_ep_close_pipes(struct usbnet * const un)
    751   1.1       mrg {
    752  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    753  1.11       mrg 
    754  1.11       mrg 	for (size_t i = 0; i < __arraycount(unp->unp_ep); i++) {
    755  1.11       mrg 		if (unp->unp_ep[i] == NULL)
    756   1.1       mrg 			continue;
    757  1.11       mrg 		usbd_status err = usbd_close_pipe(unp->unp_ep[i]);
    758   1.1       mrg 		if (err)
    759   1.1       mrg 			aprint_error_dev(un->un_dev, "close pipe %zu: %s\n", i,
    760   1.1       mrg 			    usbd_errstr(err));
    761  1.11       mrg 		unp->unp_ep[i] = NULL;
    762   1.1       mrg 	}
    763   1.1       mrg }
    764   1.1       mrg 
    765   1.1       mrg static usbd_status
    766  1.12       mrg usbnet_ep_open_pipes(struct usbnet * const un)
    767   1.1       mrg {
    768  1.11       mrg 	struct usbnet_intr * const uni = un->un_intr;
    769  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    770  1.11       mrg 
    771  1.11       mrg 	for (size_t i = 0; i < __arraycount(unp->unp_ep); i++) {
    772   1.4       mrg 		usbd_status err;
    773   1.4       mrg 
    774   1.1       mrg 		if (un->un_ed[i] == 0)
    775   1.1       mrg 			continue;
    776   1.4       mrg 
    777  1.11       mrg 		if (i == USBNET_ENDPT_INTR && uni) {
    778   1.4       mrg 			err = usbd_open_pipe_intr(un->un_iface, un->un_ed[i],
    779  1.11       mrg 			    USBD_EXCLUSIVE_USE | USBD_MPSAFE, &unp->unp_ep[i], un,
    780  1.11       mrg 			    uni->uni_buf, uni->uni_bufsz, usbnet_pipe_intr,
    781  1.11       mrg 			    uni->uni_interval);
    782   1.4       mrg 		} else {
    783   1.4       mrg 			err = usbd_open_pipe(un->un_iface, un->un_ed[i],
    784  1.11       mrg 			    USBD_EXCLUSIVE_USE | USBD_MPSAFE, &unp->unp_ep[i]);
    785   1.4       mrg 		}
    786   1.1       mrg 		if (err) {
    787   1.1       mrg 			usbnet_ep_close_pipes(un);
    788   1.1       mrg 			return err;
    789   1.1       mrg 		}
    790   1.1       mrg 	}
    791   1.1       mrg 
    792   1.1       mrg 	return USBD_NORMAL_COMPLETION;
    793   1.1       mrg }
    794   1.1       mrg 
    795   1.1       mrg static usbd_status
    796  1.12       mrg usbnet_ep_stop_pipes(struct usbnet * const un)
    797   1.1       mrg {
    798  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    799  1.17       mrg 	usbd_status err = USBD_NORMAL_COMPLETION;
    800  1.11       mrg 
    801  1.11       mrg 	for (size_t i = 0; i < __arraycount(unp->unp_ep); i++) {
    802  1.11       mrg 		if (unp->unp_ep[i] == NULL)
    803   1.1       mrg 			continue;
    804  1.17       mrg 		usbd_status err2 = usbd_abort_pipe(unp->unp_ep[i]);
    805  1.17       mrg 		if (err == USBD_NORMAL_COMPLETION && err2)
    806  1.18       mrg 			err = err2;
    807   1.1       mrg 	}
    808   1.1       mrg 
    809  1.17       mrg 	return err;
    810   1.1       mrg }
    811   1.1       mrg 
    812   1.1       mrg int
    813  1.10       mrg usbnet_init_rx_tx(struct usbnet * const un)
    814   1.1       mrg {
    815   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
    816  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    817   1.1       mrg 	struct ifnet * const ifp = usbnet_ifp(un);
    818   1.1       mrg 	usbd_status err;
    819   1.4       mrg 	int error = 0;
    820   1.4       mrg 
    821  1.38   thorpej 	usbnet_isowned_core(un);
    822   1.4       mrg 
    823  1.11       mrg 	if (unp->unp_dying) {
    824   1.4       mrg 		return EIO;
    825   1.4       mrg 	}
    826  1.38   thorpej 
    827  1.38   thorpej 	usbnet_busy(un);
    828   1.1       mrg 
    829   1.1       mrg 	/* Open RX and TX pipes. */
    830   1.1       mrg 	err = usbnet_ep_open_pipes(un);
    831   1.1       mrg 	if (err) {
    832   1.1       mrg 		aprint_error_dev(un->un_dev, "open rx/tx pipes failed: %s\n",
    833   1.1       mrg 		    usbd_errstr(err));
    834   1.4       mrg 		error = EIO;
    835   1.4       mrg 		goto out;
    836   1.1       mrg 	}
    837   1.1       mrg 
    838   1.1       mrg 	/* Init RX ring. */
    839  1.10       mrg 	if (usbnet_rx_list_init(un)) {
    840   1.1       mrg 		aprint_error_dev(un->un_dev, "rx list init failed\n");
    841   1.4       mrg 		error = ENOBUFS;
    842   1.4       mrg 		goto out;
    843   1.1       mrg 	}
    844   1.1       mrg 
    845   1.1       mrg 	/* Init TX ring. */
    846  1.10       mrg 	if (usbnet_tx_list_init(un)) {
    847   1.1       mrg 		aprint_error_dev(un->un_dev, "tx list init failed\n");
    848   1.4       mrg 		error = ENOBUFS;
    849   1.4       mrg 		goto out;
    850   1.1       mrg 	}
    851   1.1       mrg 
    852   1.1       mrg 	/* Start up the receive pipe(s). */
    853  1.16       mrg 	usbnet_rx_start_pipes(un);
    854   1.1       mrg 
    855   1.1       mrg 	/* Indicate we are up and running. */
    856  1.17       mrg #if 0
    857  1.17       mrg 	/* XXX if_mcast_op() can call this without ifnet locked */
    858   1.8       mrg 	KASSERT(ifp->if_softc == NULL || IFNET_LOCKED(ifp));
    859  1.17       mrg #endif
    860   1.1       mrg 	ifp->if_flags |= IFF_RUNNING;
    861   1.1       mrg 
    862  1.11       mrg 	callout_schedule(&unp->unp_stat_ch, hz);
    863   1.1       mrg 
    864   1.4       mrg out:
    865   1.4       mrg 	if (error) {
    866   1.4       mrg 		usbnet_rx_list_fini(un);
    867   1.4       mrg 		usbnet_tx_list_fini(un);
    868   1.4       mrg 		usbnet_ep_close_pipes(un);
    869   1.4       mrg 	}
    870  1.38   thorpej 	usbnet_unbusy(un);
    871   1.4       mrg 
    872  1.38   thorpej 	usbnet_isowned_core(un);
    873   1.1       mrg 
    874   1.4       mrg 	return error;
    875   1.1       mrg }
    876   1.1       mrg 
    877   1.1       mrg void
    878  1.38   thorpej usbnet_busy(struct usbnet *un)
    879   1.1       mrg {
    880  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    881  1.11       mrg 
    882  1.38   thorpej 	usbnet_isowned_core(un);
    883   1.1       mrg 
    884  1.11       mrg 	unp->unp_refcnt++;
    885   1.1       mrg }
    886   1.1       mrg 
    887   1.1       mrg void
    888  1.38   thorpej usbnet_unbusy(struct usbnet *un)
    889   1.1       mrg {
    890  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    891   1.1       mrg 
    892  1.38   thorpej 	usbnet_isowned_core(un);
    893  1.11       mrg 
    894  1.11       mrg 	if (--unp->unp_refcnt < 0)
    895  1.11       mrg 		cv_broadcast(&unp->unp_detachcv);
    896  1.11       mrg }
    897  1.11       mrg 
    898  1.38   thorpej /* MII management. */
    899   1.1       mrg 
    900   1.1       mrg int
    901  1.10       mrg usbnet_mii_readreg(device_t dev, int phy, int reg, uint16_t *val)
    902   1.1       mrg {
    903  1.19       mrg 	USBNETHIST_FUNC();
    904   1.1       mrg 	struct usbnet * const un = device_private(dev);
    905  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    906  1.22       mrg 	int err;
    907   1.1       mrg 
    908  1.38   thorpej 	/* MII layer ensures core_lock is held. */
    909  1.38   thorpej 	usbnet_isowned_core(un);
    910  1.38   thorpej 
    911  1.20       mrg 	if (unp->unp_dying) {
    912   1.1       mrg 		return EIO;
    913   1.1       mrg 	}
    914  1.20       mrg 
    915  1.38   thorpej 	usbnet_busy(un);
    916  1.10       mrg 	err = uno_read_reg(un, phy, reg, val);
    917  1.38   thorpej 	usbnet_unbusy(un);
    918   1.1       mrg 
    919   1.1       mrg 	if (err) {
    920  1.36  christos 		USBNETHIST_CALLARGS("%jd: read PHY failed: %jd",
    921  1.36  christos 		    unp->unp_number, err, 0, 0);
    922  1.22       mrg 		return err;
    923   1.1       mrg 	}
    924   1.1       mrg 
    925   1.1       mrg 	return 0;
    926   1.1       mrg }
    927   1.1       mrg 
    928   1.1       mrg int
    929  1.10       mrg usbnet_mii_writereg(device_t dev, int phy, int reg, uint16_t val)
    930   1.1       mrg {
    931  1.19       mrg 	USBNETHIST_FUNC();
    932   1.1       mrg 	struct usbnet * const un = device_private(dev);
    933  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    934  1.22       mrg 	int err;
    935   1.1       mrg 
    936  1.38   thorpej 	/* MII layer ensures core_lock is held. */
    937  1.38   thorpej 	usbnet_isowned_core(un);
    938  1.38   thorpej 
    939  1.20       mrg 	if (unp->unp_dying) {
    940   1.1       mrg 		return EIO;
    941   1.1       mrg 	}
    942  1.20       mrg 
    943  1.38   thorpej 	usbnet_busy(un);
    944  1.10       mrg 	err = uno_write_reg(un, phy, reg, val);
    945  1.38   thorpej 	usbnet_unbusy(un);
    946   1.1       mrg 
    947   1.1       mrg 	if (err) {
    948  1.36  christos 		USBNETHIST_CALLARGS("%jd: write PHY failed: %jd",
    949  1.36  christos 		    unp->unp_number, err, 0, 0);
    950  1.22       mrg 		return err;
    951   1.1       mrg 	}
    952   1.1       mrg 
    953   1.1       mrg 	return 0;
    954   1.1       mrg }
    955   1.1       mrg 
    956   1.1       mrg void
    957  1.10       mrg usbnet_mii_statchg(struct ifnet *ifp)
    958   1.1       mrg {
    959   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
    960   1.1       mrg 	struct usbnet * const un = ifp->if_softc;
    961   1.1       mrg 
    962  1.38   thorpej 	/* MII layer ensures core_lock is held. */
    963  1.38   thorpej 	usbnet_isowned_core(un);
    964  1.38   thorpej 
    965  1.38   thorpej 	usbnet_busy(un);
    966  1.10       mrg 	uno_mii_statchg(un, ifp);
    967  1.38   thorpej 	usbnet_unbusy(un);
    968   1.1       mrg }
    969   1.1       mrg 
    970   1.1       mrg static int
    971   1.1       mrg usbnet_media_upd(struct ifnet *ifp)
    972   1.1       mrg {
    973   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
    974   1.1       mrg 	struct usbnet * const un = ifp->if_softc;
    975  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
    976   1.1       mrg 	struct mii_data * const mii = usbnet_mii(un);
    977   1.1       mrg 
    978  1.38   thorpej 	/* ifmedia layer ensures core_lock is held. */
    979  1.38   thorpej 	usbnet_isowned_core(un);
    980  1.38   thorpej 
    981  1.11       mrg 	if (unp->unp_dying)
    982   1.1       mrg 		return EIO;
    983   1.1       mrg 
    984  1.11       mrg 	unp->unp_link = false;
    985   1.1       mrg 
    986   1.1       mrg 	if (mii->mii_instance) {
    987   1.1       mrg 		struct mii_softc *miisc;
    988   1.1       mrg 
    989   1.1       mrg 		LIST_FOREACH(miisc, &mii->mii_phys, mii_list)
    990   1.1       mrg 			mii_phy_reset(miisc);
    991   1.1       mrg 	}
    992   1.1       mrg 
    993   1.1       mrg 	return ether_mediachange(ifp);
    994   1.1       mrg }
    995   1.1       mrg 
    996   1.1       mrg /* ioctl */
    997   1.1       mrg 
    998   1.1       mrg static int
    999   1.1       mrg usbnet_ifflags_cb(struct ethercom *ec)
   1000   1.1       mrg {
   1001   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
   1002   1.1       mrg 	struct ifnet *ifp = &ec->ec_if;
   1003   1.1       mrg 	struct usbnet *un = ifp->if_softc;
   1004  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
   1005   1.1       mrg 	int rv = 0;
   1006   1.1       mrg 
   1007  1.38   thorpej 	mutex_enter(&unp->unp_core_lock);
   1008   1.1       mrg 
   1009  1.29   msaitoh 	const u_short changed = ifp->if_flags ^ unp->unp_if_flags;
   1010   1.1       mrg 	if ((changed & ~(IFF_CANTCHANGE | IFF_DEBUG)) == 0) {
   1011  1.11       mrg 		unp->unp_if_flags = ifp->if_flags;
   1012   1.1       mrg 		if ((changed & IFF_PROMISC) != 0)
   1013   1.1       mrg 			rv = ENETRESET;
   1014   1.1       mrg 	} else {
   1015   1.1       mrg 		rv = ENETRESET;
   1016   1.1       mrg 	}
   1017   1.1       mrg 
   1018  1.38   thorpej 	mutex_exit(&unp->unp_core_lock);
   1019   1.1       mrg 
   1020   1.1       mrg 	return rv;
   1021   1.1       mrg }
   1022   1.1       mrg 
   1023   1.1       mrg static int
   1024  1.38   thorpej usbnet_if_ioctl(struct ifnet *ifp, u_long cmd, void *data)
   1025   1.1       mrg {
   1026  1.23       mrg 	USBNETHIST_FUNC();
   1027   1.1       mrg 	struct usbnet * const un = ifp->if_softc;
   1028  1.23       mrg 	struct usbnet_private * const unp __unused = un->un_pri;
   1029   1.1       mrg 	int error;
   1030   1.1       mrg 
   1031  1.36  christos 	USBNETHIST_CALLARGSN(11, "%jd: enter %#jx data %#jx",
   1032  1.23       mrg 	    unp->unp_number, cmd, (uintptr_t)data, 0);
   1033  1.23       mrg 
   1034  1.10       mrg 	if (un->un_ops->uno_override_ioctl)
   1035  1.10       mrg 		return uno_override_ioctl(un, ifp, cmd, data);
   1036   1.5       mrg 
   1037   1.1       mrg 	error = ether_ioctl(ifp, cmd, data);
   1038  1.10       mrg 	if (error == ENETRESET)
   1039  1.10       mrg 		error = uno_ioctl(un, ifp, cmd, data);
   1040   1.1       mrg 
   1041   1.1       mrg 	return error;
   1042   1.1       mrg }
   1043   1.1       mrg 
   1044   1.1       mrg /*
   1045   1.1       mrg  * Generic stop network function:
   1046   1.1       mrg  *	- mark as stopping
   1047   1.1       mrg  *	- call DD routine to stop the device
   1048   1.1       mrg  *	- turn off running, timer, statchg callout, link
   1049   1.1       mrg  *	- stop transfers
   1050   1.1       mrg  *	- free RX and TX resources
   1051   1.1       mrg  *	- close pipes
   1052   1.1       mrg  *
   1053   1.1       mrg  * usbnet_stop() is exported for drivers to use, expects lock held.
   1054   1.1       mrg  *
   1055  1.38   thorpej  * usbnet_if_stop() is for the if_stop handler.
   1056   1.1       mrg  */
   1057   1.1       mrg void
   1058   1.1       mrg usbnet_stop(struct usbnet *un, struct ifnet *ifp, int disable)
   1059   1.1       mrg {
   1060  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
   1061  1.11       mrg 
   1062   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
   1063   1.4       mrg 
   1064  1.38   thorpej 	usbnet_isowned_core(un);
   1065  1.38   thorpej 
   1066  1.38   thorpej 	usbnet_busy(un);
   1067   1.1       mrg 
   1068  1.11       mrg 	mutex_enter(&unp->unp_rxlock);
   1069  1.11       mrg 	mutex_enter(&unp->unp_txlock);
   1070  1.11       mrg 	unp->unp_stopping = true;
   1071  1.11       mrg 	mutex_exit(&unp->unp_txlock);
   1072  1.11       mrg 	mutex_exit(&unp->unp_rxlock);
   1073   1.1       mrg 
   1074  1.10       mrg 	uno_stop(un, ifp, disable);
   1075   1.1       mrg 
   1076   1.1       mrg 	/*
   1077   1.1       mrg 	 * XXXSMP Would like to
   1078   1.1       mrg 	 *	KASSERT(IFNET_LOCKED(ifp))
   1079   1.1       mrg 	 * here but the locking order is:
   1080  1.38   thorpej 	 *	ifnet -> core_lock -> rxlock -> txlock
   1081  1.38   thorpej 	 * and core_lock is already held.
   1082   1.1       mrg 	 */
   1083   1.1       mrg 	ifp->if_flags &= ~IFF_RUNNING;
   1084  1.11       mrg 	unp->unp_timer = 0;
   1085   1.1       mrg 
   1086  1.38   thorpej 	callout_halt(&unp->unp_stat_ch, &unp->unp_core_lock);
   1087  1.26       mrg 	usb_rem_task_wait(un->un_udev, &unp->unp_ticktask, USB_TASKQ_DRIVER,
   1088  1.38   thorpej 	    &unp->unp_core_lock);
   1089   1.1       mrg 
   1090   1.1       mrg 	/* Stop transfers. */
   1091   1.1       mrg 	usbnet_ep_stop_pipes(un);
   1092   1.1       mrg 
   1093   1.1       mrg 	/* Free RX/TX resources. */
   1094   1.1       mrg 	usbnet_rx_list_fini(un);
   1095   1.1       mrg 	usbnet_tx_list_fini(un);
   1096   1.1       mrg 
   1097   1.1       mrg 	/* Close pipes. */
   1098   1.1       mrg 	usbnet_ep_close_pipes(un);
   1099  1.38   thorpej 
   1100  1.38   thorpej 	usbnet_unbusy(un);
   1101   1.1       mrg }
   1102   1.1       mrg 
   1103   1.1       mrg static void
   1104  1.38   thorpej usbnet_if_stop(struct ifnet *ifp, int disable)
   1105   1.1       mrg {
   1106   1.1       mrg 	struct usbnet * const un = ifp->if_softc;
   1107  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
   1108   1.1       mrg 
   1109  1.38   thorpej 	mutex_enter(&unp->unp_core_lock);
   1110   1.1       mrg 	usbnet_stop(un, ifp, disable);
   1111  1.38   thorpej 	mutex_exit(&unp->unp_core_lock);
   1112   1.1       mrg }
   1113   1.1       mrg 
   1114   1.1       mrg /*
   1115   1.1       mrg  * Generic tick task function.
   1116   1.1       mrg  *
   1117   1.1       mrg  * usbnet_tick() is triggered from a callout, and triggers a call to
   1118   1.1       mrg  * usbnet_tick_task() from the usb_task subsystem.
   1119   1.1       mrg  */
   1120   1.1       mrg static void
   1121   1.1       mrg usbnet_tick(void *arg)
   1122   1.1       mrg {
   1123  1.26       mrg 	USBNETHIST_FUNC();
   1124   1.1       mrg 	struct usbnet * const un = arg;
   1125  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
   1126   1.1       mrg 
   1127  1.36  christos 	USBNETHIST_CALLARGSN(10, "%jd: enter", unp->unp_number, 0, 0, 0);
   1128  1.26       mrg 
   1129  1.25       mrg 	if (unp != NULL && !unp->unp_stopping && !unp->unp_dying) {
   1130   1.1       mrg 		/* Perform periodic stuff in process context */
   1131  1.11       mrg 		usb_add_task(un->un_udev, &unp->unp_ticktask, USB_TASKQ_DRIVER);
   1132   1.1       mrg 	}
   1133   1.1       mrg }
   1134   1.1       mrg 
   1135   1.1       mrg static void
   1136   1.1       mrg usbnet_watchdog(struct ifnet *ifp)
   1137   1.1       mrg {
   1138  1.23       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
   1139   1.1       mrg 	struct usbnet * const un = ifp->if_softc;
   1140  1.17       mrg 	struct usbnet_private * const unp = un->un_pri;
   1141  1.11       mrg 	struct usbnet_cdata * const cd = un_cdata(un);
   1142  1.17       mrg 	usbd_status err;
   1143   1.1       mrg 
   1144  1.34   thorpej 	if_statinc(ifp, if_oerrors);
   1145  1.40  jakllsch 	device_printf(un->un_dev, "watchdog timeout\n");
   1146   1.1       mrg 
   1147   1.1       mrg 	if (cd->uncd_tx_cnt > 0) {
   1148  1.37  christos 		DPRINTF("uncd_tx_cnt=%ju non zero, aborting pipe", 0, 0, 0, 0);
   1149  1.17       mrg 		err = usbd_abort_pipe(unp->unp_ep[USBNET_ENDPT_TX]);
   1150  1.20       mrg 		if (err)
   1151  1.40  jakllsch 			device_printf(un->un_dev, "pipe abort failed: %s\n",
   1152  1.20       mrg 			    usbd_errstr(err));
   1153  1.23       mrg 		if (cd->uncd_tx_cnt != 0)
   1154  1.37  christos 			DPRINTF("uncd_tx_cnt now %ju", cd->uncd_tx_cnt, 0, 0, 0);
   1155   1.1       mrg 	}
   1156   1.1       mrg 
   1157   1.1       mrg 	if (!IFQ_IS_EMPTY(&ifp->if_snd))
   1158   1.1       mrg 		(*ifp->if_start)(ifp);
   1159   1.1       mrg }
   1160   1.1       mrg 
   1161   1.1       mrg static void
   1162   1.1       mrg usbnet_tick_task(void *arg)
   1163   1.1       mrg {
   1164  1.26       mrg 	USBNETHIST_FUNC();
   1165   1.1       mrg 	struct usbnet * const un = arg;
   1166  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
   1167   1.1       mrg 
   1168  1.26       mrg 	if (unp == NULL)
   1169  1.26       mrg 		return;
   1170  1.26       mrg 
   1171  1.36  christos 	USBNETHIST_CALLARGSN(8, "%jd: enter", unp->unp_number, 0, 0, 0);
   1172  1.26       mrg 
   1173  1.38   thorpej 	mutex_enter(&unp->unp_core_lock);
   1174  1.11       mrg 	if (unp->unp_stopping || unp->unp_dying) {
   1175  1.38   thorpej 		mutex_exit(&unp->unp_core_lock);
   1176   1.1       mrg 		return;
   1177   1.1       mrg 	}
   1178   1.1       mrg 
   1179   1.1       mrg 	struct ifnet * const ifp = usbnet_ifp(un);
   1180   1.1       mrg 	struct mii_data * const mii = usbnet_mii(un);
   1181   1.1       mrg 
   1182  1.31  riastrad 	KASSERT(ifp != NULL);	/* embedded member */
   1183  1.31  riastrad 
   1184  1.38   thorpej 	usbnet_busy(un);
   1185  1.38   thorpej 	mutex_exit(&unp->unp_core_lock);
   1186   1.1       mrg 
   1187  1.31  riastrad 	if (unp->unp_timer != 0 && --unp->unp_timer == 0)
   1188   1.1       mrg 		usbnet_watchdog(ifp);
   1189   1.1       mrg 
   1190  1.36  christos 	DPRINTFN(8, "mii %#jx ifp %#jx", (uintptr_t)mii, (uintptr_t)ifp, 0, 0);
   1191  1.33      maya 	if (mii) {
   1192  1.38   thorpej 		mutex_enter(&unp->unp_core_lock);
   1193  1.33      maya 		mii_tick(mii);
   1194  1.33      maya 		if (!unp->unp_link)
   1195  1.33      maya 			(*mii->mii_statchg)(ifp);
   1196  1.38   thorpej 		mutex_exit(&unp->unp_core_lock);
   1197  1.33      maya 	}
   1198   1.1       mrg 
   1199  1.15       mrg 	/* Call driver if requested. */
   1200  1.15       mrg 	uno_tick(un);
   1201  1.15       mrg 
   1202  1.38   thorpej 	mutex_enter(&unp->unp_core_lock);
   1203  1.38   thorpej 	usbnet_unbusy(un);
   1204  1.11       mrg 	if (!unp->unp_stopping && !unp->unp_dying)
   1205  1.11       mrg 		callout_schedule(&unp->unp_stat_ch, hz);
   1206  1.38   thorpej 	mutex_exit(&unp->unp_core_lock);
   1207   1.1       mrg }
   1208   1.1       mrg 
   1209   1.1       mrg static int
   1210  1.38   thorpej usbnet_if_init(struct ifnet *ifp)
   1211   1.1       mrg {
   1212   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
   1213   1.1       mrg 	struct usbnet * const un = ifp->if_softc;
   1214   1.1       mrg 
   1215  1.10       mrg 	return uno_init(un, ifp);
   1216   1.1       mrg }
   1217   1.1       mrg 
   1218  1.12       mrg 
   1219  1.11       mrg /* Various accessors. */
   1220  1.11       mrg 
   1221  1.11       mrg void
   1222  1.11       mrg usbnet_set_link(struct usbnet *un, bool link)
   1223  1.11       mrg {
   1224  1.11       mrg 	un->un_pri->unp_link = link;
   1225  1.11       mrg }
   1226  1.11       mrg 
   1227  1.14       mrg void
   1228  1.14       mrg usbnet_set_dying(struct usbnet *un, bool link)
   1229  1.14       mrg {
   1230  1.14       mrg 	un->un_pri->unp_dying = link;
   1231  1.14       mrg }
   1232  1.14       mrg 
   1233  1.11       mrg struct ifnet *
   1234  1.11       mrg usbnet_ifp(struct usbnet *un)
   1235  1.11       mrg {
   1236  1.11       mrg 	return &un->un_pri->unp_ec.ec_if;
   1237  1.11       mrg }
   1238  1.11       mrg 
   1239  1.11       mrg struct ethercom *
   1240  1.11       mrg usbnet_ec(struct usbnet *un)
   1241  1.11       mrg {
   1242  1.11       mrg 	return &un->un_pri->unp_ec;
   1243  1.11       mrg }
   1244  1.11       mrg 
   1245  1.11       mrg struct mii_data *
   1246  1.11       mrg usbnet_mii(struct usbnet *un)
   1247  1.11       mrg {
   1248  1.11       mrg 	return un->un_pri->unp_ec.ec_mii;
   1249  1.11       mrg }
   1250  1.11       mrg 
   1251  1.11       mrg krndsource_t *
   1252  1.11       mrg usbnet_rndsrc(struct usbnet *un)
   1253  1.11       mrg {
   1254  1.11       mrg 	return &un->un_pri->unp_rndsrc;
   1255  1.11       mrg }
   1256  1.11       mrg 
   1257  1.11       mrg void *
   1258  1.11       mrg usbnet_softc(struct usbnet *un)
   1259  1.11       mrg {
   1260  1.11       mrg 	return un->un_sc;
   1261  1.11       mrg }
   1262  1.11       mrg 
   1263  1.11       mrg bool
   1264  1.11       mrg usbnet_havelink(struct usbnet *un)
   1265  1.11       mrg {
   1266  1.11       mrg 	return un->un_pri->unp_link;
   1267  1.11       mrg }
   1268  1.11       mrg 
   1269  1.11       mrg bool
   1270  1.11       mrg usbnet_isdying(struct usbnet *un)
   1271  1.11       mrg {
   1272  1.25       mrg 	return un->un_pri == NULL || un->un_pri->unp_dying;
   1273  1.11       mrg }
   1274  1.11       mrg 
   1275  1.11       mrg 
   1276  1.11       mrg /* Locking. */
   1277  1.11       mrg 
   1278  1.11       mrg void
   1279  1.38   thorpej usbnet_lock_core(struct usbnet *un)
   1280  1.11       mrg {
   1281  1.38   thorpej 	mutex_enter(&un->un_pri->unp_core_lock);
   1282  1.11       mrg }
   1283  1.11       mrg 
   1284  1.11       mrg void
   1285  1.38   thorpej usbnet_unlock_core(struct usbnet *un)
   1286  1.11       mrg {
   1287  1.38   thorpej 	mutex_exit(&un->un_pri->unp_core_lock);
   1288  1.11       mrg }
   1289  1.11       mrg 
   1290  1.11       mrg kmutex_t *
   1291  1.38   thorpej usbnet_mutex_core(struct usbnet *un)
   1292  1.11       mrg {
   1293  1.38   thorpej 	return &un->un_pri->unp_core_lock;
   1294  1.11       mrg }
   1295  1.11       mrg 
   1296  1.11       mrg void
   1297  1.11       mrg usbnet_lock_rx(struct usbnet *un)
   1298  1.11       mrg {
   1299  1.11       mrg 	mutex_enter(&un->un_pri->unp_rxlock);
   1300  1.11       mrg }
   1301  1.11       mrg 
   1302  1.11       mrg void
   1303  1.11       mrg usbnet_unlock_rx(struct usbnet *un)
   1304  1.11       mrg {
   1305  1.11       mrg 	mutex_exit(&un->un_pri->unp_rxlock);
   1306  1.11       mrg }
   1307  1.11       mrg 
   1308  1.11       mrg kmutex_t *
   1309  1.11       mrg usbnet_mutex_rx(struct usbnet *un)
   1310  1.11       mrg {
   1311  1.11       mrg 	return &un->un_pri->unp_rxlock;
   1312  1.11       mrg }
   1313  1.11       mrg 
   1314  1.11       mrg void
   1315  1.11       mrg usbnet_lock_tx(struct usbnet *un)
   1316  1.11       mrg {
   1317  1.11       mrg 	mutex_enter(&un->un_pri->unp_txlock);
   1318  1.11       mrg }
   1319  1.11       mrg 
   1320  1.11       mrg void
   1321  1.11       mrg usbnet_unlock_tx(struct usbnet *un)
   1322  1.11       mrg {
   1323  1.11       mrg 	mutex_exit(&un->un_pri->unp_txlock);
   1324  1.11       mrg }
   1325  1.11       mrg 
   1326  1.11       mrg kmutex_t *
   1327  1.11       mrg usbnet_mutex_tx(struct usbnet *un)
   1328  1.11       mrg {
   1329  1.11       mrg 	return &un->un_pri->unp_txlock;
   1330  1.11       mrg }
   1331  1.11       mrg 
   1332   1.1       mrg /* Autoconf management. */
   1333   1.1       mrg 
   1334   1.5       mrg static bool
   1335  1.12       mrg usbnet_empty_eaddr(struct usbnet * const un)
   1336   1.5       mrg {
   1337   1.5       mrg 	return (un->un_eaddr[0] == 0 && un->un_eaddr[1] == 0 &&
   1338   1.5       mrg 		un->un_eaddr[2] == 0 && un->un_eaddr[3] == 0 &&
   1339   1.5       mrg 		un->un_eaddr[4] == 0 && un->un_eaddr[5] == 0);
   1340   1.5       mrg }
   1341   1.5       mrg 
   1342   1.1       mrg /*
   1343   1.1       mrg  * usbnet_attach() and usbnet_attach_ifp() perform setup of the relevant
   1344   1.1       mrg  * 'usbnet'.  The first is enough to enable device access (eg, endpoints
   1345   1.1       mrg  * are connected and commands can be sent), and the second connects the
   1346   1.1       mrg  * device to the system networking.
   1347   1.1       mrg  *
   1348   1.1       mrg  * Always call usbnet_detach(), even if usbnet_attach_ifp() is skippped.
   1349   1.1       mrg  * Also usable as driver detach directly.
   1350   1.5       mrg  *
   1351   1.5       mrg  * To skip ethernet configuration (eg, point-to-point), make sure that
   1352   1.5       mrg  * the un_eaddr[] is fully zero.
   1353   1.1       mrg  */
   1354  1.11       mrg 
   1355   1.1       mrg void
   1356   1.1       mrg usbnet_attach(struct usbnet *un,
   1357  1.11       mrg 	      const char *detname)	/* detach cv name */
   1358   1.1       mrg {
   1359   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
   1360   1.1       mrg 
   1361  1.10       mrg 	/* Required inputs.  */
   1362  1.10       mrg 	KASSERT(un->un_ops->uno_tx_prepare);
   1363  1.10       mrg 	KASSERT(un->un_ops->uno_rx_loop);
   1364  1.10       mrg 	KASSERT(un->un_ops->uno_init);
   1365  1.11       mrg 	KASSERT(un->un_rx_bufsz);
   1366  1.11       mrg 	KASSERT(un->un_tx_bufsz);
   1367  1.11       mrg 	KASSERT(un->un_rx_list_cnt);
   1368  1.11       mrg 	KASSERT(un->un_tx_list_cnt);
   1369  1.11       mrg 
   1370  1.13       mrg 	/* Unfortunate fact.  */
   1371  1.13       mrg 	KASSERT(un == device_private(un->un_dev));
   1372  1.13       mrg 
   1373  1.11       mrg 	un->un_pri = kmem_zalloc(sizeof(*un->un_pri), KM_SLEEP);
   1374  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
   1375  1.11       mrg 
   1376  1.11       mrg 	usb_init_task(&unp->unp_ticktask, usbnet_tick_task, un, USB_TASKQ_MPSAFE);
   1377  1.11       mrg 	callout_init(&unp->unp_stat_ch, CALLOUT_MPSAFE);
   1378  1.11       mrg 	callout_setfunc(&unp->unp_stat_ch, usbnet_tick, un);
   1379  1.11       mrg 
   1380  1.11       mrg 	mutex_init(&unp->unp_txlock, MUTEX_DEFAULT, IPL_SOFTUSB);
   1381  1.11       mrg 	mutex_init(&unp->unp_rxlock, MUTEX_DEFAULT, IPL_SOFTUSB);
   1382  1.38   thorpej 	mutex_init(&unp->unp_core_lock, MUTEX_DEFAULT, IPL_NONE);
   1383  1.11       mrg 	cv_init(&unp->unp_detachcv, detname);
   1384   1.1       mrg 
   1385  1.11       mrg 	rnd_attach_source(&unp->unp_rndsrc, device_xname(un->un_dev),
   1386   1.1       mrg 	    RND_TYPE_NET, RND_FLAG_DEFAULT);
   1387   1.1       mrg 
   1388  1.10       mrg 	usbnet_rx_list_alloc(un);
   1389  1.10       mrg 	usbnet_tx_list_alloc(un);
   1390   1.1       mrg 
   1391  1.23       mrg 	unp->unp_number = atomic_inc_uint_nv(&usbnet_number);
   1392  1.23       mrg 
   1393  1.11       mrg 	unp->unp_attached = true;
   1394   1.1       mrg }
   1395   1.1       mrg 
   1396   1.1       mrg static void
   1397  1.22       mrg usbnet_attach_mii(struct usbnet *un, const struct usbnet_mii *unm)
   1398   1.1       mrg {
   1399   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
   1400  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
   1401  1.11       mrg 	struct mii_data * const mii = &unp->unp_mii;
   1402  1.11       mrg 	struct ifnet * const ifp = usbnet_ifp(un);
   1403   1.1       mrg 
   1404  1.10       mrg 	KASSERT(un->un_ops->uno_read_reg);
   1405  1.10       mrg 	KASSERT(un->un_ops->uno_write_reg);
   1406  1.10       mrg 	KASSERT(un->un_ops->uno_statchg);
   1407  1.10       mrg 
   1408   1.1       mrg 	mii->mii_ifp = ifp;
   1409  1.10       mrg 	mii->mii_readreg = usbnet_mii_readreg;
   1410  1.10       mrg 	mii->mii_writereg = usbnet_mii_writereg;
   1411  1.10       mrg 	mii->mii_statchg = usbnet_mii_statchg;
   1412   1.1       mrg 	mii->mii_flags = MIIF_AUTOTSLEEP;
   1413   1.1       mrg 
   1414  1.11       mrg 	usbnet_ec(un)->ec_mii = mii;
   1415  1.38   thorpej 	ifmedia_init_with_lock(&mii->mii_media, 0,
   1416  1.38   thorpej 	    usbnet_media_upd, ether_mediastatus, usbnet_mutex_core(un));
   1417  1.22       mrg 	mii_attach(un->un_dev, mii, unm->un_mii_capmask, unm->un_mii_phyloc,
   1418  1.22       mrg 		   unm->un_mii_offset, unm->un_mii_flags);
   1419   1.1       mrg 
   1420   1.1       mrg 	if (LIST_FIRST(&mii->mii_phys) == NULL) {
   1421   1.1       mrg 		ifmedia_add(&mii->mii_media, IFM_ETHER | IFM_NONE, 0, NULL);
   1422   1.1       mrg 		ifmedia_set(&mii->mii_media, IFM_ETHER | IFM_NONE);
   1423   1.1       mrg 	} else
   1424   1.1       mrg 		ifmedia_set(&mii->mii_media, IFM_ETHER | IFM_AUTO);
   1425   1.1       mrg }
   1426   1.1       mrg 
   1427   1.1       mrg void
   1428   1.1       mrg usbnet_attach_ifp(struct usbnet *un,
   1429   1.1       mrg 		  unsigned if_flags,		/* additional if_flags */
   1430   1.2       mrg 		  unsigned if_extflags,		/* additional if_extflags */
   1431  1.22       mrg 		  const struct usbnet_mii *unm)	/* additional mii_attach flags */
   1432   1.1       mrg {
   1433   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
   1434  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
   1435  1.11       mrg 	struct ifnet * const ifp = usbnet_ifp(un);
   1436   1.1       mrg 
   1437  1.11       mrg 	KASSERT(unp->unp_attached);
   1438   1.1       mrg 
   1439   1.1       mrg 	strlcpy(ifp->if_xname, device_xname(un->un_dev), IFNAMSIZ);
   1440   1.1       mrg 	ifp->if_flags = if_flags;
   1441   1.1       mrg 	ifp->if_extflags = IFEF_MPSAFE | if_extflags;
   1442  1.38   thorpej 	ifp->if_ioctl = usbnet_if_ioctl;
   1443  1.38   thorpej 	ifp->if_start = usbnet_if_start;
   1444  1.38   thorpej 	ifp->if_init = usbnet_if_init;
   1445  1.38   thorpej 	ifp->if_stop = usbnet_if_stop;
   1446   1.1       mrg 
   1447  1.22       mrg 	if (unm)
   1448  1.22       mrg 		usbnet_attach_mii(un, unm);
   1449   1.4       mrg 	else
   1450  1.11       mrg 		unp->unp_link = true;
   1451   1.1       mrg 
   1452   1.1       mrg 	/* Attach the interface. */
   1453  1.42  riastrad 	if_initialize(ifp);
   1454  1.17       mrg 	if (ifp->_if_input == NULL)
   1455  1.17       mrg 		ifp->if_percpuq = if_percpuq_create(ifp);
   1456  1.17       mrg 	if_register(ifp);
   1457   1.5       mrg 
   1458   1.5       mrg 	/*
   1459   1.5       mrg 	 * If ethernet address is all zero, skip ether_ifattach() and
   1460   1.5       mrg 	 * instead attach bpf here..
   1461   1.5       mrg 	 */
   1462   1.5       mrg 	if (!usbnet_empty_eaddr(un)) {
   1463  1.11       mrg 		ether_set_ifflags_cb(&unp->unp_ec, usbnet_ifflags_cb);
   1464   1.6       mrg 		aprint_normal_dev(un->un_dev, "Ethernet address %s\n",
   1465   1.6       mrg 		    ether_sprintf(un->un_eaddr));
   1466   1.5       mrg 		ether_ifattach(ifp, un->un_eaddr);
   1467   1.5       mrg 	} else {
   1468   1.5       mrg 		if_alloc_sadl(ifp);
   1469   1.5       mrg 		bpf_attach(ifp, DLT_RAW, 0);
   1470   1.5       mrg 	}
   1471   1.8       mrg 
   1472  1.17       mrg 	/* Now ready, and attached. */
   1473  1.17       mrg 	IFQ_SET_READY(&ifp->if_snd);
   1474  1.17       mrg 	ifp->if_softc = un;
   1475  1.17       mrg 
   1476   1.8       mrg 	usbd_add_drv_event(USB_EVENT_DRIVER_ATTACH, un->un_udev, un->un_dev);
   1477   1.8       mrg 
   1478   1.8       mrg 	if (!pmf_device_register(un->un_dev, NULL, NULL))
   1479   1.8       mrg 		aprint_error_dev(un->un_dev, "couldn't establish power handler\n");
   1480   1.1       mrg }
   1481   1.1       mrg 
   1482   1.1       mrg int
   1483   1.1       mrg usbnet_detach(device_t self, int flags)
   1484   1.1       mrg {
   1485   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
   1486   1.1       mrg 	struct usbnet * const un = device_private(self);
   1487  1.24       mrg 	struct usbnet_private * const unp = un->un_pri;
   1488  1.24       mrg 
   1489  1.24       mrg 	/* Detached before attached finished, so just bail out. */
   1490  1.24       mrg 	if (unp == NULL || !unp->unp_attached)
   1491  1.24       mrg 		return 0;
   1492  1.24       mrg 
   1493  1.11       mrg 	struct ifnet * const ifp = usbnet_ifp(un);
   1494  1.11       mrg 	struct mii_data * const mii = usbnet_mii(un);
   1495   1.1       mrg 
   1496  1.38   thorpej 	mutex_enter(&unp->unp_core_lock);
   1497  1.11       mrg 	unp->unp_dying = true;
   1498  1.38   thorpej 	mutex_exit(&unp->unp_core_lock);
   1499   1.1       mrg 
   1500   1.1       mrg 	if (ifp->if_flags & IFF_RUNNING) {
   1501   1.1       mrg 		IFNET_LOCK(ifp);
   1502  1.38   thorpej 		usbnet_if_stop(ifp, 1);
   1503   1.1       mrg 		IFNET_UNLOCK(ifp);
   1504   1.1       mrg 	}
   1505   1.1       mrg 
   1506  1.26       mrg 	callout_halt(&unp->unp_stat_ch, NULL);
   1507  1.26       mrg 	usb_rem_task_wait(un->un_udev, &unp->unp_ticktask, USB_TASKQ_DRIVER,
   1508  1.26       mrg 	    NULL);
   1509  1.26       mrg 
   1510  1.38   thorpej 	mutex_enter(&unp->unp_core_lock);
   1511  1.11       mrg 	unp->unp_refcnt--;
   1512  1.32  riastrad 	while (unp->unp_refcnt >= 0) {
   1513   1.1       mrg 		/* Wait for processes to go away */
   1514  1.38   thorpej 		cv_wait(&unp->unp_detachcv, &unp->unp_core_lock);
   1515   1.1       mrg 	}
   1516  1.38   thorpej 	mutex_exit(&unp->unp_core_lock);
   1517   1.1       mrg 
   1518   1.1       mrg 	usbnet_rx_list_free(un);
   1519   1.1       mrg 	usbnet_tx_list_free(un);
   1520   1.1       mrg 
   1521  1.11       mrg 	callout_destroy(&unp->unp_stat_ch);
   1522  1.11       mrg 	rnd_detach_source(&unp->unp_rndsrc);
   1523   1.1       mrg 
   1524   1.1       mrg 	if (mii) {
   1525   1.1       mrg 		mii_detach(mii, MII_PHY_ANY, MII_OFFSET_ANY);
   1526  1.35   thorpej 		ifmedia_fini(&mii->mii_media);
   1527   1.1       mrg 	}
   1528   1.1       mrg 	if (ifp->if_softc) {
   1529   1.5       mrg 		if (!usbnet_empty_eaddr(un))
   1530   1.5       mrg 			ether_ifdetach(ifp);
   1531   1.5       mrg 		else
   1532   1.5       mrg 			bpf_detach(ifp);
   1533   1.1       mrg 		if_detach(ifp);
   1534   1.1       mrg 	}
   1535  1.31  riastrad 	usbnet_ec(un)->ec_mii = NULL;
   1536   1.1       mrg 
   1537  1.11       mrg 	cv_destroy(&unp->unp_detachcv);
   1538  1.38   thorpej 	mutex_destroy(&unp->unp_core_lock);
   1539  1.11       mrg 	mutex_destroy(&unp->unp_rxlock);
   1540  1.11       mrg 	mutex_destroy(&unp->unp_txlock);
   1541   1.1       mrg 
   1542   1.1       mrg 	pmf_device_deregister(un->un_dev);
   1543   1.1       mrg 
   1544   1.1       mrg 	usbd_add_drv_event(USB_EVENT_DRIVER_DETACH, un->un_udev, un->un_dev);
   1545   1.1       mrg 
   1546  1.11       mrg 	kmem_free(unp, sizeof(*unp));
   1547  1.26       mrg 	un->un_pri = NULL;
   1548  1.11       mrg 
   1549   1.1       mrg 	return 0;
   1550   1.1       mrg }
   1551   1.1       mrg 
   1552   1.1       mrg int
   1553   1.1       mrg usbnet_activate(device_t self, devact_t act)
   1554   1.1       mrg {
   1555   1.4       mrg 	USBNETHIST_FUNC(); USBNETHIST_CALLED();
   1556   1.1       mrg 	struct usbnet * const un = device_private(self);
   1557  1.11       mrg 	struct usbnet_private * const unp = un->un_pri;
   1558   1.1       mrg 	struct ifnet * const ifp = usbnet_ifp(un);
   1559   1.1       mrg 
   1560   1.1       mrg 	switch (act) {
   1561   1.1       mrg 	case DVACT_DEACTIVATE:
   1562   1.1       mrg 		if_deactivate(ifp);
   1563   1.1       mrg 
   1564  1.38   thorpej 		mutex_enter(&unp->unp_core_lock);
   1565  1.11       mrg 		unp->unp_dying = true;
   1566  1.38   thorpej 		mutex_exit(&unp->unp_core_lock);
   1567  1.11       mrg 
   1568  1.11       mrg 		mutex_enter(&unp->unp_rxlock);
   1569  1.11       mrg 		mutex_enter(&unp->unp_txlock);
   1570  1.11       mrg 		unp->unp_stopping = true;
   1571  1.11       mrg 		mutex_exit(&unp->unp_txlock);
   1572  1.11       mrg 		mutex_exit(&unp->unp_rxlock);
   1573   1.1       mrg 
   1574   1.1       mrg 		return 0;
   1575   1.1       mrg 	default:
   1576   1.1       mrg 		return EOPNOTSUPP;
   1577   1.1       mrg 	}
   1578   1.1       mrg }
   1579   1.1       mrg 
   1580   1.1       mrg MODULE(MODULE_CLASS_MISC, usbnet, NULL);
   1581   1.1       mrg 
   1582   1.1       mrg static int
   1583   1.1       mrg usbnet_modcmd(modcmd_t cmd, void *arg)
   1584   1.1       mrg {
   1585   1.1       mrg 	switch (cmd) {
   1586   1.1       mrg 	case MODULE_CMD_INIT:
   1587   1.4       mrg 		return 0;
   1588   1.1       mrg 	case MODULE_CMD_FINI:
   1589   1.1       mrg 		return 0;
   1590   1.1       mrg 	case MODULE_CMD_STAT:
   1591   1.1       mrg 	case MODULE_CMD_AUTOUNLOAD:
   1592   1.1       mrg 	default:
   1593   1.1       mrg 		return ENOTTY;
   1594   1.1       mrg 	}
   1595   1.1       mrg }
   1596