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