if_urndis.c revision 1.23 1 1.23 macallan /* $NetBSD: if_urndis.c,v 1.23 2019/08/07 22:26:28 macallan Exp $ */
2 1.1 jakllsch /* $OpenBSD: if_urndis.c,v 1.31 2011/07/03 15:47:17 matthew Exp $ */
3 1.1 jakllsch
4 1.1 jakllsch /*
5 1.1 jakllsch * Copyright (c) 2010 Jonathan Armani <armani (at) openbsd.org>
6 1.1 jakllsch * Copyright (c) 2010 Fabien Romano <fabien (at) openbsd.org>
7 1.1 jakllsch * Copyright (c) 2010 Michael Knudsen <mk (at) openbsd.org>
8 1.1 jakllsch * All rights reserved.
9 1.1 jakllsch *
10 1.1 jakllsch * Permission to use, copy, modify, and distribute this software for any
11 1.1 jakllsch * purpose with or without fee is hereby granted, provided that the above
12 1.1 jakllsch * copyright notice and this permission notice appear in all copies.
13 1.1 jakllsch *
14 1.1 jakllsch * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
15 1.1 jakllsch * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
16 1.1 jakllsch * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
17 1.1 jakllsch * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
18 1.1 jakllsch * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
19 1.1 jakllsch * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
20 1.1 jakllsch * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
21 1.1 jakllsch */
22 1.1 jakllsch
23 1.1 jakllsch #include <sys/cdefs.h>
24 1.23 macallan __KERNEL_RCSID(0, "$NetBSD: if_urndis.c,v 1.23 2019/08/07 22:26:28 macallan Exp $");
25 1.14 skrll
26 1.14 skrll #ifdef _KERNEL_OPT
27 1.14 skrll #include "opt_usb.h"
28 1.14 skrll #endif
29 1.1 jakllsch
30 1.1 jakllsch #include <sys/param.h>
31 1.1 jakllsch #include <sys/systm.h>
32 1.1 jakllsch #include <sys/sockio.h>
33 1.1 jakllsch #include <sys/rwlock.h>
34 1.1 jakllsch #include <sys/mbuf.h>
35 1.1 jakllsch #include <sys/kmem.h>
36 1.1 jakllsch #include <sys/kernel.h>
37 1.1 jakllsch #include <sys/proc.h>
38 1.1 jakllsch #include <sys/socket.h>
39 1.1 jakllsch #include <sys/device.h>
40 1.1 jakllsch
41 1.1 jakllsch #include <net/if.h>
42 1.1 jakllsch #include <net/if_dl.h>
43 1.1 jakllsch #include <net/if_media.h>
44 1.1 jakllsch #include <net/if_ether.h>
45 1.1 jakllsch
46 1.1 jakllsch #include <net/bpf.h>
47 1.1 jakllsch
48 1.1 jakllsch #include <sys/bus.h>
49 1.1 jakllsch #include <dev/usb/usb.h>
50 1.1 jakllsch #include <dev/usb/usbdi.h>
51 1.1 jakllsch #include <dev/usb/usbdi_util.h>
52 1.1 jakllsch #include <dev/usb/usbdivar.h>
53 1.1 jakllsch #include <dev/usb/usbdevs.h>
54 1.1 jakllsch #include <dev/usb/usbcdc.h>
55 1.1 jakllsch
56 1.20 nonaka #include <dev/ic/rndisreg.h>
57 1.20 nonaka
58 1.20 nonaka #define RNDIS_RX_LIST_CNT 1
59 1.20 nonaka #define RNDIS_TX_LIST_CNT 1
60 1.20 nonaka #define RNDIS_BUFSZ 1562
61 1.20 nonaka
62 1.20 nonaka struct urndis_softc;
63 1.20 nonaka
64 1.20 nonaka struct urndis_chain {
65 1.20 nonaka struct urndis_softc *sc_softc;
66 1.20 nonaka struct usbd_xfer *sc_xfer;
67 1.20 nonaka char *sc_buf;
68 1.20 nonaka struct mbuf *sc_mbuf;
69 1.20 nonaka };
70 1.20 nonaka
71 1.20 nonaka struct urndis_cdata {
72 1.20 nonaka struct urndis_chain sc_rx_chain[RNDIS_RX_LIST_CNT];
73 1.20 nonaka struct urndis_chain sc_tx_chain[RNDIS_TX_LIST_CNT];
74 1.20 nonaka int sc_tx_cnt;
75 1.20 nonaka };
76 1.20 nonaka
77 1.20 nonaka #define GET_IFP(sc) (&(sc)->sc_ec.ec_if)
78 1.20 nonaka struct urndis_softc {
79 1.20 nonaka device_t sc_dev;
80 1.20 nonaka
81 1.20 nonaka char sc_attached;
82 1.20 nonaka int sc_dying;
83 1.20 nonaka struct ethercom sc_ec;
84 1.20 nonaka
85 1.20 nonaka /* RNDIS device info */
86 1.20 nonaka uint32_t sc_filter;
87 1.20 nonaka uint32_t sc_maxppt;
88 1.20 nonaka uint32_t sc_maxtsz;
89 1.20 nonaka uint32_t sc_palign;
90 1.20 nonaka
91 1.20 nonaka /* USB goo */
92 1.20 nonaka struct usbd_device * sc_udev;
93 1.20 nonaka int sc_ifaceno_ctl;
94 1.20 nonaka struct usbd_interface * sc_iface_ctl;
95 1.20 nonaka struct usbd_interface * sc_iface_data;
96 1.20 nonaka
97 1.20 nonaka struct timeval sc_rx_notice;
98 1.20 nonaka int sc_bulkin_no;
99 1.20 nonaka struct usbd_pipe * sc_bulkin_pipe;
100 1.20 nonaka int sc_bulkout_no;
101 1.20 nonaka struct usbd_pipe * sc_bulkout_pipe;
102 1.20 nonaka
103 1.20 nonaka struct urndis_cdata sc_data;
104 1.20 nonaka };
105 1.1 jakllsch
106 1.1 jakllsch #ifdef URNDIS_DEBUG
107 1.1 jakllsch #define DPRINTF(x) do { printf x; } while (0)
108 1.1 jakllsch #else
109 1.1 jakllsch #define DPRINTF(x)
110 1.1 jakllsch #endif
111 1.1 jakllsch
112 1.1 jakllsch #define DEVNAME(sc) (device_xname(sc->sc_dev))
113 1.1 jakllsch
114 1.1 jakllsch #define URNDIS_RESPONSE_LEN 0x400
115 1.1 jakllsch
116 1.1 jakllsch
117 1.1 jakllsch static int urndis_newbuf(struct urndis_softc *, struct urndis_chain *);
118 1.1 jakllsch
119 1.1 jakllsch static int urndis_ioctl(struct ifnet *, unsigned long, void *);
120 1.1 jakllsch #if 0
121 1.1 jakllsch static void urndis_watchdog(struct ifnet *);
122 1.1 jakllsch #endif
123 1.1 jakllsch
124 1.1 jakllsch static void urndis_start(struct ifnet *);
125 1.11 skrll static void urndis_rxeof(struct usbd_xfer *, void *, usbd_status);
126 1.11 skrll static void urndis_txeof(struct usbd_xfer *, void *, usbd_status);
127 1.1 jakllsch static int urndis_rx_list_init(struct urndis_softc *);
128 1.1 jakllsch static int urndis_tx_list_init(struct urndis_softc *);
129 1.1 jakllsch
130 1.8 skrll static int urndis_init(struct ifnet *);
131 1.1 jakllsch static void urndis_stop(struct ifnet *);
132 1.1 jakllsch
133 1.1 jakllsch static usbd_status urndis_ctrl_msg(struct urndis_softc *, uint8_t, uint8_t,
134 1.1 jakllsch uint16_t, uint16_t, void *, size_t);
135 1.1 jakllsch static usbd_status urndis_ctrl_send(struct urndis_softc *, void *, size_t);
136 1.20 nonaka static struct rndis_comp_hdr *urndis_ctrl_recv(struct urndis_softc *);
137 1.1 jakllsch
138 1.1 jakllsch static uint32_t urndis_ctrl_handle(struct urndis_softc *,
139 1.20 nonaka struct rndis_comp_hdr *, void **, size_t *);
140 1.1 jakllsch static uint32_t urndis_ctrl_handle_init(struct urndis_softc *,
141 1.20 nonaka const struct rndis_comp_hdr *);
142 1.1 jakllsch static uint32_t urndis_ctrl_handle_query(struct urndis_softc *,
143 1.20 nonaka const struct rndis_comp_hdr *, void **, size_t *);
144 1.1 jakllsch static uint32_t urndis_ctrl_handle_reset(struct urndis_softc *,
145 1.20 nonaka const struct rndis_comp_hdr *);
146 1.1 jakllsch
147 1.1 jakllsch static uint32_t urndis_ctrl_init(struct urndis_softc *);
148 1.1 jakllsch #if 0
149 1.1 jakllsch static uint32_t urndis_ctrl_halt(struct urndis_softc *);
150 1.1 jakllsch #endif
151 1.1 jakllsch static uint32_t urndis_ctrl_query(struct urndis_softc *, uint32_t, void *,
152 1.1 jakllsch size_t, void **, size_t *);
153 1.13 msaitoh static uint32_t urndis_ctrl_set(struct urndis_softc *, uint32_t, void *,
154 1.13 msaitoh size_t);
155 1.1 jakllsch #if 0
156 1.1 jakllsch static uint32_t urndis_ctrl_set_param(struct urndis_softc *, const char *,
157 1.1 jakllsch uint32_t, void *, size_t);
158 1.1 jakllsch static uint32_t urndis_ctrl_reset(struct urndis_softc *);
159 1.1 jakllsch static uint32_t urndis_ctrl_keepalive(struct urndis_softc *);
160 1.1 jakllsch #endif
161 1.1 jakllsch
162 1.1 jakllsch static int urndis_encap(struct urndis_softc *, struct mbuf *, int);
163 1.13 msaitoh static void urndis_decap(struct urndis_softc *, struct urndis_chain *,
164 1.13 msaitoh uint32_t);
165 1.1 jakllsch
166 1.1 jakllsch static int urndis_match(device_t, cfdata_t, void *);
167 1.1 jakllsch static void urndis_attach(device_t, device_t, void *);
168 1.1 jakllsch static int urndis_detach(device_t, int);
169 1.1 jakllsch static int urndis_activate(device_t, enum devact);
170 1.1 jakllsch
171 1.1 jakllsch CFATTACH_DECL_NEW(urndis, sizeof(struct urndis_softc),
172 1.1 jakllsch urndis_match, urndis_attach, urndis_detach, urndis_activate);
173 1.1 jakllsch
174 1.1 jakllsch /*
175 1.1 jakllsch * Supported devices that we can't match by class IDs.
176 1.1 jakllsch */
177 1.1 jakllsch static const struct usb_devno urndis_devs[] = {
178 1.1 jakllsch { USB_VENDOR_HTC, USB_PRODUCT_HTC_ANDROID },
179 1.1 jakllsch { USB_VENDOR_SAMSUNG, USB_PRODUCT_SAMSUNG_ANDROID2 },
180 1.23 macallan { USB_VENDOR_SAMSUNG, USB_PRODUCT_SAMSUNG_ANDROID },
181 1.1 jakllsch };
182 1.1 jakllsch
183 1.1 jakllsch static usbd_status
184 1.1 jakllsch urndis_ctrl_msg(struct urndis_softc *sc, uint8_t rt, uint8_t r,
185 1.1 jakllsch uint16_t index, uint16_t value, void *buf, size_t buflen)
186 1.1 jakllsch {
187 1.1 jakllsch usb_device_request_t req;
188 1.1 jakllsch
189 1.1 jakllsch req.bmRequestType = rt;
190 1.1 jakllsch req.bRequest = r;
191 1.1 jakllsch USETW(req.wValue, value);
192 1.1 jakllsch USETW(req.wIndex, index);
193 1.1 jakllsch USETW(req.wLength, buflen);
194 1.1 jakllsch
195 1.1 jakllsch return usbd_do_request(sc->sc_udev, &req, buf);
196 1.1 jakllsch }
197 1.1 jakllsch
198 1.1 jakllsch static usbd_status
199 1.1 jakllsch urndis_ctrl_send(struct urndis_softc *sc, void *buf, size_t len)
200 1.1 jakllsch {
201 1.1 jakllsch usbd_status err;
202 1.1 jakllsch
203 1.1 jakllsch if (sc->sc_dying)
204 1.1 jakllsch return(0);
205 1.1 jakllsch
206 1.1 jakllsch err = urndis_ctrl_msg(sc, UT_WRITE_CLASS_INTERFACE, UR_GET_STATUS,
207 1.1 jakllsch sc->sc_ifaceno_ctl, 0, buf, len);
208 1.1 jakllsch
209 1.1 jakllsch if (err != USBD_NORMAL_COMPLETION)
210 1.1 jakllsch printf("%s: %s\n", DEVNAME(sc), usbd_errstr(err));
211 1.1 jakllsch
212 1.1 jakllsch return err;
213 1.1 jakllsch }
214 1.1 jakllsch
215 1.20 nonaka static struct rndis_comp_hdr *
216 1.1 jakllsch urndis_ctrl_recv(struct urndis_softc *sc)
217 1.1 jakllsch {
218 1.20 nonaka struct rndis_comp_hdr *hdr;
219 1.1 jakllsch char *buf;
220 1.1 jakllsch usbd_status err;
221 1.1 jakllsch
222 1.1 jakllsch buf = kmem_alloc(URNDIS_RESPONSE_LEN, KM_SLEEP);
223 1.1 jakllsch err = urndis_ctrl_msg(sc, UT_READ_CLASS_INTERFACE, UR_CLEAR_FEATURE,
224 1.1 jakllsch sc->sc_ifaceno_ctl, 0, buf, URNDIS_RESPONSE_LEN);
225 1.1 jakllsch
226 1.1 jakllsch if (err != USBD_NORMAL_COMPLETION && err != USBD_SHORT_XFER) {
227 1.1 jakllsch printf("%s: %s\n", DEVNAME(sc), usbd_errstr(err));
228 1.1 jakllsch kmem_free(buf, URNDIS_RESPONSE_LEN);
229 1.1 jakllsch return NULL;
230 1.1 jakllsch }
231 1.1 jakllsch
232 1.20 nonaka hdr = (struct rndis_comp_hdr *)buf;
233 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_recv: type 0x%x len %u\n",
234 1.1 jakllsch DEVNAME(sc),
235 1.1 jakllsch le32toh(hdr->rm_type),
236 1.1 jakllsch le32toh(hdr->rm_len)));
237 1.1 jakllsch
238 1.1 jakllsch if (le32toh(hdr->rm_len) > URNDIS_RESPONSE_LEN) {
239 1.1 jakllsch printf("%s: ctrl message error: wrong size %u > %u\n",
240 1.1 jakllsch DEVNAME(sc),
241 1.1 jakllsch le32toh(hdr->rm_len),
242 1.1 jakllsch URNDIS_RESPONSE_LEN);
243 1.1 jakllsch kmem_free(buf, URNDIS_RESPONSE_LEN);
244 1.1 jakllsch return NULL;
245 1.1 jakllsch }
246 1.1 jakllsch
247 1.1 jakllsch return hdr;
248 1.1 jakllsch }
249 1.1 jakllsch
250 1.1 jakllsch static uint32_t
251 1.20 nonaka urndis_ctrl_handle(struct urndis_softc *sc, struct rndis_comp_hdr *hdr,
252 1.1 jakllsch void **buf, size_t *bufsz)
253 1.1 jakllsch {
254 1.1 jakllsch uint32_t rval;
255 1.1 jakllsch
256 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_handle\n", DEVNAME(sc)));
257 1.1 jakllsch
258 1.1 jakllsch if (buf && bufsz) {
259 1.1 jakllsch *buf = NULL;
260 1.1 jakllsch *bufsz = 0;
261 1.1 jakllsch }
262 1.1 jakllsch
263 1.1 jakllsch switch (le32toh(hdr->rm_type)) {
264 1.1 jakllsch case REMOTE_NDIS_INITIALIZE_CMPLT:
265 1.1 jakllsch rval = urndis_ctrl_handle_init(sc, hdr);
266 1.1 jakllsch break;
267 1.1 jakllsch
268 1.1 jakllsch case REMOTE_NDIS_QUERY_CMPLT:
269 1.1 jakllsch rval = urndis_ctrl_handle_query(sc, hdr, buf, bufsz);
270 1.1 jakllsch break;
271 1.1 jakllsch
272 1.1 jakllsch case REMOTE_NDIS_RESET_CMPLT:
273 1.1 jakllsch rval = urndis_ctrl_handle_reset(sc, hdr);
274 1.1 jakllsch break;
275 1.1 jakllsch
276 1.1 jakllsch case REMOTE_NDIS_KEEPALIVE_CMPLT:
277 1.1 jakllsch case REMOTE_NDIS_SET_CMPLT:
278 1.1 jakllsch rval = le32toh(hdr->rm_status);
279 1.1 jakllsch break;
280 1.1 jakllsch
281 1.1 jakllsch default:
282 1.1 jakllsch printf("%s: ctrl message error: unknown event 0x%x\n",
283 1.1 jakllsch DEVNAME(sc), le32toh(hdr->rm_type));
284 1.1 jakllsch rval = RNDIS_STATUS_FAILURE;
285 1.1 jakllsch }
286 1.1 jakllsch
287 1.1 jakllsch kmem_free(hdr, URNDIS_RESPONSE_LEN);
288 1.1 jakllsch
289 1.1 jakllsch return rval;
290 1.1 jakllsch }
291 1.1 jakllsch
292 1.1 jakllsch static uint32_t
293 1.1 jakllsch urndis_ctrl_handle_init(struct urndis_softc *sc,
294 1.20 nonaka const struct rndis_comp_hdr *hdr)
295 1.1 jakllsch {
296 1.20 nonaka const struct rndis_init_comp *msg;
297 1.1 jakllsch
298 1.20 nonaka msg = (const struct rndis_init_comp *) hdr;
299 1.1 jakllsch
300 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_handle_init: len %u rid %u status 0x%x "
301 1.1 jakllsch "ver_major %u ver_minor %u devflags 0x%x medium 0x%x pktmaxcnt %u "
302 1.1 jakllsch "pktmaxsz %u align %u aflistoffset %u aflistsz %u\n",
303 1.1 jakllsch DEVNAME(sc),
304 1.1 jakllsch le32toh(msg->rm_len),
305 1.1 jakllsch le32toh(msg->rm_rid),
306 1.1 jakllsch le32toh(msg->rm_status),
307 1.1 jakllsch le32toh(msg->rm_ver_major),
308 1.1 jakllsch le32toh(msg->rm_ver_minor),
309 1.1 jakllsch le32toh(msg->rm_devflags),
310 1.1 jakllsch le32toh(msg->rm_medium),
311 1.1 jakllsch le32toh(msg->rm_pktmaxcnt),
312 1.1 jakllsch le32toh(msg->rm_pktmaxsz),
313 1.1 jakllsch le32toh(msg->rm_align),
314 1.1 jakllsch le32toh(msg->rm_aflistoffset),
315 1.1 jakllsch le32toh(msg->rm_aflistsz)));
316 1.1 jakllsch
317 1.1 jakllsch if (le32toh(msg->rm_status) != RNDIS_STATUS_SUCCESS) {
318 1.1 jakllsch printf("%s: init failed 0x%x\n",
319 1.1 jakllsch DEVNAME(sc),
320 1.1 jakllsch le32toh(msg->rm_status));
321 1.1 jakllsch
322 1.1 jakllsch return le32toh(msg->rm_status);
323 1.1 jakllsch }
324 1.1 jakllsch
325 1.1 jakllsch if (le32toh(msg->rm_devflags) != RNDIS_DF_CONNECTIONLESS) {
326 1.1 jakllsch printf("%s: wrong device type (current type: 0x%x)\n",
327 1.1 jakllsch DEVNAME(sc),
328 1.1 jakllsch le32toh(msg->rm_devflags));
329 1.1 jakllsch
330 1.1 jakllsch return RNDIS_STATUS_FAILURE;
331 1.1 jakllsch }
332 1.1 jakllsch
333 1.1 jakllsch if (le32toh(msg->rm_medium) != RNDIS_MEDIUM_802_3) {
334 1.1 jakllsch printf("%s: medium not 802.3 (current medium: 0x%x)\n",
335 1.1 jakllsch DEVNAME(sc), le32toh(msg->rm_medium));
336 1.1 jakllsch
337 1.1 jakllsch return RNDIS_STATUS_FAILURE;
338 1.1 jakllsch }
339 1.1 jakllsch
340 1.19 maya if (le32toh(msg->rm_ver_major) != RNDIS_MAJOR_VERSION ||
341 1.19 maya le32toh(msg->rm_ver_minor) != RNDIS_MINOR_VERSION) {
342 1.19 maya printf("%s: version not %u.%u (current version: %u.%u)\n",
343 1.19 maya DEVNAME(sc), RNDIS_MAJOR_VERSION, RNDIS_MINOR_VERSION,
344 1.19 maya le32toh(msg->rm_ver_major), le32toh(msg->rm_ver_minor));
345 1.19 maya
346 1.19 maya return RNDIS_STATUS_FAILURE;
347 1.19 maya }
348 1.19 maya
349 1.19 maya sc->sc_maxppt = le32toh(msg->rm_pktmaxcnt);
350 1.19 maya sc->sc_maxtsz = le32toh(msg->rm_pktmaxsz);
351 1.19 maya sc->sc_palign = 1U << le32toh(msg->rm_align);
352 1.1 jakllsch
353 1.1 jakllsch return le32toh(msg->rm_status);
354 1.1 jakllsch }
355 1.1 jakllsch
356 1.1 jakllsch static uint32_t
357 1.1 jakllsch urndis_ctrl_handle_query(struct urndis_softc *sc,
358 1.20 nonaka const struct rndis_comp_hdr *hdr, void **buf, size_t *bufsz)
359 1.1 jakllsch {
360 1.20 nonaka const struct rndis_query_comp *msg;
361 1.1 jakllsch
362 1.20 nonaka msg = (const struct rndis_query_comp *) hdr;
363 1.1 jakllsch
364 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_handle_query: len %u rid %u status 0x%x "
365 1.1 jakllsch "buflen %u bufoff %u\n",
366 1.1 jakllsch DEVNAME(sc),
367 1.1 jakllsch le32toh(msg->rm_len),
368 1.1 jakllsch le32toh(msg->rm_rid),
369 1.1 jakllsch le32toh(msg->rm_status),
370 1.1 jakllsch le32toh(msg->rm_infobuflen),
371 1.1 jakllsch le32toh(msg->rm_infobufoffset)));
372 1.1 jakllsch
373 1.1 jakllsch if (buf && bufsz) {
374 1.1 jakllsch *buf = NULL;
375 1.1 jakllsch *bufsz = 0;
376 1.1 jakllsch }
377 1.1 jakllsch
378 1.1 jakllsch if (le32toh(msg->rm_status) != RNDIS_STATUS_SUCCESS) {
379 1.1 jakllsch printf("%s: query failed 0x%x\n",
380 1.1 jakllsch DEVNAME(sc),
381 1.1 jakllsch le32toh(msg->rm_status));
382 1.1 jakllsch
383 1.1 jakllsch return le32toh(msg->rm_status);
384 1.1 jakllsch }
385 1.1 jakllsch
386 1.1 jakllsch if (le32toh(msg->rm_infobuflen) + le32toh(msg->rm_infobufoffset) +
387 1.1 jakllsch RNDIS_HEADER_OFFSET > le32toh(msg->rm_len)) {
388 1.1 jakllsch printf("%s: ctrl message error: invalid query info "
389 1.1 jakllsch "len/offset/end_position(%u/%u/%u) -> "
390 1.1 jakllsch "go out of buffer limit %u\n",
391 1.1 jakllsch DEVNAME(sc),
392 1.1 jakllsch le32toh(msg->rm_infobuflen),
393 1.5 christos le32toh(msg->rm_infobufoffset),
394 1.1 jakllsch le32toh(msg->rm_infobuflen) +
395 1.1 jakllsch le32toh(msg->rm_infobufoffset) + (uint32_t)RNDIS_HEADER_OFFSET,
396 1.1 jakllsch le32toh(msg->rm_len));
397 1.1 jakllsch return RNDIS_STATUS_FAILURE;
398 1.1 jakllsch }
399 1.1 jakllsch
400 1.1 jakllsch if (buf && bufsz) {
401 1.16 chs const char *p;
402 1.16 chs
403 1.1 jakllsch *buf = kmem_alloc(le32toh(msg->rm_infobuflen), KM_SLEEP);
404 1.16 chs *bufsz = le32toh(msg->rm_infobuflen);
405 1.1 jakllsch
406 1.16 chs p = (const char *)&msg->rm_rid;
407 1.16 chs p += le32toh(msg->rm_infobufoffset);
408 1.16 chs memcpy(*buf, p, le32toh(msg->rm_infobuflen));
409 1.1 jakllsch }
410 1.1 jakllsch
411 1.1 jakllsch return le32toh(msg->rm_status);
412 1.1 jakllsch }
413 1.1 jakllsch
414 1.1 jakllsch static uint32_t
415 1.1 jakllsch urndis_ctrl_handle_reset(struct urndis_softc *sc,
416 1.20 nonaka const struct rndis_comp_hdr *hdr)
417 1.1 jakllsch {
418 1.20 nonaka const struct rndis_reset_comp *msg;
419 1.1 jakllsch uint32_t rval;
420 1.1 jakllsch
421 1.20 nonaka msg = (const struct rndis_reset_comp *) hdr;
422 1.1 jakllsch
423 1.1 jakllsch rval = le32toh(msg->rm_status);
424 1.1 jakllsch
425 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_handle_reset: len %u status 0x%x "
426 1.1 jakllsch "adrreset %u\n",
427 1.1 jakllsch DEVNAME(sc),
428 1.1 jakllsch le32toh(msg->rm_len),
429 1.1 jakllsch rval,
430 1.1 jakllsch le32toh(msg->rm_adrreset)));
431 1.1 jakllsch
432 1.1 jakllsch if (rval != RNDIS_STATUS_SUCCESS) {
433 1.1 jakllsch printf("%s: reset failed 0x%x\n", DEVNAME(sc), rval);
434 1.1 jakllsch return rval;
435 1.1 jakllsch }
436 1.1 jakllsch
437 1.1 jakllsch if (le32toh(msg->rm_adrreset) != 0) {
438 1.1 jakllsch uint32_t filter;
439 1.1 jakllsch
440 1.1 jakllsch filter = htole32(sc->sc_filter);
441 1.1 jakllsch rval = urndis_ctrl_set(sc, OID_GEN_CURRENT_PACKET_FILTER,
442 1.1 jakllsch &filter, sizeof(filter));
443 1.1 jakllsch if (rval != RNDIS_STATUS_SUCCESS) {
444 1.1 jakllsch printf("%s: unable to reset data filters\n",
445 1.1 jakllsch DEVNAME(sc));
446 1.1 jakllsch return rval;
447 1.1 jakllsch }
448 1.1 jakllsch }
449 1.1 jakllsch
450 1.1 jakllsch return rval;
451 1.1 jakllsch }
452 1.1 jakllsch
453 1.1 jakllsch static uint32_t
454 1.1 jakllsch urndis_ctrl_init(struct urndis_softc *sc)
455 1.1 jakllsch {
456 1.20 nonaka struct rndis_init_req *msg;
457 1.1 jakllsch uint32_t rval;
458 1.20 nonaka struct rndis_comp_hdr *hdr;
459 1.1 jakllsch
460 1.1 jakllsch msg = kmem_alloc(sizeof(*msg), KM_SLEEP);
461 1.1 jakllsch msg->rm_type = htole32(REMOTE_NDIS_INITIALIZE_MSG);
462 1.1 jakllsch msg->rm_len = htole32(sizeof(*msg));
463 1.1 jakllsch msg->rm_rid = htole32(0);
464 1.19 maya msg->rm_ver_major = htole32(RNDIS_MAJOR_VERSION);
465 1.19 maya msg->rm_ver_minor = htole32(RNDIS_MINOR_VERSION);
466 1.1 jakllsch msg->rm_max_xfersz = htole32(RNDIS_BUFSZ);
467 1.1 jakllsch
468 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_init send: type %u len %u rid %u ver_major %u "
469 1.1 jakllsch "ver_minor %u max_xfersz %u\n",
470 1.1 jakllsch DEVNAME(sc),
471 1.1 jakllsch le32toh(msg->rm_type),
472 1.1 jakllsch le32toh(msg->rm_len),
473 1.1 jakllsch le32toh(msg->rm_rid),
474 1.1 jakllsch le32toh(msg->rm_ver_major),
475 1.1 jakllsch le32toh(msg->rm_ver_minor),
476 1.1 jakllsch le32toh(msg->rm_max_xfersz)));
477 1.1 jakllsch
478 1.1 jakllsch rval = urndis_ctrl_send(sc, msg, sizeof(*msg));
479 1.1 jakllsch kmem_free(msg, sizeof(*msg));
480 1.1 jakllsch
481 1.1 jakllsch if (rval != RNDIS_STATUS_SUCCESS) {
482 1.1 jakllsch printf("%s: init failed\n", DEVNAME(sc));
483 1.1 jakllsch return rval;
484 1.1 jakllsch }
485 1.1 jakllsch
486 1.1 jakllsch if ((hdr = urndis_ctrl_recv(sc)) == NULL) {
487 1.1 jakllsch printf("%s: unable to get init response\n", DEVNAME(sc));
488 1.1 jakllsch return RNDIS_STATUS_FAILURE;
489 1.1 jakllsch }
490 1.1 jakllsch rval = urndis_ctrl_handle(sc, hdr, NULL, NULL);
491 1.1 jakllsch
492 1.1 jakllsch return rval;
493 1.1 jakllsch }
494 1.1 jakllsch
495 1.1 jakllsch #if 0
496 1.1 jakllsch static uint32_t
497 1.1 jakllsch urndis_ctrl_halt(struct urndis_softc *sc)
498 1.1 jakllsch {
499 1.20 nonaka struct rndis_halt_req *msg;
500 1.1 jakllsch uint32_t rval;
501 1.1 jakllsch
502 1.1 jakllsch msg = kmem_alloc(sizeof(*msg), KM_SLEEP);
503 1.1 jakllsch msg->rm_type = htole32(REMOTE_NDIS_HALT_MSG);
504 1.1 jakllsch msg->rm_len = htole32(sizeof(*msg));
505 1.1 jakllsch msg->rm_rid = 0;
506 1.1 jakllsch
507 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_halt send: type %u len %u rid %u\n",
508 1.1 jakllsch DEVNAME(sc),
509 1.1 jakllsch le32toh(msg->rm_type),
510 1.1 jakllsch le32toh(msg->rm_len),
511 1.1 jakllsch le32toh(msg->rm_rid)));
512 1.1 jakllsch
513 1.1 jakllsch rval = urndis_ctrl_send(sc, msg, sizeof(*msg));
514 1.1 jakllsch kmem_free(msg, sizeof(*msg));
515 1.1 jakllsch
516 1.1 jakllsch if (rval != RNDIS_STATUS_SUCCESS)
517 1.1 jakllsch printf("%s: halt failed\n", DEVNAME(sc));
518 1.1 jakllsch
519 1.1 jakllsch return rval;
520 1.1 jakllsch }
521 1.1 jakllsch #endif
522 1.1 jakllsch
523 1.1 jakllsch static uint32_t
524 1.1 jakllsch urndis_ctrl_query(struct urndis_softc *sc, uint32_t oid,
525 1.1 jakllsch void *qbuf, size_t qlen,
526 1.1 jakllsch void **rbuf, size_t *rbufsz)
527 1.1 jakllsch {
528 1.20 nonaka struct rndis_query_req *msg;
529 1.1 jakllsch uint32_t rval;
530 1.20 nonaka struct rndis_comp_hdr *hdr;
531 1.1 jakllsch
532 1.1 jakllsch msg = kmem_alloc(sizeof(*msg) + qlen, KM_SLEEP);
533 1.1 jakllsch msg->rm_type = htole32(REMOTE_NDIS_QUERY_MSG);
534 1.1 jakllsch msg->rm_len = htole32(sizeof(*msg) + qlen);
535 1.1 jakllsch msg->rm_rid = 0; /* XXX */
536 1.1 jakllsch msg->rm_oid = htole32(oid);
537 1.1 jakllsch msg->rm_infobuflen = htole32(qlen);
538 1.1 jakllsch if (qlen != 0) {
539 1.1 jakllsch msg->rm_infobufoffset = htole32(20);
540 1.1 jakllsch memcpy((char*)msg + 20, qbuf, qlen);
541 1.1 jakllsch } else
542 1.1 jakllsch msg->rm_infobufoffset = 0;
543 1.1 jakllsch msg->rm_devicevchdl = 0;
544 1.1 jakllsch
545 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_query send: type %u len %u rid %u oid 0x%x "
546 1.1 jakllsch "infobuflen %u infobufoffset %u devicevchdl %u\n",
547 1.1 jakllsch DEVNAME(sc),
548 1.1 jakllsch le32toh(msg->rm_type),
549 1.1 jakllsch le32toh(msg->rm_len),
550 1.1 jakllsch le32toh(msg->rm_rid),
551 1.1 jakllsch le32toh(msg->rm_oid),
552 1.1 jakllsch le32toh(msg->rm_infobuflen),
553 1.1 jakllsch le32toh(msg->rm_infobufoffset),
554 1.1 jakllsch le32toh(msg->rm_devicevchdl)));
555 1.1 jakllsch
556 1.1 jakllsch rval = urndis_ctrl_send(sc, msg, sizeof(*msg));
557 1.7 skrll kmem_free(msg, sizeof(*msg) + qlen);
558 1.1 jakllsch
559 1.1 jakllsch if (rval != RNDIS_STATUS_SUCCESS) {
560 1.1 jakllsch printf("%s: query failed\n", DEVNAME(sc));
561 1.1 jakllsch return rval;
562 1.1 jakllsch }
563 1.1 jakllsch
564 1.1 jakllsch if ((hdr = urndis_ctrl_recv(sc)) == NULL) {
565 1.1 jakllsch printf("%s: unable to get query response\n", DEVNAME(sc));
566 1.1 jakllsch return RNDIS_STATUS_FAILURE;
567 1.1 jakllsch }
568 1.1 jakllsch rval = urndis_ctrl_handle(sc, hdr, rbuf, rbufsz);
569 1.1 jakllsch
570 1.1 jakllsch return rval;
571 1.1 jakllsch }
572 1.1 jakllsch
573 1.1 jakllsch static uint32_t
574 1.1 jakllsch urndis_ctrl_set(struct urndis_softc *sc, uint32_t oid, void *buf, size_t len)
575 1.1 jakllsch {
576 1.20 nonaka struct rndis_set_req *msg;
577 1.1 jakllsch uint32_t rval;
578 1.20 nonaka struct rndis_comp_hdr *hdr;
579 1.1 jakllsch
580 1.1 jakllsch msg = kmem_alloc(sizeof(*msg) + len, KM_SLEEP);
581 1.1 jakllsch msg->rm_type = htole32(REMOTE_NDIS_SET_MSG);
582 1.1 jakllsch msg->rm_len = htole32(sizeof(*msg) + len);
583 1.1 jakllsch msg->rm_rid = 0; /* XXX */
584 1.1 jakllsch msg->rm_oid = htole32(oid);
585 1.1 jakllsch msg->rm_infobuflen = htole32(len);
586 1.1 jakllsch if (len != 0) {
587 1.1 jakllsch msg->rm_infobufoffset = htole32(20);
588 1.1 jakllsch memcpy((char*)msg + 20, buf, len);
589 1.1 jakllsch } else
590 1.1 jakllsch msg->rm_infobufoffset = 0;
591 1.1 jakllsch msg->rm_devicevchdl = 0;
592 1.1 jakllsch
593 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_set send: type %u len %u rid %u oid 0x%x "
594 1.1 jakllsch "infobuflen %u infobufoffset %u devicevchdl %u\n",
595 1.1 jakllsch DEVNAME(sc),
596 1.1 jakllsch le32toh(msg->rm_type),
597 1.1 jakllsch le32toh(msg->rm_len),
598 1.1 jakllsch le32toh(msg->rm_rid),
599 1.1 jakllsch le32toh(msg->rm_oid),
600 1.1 jakllsch le32toh(msg->rm_infobuflen),
601 1.1 jakllsch le32toh(msg->rm_infobufoffset),
602 1.1 jakllsch le32toh(msg->rm_devicevchdl)));
603 1.1 jakllsch
604 1.1 jakllsch rval = urndis_ctrl_send(sc, msg, sizeof(*msg));
605 1.7 skrll kmem_free(msg, sizeof(*msg) + len);
606 1.1 jakllsch
607 1.1 jakllsch if (rval != RNDIS_STATUS_SUCCESS) {
608 1.1 jakllsch printf("%s: set failed\n", DEVNAME(sc));
609 1.1 jakllsch return rval;
610 1.1 jakllsch }
611 1.1 jakllsch
612 1.1 jakllsch if ((hdr = urndis_ctrl_recv(sc)) == NULL) {
613 1.1 jakllsch printf("%s: unable to get set response\n", DEVNAME(sc));
614 1.1 jakllsch return RNDIS_STATUS_FAILURE;
615 1.1 jakllsch }
616 1.1 jakllsch rval = urndis_ctrl_handle(sc, hdr, NULL, NULL);
617 1.1 jakllsch if (rval != RNDIS_STATUS_SUCCESS)
618 1.1 jakllsch printf("%s: set failed 0x%x\n", DEVNAME(sc), rval);
619 1.5 christos
620 1.1 jakllsch return rval;
621 1.1 jakllsch }
622 1.1 jakllsch
623 1.1 jakllsch #if 0
624 1.1 jakllsch static uint32_t
625 1.1 jakllsch urndis_ctrl_set_param(struct urndis_softc *sc,
626 1.1 jakllsch const char *name,
627 1.1 jakllsch uint32_t type,
628 1.1 jakllsch void *buf,
629 1.1 jakllsch size_t len)
630 1.1 jakllsch {
631 1.20 nonaka struct rndis_set_parameter *param;
632 1.1 jakllsch uint32_t rval;
633 1.1 jakllsch size_t namelen, tlen;
634 1.1 jakllsch
635 1.1 jakllsch if (name)
636 1.1 jakllsch namelen = strlen(name);
637 1.1 jakllsch else
638 1.1 jakllsch namelen = 0;
639 1.1 jakllsch tlen = sizeof(*param) + len + namelen;
640 1.1 jakllsch param = kmem_alloc(tlen, KM_SLEEP);
641 1.1 jakllsch param->rm_namelen = htole32(namelen);
642 1.1 jakllsch param->rm_valuelen = htole32(len);
643 1.1 jakllsch param->rm_type = htole32(type);
644 1.1 jakllsch if (namelen != 0) {
645 1.1 jakllsch param->rm_nameoffset = htole32(20);
646 1.1 jakllsch memcpy(param + 20, name, namelen);
647 1.1 jakllsch } else
648 1.1 jakllsch param->rm_nameoffset = 0;
649 1.1 jakllsch if (len != 0) {
650 1.1 jakllsch param->rm_valueoffset = htole32(20 + namelen);
651 1.1 jakllsch memcpy(param + 20 + namelen, buf, len);
652 1.1 jakllsch } else
653 1.1 jakllsch param->rm_valueoffset = 0;
654 1.1 jakllsch
655 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_set_param send: nameoffset %u namelen %u "
656 1.1 jakllsch "type 0x%x valueoffset %u valuelen %u\n",
657 1.1 jakllsch DEVNAME(sc),
658 1.1 jakllsch le32toh(param->rm_nameoffset),
659 1.1 jakllsch le32toh(param->rm_namelen),
660 1.1 jakllsch le32toh(param->rm_type),
661 1.1 jakllsch le32toh(param->rm_valueoffset),
662 1.1 jakllsch le32toh(param->rm_valuelen)));
663 1.1 jakllsch
664 1.1 jakllsch rval = urndis_ctrl_set(sc, OID_GEN_RNDIS_CONFIG_PARAMETER, param, tlen);
665 1.1 jakllsch kmem_free(param, tlen);
666 1.1 jakllsch if (rval != RNDIS_STATUS_SUCCESS)
667 1.1 jakllsch printf("%s: set param failed 0x%x\n", DEVNAME(sc), rval);
668 1.1 jakllsch
669 1.1 jakllsch return rval;
670 1.1 jakllsch }
671 1.1 jakllsch
672 1.1 jakllsch /* XXX : adrreset, get it from response */
673 1.1 jakllsch static uint32_t
674 1.1 jakllsch urndis_ctrl_reset(struct urndis_softc *sc)
675 1.1 jakllsch {
676 1.20 nonaka struct rndis_reset_req *reset;
677 1.1 jakllsch uint32_t rval;
678 1.20 nonaka struct rndis_comp_hdr *hdr;
679 1.1 jakllsch
680 1.1 jakllsch reset = kmem_alloc(sizeof(*reset), KM_SLEEP);
681 1.1 jakllsch reset->rm_type = htole32(REMOTE_NDIS_RESET_MSG);
682 1.1 jakllsch reset->rm_len = htole32(sizeof(*reset));
683 1.1 jakllsch reset->rm_rid = 0; /* XXX rm_rid == reserved ... remove ? */
684 1.1 jakllsch
685 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_reset send: type %u len %u rid %u\n",
686 1.1 jakllsch DEVNAME(sc),
687 1.1 jakllsch le32toh(reset->rm_type),
688 1.1 jakllsch le32toh(reset->rm_len),
689 1.1 jakllsch le32toh(reset->rm_rid)));
690 1.1 jakllsch
691 1.1 jakllsch rval = urndis_ctrl_send(sc, reset, sizeof(*reset));
692 1.1 jakllsch kmem_free(reset, sizeof(*reset));
693 1.1 jakllsch
694 1.1 jakllsch if (rval != RNDIS_STATUS_SUCCESS) {
695 1.1 jakllsch printf("%s: reset failed\n", DEVNAME(sc));
696 1.1 jakllsch return rval;
697 1.1 jakllsch }
698 1.1 jakllsch
699 1.1 jakllsch if ((hdr = urndis_ctrl_recv(sc)) == NULL) {
700 1.1 jakllsch printf("%s: unable to get reset response\n", DEVNAME(sc));
701 1.1 jakllsch return RNDIS_STATUS_FAILURE;
702 1.1 jakllsch }
703 1.1 jakllsch rval = urndis_ctrl_handle(sc, hdr, NULL, NULL);
704 1.1 jakllsch
705 1.1 jakllsch return rval;
706 1.1 jakllsch }
707 1.1 jakllsch
708 1.1 jakllsch static uint32_t
709 1.1 jakllsch urndis_ctrl_keepalive(struct urndis_softc *sc)
710 1.1 jakllsch {
711 1.20 nonaka struct rndis_keepalive_req *keep;
712 1.1 jakllsch uint32_t rval;
713 1.20 nonaka struct rndis_comp_hdr *hdr;
714 1.1 jakllsch
715 1.1 jakllsch keep = kmem_alloc(sizeof(*keep), KM_SLEEP);
716 1.1 jakllsch keep->rm_type = htole32(REMOTE_NDIS_KEEPALIVE_MSG);
717 1.1 jakllsch keep->rm_len = htole32(sizeof(*keep));
718 1.1 jakllsch keep->rm_rid = 0; /* XXX rm_rid == reserved ... remove ? */
719 1.1 jakllsch
720 1.1 jakllsch DPRINTF(("%s: urndis_ctrl_keepalive: type %u len %u rid %u\n",
721 1.1 jakllsch DEVNAME(sc),
722 1.1 jakllsch le32toh(keep->rm_type),
723 1.1 jakllsch le32toh(keep->rm_len),
724 1.1 jakllsch le32toh(keep->rm_rid)));
725 1.1 jakllsch
726 1.1 jakllsch rval = urndis_ctrl_send(sc, keep, sizeof(*keep));
727 1.1 jakllsch kmem_free(keep, sizeof(*keep));
728 1.1 jakllsch
729 1.1 jakllsch if (rval != RNDIS_STATUS_SUCCESS) {
730 1.1 jakllsch printf("%s: keepalive failed\n", DEVNAME(sc));
731 1.1 jakllsch return rval;
732 1.1 jakllsch }
733 1.1 jakllsch
734 1.1 jakllsch if ((hdr = urndis_ctrl_recv(sc)) == NULL) {
735 1.1 jakllsch printf("%s: unable to get keepalive response\n", DEVNAME(sc));
736 1.1 jakllsch return RNDIS_STATUS_FAILURE;
737 1.1 jakllsch }
738 1.1 jakllsch rval = urndis_ctrl_handle(sc, hdr, NULL, NULL);
739 1.1 jakllsch if (rval != RNDIS_STATUS_SUCCESS) {
740 1.1 jakllsch printf("%s: keepalive failed 0x%x\n", DEVNAME(sc), rval);
741 1.1 jakllsch urndis_ctrl_reset(sc);
742 1.1 jakllsch }
743 1.1 jakllsch
744 1.1 jakllsch return rval;
745 1.1 jakllsch }
746 1.1 jakllsch #endif
747 1.1 jakllsch
748 1.1 jakllsch static int
749 1.1 jakllsch urndis_encap(struct urndis_softc *sc, struct mbuf *m, int idx)
750 1.1 jakllsch {
751 1.1 jakllsch struct urndis_chain *c;
752 1.1 jakllsch usbd_status err;
753 1.20 nonaka struct rndis_packet_msg *msg;
754 1.1 jakllsch
755 1.1 jakllsch c = &sc->sc_data.sc_tx_chain[idx];
756 1.1 jakllsch
757 1.20 nonaka msg = (struct rndis_packet_msg *)c->sc_buf;
758 1.1 jakllsch
759 1.1 jakllsch memset(msg, 0, sizeof(*msg));
760 1.1 jakllsch msg->rm_type = htole32(REMOTE_NDIS_PACKET_MSG);
761 1.1 jakllsch msg->rm_len = htole32(sizeof(*msg) + m->m_pkthdr.len);
762 1.1 jakllsch
763 1.1 jakllsch msg->rm_dataoffset = htole32(RNDIS_DATA_OFFSET);
764 1.1 jakllsch msg->rm_datalen = htole32(m->m_pkthdr.len);
765 1.1 jakllsch
766 1.1 jakllsch m_copydata(m, 0, m->m_pkthdr.len,
767 1.1 jakllsch ((char*)msg + RNDIS_DATA_OFFSET + RNDIS_HEADER_OFFSET));
768 1.1 jakllsch
769 1.1 jakllsch DPRINTF(("%s: urndis_encap type 0x%x len %u data(off %u len %u)\n",
770 1.1 jakllsch DEVNAME(sc),
771 1.1 jakllsch le32toh(msg->rm_type),
772 1.1 jakllsch le32toh(msg->rm_len),
773 1.1 jakllsch le32toh(msg->rm_dataoffset),
774 1.1 jakllsch le32toh(msg->rm_datalen)));
775 1.1 jakllsch
776 1.1 jakllsch c->sc_mbuf = m;
777 1.1 jakllsch
778 1.11 skrll usbd_setup_xfer(c->sc_xfer, c, c->sc_buf, le32toh(msg->rm_len),
779 1.11 skrll USBD_FORCE_SHORT_XFER, 10000, urndis_txeof);
780 1.1 jakllsch
781 1.1 jakllsch /* Transmit */
782 1.1 jakllsch err = usbd_transfer(c->sc_xfer);
783 1.1 jakllsch if (err != USBD_IN_PROGRESS) {
784 1.1 jakllsch urndis_stop(GET_IFP(sc));
785 1.1 jakllsch return(EIO);
786 1.1 jakllsch }
787 1.1 jakllsch
788 1.1 jakllsch sc->sc_data.sc_tx_cnt++;
789 1.1 jakllsch
790 1.1 jakllsch return(0);
791 1.1 jakllsch }
792 1.1 jakllsch
793 1.1 jakllsch static void
794 1.1 jakllsch urndis_decap(struct urndis_softc *sc, struct urndis_chain *c, uint32_t len)
795 1.1 jakllsch {
796 1.1 jakllsch struct mbuf *m;
797 1.20 nonaka struct rndis_packet_msg *msg;
798 1.1 jakllsch struct ifnet *ifp;
799 1.1 jakllsch int s;
800 1.1 jakllsch int offset;
801 1.1 jakllsch
802 1.1 jakllsch ifp = GET_IFP(sc);
803 1.1 jakllsch offset = 0;
804 1.5 christos
805 1.19 maya while (len > 1) {
806 1.20 nonaka msg = (struct rndis_packet_msg *)((char*)c->sc_buf + offset);
807 1.1 jakllsch m = c->sc_mbuf;
808 1.1 jakllsch
809 1.1 jakllsch DPRINTF(("%s: urndis_decap buffer size left %u\n", DEVNAME(sc),
810 1.1 jakllsch len));
811 1.1 jakllsch
812 1.1 jakllsch if (len < sizeof(*msg)) {
813 1.1 jakllsch printf("%s: urndis_decap invalid buffer len %u < "
814 1.1 jakllsch "minimum header %zu\n",
815 1.1 jakllsch DEVNAME(sc),
816 1.1 jakllsch len,
817 1.1 jakllsch sizeof(*msg));
818 1.1 jakllsch return;
819 1.1 jakllsch }
820 1.1 jakllsch
821 1.1 jakllsch DPRINTF(("%s: urndis_decap len %u data(off:%u len:%u) "
822 1.1 jakllsch "oobdata(off:%u len:%u nb:%u) perpacket(off:%u len:%u)\n",
823 1.1 jakllsch DEVNAME(sc),
824 1.1 jakllsch le32toh(msg->rm_len),
825 1.1 jakllsch le32toh(msg->rm_dataoffset),
826 1.1 jakllsch le32toh(msg->rm_datalen),
827 1.1 jakllsch le32toh(msg->rm_oobdataoffset),
828 1.1 jakllsch le32toh(msg->rm_oobdatalen),
829 1.1 jakllsch le32toh(msg->rm_oobdataelements),
830 1.1 jakllsch le32toh(msg->rm_pktinfooffset),
831 1.1 jakllsch le32toh(msg->rm_pktinfooffset)));
832 1.1 jakllsch
833 1.1 jakllsch if (le32toh(msg->rm_type) != REMOTE_NDIS_PACKET_MSG) {
834 1.1 jakllsch printf("%s: urndis_decap invalid type 0x%x != 0x%x\n",
835 1.1 jakllsch DEVNAME(sc),
836 1.1 jakllsch le32toh(msg->rm_type),
837 1.1 jakllsch REMOTE_NDIS_PACKET_MSG);
838 1.1 jakllsch return;
839 1.1 jakllsch }
840 1.1 jakllsch if (le32toh(msg->rm_len) < sizeof(*msg)) {
841 1.1 jakllsch printf("%s: urndis_decap invalid msg len %u < %zu\n",
842 1.1 jakllsch DEVNAME(sc),
843 1.1 jakllsch le32toh(msg->rm_len),
844 1.1 jakllsch sizeof(*msg));
845 1.1 jakllsch return;
846 1.1 jakllsch }
847 1.1 jakllsch if (le32toh(msg->rm_len) > len) {
848 1.1 jakllsch printf("%s: urndis_decap invalid msg len %u > buffer "
849 1.1 jakllsch "len %u\n",
850 1.1 jakllsch DEVNAME(sc),
851 1.1 jakllsch le32toh(msg->rm_len),
852 1.1 jakllsch len);
853 1.1 jakllsch return;
854 1.1 jakllsch }
855 1.1 jakllsch
856 1.1 jakllsch if (le32toh(msg->rm_dataoffset) +
857 1.5 christos le32toh(msg->rm_datalen) + RNDIS_HEADER_OFFSET
858 1.1 jakllsch > le32toh(msg->rm_len)) {
859 1.1 jakllsch printf("%s: urndis_decap invalid data "
860 1.1 jakllsch "len/offset/end_position(%u/%u/%u) -> "
861 1.1 jakllsch "go out of receive buffer limit %u\n",
862 1.1 jakllsch DEVNAME(sc),
863 1.1 jakllsch le32toh(msg->rm_datalen),
864 1.1 jakllsch le32toh(msg->rm_dataoffset),
865 1.1 jakllsch le32toh(msg->rm_dataoffset) +
866 1.1 jakllsch le32toh(msg->rm_datalen) + (uint32_t)RNDIS_HEADER_OFFSET,
867 1.1 jakllsch le32toh(msg->rm_len));
868 1.1 jakllsch return;
869 1.1 jakllsch }
870 1.1 jakllsch
871 1.1 jakllsch if (le32toh(msg->rm_datalen) < sizeof(struct ether_header)) {
872 1.1 jakllsch ifp->if_ierrors++;
873 1.1 jakllsch printf("%s: urndis_decap invalid ethernet size "
874 1.1 jakllsch "%d < %zu\n",
875 1.1 jakllsch DEVNAME(sc),
876 1.1 jakllsch le32toh(msg->rm_datalen),
877 1.1 jakllsch sizeof(struct ether_header));
878 1.1 jakllsch return;
879 1.1 jakllsch }
880 1.1 jakllsch
881 1.1 jakllsch memcpy(mtod(m, char*),
882 1.1 jakllsch ((char*)&msg->rm_dataoffset + le32toh(msg->rm_dataoffset)),
883 1.1 jakllsch le32toh(msg->rm_datalen));
884 1.1 jakllsch m->m_pkthdr.len = m->m_len = le32toh(msg->rm_datalen);
885 1.1 jakllsch
886 1.12 ozaki m_set_rcvif(m, ifp);
887 1.1 jakllsch
888 1.1 jakllsch s = splnet();
889 1.1 jakllsch
890 1.1 jakllsch if (urndis_newbuf(sc, c) == ENOBUFS) {
891 1.1 jakllsch ifp->if_ierrors++;
892 1.1 jakllsch } else {
893 1.10 ozaki if_percpuq_enqueue(ifp->if_percpuq, m);
894 1.1 jakllsch }
895 1.1 jakllsch splx(s);
896 1.1 jakllsch
897 1.1 jakllsch offset += le32toh(msg->rm_len);
898 1.1 jakllsch len -= le32toh(msg->rm_len);
899 1.1 jakllsch }
900 1.1 jakllsch }
901 1.1 jakllsch
902 1.1 jakllsch static int
903 1.1 jakllsch urndis_newbuf(struct urndis_softc *sc, struct urndis_chain *c)
904 1.1 jakllsch {
905 1.1 jakllsch struct mbuf *m_new = NULL;
906 1.1 jakllsch
907 1.1 jakllsch MGETHDR(m_new, M_DONTWAIT, MT_DATA);
908 1.1 jakllsch if (m_new == NULL) {
909 1.1 jakllsch printf("%s: no memory for rx list -- packet dropped!\n",
910 1.1 jakllsch DEVNAME(sc));
911 1.11 skrll return ENOBUFS;
912 1.1 jakllsch }
913 1.1 jakllsch MCLGET(m_new, M_DONTWAIT);
914 1.1 jakllsch if (!(m_new->m_flags & M_EXT)) {
915 1.1 jakllsch printf("%s: no memory for rx list -- packet dropped!\n",
916 1.1 jakllsch DEVNAME(sc));
917 1.1 jakllsch m_freem(m_new);
918 1.11 skrll return ENOBUFS;
919 1.1 jakllsch }
920 1.1 jakllsch m_new->m_len = m_new->m_pkthdr.len = MCLBYTES;
921 1.1 jakllsch
922 1.1 jakllsch m_adj(m_new, ETHER_ALIGN);
923 1.1 jakllsch c->sc_mbuf = m_new;
924 1.11 skrll return 0;
925 1.1 jakllsch }
926 1.1 jakllsch
927 1.1 jakllsch static int
928 1.1 jakllsch urndis_rx_list_init(struct urndis_softc *sc)
929 1.1 jakllsch {
930 1.1 jakllsch struct urndis_cdata *cd;
931 1.1 jakllsch struct urndis_chain *c;
932 1.1 jakllsch int i;
933 1.1 jakllsch
934 1.1 jakllsch cd = &sc->sc_data;
935 1.1 jakllsch for (i = 0; i < RNDIS_RX_LIST_CNT; i++) {
936 1.1 jakllsch c = &cd->sc_rx_chain[i];
937 1.1 jakllsch c->sc_softc = sc;
938 1.1 jakllsch
939 1.1 jakllsch if (urndis_newbuf(sc, c) == ENOBUFS)
940 1.11 skrll return ENOBUFS;
941 1.1 jakllsch
942 1.1 jakllsch if (c->sc_xfer == NULL) {
943 1.11 skrll int err = usbd_create_xfer(sc->sc_bulkin_pipe,
944 1.17 skrll RNDIS_BUFSZ, 0, 0, &c->sc_xfer);
945 1.11 skrll if (err)
946 1.11 skrll return err;
947 1.11 skrll c->sc_buf = usbd_get_buffer(c->sc_xfer);
948 1.1 jakllsch }
949 1.1 jakllsch }
950 1.1 jakllsch
951 1.11 skrll return 0;
952 1.1 jakllsch }
953 1.1 jakllsch
954 1.1 jakllsch static int
955 1.1 jakllsch urndis_tx_list_init(struct urndis_softc *sc)
956 1.1 jakllsch {
957 1.1 jakllsch struct urndis_cdata *cd;
958 1.1 jakllsch struct urndis_chain *c;
959 1.1 jakllsch int i;
960 1.1 jakllsch
961 1.1 jakllsch cd = &sc->sc_data;
962 1.1 jakllsch for (i = 0; i < RNDIS_TX_LIST_CNT; i++) {
963 1.1 jakllsch c = &cd->sc_tx_chain[i];
964 1.1 jakllsch c->sc_softc = sc;
965 1.1 jakllsch c->sc_mbuf = NULL;
966 1.1 jakllsch if (c->sc_xfer == NULL) {
967 1.11 skrll int err = usbd_create_xfer(sc->sc_bulkout_pipe,
968 1.11 skrll RNDIS_BUFSZ, USBD_FORCE_SHORT_XFER, 0, &c->sc_xfer);
969 1.11 skrll if (err)
970 1.11 skrll return err;
971 1.11 skrll c->sc_buf = usbd_get_buffer(c->sc_xfer);
972 1.1 jakllsch }
973 1.1 jakllsch }
974 1.11 skrll return 0;
975 1.1 jakllsch }
976 1.1 jakllsch
977 1.1 jakllsch static int
978 1.1 jakllsch urndis_ioctl(struct ifnet *ifp, unsigned long command, void *data)
979 1.1 jakllsch {
980 1.1 jakllsch struct urndis_softc *sc;
981 1.1 jakllsch int s, error;
982 1.1 jakllsch
983 1.1 jakllsch sc = ifp->if_softc;
984 1.1 jakllsch error = 0;
985 1.1 jakllsch
986 1.1 jakllsch if (sc->sc_dying)
987 1.11 skrll return EIO;
988 1.1 jakllsch
989 1.1 jakllsch s = splnet();
990 1.1 jakllsch
991 1.1 jakllsch switch(command) {
992 1.1 jakllsch case SIOCSIFFLAGS:
993 1.1 jakllsch if ((error = ifioctl_common(ifp, command, data)) != 0)
994 1.1 jakllsch break;
995 1.1 jakllsch if (ifp->if_flags & IFF_UP) {
996 1.1 jakllsch if (!(ifp->if_flags & IFF_RUNNING))
997 1.1 jakllsch urndis_init(ifp);
998 1.1 jakllsch } else {
999 1.1 jakllsch if (ifp->if_flags & IFF_RUNNING)
1000 1.1 jakllsch urndis_stop(ifp);
1001 1.1 jakllsch }
1002 1.1 jakllsch error = 0;
1003 1.1 jakllsch break;
1004 1.1 jakllsch
1005 1.1 jakllsch default:
1006 1.1 jakllsch error = ether_ioctl(ifp, command, data);
1007 1.1 jakllsch break;
1008 1.1 jakllsch }
1009 1.1 jakllsch
1010 1.1 jakllsch if (error == ENETRESET)
1011 1.1 jakllsch error = 0;
1012 1.1 jakllsch
1013 1.1 jakllsch splx(s);
1014 1.11 skrll return error;
1015 1.1 jakllsch }
1016 1.1 jakllsch
1017 1.1 jakllsch #if 0
1018 1.1 jakllsch static void
1019 1.1 jakllsch urndis_watchdog(struct ifnet *ifp)
1020 1.1 jakllsch {
1021 1.1 jakllsch struct urndis_softc *sc;
1022 1.1 jakllsch
1023 1.1 jakllsch sc = ifp->if_softc;
1024 1.1 jakllsch
1025 1.1 jakllsch if (sc->sc_dying)
1026 1.1 jakllsch return;
1027 1.1 jakllsch
1028 1.1 jakllsch ifp->if_oerrors++;
1029 1.1 jakllsch printf("%s: watchdog timeout\n", DEVNAME(sc));
1030 1.1 jakllsch
1031 1.1 jakllsch urndis_ctrl_keepalive(sc);
1032 1.1 jakllsch }
1033 1.1 jakllsch #endif
1034 1.1 jakllsch
1035 1.8 skrll static int
1036 1.1 jakllsch urndis_init(struct ifnet *ifp)
1037 1.1 jakllsch {
1038 1.1 jakllsch struct urndis_softc *sc;
1039 1.1 jakllsch int i, s;
1040 1.8 skrll int err;
1041 1.8 skrll usbd_status usberr;
1042 1.1 jakllsch
1043 1.1 jakllsch sc = ifp->if_softc;
1044 1.1 jakllsch
1045 1.1 jakllsch if (ifp->if_flags & IFF_RUNNING)
1046 1.9 skrll return 0;
1047 1.1 jakllsch
1048 1.8 skrll err = urndis_ctrl_init(sc);
1049 1.8 skrll if (err != RNDIS_STATUS_SUCCESS)
1050 1.8 skrll return EIO;
1051 1.1 jakllsch
1052 1.1 jakllsch s = splnet();
1053 1.1 jakllsch
1054 1.8 skrll usberr = usbd_open_pipe(sc->sc_iface_data, sc->sc_bulkin_no,
1055 1.1 jakllsch USBD_EXCLUSIVE_USE, &sc->sc_bulkin_pipe);
1056 1.8 skrll if (usberr) {
1057 1.1 jakllsch printf("%s: open rx pipe failed: %s\n", DEVNAME(sc),
1058 1.1 jakllsch usbd_errstr(err));
1059 1.1 jakllsch splx(s);
1060 1.8 skrll return EIO;
1061 1.1 jakllsch }
1062 1.1 jakllsch
1063 1.8 skrll usberr = usbd_open_pipe(sc->sc_iface_data, sc->sc_bulkout_no,
1064 1.1 jakllsch USBD_EXCLUSIVE_USE, &sc->sc_bulkout_pipe);
1065 1.8 skrll if (usberr) {
1066 1.1 jakllsch printf("%s: open tx pipe failed: %s\n", DEVNAME(sc),
1067 1.1 jakllsch usbd_errstr(err));
1068 1.1 jakllsch splx(s);
1069 1.8 skrll return EIO;
1070 1.1 jakllsch }
1071 1.1 jakllsch
1072 1.11 skrll err = urndis_tx_list_init(sc);
1073 1.11 skrll if (err) {
1074 1.11 skrll printf("%s: tx list init failed\n",
1075 1.11 skrll DEVNAME(sc));
1076 1.11 skrll splx(s);
1077 1.11 skrll return err;
1078 1.11 skrll }
1079 1.11 skrll
1080 1.11 skrll err = urndis_rx_list_init(sc);
1081 1.11 skrll if (err) {
1082 1.11 skrll printf("%s: rx list init failed\n",
1083 1.11 skrll DEVNAME(sc));
1084 1.11 skrll splx(s);
1085 1.11 skrll return err;
1086 1.11 skrll }
1087 1.11 skrll
1088 1.1 jakllsch for (i = 0; i < RNDIS_RX_LIST_CNT; i++) {
1089 1.1 jakllsch struct urndis_chain *c;
1090 1.1 jakllsch
1091 1.1 jakllsch c = &sc->sc_data.sc_rx_chain[i];
1092 1.11 skrll
1093 1.11 skrll usbd_setup_xfer(c->sc_xfer, c, c->sc_buf, RNDIS_BUFSZ,
1094 1.11 skrll USBD_SHORT_XFER_OK, USBD_NO_TIMEOUT, urndis_rxeof);
1095 1.1 jakllsch usbd_transfer(c->sc_xfer);
1096 1.1 jakllsch }
1097 1.1 jakllsch
1098 1.1 jakllsch ifp->if_flags |= IFF_RUNNING;
1099 1.1 jakllsch ifp->if_flags &= ~IFF_OACTIVE;
1100 1.1 jakllsch
1101 1.1 jakllsch splx(s);
1102 1.8 skrll return 0;
1103 1.1 jakllsch }
1104 1.1 jakllsch
1105 1.1 jakllsch static void
1106 1.1 jakllsch urndis_stop(struct ifnet *ifp)
1107 1.1 jakllsch {
1108 1.1 jakllsch struct urndis_softc *sc;
1109 1.1 jakllsch usbd_status err;
1110 1.1 jakllsch int i;
1111 1.1 jakllsch
1112 1.1 jakllsch sc = ifp->if_softc;
1113 1.1 jakllsch
1114 1.1 jakllsch ifp->if_timer = 0;
1115 1.1 jakllsch ifp->if_flags &= ~(IFF_RUNNING | IFF_OACTIVE);
1116 1.1 jakllsch
1117 1.1 jakllsch if (sc->sc_bulkin_pipe != NULL) {
1118 1.1 jakllsch err = usbd_abort_pipe(sc->sc_bulkin_pipe);
1119 1.1 jakllsch if (err)
1120 1.1 jakllsch printf("%s: abort rx pipe failed: %s\n",
1121 1.1 jakllsch DEVNAME(sc), usbd_errstr(err));
1122 1.1 jakllsch }
1123 1.1 jakllsch
1124 1.1 jakllsch if (sc->sc_bulkout_pipe != NULL) {
1125 1.1 jakllsch err = usbd_abort_pipe(sc->sc_bulkout_pipe);
1126 1.1 jakllsch if (err)
1127 1.1 jakllsch printf("%s: abort tx pipe failed: %s\n",
1128 1.1 jakllsch DEVNAME(sc), usbd_errstr(err));
1129 1.1 jakllsch }
1130 1.1 jakllsch
1131 1.1 jakllsch for (i = 0; i < RNDIS_RX_LIST_CNT; i++) {
1132 1.1 jakllsch if (sc->sc_data.sc_rx_chain[i].sc_mbuf != NULL) {
1133 1.1 jakllsch m_freem(sc->sc_data.sc_rx_chain[i].sc_mbuf);
1134 1.1 jakllsch sc->sc_data.sc_rx_chain[i].sc_mbuf = NULL;
1135 1.1 jakllsch }
1136 1.1 jakllsch if (sc->sc_data.sc_rx_chain[i].sc_xfer != NULL) {
1137 1.11 skrll usbd_destroy_xfer(sc->sc_data.sc_rx_chain[i].sc_xfer);
1138 1.1 jakllsch sc->sc_data.sc_rx_chain[i].sc_xfer = NULL;
1139 1.1 jakllsch }
1140 1.1 jakllsch }
1141 1.1 jakllsch
1142 1.1 jakllsch for (i = 0; i < RNDIS_TX_LIST_CNT; i++) {
1143 1.1 jakllsch if (sc->sc_data.sc_tx_chain[i].sc_mbuf != NULL) {
1144 1.1 jakllsch m_freem(sc->sc_data.sc_tx_chain[i].sc_mbuf);
1145 1.1 jakllsch sc->sc_data.sc_tx_chain[i].sc_mbuf = NULL;
1146 1.1 jakllsch }
1147 1.1 jakllsch if (sc->sc_data.sc_tx_chain[i].sc_xfer != NULL) {
1148 1.11 skrll usbd_destroy_xfer(sc->sc_data.sc_tx_chain[i].sc_xfer);
1149 1.1 jakllsch sc->sc_data.sc_tx_chain[i].sc_xfer = NULL;
1150 1.1 jakllsch }
1151 1.1 jakllsch }
1152 1.11 skrll
1153 1.11 skrll /* Close pipes. */
1154 1.11 skrll if (sc->sc_bulkin_pipe != NULL) {
1155 1.11 skrll err = usbd_close_pipe(sc->sc_bulkin_pipe);
1156 1.11 skrll if (err)
1157 1.11 skrll printf("%s: close rx pipe failed: %s\n",
1158 1.11 skrll DEVNAME(sc), usbd_errstr(err));
1159 1.11 skrll sc->sc_bulkin_pipe = NULL;
1160 1.11 skrll }
1161 1.11 skrll
1162 1.11 skrll if (sc->sc_bulkout_pipe != NULL) {
1163 1.11 skrll err = usbd_close_pipe(sc->sc_bulkout_pipe);
1164 1.11 skrll if (err)
1165 1.11 skrll printf("%s: close tx pipe failed: %s\n",
1166 1.11 skrll DEVNAME(sc), usbd_errstr(err));
1167 1.11 skrll sc->sc_bulkout_pipe = NULL;
1168 1.11 skrll }
1169 1.1 jakllsch }
1170 1.1 jakllsch
1171 1.1 jakllsch static void
1172 1.1 jakllsch urndis_start(struct ifnet *ifp)
1173 1.1 jakllsch {
1174 1.1 jakllsch struct urndis_softc *sc;
1175 1.1 jakllsch struct mbuf *m_head = NULL;
1176 1.1 jakllsch
1177 1.1 jakllsch sc = ifp->if_softc;
1178 1.1 jakllsch
1179 1.1 jakllsch if (sc->sc_dying || (ifp->if_flags & IFF_OACTIVE))
1180 1.1 jakllsch return;
1181 1.1 jakllsch
1182 1.1 jakllsch IFQ_POLL(&ifp->if_snd, m_head);
1183 1.1 jakllsch if (m_head == NULL)
1184 1.1 jakllsch return;
1185 1.1 jakllsch
1186 1.1 jakllsch if (urndis_encap(sc, m_head, 0)) {
1187 1.1 jakllsch ifp->if_flags |= IFF_OACTIVE;
1188 1.1 jakllsch return;
1189 1.1 jakllsch }
1190 1.1 jakllsch IFQ_DEQUEUE(&ifp->if_snd, m_head);
1191 1.1 jakllsch
1192 1.1 jakllsch /*
1193 1.1 jakllsch * If there's a BPF listener, bounce a copy of this frame
1194 1.1 jakllsch * to him.
1195 1.1 jakllsch */
1196 1.18 msaitoh bpf_mtap(ifp, m_head, BPF_D_OUT);
1197 1.1 jakllsch
1198 1.1 jakllsch ifp->if_flags |= IFF_OACTIVE;
1199 1.1 jakllsch
1200 1.1 jakllsch /*
1201 1.1 jakllsch * Set a timeout in case the chip goes out to lunch.
1202 1.1 jakllsch */
1203 1.1 jakllsch ifp->if_timer = 5;
1204 1.1 jakllsch
1205 1.1 jakllsch return;
1206 1.1 jakllsch }
1207 1.1 jakllsch
1208 1.1 jakllsch static void
1209 1.11 skrll urndis_rxeof(struct usbd_xfer *xfer,
1210 1.11 skrll void *priv,
1211 1.1 jakllsch usbd_status status)
1212 1.1 jakllsch {
1213 1.1 jakllsch struct urndis_chain *c;
1214 1.1 jakllsch struct urndis_softc *sc;
1215 1.1 jakllsch struct ifnet *ifp;
1216 1.1 jakllsch uint32_t total_len;
1217 1.1 jakllsch
1218 1.1 jakllsch c = priv;
1219 1.1 jakllsch sc = c->sc_softc;
1220 1.1 jakllsch ifp = GET_IFP(sc);
1221 1.1 jakllsch total_len = 0;
1222 1.1 jakllsch
1223 1.1 jakllsch if (sc->sc_dying || !(ifp->if_flags & IFF_RUNNING))
1224 1.1 jakllsch return;
1225 1.1 jakllsch
1226 1.1 jakllsch if (status != USBD_NORMAL_COMPLETION) {
1227 1.1 jakllsch if (status == USBD_NOT_STARTED || status == USBD_CANCELLED)
1228 1.1 jakllsch return;
1229 1.1 jakllsch if (usbd_ratecheck(&sc->sc_rx_notice)) {
1230 1.1 jakllsch printf("%s: usb errors on rx: %s\n",
1231 1.1 jakllsch DEVNAME(sc), usbd_errstr(status));
1232 1.1 jakllsch }
1233 1.1 jakllsch if (status == USBD_STALLED)
1234 1.1 jakllsch usbd_clear_endpoint_stall_async(sc->sc_bulkin_pipe);
1235 1.1 jakllsch
1236 1.1 jakllsch goto done;
1237 1.1 jakllsch }
1238 1.1 jakllsch
1239 1.1 jakllsch usbd_get_xfer_status(xfer, NULL, NULL, &total_len, NULL);
1240 1.1 jakllsch urndis_decap(sc, c, total_len);
1241 1.1 jakllsch
1242 1.1 jakllsch done:
1243 1.1 jakllsch /* Setup new transfer. */
1244 1.11 skrll usbd_setup_xfer(c->sc_xfer, c, c->sc_buf, RNDIS_BUFSZ,
1245 1.11 skrll USBD_SHORT_XFER_OK, USBD_NO_TIMEOUT, urndis_rxeof);
1246 1.1 jakllsch usbd_transfer(c->sc_xfer);
1247 1.1 jakllsch }
1248 1.1 jakllsch
1249 1.1 jakllsch static void
1250 1.11 skrll urndis_txeof(struct usbd_xfer *xfer,
1251 1.11 skrll void *priv,
1252 1.1 jakllsch usbd_status status)
1253 1.1 jakllsch {
1254 1.1 jakllsch struct urndis_chain *c;
1255 1.1 jakllsch struct urndis_softc *sc;
1256 1.1 jakllsch struct ifnet *ifp;
1257 1.1 jakllsch usbd_status err;
1258 1.1 jakllsch int s;
1259 1.1 jakllsch
1260 1.1 jakllsch c = priv;
1261 1.1 jakllsch sc = c->sc_softc;
1262 1.1 jakllsch ifp = GET_IFP(sc);
1263 1.1 jakllsch
1264 1.1 jakllsch DPRINTF(("%s: urndis_txeof\n", DEVNAME(sc)));
1265 1.1 jakllsch
1266 1.1 jakllsch if (sc->sc_dying)
1267 1.1 jakllsch return;
1268 1.1 jakllsch
1269 1.1 jakllsch s = splnet();
1270 1.1 jakllsch
1271 1.1 jakllsch ifp->if_timer = 0;
1272 1.1 jakllsch ifp->if_flags &= ~IFF_OACTIVE;
1273 1.1 jakllsch
1274 1.1 jakllsch if (status != USBD_NORMAL_COMPLETION) {
1275 1.1 jakllsch if (status == USBD_NOT_STARTED || status == USBD_CANCELLED) {
1276 1.1 jakllsch splx(s);
1277 1.1 jakllsch return;
1278 1.1 jakllsch }
1279 1.1 jakllsch ifp->if_oerrors++;
1280 1.1 jakllsch printf("%s: usb error on tx: %s\n", DEVNAME(sc),
1281 1.1 jakllsch usbd_errstr(status));
1282 1.1 jakllsch if (status == USBD_STALLED)
1283 1.1 jakllsch usbd_clear_endpoint_stall_async(sc->sc_bulkout_pipe);
1284 1.1 jakllsch splx(s);
1285 1.1 jakllsch return;
1286 1.1 jakllsch }
1287 1.1 jakllsch
1288 1.1 jakllsch usbd_get_xfer_status(c->sc_xfer, NULL, NULL, NULL, &err);
1289 1.1 jakllsch
1290 1.1 jakllsch if (c->sc_mbuf != NULL) {
1291 1.1 jakllsch m_freem(c->sc_mbuf);
1292 1.1 jakllsch c->sc_mbuf = NULL;
1293 1.1 jakllsch }
1294 1.1 jakllsch
1295 1.1 jakllsch if (err)
1296 1.1 jakllsch ifp->if_oerrors++;
1297 1.1 jakllsch else
1298 1.1 jakllsch ifp->if_opackets++;
1299 1.1 jakllsch
1300 1.1 jakllsch if (IFQ_IS_EMPTY(&ifp->if_snd) == 0)
1301 1.1 jakllsch urndis_start(ifp);
1302 1.1 jakllsch
1303 1.1 jakllsch splx(s);
1304 1.1 jakllsch }
1305 1.1 jakllsch
1306 1.1 jakllsch static int
1307 1.1 jakllsch urndis_match(device_t parent, cfdata_t match, void *aux)
1308 1.1 jakllsch {
1309 1.11 skrll struct usbif_attach_arg *uiaa = aux;
1310 1.1 jakllsch usb_interface_descriptor_t *id;
1311 1.1 jakllsch
1312 1.11 skrll if (!uiaa->uiaa_iface)
1313 1.11 skrll return UMATCH_NONE;
1314 1.1 jakllsch
1315 1.11 skrll id = usbd_get_interface_descriptor(uiaa->uiaa_iface);
1316 1.1 jakllsch if (id == NULL)
1317 1.11 skrll return UMATCH_NONE;
1318 1.1 jakllsch
1319 1.1 jakllsch if (id->bInterfaceClass == UICLASS_WIRELESS &&
1320 1.1 jakllsch id->bInterfaceSubClass == UISUBCLASS_RF &&
1321 1.1 jakllsch id->bInterfaceProtocol == UIPROTO_RNDIS)
1322 1.11 skrll return UMATCH_IFACECLASS_IFACESUBCLASS_IFACEPROTO;
1323 1.1 jakllsch
1324 1.11 skrll return usb_lookup(urndis_devs, uiaa->uiaa_vendor, uiaa->uiaa_product) != NULL ?
1325 1.1 jakllsch UMATCH_VENDOR_PRODUCT : UMATCH_NONE;
1326 1.1 jakllsch }
1327 1.1 jakllsch
1328 1.1 jakllsch static void
1329 1.1 jakllsch urndis_attach(device_t parent, device_t self, void *aux)
1330 1.1 jakllsch {
1331 1.1 jakllsch struct urndis_softc *sc;
1332 1.11 skrll struct usbif_attach_arg *uiaa;
1333 1.1 jakllsch struct ifnet *ifp;
1334 1.1 jakllsch usb_interface_descriptor_t *id;
1335 1.1 jakllsch usb_endpoint_descriptor_t *ed;
1336 1.1 jakllsch usb_config_descriptor_t *cd;
1337 1.1 jakllsch const usb_cdc_union_descriptor_t *ud;
1338 1.1 jakllsch const usb_cdc_header_descriptor_t *desc;
1339 1.1 jakllsch usbd_desc_iter_t iter;
1340 1.1 jakllsch int if_ctl, if_data;
1341 1.1 jakllsch int i, j, altcnt;
1342 1.1 jakllsch int s;
1343 1.1 jakllsch u_char eaddr[ETHER_ADDR_LEN];
1344 1.1 jakllsch void *buf;
1345 1.1 jakllsch size_t bufsz;
1346 1.1 jakllsch uint32_t filter;
1347 1.1 jakllsch char *devinfop;
1348 1.1 jakllsch
1349 1.1 jakllsch sc = device_private(self);
1350 1.11 skrll uiaa = aux;
1351 1.1 jakllsch sc->sc_dev = self;
1352 1.11 skrll sc->sc_udev = uiaa->uiaa_device;
1353 1.1 jakllsch
1354 1.1 jakllsch aprint_naive("\n");
1355 1.1 jakllsch aprint_normal("\n");
1356 1.1 jakllsch
1357 1.11 skrll devinfop = usbd_devinfo_alloc(uiaa->uiaa_device, 0);
1358 1.1 jakllsch aprint_normal_dev(self, "%s\n", devinfop);
1359 1.1 jakllsch usbd_devinfo_free(devinfop);
1360 1.1 jakllsch
1361 1.11 skrll sc->sc_iface_ctl = uiaa->uiaa_iface;
1362 1.1 jakllsch id = usbd_get_interface_descriptor(sc->sc_iface_ctl);
1363 1.1 jakllsch if_ctl = id->bInterfaceNumber;
1364 1.1 jakllsch sc->sc_ifaceno_ctl = if_ctl;
1365 1.1 jakllsch if_data = -1;
1366 1.1 jakllsch
1367 1.1 jakllsch usb_desc_iter_init(sc->sc_udev, &iter);
1368 1.1 jakllsch while ((desc = (const void *)usb_desc_iter_next(&iter)) != NULL) {
1369 1.1 jakllsch
1370 1.1 jakllsch if (desc->bDescriptorType != UDESC_CS_INTERFACE) {
1371 1.1 jakllsch continue;
1372 1.1 jakllsch }
1373 1.1 jakllsch switch (desc->bDescriptorSubtype) {
1374 1.1 jakllsch case UDESCSUB_CDC_UNION:
1375 1.1 jakllsch /* XXX bail out when found first? */
1376 1.1 jakllsch ud = (const usb_cdc_union_descriptor_t *)desc;
1377 1.1 jakllsch if (if_data == -1)
1378 1.1 jakllsch if_data = ud->bSlaveInterface[0];
1379 1.1 jakllsch break;
1380 1.1 jakllsch }
1381 1.1 jakllsch }
1382 1.1 jakllsch
1383 1.1 jakllsch if (if_data == -1) {
1384 1.1 jakllsch DPRINTF(("urndis_attach: no union interface\n"));
1385 1.1 jakllsch sc->sc_iface_data = sc->sc_iface_ctl;
1386 1.1 jakllsch } else {
1387 1.1 jakllsch DPRINTF(("urndis_attach: union interface: ctl %u, data %u\n",
1388 1.1 jakllsch if_ctl, if_data));
1389 1.11 skrll for (i = 0; i < uiaa->uiaa_nifaces; i++) {
1390 1.11 skrll if (uiaa->uiaa_ifaces[i] != NULL) {
1391 1.1 jakllsch id = usbd_get_interface_descriptor(
1392 1.11 skrll uiaa->uiaa_ifaces[i]);
1393 1.1 jakllsch if (id != NULL && id->bInterfaceNumber ==
1394 1.1 jakllsch if_data) {
1395 1.11 skrll sc->sc_iface_data = uiaa->uiaa_ifaces[i];
1396 1.11 skrll uiaa->uiaa_ifaces[i] = NULL;
1397 1.1 jakllsch }
1398 1.1 jakllsch }
1399 1.1 jakllsch }
1400 1.1 jakllsch }
1401 1.1 jakllsch
1402 1.1 jakllsch if (sc->sc_iface_data == NULL) {
1403 1.13 msaitoh aprint_error("%s: no data interface\n", DEVNAME(sc));
1404 1.1 jakllsch return;
1405 1.1 jakllsch }
1406 1.1 jakllsch
1407 1.1 jakllsch id = usbd_get_interface_descriptor(sc->sc_iface_data);
1408 1.1 jakllsch cd = usbd_get_config_descriptor(sc->sc_udev);
1409 1.1 jakllsch altcnt = usbd_get_no_alts(cd, id->bInterfaceNumber);
1410 1.1 jakllsch
1411 1.1 jakllsch for (j = 0; j < altcnt; j++) {
1412 1.1 jakllsch if (usbd_set_interface(sc->sc_iface_data, j)) {
1413 1.13 msaitoh aprint_error("%s: interface alternate setting %u "
1414 1.13 msaitoh "failed\n", DEVNAME(sc), j);
1415 1.1 jakllsch return;
1416 1.1 jakllsch }
1417 1.1 jakllsch /* Find endpoints. */
1418 1.1 jakllsch id = usbd_get_interface_descriptor(sc->sc_iface_data);
1419 1.1 jakllsch sc->sc_bulkin_no = sc->sc_bulkout_no = -1;
1420 1.1 jakllsch for (i = 0; i < id->bNumEndpoints; i++) {
1421 1.1 jakllsch ed = usbd_interface2endpoint_descriptor(
1422 1.1 jakllsch sc->sc_iface_data, i);
1423 1.1 jakllsch if (!ed) {
1424 1.13 msaitoh aprint_error("%s: no descriptor for bulk "
1425 1.13 msaitoh "endpoint %u\n", DEVNAME(sc), i);
1426 1.1 jakllsch return;
1427 1.1 jakllsch }
1428 1.1 jakllsch if (UE_GET_DIR(ed->bEndpointAddress) == UE_DIR_IN &&
1429 1.1 jakllsch UE_GET_XFERTYPE(ed->bmAttributes) == UE_BULK) {
1430 1.1 jakllsch sc->sc_bulkin_no = ed->bEndpointAddress;
1431 1.1 jakllsch }
1432 1.1 jakllsch else if (
1433 1.1 jakllsch UE_GET_DIR(ed->bEndpointAddress) == UE_DIR_OUT &&
1434 1.1 jakllsch UE_GET_XFERTYPE(ed->bmAttributes) == UE_BULK) {
1435 1.1 jakllsch sc->sc_bulkout_no = ed->bEndpointAddress;
1436 1.1 jakllsch }
1437 1.1 jakllsch }
1438 1.1 jakllsch
1439 1.1 jakllsch if (sc->sc_bulkin_no != -1 && sc->sc_bulkout_no != -1) {
1440 1.1 jakllsch DPRINTF(("%s: in=0x%x, out=0x%x\n",
1441 1.1 jakllsch DEVNAME(sc),
1442 1.1 jakllsch sc->sc_bulkin_no,
1443 1.1 jakllsch sc->sc_bulkout_no));
1444 1.1 jakllsch goto found;
1445 1.1 jakllsch }
1446 1.1 jakllsch }
1447 1.1 jakllsch
1448 1.1 jakllsch if (sc->sc_bulkin_no == -1)
1449 1.13 msaitoh aprint_error("%s: could not find data bulk in\n", DEVNAME(sc));
1450 1.1 jakllsch if (sc->sc_bulkout_no == -1 )
1451 1.13 msaitoh aprint_error("%s: could not find data bulk out\n",DEVNAME(sc));
1452 1.1 jakllsch return;
1453 1.1 jakllsch
1454 1.1 jakllsch found:
1455 1.1 jakllsch
1456 1.1 jakllsch ifp = GET_IFP(sc);
1457 1.1 jakllsch ifp->if_softc = sc;
1458 1.1 jakllsch ifp->if_flags = IFF_BROADCAST | IFF_SIMPLEX | IFF_MULTICAST;
1459 1.1 jakllsch ifp->if_start = urndis_start;
1460 1.1 jakllsch ifp->if_ioctl = urndis_ioctl;
1461 1.8 skrll ifp->if_init = urndis_init;
1462 1.1 jakllsch #if 0
1463 1.1 jakllsch ifp->if_watchdog = urndis_watchdog;
1464 1.1 jakllsch #endif
1465 1.1 jakllsch
1466 1.1 jakllsch strlcpy(ifp->if_xname, DEVNAME(sc), IFNAMSIZ);
1467 1.1 jakllsch
1468 1.1 jakllsch IFQ_SET_READY(&ifp->if_snd);
1469 1.1 jakllsch
1470 1.1 jakllsch urndis_init(ifp);
1471 1.1 jakllsch
1472 1.1 jakllsch s = splnet();
1473 1.1 jakllsch
1474 1.1 jakllsch if (urndis_ctrl_query(sc, OID_802_3_PERMANENT_ADDRESS, NULL, 0,
1475 1.1 jakllsch &buf, &bufsz) != RNDIS_STATUS_SUCCESS) {
1476 1.13 msaitoh aprint_error("%s: unable to get hardware address\n",
1477 1.13 msaitoh DEVNAME(sc));
1478 1.1 jakllsch urndis_stop(ifp);
1479 1.1 jakllsch splx(s);
1480 1.1 jakllsch return;
1481 1.1 jakllsch }
1482 1.1 jakllsch
1483 1.1 jakllsch if (bufsz == ETHER_ADDR_LEN) {
1484 1.1 jakllsch memcpy(eaddr, buf, ETHER_ADDR_LEN);
1485 1.13 msaitoh aprint_normal("%s: address %s\n", DEVNAME(sc),
1486 1.13 msaitoh ether_sprintf(eaddr));
1487 1.1 jakllsch kmem_free(buf, bufsz);
1488 1.1 jakllsch } else {
1489 1.13 msaitoh aprint_error("%s: invalid address\n", DEVNAME(sc));
1490 1.1 jakllsch kmem_free(buf, bufsz);
1491 1.1 jakllsch urndis_stop(ifp);
1492 1.1 jakllsch splx(s);
1493 1.1 jakllsch return;
1494 1.1 jakllsch }
1495 1.1 jakllsch
1496 1.1 jakllsch /* Initialize packet filter */
1497 1.5 christos sc->sc_filter = RNDIS_PACKET_TYPE_BROADCAST;
1498 1.1 jakllsch sc->sc_filter |= RNDIS_PACKET_TYPE_ALL_MULTICAST;
1499 1.1 jakllsch filter = htole32(sc->sc_filter);
1500 1.1 jakllsch if (urndis_ctrl_set(sc, OID_GEN_CURRENT_PACKET_FILTER, &filter,
1501 1.1 jakllsch sizeof(filter)) != RNDIS_STATUS_SUCCESS) {
1502 1.13 msaitoh aprint_error("%s: unable to set data filters\n", DEVNAME(sc));
1503 1.1 jakllsch urndis_stop(ifp);
1504 1.1 jakllsch splx(s);
1505 1.1 jakllsch return;
1506 1.1 jakllsch }
1507 1.1 jakllsch
1508 1.1 jakllsch if_attach(ifp);
1509 1.1 jakllsch ether_ifattach(ifp, eaddr);
1510 1.1 jakllsch sc->sc_attached = 1;
1511 1.1 jakllsch
1512 1.1 jakllsch splx(s);
1513 1.1 jakllsch }
1514 1.1 jakllsch
1515 1.1 jakllsch static int
1516 1.1 jakllsch urndis_detach(device_t self, int flags)
1517 1.1 jakllsch {
1518 1.1 jakllsch struct urndis_softc *sc;
1519 1.1 jakllsch struct ifnet *ifp;
1520 1.1 jakllsch int s;
1521 1.1 jakllsch
1522 1.1 jakllsch sc = device_private(self);
1523 1.1 jakllsch
1524 1.1 jakllsch DPRINTF(("urndis_detach: %s flags %u\n", DEVNAME(sc),
1525 1.1 jakllsch flags));
1526 1.5 christos
1527 1.1 jakllsch if (!sc->sc_attached)
1528 1.1 jakllsch return 0;
1529 1.1 jakllsch
1530 1.1 jakllsch s = splusb();
1531 1.1 jakllsch
1532 1.1 jakllsch ifp = GET_IFP(sc);
1533 1.1 jakllsch
1534 1.1 jakllsch if (ifp->if_softc != NULL) {
1535 1.1 jakllsch ether_ifdetach(ifp);
1536 1.1 jakllsch if_detach(ifp);
1537 1.1 jakllsch }
1538 1.1 jakllsch
1539 1.1 jakllsch urndis_stop(ifp);
1540 1.1 jakllsch sc->sc_attached = 0;
1541 1.1 jakllsch
1542 1.1 jakllsch splx(s);
1543 1.1 jakllsch
1544 1.1 jakllsch return 0;
1545 1.1 jakllsch }
1546 1.1 jakllsch
1547 1.1 jakllsch static int
1548 1.1 jakllsch urndis_activate(device_t self, enum devact act)
1549 1.1 jakllsch {
1550 1.1 jakllsch struct urndis_softc *sc;
1551 1.1 jakllsch
1552 1.1 jakllsch sc = device_private(self);
1553 1.1 jakllsch
1554 1.1 jakllsch switch (act) {
1555 1.1 jakllsch case DVACT_DEACTIVATE:
1556 1.1 jakllsch sc->sc_dying = 1;
1557 1.1 jakllsch return 0;
1558 1.1 jakllsch }
1559 1.1 jakllsch
1560 1.1 jakllsch return EOPNOTSUPP;
1561 1.1 jakllsch }
1562