Home | History | Annotate | Line # | Download | only in usb
usbdi.c revision 1.119.12.6
      1  1.119.12.6     itohy /*	$NetBSD: usbdi.c,v 1.119.12.6 2008/05/21 05:04:03 itohy Exp $	*/
      2  1.119.12.1     itohy /*	$FreeBSD: src/sys/dev/usb/usbdi.c,v 1.99 2006/11/27 18:39:02 marius Exp $	*/
      3         1.1  augustss 
      4  1.119.12.1     itohy /*-
      5         1.1  augustss  * Copyright (c) 1998 The NetBSD Foundation, Inc.
      6         1.1  augustss  * All rights reserved.
      7         1.1  augustss  *
      8        1.11  augustss  * This code is derived from software contributed to The NetBSD Foundation
      9        1.72  augustss  * by Lennart Augustsson (lennart (at) augustsson.net) at
     10        1.11  augustss  * Carlstedt Research & Technology.
     11         1.1  augustss  *
     12         1.1  augustss  * Redistribution and use in source and binary forms, with or without
     13         1.1  augustss  * modification, are permitted provided that the following conditions
     14         1.1  augustss  * are met:
     15         1.1  augustss  * 1. Redistributions of source code must retain the above copyright
     16         1.1  augustss  *    notice, this list of conditions and the following disclaimer.
     17         1.1  augustss  * 2. Redistributions in binary form must reproduce the above copyright
     18         1.1  augustss  *    notice, this list of conditions and the following disclaimer in the
     19         1.1  augustss  *    documentation and/or other materials provided with the distribution.
     20         1.1  augustss  * 3. All advertising materials mentioning features or use of this software
     21         1.1  augustss  *    must display the following acknowledgement:
     22         1.1  augustss  *        This product includes software developed by the NetBSD
     23         1.1  augustss  *        Foundation, Inc. and its contributors.
     24         1.1  augustss  * 4. Neither the name of The NetBSD Foundation nor the names of its
     25         1.1  augustss  *    contributors may be used to endorse or promote products derived
     26         1.1  augustss  *    from this software without specific prior written permission.
     27         1.1  augustss  *
     28         1.1  augustss  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     29         1.1  augustss  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     30         1.1  augustss  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     31         1.1  augustss  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     32         1.1  augustss  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     33         1.1  augustss  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     34         1.1  augustss  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     35         1.1  augustss  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     36         1.1  augustss  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     37         1.1  augustss  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     38         1.1  augustss  * POSSIBILITY OF SUCH DAMAGE.
     39         1.1  augustss  */
     40        1.84     lukem 
     41        1.84     lukem #include <sys/cdefs.h>
     42  1.119.12.6     itohy __KERNEL_RCSID(0, "$NetBSD: usbdi.c,v 1.119.12.6 2008/05/21 05:04:03 itohy Exp $");
     43  1.119.12.1     itohy /* __FBSDID("$FreeBSD: src/sys/dev/usb/usbdi.c,v 1.99 2006/11/27 18:39:02 marius Exp $"); */
     44       1.115     pavel 
     45  1.119.12.1     itohy #ifdef __NetBSD__
     46       1.115     pavel #include "opt_compat_netbsd.h"
     47  1.119.12.1     itohy #endif
     48         1.1  augustss 
     49         1.1  augustss #include <sys/param.h>
     50         1.1  augustss #include <sys/systm.h>
     51        1.51  augustss #if defined(__NetBSD__) || defined(__OpenBSD__)
     52         1.1  augustss #include <sys/kernel.h>
     53        1.15  augustss #include <sys/device.h>
     54        1.45  augustss #elif defined(__FreeBSD__)
     55        1.15  augustss #include <sys/module.h>
     56        1.15  augustss #include <sys/bus.h>
     57        1.45  augustss #include "usb_if.h"
     58        1.51  augustss #if defined(DIAGNOSTIC) && defined(__i386__)
     59        1.51  augustss #include <machine/cpu.h>
     60        1.51  augustss #endif
     61        1.15  augustss #endif
     62         1.1  augustss #include <sys/malloc.h>
     63  1.119.12.2     itohy #include <sys/mbuf.h>
     64         1.1  augustss #include <sys/proc.h>
     65         1.1  augustss 
     66        1.36  augustss #include <machine/bus.h>
     67        1.36  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 #include <dev/usb/usbdivar.h>
     72  1.119.12.1     itohy /* #include <dev/usb/usb_mem.h> */
     73       1.105  augustss #include <dev/usb/usb_quirks.h>
     74         1.1  augustss 
     75  1.119.12.1     itohy #if defined(__FreeBSD__)
     76  1.119.12.1     itohy #include "usb_if.h"
     77  1.119.12.1     itohy #define delay(d)	DELAY(d)
     78  1.119.12.1     itohy #endif
     79  1.119.12.1     itohy 
     80       1.119  drochner /* UTF-8 encoding stuff */
     81       1.119  drochner #include <fs/unicode.h>
     82       1.119  drochner 
     83         1.1  augustss #ifdef USB_DEBUG
     84        1.27  augustss #define DPRINTF(x)	if (usbdebug) logprintf x
     85        1.27  augustss #define DPRINTFN(n,x)	if (usbdebug>(n)) logprintf x
     86         1.1  augustss extern int usbdebug;
     87         1.1  augustss #else
     88         1.1  augustss #define DPRINTF(x)
     89         1.1  augustss #define DPRINTFN(n,x)
     90         1.1  augustss #endif
     91         1.1  augustss 
     92  1.119.12.1     itohy Static usbd_xfer_handle usbd_alloc_xfer_flag(usbd_device_handle,
     93  1.119.12.1     itohy 	usbd_pipe_handle pipe, enum usbd_waitflg);
     94  1.119.12.1     itohy Static void usbd_free_buffer_flag(usbd_xfer_handle, enum usbd_waitflg);
     95  1.119.12.1     itohy Static usbd_status usbd_free_xfer_flag(usbd_xfer_handle, enum usbd_waitflg);
     96        1.74  augustss Static usbd_status usbd_ar_pipe(usbd_pipe_handle pipe);
     97  1.119.12.3     itohy Static void usbd_callback_task(void *);
     98       1.102  augustss Static void usbd_do_request_async_cb
     99        1.87  augustss 	(usbd_xfer_handle, usbd_private_handle, usbd_status);
    100  1.119.12.1     itohy Static void usbd_do_request_async_task(void *);
    101        1.74  augustss Static void usbd_start_next(usbd_pipe_handle pipe);
    102        1.69  augustss Static usbd_status usbd_open_pipe_ival
    103        1.87  augustss 	(usbd_interface_handle, u_int8_t, u_int8_t, usbd_pipe_handle *, int);
    104         1.1  augustss 
    105  1.119.12.1     itohy int
    106        1.74  augustss usbd_xfer_isread(usbd_xfer_handle xfer)
    107        1.37  augustss {
    108        1.48  augustss 	if (xfer->rqflags & URQ_REQUEST)
    109        1.48  augustss 		return (xfer->request.bmRequestType & UT_READ);
    110        1.37  augustss 	else
    111        1.48  augustss 		return (xfer->pipe->endpoint->edesc->bEndpointAddress &
    112        1.37  augustss 			UE_DIR_IN);
    113        1.37  augustss }
    114        1.37  augustss 
    115        1.28  augustss #ifdef USB_DEBUG
    116        1.82  augustss void
    117        1.82  augustss usbd_dump_iface(struct usbd_interface *iface)
    118        1.82  augustss {
    119        1.82  augustss 	printf("usbd_dump_iface: iface=%p\n", iface);
    120        1.82  augustss 	if (iface == NULL)
    121        1.82  augustss 		return;
    122        1.82  augustss 	printf(" device=%p idesc=%p index=%d altindex=%d priv=%p\n",
    123        1.82  augustss 	       iface->device, iface->idesc, iface->index, iface->altindex,
    124        1.82  augustss 	       iface->priv);
    125        1.82  augustss }
    126        1.82  augustss 
    127        1.82  augustss void
    128        1.82  augustss usbd_dump_device(struct usbd_device *dev)
    129        1.82  augustss {
    130        1.82  augustss 	printf("usbd_dump_device: dev=%p\n", dev);
    131        1.82  augustss 	if (dev == NULL)
    132        1.82  augustss 		return;
    133        1.82  augustss 	printf(" bus=%p default_pipe=%p\n", dev->bus, dev->default_pipe);
    134        1.86  augustss 	printf(" address=%d config=%d depth=%d speed=%d self_powered=%d "
    135        1.86  augustss 	       "power=%d langid=%d\n",
    136        1.86  augustss 	       dev->address, dev->config, dev->depth, dev->speed,
    137        1.82  augustss 	       dev->self_powered, dev->power, dev->langid);
    138        1.82  augustss }
    139        1.82  augustss 
    140        1.82  augustss void
    141        1.82  augustss usbd_dump_endpoint(struct usbd_endpoint *endp)
    142        1.82  augustss {
    143        1.82  augustss 	printf("usbd_dump_endpoint: endp=%p\n", endp);
    144        1.82  augustss 	if (endp == NULL)
    145        1.82  augustss 		return;
    146        1.82  augustss 	printf(" edesc=%p refcnt=%d\n", endp->edesc, endp->refcnt);
    147        1.82  augustss 	if (endp->edesc)
    148        1.82  augustss 		printf(" bEndpointAddress=0x%02x\n",
    149        1.82  augustss 		       endp->edesc->bEndpointAddress);
    150        1.82  augustss }
    151        1.82  augustss 
    152        1.28  augustss void
    153        1.74  augustss usbd_dump_queue(usbd_pipe_handle pipe)
    154        1.28  augustss {
    155        1.48  augustss 	usbd_xfer_handle xfer;
    156        1.28  augustss 
    157        1.28  augustss 	printf("usbd_dump_queue: pipe=%p\n", pipe);
    158       1.101     lukem 	SIMPLEQ_FOREACH(xfer, &pipe->queue, next) {
    159        1.48  augustss 		printf("  xfer=%p\n", xfer);
    160        1.28  augustss 	}
    161        1.82  augustss }
    162        1.82  augustss 
    163        1.82  augustss void
    164        1.82  augustss usbd_dump_pipe(usbd_pipe_handle pipe)
    165        1.82  augustss {
    166        1.82  augustss 	printf("usbd_dump_pipe: pipe=%p\n", pipe);
    167        1.82  augustss 	if (pipe == NULL)
    168        1.82  augustss 		return;
    169        1.82  augustss 	usbd_dump_iface(pipe->iface);
    170        1.82  augustss 	usbd_dump_device(pipe->device);
    171        1.82  augustss 	usbd_dump_endpoint(pipe->endpoint);
    172        1.82  augustss 	printf(" (usbd_dump_pipe:)\n refcnt=%d running=%d aborting=%d\n",
    173        1.82  augustss 	       pipe->refcnt, pipe->running, pipe->aborting);
    174        1.88  augustss 	printf(" intrxfer=%p, repeat=%d, interval=%d\n",
    175        1.82  augustss 	       pipe->intrxfer, pipe->repeat, pipe->interval);
    176        1.28  augustss }
    177        1.28  augustss #endif
    178        1.28  augustss 
    179       1.102  augustss usbd_status
    180        1.74  augustss usbd_open_pipe(usbd_interface_handle iface, u_int8_t address,
    181        1.74  augustss 	       u_int8_t flags, usbd_pipe_handle *pipe)
    182       1.102  augustss {
    183       1.102  augustss 	return (usbd_open_pipe_ival(iface, address, flags, pipe,
    184        1.60  augustss 				    USBD_DEFAULT_INTERVAL));
    185        1.60  augustss }
    186        1.60  augustss 
    187       1.102  augustss usbd_status
    188        1.74  augustss usbd_open_pipe_ival(usbd_interface_handle iface, u_int8_t address,
    189        1.74  augustss 		    u_int8_t flags, usbd_pipe_handle *pipe, int ival)
    190       1.102  augustss {
    191         1.1  augustss 	usbd_pipe_handle p;
    192         1.1  augustss 	struct usbd_endpoint *ep;
    193        1.48  augustss 	usbd_status err;
    194        1.12  augustss 	int i;
    195         1.1  augustss 
    196        1.57  augustss 	DPRINTFN(3,("usbd_open_pipe: iface=%p address=0x%x flags=0x%x\n",
    197        1.57  augustss 		    iface, address, flags));
    198        1.53  augustss 
    199         1.1  augustss 	for (i = 0; i < iface->idesc->bNumEndpoints; i++) {
    200         1.1  augustss 		ep = &iface->endpoints[i];
    201        1.49  augustss 		if (ep->edesc == NULL)
    202        1.49  augustss 			return (USBD_IOERROR);
    203         1.1  augustss 		if (ep->edesc->bEndpointAddress == address)
    204         1.1  augustss 			goto found;
    205         1.1  augustss 	}
    206         1.1  augustss 	return (USBD_BAD_ADDRESS);
    207         1.1  augustss  found:
    208        1.60  augustss 	if ((flags & USBD_EXCLUSIVE_USE) && ep->refcnt != 0)
    209         1.1  augustss 		return (USBD_IN_USE);
    210        1.60  augustss 	err = usbd_setup_pipe(iface->device, iface, ep, ival, &p);
    211        1.48  augustss 	if (err)
    212        1.48  augustss 		return (err);
    213         1.1  augustss 	LIST_INSERT_HEAD(&iface->pipes, p, next);
    214         1.1  augustss 	*pipe = p;
    215         1.1  augustss 	return (USBD_NORMAL_COMPLETION);
    216         1.1  augustss }
    217         1.1  augustss 
    218       1.102  augustss usbd_status
    219        1.74  augustss usbd_open_pipe_intr(usbd_interface_handle iface, u_int8_t address,
    220        1.74  augustss 		    u_int8_t flags, usbd_pipe_handle *pipe,
    221        1.74  augustss 		    usbd_private_handle priv, void *buffer, u_int32_t len,
    222        1.74  augustss 		    usbd_callback cb, int ival)
    223         1.1  augustss {
    224        1.48  augustss 	usbd_status err;
    225        1.48  augustss 	usbd_xfer_handle xfer;
    226         1.1  augustss 	usbd_pipe_handle ipipe;
    227         1.1  augustss 
    228        1.60  augustss 	DPRINTFN(3,("usbd_open_pipe_intr: address=0x%x flags=0x%x len=%d\n",
    229        1.60  augustss 		    address, flags, len));
    230        1.53  augustss 
    231       1.102  augustss 	err = usbd_open_pipe_ival(iface, address, USBD_EXCLUSIVE_USE,
    232        1.60  augustss 				  &ipipe, ival);
    233        1.48  augustss 	if (err)
    234        1.48  augustss 		return (err);
    235  1.119.12.1     itohy 	xfer = usbd_alloc_xfer(iface->device, ipipe);
    236        1.48  augustss 	if (xfer == NULL) {
    237        1.48  augustss 		err = USBD_NOMEM;
    238         1.1  augustss 		goto bad1;
    239        1.36  augustss 	}
    240        1.60  augustss 	usbd_setup_xfer(xfer, ipipe, priv, buffer, len, flags,
    241        1.60  augustss 	    USBD_NO_TIMEOUT, cb);
    242        1.48  augustss 	ipipe->intrxfer = xfer;
    243        1.25  augustss 	ipipe->repeat = 1;
    244        1.48  augustss 	err = usbd_transfer(xfer);
    245         1.1  augustss 	*pipe = ipipe;
    246  1.119.12.1     itohy 	if (err != USBD_IN_PROGRESS && err)
    247        1.36  augustss 		goto bad2;
    248         1.1  augustss 	return (USBD_NORMAL_COMPLETION);
    249         1.1  augustss 
    250        1.36  augustss  bad2:
    251        1.48  augustss 	ipipe->intrxfer = NULL;
    252        1.25  augustss 	ipipe->repeat = 0;
    253        1.50  augustss 	usbd_free_xfer(xfer);
    254        1.36  augustss  bad1:
    255         1.1  augustss 	usbd_close_pipe(ipipe);
    256        1.48  augustss 	return (err);
    257         1.9  augustss }
    258         1.9  augustss 
    259         1.1  augustss usbd_status
    260        1.74  augustss usbd_close_pipe(usbd_pipe_handle pipe)
    261         1.1  augustss {
    262        1.26  augustss #ifdef DIAGNOSTIC
    263        1.48  augustss 	if (pipe == NULL) {
    264        1.26  augustss 		printf("usbd_close_pipe: pipe==NULL\n");
    265        1.26  augustss 		return (USBD_NORMAL_COMPLETION);
    266        1.26  augustss 	}
    267        1.26  augustss #endif
    268        1.26  augustss 
    269         1.1  augustss 	if (--pipe->refcnt != 0)
    270         1.1  augustss 		return (USBD_NORMAL_COMPLETION);
    271       1.101     lukem 	if (! SIMPLEQ_EMPTY(&pipe->queue))
    272         1.1  augustss 		return (USBD_PENDING_REQUESTS);
    273         1.1  augustss 	LIST_REMOVE(pipe, next);
    274         1.1  augustss 	pipe->endpoint->refcnt--;
    275         1.1  augustss 	pipe->methods->close(pipe);
    276        1.48  augustss 	if (pipe->intrxfer != NULL)
    277        1.50  augustss 		usbd_free_xfer(pipe->intrxfer);
    278         1.1  augustss 	free(pipe, M_USB);
    279         1.1  augustss 	return (USBD_NORMAL_COMPLETION);
    280         1.1  augustss }
    281         1.1  augustss 
    282        1.31  augustss usbd_status
    283        1.74  augustss usbd_transfer(usbd_xfer_handle xfer)
    284         1.1  augustss {
    285        1.48  augustss 	usbd_pipe_handle pipe = xfer->pipe;
    286        1.48  augustss 	usbd_status err;
    287  1.119.12.5     itohy 	u_int size, flags;
    288        1.31  augustss 	int s;
    289        1.16  augustss 
    290  1.119.12.5     itohy 	DPRINTFN(5,("usbd_transfer: xfer=%p, flags=%x, pipe=%p, running=%d\n",
    291        1.48  augustss 		    xfer, xfer->flags, pipe, pipe->running));
    292        1.28  augustss #ifdef USB_DEBUG
    293        1.28  augustss 	if (usbdebug > 5)
    294        1.28  augustss 		usbd_dump_queue(pipe);
    295        1.28  augustss #endif
    296        1.48  augustss 	xfer->done = 0;
    297        1.31  augustss 
    298        1.71  augustss 	if (pipe->aborting)
    299        1.71  augustss 		return (USBD_CANCELLED);
    300        1.71  augustss 
    301        1.48  augustss 	size = xfer->length;
    302  1.119.12.5     itohy 	flags = xfer->flags;
    303        1.38  augustss 	/* If there is no buffer, allocate one. */
    304  1.119.12.1     itohy 	if (!(xfer->rqflags & URQ_MASK_DRV_REQUESTED_BUF) && size != 0) {
    305        1.37  augustss 		struct usbd_bus *bus = pipe->device->bus;
    306        1.37  augustss 
    307        1.37  augustss #ifdef DIAGNOSTIC
    308  1.119.12.1     itohy 		if (xfer->rqflags & URQ_AUTO_BUF)
    309        1.37  augustss 			printf("usbd_transfer: has old buffer!\n");
    310  1.119.12.1     itohy 		if (xfer->device->bus->intr_context)
    311  1.119.12.1     itohy 			panic("usbd_transfer: allocm not in process context");
    312        1.37  augustss #endif
    313  1.119.12.1     itohy 		err = bus->methods->allocm(bus, xfer,
    314  1.119.12.5     itohy 		    (flags & USBD_NO_COPY) ? xfer->buffer : NULL,
    315  1.119.12.1     itohy 		    size);
    316        1.48  augustss 		if (err)
    317        1.48  augustss 			return (err);
    318  1.119.12.1     itohy 		xfer->rqflags |= URQ_AUTO_BUF;
    319        1.38  augustss 	}
    320  1.119.12.2     itohy #ifdef DIAGNOSTIC
    321  1.119.12.2     itohy 	if ((xfer->rqflags & URQ_MASK_DRV_REQUESTED_BUF) != 0 &&
    322  1.119.12.2     itohy 	    size > xfer->bufsize) {
    323  1.119.12.2     itohy 		panic("usbd_transfer: buffer size overrun size=%u bufsize=%lu rqflags=%x",
    324  1.119.12.2     itohy 		    size, (unsigned long)xfer->bufsize, xfer->rqflags);
    325  1.119.12.2     itohy 	}
    326  1.119.12.2     itohy #endif
    327        1.37  augustss 
    328  1.119.12.2     itohy #ifdef DIAGNOSTIC
    329  1.119.12.5     itohy 	if ((flags & USBD_NO_COPY) == 0 && size != 0) {
    330  1.119.12.2     itohy 		if (xfer->rqflags & URQ_DEV_MAP_BUFFER)
    331  1.119.12.2     itohy 			printf("usbd_transfer: USBD_NO_COPY recommended with mapped buffer");
    332  1.119.12.2     itohy 		if (xfer->rqflags & URQ_DEV_MAP_MBUF)
    333  1.119.12.2     itohy 			panic("usbd_transfer: USBD_NO_COPY required with mapped mbuf");
    334  1.119.12.2     itohy 	}
    335  1.119.12.2     itohy #endif
    336        1.38  augustss 	/* Copy data if going out. */
    337  1.119.12.5     itohy 	if (!(flags & USBD_NO_COPY) && size != 0 &&
    338  1.119.12.1     itohy 	    !usbd_xfer_isread(xfer) && xfer->buffer != xfer->hcbuffer) {
    339  1.119.12.1     itohy 		DPRINTFN(5, ("usbd_transfer: copy %p (alloc) <- %p (buffer), %u bytes\n",
    340  1.119.12.1     itohy 			     xfer->hcbuffer, xfer->buffer, (unsigned)size));
    341  1.119.12.1     itohy 		memcpy(xfer->hcbuffer, xfer->buffer, size);
    342  1.119.12.1     itohy 	}
    343        1.37  augustss 
    344        1.48  augustss 	err = pipe->methods->transfer(xfer);
    345  1.119.12.5     itohy 	/*
    346  1.119.12.5     itohy 	 * Note xfer may not be valid after non-error completion
    347  1.119.12.5     itohy 	 * of the transfer method unless synchronous.
    348  1.119.12.5     itohy 	 */
    349        1.37  augustss 
    350        1.51  augustss 	if (err != USBD_IN_PROGRESS && err) {
    351        1.37  augustss 		/* The transfer has not been queued, so free buffer. */
    352  1.119.12.1     itohy 		if (xfer->rqflags & URQ_AUTO_BUF) {
    353        1.37  augustss 			struct usbd_bus *bus = pipe->device->bus;
    354        1.37  augustss 
    355  1.119.12.1     itohy #ifdef DIAGNOSTIC
    356  1.119.12.1     itohy 			if (bus->intr_context)
    357  1.119.12.1     itohy 				panic("usbd_transfer: freem not in process context");
    358  1.119.12.1     itohy #endif
    359  1.119.12.1     itohy 			bus->methods->freem(bus, xfer, U_WAITOK);
    360  1.119.12.1     itohy 			xfer->rqflags &= ~URQ_AUTO_BUF;
    361        1.37  augustss 		}
    362        1.37  augustss 	}
    363        1.37  augustss 
    364  1.119.12.5     itohy 	if (!(flags & USBD_SYNCHRONOUS))
    365  1.119.12.1     itohy 		return (xfer->done ? 0 : USBD_IN_PROGRESS);
    366        1.31  augustss 
    367        1.31  augustss 	/* Sync transfer, wait for completion. */
    368        1.31  augustss 	s = splusb();
    369  1.119.12.1     itohy 	while (!xfer->done) {
    370        1.37  augustss 		if (pipe->device->bus->use_polling)
    371       1.103    provos 			panic("usbd_transfer: not done");
    372        1.80  augustss 		tsleep(xfer, PRIBIO, "usbsyn", 0);
    373        1.31  augustss 	}
    374        1.31  augustss 	splx(s);
    375        1.48  augustss 	return (xfer->status);
    376        1.31  augustss }
    377        1.31  augustss 
    378        1.31  augustss /* Like usbd_transfer(), but waits for completion. */
    379        1.31  augustss usbd_status
    380        1.74  augustss usbd_sync_transfer(usbd_xfer_handle xfer)
    381        1.31  augustss {
    382        1.48  augustss 	xfer->flags |= USBD_SYNCHRONOUS;
    383        1.48  augustss 	return (usbd_transfer(xfer));
    384        1.16  augustss }
    385        1.16  augustss 
    386        1.36  augustss void *
    387        1.74  augustss usbd_alloc_buffer(usbd_xfer_handle xfer, u_int32_t size)
    388        1.36  augustss {
    389        1.48  augustss 	struct usbd_bus *bus = xfer->device->bus;
    390        1.48  augustss 	usbd_status err;
    391        1.37  augustss 
    392  1.119.12.1     itohy 	USB_KASSERT2((xfer->rqflags & URQ_MASK_BUF) == 0,
    393  1.119.12.1     itohy 	    ("usbd_alloc_buffer: xfer already has a buffer"));
    394  1.119.12.1     itohy 
    395        1.92  augustss #ifdef DIAGNOSTIC
    396  1.119.12.1     itohy 	if (xfer->device->bus->intr_context)
    397  1.119.12.1     itohy 		panic("usbd_alloc_buffer: allocm not in process context");
    398        1.92  augustss #endif
    399  1.119.12.1     itohy 	err = bus->methods->allocm(bus, xfer, NULL, size);
    400        1.48  augustss 	if (err)
    401        1.92  augustss 		return (NULL);
    402  1.119.12.2     itohy 	xfer->bufsize = size;
    403  1.119.12.1     itohy 	xfer->rqflags |= URQ_DEV_BUF;
    404  1.119.12.1     itohy 	return xfer->hcbuffer;
    405        1.36  augustss }
    406        1.36  augustss 
    407  1.119.12.1     itohy Static void
    408  1.119.12.1     itohy usbd_free_buffer_flag(usbd_xfer_handle xfer, enum usbd_waitflg waitflg)
    409        1.36  augustss {
    410  1.119.12.1     itohy 	struct usbd_bus *bus;
    411  1.119.12.1     itohy 
    412  1.119.12.1     itohy 	USB_KASSERT2((xfer->rqflags & URQ_MASK_BUF) == URQ_DEV_BUF,
    413  1.119.12.1     itohy 	    ("usbd_free_buffer_flag: no/auto buffer"));
    414  1.119.12.1     itohy 
    415  1.119.12.1     itohy 	xfer->rqflags &= ~(URQ_DEV_BUF | URQ_AUTO_BUF);
    416  1.119.12.2     itohy 	xfer->bufsize = 0;
    417  1.119.12.1     itohy 	bus = xfer->device->bus;
    418        1.37  augustss #ifdef DIAGNOSTIC
    419  1.119.12.1     itohy 	if (waitflg == U_WAITOK && bus->intr_context)
    420  1.119.12.1     itohy 		panic("usbd_free_buffer: freem not in process context");
    421        1.37  augustss #endif
    422  1.119.12.1     itohy 	bus->methods->freem(bus, xfer, waitflg);
    423  1.119.12.1     itohy 
    424  1.119.12.1     itohy 	xfer->hcbuffer = NULL;
    425  1.119.12.1     itohy }
    426  1.119.12.1     itohy 
    427  1.119.12.1     itohy void
    428  1.119.12.1     itohy usbd_free_buffer(usbd_xfer_handle xfer)
    429  1.119.12.1     itohy {
    430  1.119.12.1     itohy 	usbd_free_buffer_flag(xfer, U_WAITOK);
    431        1.36  augustss }
    432        1.36  augustss 
    433        1.38  augustss void *
    434        1.74  augustss usbd_get_buffer(usbd_xfer_handle xfer)
    435        1.38  augustss {
    436  1.119.12.1     itohy 	if (!(xfer->rqflags & URQ_DEV_BUF))
    437  1.119.12.1     itohy 		return (NULL);
    438  1.119.12.1     itohy 	return (xfer->hcbuffer);
    439        1.38  augustss }
    440        1.38  augustss 
    441  1.119.12.1     itohy /*
    442  1.119.12.1     itohy  * map buffer handlings
    443  1.119.12.1     itohy  */
    444  1.119.12.1     itohy 
    445  1.119.12.1     itohy /* Allocate mapping resources to prepare buffer mapping. */
    446  1.119.12.1     itohy usbd_status
    447  1.119.12.1     itohy usbd_map_alloc(usbd_xfer_handle xfer)
    448  1.119.12.1     itohy {
    449  1.119.12.1     itohy 	struct usbd_bus *bus = xfer->device->bus;
    450  1.119.12.1     itohy 	usbd_status err;
    451  1.119.12.1     itohy 
    452  1.119.12.1     itohy #ifdef DIAGNOSTIC
    453  1.119.12.1     itohy 	if (bus->intr_context)
    454  1.119.12.1     itohy 		panic("usbd_map_alloc: map_alloc not in process context");
    455  1.119.12.1     itohy #endif
    456  1.119.12.1     itohy 	USB_KASSERT2((xfer->rqflags & URQ_DEV_MAP_PREPARED) == 0,
    457  1.119.12.1     itohy 	    ("usbd_map_alloc: map already allocated"));
    458  1.119.12.1     itohy 
    459  1.119.12.1     itohy 	err = bus->methods->map_alloc(xfer);
    460  1.119.12.1     itohy 	if (err != USBD_NORMAL_COMPLETION)
    461  1.119.12.1     itohy 		return (err);
    462  1.119.12.1     itohy 
    463  1.119.12.1     itohy 	xfer->rqflags |= URQ_DEV_MAP_PREPARED;
    464  1.119.12.1     itohy 
    465  1.119.12.1     itohy 	return (USBD_NORMAL_COMPLETION);
    466  1.119.12.1     itohy }
    467  1.119.12.1     itohy 
    468  1.119.12.1     itohy /* Free mapping resources. */
    469  1.119.12.1     itohy void
    470  1.119.12.1     itohy usbd_map_free(usbd_xfer_handle xfer)
    471  1.119.12.1     itohy {
    472  1.119.12.1     itohy 	struct usbd_bus *bus = xfer->device->bus;
    473  1.119.12.1     itohy 
    474  1.119.12.1     itohy #ifdef DIAGNOSTIC
    475  1.119.12.1     itohy 	if (bus->intr_context)
    476  1.119.12.1     itohy 		panic("usbd_map_free: map_free not in process context");
    477  1.119.12.1     itohy #endif
    478  1.119.12.1     itohy 	USB_KASSERT2((xfer->rqflags & URQ_DEV_MAP_PREPARED),
    479  1.119.12.1     itohy 	    ("usbd_map_free: map not allocated"));
    480  1.119.12.1     itohy 
    481  1.119.12.1     itohy 	bus->methods->map_free(xfer);
    482  1.119.12.1     itohy 
    483  1.119.12.1     itohy 	xfer->rqflags &= ~URQ_DEV_MAP_PREPARED;
    484  1.119.12.1     itohy }
    485  1.119.12.1     itohy 
    486  1.119.12.1     itohy /* Map plain buffer. */
    487  1.119.12.1     itohy void
    488  1.119.12.1     itohy usbd_map_buffer(usbd_xfer_handle xfer, void *buf, u_int32_t size)
    489  1.119.12.1     itohy {
    490  1.119.12.1     itohy 	struct usbd_bus *bus = xfer->device->bus;
    491  1.119.12.1     itohy 
    492  1.119.12.1     itohy #ifdef DIAGNOSTIC
    493  1.119.12.1     itohy 	if ((xfer->rqflags & URQ_MASK_BUF))
    494  1.119.12.1     itohy 		panic("usbd_map_buffer: already has buffer (rqflags=%x)",
    495  1.119.12.1     itohy 		    xfer->rqflags);
    496  1.119.12.1     itohy 	if ((xfer->rqflags & URQ_DEV_MAP_PREPARED) == 0 && bus->intr_context)
    497  1.119.12.1     itohy 		panic("usbd_map_buffer: mapm (without map_alloc) not in process context");
    498  1.119.12.1     itohy #endif
    499  1.119.12.1     itohy 
    500  1.119.12.1     itohy 	bus->methods->mapm(xfer, buf, size);
    501  1.119.12.1     itohy 
    502  1.119.12.2     itohy 	xfer->bufsize = size;
    503  1.119.12.1     itohy 	xfer->rqflags |= URQ_DEV_MAP_BUFFER;
    504  1.119.12.1     itohy }
    505  1.119.12.1     itohy 
    506  1.119.12.1     itohy /* Map mbuf(9) chain. */
    507  1.119.12.2     itohy usbd_status
    508  1.119.12.1     itohy usbd_map_buffer_mbuf(usbd_xfer_handle xfer, struct mbuf *chain)
    509  1.119.12.1     itohy {
    510  1.119.12.1     itohy 	struct usbd_bus *bus = xfer->device->bus;
    511  1.119.12.2     itohy 	usbd_status err;
    512  1.119.12.1     itohy 
    513  1.119.12.1     itohy #ifdef DIAGNOSTIC
    514  1.119.12.1     itohy 	if ((xfer->rqflags & URQ_MASK_BUF))
    515  1.119.12.1     itohy 		panic("usbd_map_buffer_mbuf: already has buffer (rqflags=%x)",
    516  1.119.12.1     itohy 		    xfer->rqflags);
    517  1.119.12.1     itohy 	if ((xfer->rqflags & URQ_DEV_MAP_PREPARED) == 0 && bus->intr_context)
    518  1.119.12.1     itohy 		panic("usbd_map_buffer_mbuf: mapm_mbuf (without map_alloc) not in process context");
    519  1.119.12.1     itohy #endif
    520  1.119.12.1     itohy 
    521  1.119.12.2     itohy 	err = bus->methods->mapm_mbuf(xfer, chain);
    522  1.119.12.2     itohy 	if (err != USBD_NORMAL_COMPLETION)
    523  1.119.12.2     itohy 		return (err);
    524  1.119.12.1     itohy 
    525  1.119.12.2     itohy 	xfer->bufsize = chain->m_pkthdr.len;
    526  1.119.12.6     itohy 	xfer->mbuf_chain = chain;
    527  1.119.12.1     itohy 	xfer->rqflags |= URQ_DEV_MAP_MBUF;
    528  1.119.12.2     itohy 
    529  1.119.12.2     itohy 	return (err);
    530  1.119.12.1     itohy }
    531  1.119.12.1     itohy 
    532  1.119.12.1     itohy /* Unmap plain buffer or mbuf(9) chain. */
    533  1.119.12.1     itohy void
    534  1.119.12.1     itohy usbd_unmap_buffer(usbd_xfer_handle xfer)
    535  1.119.12.1     itohy {
    536  1.119.12.1     itohy 	struct usbd_bus *bus = xfer->device->bus;
    537  1.119.12.1     itohy 
    538  1.119.12.1     itohy 	USB_KASSERT2((xfer->rqflags & (URQ_DEV_MAP_BUFFER | URQ_DEV_MAP_MBUF)),
    539  1.119.12.1     itohy 	    ("usbd_unmap_buffer: no map"));
    540  1.119.12.1     itohy #ifdef DIAGNOSTIC
    541  1.119.12.1     itohy 	if ((xfer->rqflags & URQ_DEV_MAP_PREPARED) == 0 && bus->intr_context)
    542  1.119.12.1     itohy 		panic("usbd_unmap_buffer: unmapm (without map_alloc) not in process context");
    543  1.119.12.1     itohy #endif
    544  1.119.12.1     itohy 
    545  1.119.12.1     itohy 	bus->methods->unmapm(xfer);
    546  1.119.12.1     itohy 
    547  1.119.12.1     itohy 	xfer->rqflags &= ~(URQ_DEV_MAP_BUFFER | URQ_DEV_MAP_MBUF);
    548  1.119.12.2     itohy 	xfer->bufsize = 0;
    549  1.119.12.6     itohy 	xfer->mbuf_chain = NULL;
    550  1.119.12.1     itohy }
    551  1.119.12.1     itohy 
    552  1.119.12.1     itohy Static usbd_xfer_handle
    553  1.119.12.1     itohy usbd_alloc_xfer_flag(usbd_device_handle dev, usbd_pipe_handle pipe,
    554  1.119.12.1     itohy 	enum usbd_waitflg waitflg)
    555         1.1  augustss {
    556        1.48  augustss 	usbd_xfer_handle xfer;
    557         1.1  augustss 
    558  1.119.12.1     itohy #ifdef DIAGNOSTIC
    559  1.119.12.1     itohy 	if (waitflg == U_WAITOK && dev->bus->intr_context)
    560  1.119.12.1     itohy 		panic("usbd_alloc_xfer: allocx not in process context");
    561  1.119.12.1     itohy 	if (pipe == NULL)
    562  1.119.12.1     itohy 		panic("usbd_alloc_xfer: pipe == NULL");
    563  1.119.12.1     itohy #endif
    564  1.119.12.1     itohy 	xfer = dev->bus->methods->allocx(dev->bus, pipe, waitflg);
    565        1.48  augustss 	if (xfer == NULL)
    566        1.58  augustss 		return (NULL);
    567  1.119.12.1     itohy 	xfer->pipe = pipe;
    568        1.48  augustss 	xfer->device = dev;
    569        1.68  augustss 	usb_callout_init(xfer->timeout_handle);
    570  1.119.12.1     itohy 	DPRINTFN(5,("usbd_alloc_xfer_flag() = %p\n", xfer));
    571        1.48  augustss 	return (xfer);
    572         1.1  augustss }
    573         1.1  augustss 
    574  1.119.12.1     itohy usbd_xfer_handle
    575  1.119.12.1     itohy usbd_alloc_xfer(usbd_device_handle dev, usbd_pipe_handle pipe)
    576  1.119.12.1     itohy {
    577  1.119.12.1     itohy 	return (usbd_alloc_xfer_flag(dev, pipe, U_WAITOK));
    578  1.119.12.1     itohy }
    579  1.119.12.1     itohy 
    580  1.119.12.1     itohy usbd_xfer_handle
    581  1.119.12.1     itohy usbd_alloc_default_xfer(usbd_device_handle dev)
    582  1.119.12.1     itohy {
    583  1.119.12.1     itohy 	return (usbd_alloc_xfer_flag(dev, dev->default_pipe, U_WAITOK));
    584  1.119.12.1     itohy }
    585  1.119.12.1     itohy 
    586  1.119.12.1     itohy Static usbd_status
    587  1.119.12.1     itohy usbd_free_xfer_flag(usbd_xfer_handle xfer, enum usbd_waitflg waitflg)
    588         1.1  augustss {
    589  1.119.12.1     itohy 	DPRINTFN(5,("usbd_free_xfer_flag: %p %d\n", xfer, waitflg));
    590  1.119.12.3     itohy 	usb_rem_task(xfer->device, &xfer->task);
    591  1.119.12.1     itohy 	if (xfer->rqflags & (URQ_DEV_BUF | URQ_AUTO_BUF))
    592  1.119.12.1     itohy 		usbd_free_buffer_flag(xfer, waitflg);
    593  1.119.12.1     itohy 	if (xfer->rqflags & (URQ_DEV_MAP_BUFFER | URQ_DEV_MAP_MBUF))
    594  1.119.12.1     itohy 		usbd_unmap_buffer(xfer);
    595  1.119.12.1     itohy 	if (waitflg == U_WAITOK && (xfer->rqflags & URQ_DEV_MAP_PREPARED))
    596  1.119.12.1     itohy 		usbd_map_free(xfer);
    597        1.66   thorpej #if defined(__NetBSD__) && defined(DIAGNOSTIC)
    598        1.68  augustss 	if (callout_pending(&xfer->timeout_handle)) {
    599        1.68  augustss 		callout_stop(&xfer->timeout_handle);
    600  1.119.12.1     itohy 		printf("usbd_free_xfer_flag: timout_handle pending");
    601        1.68  augustss 	}
    602        1.66   thorpej #endif
    603        1.58  augustss 	xfer->device->bus->methods->freex(xfer->device->bus, xfer);
    604         1.1  augustss 	return (USBD_NORMAL_COMPLETION);
    605         1.1  augustss }
    606         1.1  augustss 
    607  1.119.12.1     itohy usbd_status
    608  1.119.12.1     itohy usbd_free_xfer(usbd_xfer_handle xfer)
    609  1.119.12.1     itohy {
    610  1.119.12.1     itohy 
    611  1.119.12.1     itohy 	return (usbd_free_xfer_flag(xfer, U_WAITOK));
    612  1.119.12.1     itohy }
    613  1.119.12.1     itohy 
    614        1.36  augustss void
    615        1.74  augustss usbd_setup_xfer(usbd_xfer_handle xfer, usbd_pipe_handle pipe,
    616        1.74  augustss 		usbd_private_handle priv, void *buffer, u_int32_t length,
    617        1.74  augustss 		u_int16_t flags, u_int32_t timeout,
    618        1.74  augustss 		usbd_callback callback)
    619         1.1  augustss {
    620  1.119.12.1     itohy 	USB_KASSERT(xfer->pipe == pipe);	/* XXX pipe arg should go */
    621        1.48  augustss 	xfer->priv = priv;
    622        1.48  augustss 	xfer->buffer = buffer;
    623        1.48  augustss 	xfer->length = length;
    624        1.48  augustss 	xfer->actlen = 0;
    625        1.48  augustss 	xfer->flags = flags;
    626        1.48  augustss 	xfer->timeout = timeout;
    627        1.48  augustss 	xfer->status = USBD_NOT_STARTED;
    628        1.48  augustss 	xfer->callback = callback;
    629        1.48  augustss 	xfer->rqflags &= ~URQ_REQUEST;
    630        1.48  augustss 	xfer->nframes = 0;
    631         1.1  augustss }
    632         1.1  augustss 
    633        1.36  augustss void
    634        1.74  augustss usbd_setup_default_xfer(usbd_xfer_handle xfer, usbd_device_handle dev,
    635        1.74  augustss 			usbd_private_handle priv, u_int32_t timeout,
    636        1.74  augustss 			usb_device_request_t *req, void *buffer,
    637        1.74  augustss 			u_int32_t length, u_int16_t flags,
    638        1.74  augustss 			usbd_callback callback)
    639         1.1  augustss {
    640  1.119.12.1     itohy 	USB_KASSERT(xfer->pipe == dev->default_pipe);	/* XXX */
    641        1.48  augustss 	xfer->priv = priv;
    642        1.48  augustss 	xfer->buffer = buffer;
    643        1.48  augustss 	xfer->length = length;
    644        1.48  augustss 	xfer->actlen = 0;
    645        1.48  augustss 	xfer->flags = flags;
    646        1.48  augustss 	xfer->timeout = timeout;
    647        1.48  augustss 	xfer->status = USBD_NOT_STARTED;
    648        1.48  augustss 	xfer->callback = callback;
    649        1.48  augustss 	xfer->request = *req;
    650        1.48  augustss 	xfer->rqflags |= URQ_REQUEST;
    651        1.48  augustss 	xfer->nframes = 0;
    652        1.36  augustss }
    653        1.36  augustss 
    654        1.36  augustss void
    655        1.74  augustss usbd_setup_isoc_xfer(usbd_xfer_handle xfer, usbd_pipe_handle pipe,
    656        1.74  augustss 		     usbd_private_handle priv, u_int16_t *frlengths,
    657        1.74  augustss 		     u_int32_t nframes, u_int16_t flags, usbd_callback callback)
    658        1.36  augustss {
    659  1.119.12.1     itohy 	int i;
    660  1.119.12.1     itohy 
    661  1.119.12.1     itohy 	USB_KASSERT(xfer->pipe == pipe);	/* XXX pipe arg should go */
    662        1.48  augustss 	xfer->priv = priv;
    663        1.48  augustss 	xfer->buffer = 0;
    664        1.48  augustss 	xfer->length = 0;
    665  1.119.12.1     itohy 	for (i = 0; i < nframes; i++)
    666  1.119.12.1     itohy 		xfer->length += frlengths[i];
    667        1.48  augustss 	xfer->actlen = 0;
    668        1.48  augustss 	xfer->flags = flags;
    669        1.48  augustss 	xfer->timeout = USBD_NO_TIMEOUT;
    670        1.48  augustss 	xfer->status = USBD_NOT_STARTED;
    671        1.48  augustss 	xfer->callback = callback;
    672        1.48  augustss 	xfer->rqflags &= ~URQ_REQUEST;
    673        1.48  augustss 	xfer->frlengths = frlengths;
    674        1.48  augustss 	xfer->nframes = nframes;
    675         1.1  augustss }
    676         1.1  augustss 
    677        1.31  augustss void
    678        1.74  augustss usbd_get_xfer_status(usbd_xfer_handle xfer, usbd_private_handle *priv,
    679        1.74  augustss 		     void **buffer, u_int32_t *count, usbd_status *status)
    680         1.1  augustss {
    681        1.48  augustss 	if (priv != NULL)
    682        1.48  augustss 		*priv = xfer->priv;
    683        1.48  augustss 	if (buffer != NULL)
    684        1.48  augustss 		*buffer = xfer->buffer;
    685        1.48  augustss 	if (count != NULL)
    686        1.48  augustss 		*count = xfer->actlen;
    687        1.48  augustss 	if (status != NULL)
    688        1.48  augustss 		*status = xfer->status;
    689         1.1  augustss }
    690         1.1  augustss 
    691         1.1  augustss usb_config_descriptor_t *
    692        1.74  augustss usbd_get_config_descriptor(usbd_device_handle dev)
    693         1.1  augustss {
    694        1.53  augustss #ifdef DIAGNOSTIC
    695        1.53  augustss 	if (dev == NULL) {
    696        1.53  augustss 		printf("usbd_get_config_descriptor: dev == NULL\n");
    697        1.53  augustss 		return (NULL);
    698        1.53  augustss 	}
    699        1.53  augustss #endif
    700         1.1  augustss 	return (dev->cdesc);
    701         1.1  augustss }
    702         1.1  augustss 
    703  1.119.12.1     itohy int
    704  1.119.12.1     itohy usbd_get_speed(usbd_device_handle dev)
    705  1.119.12.1     itohy {
    706  1.119.12.1     itohy 	return (dev->speed);
    707  1.119.12.1     itohy }
    708  1.119.12.1     itohy 
    709         1.1  augustss usb_interface_descriptor_t *
    710        1.74  augustss usbd_get_interface_descriptor(usbd_interface_handle iface)
    711         1.1  augustss {
    712        1.53  augustss #ifdef DIAGNOSTIC
    713        1.53  augustss 	if (iface == NULL) {
    714        1.53  augustss 		printf("usbd_get_interface_descriptor: dev == NULL\n");
    715        1.53  augustss 		return (NULL);
    716        1.53  augustss 	}
    717        1.53  augustss #endif
    718         1.1  augustss 	return (iface->idesc);
    719         1.1  augustss }
    720         1.1  augustss 
    721         1.1  augustss usb_device_descriptor_t *
    722        1.74  augustss usbd_get_device_descriptor(usbd_device_handle dev)
    723         1.1  augustss {
    724         1.1  augustss 	return (&dev->ddesc);
    725         1.1  augustss }
    726         1.1  augustss 
    727         1.1  augustss usb_endpoint_descriptor_t *
    728        1.74  augustss usbd_interface2endpoint_descriptor(usbd_interface_handle iface, u_int8_t index)
    729         1.1  augustss {
    730         1.1  augustss 	if (index >= iface->idesc->bNumEndpoints)
    731        1.12  augustss 		return (0);
    732         1.1  augustss 	return (iface->endpoints[index].edesc);
    733         1.1  augustss }
    734         1.1  augustss 
    735       1.102  augustss usbd_status
    736        1.74  augustss usbd_abort_pipe(usbd_pipe_handle pipe)
    737         1.1  augustss {
    738        1.48  augustss 	usbd_status err;
    739        1.24  augustss 	int s;
    740         1.1  augustss 
    741        1.26  augustss #ifdef DIAGNOSTIC
    742        1.48  augustss 	if (pipe == NULL) {
    743  1.119.12.3     itohy 		printf("usbd_abort_pipe: pipe==NULL\n");
    744        1.26  augustss 		return (USBD_NORMAL_COMPLETION);
    745        1.26  augustss 	}
    746        1.26  augustss #endif
    747         1.1  augustss 	s = splusb();
    748        1.48  augustss 	err = usbd_ar_pipe(pipe);
    749         1.1  augustss 	splx(s);
    750        1.48  augustss 	return (err);
    751         1.1  augustss }
    752       1.102  augustss 
    753       1.102  augustss usbd_status
    754  1.119.12.1     itohy usbd_abort_default_pipe(usbd_device_handle dev)
    755  1.119.12.1     itohy {
    756  1.119.12.1     itohy 	return (usbd_abort_pipe(dev->default_pipe));
    757  1.119.12.1     itohy }
    758  1.119.12.1     itohy 
    759  1.119.12.1     itohy usbd_status
    760        1.74  augustss usbd_clear_endpoint_stall(usbd_pipe_handle pipe)
    761         1.1  augustss {
    762         1.1  augustss 	usbd_device_handle dev = pipe->device;
    763         1.1  augustss 	usb_device_request_t req;
    764        1.48  augustss 	usbd_status err;
    765         1.1  augustss 
    766        1.22  augustss 	DPRINTFN(8, ("usbd_clear_endpoint_stall\n"));
    767        1.33  augustss 
    768       1.102  augustss 	/*
    769        1.87  augustss 	 * Clearing en endpoint stall resets the endpoint toggle, so
    770        1.33  augustss 	 * do the same to the HC toggle.
    771        1.33  augustss 	 */
    772        1.30  augustss 	pipe->methods->cleartoggle(pipe);
    773        1.33  augustss 
    774         1.1  augustss 	req.bmRequestType = UT_WRITE_ENDPOINT;
    775         1.1  augustss 	req.bRequest = UR_CLEAR_FEATURE;
    776        1.15  augustss 	USETW(req.wValue, UF_ENDPOINT_HALT);
    777         1.7  augustss 	USETW(req.wIndex, pipe->endpoint->edesc->bEndpointAddress);
    778         1.1  augustss 	USETW(req.wLength, 0);
    779        1.48  augustss 	err = usbd_do_request(dev, &req, 0);
    780         1.1  augustss #if 0
    781         1.1  augustss XXX should we do this?
    782        1.51  augustss 	if (!err) {
    783         1.1  augustss 		pipe->state = USBD_PIPE_ACTIVE;
    784         1.1  augustss 		/* XXX activate pipe */
    785         1.1  augustss 	}
    786         1.1  augustss #endif
    787        1.48  augustss 	return (err);
    788         1.1  augustss }
    789         1.1  augustss 
    790       1.102  augustss usbd_status
    791        1.74  augustss usbd_clear_endpoint_stall_async(usbd_pipe_handle pipe)
    792         1.7  augustss {
    793         1.7  augustss 	usbd_device_handle dev = pipe->device;
    794         1.7  augustss 	usb_device_request_t req;
    795        1.48  augustss 	usbd_status err;
    796         1.7  augustss 
    797        1.30  augustss 	pipe->methods->cleartoggle(pipe);
    798        1.33  augustss 
    799         1.7  augustss 	req.bmRequestType = UT_WRITE_ENDPOINT;
    800         1.7  augustss 	req.bRequest = UR_CLEAR_FEATURE;
    801        1.15  augustss 	USETW(req.wValue, UF_ENDPOINT_HALT);
    802         1.7  augustss 	USETW(req.wIndex, pipe->endpoint->edesc->bEndpointAddress);
    803         1.7  augustss 	USETW(req.wLength, 0);
    804        1.48  augustss 	err = usbd_do_request_async(dev, &req, 0);
    805        1.48  augustss 	return (err);
    806         1.7  augustss }
    807         1.7  augustss 
    808        1.61  augustss void
    809        1.74  augustss usbd_clear_endpoint_toggle(usbd_pipe_handle pipe)
    810        1.61  augustss {
    811        1.61  augustss 	pipe->methods->cleartoggle(pipe);
    812        1.61  augustss }
    813        1.61  augustss 
    814       1.102  augustss usbd_status
    815        1.74  augustss usbd_endpoint_count(usbd_interface_handle iface, u_int8_t *count)
    816         1.1  augustss {
    817        1.73  augustss #ifdef DIAGNOSTIC
    818        1.73  augustss 	if (iface == NULL || iface->idesc == NULL) {
    819        1.73  augustss 		printf("usbd_endpoint_count: NULL pointer\n");
    820        1.73  augustss 		return (USBD_INVAL);
    821        1.73  augustss 	}
    822        1.73  augustss #endif
    823         1.1  augustss 	*count = iface->idesc->bNumEndpoints;
    824         1.1  augustss 	return (USBD_NORMAL_COMPLETION);
    825         1.1  augustss }
    826         1.1  augustss 
    827       1.102  augustss usbd_status
    828        1.74  augustss usbd_interface_count(usbd_device_handle dev, u_int8_t *count)
    829         1.1  augustss {
    830        1.48  augustss 	if (dev->cdesc == NULL)
    831         1.1  augustss 		return (USBD_NOT_CONFIGURED);
    832         1.1  augustss 	*count = dev->cdesc->bNumInterface;
    833         1.1  augustss 	return (USBD_NORMAL_COMPLETION);
    834         1.1  augustss }
    835         1.1  augustss 
    836        1.85  augustss void
    837        1.74  augustss usbd_interface2device_handle(usbd_interface_handle iface,
    838        1.74  augustss 			     usbd_device_handle *dev)
    839         1.1  augustss {
    840         1.1  augustss 	*dev = iface->device;
    841         1.1  augustss }
    842         1.1  augustss 
    843       1.102  augustss usbd_status
    844        1.74  augustss usbd_device2interface_handle(usbd_device_handle dev,
    845        1.74  augustss 			     u_int8_t ifaceno, usbd_interface_handle *iface)
    846         1.1  augustss {
    847        1.48  augustss 	if (dev->cdesc == NULL)
    848         1.1  augustss 		return (USBD_NOT_CONFIGURED);
    849         1.1  augustss 	if (ifaceno >= dev->cdesc->bNumInterface)
    850         1.1  augustss 		return (USBD_INVAL);
    851         1.1  augustss 	*iface = &dev->ifaces[ifaceno];
    852         1.1  augustss 	return (USBD_NORMAL_COMPLETION);
    853         1.1  augustss }
    854         1.1  augustss 
    855        1.36  augustss usbd_device_handle
    856        1.74  augustss usbd_pipe2device_handle(usbd_pipe_handle pipe)
    857        1.36  augustss {
    858        1.36  augustss 	return (pipe->device);
    859        1.36  augustss }
    860        1.36  augustss 
    861        1.13  augustss /* XXXX use altno */
    862         1.3  augustss usbd_status
    863        1.74  augustss usbd_set_interface(usbd_interface_handle iface, int altidx)
    864         1.3  augustss {
    865         1.3  augustss 	usb_device_request_t req;
    866        1.48  augustss 	usbd_status err;
    867        1.73  augustss 	void *endpoints;
    868        1.13  augustss 
    869        1.13  augustss 	if (LIST_FIRST(&iface->pipes) != 0)
    870        1.13  augustss 		return (USBD_IN_USE);
    871        1.13  augustss 
    872        1.76  augustss 	endpoints = iface->endpoints;
    873        1.48  augustss 	err = usbd_fill_iface_data(iface->device, iface->index, altidx);
    874        1.48  augustss 	if (err)
    875        1.48  augustss 		return (err);
    876        1.73  augustss 
    877        1.76  augustss 	/* new setting works, we can free old endpoints */
    878        1.73  augustss 	if (endpoints != NULL)
    879        1.73  augustss 		free(endpoints, M_USB);
    880        1.73  augustss 
    881        1.73  augustss #ifdef DIAGNOSTIC
    882        1.73  augustss 	if (iface->idesc == NULL) {
    883        1.73  augustss 		printf("usbd_set_interface: NULL pointer\n");
    884        1.73  augustss 		return (USBD_INVAL);
    885        1.73  augustss 	}
    886        1.73  augustss #endif
    887         1.3  augustss 
    888         1.3  augustss 	req.bmRequestType = UT_WRITE_INTERFACE;
    889         1.3  augustss 	req.bRequest = UR_SET_INTERFACE;
    890        1.13  augustss 	USETW(req.wValue, iface->idesc->bAlternateSetting);
    891        1.16  augustss 	USETW(req.wIndex, iface->idesc->bInterfaceNumber);
    892         1.3  augustss 	USETW(req.wLength, 0);
    893        1.48  augustss 	return (usbd_do_request(iface->device, &req, 0));
    894        1.12  augustss }
    895        1.12  augustss 
    896        1.12  augustss int
    897        1.74  augustss usbd_get_no_alts(usb_config_descriptor_t *cdesc, int ifaceno)
    898        1.12  augustss {
    899        1.13  augustss 	char *p = (char *)cdesc;
    900        1.13  augustss 	char *end = p + UGETW(cdesc->wTotalLength);
    901        1.12  augustss 	usb_interface_descriptor_t *d;
    902        1.12  augustss 	int n;
    903        1.12  augustss 
    904        1.12  augustss 	for (n = 0; p < end; p += d->bLength) {
    905        1.12  augustss 		d = (usb_interface_descriptor_t *)p;
    906       1.102  augustss 		if (p + d->bLength <= end &&
    907        1.12  augustss 		    d->bDescriptorType == UDESC_INTERFACE &&
    908        1.13  augustss 		    d->bInterfaceNumber == ifaceno)
    909        1.12  augustss 			n++;
    910        1.12  augustss 	}
    911        1.12  augustss 	return (n);
    912        1.13  augustss }
    913        1.13  augustss 
    914        1.13  augustss int
    915        1.74  augustss usbd_get_interface_altindex(usbd_interface_handle iface)
    916        1.13  augustss {
    917        1.13  augustss 	return (iface->altindex);
    918        1.12  augustss }
    919        1.12  augustss 
    920        1.12  augustss usbd_status
    921        1.74  augustss usbd_get_interface(usbd_interface_handle iface, u_int8_t *aiface)
    922        1.12  augustss {
    923        1.12  augustss 	usb_device_request_t req;
    924        1.12  augustss 
    925        1.12  augustss 	req.bmRequestType = UT_READ_INTERFACE;
    926        1.12  augustss 	req.bRequest = UR_GET_INTERFACE;
    927        1.12  augustss 	USETW(req.wValue, 0);
    928        1.16  augustss 	USETW(req.wIndex, iface->idesc->bInterfaceNumber);
    929        1.12  augustss 	USETW(req.wLength, 1);
    930        1.48  augustss 	return (usbd_do_request(iface->device, &req, aiface));
    931         1.3  augustss }
    932         1.1  augustss 
    933         1.1  augustss /*** Internal routines ***/
    934         1.1  augustss 
    935         1.1  augustss /* Dequeue all pipe operations, called at splusb(). */
    936        1.69  augustss Static usbd_status
    937        1.74  augustss usbd_ar_pipe(usbd_pipe_handle pipe)
    938         1.1  augustss {
    939        1.48  augustss 	usbd_xfer_handle xfer;
    940         1.1  augustss 
    941        1.40  augustss 	SPLUSBCHECK;
    942        1.40  augustss 
    943        1.25  augustss 	DPRINTFN(2,("usbd_ar_pipe: pipe=%p\n", pipe));
    944        1.28  augustss #ifdef USB_DEBUG
    945        1.28  augustss 	if (usbdebug > 5)
    946        1.28  augustss 		usbd_dump_queue(pipe);
    947        1.28  augustss #endif
    948        1.47  augustss 	pipe->repeat = 0;
    949        1.71  augustss 	pipe->aborting = 1;
    950        1.48  augustss 	while ((xfer = SIMPLEQ_FIRST(&pipe->queue)) != NULL) {
    951       1.102  augustss 		DPRINTFN(2,("usbd_ar_pipe: pipe=%p xfer=%p (methods=%p)\n",
    952        1.48  augustss 			    pipe, xfer, pipe->methods));
    953        1.28  augustss 		/* Make the HC abort it (and invoke the callback). */
    954        1.48  augustss 		pipe->methods->abort(xfer);
    955  1.119.12.1     itohy 		USB_KASSERT2(SIMPLEQ_FIRST(&pipe->queue) != xfer,
    956  1.119.12.1     itohy 		    ("usbd_ar_pipe"));
    957        1.33  augustss 		/* XXX only for non-0 usbd_clear_endpoint_stall(pipe); */
    958        1.20  augustss 	}
    959        1.71  augustss 	pipe->aborting = 0;
    960         1.1  augustss 	return (USBD_NORMAL_COMPLETION);
    961         1.1  augustss }
    962         1.1  augustss 
    963        1.40  augustss /* Called at splusb() */
    964        1.31  augustss void
    965        1.74  augustss usb_transfer_complete(usbd_xfer_handle xfer)
    966         1.1  augustss {
    967        1.48  augustss 	usbd_pipe_handle pipe = xfer->pipe;
    968       1.104   mycroft 	int sync = xfer->flags & USBD_SYNCHRONOUS;
    969       1.104   mycroft 	int erred = xfer->status == USBD_CANCELLED ||
    970       1.104   mycroft 	    xfer->status == USBD_TIMEOUT;
    971       1.111  christos 	int repeat, polling;
    972        1.31  augustss 
    973        1.40  augustss 	SPLUSBCHECK;
    974        1.40  augustss 
    975        1.48  augustss 	DPRINTFN(5, ("usb_transfer_complete: pipe=%p xfer=%p status=%d "
    976        1.48  augustss 		     "actlen=%d\n", pipe, xfer, xfer->status, xfer->actlen));
    977        1.93  augustss #ifdef DIAGNOSTIC
    978        1.93  augustss 	if (xfer->busy_free != XFER_ONQU) {
    979        1.93  augustss 		printf("usb_transfer_complete: xfer=%p not busy 0x%08x\n",
    980        1.93  augustss 		       xfer, xfer->busy_free);
    981        1.93  augustss 	}
    982        1.93  augustss #endif
    983         1.5  augustss 
    984        1.23  augustss #ifdef DIAGNOSTIC
    985        1.48  augustss 	if (pipe == NULL) {
    986  1.119.12.5     itohy 		printf("usb_transfer_complete: pipe==0, xfer=%p\n", xfer);
    987        1.31  augustss 		return;
    988        1.31  augustss 	}
    989        1.23  augustss #endif
    990       1.111  christos 	repeat = pipe->repeat;
    991        1.37  augustss 	polling = pipe->device->bus->use_polling;
    992        1.31  augustss 	/* XXXX */
    993        1.31  augustss 	if (polling)
    994        1.31  augustss 		pipe->running = 0;
    995        1.31  augustss 
    996        1.48  augustss 	if (!(xfer->flags & USBD_NO_COPY) && xfer->actlen != 0 &&
    997        1.48  augustss 	    usbd_xfer_isread(xfer)) {
    998        1.43  augustss #ifdef DIAGNOSTIC
    999        1.48  augustss 		if (xfer->actlen > xfer->length) {
   1000        1.43  augustss 			printf("usb_transfer_complete: actlen > len %d > %d\n",
   1001        1.48  augustss 			       xfer->actlen, xfer->length);
   1002        1.48  augustss 			xfer->actlen = xfer->length;
   1003        1.43  augustss 		}
   1004        1.43  augustss #endif
   1005  1.119.12.1     itohy 		/* Copy data if it is not already in the correct buffer. */
   1006  1.119.12.1     itohy 		if (!(xfer->flags & USBD_NO_COPY) && xfer->hcbuffer != NULL) {
   1007  1.119.12.1     itohy 			DPRINTFN(5, ("usb_transfer_complete: copy %p (buffer) <- %p (alloc), %u bytes\n",
   1008  1.119.12.1     itohy 				     xfer->buffer, xfer->hcbuffer, (unsigned)xfer->actlen));
   1009  1.119.12.1     itohy #ifdef DIAGNOSTIC
   1010  1.119.12.1     itohy 			if ((xfer->rqflags & (URQ_AUTO_BUF | URQ_DEV_BUF)) == 0)
   1011  1.119.12.5     itohy 				panic("usb_transfer_complete: USBD_NO_COPY required with mapped buffer");
   1012  1.119.12.1     itohy #endif
   1013  1.119.12.1     itohy 			memcpy(xfer->buffer, xfer->hcbuffer, xfer->actlen);
   1014  1.119.12.1     itohy 		}
   1015        1.43  augustss 	}
   1016        1.38  augustss 
   1017  1.119.12.1     itohy 	/*
   1018  1.119.12.1     itohy 	 * if we allocated or mapped the buffer in usbd_transfer()
   1019  1.119.12.1     itohy 	 * we unmap it here.
   1020  1.119.12.1     itohy 	 */
   1021  1.119.12.1     itohy 	if (xfer->rqflags & URQ_AUTO_BUF) {
   1022        1.47  augustss 		if (!repeat) {
   1023        1.37  augustss 			struct usbd_bus *bus = pipe->device->bus;
   1024  1.119.12.1     itohy 			bus->methods->freem(bus, xfer, U_NOWAIT);
   1025  1.119.12.1     itohy 			xfer->rqflags &= ~URQ_AUTO_BUF;
   1026        1.37  augustss 		}
   1027        1.37  augustss 	}
   1028        1.37  augustss 
   1029        1.47  augustss 	if (!repeat) {
   1030        1.47  augustss 		/* Remove request from queue. */
   1031        1.47  augustss #ifdef DIAGNOSTIC
   1032        1.93  augustss 		xfer->busy_free = XFER_BUSY;
   1033        1.45  augustss #endif
   1034  1.119.12.1     itohy 		USB_KASSERT2(SIMPLEQ_FIRST(&pipe->queue) == xfer,
   1035  1.119.12.1     itohy 		    ("usb_transfer_complete: bad dequeue"));
   1036       1.101     lukem 		SIMPLEQ_REMOVE_HEAD(&pipe->queue, next);
   1037        1.47  augustss 	}
   1038       1.102  augustss 	DPRINTFN(5,("usb_transfer_complete: repeat=%d new head=%p\n",
   1039        1.61  augustss 		    repeat, SIMPLEQ_FIRST(&pipe->queue)));
   1040        1.31  augustss 
   1041        1.31  augustss 	/* Count completed transfers. */
   1042        1.97  christos 	++pipe->device->bus->stats.uds_requests
   1043         1.5  augustss 		[pipe->endpoint->edesc->bmAttributes & UE_XFERTYPE];
   1044         1.1  augustss 
   1045        1.48  augustss 	xfer->done = 1;
   1046        1.52  augustss 	if (!xfer->status && xfer->actlen < xfer->length &&
   1047        1.48  augustss 	    !(xfer->flags & USBD_SHORT_XFER_OK)) {
   1048        1.48  augustss 		DPRINTFN(-1,("usbd_transfer_cb: short transfer %d<%d\n",
   1049        1.48  augustss 			     xfer->actlen, xfer->length));
   1050        1.48  augustss 		xfer->status = USBD_SHORT_XFER;
   1051         1.1  augustss 	}
   1052        1.31  augustss 
   1053  1.119.12.1     itohy 	/*
   1054  1.119.12.1     itohy 	 * For repeat operations, call the callback first, as the xfer
   1055  1.119.12.1     itohy 	 * will not go away and the "done" method may modify it. Otherwise
   1056  1.119.12.1     itohy 	 * reverse the order in case the callback wants to free or reuse
   1057  1.119.12.1     itohy 	 * the xfer.
   1058  1.119.12.1     itohy 	 */
   1059  1.119.12.1     itohy 	if (repeat) {
   1060  1.119.12.1     itohy 		if (xfer->callback)
   1061  1.119.12.1     itohy 			xfer->callback(xfer, xfer->priv, xfer->status);
   1062        1.61  augustss 		pipe->methods->done(xfer);
   1063  1.119.12.1     itohy 	} else {
   1064  1.119.12.1     itohy 		pipe->methods->done(xfer);
   1065  1.119.12.3     itohy 		if (xfer->callback) {
   1066  1.119.12.4     itohy 			if (xfer->flags & USBD_CALLBACK_AS_TASK) {
   1067  1.119.12.3     itohy 				/*
   1068  1.119.12.3     itohy 				 * Callback as a task (in thread context).
   1069  1.119.12.3     itohy 				 */
   1070  1.119.12.3     itohy 				usb_init_task(&xfer->task, usbd_callback_task,
   1071  1.119.12.3     itohy 				    xfer);
   1072  1.119.12.3     itohy 				usb_add_task(xfer->device, &xfer->task,
   1073  1.119.12.3     itohy 				    USB_TASKQ_DRIVER);
   1074  1.119.12.3     itohy 			} else
   1075  1.119.12.3     itohy 				xfer->callback(xfer, xfer->priv, xfer->status);
   1076  1.119.12.3     itohy 		}
   1077  1.119.12.1     itohy 	}
   1078        1.31  augustss 
   1079       1.104   mycroft 	if (sync && !polling)
   1080        1.48  augustss 		wakeup(xfer);
   1081        1.31  augustss 
   1082        1.47  augustss 	if (!repeat) {
   1083        1.40  augustss 		/* XXX should we stop the queue on all errors? */
   1084       1.104   mycroft 		if (erred && pipe->iface != NULL)	/* not control pipe */
   1085        1.40  augustss 			pipe->running = 0;
   1086        1.40  augustss 		else
   1087        1.40  augustss 			usbd_start_next(pipe);
   1088        1.40  augustss 	}
   1089         1.1  augustss }
   1090         1.1  augustss 
   1091  1.119.12.3     itohy Static void
   1092  1.119.12.3     itohy usbd_callback_task(void *arg)
   1093  1.119.12.3     itohy {
   1094  1.119.12.3     itohy 	usbd_xfer_handle xfer = arg;
   1095  1.119.12.3     itohy 
   1096  1.119.12.3     itohy 	xfer->callback(xfer, xfer->priv, xfer->status);
   1097  1.119.12.3     itohy }
   1098  1.119.12.3     itohy 
   1099        1.31  augustss usbd_status
   1100        1.74  augustss usb_insert_transfer(usbd_xfer_handle xfer)
   1101         1.1  augustss {
   1102        1.48  augustss 	usbd_pipe_handle pipe = xfer->pipe;
   1103        1.48  augustss 	usbd_status err;
   1104        1.37  augustss 	int s;
   1105        1.31  augustss 
   1106       1.102  augustss 	DPRINTFN(5,("usb_insert_transfer: pipe=%p running=%d timeout=%d\n",
   1107        1.48  augustss 		    pipe, pipe->running, xfer->timeout));
   1108        1.93  augustss #ifdef DIAGNOSTIC
   1109        1.93  augustss 	if (xfer->busy_free != XFER_BUSY) {
   1110        1.93  augustss 		printf("usb_insert_transfer: xfer=%p not busy 0x%08x\n",
   1111        1.93  augustss 		       xfer, xfer->busy_free);
   1112        1.93  augustss 		return (USBD_INVAL);
   1113        1.93  augustss 	}
   1114        1.93  augustss 	xfer->busy_free = XFER_ONQU;
   1115        1.93  augustss #endif
   1116        1.37  augustss 	s = splusb();
   1117  1.119.12.1     itohy 	USB_KASSERT2(SIMPLEQ_FIRST(&pipe->queue) != xfer,
   1118  1.119.12.1     itohy 	    ("usb_insert_transfer"));
   1119        1.48  augustss 	SIMPLEQ_INSERT_TAIL(&pipe->queue, xfer, next);
   1120        1.31  augustss 	if (pipe->running)
   1121        1.48  augustss 		err = USBD_IN_PROGRESS;
   1122        1.37  augustss 	else {
   1123        1.37  augustss 		pipe->running = 1;
   1124        1.48  augustss 		err = USBD_NORMAL_COMPLETION;
   1125        1.37  augustss 	}
   1126        1.37  augustss 	splx(s);
   1127        1.48  augustss 	return (err);
   1128         1.1  augustss }
   1129         1.1  augustss 
   1130        1.40  augustss /* Called at splusb() */
   1131        1.31  augustss void
   1132        1.74  augustss usbd_start_next(usbd_pipe_handle pipe)
   1133        1.31  augustss {
   1134        1.48  augustss 	usbd_xfer_handle xfer;
   1135        1.48  augustss 	usbd_status err;
   1136        1.40  augustss 
   1137        1.40  augustss 	SPLUSBCHECK;
   1138         1.1  augustss 
   1139        1.31  augustss #ifdef DIAGNOSTIC
   1140        1.48  augustss 	if (pipe == NULL) {
   1141        1.51  augustss 		printf("usbd_start_next: pipe == NULL\n");
   1142        1.31  augustss 		return;
   1143        1.31  augustss 	}
   1144        1.48  augustss 	if (pipe->methods == NULL || pipe->methods->start == NULL) {
   1145        1.51  augustss 		printf("usbd_start_next: pipe=%p no start method\n", pipe);
   1146        1.31  augustss 		return;
   1147        1.31  augustss 	}
   1148        1.31  augustss #endif
   1149        1.31  augustss 
   1150        1.31  augustss 	/* Get next request in queue. */
   1151        1.48  augustss 	xfer = SIMPLEQ_FIRST(&pipe->queue);
   1152        1.51  augustss 	DPRINTFN(5, ("usbd_start_next: pipe=%p, xfer=%p\n", pipe, xfer));
   1153        1.51  augustss 	if (xfer == NULL) {
   1154        1.31  augustss 		pipe->running = 0;
   1155        1.51  augustss 	} else {
   1156        1.48  augustss 		err = pipe->methods->start(xfer);
   1157        1.48  augustss 		if (err != USBD_IN_PROGRESS) {
   1158        1.48  augustss 			printf("usbd_start_next: error=%d\n", err);
   1159        1.31  augustss 			pipe->running = 0;
   1160        1.31  augustss 			/* XXX do what? */
   1161        1.31  augustss 		}
   1162         1.1  augustss 	}
   1163         1.1  augustss }
   1164         1.1  augustss 
   1165         1.1  augustss usbd_status
   1166        1.74  augustss usbd_do_request(usbd_device_handle dev, usb_device_request_t *req, void *data)
   1167         1.1  augustss {
   1168        1.99   thorpej 	return (usbd_do_request_flags(dev, req, data, 0, 0,
   1169        1.98  augustss 				      USBD_DEFAULT_TIMEOUT));
   1170        1.17  augustss }
   1171        1.17  augustss 
   1172        1.17  augustss usbd_status
   1173        1.74  augustss usbd_do_request_flags(usbd_device_handle dev, usb_device_request_t *req,
   1174        1.96  augustss 		      void *data, u_int16_t flags, int *actlen, u_int32_t timo)
   1175        1.17  augustss {
   1176       1.102  augustss 	return (usbd_do_request_flags_pipe(dev, dev->default_pipe, req,
   1177        1.96  augustss 					   data, flags, actlen, timo));
   1178        1.77  augustss }
   1179        1.77  augustss 
   1180        1.77  augustss usbd_status
   1181        1.77  augustss usbd_do_request_flags_pipe(usbd_device_handle dev, usbd_pipe_handle pipe,
   1182        1.96  augustss 	usb_device_request_t *req, void *data, u_int16_t flags, int *actlen,
   1183        1.96  augustss 	u_int32_t timeout)
   1184        1.77  augustss {
   1185        1.48  augustss 	usbd_xfer_handle xfer;
   1186        1.48  augustss 	usbd_status err;
   1187         1.1  augustss 
   1188         1.7  augustss #ifdef DIAGNOSTIC
   1189        1.51  augustss #if defined(__i386__) && defined(__FreeBSD__)
   1190  1.119.12.1     itohy 	KASSERT(curthread->td_intr_nesting_level == 0,
   1191        1.62  augustss 	       	("usbd_do_request: in interrupt context"));
   1192        1.51  augustss #endif
   1193        1.39  augustss 	if (dev->bus->intr_context) {
   1194  1.119.12.1     itohy 		panic("usbd_do_request: not in process context");
   1195         1.7  augustss 	}
   1196         1.7  augustss #endif
   1197         1.7  augustss 
   1198  1.119.12.1     itohy 	xfer = usbd_alloc_xfer(dev, pipe);
   1199        1.48  augustss 	if (xfer == NULL)
   1200         1.1  augustss 		return (USBD_NOMEM);
   1201  1.119.12.1     itohy 	xfer->pipe = dev->default_pipe;	/* XXX */
   1202  1.119.12.1     itohy 	/* XXX */
   1203        1.96  augustss 	usbd_setup_default_xfer(xfer, dev, 0, timeout, req,
   1204        1.77  augustss 				data, UGETW(req->wLength), flags, 0);
   1205  1.119.12.1     itohy 	/* XXX */
   1206        1.77  augustss 	xfer->pipe = pipe;
   1207        1.48  augustss 	err = usbd_sync_transfer(xfer);
   1208         1.1  augustss #if defined(USB_DEBUG) || defined(DIAGNOSTIC)
   1209       1.112    dogcow 	if (xfer->actlen > xfer->length) {
   1210        1.35  augustss 		DPRINTF(("usbd_do_request: overrun addr=%d type=0x%02x req=0x"
   1211        1.35  augustss 			 "%02x val=%d index=%d rlen=%d length=%d actlen=%d\n",
   1212        1.48  augustss 			 dev->address, xfer->request.bmRequestType,
   1213        1.48  augustss 			 xfer->request.bRequest, UGETW(xfer->request.wValue),
   1214       1.102  augustss 			 UGETW(xfer->request.wIndex),
   1215       1.102  augustss 			 UGETW(xfer->request.wLength),
   1216        1.48  augustss 			 xfer->length, xfer->actlen));
   1217       1.112    dogcow 	}
   1218         1.1  augustss #endif
   1219        1.48  augustss 	if (actlen != NULL)
   1220        1.48  augustss 		*actlen = xfer->actlen;
   1221        1.48  augustss 	if (err == USBD_STALLED) {
   1222       1.102  augustss 		/*
   1223        1.15  augustss 		 * The control endpoint has stalled.  Control endpoints
   1224        1.15  augustss 		 * should not halt, but some may do so anyway so clear
   1225        1.15  augustss 		 * any halt condition.
   1226        1.15  augustss 		 */
   1227        1.15  augustss 		usb_device_request_t treq;
   1228        1.15  augustss 		usb_status_t status;
   1229        1.15  augustss 		u_int16_t s;
   1230        1.48  augustss 		usbd_status nerr;
   1231        1.15  augustss 
   1232        1.15  augustss 		treq.bmRequestType = UT_READ_ENDPOINT;
   1233        1.15  augustss 		treq.bRequest = UR_GET_STATUS;
   1234        1.15  augustss 		USETW(treq.wValue, 0);
   1235        1.15  augustss 		USETW(treq.wIndex, 0);
   1236        1.15  augustss 		USETW(treq.wLength, sizeof(usb_status_t));
   1237        1.50  augustss 		usbd_setup_default_xfer(xfer, dev, 0, USBD_DEFAULT_TIMEOUT,
   1238        1.37  augustss 					   &treq, &status,sizeof(usb_status_t),
   1239        1.36  augustss 					   0, 0);
   1240        1.48  augustss 		nerr = usbd_sync_transfer(xfer);
   1241        1.48  augustss 		if (nerr)
   1242        1.15  augustss 			goto bad;
   1243        1.15  augustss 		s = UGETW(status.wStatus);
   1244        1.15  augustss 		DPRINTF(("usbd_do_request: status = 0x%04x\n", s));
   1245        1.15  augustss 		if (!(s & UES_HALT))
   1246        1.15  augustss 			goto bad;
   1247        1.15  augustss 		treq.bmRequestType = UT_WRITE_ENDPOINT;
   1248        1.15  augustss 		treq.bRequest = UR_CLEAR_FEATURE;
   1249        1.15  augustss 		USETW(treq.wValue, UF_ENDPOINT_HALT);
   1250        1.15  augustss 		USETW(treq.wIndex, 0);
   1251        1.15  augustss 		USETW(treq.wLength, 0);
   1252        1.50  augustss 		usbd_setup_default_xfer(xfer, dev, 0, USBD_DEFAULT_TIMEOUT,
   1253        1.36  augustss 					   &treq, &status, 0, 0, 0);
   1254        1.48  augustss 		nerr = usbd_sync_transfer(xfer);
   1255        1.48  augustss 		if (nerr)
   1256        1.15  augustss 			goto bad;
   1257        1.15  augustss 	}
   1258        1.15  augustss 
   1259        1.15  augustss  bad:
   1260        1.50  augustss 	usbd_free_xfer(xfer);
   1261        1.48  augustss 	return (err);
   1262         1.7  augustss }
   1263         1.7  augustss 
   1264         1.7  augustss void
   1265       1.113  christos usbd_do_request_async_cb(usbd_xfer_handle xfer,
   1266       1.114  christos     usbd_private_handle priv, usbd_status status)
   1267         1.7  augustss {
   1268         1.7  augustss #if defined(USB_DEBUG) || defined(DIAGNOSTIC)
   1269       1.112    dogcow 	if (xfer->actlen > xfer->length) {
   1270        1.35  augustss 		DPRINTF(("usbd_do_request: overrun addr=%d type=0x%02x req=0x"
   1271        1.35  augustss 			 "%02x val=%d index=%d rlen=%d length=%d actlen=%d\n",
   1272       1.102  augustss 			 xfer->pipe->device->address,
   1273        1.48  augustss 			 xfer->request.bmRequestType,
   1274        1.48  augustss 			 xfer->request.bRequest, UGETW(xfer->request.wValue),
   1275       1.102  augustss 			 UGETW(xfer->request.wIndex),
   1276       1.102  augustss 			 UGETW(xfer->request.wLength),
   1277        1.48  augustss 			 xfer->length, xfer->actlen));
   1278       1.112    dogcow 	}
   1279         1.7  augustss #endif
   1280  1.119.12.1     itohy 	usbd_free_xfer_flag(xfer, U_NOWAIT);
   1281         1.7  augustss }
   1282         1.7  augustss 
   1283         1.7  augustss /*
   1284         1.7  augustss  * Execute a request without waiting for completion.
   1285         1.7  augustss  * Can be used from interrupt context.
   1286         1.7  augustss  */
   1287         1.7  augustss usbd_status
   1288        1.74  augustss usbd_do_request_async(usbd_device_handle dev, usb_device_request_t *req,
   1289        1.74  augustss 		      void *data)
   1290         1.7  augustss {
   1291        1.48  augustss 	usbd_xfer_handle xfer;
   1292         1.7  augustss 
   1293  1.119.12.1     itohy 	xfer = usbd_alloc_xfer_flag(dev, dev->default_pipe, U_NOWAIT);
   1294        1.49  augustss 	if (xfer == NULL)
   1295         1.7  augustss 		return (USBD_NOMEM);
   1296        1.50  augustss 	usbd_setup_default_xfer(xfer, dev, 0, USBD_DEFAULT_TIMEOUT, req,
   1297        1.48  augustss 	    data, UGETW(req->wLength), 0, usbd_do_request_async_cb);
   1298  1.119.12.1     itohy 
   1299  1.119.12.1     itohy 	/*
   1300  1.119.12.1     itohy 	 * Request will be processed later as a task (in thread context).
   1301  1.119.12.1     itohy 	 */
   1302  1.119.12.3     itohy 	usb_init_task(&xfer->task, usbd_do_request_async_task, xfer);
   1303  1.119.12.3     itohy 	usb_add_task(dev, &xfer->task, USB_TASKQ_HC);
   1304  1.119.12.1     itohy 
   1305  1.119.12.1     itohy 	return (USBD_IN_PROGRESS);
   1306  1.119.12.1     itohy }
   1307  1.119.12.1     itohy 
   1308  1.119.12.1     itohy Static void
   1309  1.119.12.1     itohy usbd_do_request_async_task(void *arg)
   1310  1.119.12.1     itohy {
   1311  1.119.12.1     itohy 	usbd_xfer_handle xfer = arg;
   1312  1.119.12.1     itohy 	usbd_status err;
   1313  1.119.12.1     itohy 
   1314  1.119.12.1     itohy 	/* XXX impossible to notify caller the error */
   1315        1.48  augustss 	err = usbd_transfer(xfer);
   1316  1.119.12.1     itohy 	if (err != USBD_IN_PROGRESS && err) {
   1317        1.50  augustss 		usbd_free_xfer(xfer);
   1318         1.7  augustss 	}
   1319         1.1  augustss }
   1320         1.1  augustss 
   1321        1.78  augustss const struct usbd_quirks *
   1322        1.74  augustss usbd_get_quirks(usbd_device_handle dev)
   1323         1.1  augustss {
   1324        1.81  augustss #ifdef DIAGNOSTIC
   1325        1.81  augustss 	if (dev == NULL) {
   1326        1.81  augustss 		printf("usbd_get_quirks: dev == NULL\n");
   1327        1.81  augustss 		return 0;
   1328        1.81  augustss 	}
   1329        1.81  augustss #endif
   1330         1.1  augustss 	return (dev->quirks);
   1331         1.1  augustss }
   1332         1.1  augustss 
   1333         1.1  augustss /* XXX do periodic free() of free list */
   1334         1.1  augustss 
   1335         1.6  augustss /*
   1336         1.6  augustss  * Called from keyboard driver when in polling mode.
   1337         1.6  augustss  */
   1338         1.6  augustss void
   1339        1.74  augustss usbd_dopoll(usbd_interface_handle iface)
   1340         1.6  augustss {
   1341        1.36  augustss 	iface->device->bus->methods->do_poll(iface->device->bus);
   1342         1.8  augustss }
   1343         1.8  augustss 
   1344         1.8  augustss void
   1345        1.74  augustss usbd_set_polling(usbd_device_handle dev, int on)
   1346         1.8  augustss {
   1347        1.42  augustss 	if (on)
   1348        1.54  augustss 		dev->bus->use_polling++;
   1349        1.42  augustss 	else
   1350        1.54  augustss 		dev->bus->use_polling--;
   1351        1.94  augustss 	/* When polling we need to make sure there is nothing pending to do. */
   1352        1.94  augustss 	if (dev->bus->use_polling)
   1353        1.94  augustss 		dev->bus->methods->soft_intr(dev->bus);
   1354         1.6  augustss }
   1355        1.12  augustss 
   1356        1.12  augustss 
   1357        1.12  augustss usb_endpoint_descriptor_t *
   1358        1.74  augustss usbd_get_endpoint_descriptor(usbd_interface_handle iface, u_int8_t address)
   1359        1.12  augustss {
   1360        1.12  augustss 	struct usbd_endpoint *ep;
   1361        1.12  augustss 	int i;
   1362        1.12  augustss 
   1363        1.12  augustss 	for (i = 0; i < iface->idesc->bNumEndpoints; i++) {
   1364        1.12  augustss 		ep = &iface->endpoints[i];
   1365        1.12  augustss 		if (ep->edesc->bEndpointAddress == address)
   1366        1.12  augustss 			return (iface->endpoints[i].edesc);
   1367        1.12  augustss 	}
   1368        1.12  augustss 	return (0);
   1369        1.63  augustss }
   1370        1.63  augustss 
   1371        1.63  augustss /*
   1372        1.63  augustss  * usbd_ratecheck() can limit the number of error messages that occurs.
   1373        1.63  augustss  * When a device is unplugged it may take up to 0.25s for the hub driver
   1374        1.63  augustss  * to notice it.  If the driver continuosly tries to do I/O operations
   1375        1.63  augustss  * this can generate a large number of messages.
   1376        1.63  augustss  */
   1377        1.63  augustss int
   1378        1.74  augustss usbd_ratecheck(struct timeval *last)
   1379        1.63  augustss {
   1380  1.119.12.1     itohy #if defined(__NetBSD__)
   1381        1.64  augustss 	static struct timeval errinterval = { 0, 250000 }; /* 0.25 s*/
   1382        1.63  augustss 
   1383        1.63  augustss 	return (ratecheck(last, &errinterval));
   1384  1.119.12.1     itohy #elif defined(__FreeBSD__)
   1385  1.119.12.1     itohy 	if (last->tv_sec == time_second)
   1386  1.119.12.1     itohy 		return (0);
   1387  1.119.12.1     itohy 	last->tv_sec = time_second;
   1388  1.119.12.1     itohy 	return (1);
   1389  1.119.12.1     itohy #endif
   1390        1.89  augustss }
   1391        1.89  augustss 
   1392        1.89  augustss /*
   1393        1.89  augustss  * Search for a vendor/product pair in an array.  The item size is
   1394        1.89  augustss  * given as an argument.
   1395        1.89  augustss  */
   1396        1.90  augustss const struct usb_devno *
   1397        1.90  augustss usb_match_device(const struct usb_devno *tbl, u_int nentries, u_int sz,
   1398        1.89  augustss 		 u_int16_t vendor, u_int16_t product)
   1399        1.89  augustss {
   1400        1.89  augustss 	while (nentries-- > 0) {
   1401        1.93  augustss 		u_int16_t tproduct = tbl->ud_product;
   1402        1.93  augustss 		if (tbl->ud_vendor == vendor &&
   1403        1.93  augustss 		    (tproduct == product || tproduct == USB_PRODUCT_ANY))
   1404        1.89  augustss 			return (tbl);
   1405        1.95  augustss 		tbl = (const struct usb_devno *)((const char *)tbl + sz);
   1406        1.89  augustss 	}
   1407        1.89  augustss 	return (NULL);
   1408        1.12  augustss }
   1409        1.12  augustss 
   1410       1.105  augustss 
   1411       1.105  augustss void
   1412       1.105  augustss usb_desc_iter_init(usbd_device_handle dev, usbd_desc_iter_t *iter)
   1413       1.105  augustss {
   1414       1.105  augustss 	const usb_config_descriptor_t *cd = usbd_get_config_descriptor(dev);
   1415       1.105  augustss 
   1416       1.108  christos         iter->cur = (const uByte *)cd;
   1417       1.108  christos         iter->end = (const uByte *)cd + UGETW(cd->wTotalLength);
   1418       1.105  augustss }
   1419       1.105  augustss 
   1420       1.105  augustss const usb_descriptor_t *
   1421       1.105  augustss usb_desc_iter_next(usbd_desc_iter_t *iter)
   1422       1.105  augustss {
   1423       1.105  augustss 	const usb_descriptor_t *desc;
   1424       1.105  augustss 
   1425       1.105  augustss 	if (iter->cur + sizeof(usb_descriptor_t) >= iter->end) {
   1426       1.105  augustss 		if (iter->cur != iter->end)
   1427       1.105  augustss 			printf("usb_desc_iter_next: bad descriptor\n");
   1428       1.105  augustss 		return NULL;
   1429       1.105  augustss 	}
   1430       1.108  christos 	desc = (const usb_descriptor_t *)iter->cur;
   1431       1.105  augustss 	if (desc->bLength == 0) {
   1432       1.105  augustss 		printf("usb_desc_iter_next: descriptor length = 0\n");
   1433       1.105  augustss 		return NULL;
   1434       1.105  augustss 	}
   1435       1.105  augustss 	iter->cur += desc->bLength;
   1436       1.105  augustss 	if (iter->cur > iter->end) {
   1437       1.105  augustss 		printf("usb_desc_iter_next: descriptor length too large\n");
   1438       1.105  augustss 		return NULL;
   1439       1.105  augustss 	}
   1440       1.105  augustss 	return desc;
   1441       1.105  augustss }
   1442       1.105  augustss 
   1443       1.105  augustss usbd_status
   1444       1.105  augustss usbd_get_string(usbd_device_handle dev, int si, char *buf)
   1445       1.105  augustss {
   1446       1.115     pavel 	return usbd_get_string0(dev, si, buf, 1);
   1447       1.115     pavel }
   1448       1.115     pavel 
   1449       1.115     pavel usbd_status
   1450       1.115     pavel usbd_get_string0(usbd_device_handle dev, int si, char *buf, int unicode)
   1451       1.115     pavel {
   1452       1.105  augustss 	int swap = dev->quirks->uq_flags & UQ_SWAP_UNICODE;
   1453       1.105  augustss 	usb_string_descriptor_t us;
   1454       1.105  augustss 	char *s;
   1455       1.116  macallan 	int i, n;
   1456       1.105  augustss 	u_int16_t c;
   1457       1.105  augustss 	usbd_status err;
   1458       1.105  augustss 	int size;
   1459       1.105  augustss 
   1460       1.105  augustss 	buf[0] = '\0';
   1461       1.105  augustss 	if (si == 0)
   1462       1.105  augustss 		return (USBD_INVAL);
   1463       1.105  augustss 	if (dev->quirks->uq_flags & UQ_NO_STRINGS)
   1464       1.105  augustss 		return (USBD_STALLED);
   1465       1.105  augustss 	if (dev->langid == USBD_NOLANG) {
   1466       1.105  augustss 		/* Set up default language */
   1467       1.105  augustss 		err = usbd_get_string_desc(dev, USB_LANGUAGE_TABLE, 0, &us,
   1468       1.105  augustss 		    &size);
   1469       1.105  augustss 		if (err || size < 4) {
   1470       1.106  augustss 			DPRINTFN(-1,("usbd_get_string: getting lang failed, using 0\n"));
   1471       1.105  augustss 			dev->langid = 0; /* Well, just pick something then */
   1472       1.105  augustss 		} else {
   1473       1.105  augustss 			/* Pick the first language as the default. */
   1474       1.105  augustss 			dev->langid = UGETW(us.bString[0]);
   1475       1.105  augustss 		}
   1476       1.105  augustss 	}
   1477       1.105  augustss 	err = usbd_get_string_desc(dev, si, dev->langid, &us, &size);
   1478       1.105  augustss 	if (err)
   1479       1.105  augustss 		return (err);
   1480       1.105  augustss 	s = buf;
   1481       1.105  augustss 	n = size / 2 - 1;
   1482       1.115     pavel 	if (unicode) {
   1483       1.115     pavel 		for (i = 0; i < n; i++) {
   1484       1.115     pavel 			c = UGETW(us.bString[i]);
   1485       1.115     pavel 			if (swap)
   1486       1.115     pavel 				c = (c >> 8) | (c << 8);
   1487       1.119  drochner 			s += wput_utf8(s, 3, c);
   1488       1.115     pavel 		}
   1489       1.115     pavel 		*s++ = 0;
   1490       1.115     pavel 	}
   1491  1.119.12.1     itohy #if defined(__NetBSD__) && defined(COMPAT_30)
   1492       1.115     pavel 	else {
   1493       1.119  drochner 		for (i = 0; i < n; i++) {
   1494       1.115     pavel 			c = UGETW(us.bString[i]);
   1495       1.115     pavel 			if (swap)
   1496       1.115     pavel 				c = (c >> 8) | (c << 8);
   1497       1.119  drochner 			*s++ = (c < 0x80) ? c : '?';
   1498       1.107  augustss 		}
   1499       1.119  drochner 		*s++ = 0;
   1500       1.105  augustss 	}
   1501       1.115     pavel #endif
   1502       1.105  augustss 	return (USBD_NORMAL_COMPLETION);
   1503       1.105  augustss }
   1504       1.105  augustss 
   1505        1.20  augustss #if defined(__FreeBSD__)
   1506        1.20  augustss int
   1507        1.20  augustss usbd_driver_load(module_t mod, int what, void *arg)
   1508        1.20  augustss {
   1509        1.45  augustss 	/* XXX should implement something like a function that removes all generic devices */
   1510       1.102  augustss 
   1511        1.48  augustss  	return (0);
   1512        1.20  augustss }
   1513        1.20  augustss 
   1514        1.20  augustss #endif
   1515