ugen.c revision 1.104 1 1.104 pooka /* $NetBSD: ugen.c,v 1.104 2009/09/24 15:36:59 pooka Exp $ */
2 1.1 augustss
3 1.1 augustss /*
4 1.71 mycroft * Copyright (c) 1998, 2004 The NetBSD Foundation, Inc.
5 1.1 augustss * All rights reserved.
6 1.1 augustss *
7 1.1 augustss * This code is derived from software contributed to The NetBSD Foundation
8 1.38 augustss * by Lennart Augustsson (lennart (at) augustsson.net) at
9 1.1 augustss * Carlstedt Research & Technology.
10 1.1 augustss *
11 1.84 gdt * Copyright (c) 2006 BBN Technologies Corp. All rights reserved.
12 1.84 gdt * Effort sponsored in part by the Defense Advanced Research Projects
13 1.84 gdt * Agency (DARPA) and the Department of the Interior National Business
14 1.84 gdt * Center under agreement number NBCHC050166.
15 1.84 gdt *
16 1.1 augustss * Redistribution and use in source and binary forms, with or without
17 1.1 augustss * modification, are permitted provided that the following conditions
18 1.1 augustss * are met:
19 1.1 augustss * 1. Redistributions of source code must retain the above copyright
20 1.1 augustss * notice, this list of conditions and the following disclaimer.
21 1.1 augustss * 2. Redistributions in binary form must reproduce the above copyright
22 1.1 augustss * notice, this list of conditions and the following disclaimer in the
23 1.1 augustss * documentation and/or other materials provided with the distribution.
24 1.1 augustss *
25 1.1 augustss * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
26 1.1 augustss * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
27 1.1 augustss * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
28 1.1 augustss * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
29 1.1 augustss * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
30 1.1 augustss * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
31 1.1 augustss * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
32 1.1 augustss * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
33 1.1 augustss * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
34 1.1 augustss * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
35 1.1 augustss * POSSIBILITY OF SUCH DAMAGE.
36 1.1 augustss */
37 1.1 augustss
38 1.50 lukem
39 1.50 lukem #include <sys/cdefs.h>
40 1.104 pooka __KERNEL_RCSID(0, "$NetBSD: ugen.c,v 1.104 2009/09/24 15:36:59 pooka Exp $");
41 1.84 gdt
42 1.84 gdt #include "opt_ugen_bulk_ra_wb.h"
43 1.89 pavel #include "opt_compat_netbsd.h"
44 1.1 augustss
45 1.1 augustss #include <sys/param.h>
46 1.1 augustss #include <sys/systm.h>
47 1.1 augustss #include <sys/kernel.h>
48 1.1 augustss #include <sys/malloc.h>
49 1.15 augustss #if defined(__NetBSD__) || defined(__OpenBSD__)
50 1.1 augustss #include <sys/device.h>
51 1.1 augustss #include <sys/ioctl.h>
52 1.11 augustss #elif defined(__FreeBSD__)
53 1.11 augustss #include <sys/module.h>
54 1.11 augustss #include <sys/bus.h>
55 1.11 augustss #include <sys/ioccom.h>
56 1.11 augustss #include <sys/conf.h>
57 1.11 augustss #include <sys/fcntl.h>
58 1.11 augustss #include <sys/filio.h>
59 1.11 augustss #endif
60 1.12 augustss #include <sys/conf.h>
61 1.1 augustss #include <sys/tty.h>
62 1.1 augustss #include <sys/file.h>
63 1.1 augustss #include <sys/select.h>
64 1.1 augustss #include <sys/proc.h>
65 1.1 augustss #include <sys/vnode.h>
66 1.1 augustss #include <sys/poll.h>
67 1.1 augustss
68 1.1 augustss #include <dev/usb/usb.h>
69 1.1 augustss #include <dev/usb/usbdi.h>
70 1.1 augustss #include <dev/usb/usbdi_util.h>
71 1.1 augustss
72 1.25 augustss #ifdef UGEN_DEBUG
73 1.14 augustss #define DPRINTF(x) if (ugendebug) logprintf x
74 1.14 augustss #define DPRINTFN(n,x) if (ugendebug>(n)) logprintf x
75 1.2 augustss int ugendebug = 0;
76 1.1 augustss #else
77 1.1 augustss #define DPRINTF(x)
78 1.1 augustss #define DPRINTFN(n,x)
79 1.1 augustss #endif
80 1.1 augustss
81 1.41 augustss #define UGEN_CHUNK 128 /* chunk size for read */
82 1.41 augustss #define UGEN_IBSIZE 1020 /* buffer size */
83 1.41 augustss #define UGEN_BBSIZE 1024
84 1.41 augustss
85 1.41 augustss #define UGEN_NISOFRAMES 500 /* 0.5 seconds worth */
86 1.41 augustss #define UGEN_NISOREQS 6 /* number of outstanding xfer requests */
87 1.41 augustss #define UGEN_NISORFRMS 4 /* number of frames (miliseconds) per req */
88 1.41 augustss
89 1.84 gdt #define UGEN_BULK_RA_WB_BUFSIZE 16384 /* default buffer size */
90 1.84 gdt #define UGEN_BULK_RA_WB_BUFMAX (1 << 20) /* maximum allowed buffer */
91 1.84 gdt
92 1.1 augustss struct ugen_endpoint {
93 1.1 augustss struct ugen_softc *sc;
94 1.1 augustss usb_endpoint_descriptor_t *edesc;
95 1.1 augustss usbd_interface_handle iface;
96 1.1 augustss int state;
97 1.1 augustss #define UGEN_ASLP 0x02 /* waiting for data */
98 1.8 augustss #define UGEN_SHORT_OK 0x04 /* short xfers are OK */
99 1.84 gdt #define UGEN_BULK_RA 0x08 /* in bulk read-ahead mode */
100 1.84 gdt #define UGEN_BULK_WB 0x10 /* in bulk write-behind mode */
101 1.84 gdt #define UGEN_RA_WB_STOP 0x20 /* RA/WB xfer is stopped (buffer full/empty) */
102 1.1 augustss usbd_pipe_handle pipeh;
103 1.1 augustss struct clist q;
104 1.1 augustss struct selinfo rsel;
105 1.41 augustss u_char *ibuf; /* start of buffer (circular for isoc) */
106 1.41 augustss u_char *fill; /* location for input (isoc) */
107 1.41 augustss u_char *limit; /* end of circular buffer (isoc) */
108 1.41 augustss u_char *cur; /* current read location (isoc) */
109 1.17 augustss u_int32_t timeout;
110 1.84 gdt #ifdef UGEN_BULK_RA_WB
111 1.84 gdt u_int32_t ra_wb_bufsize; /* requested size for RA/WB buffer */
112 1.84 gdt u_int32_t ra_wb_reqsize; /* requested xfer length for RA/WB */
113 1.84 gdt u_int32_t ra_wb_used; /* how much is in buffer */
114 1.84 gdt u_int32_t ra_wb_xferlen; /* current xfer length for RA/WB */
115 1.84 gdt usbd_xfer_handle ra_wb_xfer;
116 1.84 gdt #endif
117 1.41 augustss struct isoreq {
118 1.41 augustss struct ugen_endpoint *sce;
119 1.41 augustss usbd_xfer_handle xfer;
120 1.41 augustss void *dmabuf;
121 1.41 augustss u_int16_t sizes[UGEN_NISORFRMS];
122 1.41 augustss } isoreqs[UGEN_NISOREQS];
123 1.1 augustss };
124 1.1 augustss
125 1.1 augustss struct ugen_softc {
126 1.22 augustss USBBASEDEVICE sc_dev; /* base device */
127 1.19 augustss usbd_device_handle sc_udev;
128 1.1 augustss
129 1.13 augustss char sc_is_open[USB_MAX_ENDPOINTS];
130 1.1 augustss struct ugen_endpoint sc_endpoints[USB_MAX_ENDPOINTS][2];
131 1.21 augustss #define OUT 0
132 1.21 augustss #define IN 1
133 1.1 augustss
134 1.12 augustss int sc_refcnt;
135 1.83 christos char sc_buffer[UGEN_BBSIZE];
136 1.12 augustss u_char sc_dying;
137 1.1 augustss };
138 1.1 augustss
139 1.60 gehenna #if defined(__NetBSD__)
140 1.60 gehenna dev_type_open(ugenopen);
141 1.60 gehenna dev_type_close(ugenclose);
142 1.60 gehenna dev_type_read(ugenread);
143 1.60 gehenna dev_type_write(ugenwrite);
144 1.60 gehenna dev_type_ioctl(ugenioctl);
145 1.60 gehenna dev_type_poll(ugenpoll);
146 1.62 jdolecek dev_type_kqfilter(ugenkqfilter);
147 1.60 gehenna
148 1.60 gehenna const struct cdevsw ugen_cdevsw = {
149 1.60 gehenna ugenopen, ugenclose, ugenread, ugenwrite, ugenioctl,
150 1.85 christos nostop, notty, ugenpoll, nommap, ugenkqfilter, D_OTHER,
151 1.60 gehenna };
152 1.60 gehenna #elif defined(__OpenBSD__)
153 1.14 augustss cdev_decl(ugen);
154 1.14 augustss #elif defined(__FreeBSD__)
155 1.14 augustss d_open_t ugenopen;
156 1.14 augustss d_close_t ugenclose;
157 1.14 augustss d_read_t ugenread;
158 1.14 augustss d_write_t ugenwrite;
159 1.14 augustss d_ioctl_t ugenioctl;
160 1.14 augustss d_poll_t ugenpoll;
161 1.14 augustss
162 1.14 augustss #define UGEN_CDEV_MAJOR 114
163 1.14 augustss
164 1.37 augustss Static struct cdevsw ugen_cdevsw = {
165 1.14 augustss /* open */ ugenopen,
166 1.14 augustss /* close */ ugenclose,
167 1.14 augustss /* read */ ugenread,
168 1.14 augustss /* write */ ugenwrite,
169 1.14 augustss /* ioctl */ ugenioctl,
170 1.14 augustss /* poll */ ugenpoll,
171 1.14 augustss /* mmap */ nommap,
172 1.14 augustss /* strategy */ nostrategy,
173 1.14 augustss /* name */ "ugen",
174 1.14 augustss /* maj */ UGEN_CDEV_MAJOR,
175 1.14 augustss /* dump */ nodump,
176 1.14 augustss /* psize */ nopsize,
177 1.14 augustss /* flags */ 0,
178 1.14 augustss /* bmaj */ -1
179 1.14 augustss };
180 1.14 augustss #endif
181 1.14 augustss
182 1.55 augustss Static void ugenintr(usbd_xfer_handle xfer, usbd_private_handle addr,
183 1.40 augustss usbd_status status);
184 1.42 augustss Static void ugen_isoc_rintr(usbd_xfer_handle xfer, usbd_private_handle addr,
185 1.42 augustss usbd_status status);
186 1.84 gdt #ifdef UGEN_BULK_RA_WB
187 1.84 gdt Static void ugen_bulkra_intr(usbd_xfer_handle xfer, usbd_private_handle addr,
188 1.84 gdt usbd_status status);
189 1.84 gdt Static void ugen_bulkwb_intr(usbd_xfer_handle xfer, usbd_private_handle addr,
190 1.84 gdt usbd_status status);
191 1.84 gdt #endif
192 1.40 augustss Static int ugen_do_read(struct ugen_softc *, int, struct uio *, int);
193 1.40 augustss Static int ugen_do_write(struct ugen_softc *, int, struct uio *, int);
194 1.55 augustss Static int ugen_do_ioctl(struct ugen_softc *, int, u_long,
195 1.92 christos void *, int, struct lwp *);
196 1.40 augustss Static int ugen_set_config(struct ugen_softc *sc, int configno);
197 1.55 augustss Static usb_config_descriptor_t *ugen_get_cdesc(struct ugen_softc *sc,
198 1.40 augustss int index, int *lenp);
199 1.40 augustss Static usbd_status ugen_set_interface(struct ugen_softc *, int, int);
200 1.40 augustss Static int ugen_get_alt_index(struct ugen_softc *sc, int ifaceidx);
201 1.1 augustss
202 1.12 augustss #define UGENUNIT(n) ((minor(n) >> 4) & 0xf)
203 1.12 augustss #define UGENENDPOINT(n) (minor(n) & 0xf)
204 1.12 augustss #define UGENDEV(u, e) (makedev(0, ((u) << 4) | (e)))
205 1.1 augustss
206 1.5 augustss USB_DECLARE_DRIVER(ugen);
207 1.1 augustss
208 1.5 augustss USB_MATCH(ugen)
209 1.1 augustss {
210 1.5 augustss USB_MATCH_START(ugen, uaa);
211 1.1 augustss
212 1.76 augustss if (match->cf_flags & 1)
213 1.77 augustss return (UMATCH_HIGHEST);
214 1.76 augustss else if (uaa->usegeneric)
215 1.1 augustss return (UMATCH_GENERIC);
216 1.1 augustss else
217 1.1 augustss return (UMATCH_NONE);
218 1.1 augustss }
219 1.1 augustss
220 1.5 augustss USB_ATTACH(ugen)
221 1.1 augustss {
222 1.5 augustss USB_ATTACH_START(ugen, sc, uaa);
223 1.31 augustss usbd_device_handle udev;
224 1.72 augustss char *devinfop;
225 1.28 augustss usbd_status err;
226 1.97 rmind int i, dir, conf;
227 1.59 augustss
228 1.103 plunky aprint_naive("\n");
229 1.103 plunky aprint_normal("\n");
230 1.103 plunky
231 1.72 augustss devinfop = usbd_devinfo_alloc(uaa->device, 0);
232 1.99 cube aprint_normal_dev(self, "%s\n", devinfop);
233 1.72 augustss usbd_devinfo_free(devinfop);
234 1.1 augustss
235 1.99 cube sc->sc_dev = self;
236 1.31 augustss sc->sc_udev = udev = uaa->device;
237 1.31 augustss
238 1.31 augustss /* First set configuration index 0, the default one for ugen. */
239 1.31 augustss err = usbd_set_config_index(udev, 0, 0);
240 1.31 augustss if (err) {
241 1.99 cube aprint_error_dev(self,
242 1.99 cube "setting configuration index 0 failed\n");
243 1.31 augustss sc->sc_dying = 1;
244 1.31 augustss USB_ATTACH_ERROR_RETURN;
245 1.31 augustss }
246 1.31 augustss conf = usbd_get_config_descriptor(udev)->bConfigurationValue;
247 1.31 augustss
248 1.31 augustss /* Set up all the local state for this configuration. */
249 1.28 augustss err = ugen_set_config(sc, conf);
250 1.28 augustss if (err) {
251 1.99 cube aprint_error_dev(self, "setting configuration %d failed\n",
252 1.99 cube conf);
253 1.12 augustss sc->sc_dying = 1;
254 1.5 augustss USB_ATTACH_ERROR_RETURN;
255 1.1 augustss }
256 1.30 augustss
257 1.30 augustss #ifdef __FreeBSD__
258 1.30 augustss {
259 1.30 augustss static int global_init_done = 0;
260 1.30 augustss if (!global_init_done) {
261 1.30 augustss cdevsw_add(&ugen_cdevsw);
262 1.30 augustss global_init_done = 1;
263 1.30 augustss }
264 1.30 augustss }
265 1.30 augustss #endif
266 1.97 rmind for (i = 0; i < USB_MAX_ENDPOINTS; i++) {
267 1.97 rmind for (dir = OUT; dir <= IN; dir++) {
268 1.97 rmind struct ugen_endpoint *sce;
269 1.97 rmind
270 1.97 rmind sce = &sc->sc_endpoints[i][dir];
271 1.97 rmind selinit(&sce->rsel);
272 1.97 rmind }
273 1.97 rmind }
274 1.30 augustss
275 1.33 augustss usbd_add_drv_event(USB_EVENT_DRIVER_ATTACH, sc->sc_udev,
276 1.33 augustss USBDEV(sc->sc_dev));
277 1.33 augustss
278 1.95 jmcneill if (!pmf_device_register(self, NULL, NULL))
279 1.95 jmcneill aprint_error_dev(self, "couldn't establish power handler\n");
280 1.95 jmcneill
281 1.5 augustss USB_ATTACH_SUCCESS_RETURN;
282 1.1 augustss }
283 1.1 augustss
284 1.37 augustss Static int
285 1.40 augustss ugen_set_config(struct ugen_softc *sc, int configno)
286 1.1 augustss {
287 1.1 augustss usbd_device_handle dev = sc->sc_udev;
288 1.102 drochner usb_config_descriptor_t *cdesc;
289 1.1 augustss usbd_interface_handle iface;
290 1.1 augustss usb_endpoint_descriptor_t *ed;
291 1.1 augustss struct ugen_endpoint *sce;
292 1.1 augustss u_int8_t niface, nendpt;
293 1.1 augustss int ifaceno, endptno, endpt;
294 1.28 augustss usbd_status err;
295 1.21 augustss int dir;
296 1.1 augustss
297 1.1 augustss DPRINTFN(1,("ugen_set_config: %s to configno %d, sc=%p\n",
298 1.5 augustss USBDEVNAME(sc->sc_dev), configno, sc));
299 1.53 augustss
300 1.53 augustss /*
301 1.53 augustss * We start at 1, not 0, because we don't care whether the
302 1.53 augustss * control endpoint is open or not. It is always present.
303 1.53 augustss */
304 1.53 augustss for (endptno = 1; endptno < USB_MAX_ENDPOINTS; endptno++)
305 1.53 augustss if (sc->sc_is_open[endptno]) {
306 1.53 augustss DPRINTFN(1,
307 1.53 augustss ("ugen_set_config: %s - endpoint %d is open\n",
308 1.53 augustss USBDEVNAME(sc->sc_dev), endptno));
309 1.53 augustss return (USBD_IN_USE);
310 1.53 augustss }
311 1.53 augustss
312 1.31 augustss /* Avoid setting the current value. */
313 1.102 drochner cdesc = usbd_get_config_descriptor(dev);
314 1.102 drochner if (!cdesc || cdesc->bConfigurationValue != configno) {
315 1.43 augustss err = usbd_set_config_no(dev, configno, 1);
316 1.28 augustss if (err)
317 1.28 augustss return (err);
318 1.7 augustss }
319 1.1 augustss
320 1.28 augustss err = usbd_interface_count(dev, &niface);
321 1.28 augustss if (err)
322 1.28 augustss return (err);
323 1.1 augustss memset(sc->sc_endpoints, 0, sizeof sc->sc_endpoints);
324 1.1 augustss for (ifaceno = 0; ifaceno < niface; ifaceno++) {
325 1.1 augustss DPRINTFN(1,("ugen_set_config: ifaceno %d\n", ifaceno));
326 1.28 augustss err = usbd_device2interface_handle(dev, ifaceno, &iface);
327 1.28 augustss if (err)
328 1.28 augustss return (err);
329 1.28 augustss err = usbd_endpoint_count(iface, &nendpt);
330 1.28 augustss if (err)
331 1.28 augustss return (err);
332 1.1 augustss for (endptno = 0; endptno < nendpt; endptno++) {
333 1.1 augustss ed = usbd_interface2endpoint_descriptor(iface,endptno);
334 1.82 christos KASSERT(ed != NULL);
335 1.1 augustss endpt = ed->bEndpointAddress;
336 1.21 augustss dir = UE_GET_DIR(endpt) == UE_DIR_IN ? IN : OUT;
337 1.21 augustss sce = &sc->sc_endpoints[UE_GET_ADDR(endpt)][dir];
338 1.3 augustss DPRINTFN(1,("ugen_set_config: endptno %d, endpt=0x%02x"
339 1.55 augustss "(%d,%d), sce=%p\n",
340 1.1 augustss endptno, endpt, UE_GET_ADDR(endpt),
341 1.21 augustss UE_GET_DIR(endpt), sce));
342 1.1 augustss sce->sc = sc;
343 1.1 augustss sce->edesc = ed;
344 1.1 augustss sce->iface = iface;
345 1.1 augustss }
346 1.1 augustss }
347 1.1 augustss return (USBD_NORMAL_COMPLETION);
348 1.1 augustss }
349 1.1 augustss
350 1.1 augustss int
351 1.88 christos ugenopen(dev_t dev, int flag, int mode, struct lwp *l)
352 1.1 augustss {
353 1.24 augustss struct ugen_softc *sc;
354 1.1 augustss int unit = UGENUNIT(dev);
355 1.1 augustss int endpt = UGENENDPOINT(dev);
356 1.1 augustss usb_endpoint_descriptor_t *edesc;
357 1.1 augustss struct ugen_endpoint *sce;
358 1.1 augustss int dir, isize;
359 1.28 augustss usbd_status err;
360 1.41 augustss usbd_xfer_handle xfer;
361 1.74 christos void *tbuf;
362 1.41 augustss int i, j;
363 1.1 augustss
364 1.11 augustss USB_GET_SC_OPEN(ugen, unit, sc);
365 1.30 augustss
366 1.55 augustss DPRINTFN(5, ("ugenopen: flag=%d, mode=%d, unit=%d endpt=%d\n",
367 1.9 augustss flag, mode, unit, endpt));
368 1.1 augustss
369 1.30 augustss if (sc == NULL || sc->sc_dying)
370 1.12 augustss return (ENXIO);
371 1.1 augustss
372 1.73 augustss /* The control endpoint allows multiple opens. */
373 1.1 augustss if (endpt == USB_CONTROL_ENDPOINT) {
374 1.13 augustss sc->sc_is_open[USB_CONTROL_ENDPOINT] = 1;
375 1.13 augustss return (0);
376 1.13 augustss }
377 1.35 augustss
378 1.73 augustss if (sc->sc_is_open[endpt])
379 1.73 augustss return (EBUSY);
380 1.73 augustss
381 1.13 augustss /* Make sure there are pipes for all directions. */
382 1.13 augustss for (dir = OUT; dir <= IN; dir++) {
383 1.13 augustss if (flag & (dir == OUT ? FWRITE : FREAD)) {
384 1.13 augustss sce = &sc->sc_endpoints[endpt][dir];
385 1.13 augustss if (sce == 0 || sce->edesc == 0)
386 1.13 augustss return (ENXIO);
387 1.1 augustss }
388 1.13 augustss }
389 1.13 augustss
390 1.13 augustss /* Actually open the pipes. */
391 1.13 augustss /* XXX Should back out properly if it fails. */
392 1.13 augustss for (dir = OUT; dir <= IN; dir++) {
393 1.13 augustss if (!(flag & (dir == OUT ? FWRITE : FREAD)))
394 1.13 augustss continue;
395 1.1 augustss sce = &sc->sc_endpoints[endpt][dir];
396 1.13 augustss sce->state = 0;
397 1.17 augustss sce->timeout = USBD_NO_TIMEOUT;
398 1.55 augustss DPRINTFN(5, ("ugenopen: sc=%p, endpt=%d, dir=%d, sce=%p\n",
399 1.3 augustss sc, endpt, dir, sce));
400 1.1 augustss edesc = sce->edesc;
401 1.1 augustss switch (edesc->bmAttributes & UE_XFERTYPE) {
402 1.1 augustss case UE_INTERRUPT:
403 1.69 augustss if (dir == OUT) {
404 1.69 augustss err = usbd_open_pipe(sce->iface,
405 1.69 augustss edesc->bEndpointAddress, 0, &sce->pipeh);
406 1.69 augustss if (err)
407 1.69 augustss return (EIO);
408 1.69 augustss break;
409 1.69 augustss }
410 1.1 augustss isize = UGETW(edesc->wMaxPacketSize);
411 1.1 augustss if (isize == 0) /* shouldn't happen */
412 1.1 augustss return (EINVAL);
413 1.12 augustss sce->ibuf = malloc(isize, M_USBDEV, M_WAITOK);
414 1.55 augustss DPRINTFN(5, ("ugenopen: intr endpt=%d,isize=%d\n",
415 1.1 augustss endpt, isize));
416 1.56 augustss if (clalloc(&sce->q, UGEN_IBSIZE, 0) == -1)
417 1.56 augustss return (ENOMEM);
418 1.55 augustss err = usbd_open_pipe_intr(sce->iface,
419 1.55 augustss edesc->bEndpointAddress,
420 1.55 augustss USBD_SHORT_XFER_OK, &sce->pipeh, sce,
421 1.55 augustss sce->ibuf, isize, ugenintr,
422 1.32 augustss USBD_DEFAULT_INTERVAL);
423 1.28 augustss if (err) {
424 1.12 augustss free(sce->ibuf, M_USBDEV);
425 1.1 augustss clfree(&sce->q);
426 1.1 augustss return (EIO);
427 1.1 augustss }
428 1.1 augustss DPRINTFN(5, ("ugenopen: interrupt open done\n"));
429 1.1 augustss break;
430 1.1 augustss case UE_BULK:
431 1.55 augustss err = usbd_open_pipe(sce->iface,
432 1.28 augustss edesc->bEndpointAddress, 0, &sce->pipeh);
433 1.28 augustss if (err)
434 1.1 augustss return (EIO);
435 1.84 gdt #ifdef UGEN_BULK_RA_WB
436 1.84 gdt sce->ra_wb_bufsize = UGEN_BULK_RA_WB_BUFSIZE;
437 1.84 gdt /*
438 1.84 gdt * Use request size for non-RA/WB transfers
439 1.84 gdt * as the default.
440 1.84 gdt */
441 1.84 gdt sce->ra_wb_reqsize = UGEN_BBSIZE;
442 1.84 gdt #endif
443 1.1 augustss break;
444 1.41 augustss case UE_ISOCHRONOUS:
445 1.41 augustss if (dir == OUT)
446 1.41 augustss return (EINVAL);
447 1.41 augustss isize = UGETW(edesc->wMaxPacketSize);
448 1.41 augustss if (isize == 0) /* shouldn't happen */
449 1.41 augustss return (EINVAL);
450 1.41 augustss sce->ibuf = malloc(isize * UGEN_NISOFRAMES,
451 1.41 augustss M_USBDEV, M_WAITOK);
452 1.41 augustss sce->cur = sce->fill = sce->ibuf;
453 1.41 augustss sce->limit = sce->ibuf + isize * UGEN_NISOFRAMES;
454 1.55 augustss DPRINTFN(5, ("ugenopen: isoc endpt=%d, isize=%d\n",
455 1.41 augustss endpt, isize));
456 1.41 augustss err = usbd_open_pipe(sce->iface,
457 1.41 augustss edesc->bEndpointAddress, 0, &sce->pipeh);
458 1.41 augustss if (err) {
459 1.41 augustss free(sce->ibuf, M_USBDEV);
460 1.41 augustss return (EIO);
461 1.41 augustss }
462 1.41 augustss for(i = 0; i < UGEN_NISOREQS; ++i) {
463 1.41 augustss sce->isoreqs[i].sce = sce;
464 1.41 augustss xfer = usbd_alloc_xfer(sc->sc_udev);
465 1.41 augustss if (xfer == 0)
466 1.41 augustss goto bad;
467 1.41 augustss sce->isoreqs[i].xfer = xfer;
468 1.74 christos tbuf = usbd_alloc_buffer
469 1.41 augustss (xfer, isize * UGEN_NISORFRMS);
470 1.74 christos if (tbuf == 0) {
471 1.41 augustss i++;
472 1.41 augustss goto bad;
473 1.41 augustss }
474 1.74 christos sce->isoreqs[i].dmabuf = tbuf;
475 1.41 augustss for(j = 0; j < UGEN_NISORFRMS; ++j)
476 1.41 augustss sce->isoreqs[i].sizes[j] = isize;
477 1.41 augustss usbd_setup_isoc_xfer
478 1.41 augustss (xfer, sce->pipeh, &sce->isoreqs[i],
479 1.41 augustss sce->isoreqs[i].sizes,
480 1.41 augustss UGEN_NISORFRMS, USBD_NO_COPY,
481 1.41 augustss ugen_isoc_rintr);
482 1.41 augustss (void)usbd_transfer(xfer);
483 1.41 augustss }
484 1.41 augustss DPRINTFN(5, ("ugenopen: isoc open done\n"));
485 1.41 augustss break;
486 1.41 augustss bad:
487 1.41 augustss while (--i >= 0) /* implicit buffer free */
488 1.41 augustss usbd_free_xfer(sce->isoreqs[i].xfer);
489 1.41 augustss return (ENOMEM);
490 1.1 augustss case UE_CONTROL:
491 1.57 augustss sce->timeout = USBD_DEFAULT_TIMEOUT;
492 1.1 augustss return (EINVAL);
493 1.1 augustss }
494 1.1 augustss }
495 1.13 augustss sc->sc_is_open[endpt] = 1;
496 1.1 augustss return (0);
497 1.1 augustss }
498 1.1 augustss
499 1.1 augustss int
500 1.88 christos ugenclose(dev_t dev, int flag, int mode, struct lwp *l)
501 1.1 augustss {
502 1.1 augustss int endpt = UGENENDPOINT(dev);
503 1.24 augustss struct ugen_softc *sc;
504 1.1 augustss struct ugen_endpoint *sce;
505 1.1 augustss int dir;
506 1.41 augustss int i;
507 1.1 augustss
508 1.24 augustss USB_GET_SC(ugen, UGENUNIT(dev), sc);
509 1.30 augustss
510 1.101 drochner DPRINTFN(5, ("ugenclose: flag=%d, mode=%d, unit=%d, endpt=%d\n",
511 1.13 augustss flag, mode, UGENUNIT(dev), endpt));
512 1.13 augustss
513 1.13 augustss #ifdef DIAGNOSTIC
514 1.13 augustss if (!sc->sc_is_open[endpt]) {
515 1.13 augustss printf("ugenclose: not open\n");
516 1.13 augustss return (EINVAL);
517 1.13 augustss }
518 1.13 augustss #endif
519 1.1 augustss
520 1.1 augustss if (endpt == USB_CONTROL_ENDPOINT) {
521 1.9 augustss DPRINTFN(5, ("ugenclose: close control\n"));
522 1.13 augustss sc->sc_is_open[endpt] = 0;
523 1.1 augustss return (0);
524 1.1 augustss }
525 1.9 augustss
526 1.9 augustss for (dir = OUT; dir <= IN; dir++) {
527 1.13 augustss if (!(flag & (dir == OUT ? FWRITE : FREAD)))
528 1.13 augustss continue;
529 1.13 augustss sce = &sc->sc_endpoints[endpt][dir];
530 1.30 augustss if (sce == NULL || sce->pipeh == NULL)
531 1.13 augustss continue;
532 1.55 augustss DPRINTFN(5, ("ugenclose: endpt=%d dir=%d sce=%p\n",
533 1.13 augustss endpt, dir, sce));
534 1.59 augustss
535 1.13 augustss usbd_abort_pipe(sce->pipeh);
536 1.13 augustss usbd_close_pipe(sce->pipeh);
537 1.28 augustss sce->pipeh = NULL;
538 1.41 augustss
539 1.56 augustss switch (sce->edesc->bmAttributes & UE_XFERTYPE) {
540 1.56 augustss case UE_INTERRUPT:
541 1.56 augustss ndflush(&sce->q, sce->q.c_cc);
542 1.56 augustss clfree(&sce->q);
543 1.56 augustss break;
544 1.56 augustss case UE_ISOCHRONOUS:
545 1.56 augustss for (i = 0; i < UGEN_NISOREQS; ++i)
546 1.56 augustss usbd_free_xfer(sce->isoreqs[i].xfer);
547 1.84 gdt break;
548 1.84 gdt #ifdef UGEN_BULK_RA_WB
549 1.84 gdt case UE_BULK:
550 1.84 gdt if (sce->state & (UGEN_BULK_RA | UGEN_BULK_WB))
551 1.84 gdt /* ibuf freed below */
552 1.84 gdt usbd_free_xfer(sce->ra_wb_xfer);
553 1.84 gdt break;
554 1.84 gdt #endif
555 1.56 augustss default:
556 1.56 augustss break;
557 1.41 augustss }
558 1.41 augustss
559 1.28 augustss if (sce->ibuf != NULL) {
560 1.13 augustss free(sce->ibuf, M_USBDEV);
561 1.30 augustss sce->ibuf = NULL;
562 1.13 augustss clfree(&sce->q);
563 1.9 augustss }
564 1.1 augustss }
565 1.13 augustss sc->sc_is_open[endpt] = 0;
566 1.1 augustss
567 1.1 augustss return (0);
568 1.1 augustss }
569 1.1 augustss
570 1.37 augustss Static int
571 1.40 augustss ugen_do_read(struct ugen_softc *sc, int endpt, struct uio *uio, int flag)
572 1.1 augustss {
573 1.1 augustss struct ugen_endpoint *sce = &sc->sc_endpoints[endpt][IN];
574 1.9 augustss u_int32_t n, tn;
575 1.28 augustss usbd_xfer_handle xfer;
576 1.28 augustss usbd_status err;
577 1.1 augustss int s;
578 1.1 augustss int error = 0;
579 1.1 augustss
580 1.44 augustss DPRINTFN(5, ("%s: ugenread: %d\n", USBDEVNAME(sc->sc_dev), endpt));
581 1.26 augustss
582 1.12 augustss if (sc->sc_dying)
583 1.1 augustss return (EIO);
584 1.1 augustss
585 1.26 augustss if (endpt == USB_CONTROL_ENDPOINT)
586 1.26 augustss return (ENODEV);
587 1.26 augustss
588 1.1 augustss #ifdef DIAGNOSTIC
589 1.28 augustss if (sce->edesc == NULL) {
590 1.1 augustss printf("ugenread: no edesc\n");
591 1.1 augustss return (EIO);
592 1.1 augustss }
593 1.28 augustss if (sce->pipeh == NULL) {
594 1.9 augustss printf("ugenread: no pipe\n");
595 1.9 augustss return (EIO);
596 1.9 augustss }
597 1.1 augustss #endif
598 1.1 augustss
599 1.1 augustss switch (sce->edesc->bmAttributes & UE_XFERTYPE) {
600 1.1 augustss case UE_INTERRUPT:
601 1.47 wiz /* Block until activity occurred. */
602 1.2 augustss s = splusb();
603 1.1 augustss while (sce->q.c_cc == 0) {
604 1.1 augustss if (flag & IO_NDELAY) {
605 1.1 augustss splx(s);
606 1.8 augustss return (EWOULDBLOCK);
607 1.1 augustss }
608 1.1 augustss sce->state |= UGEN_ASLP;
609 1.46 yamt DPRINTFN(5, ("ugenread: sleep on %p\n", sce));
610 1.12 augustss error = tsleep(sce, PZERO | PCATCH, "ugenri", 0);
611 1.1 augustss DPRINTFN(5, ("ugenread: woke, error=%d\n", error));
612 1.12 augustss if (sc->sc_dying)
613 1.12 augustss error = EIO;
614 1.1 augustss if (error) {
615 1.1 augustss sce->state &= ~UGEN_ASLP;
616 1.12 augustss break;
617 1.1 augustss }
618 1.1 augustss }
619 1.1 augustss splx(s);
620 1.1 augustss
621 1.1 augustss /* Transfer as many chunks as possible. */
622 1.12 augustss while (sce->q.c_cc > 0 && uio->uio_resid > 0 && !error) {
623 1.1 augustss n = min(sce->q.c_cc, uio->uio_resid);
624 1.83 christos if (n > sizeof(sc->sc_buffer))
625 1.83 christos n = sizeof(sc->sc_buffer);
626 1.1 augustss
627 1.1 augustss /* Remove a small chunk from the input queue. */
628 1.83 christos q_to_b(&sce->q, sc->sc_buffer, n);
629 1.1 augustss DPRINTFN(5, ("ugenread: got %d chars\n", n));
630 1.1 augustss
631 1.1 augustss /* Copy the data to the user process. */
632 1.83 christos error = uiomove(sc->sc_buffer, n, uio);
633 1.1 augustss if (error)
634 1.1 augustss break;
635 1.1 augustss }
636 1.1 augustss break;
637 1.1 augustss case UE_BULK:
638 1.84 gdt #ifdef UGEN_BULK_RA_WB
639 1.84 gdt if (sce->state & UGEN_BULK_RA) {
640 1.90 wiz DPRINTFN(5, ("ugenread: BULK_RA req: %zd used: %d\n",
641 1.84 gdt uio->uio_resid, sce->ra_wb_used));
642 1.84 gdt xfer = sce->ra_wb_xfer;
643 1.84 gdt
644 1.84 gdt s = splusb();
645 1.84 gdt if (sce->ra_wb_used == 0 && flag & IO_NDELAY) {
646 1.84 gdt splx(s);
647 1.84 gdt return (EWOULDBLOCK);
648 1.84 gdt }
649 1.84 gdt while (uio->uio_resid > 0 && !error) {
650 1.84 gdt while (sce->ra_wb_used == 0) {
651 1.84 gdt sce->state |= UGEN_ASLP;
652 1.84 gdt DPRINTFN(5,
653 1.84 gdt ("ugenread: sleep on %p\n",
654 1.84 gdt sce));
655 1.84 gdt error = tsleep(sce, PZERO | PCATCH,
656 1.84 gdt "ugenrb", 0);
657 1.84 gdt DPRINTFN(5,
658 1.84 gdt ("ugenread: woke, error=%d\n",
659 1.84 gdt error));
660 1.84 gdt if (sc->sc_dying)
661 1.84 gdt error = EIO;
662 1.84 gdt if (error) {
663 1.84 gdt sce->state &= ~UGEN_ASLP;
664 1.84 gdt break;
665 1.84 gdt }
666 1.84 gdt }
667 1.84 gdt
668 1.84 gdt /* Copy data to the process. */
669 1.84 gdt while (uio->uio_resid > 0
670 1.84 gdt && sce->ra_wb_used > 0) {
671 1.84 gdt n = min(uio->uio_resid,
672 1.84 gdt sce->ra_wb_used);
673 1.84 gdt n = min(n, sce->limit - sce->cur);
674 1.84 gdt error = uiomove(sce->cur, n, uio);
675 1.84 gdt if (error)
676 1.84 gdt break;
677 1.84 gdt sce->cur += n;
678 1.84 gdt sce->ra_wb_used -= n;
679 1.84 gdt if (sce->cur == sce->limit)
680 1.84 gdt sce->cur = sce->ibuf;
681 1.84 gdt }
682 1.84 gdt
683 1.84 gdt /*
684 1.84 gdt * If the transfers stopped because the
685 1.84 gdt * buffer was full, restart them.
686 1.84 gdt */
687 1.84 gdt if (sce->state & UGEN_RA_WB_STOP &&
688 1.84 gdt sce->ra_wb_used < sce->limit - sce->ibuf) {
689 1.84 gdt n = (sce->limit - sce->ibuf)
690 1.84 gdt - sce->ra_wb_used;
691 1.84 gdt usbd_setup_xfer(xfer,
692 1.84 gdt sce->pipeh, sce, NULL,
693 1.84 gdt min(n, sce->ra_wb_xferlen),
694 1.84 gdt USBD_NO_COPY, USBD_NO_TIMEOUT,
695 1.84 gdt ugen_bulkra_intr);
696 1.84 gdt sce->state &= ~UGEN_RA_WB_STOP;
697 1.84 gdt err = usbd_transfer(xfer);
698 1.84 gdt if (err != USBD_IN_PROGRESS)
699 1.84 gdt /*
700 1.84 gdt * The transfer has not been
701 1.84 gdt * queued. Setting STOP
702 1.84 gdt * will make us try
703 1.84 gdt * again at the next read.
704 1.84 gdt */
705 1.84 gdt sce->state |= UGEN_RA_WB_STOP;
706 1.84 gdt }
707 1.84 gdt }
708 1.84 gdt splx(s);
709 1.84 gdt break;
710 1.84 gdt }
711 1.84 gdt #endif
712 1.29 augustss xfer = usbd_alloc_xfer(sc->sc_udev);
713 1.28 augustss if (xfer == 0)
714 1.1 augustss return (ENOMEM);
715 1.1 augustss while ((n = min(UGEN_BBSIZE, uio->uio_resid)) != 0) {
716 1.10 augustss DPRINTFN(1, ("ugenread: start transfer %d bytes\n",n));
717 1.10 augustss tn = n;
718 1.28 augustss err = usbd_bulk_transfer(
719 1.28 augustss xfer, sce->pipeh,
720 1.55 augustss sce->state & UGEN_SHORT_OK ?
721 1.55 augustss USBD_SHORT_XFER_OK : 0,
722 1.83 christos sce->timeout, sc->sc_buffer, &tn, "ugenrb");
723 1.30 augustss if (err) {
724 1.28 augustss if (err == USBD_INTERRUPTED)
725 1.8 augustss error = EINTR;
726 1.28 augustss else if (err == USBD_TIMEOUT)
727 1.17 augustss error = ETIMEDOUT;
728 1.8 augustss else
729 1.8 augustss error = EIO;
730 1.1 augustss break;
731 1.1 augustss }
732 1.10 augustss DPRINTFN(1, ("ugenread: got %d bytes\n", tn));
733 1.83 christos error = uiomove(sc->sc_buffer, tn, uio);
734 1.9 augustss if (error || tn < n)
735 1.1 augustss break;
736 1.1 augustss }
737 1.29 augustss usbd_free_xfer(xfer);
738 1.1 augustss break;
739 1.41 augustss case UE_ISOCHRONOUS:
740 1.41 augustss s = splusb();
741 1.41 augustss while (sce->cur == sce->fill) {
742 1.41 augustss if (flag & IO_NDELAY) {
743 1.41 augustss splx(s);
744 1.41 augustss return (EWOULDBLOCK);
745 1.41 augustss }
746 1.41 augustss sce->state |= UGEN_ASLP;
747 1.46 yamt DPRINTFN(5, ("ugenread: sleep on %p\n", sce));
748 1.41 augustss error = tsleep(sce, PZERO | PCATCH, "ugenri", 0);
749 1.41 augustss DPRINTFN(5, ("ugenread: woke, error=%d\n", error));
750 1.41 augustss if (sc->sc_dying)
751 1.41 augustss error = EIO;
752 1.41 augustss if (error) {
753 1.41 augustss sce->state &= ~UGEN_ASLP;
754 1.41 augustss break;
755 1.41 augustss }
756 1.41 augustss }
757 1.41 augustss
758 1.41 augustss while (sce->cur != sce->fill && uio->uio_resid > 0 && !error) {
759 1.41 augustss if(sce->fill > sce->cur)
760 1.41 augustss n = min(sce->fill - sce->cur, uio->uio_resid);
761 1.41 augustss else
762 1.41 augustss n = min(sce->limit - sce->cur, uio->uio_resid);
763 1.41 augustss
764 1.41 augustss DPRINTFN(5, ("ugenread: isoc got %d chars\n", n));
765 1.41 augustss
766 1.41 augustss /* Copy the data to the user process. */
767 1.41 augustss error = uiomove(sce->cur, n, uio);
768 1.41 augustss if (error)
769 1.41 augustss break;
770 1.41 augustss sce->cur += n;
771 1.41 augustss if(sce->cur >= sce->limit)
772 1.41 augustss sce->cur = sce->ibuf;
773 1.41 augustss }
774 1.41 augustss splx(s);
775 1.41 augustss break;
776 1.41 augustss
777 1.59 augustss
778 1.1 augustss default:
779 1.1 augustss return (ENXIO);
780 1.1 augustss }
781 1.1 augustss return (error);
782 1.1 augustss }
783 1.1 augustss
784 1.1 augustss int
785 1.40 augustss ugenread(dev_t dev, struct uio *uio, int flag)
786 1.1 augustss {
787 1.1 augustss int endpt = UGENENDPOINT(dev);
788 1.24 augustss struct ugen_softc *sc;
789 1.12 augustss int error;
790 1.12 augustss
791 1.24 augustss USB_GET_SC(ugen, UGENUNIT(dev), sc);
792 1.30 augustss
793 1.12 augustss sc->sc_refcnt++;
794 1.12 augustss error = ugen_do_read(sc, endpt, uio, flag);
795 1.12 augustss if (--sc->sc_refcnt < 0)
796 1.22 augustss usb_detach_wakeup(USBDEV(sc->sc_dev));
797 1.12 augustss return (error);
798 1.12 augustss }
799 1.12 augustss
800 1.37 augustss Static int
801 1.87 xtraeme ugen_do_write(struct ugen_softc *sc, int endpt, struct uio *uio,
802 1.88 christos int flag)
803 1.12 augustss {
804 1.10 augustss struct ugen_endpoint *sce = &sc->sc_endpoints[endpt][OUT];
805 1.16 augustss u_int32_t n;
806 1.1 augustss int error = 0;
807 1.84 gdt #ifdef UGEN_BULK_RA_WB
808 1.84 gdt int s;
809 1.84 gdt u_int32_t tn;
810 1.84 gdt char *dbuf;
811 1.84 gdt #endif
812 1.28 augustss usbd_xfer_handle xfer;
813 1.28 augustss usbd_status err;
814 1.1 augustss
815 1.30 augustss DPRINTFN(5, ("%s: ugenwrite: %d\n", USBDEVNAME(sc->sc_dev), endpt));
816 1.26 augustss
817 1.12 augustss if (sc->sc_dying)
818 1.1 augustss return (EIO);
819 1.1 augustss
820 1.26 augustss if (endpt == USB_CONTROL_ENDPOINT)
821 1.26 augustss return (ENODEV);
822 1.26 augustss
823 1.1 augustss #ifdef DIAGNOSTIC
824 1.28 augustss if (sce->edesc == NULL) {
825 1.1 augustss printf("ugenwrite: no edesc\n");
826 1.1 augustss return (EIO);
827 1.1 augustss }
828 1.28 augustss if (sce->pipeh == NULL) {
829 1.9 augustss printf("ugenwrite: no pipe\n");
830 1.9 augustss return (EIO);
831 1.9 augustss }
832 1.1 augustss #endif
833 1.1 augustss
834 1.1 augustss switch (sce->edesc->bmAttributes & UE_XFERTYPE) {
835 1.1 augustss case UE_BULK:
836 1.84 gdt #ifdef UGEN_BULK_RA_WB
837 1.84 gdt if (sce->state & UGEN_BULK_WB) {
838 1.90 wiz DPRINTFN(5, ("ugenwrite: BULK_WB req: %zd used: %d\n",
839 1.84 gdt uio->uio_resid, sce->ra_wb_used));
840 1.84 gdt xfer = sce->ra_wb_xfer;
841 1.84 gdt
842 1.84 gdt s = splusb();
843 1.84 gdt if (sce->ra_wb_used == sce->limit - sce->ibuf &&
844 1.84 gdt flag & IO_NDELAY) {
845 1.84 gdt splx(s);
846 1.84 gdt return (EWOULDBLOCK);
847 1.84 gdt }
848 1.84 gdt while (uio->uio_resid > 0 && !error) {
849 1.84 gdt while (sce->ra_wb_used ==
850 1.84 gdt sce->limit - sce->ibuf) {
851 1.84 gdt sce->state |= UGEN_ASLP;
852 1.84 gdt DPRINTFN(5,
853 1.84 gdt ("ugenwrite: sleep on %p\n",
854 1.84 gdt sce));
855 1.84 gdt error = tsleep(sce, PZERO | PCATCH,
856 1.84 gdt "ugenwb", 0);
857 1.84 gdt DPRINTFN(5,
858 1.84 gdt ("ugenwrite: woke, error=%d\n",
859 1.84 gdt error));
860 1.84 gdt if (sc->sc_dying)
861 1.84 gdt error = EIO;
862 1.84 gdt if (error) {
863 1.84 gdt sce->state &= ~UGEN_ASLP;
864 1.84 gdt break;
865 1.84 gdt }
866 1.84 gdt }
867 1.84 gdt
868 1.84 gdt /* Copy data from the process. */
869 1.84 gdt while (uio->uio_resid > 0 &&
870 1.84 gdt sce->ra_wb_used < sce->limit - sce->ibuf) {
871 1.84 gdt n = min(uio->uio_resid,
872 1.84 gdt (sce->limit - sce->ibuf)
873 1.84 gdt - sce->ra_wb_used);
874 1.84 gdt n = min(n, sce->limit - sce->fill);
875 1.84 gdt error = uiomove(sce->fill, n, uio);
876 1.84 gdt if (error)
877 1.84 gdt break;
878 1.84 gdt sce->fill += n;
879 1.84 gdt sce->ra_wb_used += n;
880 1.84 gdt if (sce->fill == sce->limit)
881 1.84 gdt sce->fill = sce->ibuf;
882 1.84 gdt }
883 1.84 gdt
884 1.84 gdt /*
885 1.84 gdt * If the transfers stopped because the
886 1.84 gdt * buffer was empty, restart them.
887 1.84 gdt */
888 1.84 gdt if (sce->state & UGEN_RA_WB_STOP &&
889 1.84 gdt sce->ra_wb_used > 0) {
890 1.84 gdt dbuf = (char *)usbd_get_buffer(xfer);
891 1.84 gdt n = min(sce->ra_wb_used,
892 1.84 gdt sce->ra_wb_xferlen);
893 1.84 gdt tn = min(n, sce->limit - sce->cur);
894 1.84 gdt memcpy(dbuf, sce->cur, tn);
895 1.84 gdt dbuf += tn;
896 1.84 gdt if (n - tn > 0)
897 1.84 gdt memcpy(dbuf, sce->ibuf,
898 1.84 gdt n - tn);
899 1.84 gdt usbd_setup_xfer(xfer,
900 1.84 gdt sce->pipeh, sce, NULL, n,
901 1.84 gdt USBD_NO_COPY, USBD_NO_TIMEOUT,
902 1.84 gdt ugen_bulkwb_intr);
903 1.84 gdt sce->state &= ~UGEN_RA_WB_STOP;
904 1.84 gdt err = usbd_transfer(xfer);
905 1.84 gdt if (err != USBD_IN_PROGRESS)
906 1.84 gdt /*
907 1.84 gdt * The transfer has not been
908 1.84 gdt * queued. Setting STOP
909 1.84 gdt * will make us try again
910 1.84 gdt * at the next read.
911 1.84 gdt */
912 1.84 gdt sce->state |= UGEN_RA_WB_STOP;
913 1.84 gdt }
914 1.84 gdt }
915 1.84 gdt splx(s);
916 1.84 gdt break;
917 1.84 gdt }
918 1.84 gdt #endif
919 1.29 augustss xfer = usbd_alloc_xfer(sc->sc_udev);
920 1.28 augustss if (xfer == 0)
921 1.1 augustss return (EIO);
922 1.1 augustss while ((n = min(UGEN_BBSIZE, uio->uio_resid)) != 0) {
923 1.83 christos error = uiomove(sc->sc_buffer, n, uio);
924 1.1 augustss if (error)
925 1.1 augustss break;
926 1.1 augustss DPRINTFN(1, ("ugenwrite: transfer %d bytes\n", n));
927 1.55 augustss err = usbd_bulk_transfer(xfer, sce->pipeh, 0,
928 1.83 christos sce->timeout, sc->sc_buffer, &n,"ugenwb");
929 1.28 augustss if (err) {
930 1.28 augustss if (err == USBD_INTERRUPTED)
931 1.8 augustss error = EINTR;
932 1.36 augustss else if (err == USBD_TIMEOUT)
933 1.36 augustss error = ETIMEDOUT;
934 1.8 augustss else
935 1.8 augustss error = EIO;
936 1.1 augustss break;
937 1.1 augustss }
938 1.1 augustss }
939 1.29 augustss usbd_free_xfer(xfer);
940 1.1 augustss break;
941 1.69 augustss case UE_INTERRUPT:
942 1.69 augustss xfer = usbd_alloc_xfer(sc->sc_udev);
943 1.69 augustss if (xfer == 0)
944 1.69 augustss return (EIO);
945 1.69 augustss while ((n = min(UGETW(sce->edesc->wMaxPacketSize),
946 1.69 augustss uio->uio_resid)) != 0) {
947 1.83 christos error = uiomove(sc->sc_buffer, n, uio);
948 1.69 augustss if (error)
949 1.69 augustss break;
950 1.69 augustss DPRINTFN(1, ("ugenwrite: transfer %d bytes\n", n));
951 1.69 augustss err = usbd_intr_transfer(xfer, sce->pipeh, 0,
952 1.83 christos sce->timeout, sc->sc_buffer, &n, "ugenwi");
953 1.69 augustss if (err) {
954 1.69 augustss if (err == USBD_INTERRUPTED)
955 1.69 augustss error = EINTR;
956 1.69 augustss else if (err == USBD_TIMEOUT)
957 1.69 augustss error = ETIMEDOUT;
958 1.69 augustss else
959 1.69 augustss error = EIO;
960 1.69 augustss break;
961 1.69 augustss }
962 1.69 augustss }
963 1.69 augustss usbd_free_xfer(xfer);
964 1.69 augustss break;
965 1.1 augustss default:
966 1.1 augustss return (ENXIO);
967 1.1 augustss }
968 1.1 augustss return (error);
969 1.1 augustss }
970 1.1 augustss
971 1.12 augustss int
972 1.40 augustss ugenwrite(dev_t dev, struct uio *uio, int flag)
973 1.12 augustss {
974 1.12 augustss int endpt = UGENENDPOINT(dev);
975 1.24 augustss struct ugen_softc *sc;
976 1.12 augustss int error;
977 1.12 augustss
978 1.24 augustss USB_GET_SC(ugen, UGENUNIT(dev), sc);
979 1.30 augustss
980 1.12 augustss sc->sc_refcnt++;
981 1.12 augustss error = ugen_do_write(sc, endpt, uio, flag);
982 1.12 augustss if (--sc->sc_refcnt < 0)
983 1.22 augustss usb_detach_wakeup(USBDEV(sc->sc_dev));
984 1.12 augustss return (error);
985 1.12 augustss }
986 1.12 augustss
987 1.25 augustss #if defined(__NetBSD__) || defined(__OpenBSD__)
988 1.12 augustss int
989 1.40 augustss ugen_activate(device_ptr_t self, enum devact act)
990 1.12 augustss {
991 1.99 cube struct ugen_softc *sc = device_private(self);
992 1.18 augustss
993 1.18 augustss switch (act) {
994 1.18 augustss case DVACT_ACTIVATE:
995 1.18 augustss return (EOPNOTSUPP);
996 1.18 augustss
997 1.18 augustss case DVACT_DEACTIVATE:
998 1.18 augustss sc->sc_dying = 1;
999 1.18 augustss break;
1000 1.18 augustss }
1001 1.12 augustss return (0);
1002 1.12 augustss }
1003 1.25 augustss #endif
1004 1.12 augustss
1005 1.25 augustss USB_DETACH(ugen)
1006 1.12 augustss {
1007 1.25 augustss USB_DETACH_START(ugen, sc);
1008 1.12 augustss struct ugen_endpoint *sce;
1009 1.12 augustss int i, dir;
1010 1.12 augustss int s;
1011 1.25 augustss #if defined(__NetBSD__) || defined(__OpenBSD__)
1012 1.25 augustss int maj, mn;
1013 1.12 augustss
1014 1.12 augustss DPRINTF(("ugen_detach: sc=%p flags=%d\n", sc, flags));
1015 1.25 augustss #elif defined(__FreeBSD__)
1016 1.25 augustss DPRINTF(("ugen_detach: sc=%p\n", sc));
1017 1.25 augustss #endif
1018 1.12 augustss
1019 1.12 augustss sc->sc_dying = 1;
1020 1.96 smb pmf_device_deregister(self);
1021 1.12 augustss /* Abort all pipes. Causes processes waiting for transfer to wake. */
1022 1.12 augustss for (i = 0; i < USB_MAX_ENDPOINTS; i++) {
1023 1.12 augustss for (dir = OUT; dir <= IN; dir++) {
1024 1.12 augustss sce = &sc->sc_endpoints[i][dir];
1025 1.12 augustss if (sce && sce->pipeh)
1026 1.12 augustss usbd_abort_pipe(sce->pipeh);
1027 1.12 augustss }
1028 1.12 augustss }
1029 1.12 augustss
1030 1.12 augustss s = splusb();
1031 1.12 augustss if (--sc->sc_refcnt >= 0) {
1032 1.12 augustss /* Wake everyone */
1033 1.12 augustss for (i = 0; i < USB_MAX_ENDPOINTS; i++)
1034 1.12 augustss wakeup(&sc->sc_endpoints[i][IN]);
1035 1.12 augustss /* Wait for processes to go away. */
1036 1.22 augustss usb_detach_wait(USBDEV(sc->sc_dev));
1037 1.12 augustss }
1038 1.12 augustss splx(s);
1039 1.12 augustss
1040 1.25 augustss #if defined(__NetBSD__) || defined(__OpenBSD__)
1041 1.12 augustss /* locate the major number */
1042 1.60 gehenna #if defined(__NetBSD__)
1043 1.60 gehenna maj = cdevsw_lookup_major(&ugen_cdevsw);
1044 1.60 gehenna #elif defined(__OpenBSD__)
1045 1.12 augustss for (maj = 0; maj < nchrdev; maj++)
1046 1.12 augustss if (cdevsw[maj].d_open == ugenopen)
1047 1.12 augustss break;
1048 1.60 gehenna #endif
1049 1.12 augustss
1050 1.12 augustss /* Nuke the vnodes for any open instances (calls close). */
1051 1.80 thorpej mn = device_unit(self) * USB_MAX_ENDPOINTS;
1052 1.12 augustss vdevgone(maj, mn, mn + USB_MAX_ENDPOINTS - 1, VCHR);
1053 1.25 augustss #elif defined(__FreeBSD__)
1054 1.25 augustss /* XXX not implemented yet */
1055 1.25 augustss #endif
1056 1.33 augustss
1057 1.33 augustss usbd_add_drv_event(USB_EVENT_DRIVER_DETACH, sc->sc_udev,
1058 1.33 augustss USBDEV(sc->sc_dev));
1059 1.12 augustss
1060 1.97 rmind for (i = 0; i < USB_MAX_ENDPOINTS; i++) {
1061 1.97 rmind for (dir = OUT; dir <= IN; dir++) {
1062 1.97 rmind sce = &sc->sc_endpoints[i][dir];
1063 1.97 rmind seldestroy(&sce->rsel);
1064 1.97 rmind }
1065 1.97 rmind }
1066 1.97 rmind
1067 1.12 augustss return (0);
1068 1.12 augustss }
1069 1.1 augustss
1070 1.37 augustss Static void
1071 1.40 augustss ugenintr(usbd_xfer_handle xfer, usbd_private_handle addr, usbd_status status)
1072 1.1 augustss {
1073 1.1 augustss struct ugen_endpoint *sce = addr;
1074 1.1 augustss /*struct ugen_softc *sc = sce->sc;*/
1075 1.8 augustss u_int32_t count;
1076 1.1 augustss u_char *ibuf;
1077 1.1 augustss
1078 1.1 augustss if (status == USBD_CANCELLED)
1079 1.1 augustss return;
1080 1.1 augustss
1081 1.1 augustss if (status != USBD_NORMAL_COMPLETION) {
1082 1.1 augustss DPRINTF(("ugenintr: status=%d\n", status));
1083 1.52 augustss if (status == USBD_STALLED)
1084 1.52 augustss usbd_clear_endpoint_stall_async(sce->pipeh);
1085 1.1 augustss return;
1086 1.1 augustss }
1087 1.1 augustss
1088 1.34 augustss usbd_get_xfer_status(xfer, NULL, NULL, &count, NULL);
1089 1.1 augustss ibuf = sce->ibuf;
1090 1.1 augustss
1091 1.55 augustss DPRINTFN(5, ("ugenintr: xfer=%p status=%d count=%d\n",
1092 1.28 augustss xfer, status, count));
1093 1.1 augustss DPRINTFN(5, (" data = %02x %02x %02x\n",
1094 1.8 augustss ibuf[0], ibuf[1], ibuf[2]));
1095 1.1 augustss
1096 1.8 augustss (void)b_to_q(ibuf, count, &sce->q);
1097 1.59 augustss
1098 1.1 augustss if (sce->state & UGEN_ASLP) {
1099 1.1 augustss sce->state &= ~UGEN_ASLP;
1100 1.1 augustss DPRINTFN(5, ("ugen_intr: waking %p\n", sce));
1101 1.12 augustss wakeup(sce);
1102 1.1 augustss }
1103 1.97 rmind selnotify(&sce->rsel, 0, 0);
1104 1.1 augustss }
1105 1.1 augustss
1106 1.41 augustss Static void
1107 1.55 augustss ugen_isoc_rintr(usbd_xfer_handle xfer, usbd_private_handle addr,
1108 1.42 augustss usbd_status status)
1109 1.41 augustss {
1110 1.41 augustss struct isoreq *req = addr;
1111 1.41 augustss struct ugen_endpoint *sce = req->sce;
1112 1.41 augustss u_int32_t count, n;
1113 1.48 yamt int i, isize;
1114 1.41 augustss
1115 1.41 augustss /* Return if we are aborting. */
1116 1.41 augustss if (status == USBD_CANCELLED)
1117 1.41 augustss return;
1118 1.41 augustss
1119 1.41 augustss usbd_get_xfer_status(xfer, NULL, NULL, &count, NULL);
1120 1.66 mycroft DPRINTFN(5,("ugen_isoc_rintr: xfer %ld, count=%d\n",
1121 1.66 mycroft (long)(req - sce->isoreqs), count));
1122 1.41 augustss
1123 1.41 augustss /* throw away oldest input if the buffer is full */
1124 1.41 augustss if(sce->fill < sce->cur && sce->cur <= sce->fill + count) {
1125 1.41 augustss sce->cur += count;
1126 1.41 augustss if(sce->cur >= sce->limit)
1127 1.41 augustss sce->cur = sce->ibuf + (sce->limit - sce->cur);
1128 1.41 augustss DPRINTFN(5, ("ugen_isoc_rintr: throwing away %d bytes\n",
1129 1.41 augustss count));
1130 1.41 augustss }
1131 1.41 augustss
1132 1.48 yamt isize = UGETW(sce->edesc->wMaxPacketSize);
1133 1.48 yamt for (i = 0; i < UGEN_NISORFRMS; i++) {
1134 1.48 yamt u_int32_t actlen = req->sizes[i];
1135 1.74 christos char const *tbuf = (char const *)req->dmabuf + isize * i;
1136 1.48 yamt
1137 1.48 yamt /* copy data to buffer */
1138 1.48 yamt while (actlen > 0) {
1139 1.48 yamt n = min(actlen, sce->limit - sce->fill);
1140 1.74 christos memcpy(sce->fill, tbuf, n);
1141 1.48 yamt
1142 1.74 christos tbuf += n;
1143 1.48 yamt actlen -= n;
1144 1.48 yamt sce->fill += n;
1145 1.48 yamt if(sce->fill == sce->limit)
1146 1.48 yamt sce->fill = sce->ibuf;
1147 1.48 yamt }
1148 1.48 yamt
1149 1.48 yamt /* setup size for next transfer */
1150 1.48 yamt req->sizes[i] = isize;
1151 1.41 augustss }
1152 1.41 augustss
1153 1.41 augustss usbd_setup_isoc_xfer(xfer, sce->pipeh, req, req->sizes, UGEN_NISORFRMS,
1154 1.41 augustss USBD_NO_COPY, ugen_isoc_rintr);
1155 1.41 augustss (void)usbd_transfer(xfer);
1156 1.41 augustss
1157 1.41 augustss if (sce->state & UGEN_ASLP) {
1158 1.41 augustss sce->state &= ~UGEN_ASLP;
1159 1.41 augustss DPRINTFN(5, ("ugen_isoc_rintr: waking %p\n", sce));
1160 1.41 augustss wakeup(sce);
1161 1.41 augustss }
1162 1.97 rmind selnotify(&sce->rsel, 0, 0);
1163 1.41 augustss }
1164 1.41 augustss
1165 1.84 gdt #ifdef UGEN_BULK_RA_WB
1166 1.84 gdt Static void
1167 1.84 gdt ugen_bulkra_intr(usbd_xfer_handle xfer, usbd_private_handle addr,
1168 1.84 gdt usbd_status status)
1169 1.84 gdt {
1170 1.84 gdt struct ugen_endpoint *sce = addr;
1171 1.84 gdt u_int32_t count, n;
1172 1.84 gdt char const *tbuf;
1173 1.84 gdt usbd_status err;
1174 1.84 gdt
1175 1.84 gdt /* Return if we are aborting. */
1176 1.84 gdt if (status == USBD_CANCELLED)
1177 1.84 gdt return;
1178 1.84 gdt
1179 1.84 gdt if (status != USBD_NORMAL_COMPLETION) {
1180 1.84 gdt DPRINTF(("ugen_bulkra_intr: status=%d\n", status));
1181 1.84 gdt sce->state |= UGEN_RA_WB_STOP;
1182 1.84 gdt if (status == USBD_STALLED)
1183 1.84 gdt usbd_clear_endpoint_stall_async(sce->pipeh);
1184 1.84 gdt return;
1185 1.84 gdt }
1186 1.84 gdt
1187 1.84 gdt usbd_get_xfer_status(xfer, NULL, NULL, &count, NULL);
1188 1.84 gdt
1189 1.84 gdt /* Keep track of how much is in the buffer. */
1190 1.84 gdt sce->ra_wb_used += count;
1191 1.84 gdt
1192 1.84 gdt /* Copy data to buffer. */
1193 1.84 gdt tbuf = (char const *)usbd_get_buffer(sce->ra_wb_xfer);
1194 1.84 gdt n = min(count, sce->limit - sce->fill);
1195 1.84 gdt memcpy(sce->fill, tbuf, n);
1196 1.84 gdt tbuf += n;
1197 1.84 gdt count -= n;
1198 1.84 gdt sce->fill += n;
1199 1.84 gdt if (sce->fill == sce->limit)
1200 1.84 gdt sce->fill = sce->ibuf;
1201 1.84 gdt if (count > 0) {
1202 1.84 gdt memcpy(sce->fill, tbuf, count);
1203 1.84 gdt sce->fill += count;
1204 1.84 gdt }
1205 1.84 gdt
1206 1.84 gdt /* Set up the next request if necessary. */
1207 1.84 gdt n = (sce->limit - sce->ibuf) - sce->ra_wb_used;
1208 1.84 gdt if (n > 0) {
1209 1.84 gdt usbd_setup_xfer(xfer, sce->pipeh, sce, NULL,
1210 1.84 gdt min(n, sce->ra_wb_xferlen), USBD_NO_COPY,
1211 1.84 gdt USBD_NO_TIMEOUT, ugen_bulkra_intr);
1212 1.84 gdt err = usbd_transfer(xfer);
1213 1.84 gdt if (err != USBD_IN_PROGRESS) {
1214 1.84 gdt printf("usbd_bulkra_intr: error=%d\n", err);
1215 1.84 gdt /*
1216 1.84 gdt * The transfer has not been queued. Setting STOP
1217 1.84 gdt * will make us try again at the next read.
1218 1.84 gdt */
1219 1.84 gdt sce->state |= UGEN_RA_WB_STOP;
1220 1.84 gdt }
1221 1.84 gdt }
1222 1.84 gdt else
1223 1.84 gdt sce->state |= UGEN_RA_WB_STOP;
1224 1.84 gdt
1225 1.84 gdt if (sce->state & UGEN_ASLP) {
1226 1.84 gdt sce->state &= ~UGEN_ASLP;
1227 1.84 gdt DPRINTFN(5, ("ugen_bulkra_intr: waking %p\n", sce));
1228 1.84 gdt wakeup(sce);
1229 1.84 gdt }
1230 1.97 rmind selnotify(&sce->rsel, 0, 0);
1231 1.84 gdt }
1232 1.84 gdt
1233 1.84 gdt Static void
1234 1.84 gdt ugen_bulkwb_intr(usbd_xfer_handle xfer, usbd_private_handle addr,
1235 1.84 gdt usbd_status status)
1236 1.84 gdt {
1237 1.84 gdt struct ugen_endpoint *sce = addr;
1238 1.84 gdt u_int32_t count, n;
1239 1.84 gdt char *tbuf;
1240 1.84 gdt usbd_status err;
1241 1.84 gdt
1242 1.84 gdt /* Return if we are aborting. */
1243 1.84 gdt if (status == USBD_CANCELLED)
1244 1.84 gdt return;
1245 1.84 gdt
1246 1.84 gdt if (status != USBD_NORMAL_COMPLETION) {
1247 1.84 gdt DPRINTF(("ugen_bulkwb_intr: status=%d\n", status));
1248 1.84 gdt sce->state |= UGEN_RA_WB_STOP;
1249 1.84 gdt if (status == USBD_STALLED)
1250 1.84 gdt usbd_clear_endpoint_stall_async(sce->pipeh);
1251 1.84 gdt return;
1252 1.84 gdt }
1253 1.84 gdt
1254 1.84 gdt usbd_get_xfer_status(xfer, NULL, NULL, &count, NULL);
1255 1.84 gdt
1256 1.84 gdt /* Keep track of how much is in the buffer. */
1257 1.84 gdt sce->ra_wb_used -= count;
1258 1.84 gdt
1259 1.84 gdt /* Update buffer pointers. */
1260 1.84 gdt sce->cur += count;
1261 1.84 gdt if (sce->cur >= sce->limit)
1262 1.84 gdt sce->cur = sce->ibuf + (sce->cur - sce->limit);
1263 1.84 gdt
1264 1.84 gdt /* Set up next request if necessary. */
1265 1.84 gdt if (sce->ra_wb_used > 0) {
1266 1.84 gdt /* copy data from buffer */
1267 1.84 gdt tbuf = (char *)usbd_get_buffer(sce->ra_wb_xfer);
1268 1.84 gdt count = min(sce->ra_wb_used, sce->ra_wb_xferlen);
1269 1.84 gdt n = min(count, sce->limit - sce->cur);
1270 1.84 gdt memcpy(tbuf, sce->cur, n);
1271 1.84 gdt tbuf += n;
1272 1.84 gdt if (count - n > 0)
1273 1.84 gdt memcpy(tbuf, sce->ibuf, count - n);
1274 1.84 gdt
1275 1.84 gdt usbd_setup_xfer(xfer, sce->pipeh, sce, NULL,
1276 1.84 gdt count, USBD_NO_COPY, USBD_NO_TIMEOUT, ugen_bulkwb_intr);
1277 1.84 gdt err = usbd_transfer(xfer);
1278 1.84 gdt if (err != USBD_IN_PROGRESS) {
1279 1.84 gdt printf("usbd_bulkwb_intr: error=%d\n", err);
1280 1.84 gdt /*
1281 1.84 gdt * The transfer has not been queued. Setting STOP
1282 1.84 gdt * will make us try again at the next write.
1283 1.84 gdt */
1284 1.84 gdt sce->state |= UGEN_RA_WB_STOP;
1285 1.84 gdt }
1286 1.84 gdt }
1287 1.84 gdt else
1288 1.84 gdt sce->state |= UGEN_RA_WB_STOP;
1289 1.84 gdt
1290 1.84 gdt if (sce->state & UGEN_ASLP) {
1291 1.84 gdt sce->state &= ~UGEN_ASLP;
1292 1.84 gdt DPRINTFN(5, ("ugen_bulkwb_intr: waking %p\n", sce));
1293 1.84 gdt wakeup(sce);
1294 1.84 gdt }
1295 1.97 rmind selnotify(&sce->rsel, 0, 0);
1296 1.84 gdt }
1297 1.84 gdt #endif
1298 1.84 gdt
1299 1.37 augustss Static usbd_status
1300 1.40 augustss ugen_set_interface(struct ugen_softc *sc, int ifaceidx, int altno)
1301 1.1 augustss {
1302 1.1 augustss usbd_interface_handle iface;
1303 1.1 augustss usb_endpoint_descriptor_t *ed;
1304 1.28 augustss usbd_status err;
1305 1.1 augustss struct ugen_endpoint *sce;
1306 1.1 augustss u_int8_t niface, nendpt, endptno, endpt;
1307 1.21 augustss int dir;
1308 1.1 augustss
1309 1.1 augustss DPRINTFN(15, ("ugen_set_interface %d %d\n", ifaceidx, altno));
1310 1.1 augustss
1311 1.28 augustss err = usbd_interface_count(sc->sc_udev, &niface);
1312 1.28 augustss if (err)
1313 1.28 augustss return (err);
1314 1.1 augustss if (ifaceidx < 0 || ifaceidx >= niface)
1315 1.1 augustss return (USBD_INVAL);
1316 1.59 augustss
1317 1.28 augustss err = usbd_device2interface_handle(sc->sc_udev, ifaceidx, &iface);
1318 1.28 augustss if (err)
1319 1.28 augustss return (err);
1320 1.28 augustss err = usbd_endpoint_count(iface, &nendpt);
1321 1.28 augustss if (err)
1322 1.28 augustss return (err);
1323 1.39 augustss /* XXX should only do this after setting new altno has succeeded */
1324 1.1 augustss for (endptno = 0; endptno < nendpt; endptno++) {
1325 1.1 augustss ed = usbd_interface2endpoint_descriptor(iface,endptno);
1326 1.1 augustss endpt = ed->bEndpointAddress;
1327 1.21 augustss dir = UE_GET_DIR(endpt) == UE_DIR_IN ? IN : OUT;
1328 1.21 augustss sce = &sc->sc_endpoints[UE_GET_ADDR(endpt)][dir];
1329 1.1 augustss sce->sc = 0;
1330 1.1 augustss sce->edesc = 0;
1331 1.1 augustss sce->iface = 0;
1332 1.1 augustss }
1333 1.1 augustss
1334 1.1 augustss /* change setting */
1335 1.28 augustss err = usbd_set_interface(iface, altno);
1336 1.28 augustss if (err)
1337 1.28 augustss return (err);
1338 1.28 augustss
1339 1.28 augustss err = usbd_endpoint_count(iface, &nendpt);
1340 1.28 augustss if (err)
1341 1.28 augustss return (err);
1342 1.1 augustss for (endptno = 0; endptno < nendpt; endptno++) {
1343 1.1 augustss ed = usbd_interface2endpoint_descriptor(iface,endptno);
1344 1.81 christos KASSERT(ed != NULL);
1345 1.1 augustss endpt = ed->bEndpointAddress;
1346 1.21 augustss dir = UE_GET_DIR(endpt) == UE_DIR_IN ? IN : OUT;
1347 1.21 augustss sce = &sc->sc_endpoints[UE_GET_ADDR(endpt)][dir];
1348 1.1 augustss sce->sc = sc;
1349 1.1 augustss sce->edesc = ed;
1350 1.1 augustss sce->iface = iface;
1351 1.1 augustss }
1352 1.1 augustss return (0);
1353 1.1 augustss }
1354 1.1 augustss
1355 1.1 augustss /* Retrieve a complete descriptor for a certain device and index. */
1356 1.37 augustss Static usb_config_descriptor_t *
1357 1.40 augustss ugen_get_cdesc(struct ugen_softc *sc, int index, int *lenp)
1358 1.1 augustss {
1359 1.1 augustss usb_config_descriptor_t *cdesc, *tdesc, cdescr;
1360 1.1 augustss int len;
1361 1.28 augustss usbd_status err;
1362 1.1 augustss
1363 1.1 augustss if (index == USB_CURRENT_CONFIG_INDEX) {
1364 1.1 augustss tdesc = usbd_get_config_descriptor(sc->sc_udev);
1365 1.1 augustss len = UGETW(tdesc->wTotalLength);
1366 1.1 augustss if (lenp)
1367 1.1 augustss *lenp = len;
1368 1.1 augustss cdesc = malloc(len, M_TEMP, M_WAITOK);
1369 1.1 augustss memcpy(cdesc, tdesc, len);
1370 1.1 augustss DPRINTFN(5,("ugen_get_cdesc: current, len=%d\n", len));
1371 1.1 augustss } else {
1372 1.28 augustss err = usbd_get_config_desc(sc->sc_udev, index, &cdescr);
1373 1.28 augustss if (err)
1374 1.1 augustss return (0);
1375 1.1 augustss len = UGETW(cdescr.wTotalLength);
1376 1.1 augustss DPRINTFN(5,("ugen_get_cdesc: index=%d, len=%d\n", index, len));
1377 1.1 augustss if (lenp)
1378 1.1 augustss *lenp = len;
1379 1.1 augustss cdesc = malloc(len, M_TEMP, M_WAITOK);
1380 1.56 augustss err = usbd_get_config_desc_full(sc->sc_udev, index, cdesc, len);
1381 1.28 augustss if (err) {
1382 1.1 augustss free(cdesc, M_TEMP);
1383 1.1 augustss return (0);
1384 1.1 augustss }
1385 1.1 augustss }
1386 1.1 augustss return (cdesc);
1387 1.1 augustss }
1388 1.1 augustss
1389 1.37 augustss Static int
1390 1.40 augustss ugen_get_alt_index(struct ugen_softc *sc, int ifaceidx)
1391 1.1 augustss {
1392 1.1 augustss usbd_interface_handle iface;
1393 1.28 augustss usbd_status err;
1394 1.1 augustss
1395 1.28 augustss err = usbd_device2interface_handle(sc->sc_udev, ifaceidx, &iface);
1396 1.28 augustss if (err)
1397 1.39 augustss return (-1);
1398 1.2 augustss return (usbd_get_interface_altindex(iface));
1399 1.1 augustss }
1400 1.1 augustss
1401 1.37 augustss Static int
1402 1.40 augustss ugen_do_ioctl(struct ugen_softc *sc, int endpt, u_long cmd,
1403 1.92 christos void *addr, int flag, struct lwp *l)
1404 1.1 augustss {
1405 1.8 augustss struct ugen_endpoint *sce;
1406 1.28 augustss usbd_status err;
1407 1.1 augustss usbd_interface_handle iface;
1408 1.1 augustss struct usb_config_desc *cd;
1409 1.1 augustss usb_config_descriptor_t *cdesc;
1410 1.1 augustss struct usb_interface_desc *id;
1411 1.1 augustss usb_interface_descriptor_t *idesc;
1412 1.1 augustss struct usb_endpoint_desc *ed;
1413 1.1 augustss usb_endpoint_descriptor_t *edesc;
1414 1.1 augustss struct usb_alt_interface *ai;
1415 1.2 augustss struct usb_string_desc *si;
1416 1.1 augustss u_int8_t conf, alt;
1417 1.1 augustss
1418 1.1 augustss DPRINTFN(5, ("ugenioctl: cmd=%08lx\n", cmd));
1419 1.12 augustss if (sc->sc_dying)
1420 1.1 augustss return (EIO);
1421 1.1 augustss
1422 1.2 augustss switch (cmd) {
1423 1.2 augustss case FIONBIO:
1424 1.2 augustss /* All handled in the upper FS layer. */
1425 1.2 augustss return (0);
1426 1.8 augustss case USB_SET_SHORT_XFER:
1427 1.13 augustss if (endpt == USB_CONTROL_ENDPOINT)
1428 1.13 augustss return (EINVAL);
1429 1.51 augustss /* This flag only affects read */
1430 1.8 augustss sce = &sc->sc_endpoints[endpt][IN];
1431 1.51 augustss if (sce == NULL || sce->pipeh == NULL)
1432 1.27 augustss return (EINVAL);
1433 1.8 augustss if (*(int *)addr)
1434 1.8 augustss sce->state |= UGEN_SHORT_OK;
1435 1.8 augustss else
1436 1.8 augustss sce->state &= ~UGEN_SHORT_OK;
1437 1.17 augustss return (0);
1438 1.17 augustss case USB_SET_TIMEOUT:
1439 1.17 augustss sce = &sc->sc_endpoints[endpt][IN];
1440 1.59 augustss if (sce == NULL
1441 1.57 augustss /* XXX this shouldn't happen, but the distinction between
1442 1.57 augustss input and output pipes isn't clear enough.
1443 1.57 augustss || sce->pipeh == NULL */
1444 1.57 augustss )
1445 1.27 augustss return (EINVAL);
1446 1.17 augustss sce->timeout = *(int *)addr;
1447 1.8 augustss return (0);
1448 1.84 gdt case USB_SET_BULK_RA:
1449 1.84 gdt #ifdef UGEN_BULK_RA_WB
1450 1.84 gdt if (endpt == USB_CONTROL_ENDPOINT)
1451 1.84 gdt return (EINVAL);
1452 1.84 gdt sce = &sc->sc_endpoints[endpt][IN];
1453 1.84 gdt if (sce == NULL || sce->pipeh == NULL)
1454 1.84 gdt return (EINVAL);
1455 1.84 gdt edesc = sce->edesc;
1456 1.84 gdt if ((edesc->bmAttributes & UE_XFERTYPE) != UE_BULK)
1457 1.84 gdt return (EINVAL);
1458 1.84 gdt
1459 1.84 gdt if (*(int *)addr) {
1460 1.84 gdt /* Only turn RA on if it's currently off. */
1461 1.84 gdt if (sce->state & UGEN_BULK_RA)
1462 1.84 gdt return (0);
1463 1.84 gdt
1464 1.84 gdt if (sce->ra_wb_bufsize == 0 || sce->ra_wb_reqsize == 0)
1465 1.84 gdt /* shouldn't happen */
1466 1.84 gdt return (EINVAL);
1467 1.84 gdt sce->ra_wb_xfer = usbd_alloc_xfer(sc->sc_udev);
1468 1.84 gdt if (sce->ra_wb_xfer == NULL)
1469 1.84 gdt return (ENOMEM);
1470 1.84 gdt sce->ra_wb_xferlen = sce->ra_wb_reqsize;
1471 1.84 gdt /*
1472 1.84 gdt * Set up a dmabuf because we reuse the xfer with
1473 1.84 gdt * the same (max) request length like isoc.
1474 1.84 gdt */
1475 1.84 gdt if (usbd_alloc_buffer(sce->ra_wb_xfer,
1476 1.84 gdt sce->ra_wb_xferlen) == 0) {
1477 1.84 gdt usbd_free_xfer(sce->ra_wb_xfer);
1478 1.84 gdt return (ENOMEM);
1479 1.84 gdt }
1480 1.84 gdt sce->ibuf = malloc(sce->ra_wb_bufsize,
1481 1.84 gdt M_USBDEV, M_WAITOK);
1482 1.84 gdt sce->fill = sce->cur = sce->ibuf;
1483 1.84 gdt sce->limit = sce->ibuf + sce->ra_wb_bufsize;
1484 1.84 gdt sce->ra_wb_used = 0;
1485 1.84 gdt sce->state |= UGEN_BULK_RA;
1486 1.84 gdt sce->state &= ~UGEN_RA_WB_STOP;
1487 1.84 gdt /* Now start reading. */
1488 1.84 gdt usbd_setup_xfer(sce->ra_wb_xfer, sce->pipeh, sce,
1489 1.84 gdt NULL,
1490 1.84 gdt min(sce->ra_wb_xferlen, sce->ra_wb_bufsize),
1491 1.84 gdt USBD_NO_COPY, USBD_NO_TIMEOUT,
1492 1.84 gdt ugen_bulkra_intr);
1493 1.84 gdt err = usbd_transfer(sce->ra_wb_xfer);
1494 1.84 gdt if (err != USBD_IN_PROGRESS) {
1495 1.84 gdt sce->state &= ~UGEN_BULK_RA;
1496 1.84 gdt free(sce->ibuf, M_USBDEV);
1497 1.84 gdt sce->ibuf = NULL;
1498 1.84 gdt usbd_free_xfer(sce->ra_wb_xfer);
1499 1.84 gdt return (EIO);
1500 1.84 gdt }
1501 1.84 gdt } else {
1502 1.84 gdt /* Only turn RA off if it's currently on. */
1503 1.84 gdt if (!(sce->state & UGEN_BULK_RA))
1504 1.84 gdt return (0);
1505 1.84 gdt
1506 1.84 gdt sce->state &= ~UGEN_BULK_RA;
1507 1.84 gdt usbd_abort_pipe(sce->pipeh);
1508 1.84 gdt usbd_free_xfer(sce->ra_wb_xfer);
1509 1.84 gdt /*
1510 1.84 gdt * XXX Discard whatever's in the buffer, but we
1511 1.84 gdt * should keep it around and drain the buffer
1512 1.84 gdt * instead.
1513 1.84 gdt */
1514 1.84 gdt free(sce->ibuf, M_USBDEV);
1515 1.84 gdt sce->ibuf = NULL;
1516 1.84 gdt }
1517 1.84 gdt return (0);
1518 1.84 gdt #else
1519 1.84 gdt return (EOPNOTSUPP);
1520 1.84 gdt #endif
1521 1.84 gdt case USB_SET_BULK_WB:
1522 1.84 gdt #ifdef UGEN_BULK_RA_WB
1523 1.84 gdt if (endpt == USB_CONTROL_ENDPOINT)
1524 1.84 gdt return (EINVAL);
1525 1.84 gdt sce = &sc->sc_endpoints[endpt][OUT];
1526 1.84 gdt if (sce == NULL || sce->pipeh == NULL)
1527 1.84 gdt return (EINVAL);
1528 1.84 gdt edesc = sce->edesc;
1529 1.84 gdt if ((edesc->bmAttributes & UE_XFERTYPE) != UE_BULK)
1530 1.84 gdt return (EINVAL);
1531 1.84 gdt
1532 1.84 gdt if (*(int *)addr) {
1533 1.84 gdt /* Only turn WB on if it's currently off. */
1534 1.84 gdt if (sce->state & UGEN_BULK_WB)
1535 1.84 gdt return (0);
1536 1.84 gdt
1537 1.84 gdt if (sce->ra_wb_bufsize == 0 || sce->ra_wb_reqsize == 0)
1538 1.84 gdt /* shouldn't happen */
1539 1.84 gdt return (EINVAL);
1540 1.84 gdt sce->ra_wb_xfer = usbd_alloc_xfer(sc->sc_udev);
1541 1.84 gdt if (sce->ra_wb_xfer == NULL)
1542 1.84 gdt return (ENOMEM);
1543 1.84 gdt sce->ra_wb_xferlen = sce->ra_wb_reqsize;
1544 1.84 gdt /*
1545 1.84 gdt * Set up a dmabuf because we reuse the xfer with
1546 1.84 gdt * the same (max) request length like isoc.
1547 1.84 gdt */
1548 1.84 gdt if (usbd_alloc_buffer(sce->ra_wb_xfer,
1549 1.84 gdt sce->ra_wb_xferlen) == 0) {
1550 1.84 gdt usbd_free_xfer(sce->ra_wb_xfer);
1551 1.84 gdt return (ENOMEM);
1552 1.84 gdt }
1553 1.84 gdt sce->ibuf = malloc(sce->ra_wb_bufsize,
1554 1.84 gdt M_USBDEV, M_WAITOK);
1555 1.84 gdt sce->fill = sce->cur = sce->ibuf;
1556 1.84 gdt sce->limit = sce->ibuf + sce->ra_wb_bufsize;
1557 1.84 gdt sce->ra_wb_used = 0;
1558 1.84 gdt sce->state |= UGEN_BULK_WB | UGEN_RA_WB_STOP;
1559 1.84 gdt } else {
1560 1.84 gdt /* Only turn WB off if it's currently on. */
1561 1.84 gdt if (!(sce->state & UGEN_BULK_WB))
1562 1.84 gdt return (0);
1563 1.84 gdt
1564 1.84 gdt sce->state &= ~UGEN_BULK_WB;
1565 1.84 gdt /*
1566 1.84 gdt * XXX Discard whatever's in the buffer, but we
1567 1.84 gdt * should keep it around and keep writing to
1568 1.84 gdt * drain the buffer instead.
1569 1.84 gdt */
1570 1.84 gdt usbd_abort_pipe(sce->pipeh);
1571 1.84 gdt usbd_free_xfer(sce->ra_wb_xfer);
1572 1.84 gdt free(sce->ibuf, M_USBDEV);
1573 1.84 gdt sce->ibuf = NULL;
1574 1.84 gdt }
1575 1.84 gdt return (0);
1576 1.84 gdt #else
1577 1.84 gdt return (EOPNOTSUPP);
1578 1.84 gdt #endif
1579 1.84 gdt case USB_SET_BULK_RA_OPT:
1580 1.84 gdt case USB_SET_BULK_WB_OPT:
1581 1.84 gdt #ifdef UGEN_BULK_RA_WB
1582 1.84 gdt {
1583 1.84 gdt struct usb_bulk_ra_wb_opt *opt;
1584 1.84 gdt
1585 1.84 gdt if (endpt == USB_CONTROL_ENDPOINT)
1586 1.84 gdt return (EINVAL);
1587 1.84 gdt opt = (struct usb_bulk_ra_wb_opt *)addr;
1588 1.84 gdt if (cmd == USB_SET_BULK_RA_OPT)
1589 1.84 gdt sce = &sc->sc_endpoints[endpt][IN];
1590 1.84 gdt else
1591 1.84 gdt sce = &sc->sc_endpoints[endpt][OUT];
1592 1.84 gdt if (sce == NULL || sce->pipeh == NULL)
1593 1.84 gdt return (EINVAL);
1594 1.84 gdt if (opt->ra_wb_buffer_size < 1 ||
1595 1.84 gdt opt->ra_wb_buffer_size > UGEN_BULK_RA_WB_BUFMAX ||
1596 1.84 gdt opt->ra_wb_request_size < 1 ||
1597 1.84 gdt opt->ra_wb_request_size > opt->ra_wb_buffer_size)
1598 1.84 gdt return (EINVAL);
1599 1.84 gdt /*
1600 1.84 gdt * XXX These changes do not take effect until the
1601 1.84 gdt * next time RA/WB mode is enabled but they ought to
1602 1.84 gdt * take effect immediately.
1603 1.84 gdt */
1604 1.84 gdt sce->ra_wb_bufsize = opt->ra_wb_buffer_size;
1605 1.84 gdt sce->ra_wb_reqsize = opt->ra_wb_request_size;
1606 1.84 gdt return (0);
1607 1.84 gdt }
1608 1.84 gdt #else
1609 1.84 gdt return (EOPNOTSUPP);
1610 1.84 gdt #endif
1611 1.2 augustss default:
1612 1.2 augustss break;
1613 1.2 augustss }
1614 1.2 augustss
1615 1.1 augustss if (endpt != USB_CONTROL_ENDPOINT)
1616 1.1 augustss return (EINVAL);
1617 1.1 augustss
1618 1.1 augustss switch (cmd) {
1619 1.30 augustss #ifdef UGEN_DEBUG
1620 1.8 augustss case USB_SETDEBUG:
1621 1.8 augustss ugendebug = *(int *)addr;
1622 1.8 augustss break;
1623 1.8 augustss #endif
1624 1.1 augustss case USB_GET_CONFIG:
1625 1.28 augustss err = usbd_get_config(sc->sc_udev, &conf);
1626 1.28 augustss if (err)
1627 1.1 augustss return (EIO);
1628 1.1 augustss *(int *)addr = conf;
1629 1.1 augustss break;
1630 1.1 augustss case USB_SET_CONFIG:
1631 1.2 augustss if (!(flag & FWRITE))
1632 1.2 augustss return (EPERM);
1633 1.28 augustss err = ugen_set_config(sc, *(int *)addr);
1634 1.53 augustss switch (err) {
1635 1.53 augustss case USBD_NORMAL_COMPLETION:
1636 1.53 augustss break;
1637 1.53 augustss case USBD_IN_USE:
1638 1.53 augustss return (EBUSY);
1639 1.53 augustss default:
1640 1.1 augustss return (EIO);
1641 1.53 augustss }
1642 1.1 augustss break;
1643 1.1 augustss case USB_GET_ALTINTERFACE:
1644 1.1 augustss ai = (struct usb_alt_interface *)addr;
1645 1.55 augustss err = usbd_device2interface_handle(sc->sc_udev,
1646 1.58 christos ai->uai_interface_index, &iface);
1647 1.28 augustss if (err)
1648 1.1 augustss return (EINVAL);
1649 1.1 augustss idesc = usbd_get_interface_descriptor(iface);
1650 1.28 augustss if (idesc == NULL)
1651 1.2 augustss return (EIO);
1652 1.58 christos ai->uai_alt_no = idesc->bAlternateSetting;
1653 1.1 augustss break;
1654 1.1 augustss case USB_SET_ALTINTERFACE:
1655 1.2 augustss if (!(flag & FWRITE))
1656 1.2 augustss return (EPERM);
1657 1.1 augustss ai = (struct usb_alt_interface *)addr;
1658 1.55 augustss err = usbd_device2interface_handle(sc->sc_udev,
1659 1.58 christos ai->uai_interface_index, &iface);
1660 1.28 augustss if (err)
1661 1.1 augustss return (EINVAL);
1662 1.58 christos err = ugen_set_interface(sc, ai->uai_interface_index,
1663 1.58 christos ai->uai_alt_no);
1664 1.28 augustss if (err)
1665 1.1 augustss return (EINVAL);
1666 1.1 augustss break;
1667 1.1 augustss case USB_GET_NO_ALT:
1668 1.1 augustss ai = (struct usb_alt_interface *)addr;
1669 1.58 christos cdesc = ugen_get_cdesc(sc, ai->uai_config_index, 0);
1670 1.28 augustss if (cdesc == NULL)
1671 1.2 augustss return (EINVAL);
1672 1.58 christos idesc = usbd_find_idesc(cdesc, ai->uai_interface_index, 0);
1673 1.28 augustss if (idesc == NULL) {
1674 1.12 augustss free(cdesc, M_TEMP);
1675 1.1 augustss return (EINVAL);
1676 1.12 augustss }
1677 1.58 christos ai->uai_alt_no = usbd_get_no_alts(cdesc,
1678 1.58 christos idesc->bInterfaceNumber);
1679 1.12 augustss free(cdesc, M_TEMP);
1680 1.1 augustss break;
1681 1.1 augustss case USB_GET_DEVICE_DESC:
1682 1.1 augustss *(usb_device_descriptor_t *)addr =
1683 1.1 augustss *usbd_get_device_descriptor(sc->sc_udev);
1684 1.1 augustss break;
1685 1.1 augustss case USB_GET_CONFIG_DESC:
1686 1.1 augustss cd = (struct usb_config_desc *)addr;
1687 1.58 christos cdesc = ugen_get_cdesc(sc, cd->ucd_config_index, 0);
1688 1.28 augustss if (cdesc == NULL)
1689 1.1 augustss return (EINVAL);
1690 1.58 christos cd->ucd_desc = *cdesc;
1691 1.1 augustss free(cdesc, M_TEMP);
1692 1.1 augustss break;
1693 1.1 augustss case USB_GET_INTERFACE_DESC:
1694 1.1 augustss id = (struct usb_interface_desc *)addr;
1695 1.58 christos cdesc = ugen_get_cdesc(sc, id->uid_config_index, 0);
1696 1.28 augustss if (cdesc == NULL)
1697 1.1 augustss return (EINVAL);
1698 1.58 christos if (id->uid_config_index == USB_CURRENT_CONFIG_INDEX &&
1699 1.58 christos id->uid_alt_index == USB_CURRENT_ALT_INDEX)
1700 1.58 christos alt = ugen_get_alt_index(sc, id->uid_interface_index);
1701 1.1 augustss else
1702 1.58 christos alt = id->uid_alt_index;
1703 1.58 christos idesc = usbd_find_idesc(cdesc, id->uid_interface_index, alt);
1704 1.28 augustss if (idesc == NULL) {
1705 1.1 augustss free(cdesc, M_TEMP);
1706 1.1 augustss return (EINVAL);
1707 1.1 augustss }
1708 1.58 christos id->uid_desc = *idesc;
1709 1.1 augustss free(cdesc, M_TEMP);
1710 1.1 augustss break;
1711 1.1 augustss case USB_GET_ENDPOINT_DESC:
1712 1.1 augustss ed = (struct usb_endpoint_desc *)addr;
1713 1.58 christos cdesc = ugen_get_cdesc(sc, ed->ued_config_index, 0);
1714 1.28 augustss if (cdesc == NULL)
1715 1.1 augustss return (EINVAL);
1716 1.58 christos if (ed->ued_config_index == USB_CURRENT_CONFIG_INDEX &&
1717 1.58 christos ed->ued_alt_index == USB_CURRENT_ALT_INDEX)
1718 1.58 christos alt = ugen_get_alt_index(sc, ed->ued_interface_index);
1719 1.1 augustss else
1720 1.58 christos alt = ed->ued_alt_index;
1721 1.58 christos edesc = usbd_find_edesc(cdesc, ed->ued_interface_index,
1722 1.58 christos alt, ed->ued_endpoint_index);
1723 1.28 augustss if (edesc == NULL) {
1724 1.1 augustss free(cdesc, M_TEMP);
1725 1.1 augustss return (EINVAL);
1726 1.1 augustss }
1727 1.58 christos ed->ued_desc = *edesc;
1728 1.1 augustss free(cdesc, M_TEMP);
1729 1.1 augustss break;
1730 1.1 augustss case USB_GET_FULL_DESC:
1731 1.1 augustss {
1732 1.1 augustss int len;
1733 1.1 augustss struct iovec iov;
1734 1.1 augustss struct uio uio;
1735 1.1 augustss struct usb_full_desc *fd = (struct usb_full_desc *)addr;
1736 1.1 augustss int error;
1737 1.1 augustss
1738 1.58 christos cdesc = ugen_get_cdesc(sc, fd->ufd_config_index, &len);
1739 1.104 pooka if (cdesc == NULL)
1740 1.104 pooka return (EINVAL);
1741 1.58 christos if (len > fd->ufd_size)
1742 1.58 christos len = fd->ufd_size;
1743 1.92 christos iov.iov_base = (void *)fd->ufd_data;
1744 1.1 augustss iov.iov_len = len;
1745 1.1 augustss uio.uio_iov = &iov;
1746 1.1 augustss uio.uio_iovcnt = 1;
1747 1.1 augustss uio.uio_resid = len;
1748 1.1 augustss uio.uio_offset = 0;
1749 1.1 augustss uio.uio_rw = UIO_READ;
1750 1.79 yamt uio.uio_vmspace = l->l_proc->p_vmspace;
1751 1.30 augustss error = uiomove((void *)cdesc, len, &uio);
1752 1.1 augustss free(cdesc, M_TEMP);
1753 1.1 augustss return (error);
1754 1.1 augustss }
1755 1.68 mycroft case USB_GET_STRING_DESC: {
1756 1.68 mycroft int len;
1757 1.2 augustss si = (struct usb_string_desc *)addr;
1758 1.58 christos err = usbd_get_string_desc(sc->sc_udev, si->usd_string_index,
1759 1.68 mycroft si->usd_language_id, &si->usd_desc, &len);
1760 1.28 augustss if (err)
1761 1.2 augustss return (EINVAL);
1762 1.2 augustss break;
1763 1.68 mycroft }
1764 1.1 augustss case USB_DO_REQUEST:
1765 1.1 augustss {
1766 1.1 augustss struct usb_ctl_request *ur = (void *)addr;
1767 1.58 christos int len = UGETW(ur->ucr_request.wLength);
1768 1.1 augustss struct iovec iov;
1769 1.1 augustss struct uio uio;
1770 1.1 augustss void *ptr = 0;
1771 1.74 christos usbd_status xerr;
1772 1.1 augustss int error = 0;
1773 1.1 augustss
1774 1.2 augustss if (!(flag & FWRITE))
1775 1.2 augustss return (EPERM);
1776 1.1 augustss /* Avoid requests that would damage the bus integrity. */
1777 1.58 christos if ((ur->ucr_request.bmRequestType == UT_WRITE_DEVICE &&
1778 1.58 christos ur->ucr_request.bRequest == UR_SET_ADDRESS) ||
1779 1.58 christos (ur->ucr_request.bmRequestType == UT_WRITE_DEVICE &&
1780 1.58 christos ur->ucr_request.bRequest == UR_SET_CONFIG) ||
1781 1.58 christos (ur->ucr_request.bmRequestType == UT_WRITE_INTERFACE &&
1782 1.58 christos ur->ucr_request.bRequest == UR_SET_INTERFACE))
1783 1.1 augustss return (EINVAL);
1784 1.1 augustss
1785 1.1 augustss if (len < 0 || len > 32767)
1786 1.1 augustss return (EINVAL);
1787 1.1 augustss if (len != 0) {
1788 1.92 christos iov.iov_base = (void *)ur->ucr_data;
1789 1.1 augustss iov.iov_len = len;
1790 1.1 augustss uio.uio_iov = &iov;
1791 1.1 augustss uio.uio_iovcnt = 1;
1792 1.1 augustss uio.uio_resid = len;
1793 1.1 augustss uio.uio_offset = 0;
1794 1.1 augustss uio.uio_rw =
1795 1.58 christos ur->ucr_request.bmRequestType & UT_READ ?
1796 1.1 augustss UIO_READ : UIO_WRITE;
1797 1.79 yamt uio.uio_vmspace = l->l_proc->p_vmspace;
1798 1.1 augustss ptr = malloc(len, M_TEMP, M_WAITOK);
1799 1.1 augustss if (uio.uio_rw == UIO_WRITE) {
1800 1.1 augustss error = uiomove(ptr, len, &uio);
1801 1.1 augustss if (error)
1802 1.1 augustss goto ret;
1803 1.1 augustss }
1804 1.1 augustss }
1805 1.57 augustss sce = &sc->sc_endpoints[endpt][IN];
1806 1.74 christos xerr = usbd_do_request_flags(sc->sc_udev, &ur->ucr_request,
1807 1.58 christos ptr, ur->ucr_flags, &ur->ucr_actlen, sce->timeout);
1808 1.74 christos if (xerr) {
1809 1.1 augustss error = EIO;
1810 1.1 augustss goto ret;
1811 1.1 augustss }
1812 1.1 augustss if (len != 0) {
1813 1.1 augustss if (uio.uio_rw == UIO_READ) {
1814 1.1 augustss error = uiomove(ptr, len, &uio);
1815 1.1 augustss if (error)
1816 1.1 augustss goto ret;
1817 1.1 augustss }
1818 1.1 augustss }
1819 1.1 augustss ret:
1820 1.1 augustss if (ptr)
1821 1.1 augustss free(ptr, M_TEMP);
1822 1.1 augustss return (error);
1823 1.1 augustss }
1824 1.2 augustss case USB_GET_DEVICEINFO:
1825 1.2 augustss usbd_fill_deviceinfo(sc->sc_udev,
1826 1.91 drochner (struct usb_device_info *)addr, 0);
1827 1.2 augustss break;
1828 1.89 pavel #ifdef COMPAT_30
1829 1.89 pavel case USB_GET_DEVICEINFO_OLD:
1830 1.89 pavel usbd_fill_deviceinfo_old(sc->sc_udev,
1831 1.91 drochner (struct usb_device_info_old *)addr, 0);
1832 1.89 pavel
1833 1.89 pavel break;
1834 1.89 pavel #endif
1835 1.1 augustss default:
1836 1.1 augustss return (EINVAL);
1837 1.1 augustss }
1838 1.1 augustss return (0);
1839 1.1 augustss }
1840 1.1 augustss
1841 1.1 augustss int
1842 1.92 christos ugenioctl(dev_t dev, u_long cmd, void *addr, int flag, struct lwp *l)
1843 1.12 augustss {
1844 1.12 augustss int endpt = UGENENDPOINT(dev);
1845 1.24 augustss struct ugen_softc *sc;
1846 1.12 augustss int error;
1847 1.12 augustss
1848 1.24 augustss USB_GET_SC(ugen, UGENUNIT(dev), sc);
1849 1.30 augustss
1850 1.12 augustss sc->sc_refcnt++;
1851 1.78 christos error = ugen_do_ioctl(sc, endpt, cmd, addr, flag, l);
1852 1.12 augustss if (--sc->sc_refcnt < 0)
1853 1.22 augustss usb_detach_wakeup(USBDEV(sc->sc_dev));
1854 1.12 augustss return (error);
1855 1.12 augustss }
1856 1.12 augustss
1857 1.12 augustss int
1858 1.78 christos ugenpoll(dev_t dev, int events, struct lwp *l)
1859 1.1 augustss {
1860 1.24 augustss struct ugen_softc *sc;
1861 1.84 gdt struct ugen_endpoint *sce_in, *sce_out;
1862 1.1 augustss int revents = 0;
1863 1.1 augustss int s;
1864 1.1 augustss
1865 1.24 augustss USB_GET_SC(ugen, UGENUNIT(dev), sc);
1866 1.30 augustss
1867 1.12 augustss if (sc->sc_dying)
1868 1.75 ws return (POLLHUP);
1869 1.1 augustss
1870 1.84 gdt sce_in = &sc->sc_endpoints[UGENENDPOINT(dev)][IN];
1871 1.84 gdt sce_out = &sc->sc_endpoints[UGENENDPOINT(dev)][OUT];
1872 1.84 gdt if (sce_in == NULL && sce_out == NULL)
1873 1.75 ws return (POLLERR);
1874 1.9 augustss #ifdef DIAGNOSTIC
1875 1.84 gdt if (!sce_in->edesc && !sce_out->edesc) {
1876 1.36 augustss printf("ugenpoll: no edesc\n");
1877 1.75 ws return (POLLERR);
1878 1.9 augustss }
1879 1.84 gdt /* It's possible to have only one pipe open. */
1880 1.84 gdt if (!sce_in->pipeh && !sce_out->pipeh) {
1881 1.9 augustss printf("ugenpoll: no pipe\n");
1882 1.75 ws return (POLLERR);
1883 1.9 augustss }
1884 1.9 augustss #endif
1885 1.2 augustss s = splusb();
1886 1.84 gdt if (sce_in && sce_in->pipeh && (events & (POLLIN | POLLRDNORM)))
1887 1.84 gdt switch (sce_in->edesc->bmAttributes & UE_XFERTYPE) {
1888 1.84 gdt case UE_INTERRUPT:
1889 1.84 gdt if (sce_in->q.c_cc > 0)
1890 1.41 augustss revents |= events & (POLLIN | POLLRDNORM);
1891 1.41 augustss else
1892 1.84 gdt selrecord(l, &sce_in->rsel);
1893 1.84 gdt break;
1894 1.84 gdt case UE_ISOCHRONOUS:
1895 1.84 gdt if (sce_in->cur != sce_in->fill)
1896 1.1 augustss revents |= events & (POLLIN | POLLRDNORM);
1897 1.1 augustss else
1898 1.84 gdt selrecord(l, &sce_in->rsel);
1899 1.84 gdt break;
1900 1.84 gdt case UE_BULK:
1901 1.84 gdt #ifdef UGEN_BULK_RA_WB
1902 1.84 gdt if (sce_in->state & UGEN_BULK_RA) {
1903 1.84 gdt if (sce_in->ra_wb_used > 0)
1904 1.84 gdt revents |= events &
1905 1.84 gdt (POLLIN | POLLRDNORM);
1906 1.84 gdt else
1907 1.84 gdt selrecord(l, &sce_in->rsel);
1908 1.84 gdt break;
1909 1.84 gdt }
1910 1.84 gdt #endif
1911 1.84 gdt /*
1912 1.84 gdt * We have no easy way of determining if a read will
1913 1.84 gdt * yield any data or a write will happen.
1914 1.84 gdt * Pretend they will.
1915 1.84 gdt */
1916 1.84 gdt revents |= events & (POLLIN | POLLRDNORM);
1917 1.84 gdt break;
1918 1.84 gdt default:
1919 1.84 gdt break;
1920 1.1 augustss }
1921 1.84 gdt if (sce_out && sce_out->pipeh && (events & (POLLOUT | POLLWRNORM)))
1922 1.84 gdt switch (sce_out->edesc->bmAttributes & UE_XFERTYPE) {
1923 1.84 gdt case UE_INTERRUPT:
1924 1.84 gdt case UE_ISOCHRONOUS:
1925 1.84 gdt /* XXX unimplemented */
1926 1.84 gdt break;
1927 1.84 gdt case UE_BULK:
1928 1.84 gdt #ifdef UGEN_BULK_RA_WB
1929 1.84 gdt if (sce_out->state & UGEN_BULK_WB) {
1930 1.84 gdt if (sce_out->ra_wb_used <
1931 1.84 gdt sce_out->limit - sce_out->ibuf)
1932 1.84 gdt revents |= events &
1933 1.84 gdt (POLLOUT | POLLWRNORM);
1934 1.84 gdt else
1935 1.84 gdt selrecord(l, &sce_out->rsel);
1936 1.84 gdt break;
1937 1.84 gdt }
1938 1.84 gdt #endif
1939 1.84 gdt /*
1940 1.84 gdt * We have no easy way of determining if a read will
1941 1.84 gdt * yield any data or a write will happen.
1942 1.84 gdt * Pretend they will.
1943 1.84 gdt */
1944 1.84 gdt revents |= events & (POLLOUT | POLLWRNORM);
1945 1.84 gdt break;
1946 1.84 gdt default:
1947 1.84 gdt break;
1948 1.84 gdt }
1949 1.84 gdt
1950 1.84 gdt
1951 1.1 augustss splx(s);
1952 1.1 augustss return (revents);
1953 1.62 jdolecek }
1954 1.62 jdolecek
1955 1.62 jdolecek static void
1956 1.62 jdolecek filt_ugenrdetach(struct knote *kn)
1957 1.62 jdolecek {
1958 1.62 jdolecek struct ugen_endpoint *sce = kn->kn_hook;
1959 1.62 jdolecek int s;
1960 1.62 jdolecek
1961 1.62 jdolecek s = splusb();
1962 1.63 christos SLIST_REMOVE(&sce->rsel.sel_klist, kn, knote, kn_selnext);
1963 1.62 jdolecek splx(s);
1964 1.62 jdolecek }
1965 1.62 jdolecek
1966 1.62 jdolecek static int
1967 1.88 christos filt_ugenread_intr(struct knote *kn, long hint)
1968 1.62 jdolecek {
1969 1.62 jdolecek struct ugen_endpoint *sce = kn->kn_hook;
1970 1.62 jdolecek
1971 1.62 jdolecek kn->kn_data = sce->q.c_cc;
1972 1.62 jdolecek return (kn->kn_data > 0);
1973 1.62 jdolecek }
1974 1.62 jdolecek
1975 1.62 jdolecek static int
1976 1.88 christos filt_ugenread_isoc(struct knote *kn, long hint)
1977 1.62 jdolecek {
1978 1.62 jdolecek struct ugen_endpoint *sce = kn->kn_hook;
1979 1.62 jdolecek
1980 1.62 jdolecek if (sce->cur == sce->fill)
1981 1.62 jdolecek return (0);
1982 1.62 jdolecek
1983 1.62 jdolecek if (sce->cur < sce->fill)
1984 1.62 jdolecek kn->kn_data = sce->fill - sce->cur;
1985 1.62 jdolecek else
1986 1.62 jdolecek kn->kn_data = (sce->limit - sce->cur) +
1987 1.62 jdolecek (sce->fill - sce->ibuf);
1988 1.62 jdolecek
1989 1.62 jdolecek return (1);
1990 1.62 jdolecek }
1991 1.62 jdolecek
1992 1.84 gdt #ifdef UGEN_BULK_RA_WB
1993 1.84 gdt static int
1994 1.84 gdt filt_ugenread_bulk(struct knote *kn, long hint)
1995 1.84 gdt {
1996 1.84 gdt struct ugen_endpoint *sce = kn->kn_hook;
1997 1.84 gdt
1998 1.84 gdt if (!(sce->state & UGEN_BULK_RA))
1999 1.84 gdt /*
2000 1.84 gdt * We have no easy way of determining if a read will
2001 1.84 gdt * yield any data or a write will happen.
2002 1.84 gdt * So, emulate "seltrue".
2003 1.84 gdt */
2004 1.84 gdt return (filt_seltrue(kn, hint));
2005 1.84 gdt
2006 1.84 gdt if (sce->ra_wb_used == 0)
2007 1.84 gdt return (0);
2008 1.84 gdt
2009 1.84 gdt kn->kn_data = sce->ra_wb_used;
2010 1.84 gdt
2011 1.84 gdt return (1);
2012 1.84 gdt }
2013 1.84 gdt
2014 1.84 gdt static int
2015 1.84 gdt filt_ugenwrite_bulk(struct knote *kn, long hint)
2016 1.84 gdt {
2017 1.84 gdt struct ugen_endpoint *sce = kn->kn_hook;
2018 1.84 gdt
2019 1.84 gdt if (!(sce->state & UGEN_BULK_WB))
2020 1.84 gdt /*
2021 1.84 gdt * We have no easy way of determining if a read will
2022 1.84 gdt * yield any data or a write will happen.
2023 1.84 gdt * So, emulate "seltrue".
2024 1.84 gdt */
2025 1.84 gdt return (filt_seltrue(kn, hint));
2026 1.84 gdt
2027 1.84 gdt if (sce->ra_wb_used == sce->limit - sce->ibuf)
2028 1.84 gdt return (0);
2029 1.84 gdt
2030 1.84 gdt kn->kn_data = (sce->limit - sce->ibuf) - sce->ra_wb_used;
2031 1.84 gdt
2032 1.84 gdt return (1);
2033 1.84 gdt }
2034 1.84 gdt #endif
2035 1.84 gdt
2036 1.62 jdolecek static const struct filterops ugenread_intr_filtops =
2037 1.62 jdolecek { 1, NULL, filt_ugenrdetach, filt_ugenread_intr };
2038 1.62 jdolecek
2039 1.62 jdolecek static const struct filterops ugenread_isoc_filtops =
2040 1.62 jdolecek { 1, NULL, filt_ugenrdetach, filt_ugenread_isoc };
2041 1.62 jdolecek
2042 1.84 gdt #ifdef UGEN_BULK_RA_WB
2043 1.84 gdt static const struct filterops ugenread_bulk_filtops =
2044 1.84 gdt { 1, NULL, filt_ugenrdetach, filt_ugenread_bulk };
2045 1.84 gdt
2046 1.84 gdt static const struct filterops ugenwrite_bulk_filtops =
2047 1.84 gdt { 1, NULL, filt_ugenrdetach, filt_ugenwrite_bulk };
2048 1.84 gdt #else
2049 1.62 jdolecek static const struct filterops ugen_seltrue_filtops =
2050 1.62 jdolecek { 1, NULL, filt_ugenrdetach, filt_seltrue };
2051 1.84 gdt #endif
2052 1.62 jdolecek
2053 1.62 jdolecek int
2054 1.62 jdolecek ugenkqfilter(dev_t dev, struct knote *kn)
2055 1.62 jdolecek {
2056 1.62 jdolecek struct ugen_softc *sc;
2057 1.62 jdolecek struct ugen_endpoint *sce;
2058 1.62 jdolecek struct klist *klist;
2059 1.62 jdolecek int s;
2060 1.62 jdolecek
2061 1.62 jdolecek USB_GET_SC(ugen, UGENUNIT(dev), sc);
2062 1.62 jdolecek
2063 1.62 jdolecek if (sc->sc_dying)
2064 1.94 pooka return (ENXIO);
2065 1.62 jdolecek
2066 1.62 jdolecek switch (kn->kn_filter) {
2067 1.62 jdolecek case EVFILT_READ:
2068 1.84 gdt sce = &sc->sc_endpoints[UGENENDPOINT(dev)][IN];
2069 1.84 gdt if (sce == NULL)
2070 1.94 pooka return (EINVAL);
2071 1.84 gdt
2072 1.63 christos klist = &sce->rsel.sel_klist;
2073 1.62 jdolecek switch (sce->edesc->bmAttributes & UE_XFERTYPE) {
2074 1.62 jdolecek case UE_INTERRUPT:
2075 1.62 jdolecek kn->kn_fop = &ugenread_intr_filtops;
2076 1.62 jdolecek break;
2077 1.62 jdolecek case UE_ISOCHRONOUS:
2078 1.62 jdolecek kn->kn_fop = &ugenread_isoc_filtops;
2079 1.62 jdolecek break;
2080 1.62 jdolecek case UE_BULK:
2081 1.84 gdt #ifdef UGEN_BULK_RA_WB
2082 1.84 gdt kn->kn_fop = &ugenread_bulk_filtops;
2083 1.84 gdt break;
2084 1.84 gdt #else
2085 1.70 perry /*
2086 1.62 jdolecek * We have no easy way of determining if a read will
2087 1.62 jdolecek * yield any data or a write will happen.
2088 1.62 jdolecek * So, emulate "seltrue".
2089 1.62 jdolecek */
2090 1.62 jdolecek kn->kn_fop = &ugen_seltrue_filtops;
2091 1.84 gdt #endif
2092 1.62 jdolecek break;
2093 1.62 jdolecek default:
2094 1.94 pooka return (EINVAL);
2095 1.62 jdolecek }
2096 1.62 jdolecek break;
2097 1.62 jdolecek
2098 1.62 jdolecek case EVFILT_WRITE:
2099 1.84 gdt sce = &sc->sc_endpoints[UGENENDPOINT(dev)][OUT];
2100 1.84 gdt if (sce == NULL)
2101 1.94 pooka return (EINVAL);
2102 1.84 gdt
2103 1.63 christos klist = &sce->rsel.sel_klist;
2104 1.62 jdolecek switch (sce->edesc->bmAttributes & UE_XFERTYPE) {
2105 1.62 jdolecek case UE_INTERRUPT:
2106 1.62 jdolecek case UE_ISOCHRONOUS:
2107 1.62 jdolecek /* XXX poll doesn't support this */
2108 1.94 pooka return (EINVAL);
2109 1.62 jdolecek
2110 1.62 jdolecek case UE_BULK:
2111 1.84 gdt #ifdef UGEN_BULK_RA_WB
2112 1.84 gdt kn->kn_fop = &ugenwrite_bulk_filtops;
2113 1.84 gdt #else
2114 1.62 jdolecek /*
2115 1.62 jdolecek * We have no easy way of determining if a read will
2116 1.62 jdolecek * yield any data or a write will happen.
2117 1.62 jdolecek * So, emulate "seltrue".
2118 1.62 jdolecek */
2119 1.62 jdolecek kn->kn_fop = &ugen_seltrue_filtops;
2120 1.84 gdt #endif
2121 1.62 jdolecek break;
2122 1.62 jdolecek default:
2123 1.94 pooka return (EINVAL);
2124 1.62 jdolecek }
2125 1.62 jdolecek break;
2126 1.62 jdolecek
2127 1.62 jdolecek default:
2128 1.94 pooka return (EINVAL);
2129 1.62 jdolecek }
2130 1.62 jdolecek
2131 1.62 jdolecek kn->kn_hook = sce;
2132 1.62 jdolecek
2133 1.62 jdolecek s = splusb();
2134 1.62 jdolecek SLIST_INSERT_HEAD(klist, kn, kn_selnext);
2135 1.62 jdolecek splx(s);
2136 1.62 jdolecek
2137 1.62 jdolecek return (0);
2138 1.1 augustss }
2139 1.5 augustss
2140 1.5 augustss #if defined(__FreeBSD__)
2141 1.30 augustss DRIVER_MODULE(ugen, uhub, ugen_driver, ugen_devclass, usbd_driver_load, 0);
2142 1.5 augustss #endif
2143