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