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