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