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