Home | History | Annotate | Line # | Download | only in usb
ucom.c revision 1.108.2.9
      1  1.108.2.9     skrll /*	$NetBSD: ucom.c,v 1.108.2.9 2015/10/06 21:32:15 skrll Exp $	*/
      2        1.1  augustss 
      3        1.1  augustss /*
      4       1.22  augustss  * Copyright (c) 1998, 2000 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.23  augustss  * by Lennart Augustsson (lennart (at) augustsson.net) at
      9        1.1  augustss  * Carlstedt Research & Technology.
     10        1.1  augustss  *
     11        1.1  augustss  * Redistribution and use in source and binary forms, with or without
     12        1.1  augustss  * modification, are permitted provided that the following conditions
     13        1.1  augustss  * are met:
     14        1.1  augustss  * 1. Redistributions of source code must retain the above copyright
     15        1.1  augustss  *    notice, this list of conditions and the following disclaimer.
     16        1.1  augustss  * 2. Redistributions in binary form must reproduce the above copyright
     17        1.1  augustss  *    notice, this list of conditions and the following disclaimer in the
     18        1.1  augustss  *    documentation and/or other materials provided with the distribution.
     19        1.1  augustss  *
     20        1.1  augustss  * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
     21        1.1  augustss  * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
     22        1.1  augustss  * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     23        1.1  augustss  * PURPOSE ARE DISCLAIMED.  IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
     24        1.1  augustss  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
     25        1.1  augustss  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
     26        1.1  augustss  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
     27        1.1  augustss  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
     28        1.1  augustss  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
     29        1.1  augustss  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     30        1.1  augustss  * POSSIBILITY OF SUCH DAMAGE.
     31        1.1  augustss  */
     32       1.22  augustss /*
     33       1.22  augustss  * This code is very heavily based on the 16550 driver, com.c.
     34       1.22  augustss  */
     35       1.40     lukem 
     36       1.40     lukem #include <sys/cdefs.h>
     37  1.108.2.9     skrll __KERNEL_RCSID(0, "$NetBSD: ucom.c,v 1.108.2.9 2015/10/06 21:32:15 skrll Exp $");
     38        1.1  augustss 
     39        1.1  augustss #include <sys/param.h>
     40        1.1  augustss #include <sys/systm.h>
     41        1.1  augustss #include <sys/kernel.h>
     42        1.1  augustss #include <sys/ioctl.h>
     43        1.3  augustss #include <sys/conf.h>
     44        1.1  augustss #include <sys/tty.h>
     45        1.1  augustss #include <sys/file.h>
     46        1.1  augustss #include <sys/select.h>
     47        1.1  augustss #include <sys/proc.h>
     48        1.1  augustss #include <sys/vnode.h>
     49       1.12  augustss #include <sys/device.h>
     50        1.1  augustss #include <sys/poll.h>
     51       1.82    martin #include <sys/queue.h>
     52       1.63      elad #include <sys/kauth.h>
     53  1.108.2.7     skrll #include <sys/sysctl.h>
     54      1.106       gdt #include <sys/timepps.h>
     55  1.108.2.6     skrll #include <sys/rndsource.h>
     56        1.1  augustss 
     57        1.1  augustss #include <dev/usb/usb.h>
     58        1.1  augustss 
     59        1.1  augustss #include <dev/usb/usbdi.h>
     60        1.1  augustss #include <dev/usb/usbdi_util.h>
     61        1.1  augustss #include <dev/usb/usbdevs.h>
     62        1.1  augustss #include <dev/usb/usb_quirks.h>
     63  1.108.2.7     skrll #include <dev/usb/usbhist.h>
     64        1.1  augustss 
     65       1.12  augustss #include <dev/usb/ucomvar.h>
     66       1.12  augustss 
     67       1.13  augustss #include "ucom.h"
     68       1.13  augustss 
     69       1.53  drochner #include "locators.h"
     70       1.53  drochner 
     71       1.13  augustss #if NUCOM > 0
     72       1.13  augustss 
     73  1.108.2.7     skrll #ifdef USB_DEBUG
     74  1.108.2.7     skrll #ifndef UCOM_DEBUG
     75  1.108.2.7     skrll #define ucomdebug 0
     76        1.1  augustss #else
     77  1.108.2.7     skrll int ucomdebug = 0;
     78  1.108.2.7     skrll 
     79  1.108.2.7     skrll SYSCTL_SETUP(sysctl_hw_ucom_setup, "sysctl hw.ucom setup")
     80  1.108.2.7     skrll {
     81  1.108.2.7     skrll         int err;
     82  1.108.2.7     skrll         const struct sysctlnode *rnode;
     83  1.108.2.7     skrll         const struct sysctlnode *cnode;
     84  1.108.2.7     skrll 
     85  1.108.2.7     skrll         err = sysctl_createv(clog, 0, NULL, &rnode,
     86  1.108.2.7     skrll             CTLFLAG_PERMANENT, CTLTYPE_NODE, "ucom",
     87  1.108.2.7     skrll             SYSCTL_DESCR("ucom global controls"),
     88  1.108.2.7     skrll             NULL, 0, NULL, 0, CTL_HW, CTL_CREATE, CTL_EOL);
     89  1.108.2.7     skrll 
     90  1.108.2.7     skrll         if (err)
     91  1.108.2.7     skrll                 goto fail;
     92  1.108.2.7     skrll 
     93  1.108.2.7     skrll         /* control debugging printfs */
     94  1.108.2.7     skrll         err = sysctl_createv(clog, 0, &rnode, &cnode,
     95  1.108.2.7     skrll             CTLFLAG_PERMANENT|CTLFLAG_READWRITE, CTLTYPE_INT,
     96  1.108.2.7     skrll             "debug", SYSCTL_DESCR("Enable debugging output"),
     97  1.108.2.7     skrll             NULL, 0, &ucomdebug, sizeof(ucomdebug), CTL_CREATE, CTL_EOL);
     98  1.108.2.7     skrll         if (err)
     99  1.108.2.7     skrll                 goto fail;
    100  1.108.2.7     skrll 
    101  1.108.2.7     skrll         return;
    102  1.108.2.7     skrll fail:
    103  1.108.2.7     skrll         aprint_error("%s: sysctl_createv failed (err = %d)\n", __func__, err);
    104  1.108.2.7     skrll }
    105  1.108.2.7     skrll 
    106  1.108.2.7     skrll #endif /* UCOM_DEBUG */
    107  1.108.2.7     skrll #endif /* USB_DEBUG */
    108  1.108.2.7     skrll 
    109  1.108.2.7     skrll #define DPRINTF(FMT,A,B,C,D)    USBHIST_LOGN(ucomdebug,1,FMT,A,B,C,D)
    110  1.108.2.7     skrll #define DPRINTFN(N,FMT,A,B,C,D) USBHIST_LOGN(ucomdebug,N,FMT,A,B,C,D)
    111  1.108.2.7     skrll #define UCOMHIST_FUNC()         USBHIST_FUNC()
    112  1.108.2.7     skrll #define UCOMHIST_CALLED(name)   USBHIST_CALLED(ucomdebug)
    113       1.12  augustss 
    114      1.108  christos #define	UCOMCALLUNIT_MASK	TTCALLUNIT_MASK
    115      1.108  christos #define	UCOMUNIT_MASK		TTUNIT_MASK
    116      1.108  christos #define	UCOMDIALOUT_MASK	TTDIALOUT_MASK
    117      1.108  christos 
    118      1.108  christos #define	UCOMCALLUNIT(x)		TTCALLUNIT(x)
    119      1.108  christos #define	UCOMUNIT(x)		TTUNIT(x)
    120      1.108  christos #define	UCOMDIALOUT(x)		TTDIALOUT(x)
    121       1.12  augustss 
    122       1.82    martin /*
    123       1.82    martin  * XXX: We can submit multiple input/output buffers to the usb stack
    124       1.82    martin  * to improve throughput, but the usb stack is too lame to deal with this
    125       1.82    martin  * in a number of places.
    126       1.82    martin  */
    127       1.82    martin #define	UCOM_IN_BUFFS	1
    128       1.82    martin #define	UCOM_OUT_BUFFS	1
    129       1.82    martin 
    130       1.82    martin struct ucom_buffer {
    131       1.82    martin 	SIMPLEQ_ENTRY(ucom_buffer) ub_link;
    132  1.108.2.5     skrll 	struct usbd_xfer *ub_xfer;
    133       1.82    martin 	u_char *ub_data;
    134       1.82    martin 	u_int ub_len;
    135       1.82    martin 	u_int ub_index;
    136       1.82    martin };
    137       1.82    martin 
    138        1.1  augustss struct ucom_softc {
    139       1.85    dyoung 	device_t		sc_dev;		/* base device */
    140       1.12  augustss 
    141  1.108.2.5     skrll 	struct usbd_device *	sc_udev;	/* USB device */
    142       1.12  augustss 
    143  1.108.2.5     skrll 	struct usbd_interface *	sc_iface;	/* data interface */
    144       1.12  augustss 
    145       1.12  augustss 	int			sc_bulkin_no;	/* bulk in endpoint address */
    146  1.108.2.5     skrll 	struct usbd_pipe *	sc_bulkin_pipe;	/* bulk in pipe */
    147       1.19  augustss 	u_int			sc_ibufsize;	/* read buffer size */
    148       1.22  augustss 	u_int			sc_ibufsizepad;	/* read buffer size padded */
    149       1.82    martin 	struct ucom_buffer	sc_ibuff[UCOM_IN_BUFFS];
    150       1.82    martin 	SIMPLEQ_HEAD(, ucom_buffer) sc_ibuff_empty;
    151       1.82    martin 	SIMPLEQ_HEAD(, ucom_buffer) sc_ibuff_full;
    152       1.12  augustss 
    153       1.12  augustss 	int			sc_bulkout_no;	/* bulk out endpoint address */
    154  1.108.2.5     skrll 	struct usbd_pipe *	sc_bulkout_pipe;/* bulk out pipe */
    155       1.19  augustss 	u_int			sc_obufsize;	/* write buffer size */
    156       1.82    martin 	u_int			sc_opkthdrlen;	/* header length of */
    157       1.82    martin 	struct ucom_buffer	sc_obuff[UCOM_OUT_BUFFS];
    158       1.82    martin 	SIMPLEQ_HEAD(, ucom_buffer) sc_obuff_free;
    159       1.82    martin 	SIMPLEQ_HEAD(, ucom_buffer) sc_obuff_full;
    160       1.82    martin 
    161       1.82    martin 	void			*sc_si;
    162       1.12  augustss 
    163       1.90  jakllsch 	const struct ucom_methods *sc_methods;
    164       1.12  augustss 	void                    *sc_parent;
    165       1.12  augustss 	int			sc_portno;
    166       1.12  augustss 
    167       1.12  augustss 	struct tty		*sc_tty;	/* our tty */
    168       1.12  augustss 	u_char			sc_lsr;
    169       1.12  augustss 	u_char			sc_msr;
    170       1.12  augustss 	u_char			sc_mcr;
    171       1.82    martin 	volatile u_char		sc_rx_stopped;
    172       1.82    martin 	u_char			sc_rx_unblock;
    173       1.12  augustss 	u_char			sc_tx_stopped;
    174       1.12  augustss 	int			sc_swflags;
    175       1.12  augustss 
    176       1.12  augustss 	u_char			sc_opening;	/* lock during open */
    177       1.17  augustss 	int			sc_refcnt;
    178       1.12  augustss 	u_char			sc_dying;	/* disconnecting */
    179       1.31  explorer 
    180      1.106       gdt 	struct pps_state	sc_pps_state;	/* pps state */
    181      1.106       gdt 
    182  1.108.2.8     skrll 	krndsource_t		sc_rndsource;	/* random source */
    183  1.108.2.8     skrll 
    184  1.108.2.8     skrll 	kmutex_t		*sc_lock;
    185  1.108.2.8     skrll 	kcondvar_t		sc_opencv;
    186  1.108.2.8     skrll 	kcondvar_t		sc_detachcv;
    187        1.1  augustss };
    188        1.1  augustss 
    189       1.44   gehenna dev_type_open(ucomopen);
    190       1.44   gehenna dev_type_close(ucomclose);
    191       1.44   gehenna dev_type_read(ucomread);
    192       1.44   gehenna dev_type_write(ucomwrite);
    193       1.44   gehenna dev_type_ioctl(ucomioctl);
    194       1.44   gehenna dev_type_stop(ucomstop);
    195       1.44   gehenna dev_type_tty(ucomtty);
    196       1.44   gehenna dev_type_poll(ucompoll);
    197       1.44   gehenna 
    198       1.44   gehenna const struct cdevsw ucom_cdevsw = {
    199      1.103  dholland 	.d_open = ucomopen,
    200      1.103  dholland 	.d_close = ucomclose,
    201      1.103  dholland 	.d_read = ucomread,
    202      1.103  dholland 	.d_write = ucomwrite,
    203      1.103  dholland 	.d_ioctl = ucomioctl,
    204      1.103  dholland 	.d_stop = ucomstop,
    205      1.103  dholland 	.d_tty = ucomtty,
    206      1.103  dholland 	.d_poll = ucompoll,
    207      1.103  dholland 	.d_mmap = nommap,
    208      1.103  dholland 	.d_kqfilter = ttykqfilter,
    209      1.105  dholland 	.d_discard = nodiscard,
    210  1.108.2.8     skrll 	.d_flag = D_TTY | D_MPSAFE
    211       1.44   gehenna };
    212       1.12  augustss 
    213       1.82    martin static void	ucom_cleanup(struct ucom_softc *);
    214       1.82    martin static int	ucomparam(struct tty *, struct termios *);
    215       1.82    martin static int	ucomhwiflow(struct tty *, int);
    216       1.82    martin static void	ucomstart(struct tty *);
    217       1.82    martin static void	ucom_shutdown(struct ucom_softc *);
    218       1.82    martin static int	ucom_do_ioctl(struct ucom_softc *, u_long, void *,
    219       1.60  christos 			      int, struct lwp *);
    220       1.82    martin static void	ucom_dtr(struct ucom_softc *, int);
    221       1.82    martin static void	ucom_rts(struct ucom_softc *, int);
    222       1.82    martin static void	ucom_break(struct ucom_softc *, int);
    223       1.82    martin static void	tiocm_to_ucom(struct ucom_softc *, u_long, int);
    224       1.82    martin static int	ucom_to_tiocm(struct ucom_softc *);
    225       1.82    martin 
    226  1.108.2.5     skrll static void	ucomreadcb(struct usbd_xfer *, void *, usbd_status);
    227       1.82    martin static void	ucom_submit_write(struct ucom_softc *, struct ucom_buffer *);
    228       1.82    martin static void	ucom_write_status(struct ucom_softc *, struct ucom_buffer *,
    229       1.82    martin 			usbd_status);
    230       1.82    martin 
    231  1.108.2.5     skrll static void	ucomwritecb(struct usbd_xfer *, void *, usbd_status);
    232       1.82    martin static void	ucom_read_complete(struct ucom_softc *);
    233       1.82    martin static usbd_status ucomsubmitread(struct ucom_softc *, struct ucom_buffer *);
    234       1.82    martin static void	ucom_softintr(void *);
    235        1.1  augustss 
    236       1.85    dyoung int ucom_match(device_t, cfdata_t, void *);
    237       1.85    dyoung void ucom_attach(device_t, device_t, void *);
    238       1.85    dyoung int ucom_detach(device_t, int);
    239       1.85    dyoung int ucom_activate(device_t, enum devact);
    240       1.85    dyoung extern struct cfdriver ucom_cd;
    241       1.85    dyoung CFATTACH_DECL_NEW(ucom, sizeof(struct ucom_softc), ucom_match, ucom_attach,
    242       1.85    dyoung     ucom_detach, ucom_activate);
    243        1.1  augustss 
    244       1.85    dyoung int
    245       1.85    dyoung ucom_match(device_t parent, cfdata_t match, void *aux)
    246        1.1  augustss {
    247  1.108.2.3     skrll 	return 1;
    248        1.1  augustss }
    249        1.1  augustss 
    250       1.85    dyoung void
    251       1.85    dyoung ucom_attach(device_t parent, device_t self, void *aux)
    252        1.1  augustss {
    253       1.77      cube 	struct ucom_softc *sc = device_private(self);
    254       1.12  augustss 	struct ucom_attach_args *uca = aux;
    255       1.12  augustss 	struct tty *tp;
    256       1.12  augustss 
    257  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
    258  1.108.2.7     skrll 
    259       1.35  augustss 	if (uca->info != NULL)
    260       1.83     pooka 		aprint_normal(": %s", uca->info);
    261       1.83     pooka 	aprint_normal("\n");
    262       1.12  augustss 
    263       1.77      cube 	sc->sc_dev = self;
    264       1.12  augustss 	sc->sc_udev = uca->device;
    265       1.12  augustss 	sc->sc_iface = uca->iface;
    266       1.12  augustss 	sc->sc_bulkout_no = uca->bulkout;
    267       1.12  augustss 	sc->sc_bulkin_no = uca->bulkin;
    268       1.19  augustss 	sc->sc_ibufsize = uca->ibufsize;
    269       1.22  augustss 	sc->sc_ibufsizepad = uca->ibufsizepad;
    270       1.19  augustss 	sc->sc_obufsize = uca->obufsize;
    271       1.25  augustss 	sc->sc_opkthdrlen = uca->opkthdrlen;
    272       1.12  augustss 	sc->sc_methods = uca->methods;
    273       1.12  augustss 	sc->sc_parent = uca->arg;
    274       1.12  augustss 	sc->sc_portno = uca->portno;
    275       1.12  augustss 
    276       1.82    martin 	sc->sc_lsr = 0;
    277       1.82    martin 	sc->sc_msr = 0;
    278       1.82    martin 	sc->sc_mcr = 0;
    279       1.82    martin 	sc->sc_tx_stopped = 0;
    280       1.82    martin 	sc->sc_swflags = 0;
    281       1.82    martin 	sc->sc_opening = 0;
    282       1.82    martin 	sc->sc_refcnt = 0;
    283       1.82    martin 	sc->sc_dying = 0;
    284       1.82    martin 
    285  1.108.2.8     skrll 	sc->sc_si = softint_establish(SOFTINT_USB, ucom_softintr, sc);
    286  1.108.2.8     skrll 	sc->sc_lock = mutex_obj_alloc(MUTEX_DEFAULT, IPL_SOFTUSB);
    287  1.108.2.8     skrll 	cv_init(&sc->sc_opencv, "ucomopen");
    288  1.108.2.8     skrll 	cv_init(&sc->sc_detachcv, "ucomdtch");
    289       1.82    martin 
    290  1.108.2.9     skrll 	SIMPLEQ_INIT(&sc->sc_ibuff_empty);
    291  1.108.2.9     skrll 	SIMPLEQ_INIT(&sc->sc_ibuff_full);
    292  1.108.2.9     skrll 	SIMPLEQ_INIT(&sc->sc_obuff_free);
    293  1.108.2.9     skrll 	SIMPLEQ_INIT(&sc->sc_obuff_full);
    294  1.108.2.9     skrll 
    295  1.108.2.9     skrll 	memset(sc->sc_ibuff, 0, sizeof(sc->sc_ibuff));
    296  1.108.2.9     skrll 	memset(sc->sc_obuff, 0, sizeof(sc->sc_obuff));
    297  1.108.2.9     skrll 
    298  1.108.2.9     skrll 	DPRINTF("open pipes in=%d out=%d", sc->sc_bulkin_no, sc->sc_bulkout_no,
    299  1.108.2.9     skrll 	    0, 0);
    300  1.108.2.9     skrll 
    301  1.108.2.9     skrll 	struct ucom_buffer *ub;
    302  1.108.2.9     skrll 	usbd_status err;
    303  1.108.2.9     skrll 	int error;
    304  1.108.2.9     skrll 
    305  1.108.2.9     skrll 	/* Open the bulk pipes */
    306  1.108.2.9     skrll 	err = usbd_open_pipe(sc->sc_iface, sc->sc_bulkin_no,
    307  1.108.2.9     skrll 	    USBD_EXCLUSIVE_USE, &sc->sc_bulkin_pipe);
    308  1.108.2.9     skrll 	if (err) {
    309  1.108.2.9     skrll 		DPRINTF("open bulk in error (addr %d), err=%d",
    310  1.108.2.9     skrll 		    sc->sc_bulkin_no, err, 0, 0);
    311  1.108.2.9     skrll 		error = EIO;
    312  1.108.2.9     skrll 		goto fail_0;
    313  1.108.2.9     skrll 	}
    314  1.108.2.9     skrll 	err = usbd_open_pipe(sc->sc_iface, sc->sc_bulkout_no,
    315  1.108.2.9     skrll 	    USBD_EXCLUSIVE_USE, &sc->sc_bulkout_pipe);
    316  1.108.2.9     skrll 	if (err) {
    317  1.108.2.9     skrll 		DPRINTF("open bulk out error (addr %d), err=%d",
    318  1.108.2.9     skrll 		    sc->sc_bulkout_no, err, 0, 0);
    319  1.108.2.9     skrll 		error = EIO;
    320  1.108.2.9     skrll 		goto fail_1;
    321  1.108.2.9     skrll 	}
    322  1.108.2.9     skrll 
    323  1.108.2.9     skrll 	/* Allocate input buffers */
    324  1.108.2.9     skrll 	for (ub = &sc->sc_ibuff[0]; ub != &sc->sc_ibuff[UCOM_IN_BUFFS];
    325  1.108.2.9     skrll 	    ub++) {
    326  1.108.2.9     skrll 		error = usbd_create_xfer(sc->sc_bulkin_pipe, sc->sc_ibufsizepad,
    327  1.108.2.9     skrll 		    USBD_SHORT_XFER_OK, 0, &ub->ub_xfer);
    328  1.108.2.9     skrll 		if (error)
    329  1.108.2.9     skrll 			goto fail_2;
    330  1.108.2.9     skrll 		ub->ub_data = usbd_get_buffer(ub->ub_xfer);
    331  1.108.2.9     skrll 	}
    332  1.108.2.9     skrll 
    333  1.108.2.9     skrll 	for (ub = &sc->sc_obuff[0]; ub != &sc->sc_obuff[UCOM_OUT_BUFFS];
    334  1.108.2.9     skrll 	    ub++) {
    335  1.108.2.9     skrll 		error = usbd_create_xfer(sc->sc_bulkout_pipe, sc->sc_obufsize,
    336  1.108.2.9     skrll 		    0, 0, &ub->ub_xfer);
    337  1.108.2.9     skrll 		if (error)
    338  1.108.2.9     skrll 			goto fail_2;
    339  1.108.2.9     skrll 		ub->ub_data = usbd_get_buffer(ub->ub_xfer);
    340  1.108.2.9     skrll 		SIMPLEQ_INSERT_TAIL(&sc->sc_obuff_free, ub, ub_link);
    341  1.108.2.9     skrll 	}
    342  1.108.2.9     skrll 
    343       1.87     rmind 	tp = tty_alloc();
    344       1.12  augustss 	tp->t_oproc = ucomstart;
    345       1.12  augustss 	tp->t_param = ucomparam;
    346       1.82    martin 	tp->t_hwiflow = ucomhwiflow;
    347       1.12  augustss 	sc->sc_tty = tp;
    348       1.12  augustss 
    349  1.108.2.7     skrll 	DPRINTF("tty_attach %p", tp, 0, 0, 0);
    350       1.12  augustss 	tty_attach(tp);
    351       1.12  augustss 
    352       1.85    dyoung 	rnd_attach_source(&sc->sc_rndsource, device_xname(sc->sc_dev),
    353      1.107       tls 			  RND_TYPE_TTY, RND_FLAG_DEFAULT);
    354       1.31  explorer 
    355       1.74       smb 	if (!pmf_device_register(self, NULL, NULL))
    356       1.74       smb 		aprint_error_dev(self, "couldn't establish power handler\n");
    357       1.85    dyoung 	return;
    358  1.108.2.9     skrll 
    359  1.108.2.9     skrll fail_2:
    360  1.108.2.9     skrll 	for (ub = &sc->sc_ibuff[0]; ub != &sc->sc_ibuff[UCOM_IN_BUFFS];
    361  1.108.2.9     skrll 	    ub++) {
    362  1.108.2.9     skrll 		if (ub->ub_xfer)
    363  1.108.2.9     skrll 			usbd_destroy_xfer(ub->ub_xfer);
    364  1.108.2.9     skrll 	}
    365  1.108.2.9     skrll 	for (ub = &sc->sc_obuff[0]; ub != &sc->sc_obuff[UCOM_OUT_BUFFS];
    366  1.108.2.9     skrll 	    ub++) {
    367  1.108.2.9     skrll 		if (ub->ub_xfer)
    368  1.108.2.9     skrll 			usbd_destroy_xfer(ub->ub_xfer);
    369  1.108.2.9     skrll 	}
    370  1.108.2.9     skrll 
    371  1.108.2.9     skrll fail_1:
    372  1.108.2.9     skrll 	usbd_close_pipe(sc->sc_bulkin_pipe);
    373  1.108.2.9     skrll 
    374  1.108.2.9     skrll fail_0:
    375  1.108.2.9     skrll 	aprint_error_dev(self, "attach failed, error=%d\n", error);
    376  1.108.2.9     skrll 
    377  1.108.2.9     skrll 	return;
    378       1.12  augustss }
    379       1.12  augustss 
    380       1.85    dyoung int
    381       1.85    dyoung ucom_detach(device_t self, int flags)
    382       1.12  augustss {
    383       1.77      cube 	struct ucom_softc *sc = device_private(self);
    384       1.36  augustss 	struct tty *tp = sc->sc_tty;
    385       1.12  augustss 	int maj, mn;
    386  1.108.2.8     skrll 	int i;
    387       1.12  augustss 
    388  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
    389  1.108.2.7     skrll 
    390  1.108.2.7     skrll 	DPRINTF("sc=%p flags=%d tp=%p", sc, flags, tp, 0);
    391  1.108.2.7     skrll 	DPRINTF("... pipe=%d,%d",sc->sc_bulkin_no, sc->sc_bulkout_no, 0, 0);
    392       1.12  augustss 
    393  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    394       1.12  augustss 	sc->sc_dying = 1;
    395  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    396  1.108.2.8     skrll 
    397       1.74       smb 	pmf_device_deregister(self);
    398       1.12  augustss 
    399       1.33  augustss 	if (sc->sc_bulkin_pipe != NULL)
    400       1.33  augustss 		usbd_abort_pipe(sc->sc_bulkin_pipe);
    401       1.33  augustss 	if (sc->sc_bulkout_pipe != NULL)
    402       1.33  augustss 		usbd_abort_pipe(sc->sc_bulkout_pipe);
    403       1.12  augustss 
    404  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    405  1.108.2.8     skrll 	while (sc->sc_refcnt > 0) {
    406       1.35  augustss 		/* Wake up anyone waiting */
    407       1.36  augustss 		if (tp != NULL) {
    408       1.71        ad 			mutex_spin_enter(&tty_lock);
    409       1.36  augustss 			CLR(tp->t_state, TS_CARR_ON);
    410       1.36  augustss 			CLR(tp->t_cflag, CLOCAL | MDMBUF);
    411       1.36  augustss 			ttyflush(tp, FREAD|FWRITE);
    412       1.71        ad 			mutex_spin_exit(&tty_lock);
    413       1.36  augustss 		}
    414       1.17  augustss 		/* Wait for processes to go away. */
    415  1.108.2.8     skrll 		usb_detach_wait(sc->sc_dev, &sc->sc_detachcv, sc->sc_lock);
    416       1.17  augustss 	}
    417       1.82    martin 
    418       1.82    martin 	softint_disestablish(sc->sc_si);
    419  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    420       1.12  augustss 
    421       1.12  augustss 	/* locate the major number */
    422       1.44   gehenna 	maj = cdevsw_lookup_major(&ucom_cdevsw);
    423       1.12  augustss 
    424       1.12  augustss 	/* Nuke the vnodes for any open instances. */
    425       1.62   thorpej 	mn = device_unit(self);
    426  1.108.2.7     skrll 	DPRINTF("maj=%d mn=%d\n", maj, mn, 0, 0);
    427       1.12  augustss 	vdevgone(maj, mn, mn, VCHR);
    428       1.22  augustss 	vdevgone(maj, mn | UCOMDIALOUT_MASK, mn | UCOMDIALOUT_MASK, VCHR);
    429       1.22  augustss 	vdevgone(maj, mn | UCOMCALLUNIT_MASK, mn | UCOMCALLUNIT_MASK, VCHR);
    430       1.12  augustss 
    431       1.12  augustss 	/* Detach and free the tty. */
    432       1.36  augustss 	if (tp != NULL) {
    433       1.36  augustss 		tty_detach(tp);
    434       1.87     rmind 		tty_free(tp);
    435       1.33  augustss 		sc->sc_tty = NULL;
    436       1.33  augustss 	}
    437       1.12  augustss 
    438       1.82    martin 	for (i = 0; i < UCOM_IN_BUFFS; i++) {
    439       1.82    martin 		if (sc->sc_ibuff[i].ub_xfer != NULL)
    440  1.108.2.9     skrll 			usbd_destroy_xfer(sc->sc_ibuff[i].ub_xfer);
    441       1.82    martin 	}
    442       1.82    martin 
    443       1.82    martin 	for (i = 0; i < UCOM_OUT_BUFFS; i++) {
    444       1.82    martin 		if (sc->sc_obuff[i].ub_xfer != NULL)
    445  1.108.2.9     skrll 			usbd_destroy_xfer(sc->sc_obuff[i].ub_xfer);
    446       1.82    martin 	}
    447       1.82    martin 
    448       1.31  explorer 	/* Detach the random source */
    449       1.31  explorer 	rnd_detach_source(&sc->sc_rndsource);
    450       1.31  explorer 
    451  1.108.2.8     skrll 	mutex_destroy(sc->sc_lock);
    452  1.108.2.8     skrll 	cv_destroy(&sc->sc_opencv);
    453  1.108.2.8     skrll 	cv_destroy(&sc->sc_detachcv);
    454  1.108.2.8     skrll 
    455  1.108.2.3     skrll 	return 0;
    456       1.12  augustss }
    457       1.12  augustss 
    458       1.12  augustss int
    459       1.85    dyoung ucom_activate(device_t self, enum devact act)
    460       1.12  augustss {
    461       1.77      cube 	struct ucom_softc *sc = device_private(self);
    462       1.12  augustss 
    463  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
    464  1.108.2.7     skrll 
    465  1.108.2.7     skrll 	DPRINTFN(5, "%d", act, 0, 0, 0);
    466       1.34  augustss 
    467       1.12  augustss 	switch (act) {
    468       1.12  augustss 	case DVACT_DEACTIVATE:
    469  1.108.2.8     skrll 		mutex_enter(sc->sc_lock);
    470       1.12  augustss 		sc->sc_dying = 1;
    471  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
    472       1.81    dyoung 		return 0;
    473       1.81    dyoung 	default:
    474       1.81    dyoung 		return EOPNOTSUPP;
    475       1.12  augustss 	}
    476       1.12  augustss }
    477       1.12  augustss 
    478       1.12  augustss void
    479       1.24  augustss ucom_shutdown(struct ucom_softc *sc)
    480       1.12  augustss {
    481       1.12  augustss 	struct tty *tp = sc->sc_tty;
    482       1.12  augustss 
    483  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
    484  1.108.2.7     skrll 
    485  1.108.2.8     skrll 	KASSERT(mutex_owned(sc->sc_lock));
    486       1.12  augustss 	/*
    487       1.12  augustss 	 * Hang up if necessary.  Wait a bit, so the other side has time to
    488       1.12  augustss 	 * notice even if we immediately open the port again.
    489       1.12  augustss 	 */
    490       1.12  augustss 	if (ISSET(tp->t_cflag, HUPCL)) {
    491       1.12  augustss 		ucom_dtr(sc, 0);
    492  1.108.2.8     skrll 		/* XXX will only timeout */
    493  1.108.2.8     skrll 		(void) kpause(ttclos, false, hz, sc->sc_lock);
    494       1.12  augustss 	}
    495       1.12  augustss }
    496       1.12  augustss 
    497       1.12  augustss int
    498       1.69  christos ucomopen(dev_t dev, int flag, int mode, struct lwp *l)
    499       1.12  augustss {
    500       1.12  augustss 	int unit = UCOMUNIT(dev);
    501       1.77      cube 	struct ucom_softc *sc = device_lookup_private(&ucom_cd, unit);
    502       1.82    martin 	struct ucom_buffer *ub;
    503       1.12  augustss 	struct tty *tp;
    504       1.12  augustss 	int error;
    505       1.43  augustss 
    506  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
    507  1.108.2.7     skrll 
    508       1.12  augustss 	if (sc == NULL)
    509  1.108.2.3     skrll 		return ENXIO;
    510       1.12  augustss 
    511  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    512  1.108.2.8     skrll 	if (sc->sc_dying) {
    513  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
    514  1.108.2.3     skrll 		return EIO;
    515  1.108.2.8     skrll 	}
    516       1.12  augustss 
    517  1.108.2.8     skrll 	if (!device_is_active(sc->sc_dev)) {
    518  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
    519  1.108.2.3     skrll 		return ENXIO;
    520  1.108.2.8     skrll 	}
    521       1.12  augustss 
    522       1.12  augustss 	tp = sc->sc_tty;
    523       1.12  augustss 
    524  1.108.2.7     skrll 	DPRINTF("unit=%d, tp=%p\n", unit, tp, 0, 0);
    525       1.12  augustss 
    526  1.108.2.8     skrll 	if (kauth_authorize_device_tty(l->l_cred, KAUTH_DEVICE_TTY_OPEN, tp)) {
    527  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
    528  1.108.2.3     skrll 		return EBUSY;
    529  1.108.2.8     skrll 	}
    530       1.12  augustss 
    531       1.12  augustss 	/*
    532       1.12  augustss 	 * Do the following iff this is a first open.
    533       1.12  augustss 	 */
    534  1.108.2.8     skrll 	while (sc->sc_opening) {
    535  1.108.2.8     skrll 		error = cv_wait_sig(&sc->sc_opencv, sc->sc_lock);
    536       1.17  augustss 
    537  1.108.2.8     skrll 		if (error) {
    538  1.108.2.8     skrll 			mutex_exit(sc->sc_lock);
    539  1.108.2.8     skrll 			return error;
    540  1.108.2.8     skrll 		}
    541       1.17  augustss 	}
    542  1.108.2.8     skrll 
    543       1.12  augustss 	sc->sc_opening = 1;
    544       1.43  augustss 
    545       1.12  augustss 	if (!ISSET(tp->t_state, TS_ISOPEN) && tp->t_wopen == 0) {
    546       1.12  augustss 		struct termios t;
    547       1.12  augustss 
    548       1.12  augustss 		tp->t_dev = dev;
    549       1.12  augustss 
    550       1.22  augustss 		if (sc->sc_methods->ucom_open != NULL) {
    551       1.22  augustss 			error = sc->sc_methods->ucom_open(sc->sc_parent,
    552       1.22  augustss 							  sc->sc_portno);
    553       1.22  augustss 			if (error) {
    554       1.22  augustss 				ucom_cleanup(sc);
    555       1.26    toshii 				sc->sc_opening = 0;
    556  1.108.2.8     skrll 				cv_signal(&sc->sc_opencv);
    557  1.108.2.8     skrll 				mutex_exit(sc->sc_lock);
    558  1.108.2.3     skrll 				return error;
    559       1.22  augustss 			}
    560       1.22  augustss 		}
    561       1.22  augustss 
    562       1.12  augustss 		ucom_status_change(sc);
    563       1.12  augustss 
    564      1.106       gdt 		/* Clear PPS capture state on first open. */
    565      1.106       gdt 		mutex_spin_enter(&timecounter_lock);
    566      1.106       gdt 		memset(&sc->sc_pps_state, 0, sizeof(sc->sc_pps_state));
    567      1.106       gdt 		sc->sc_pps_state.ppscap = PPS_CAPTUREASSERT | PPS_CAPTURECLEAR;
    568      1.106       gdt 		pps_init(&sc->sc_pps_state);
    569      1.106       gdt 		mutex_spin_exit(&timecounter_lock);
    570      1.106       gdt 
    571       1.12  augustss 		/*
    572       1.12  augustss 		 * Initialize the termios status to the defaults.  Add in the
    573       1.12  augustss 		 * sticky bits from TIOCSFLAGS.
    574       1.12  augustss 		 */
    575       1.12  augustss 		t.c_ispeed = 0;
    576       1.12  augustss 		t.c_ospeed = TTYDEF_SPEED;
    577       1.12  augustss 		t.c_cflag = TTYDEF_CFLAG;
    578       1.12  augustss 		if (ISSET(sc->sc_swflags, TIOCFLAG_CLOCAL))
    579       1.12  augustss 			SET(t.c_cflag, CLOCAL);
    580       1.12  augustss 		if (ISSET(sc->sc_swflags, TIOCFLAG_CRTSCTS))
    581       1.12  augustss 			SET(t.c_cflag, CRTSCTS);
    582       1.12  augustss 		if (ISSET(sc->sc_swflags, TIOCFLAG_MDMBUF))
    583       1.12  augustss 			SET(t.c_cflag, MDMBUF);
    584       1.12  augustss 		/* Make sure ucomparam() will do something. */
    585       1.12  augustss 		tp->t_ospeed = 0;
    586       1.12  augustss 		(void) ucomparam(tp, &t);
    587       1.12  augustss 		tp->t_iflag = TTYDEF_IFLAG;
    588       1.12  augustss 		tp->t_oflag = TTYDEF_OFLAG;
    589       1.12  augustss 		tp->t_lflag = TTYDEF_LFLAG;
    590       1.12  augustss 		ttychars(tp);
    591       1.12  augustss 		ttsetwater(tp);
    592       1.12  augustss 
    593       1.12  augustss 		/*
    594       1.12  augustss 		 * Turn on DTR.  We must always do this, even if carrier is not
    595       1.12  augustss 		 * present, because otherwise we'd have to use TIOCSDTR
    596       1.12  augustss 		 * immediately after setting CLOCAL, which applications do not
    597       1.12  augustss 		 * expect.  We always assert DTR while the device is open
    598       1.64      gson 		 * unless explicitly requested to deassert it.  Ditto RTS.
    599       1.12  augustss 		 */
    600       1.12  augustss 		ucom_dtr(sc, 1);
    601      1.102  jakllsch 		ucom_rts(sc, 1);
    602       1.12  augustss 
    603       1.82    martin 		sc->sc_rx_unblock = 0;
    604       1.82    martin 		sc->sc_rx_stopped = 0;
    605       1.82    martin 		sc->sc_tx_stopped = 0;
    606       1.82    martin 
    607       1.82    martin 		for (ub = &sc->sc_ibuff[0]; ub != &sc->sc_ibuff[UCOM_IN_BUFFS];
    608       1.82    martin 		    ub++) {
    609       1.82    martin 			if (ucomsubmitread(sc, ub) != USBD_NORMAL_COMPLETION) {
    610       1.82    martin 				error = EIO;
    611       1.82    martin 				goto fail_2;
    612       1.82    martin 			}
    613       1.28    toshii 		}
    614       1.12  augustss 	}
    615       1.12  augustss 	sc->sc_opening = 0;
    616  1.108.2.8     skrll 	cv_signal(&sc->sc_opencv);
    617  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    618       1.12  augustss 
    619       1.12  augustss 	error = ttyopen(tp, UCOMDIALOUT(dev), ISSET(flag, O_NONBLOCK));
    620       1.12  augustss 	if (error)
    621       1.12  augustss 		goto bad;
    622       1.12  augustss 
    623       1.32       eeh 	error = (*tp->t_linesw->l_open)(dev, tp);
    624       1.12  augustss 	if (error)
    625       1.12  augustss 		goto bad;
    626       1.12  augustss 
    627  1.108.2.3     skrll 	return 0;
    628       1.26    toshii 
    629       1.26    toshii fail_2:
    630       1.82    martin 	usbd_abort_pipe(sc->sc_bulkin_pipe);
    631       1.82    martin 	usbd_abort_pipe(sc->sc_bulkout_pipe);
    632       1.82    martin 
    633  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    634       1.26    toshii 	sc->sc_opening = 0;
    635  1.108.2.8     skrll 	cv_signal(&sc->sc_opencv);
    636  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    637  1.108.2.8     skrll 
    638  1.108.2.3     skrll 	return error;
    639       1.12  augustss 
    640       1.12  augustss bad:
    641  1.108.2.8     skrll 	mutex_spin_enter(&tty_lock);
    642       1.82    martin 	CLR(tp->t_state, TS_BUSY);
    643       1.12  augustss 	if (!ISSET(tp->t_state, TS_ISOPEN) && tp->t_wopen == 0) {
    644       1.12  augustss 		/*
    645       1.12  augustss 		 * We failed to open the device, and nobody else had it opened.
    646       1.12  augustss 		 * Clean up the state as appropriate.
    647       1.12  augustss 		 */
    648       1.12  augustss 		ucom_cleanup(sc);
    649       1.12  augustss 	}
    650  1.108.2.8     skrll 	mutex_spin_exit(&tty_lock);
    651       1.12  augustss 
    652  1.108.2.3     skrll 	return error;
    653       1.12  augustss }
    654       1.12  augustss 
    655       1.12  augustss int
    656       1.69  christos ucomclose(dev_t dev, int flag, int mode, struct lwp *l)
    657       1.12  augustss {
    658       1.77      cube 	struct ucom_softc *sc = device_lookup_private(&ucom_cd, UCOMUNIT(dev));
    659      1.101  jakllsch 	struct tty *tp;
    660       1.12  augustss 
    661  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
    662  1.108.2.7     skrll 
    663  1.108.2.7     skrll 	DPRINTF("unit=%d", UCOMUNIT(dev), 0, 0, 0);
    664      1.101  jakllsch 
    665      1.101  jakllsch 	if (sc == NULL)
    666      1.101  jakllsch 		return 0;
    667      1.101  jakllsch 
    668  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    669      1.101  jakllsch 	tp = sc->sc_tty;
    670      1.101  jakllsch 
    671  1.108.2.8     skrll 	if (!ISSET(tp->t_state, TS_ISOPEN)) {
    672  1.108.2.8     skrll 		goto out;
    673  1.108.2.8     skrll 	}
    674       1.12  augustss 
    675       1.17  augustss 	sc->sc_refcnt++;
    676       1.17  augustss 
    677       1.32       eeh 	(*tp->t_linesw->l_close)(tp, flag);
    678       1.12  augustss 	ttyclose(tp);
    679       1.12  augustss 
    680       1.12  augustss 	if (!ISSET(tp->t_state, TS_ISOPEN) && tp->t_wopen == 0) {
    681       1.12  augustss 		/*
    682       1.12  augustss 		 * Although we got a last close, the device may still be in
    683       1.12  augustss 		 * use; e.g. if this was the dialout node, and there are still
    684       1.12  augustss 		 * processes waiting for carrier on the non-dialout node.
    685       1.12  augustss 		 */
    686       1.12  augustss 		ucom_cleanup(sc);
    687       1.12  augustss 	}
    688       1.12  augustss 
    689       1.14  augustss 	if (sc->sc_methods->ucom_close != NULL)
    690       1.14  augustss 		sc->sc_methods->ucom_close(sc->sc_parent, sc->sc_portno);
    691       1.14  augustss 
    692       1.17  augustss 	if (--sc->sc_refcnt < 0)
    693  1.108.2.8     skrll 		usb_detach_broadcast(sc->sc_dev, &sc->sc_detachcv);
    694  1.108.2.8     skrll 
    695  1.108.2.8     skrll out:
    696  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    697       1.17  augustss 
    698  1.108.2.3     skrll 	return 0;
    699       1.12  augustss }
    700       1.43  augustss 
    701       1.12  augustss int
    702       1.24  augustss ucomread(dev_t dev, struct uio *uio, int flag)
    703       1.12  augustss {
    704       1.77      cube 	struct ucom_softc *sc = device_lookup_private(&ucom_cd, UCOMUNIT(dev));
    705      1.101  jakllsch 	struct tty *tp;
    706       1.17  augustss 	int error;
    707       1.12  augustss 
    708  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
    709  1.108.2.7     skrll 
    710  1.108.2.8     skrll 	if (sc == NULL)
    711  1.108.2.8     skrll 		return EIO;
    712  1.108.2.8     skrll 
    713  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    714  1.108.2.8     skrll 	if (sc->sc_dying) {
    715  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
    716  1.108.2.3     skrll 		return EIO;
    717  1.108.2.8     skrll 	}
    718       1.43  augustss 
    719      1.101  jakllsch 	tp = sc->sc_tty;
    720      1.101  jakllsch 
    721       1.17  augustss 	sc->sc_refcnt++;
    722  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    723       1.32       eeh 	error = ((*tp->t_linesw->l_read)(tp, uio, flag));
    724  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    725  1.108.2.8     skrll 
    726       1.17  augustss 	if (--sc->sc_refcnt < 0)
    727  1.108.2.8     skrll 		usb_detach_broadcast(sc->sc_dev, &sc->sc_detachcv);
    728  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    729  1.108.2.8     skrll 
    730  1.108.2.3     skrll 	return error;
    731       1.12  augustss }
    732       1.43  augustss 
    733       1.12  augustss int
    734       1.24  augustss ucomwrite(dev_t dev, struct uio *uio, int flag)
    735       1.12  augustss {
    736       1.77      cube 	struct ucom_softc *sc = device_lookup_private(&ucom_cd, UCOMUNIT(dev));
    737      1.101  jakllsch 	struct tty *tp;
    738       1.17  augustss 	int error;
    739       1.12  augustss 
    740  1.108.2.8     skrll 	if (sc == NULL)
    741  1.108.2.8     skrll 		return EIO;
    742  1.108.2.8     skrll 
    743  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    744  1.108.2.8     skrll 	if (sc->sc_dying) {
    745  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
    746  1.108.2.3     skrll 		return EIO;
    747  1.108.2.8     skrll 	}
    748       1.43  augustss 
    749      1.101  jakllsch 	tp = sc->sc_tty;
    750      1.101  jakllsch 
    751       1.17  augustss 	sc->sc_refcnt++;
    752  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    753       1.32       eeh 	error = ((*tp->t_linesw->l_write)(tp, uio, flag));
    754  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    755       1.38       scw 	if (--sc->sc_refcnt < 0)
    756  1.108.2.8     skrll 		usb_detach_broadcast(sc->sc_dev, &sc->sc_detachcv);
    757  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    758  1.108.2.8     skrll 
    759  1.108.2.3     skrll 	return error;
    760       1.38       scw }
    761       1.38       scw 
    762       1.38       scw int
    763       1.60  christos ucompoll(dev_t dev, int events, struct lwp *l)
    764       1.38       scw {
    765       1.94  jakllsch 	struct ucom_softc *sc;
    766       1.94  jakllsch 	struct tty *tp;
    767       1.56        ws 	int revents;
    768       1.38       scw 
    769       1.94  jakllsch 	sc = device_lookup_private(&ucom_cd, UCOMUNIT(dev));
    770  1.108.2.8     skrll 	if (sc == NULL)
    771  1.108.2.3     skrll 		return POLLHUP;
    772       1.43  augustss 
    773  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    774  1.108.2.8     skrll 	if (sc->sc_dying) {
    775  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
    776  1.108.2.8     skrll 		return POLLHUP;
    777  1.108.2.8     skrll 	}
    778       1.94  jakllsch 	tp = sc->sc_tty;
    779       1.94  jakllsch 
    780       1.38       scw 	sc->sc_refcnt++;
    781  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    782       1.60  christos 	revents = ((*tp->t_linesw->l_poll)(tp, events, l));
    783  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    784       1.17  augustss 	if (--sc->sc_refcnt < 0)
    785  1.108.2.8     skrll 		usb_detach_broadcast(sc->sc_dev, &sc->sc_detachcv);
    786  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    787  1.108.2.8     skrll 
    788  1.108.2.3     skrll 	return revents;
    789       1.12  augustss }
    790       1.12  augustss 
    791       1.12  augustss struct tty *
    792       1.24  augustss ucomtty(dev_t dev)
    793       1.12  augustss {
    794       1.77      cube 	struct ucom_softc *sc = device_lookup_private(&ucom_cd, UCOMUNIT(dev));
    795       1.12  augustss 
    796  1.108.2.4     skrll 	return sc != NULL ? sc->sc_tty : NULL;
    797       1.12  augustss }
    798       1.12  augustss 
    799       1.12  augustss int
    800       1.70  christos ucomioctl(dev_t dev, u_long cmd, void *data, int flag, struct lwp *l)
    801       1.12  augustss {
    802       1.77      cube 	struct ucom_softc *sc = device_lookup_private(&ucom_cd, UCOMUNIT(dev));
    803       1.17  augustss 	int error;
    804       1.17  augustss 
    805  1.108.2.8     skrll 	if (sc == NULL)
    806  1.108.2.3     skrll 		return EIO;
    807      1.101  jakllsch 
    808  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
    809  1.108.2.8     skrll 	if (sc->sc_dying) {
    810  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
    811  1.108.2.8     skrll 		return EIO;
    812  1.108.2.8     skrll 	}
    813  1.108.2.8     skrll 
    814       1.17  augustss 	sc->sc_refcnt++;
    815       1.60  christos 	error = ucom_do_ioctl(sc, cmd, data, flag, l);
    816       1.17  augustss 	if (--sc->sc_refcnt < 0)
    817  1.108.2.8     skrll 		usb_detach_broadcast(sc->sc_dev, &sc->sc_detachcv);
    818  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
    819  1.108.2.3     skrll 	return error;
    820       1.17  augustss }
    821       1.17  augustss 
    822       1.82    martin static int
    823       1.70  christos ucom_do_ioctl(struct ucom_softc *sc, u_long cmd, void *data,
    824       1.60  christos 	      int flag, struct lwp *l)
    825       1.17  augustss {
    826       1.12  augustss 	struct tty *tp = sc->sc_tty;
    827       1.12  augustss 	int error;
    828       1.12  augustss 
    829  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
    830  1.108.2.7     skrll 
    831  1.108.2.7     skrll 	DPRINTF("cmd=0x%08lx", cmd, 0, 0, 0);
    832       1.12  augustss 
    833       1.60  christos 	error = (*tp->t_linesw->l_ioctl)(tp, cmd, data, flag, l);
    834       1.42    atatat 	if (error != EPASSTHROUGH)
    835  1.108.2.3     skrll 		return error;
    836       1.12  augustss 
    837       1.60  christos 	error = ttioctl(tp, cmd, data, flag, l);
    838       1.42    atatat 	if (error != EPASSTHROUGH)
    839  1.108.2.3     skrll 		return error;
    840       1.12  augustss 
    841       1.12  augustss 	if (sc->sc_methods->ucom_ioctl != NULL) {
    842       1.12  augustss 		error = sc->sc_methods->ucom_ioctl(sc->sc_parent,
    843       1.60  christos 			    sc->sc_portno, cmd, data, flag, l->l_proc);
    844       1.42    atatat 		if (error != EPASSTHROUGH)
    845  1.108.2.3     skrll 			return error;
    846       1.12  augustss 	}
    847       1.12  augustss 
    848       1.12  augustss 	error = 0;
    849       1.12  augustss 
    850  1.108.2.7     skrll 	DPRINTF("our cmd=0x%08lx", cmd, 0, 0, 0);
    851  1.108.2.8     skrll 	//mutex_enter(&tty_lock);
    852       1.12  augustss 
    853       1.12  augustss 	switch (cmd) {
    854       1.12  augustss 	case TIOCSBRK:
    855       1.12  augustss 		ucom_break(sc, 1);
    856       1.12  augustss 		break;
    857       1.12  augustss 
    858       1.12  augustss 	case TIOCCBRK:
    859       1.12  augustss 		ucom_break(sc, 0);
    860       1.12  augustss 		break;
    861       1.12  augustss 
    862       1.12  augustss 	case TIOCSDTR:
    863       1.12  augustss 		ucom_dtr(sc, 1);
    864       1.12  augustss 		break;
    865       1.12  augustss 
    866       1.12  augustss 	case TIOCCDTR:
    867       1.12  augustss 		ucom_dtr(sc, 0);
    868       1.12  augustss 		break;
    869       1.12  augustss 
    870       1.12  augustss 	case TIOCGFLAGS:
    871       1.12  augustss 		*(int *)data = sc->sc_swflags;
    872       1.12  augustss 		break;
    873       1.12  augustss 
    874       1.12  augustss 	case TIOCSFLAGS:
    875       1.67      elad 		error = kauth_authorize_device_tty(l->l_cred,
    876       1.67      elad 		    KAUTH_DEVICE_TTY_PRIVSET, tp);
    877       1.12  augustss 		if (error)
    878       1.12  augustss 			break;
    879       1.12  augustss 		sc->sc_swflags = *(int *)data;
    880       1.12  augustss 		break;
    881       1.12  augustss 
    882       1.12  augustss 	case TIOCMSET:
    883       1.12  augustss 	case TIOCMBIS:
    884       1.12  augustss 	case TIOCMBIC:
    885       1.12  augustss 		tiocm_to_ucom(sc, cmd, *(int *)data);
    886       1.12  augustss 		break;
    887       1.12  augustss 
    888       1.12  augustss 	case TIOCMGET:
    889       1.12  augustss 		*(int *)data = ucom_to_tiocm(sc);
    890       1.12  augustss 		break;
    891       1.12  augustss 
    892      1.106       gdt 	case PPS_IOC_CREATE:
    893      1.106       gdt 	case PPS_IOC_DESTROY:
    894      1.106       gdt 	case PPS_IOC_GETPARAMS:
    895      1.106       gdt 	case PPS_IOC_SETPARAMS:
    896      1.106       gdt 	case PPS_IOC_GETCAP:
    897      1.106       gdt 	case PPS_IOC_FETCH:
    898      1.106       gdt #ifdef PPS_SYNC
    899      1.106       gdt 	case PPS_IOC_KCBIND:
    900      1.106       gdt #endif
    901      1.106       gdt 		mutex_spin_enter(&timecounter_lock);
    902      1.106       gdt 		error = pps_ioctl(cmd, data, &sc->sc_pps_state);
    903      1.106       gdt 		mutex_spin_exit(&timecounter_lock);
    904      1.106       gdt 		break;
    905      1.106       gdt 
    906       1.12  augustss 	default:
    907       1.42    atatat 		error = EPASSTHROUGH;
    908       1.12  augustss 		break;
    909       1.12  augustss 	}
    910       1.12  augustss 
    911  1.108.2.8     skrll 	//mutex_exit(&tty_lock);
    912       1.12  augustss 
    913  1.108.2.3     skrll 	return error;
    914       1.12  augustss }
    915       1.12  augustss 
    916       1.82    martin static void
    917       1.29    toshii tiocm_to_ucom(struct ucom_softc *sc, u_long how, int ttybits)
    918       1.12  augustss {
    919       1.12  augustss 	u_char combits;
    920        1.3  augustss 
    921       1.12  augustss 	combits = 0;
    922       1.12  augustss 	if (ISSET(ttybits, TIOCM_DTR))
    923       1.12  augustss 		SET(combits, UMCR_DTR);
    924       1.12  augustss 	if (ISSET(ttybits, TIOCM_RTS))
    925       1.12  augustss 		SET(combits, UMCR_RTS);
    926       1.43  augustss 
    927       1.12  augustss 	switch (how) {
    928       1.12  augustss 	case TIOCMBIC:
    929       1.12  augustss 		CLR(sc->sc_mcr, combits);
    930       1.12  augustss 		break;
    931       1.12  augustss 
    932       1.12  augustss 	case TIOCMBIS:
    933       1.12  augustss 		SET(sc->sc_mcr, combits);
    934       1.12  augustss 		break;
    935       1.12  augustss 
    936       1.12  augustss 	case TIOCMSET:
    937       1.12  augustss 		CLR(sc->sc_mcr, UMCR_DTR | UMCR_RTS);
    938       1.12  augustss 		SET(sc->sc_mcr, combits);
    939       1.12  augustss 		break;
    940       1.12  augustss 	}
    941       1.12  augustss 
    942       1.27    toshii 	if (how == TIOCMSET || ISSET(combits, UMCR_DTR))
    943       1.27    toshii 		ucom_dtr(sc, (sc->sc_mcr & UMCR_DTR) != 0);
    944       1.27    toshii 	if (how == TIOCMSET || ISSET(combits, UMCR_RTS))
    945       1.27    toshii 		ucom_rts(sc, (sc->sc_mcr & UMCR_RTS) != 0);
    946       1.12  augustss }
    947       1.12  augustss 
    948       1.82    martin static int
    949       1.24  augustss ucom_to_tiocm(struct ucom_softc *sc)
    950       1.12  augustss {
    951       1.12  augustss 	u_char combits;
    952       1.12  augustss 	int ttybits = 0;
    953       1.12  augustss 
    954       1.12  augustss 	combits = sc->sc_mcr;
    955       1.12  augustss 	if (ISSET(combits, UMCR_DTR))
    956       1.12  augustss 		SET(ttybits, TIOCM_DTR);
    957       1.12  augustss 	if (ISSET(combits, UMCR_RTS))
    958       1.12  augustss 		SET(ttybits, TIOCM_RTS);
    959       1.12  augustss 
    960       1.12  augustss 	combits = sc->sc_msr;
    961       1.12  augustss 	if (ISSET(combits, UMSR_DCD))
    962       1.12  augustss 		SET(ttybits, TIOCM_CD);
    963       1.12  augustss 	if (ISSET(combits, UMSR_CTS))
    964       1.12  augustss 		SET(ttybits, TIOCM_CTS);
    965       1.12  augustss 	if (ISSET(combits, UMSR_DSR))
    966       1.12  augustss 		SET(ttybits, TIOCM_DSR);
    967       1.12  augustss 	if (ISSET(combits, UMSR_RI | UMSR_TERI))
    968       1.12  augustss 		SET(ttybits, TIOCM_RI);
    969       1.12  augustss 
    970       1.12  augustss #if 0
    971       1.12  augustss XXX;
    972       1.12  augustss 	if (sc->sc_ier != 0)
    973       1.12  augustss 		SET(ttybits, TIOCM_LE);
    974       1.12  augustss #endif
    975       1.12  augustss 
    976  1.108.2.3     skrll 	return ttybits;
    977       1.12  augustss }
    978       1.12  augustss 
    979       1.82    martin static void
    980       1.77      cube ucom_break(struct ucom_softc *sc, int onoff)
    981       1.12  augustss {
    982  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
    983  1.108.2.7     skrll 
    984  1.108.2.7     skrll 	DPRINTF("onoff=%d", onoff, 0, 0, 0);
    985       1.12  augustss 
    986       1.14  augustss 	if (sc->sc_methods->ucom_set != NULL)
    987       1.14  augustss 		sc->sc_methods->ucom_set(sc->sc_parent, sc->sc_portno,
    988       1.14  augustss 		    UCOM_SET_BREAK, onoff);
    989       1.12  augustss }
    990       1.12  augustss 
    991       1.82    martin static void
    992       1.24  augustss ucom_dtr(struct ucom_softc *sc, int onoff)
    993       1.12  augustss {
    994  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
    995  1.108.2.7     skrll 
    996  1.108.2.7     skrll 	DPRINTF("onoff=%d", onoff, 0, 0, 0);
    997       1.12  augustss 
    998       1.14  augustss 	if (sc->sc_methods->ucom_set != NULL)
    999       1.43  augustss 		sc->sc_methods->ucom_set(sc->sc_parent, sc->sc_portno,
   1000       1.14  augustss 		    UCOM_SET_DTR, onoff);
   1001       1.12  augustss }
   1002       1.12  augustss 
   1003       1.82    martin static void
   1004       1.24  augustss ucom_rts(struct ucom_softc *sc, int onoff)
   1005       1.12  augustss {
   1006  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
   1007  1.108.2.7     skrll 
   1008  1.108.2.7     skrll 	DPRINTF("onoff=%d", onoff, 0, 0, 0);
   1009       1.12  augustss 
   1010       1.14  augustss 	if (sc->sc_methods->ucom_set != NULL)
   1011       1.43  augustss 		sc->sc_methods->ucom_set(sc->sc_parent, sc->sc_portno,
   1012       1.14  augustss 		    UCOM_SET_RTS, onoff);
   1013       1.12  augustss }
   1014       1.12  augustss 
   1015       1.22  augustss void
   1016       1.24  augustss ucom_status_change(struct ucom_softc *sc)
   1017       1.12  augustss {
   1018       1.27    toshii 	struct tty *tp = sc->sc_tty;
   1019       1.27    toshii 	u_char old_msr;
   1020       1.27    toshii 
   1021       1.14  augustss 	if (sc->sc_methods->ucom_get_status != NULL) {
   1022       1.27    toshii 		old_msr = sc->sc_msr;
   1023       1.14  augustss 		sc->sc_methods->ucom_get_status(sc->sc_parent, sc->sc_portno,
   1024       1.14  augustss 		    &sc->sc_lsr, &sc->sc_msr);
   1025      1.106       gdt 		if (ISSET((sc->sc_msr ^ old_msr), UMSR_DCD)) {
   1026      1.106       gdt 			mutex_spin_enter(&timecounter_lock);
   1027      1.106       gdt 			pps_capture(&sc->sc_pps_state);
   1028      1.106       gdt 			pps_event(&sc->sc_pps_state,
   1029      1.106       gdt 			    (sc->sc_msr & UMSR_DCD) ?
   1030      1.106       gdt 			    PPS_CAPTUREASSERT :
   1031      1.106       gdt 			    PPS_CAPTURECLEAR);
   1032      1.106       gdt 			mutex_spin_exit(&timecounter_lock);
   1033      1.106       gdt 
   1034       1.32       eeh 			(*tp->t_linesw->l_modem)(tp,
   1035       1.27    toshii 			    ISSET(sc->sc_msr, UMSR_DCD));
   1036      1.106       gdt 		}
   1037       1.14  augustss 	} else {
   1038       1.14  augustss 		sc->sc_lsr = 0;
   1039       1.54  augustss 		/* Assume DCD is present, if we have no chance to check it. */
   1040       1.54  augustss 		sc->sc_msr = UMSR_DCD;
   1041       1.14  augustss 	}
   1042       1.12  augustss }
   1043       1.12  augustss 
   1044       1.82    martin static int
   1045       1.24  augustss ucomparam(struct tty *tp, struct termios *t)
   1046       1.12  augustss {
   1047       1.77      cube 	struct ucom_softc *sc = device_lookup_private(&ucom_cd,
   1048       1.77      cube 	    UCOMUNIT(tp->t_dev));
   1049       1.14  augustss 	int error;
   1050       1.12  augustss 
   1051  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
   1052  1.108.2.7     skrll 
   1053      1.101  jakllsch 	if (sc == NULL || sc->sc_dying)
   1054  1.108.2.3     skrll 		return EIO;
   1055       1.12  augustss 
   1056       1.12  augustss 	/* Check requested parameters. */
   1057       1.12  augustss 	if (t->c_ispeed && t->c_ispeed != t->c_ospeed)
   1058  1.108.2.3     skrll 		return EINVAL;
   1059       1.12  augustss 
   1060       1.12  augustss 	/*
   1061       1.12  augustss 	 * For the console, always force CLOCAL and !HUPCL, so that the port
   1062       1.12  augustss 	 * is always active.
   1063       1.12  augustss 	 */
   1064       1.12  augustss 	if (ISSET(sc->sc_swflags, TIOCFLAG_SOFTCAR)) {
   1065       1.12  augustss 		SET(t->c_cflag, CLOCAL);
   1066       1.12  augustss 		CLR(t->c_cflag, HUPCL);
   1067       1.12  augustss 	}
   1068       1.12  augustss 
   1069       1.12  augustss 	/*
   1070       1.12  augustss 	 * If there were no changes, don't do anything.  This avoids dropping
   1071       1.12  augustss 	 * input and improves performance when all we did was frob things like
   1072       1.12  augustss 	 * VMIN and VTIME.
   1073       1.12  augustss 	 */
   1074       1.12  augustss 	if (tp->t_ospeed == t->c_ospeed &&
   1075       1.12  augustss 	    tp->t_cflag == t->c_cflag)
   1076  1.108.2.3     skrll 		return 0;
   1077       1.12  augustss 
   1078       1.30  augustss 	/* XXX lcr = ISSET(sc->sc_lcr, LCR_SBREAK) | cflag2lcr(t->c_cflag); */
   1079       1.12  augustss 
   1080       1.12  augustss 	/* And copy to tty. */
   1081       1.12  augustss 	tp->t_ispeed = 0;
   1082       1.12  augustss 	tp->t_ospeed = t->c_ospeed;
   1083       1.12  augustss 	tp->t_cflag = t->c_cflag;
   1084       1.12  augustss 
   1085       1.14  augustss 	if (sc->sc_methods->ucom_param != NULL) {
   1086       1.14  augustss 		error = sc->sc_methods->ucom_param(sc->sc_parent, sc->sc_portno,
   1087       1.14  augustss 			    t);
   1088       1.14  augustss 		if (error)
   1089  1.108.2.3     skrll 			return error;
   1090       1.14  augustss 	}
   1091       1.12  augustss 
   1092       1.30  augustss 	/* XXX worry about CHWFLOW */
   1093       1.12  augustss 
   1094       1.12  augustss 	/*
   1095       1.12  augustss 	 * Update the tty layer's idea of the carrier bit, in case we changed
   1096       1.12  augustss 	 * CLOCAL or MDMBUF.  We don't hang up here; we only do that by
   1097       1.12  augustss 	 * explicit request.
   1098       1.12  augustss 	 */
   1099  1.108.2.7     skrll 	DPRINTF("l_modem", 0, 0, 0, 0);
   1100       1.54  augustss 	(void) (*tp->t_linesw->l_modem)(tp, ISSET(sc->sc_msr, UMSR_DCD));
   1101       1.12  augustss 
   1102       1.12  augustss #if 0
   1103       1.12  augustss XXX what if the hardware is not open
   1104       1.12  augustss 	if (!ISSET(t->c_cflag, CHWFLOW)) {
   1105       1.12  augustss 		if (sc->sc_tx_stopped) {
   1106       1.12  augustss 			sc->sc_tx_stopped = 0;
   1107       1.12  augustss 			ucomstart(tp);
   1108       1.12  augustss 		}
   1109       1.12  augustss 	}
   1110       1.12  augustss #endif
   1111       1.12  augustss 
   1112  1.108.2.3     skrll 	return 0;
   1113       1.12  augustss }
   1114       1.12  augustss 
   1115       1.82    martin static int
   1116       1.82    martin ucomhwiflow(struct tty *tp, int block)
   1117       1.12  augustss {
   1118       1.82    martin 	struct ucom_softc *sc = device_lookup_private(&ucom_cd,
   1119       1.82    martin 	    UCOMUNIT(tp->t_dev));
   1120       1.82    martin 	int old;
   1121       1.12  augustss 
   1122      1.101  jakllsch 	if (sc == NULL)
   1123  1.108.2.3     skrll 		return 0;
   1124      1.101  jakllsch 
   1125  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
   1126       1.82    martin 	old = sc->sc_rx_stopped;
   1127       1.82    martin 	sc->sc_rx_stopped = (u_char)block;
   1128       1.12  augustss 
   1129       1.82    martin 	if (old && !block) {
   1130       1.82    martin 		sc->sc_rx_unblock = 1;
   1131       1.82    martin 		softint_schedule(sc->sc_si);
   1132       1.12  augustss 	}
   1133  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
   1134       1.82    martin 
   1135  1.108.2.3     skrll 	return 1;
   1136        1.1  augustss }
   1137        1.3  augustss 
   1138       1.82    martin static void
   1139       1.24  augustss ucomstart(struct tty *tp)
   1140       1.12  augustss {
   1141       1.77      cube 	struct ucom_softc *sc = device_lookup_private(&ucom_cd,
   1142       1.77      cube 	    UCOMUNIT(tp->t_dev));
   1143       1.82    martin 	struct ucom_buffer *ub;
   1144       1.12  augustss 	u_char *data;
   1145       1.12  augustss 	int cnt;
   1146       1.12  augustss 
   1147  1.108.2.8     skrll 	if (sc == NULL)
   1148       1.12  augustss 		return;
   1149       1.12  augustss 
   1150  1.108.2.8     skrll 	KASSERT(sc->sc_lock);
   1151  1.108.2.8     skrll 	KASSERT(mutex_owned(&tty_lock));
   1152  1.108.2.8     skrll 	if (sc->sc_dying) {
   1153  1.108.2.8     skrll 		return;
   1154  1.108.2.8     skrll 	}
   1155  1.108.2.8     skrll 
   1156       1.84  christos 	if (ISSET(tp->t_state, TS_BUSY | TS_TIMEOUT | TS_TTSTOP))
   1157       1.12  augustss 		goto out;
   1158       1.12  augustss 	if (sc->sc_tx_stopped)
   1159       1.12  augustss 		goto out;
   1160       1.12  augustss 
   1161       1.82    martin 	if (!ttypull(tp))
   1162       1.73        ad 		goto out;
   1163       1.12  augustss 
   1164       1.12  augustss 	/* Grab the first contiguous region of buffer space. */
   1165       1.12  augustss 	data = tp->t_outq.c_cf;
   1166       1.12  augustss 	cnt = ndqb(&tp->t_outq, 0);
   1167       1.12  augustss 
   1168       1.84  christos 	if (cnt == 0)
   1169       1.12  augustss 		goto out;
   1170       1.12  augustss 
   1171       1.82    martin 	ub = SIMPLEQ_FIRST(&sc->sc_obuff_free);
   1172      1.100   mlelstv 	if (ub == NULL) {
   1173      1.100   mlelstv 		SET(tp->t_state, TS_BUSY);
   1174      1.100   mlelstv 		goto out;
   1175      1.100   mlelstv 	}
   1176  1.108.2.8     skrll 
   1177       1.82    martin 	SIMPLEQ_REMOVE_HEAD(&sc->sc_obuff_free, ub_link);
   1178       1.12  augustss 
   1179       1.82    martin 	if (SIMPLEQ_FIRST(&sc->sc_obuff_free) == NULL)
   1180       1.82    martin 		SET(tp->t_state, TS_BUSY);
   1181       1.82    martin 
   1182       1.82    martin 	if (cnt > sc->sc_obufsize)
   1183       1.19  augustss 		cnt = sc->sc_obufsize;
   1184       1.82    martin 
   1185       1.22  augustss 	if (sc->sc_methods->ucom_write != NULL)
   1186       1.22  augustss 		sc->sc_methods->ucom_write(sc->sc_parent, sc->sc_portno,
   1187       1.82    martin 					   ub->ub_data, data, &cnt);
   1188       1.22  augustss 	else
   1189       1.82    martin 		memcpy(ub->ub_data, data, cnt);
   1190       1.82    martin 
   1191       1.82    martin 	ub->ub_len = cnt;
   1192       1.82    martin 	ub->ub_index = 0;
   1193       1.12  augustss 
   1194       1.82    martin 	SIMPLEQ_INSERT_TAIL(&sc->sc_obuff_full, ub, ub_link);
   1195       1.82    martin 
   1196       1.82    martin 	softint_schedule(sc->sc_si);
   1197        1.3  augustss 
   1198       1.82    martin  out:
   1199  1.108.2.8     skrll 	return;
   1200       1.12  augustss }
   1201       1.12  augustss 
   1202       1.21    itojun void
   1203       1.69  christos ucomstop(struct tty *tp, int flag)
   1204       1.12  augustss {
   1205       1.19  augustss #if 0
   1206  1.108.2.8     skrll 	struct ucom_softc *sc =
   1207  1.108.2.8     skrll 	    device_lookup_private(&ucom_cd, UCOMUNIT(tp->t_dev));
   1208       1.12  augustss 
   1209  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
   1210  1.108.2.8     skrll 	mutex_spin_enter(&tty_lock);
   1211       1.12  augustss 	if (ISSET(tp->t_state, TS_BUSY)) {
   1212  1.108.2.8     skrll 		/* obuff_full -> obuff_free? */
   1213       1.19  augustss 		/* sc->sc_tx_stopped = 1; */
   1214       1.12  augustss 		if (!ISSET(tp->t_state, TS_TTSTOP))
   1215       1.12  augustss 			SET(tp->t_state, TS_FLUSH);
   1216       1.12  augustss 	}
   1217  1.108.2.8     skrll 	mutex_spin_exit(&tty_lock);
   1218  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
   1219       1.19  augustss #endif
   1220       1.12  augustss }
   1221       1.12  augustss 
   1222       1.82    martin static void
   1223       1.82    martin ucom_write_status(struct ucom_softc *sc, struct ucom_buffer *ub,
   1224       1.82    martin     usbd_status err)
   1225       1.82    martin {
   1226       1.82    martin 	struct tty *tp = sc->sc_tty;
   1227       1.82    martin 	uint32_t cc = ub->ub_len;
   1228       1.82    martin 
   1229  1.108.2.8     skrll 	KASSERT(mutex_owned(sc->sc_lock));
   1230  1.108.2.8     skrll 
   1231       1.82    martin 	switch (err) {
   1232       1.82    martin 	case USBD_IN_PROGRESS:
   1233       1.82    martin 		ub->ub_index = ub->ub_len;
   1234       1.82    martin 		break;
   1235       1.82    martin 	case USBD_STALLED:
   1236       1.82    martin 		ub->ub_index = 0;
   1237       1.82    martin 		softint_schedule(sc->sc_si);
   1238       1.82    martin 		break;
   1239       1.82    martin 	case USBD_NORMAL_COMPLETION:
   1240       1.82    martin 		usbd_get_xfer_status(ub->ub_xfer, NULL, NULL, &cc, NULL);
   1241       1.82    martin 		rnd_add_uint32(&sc->sc_rndsource, cc);
   1242       1.82    martin 		/*FALLTHROUGH*/
   1243       1.82    martin 	default:
   1244       1.82    martin 		SIMPLEQ_REMOVE_HEAD(&sc->sc_obuff_full, ub_link);
   1245       1.82    martin 		SIMPLEQ_INSERT_TAIL(&sc->sc_obuff_free, ub, ub_link);
   1246       1.82    martin 		cc -= sc->sc_opkthdrlen;
   1247       1.82    martin 
   1248      1.100   mlelstv 		mutex_spin_enter(&tty_lock);
   1249       1.82    martin 		CLR(tp->t_state, TS_BUSY);
   1250       1.82    martin 		if (ISSET(tp->t_state, TS_FLUSH))
   1251       1.82    martin 			CLR(tp->t_state, TS_FLUSH);
   1252       1.82    martin 		else
   1253       1.82    martin 			ndflush(&tp->t_outq, cc);
   1254      1.100   mlelstv 		mutex_spin_exit(&tty_lock);
   1255       1.82    martin 
   1256       1.82    martin 		if (err != USBD_CANCELLED && err != USBD_IOERROR &&
   1257       1.82    martin 		    !sc->sc_dying) {
   1258       1.82    martin 			if ((ub = SIMPLEQ_FIRST(&sc->sc_obuff_full)) != NULL)
   1259       1.82    martin 				ucom_submit_write(sc, ub);
   1260       1.82    martin 
   1261  1.108.2.8     skrll 			mutex_spin_enter(&tty_lock);
   1262       1.82    martin 			(*tp->t_linesw->l_start)(tp);
   1263  1.108.2.8     skrll 			mutex_spin_exit(&tty_lock);
   1264       1.82    martin 		}
   1265       1.82    martin 		break;
   1266       1.82    martin 	}
   1267       1.82    martin }
   1268       1.82    martin 
   1269       1.82    martin static void
   1270       1.82    martin ucom_submit_write(struct ucom_softc *sc, struct ucom_buffer *ub)
   1271       1.82    martin {
   1272       1.82    martin 
   1273  1.108.2.8     skrll 	KASSERT(mutex_owned(sc->sc_lock));
   1274  1.108.2.8     skrll 
   1275  1.108.2.9     skrll 	usbd_setup_xfer(ub->ub_xfer, sc, ub->ub_data, ub->ub_len,
   1276  1.108.2.2     skrll 	    0, USBD_NO_TIMEOUT, ucomwritecb);
   1277       1.82    martin 
   1278       1.82    martin 	ucom_write_status(sc, ub, usbd_transfer(ub->ub_xfer));
   1279       1.82    martin }
   1280       1.82    martin 
   1281       1.82    martin static void
   1282  1.108.2.5     skrll ucomwritecb(struct usbd_xfer *xfer, void *p, usbd_status status)
   1283       1.12  augustss {
   1284       1.12  augustss 	struct ucom_softc *sc = (struct ucom_softc *)p;
   1285       1.82    martin 
   1286  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
   1287       1.82    martin 	ucom_write_status(sc, SIMPLEQ_FIRST(&sc->sc_obuff_full), status);
   1288  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
   1289       1.82    martin 
   1290       1.82    martin }
   1291       1.82    martin 
   1292       1.82    martin static void
   1293       1.82    martin ucom_softintr(void *arg)
   1294       1.82    martin {
   1295       1.82    martin 	struct ucom_softc *sc = arg;
   1296       1.12  augustss 	struct tty *tp = sc->sc_tty;
   1297       1.82    martin 	struct ucom_buffer *ub;
   1298       1.12  augustss 
   1299  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
   1300  1.108.2.8     skrll 	mutex_enter(&tty_lock);
   1301  1.108.2.8     skrll 	if (!ISSET(tp->t_state, TS_ISOPEN)) {
   1302  1.108.2.8     skrll 		mutex_exit(&tty_lock);
   1303  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
   1304       1.82    martin 		return;
   1305  1.108.2.8     skrll 	}
   1306  1.108.2.8     skrll 	mutex_exit(&tty_lock);
   1307       1.12  augustss 
   1308       1.82    martin 	ub = SIMPLEQ_FIRST(&sc->sc_obuff_full);
   1309       1.82    martin 
   1310       1.82    martin 	if (ub != NULL && ub->ub_index == 0)
   1311       1.82    martin 		ucom_submit_write(sc, ub);
   1312       1.12  augustss 
   1313       1.82    martin 	if (sc->sc_rx_unblock)
   1314       1.82    martin 		ucom_read_complete(sc);
   1315       1.12  augustss 
   1316  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
   1317       1.82    martin }
   1318       1.82    martin 
   1319       1.82    martin static void
   1320       1.82    martin ucom_read_complete(struct ucom_softc *sc)
   1321       1.82    martin {
   1322       1.82    martin 	int (*rint)(int, struct tty *);
   1323       1.82    martin 	struct ucom_buffer *ub;
   1324       1.82    martin 	struct tty *tp;
   1325  1.108.2.8     skrll 
   1326  1.108.2.8     skrll 	KASSERT(mutex_owned(sc->sc_lock));
   1327       1.82    martin 
   1328       1.82    martin 	tp = sc->sc_tty;
   1329       1.82    martin 	rint = tp->t_linesw->l_rint;
   1330       1.82    martin 	ub = SIMPLEQ_FIRST(&sc->sc_ibuff_full);
   1331       1.39  augustss 
   1332       1.82    martin 	while (ub != NULL && !sc->sc_rx_stopped) {
   1333       1.82    martin 
   1334  1.108.2.8     skrll 		/* XXX ttyinput takes tty_lock */
   1335       1.82    martin 		while (ub->ub_index < ub->ub_len && !sc->sc_rx_stopped) {
   1336       1.82    martin 			/* Give characters to tty layer. */
   1337       1.82    martin 			if ((*rint)(ub->ub_data[ub->ub_index], tp) == -1) {
   1338       1.82    martin 				/* Overflow: drop remainder */
   1339       1.82    martin 				ub->ub_index = ub->ub_len;
   1340       1.82    martin 			} else
   1341       1.82    martin 				ub->ub_index++;
   1342       1.82    martin 		}
   1343       1.82    martin 
   1344       1.82    martin 		if (ub->ub_index == ub->ub_len) {
   1345       1.82    martin 			SIMPLEQ_REMOVE_HEAD(&sc->sc_ibuff_full, ub_link);
   1346       1.82    martin 
   1347       1.82    martin 			ucomsubmitread(sc, ub);
   1348       1.82    martin 
   1349       1.82    martin 			ub = SIMPLEQ_FIRST(&sc->sc_ibuff_full);
   1350       1.82    martin 		}
   1351       1.82    martin 	}
   1352       1.82    martin 
   1353       1.82    martin 	sc->sc_rx_unblock = (ub != NULL);
   1354       1.12  augustss }
   1355       1.12  augustss 
   1356       1.82    martin static usbd_status
   1357       1.82    martin ucomsubmitread(struct ucom_softc *sc, struct ucom_buffer *ub)
   1358       1.12  augustss {
   1359       1.12  augustss 	usbd_status err;
   1360       1.12  augustss 
   1361  1.108.2.9     skrll 	usbd_setup_xfer(ub->ub_xfer, sc, ub->ub_data, sc->sc_ibufsize,
   1362  1.108.2.2     skrll 	    USBD_SHORT_XFER_OK, USBD_NO_TIMEOUT, ucomreadcb);
   1363       1.82    martin 
   1364       1.82    martin 	if ((err = usbd_transfer(ub->ub_xfer)) != USBD_IN_PROGRESS) {
   1365       1.82    martin 		/* XXX: Recover from this, please! */
   1366       1.82    martin 		printf("ucomsubmitread: err=%s\n", usbd_errstr(err));
   1367  1.108.2.3     skrll 		return err;
   1368       1.12  augustss 	}
   1369       1.82    martin 
   1370       1.82    martin 	SIMPLEQ_INSERT_TAIL(&sc->sc_ibuff_empty, ub, ub_link);
   1371       1.82    martin 
   1372  1.108.2.3     skrll 	return USBD_NORMAL_COMPLETION;
   1373       1.12  augustss }
   1374       1.43  augustss 
   1375       1.82    martin static void
   1376  1.108.2.5     skrll ucomreadcb(struct usbd_xfer *xfer, void *p, usbd_status status)
   1377       1.12  augustss {
   1378       1.12  augustss 	struct ucom_softc *sc = (struct ucom_softc *)p;
   1379       1.12  augustss 	struct tty *tp = sc->sc_tty;
   1380       1.82    martin 	struct ucom_buffer *ub;
   1381  1.108.2.1     skrll 	uint32_t cc;
   1382       1.12  augustss 	u_char *cp;
   1383       1.12  augustss 
   1384  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
   1385  1.108.2.7     skrll 
   1386  1.108.2.8     skrll 	mutex_enter(sc->sc_lock);
   1387       1.82    martin 	ub = SIMPLEQ_FIRST(&sc->sc_ibuff_empty);
   1388       1.82    martin 	SIMPLEQ_REMOVE_HEAD(&sc->sc_ibuff_empty, ub_link);
   1389       1.34  augustss 
   1390       1.34  augustss 	if (status == USBD_CANCELLED || status == USBD_IOERROR ||
   1391       1.34  augustss 	    sc->sc_dying) {
   1392  1.108.2.7     skrll 		DPRINTF("dying", 0, 0, 0, 0);
   1393       1.82    martin 		ub->ub_index = ub->ub_len = 0;
   1394       1.34  augustss 		/* Send something to wake upper layer */
   1395       1.82    martin 		if (status != USBD_CANCELLED) {
   1396       1.82    martin 			(tp->t_linesw->l_rint)('\n', tp);
   1397       1.82    martin 			mutex_spin_enter(&tty_lock);	/* XXX */
   1398       1.82    martin 			ttwakeup(tp);
   1399       1.82    martin 			mutex_spin_exit(&tty_lock);	/* XXX */
   1400       1.82    martin 		}
   1401  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
   1402       1.12  augustss 		return;
   1403       1.34  augustss 	}
   1404       1.12  augustss 
   1405       1.82    martin 	if (status == USBD_STALLED) {
   1406       1.12  augustss 		usbd_clear_endpoint_stall_async(sc->sc_bulkin_pipe);
   1407       1.82    martin 		ucomsubmitread(sc, ub);
   1408  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
   1409       1.82    martin 		return;
   1410       1.82    martin 	}
   1411       1.82    martin 
   1412       1.82    martin 	if (status != USBD_NORMAL_COMPLETION) {
   1413       1.82    martin 		printf("ucomreadcb: wonky status=%s\n", usbd_errstr(status));
   1414  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
   1415       1.12  augustss 		return;
   1416       1.12  augustss 	}
   1417       1.12  augustss 
   1418       1.48   thorpej 	usbd_get_xfer_status(xfer, NULL, (void *)&cp, &cc, NULL);
   1419       1.82    martin 
   1420       1.95  jakllsch #ifdef UCOM_DEBUG
   1421       1.95  jakllsch 	/* This is triggered by uslsa(4) occasionally. */
   1422       1.95  jakllsch 	if ((ucomdebug > 0) && (cc == 0)) {
   1423       1.95  jakllsch 		device_printf(sc->sc_dev, "ucomreadcb: zero length xfer!\n");
   1424       1.82    martin 	}
   1425       1.95  jakllsch #endif
   1426       1.82    martin 
   1427       1.82    martin 	KDASSERT(cp == ub->ub_data);
   1428       1.82    martin 
   1429       1.31  explorer 	rnd_add_uint32(&sc->sc_rndsource, cc);
   1430       1.82    martin 
   1431       1.82    martin 	if (sc->sc_opening) {
   1432       1.82    martin 		ucomsubmitread(sc, ub);
   1433  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
   1434       1.82    martin 		return;
   1435       1.82    martin 	}
   1436       1.82    martin 
   1437       1.82    martin 	if (sc->sc_methods->ucom_read != NULL) {
   1438       1.22  augustss 		sc->sc_methods->ucom_read(sc->sc_parent, sc->sc_portno,
   1439       1.82    martin 		    &cp, &cc);
   1440       1.82    martin 		ub->ub_index = (u_int)(cp - ub->ub_data);
   1441       1.82    martin 	} else
   1442       1.82    martin 		ub->ub_index = 0;
   1443       1.82    martin 
   1444       1.82    martin 	ub->ub_len = cc;
   1445       1.22  augustss 
   1446       1.82    martin 	SIMPLEQ_INSERT_TAIL(&sc->sc_ibuff_full, ub, ub_link);
   1447       1.12  augustss 
   1448       1.82    martin 	ucom_read_complete(sc);
   1449  1.108.2.8     skrll 	mutex_exit(sc->sc_lock);
   1450       1.12  augustss }
   1451       1.12  augustss 
   1452       1.82    martin static void
   1453       1.24  augustss ucom_cleanup(struct ucom_softc *sc)
   1454       1.12  augustss {
   1455       1.82    martin 
   1456  1.108.2.7     skrll 	UCOMHIST_FUNC(); UCOMHIST_CALLED();
   1457  1.108.2.7     skrll 
   1458  1.108.2.9     skrll 	DPRINTF("aborting pipes", 0, 0, 0, 0);
   1459       1.12  augustss 
   1460  1.108.2.8     skrll 	KASSERT(mutex_owned(sc->sc_lock));
   1461  1.108.2.8     skrll 
   1462       1.12  augustss 	ucom_shutdown(sc);
   1463       1.33  augustss 	if (sc->sc_bulkin_pipe != NULL) {
   1464  1.108.2.8     skrll 		struct usbd_pipe *bulkin_pipe = sc->sc_bulkin_pipe;
   1465       1.33  augustss 		sc->sc_bulkin_pipe = NULL;
   1466  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
   1467  1.108.2.8     skrll 		usbd_abort_pipe(bulkin_pipe);
   1468  1.108.2.8     skrll 		mutex_enter(sc->sc_lock);
   1469       1.33  augustss 	}
   1470       1.33  augustss 	if (sc->sc_bulkout_pipe != NULL) {
   1471  1.108.2.8     skrll 		struct usbd_pipe *bulkout_pipe = sc->sc_bulkout_pipe;
   1472       1.33  augustss 		sc->sc_bulkout_pipe = NULL;
   1473  1.108.2.8     skrll 		mutex_exit(sc->sc_lock);
   1474  1.108.2.8     skrll 		usbd_abort_pipe(bulkout_pipe);
   1475  1.108.2.8     skrll 		mutex_enter(sc->sc_lock);
   1476       1.33  augustss 	}
   1477       1.12  augustss }
   1478       1.13  augustss 
   1479       1.13  augustss #endif /* NUCOM > 0 */
   1480       1.12  augustss 
   1481       1.20  augustss int
   1482       1.24  augustss ucomprint(void *aux, const char *pnp)
   1483       1.12  augustss {
   1484       1.37  augustss 	struct ucom_attach_args *uca = aux;
   1485       1.12  augustss 
   1486       1.12  augustss 	if (pnp)
   1487       1.49   thorpej 		aprint_normal("ucom at %s", pnp);
   1488       1.37  augustss 	if (uca->portno != UCOM_UNK_PORTNO)
   1489       1.49   thorpej 		aprint_normal(" portno %d", uca->portno);
   1490  1.108.2.3     skrll 	return UNCONF;
   1491       1.12  augustss }
   1492       1.12  augustss 
   1493       1.20  augustss int
   1494       1.77      cube ucomsubmatch(device_t parent, cfdata_t cf,
   1495       1.69  christos 	     const int *ldesc, void *aux)
   1496       1.12  augustss {
   1497       1.12  augustss 	struct ucom_attach_args *uca = aux;
   1498       1.12  augustss 
   1499       1.12  augustss 	if (uca->portno != UCOM_UNK_PORTNO &&
   1500       1.53  drochner 	    cf->cf_loc[UCOMBUSCF_PORTNO] != UCOMBUSCF_PORTNO_DEFAULT &&
   1501       1.53  drochner 	    cf->cf_loc[UCOMBUSCF_PORTNO] != uca->portno)
   1502  1.108.2.3     skrll 		return 0;
   1503  1.108.2.3     skrll 	return config_match(parent, cf, aux);
   1504       1.12  augustss }
   1505