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