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