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