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