midi.c revision 1.43.2.8 1 1.43.2.2 chap /* $NetBSD: midi.c,v 1.43.2.8 2006/05/20 03:19:02 chap Exp $ */
2 1.1 augustss
3 1.1 augustss /*
4 1.1 augustss * Copyright (c) 1998 The NetBSD Foundation, Inc.
5 1.1 augustss * All rights reserved.
6 1.1 augustss *
7 1.8 augustss * This code is derived from software contributed to The NetBSD Foundation
8 1.43.2.7 chap * by Lennart Augustsson (augustss (at) NetBSD.org) and (MIDI FST and Active
9 1.43.2.6 chap * Sense handling) Chapman Flack (nblists (at) anastigmatix.net).
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 * 3. All advertising materials mentioning features or use of this software
20 1.1 augustss * must display the following acknowledgement:
21 1.1 augustss * This product includes software developed by the NetBSD
22 1.1 augustss * Foundation, Inc. and its contributors.
23 1.1 augustss * 4. Neither the name of The NetBSD Foundation nor the names of its
24 1.1 augustss * contributors may be used to endorse or promote products derived
25 1.1 augustss * from this software without specific prior written permission.
26 1.1 augustss *
27 1.1 augustss * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
28 1.1 augustss * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
29 1.1 augustss * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
30 1.1 augustss * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
31 1.1 augustss * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
32 1.1 augustss * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
33 1.1 augustss * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
34 1.1 augustss * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
35 1.1 augustss * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
36 1.1 augustss * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
37 1.1 augustss * POSSIBILITY OF SUCH DAMAGE.
38 1.1 augustss */
39 1.23 lukem
40 1.23 lukem #include <sys/cdefs.h>
41 1.43.2.2 chap __KERNEL_RCSID(0, "$NetBSD: midi.c,v 1.43.2.8 2006/05/20 03:19:02 chap Exp $");
42 1.1 augustss
43 1.1 augustss #include "midi.h"
44 1.1 augustss #include "sequencer.h"
45 1.1 augustss
46 1.1 augustss #include <sys/param.h>
47 1.1 augustss #include <sys/ioctl.h>
48 1.1 augustss #include <sys/fcntl.h>
49 1.1 augustss #include <sys/vnode.h>
50 1.1 augustss #include <sys/select.h>
51 1.1 augustss #include <sys/poll.h>
52 1.1 augustss #include <sys/malloc.h>
53 1.1 augustss #include <sys/proc.h>
54 1.1 augustss #include <sys/systm.h>
55 1.15 thorpej #include <sys/callout.h>
56 1.1 augustss #include <sys/syslog.h>
57 1.1 augustss #include <sys/kernel.h>
58 1.1 augustss #include <sys/signalvar.h>
59 1.1 augustss #include <sys/conf.h>
60 1.1 augustss #include <sys/audioio.h>
61 1.1 augustss #include <sys/midiio.h>
62 1.1 augustss
63 1.1 augustss #include <dev/audio_if.h>
64 1.4 augustss #include <dev/midi_if.h>
65 1.1 augustss #include <dev/midivar.h>
66 1.1 augustss
67 1.10 drochner #if NMIDI > 0
68 1.10 drochner
69 1.1 augustss #ifdef AUDIO_DEBUG
70 1.1 augustss #define DPRINTF(x) if (mididebug) printf x
71 1.1 augustss #define DPRINTFN(n,x) if (mididebug >= (n)) printf x
72 1.1 augustss int mididebug = 0;
73 1.43.2.2 chap /*
74 1.43.2.2 chap * 1: detected protocol errors and buffer overflows
75 1.43.2.2 chap * 2: probe, attach, detach
76 1.43.2.2 chap * 3: open, close
77 1.43.2.2 chap * 4: data received except realtime
78 1.43.2.2 chap * 5: ioctl
79 1.43.2.2 chap * 6: read, write, poll
80 1.43.2.2 chap * 7: data transmitted
81 1.43.2.2 chap * 8: uiomoves, synchronization
82 1.43.2.2 chap * 9: realtime data received
83 1.43.2.2 chap */
84 1.1 augustss #else
85 1.1 augustss #define DPRINTF(x)
86 1.1 augustss #define DPRINTFN(n,x)
87 1.1 augustss #endif
88 1.1 augustss
89 1.43.2.8 chap static struct simplelock hwif_register_lock = SIMPLELOCK_INITIALIZER;
90 1.43.2.8 chap static struct midi_softc *hwif_softc = NULL;
91 1.1 augustss
92 1.22 augustss void midi_in(void *, int);
93 1.22 augustss void midi_out(void *);
94 1.43.2.7 chap int midi_poll_out(struct midi_softc *);
95 1.43.2.7 chap int midi_intr_out(struct midi_softc *);
96 1.43.2.8 chap int midi_msg_out(struct midi_softc *,
97 1.43.2.8 chap u_char **, u_char **, u_char **, u_char **);
98 1.43.2.7 chap int midi_start_output(struct midi_softc *);
99 1.43.2.7 chap int midi_sleep_timo(int *, char *, int, struct simplelock *);
100 1.43.2.7 chap int midi_sleep(int *, char *, struct simplelock *);
101 1.22 augustss void midi_wakeup(int *);
102 1.22 augustss void midi_initbuf(struct midi_buffer *);
103 1.22 augustss void midi_timeout(void *);
104 1.22 augustss
105 1.22 augustss int midiprobe(struct device *, struct cfdata *, void *);
106 1.22 augustss void midiattach(struct device *, struct device *, void *);
107 1.22 augustss int mididetach(struct device *, int);
108 1.22 augustss int midiactivate(struct device *, enum devact);
109 1.1 augustss
110 1.25 gehenna dev_type_open(midiopen);
111 1.25 gehenna dev_type_close(midiclose);
112 1.25 gehenna dev_type_read(midiread);
113 1.25 gehenna dev_type_write(midiwrite);
114 1.25 gehenna dev_type_ioctl(midiioctl);
115 1.25 gehenna dev_type_poll(midipoll);
116 1.30 jdolecek dev_type_kqfilter(midikqfilter);
117 1.25 gehenna
118 1.25 gehenna const struct cdevsw midi_cdevsw = {
119 1.25 gehenna midiopen, midiclose, midiread, midiwrite, midiioctl,
120 1.30 jdolecek nostop, notty, midipoll, nommap, midikqfilter,
121 1.25 gehenna };
122 1.25 gehenna
123 1.28 thorpej CFATTACH_DECL(midi, sizeof(struct midi_softc),
124 1.29 thorpej midiprobe, midiattach, mididetach, midiactivate);
125 1.1 augustss
126 1.4 augustss #ifdef MIDI_SAVE
127 1.4 augustss #define MIDI_SAVE_SIZE 100000
128 1.4 augustss int midicnt;
129 1.4 augustss struct {
130 1.4 augustss int cnt;
131 1.4 augustss u_char buf[MIDI_SAVE_SIZE];
132 1.4 augustss } midisave;
133 1.4 augustss #define MIDI_GETSAVE _IOWR('m', 100, int)
134 1.4 augustss
135 1.4 augustss #endif
136 1.4 augustss
137 1.1 augustss extern struct cfdriver midi_cd;
138 1.1 augustss
139 1.1 augustss int
140 1.22 augustss midiprobe(struct device *parent, struct cfdata *match, void *aux)
141 1.1 augustss {
142 1.1 augustss struct audio_attach_args *sa = aux;
143 1.1 augustss
144 1.43.2.2 chap DPRINTFN(2,("midiprobe: type=%d sa=%p hw=%p\n",
145 1.1 augustss sa->type, sa, sa->hwif));
146 1.16 augustss return (sa->type == AUDIODEV_TYPE_MIDI);
147 1.1 augustss }
148 1.1 augustss
149 1.1 augustss void
150 1.22 augustss midiattach(struct device *parent, struct device *self, void *aux)
151 1.1 augustss {
152 1.1 augustss struct midi_softc *sc = (void *)self;
153 1.1 augustss struct audio_attach_args *sa = aux;
154 1.43.2.1 chap struct midi_hw_if *hwp = sa->hwif;
155 1.1 augustss void *hdlp = sa->hdl;
156 1.1 augustss
157 1.43.2.2 chap DPRINTFN(2, ("MIDI attach\n"));
158 1.1 augustss
159 1.1 augustss #ifdef DIAGNOSTIC
160 1.1 augustss if (hwp == 0 ||
161 1.1 augustss hwp->open == 0 ||
162 1.1 augustss hwp->close == 0 ||
163 1.1 augustss hwp->output == 0 ||
164 1.1 augustss hwp->getinfo == 0) {
165 1.1 augustss printf("midi: missing method\n");
166 1.1 augustss return;
167 1.1 augustss }
168 1.1 augustss #endif
169 1.15 thorpej
170 1.1 augustss sc->hw_if = hwp;
171 1.1 augustss sc->hw_hdl = hdlp;
172 1.2 augustss midi_attach(sc, parent);
173 1.2 augustss }
174 1.2 augustss
175 1.18 tshiozak int
176 1.22 augustss midiactivate(struct device *self, enum devact act)
177 1.18 tshiozak {
178 1.18 tshiozak struct midi_softc *sc = (struct midi_softc *)self;
179 1.18 tshiozak
180 1.18 tshiozak switch (act) {
181 1.18 tshiozak case DVACT_ACTIVATE:
182 1.18 tshiozak return (EOPNOTSUPP);
183 1.18 tshiozak
184 1.18 tshiozak case DVACT_DEACTIVATE:
185 1.18 tshiozak sc->dying = 1;
186 1.18 tshiozak break;
187 1.18 tshiozak }
188 1.18 tshiozak return (0);
189 1.18 tshiozak }
190 1.18 tshiozak
191 1.18 tshiozak int
192 1.22 augustss mididetach(struct device *self, int flags)
193 1.18 tshiozak {
194 1.18 tshiozak struct midi_softc *sc = (struct midi_softc *)self;
195 1.18 tshiozak int maj, mn;
196 1.18 tshiozak
197 1.43.2.2 chap DPRINTFN(2,("midi_detach: sc=%p flags=%d\n", sc, flags));
198 1.18 tshiozak
199 1.18 tshiozak sc->dying = 1;
200 1.18 tshiozak
201 1.18 tshiozak wakeup(&sc->wchan);
202 1.18 tshiozak wakeup(&sc->rchan);
203 1.18 tshiozak
204 1.18 tshiozak /* locate the major number */
205 1.25 gehenna maj = cdevsw_lookup_major(&midi_cdevsw);
206 1.18 tshiozak
207 1.18 tshiozak /* Nuke the vnodes for any open instances (calls close). */
208 1.43.2.1 chap mn = self->dv_unit;
209 1.18 tshiozak vdevgone(maj, mn, mn, VCHR);
210 1.43.2.3 chap
211 1.43.2.6 chap evcnt_detach(&sc->xmt.bytesDiscarded);
212 1.43.2.6 chap evcnt_detach(&sc->xmt.incompleteMessages);
213 1.43.2.3 chap if ( sc->props & MIDI_PROP_CAN_INPUT ) {
214 1.43.2.6 chap evcnt_detach(&sc->rcv.bytesDiscarded);
215 1.43.2.6 chap evcnt_detach(&sc->rcv.incompleteMessages);
216 1.43.2.3 chap }
217 1.18 tshiozak
218 1.18 tshiozak return (0);
219 1.18 tshiozak }
220 1.18 tshiozak
221 1.2 augustss void
222 1.22 augustss midi_attach(struct midi_softc *sc, struct device *parent)
223 1.2 augustss {
224 1.2 augustss struct midi_info mi;
225 1.43.2.8 chap int s;
226 1.43.2.5 chap
227 1.43.2.5 chap callout_init(&sc->sc_callout);
228 1.43.2.5 chap callout_setfunc(&sc->sc_callout, midi_timeout, sc);
229 1.43.2.5 chap simple_lock_init(&sc->out_lock);
230 1.43.2.7 chap simple_lock_init(&sc->in_lock);
231 1.43.2.5 chap sc->dying = 0;
232 1.1 augustss sc->isopen = 0;
233 1.1 augustss
234 1.2 augustss sc->sc_dev = parent;
235 1.43.2.8 chap
236 1.43.2.8 chap s = splaudio();
237 1.43.2.8 chap simple_lock(&hwif_register_lock);
238 1.43.2.8 chap hwif_softc = sc;
239 1.2 augustss sc->hw_if->getinfo(sc->hw_hdl, &mi);
240 1.43.2.8 chap hwif_softc = NULL;
241 1.43.2.8 chap simple_unlock(&hwif_register_lock);
242 1.43.2.8 chap splx(s);
243 1.43.2.8 chap
244 1.1 augustss sc->props = mi.props;
245 1.43.2.3 chap
246 1.43.2.6 chap evcnt_attach_dynamic(&sc->xmt.bytesDiscarded,
247 1.43.2.6 chap EVCNT_TYPE_MISC, NULL,
248 1.43.2.6 chap sc->dev.dv_xname, "xmt bytes discarded");
249 1.43.2.6 chap evcnt_attach_dynamic(&sc->xmt.incompleteMessages,
250 1.43.2.6 chap EVCNT_TYPE_MISC, NULL,
251 1.43.2.6 chap sc->dev.dv_xname, "xmt incomplete msgs");
252 1.43.2.3 chap if ( sc->props & MIDI_PROP_CAN_INPUT ) {
253 1.43.2.6 chap evcnt_attach_dynamic(&sc->rcv.bytesDiscarded,
254 1.43.2.3 chap EVCNT_TYPE_MISC, NULL,
255 1.43.2.3 chap sc->dev.dv_xname, "rcv bytes discarded");
256 1.43.2.6 chap evcnt_attach_dynamic(&sc->rcv.incompleteMessages,
257 1.43.2.3 chap EVCNT_TYPE_MISC, NULL,
258 1.43.2.3 chap sc->dev.dv_xname, "rcv incomplete msgs");
259 1.43.2.3 chap }
260 1.43.2.3 chap
261 1.13 soren printf(": %s\n", mi.name);
262 1.1 augustss }
263 1.1 augustss
264 1.43.2.8 chap void midi_register_hw_if_ext(struct midi_hw_if_ext *exthw) {
265 1.43.2.8 chap if ( hwif_softc != NULL )
266 1.43.2.8 chap hwif_softc->hw_if_ext = exthw;
267 1.43.2.8 chap }
268 1.43.2.8 chap
269 1.1 augustss int
270 1.22 augustss midi_unit_count(void)
271 1.1 augustss {
272 1.43.2.3 chap int i;
273 1.43.2.3 chap for ( i = 0; i < midi_cd.cd_ndevs; ++i )
274 1.43.2.3 chap if ( NULL == midi_cd.cd_devs[i] )
275 1.43.2.3 chap break;
276 1.43.2.3 chap return i;
277 1.1 augustss }
278 1.1 augustss
279 1.1 augustss void
280 1.22 augustss midi_initbuf(struct midi_buffer *mb)
281 1.1 augustss {
282 1.43.2.7 chap mb->idx_producerp = mb->idx_consumerp = mb->idx;
283 1.43.2.7 chap mb->buf_producerp = mb->buf_consumerp = mb->buf;
284 1.1 augustss }
285 1.43.2.7 chap #define PACK_MB_IDX(cat,len) (((cat)<<4)|(len))
286 1.43.2.7 chap #define MB_IDX_CAT(idx) ((idx)>>4)
287 1.43.2.7 chap #define MB_IDX_LEN(idx) ((idx)&0xf)
288 1.1 augustss
289 1.2 augustss int
290 1.43.2.7 chap midi_sleep_timo(int *chan, char *label, int timo, struct simplelock *lk)
291 1.1 augustss {
292 1.1 augustss int st;
293 1.1 augustss
294 1.1 augustss if (!label)
295 1.1 augustss label = "midi";
296 1.1 augustss
297 1.43.2.2 chap DPRINTFN(8, ("midi_sleep_timo: %p %s %d\n", chan, label, timo));
298 1.1 augustss *chan = 1;
299 1.43.2.7 chap st = ltsleep(chan, PWAIT | PCATCH, label, timo, lk);
300 1.1 augustss *chan = 0;
301 1.1 augustss #ifdef MIDI_DEBUG
302 1.1 augustss if (st != 0)
303 1.1 augustss printf("midi_sleep: %d\n", st);
304 1.1 augustss #endif
305 1.1 augustss return st;
306 1.1 augustss }
307 1.1 augustss
308 1.2 augustss int
309 1.43.2.7 chap midi_sleep(int *chan, char *label, struct simplelock *lk)
310 1.1 augustss {
311 1.43.2.7 chap return midi_sleep_timo(chan, label, 0, lk);
312 1.1 augustss }
313 1.1 augustss
314 1.2 augustss void
315 1.22 augustss midi_wakeup(int *chan)
316 1.1 augustss {
317 1.1 augustss if (*chan) {
318 1.43.2.2 chap DPRINTFN(8, ("midi_wakeup: %p\n", chan));
319 1.1 augustss wakeup(chan);
320 1.1 augustss *chan = 0;
321 1.1 augustss }
322 1.1 augustss }
323 1.1 augustss
324 1.43.2.2 chap /* in midivar.h:
325 1.43.2.2 chap #define MIDI_CAT_DATA 0
326 1.43.2.2 chap #define MIDI_CAT_STATUS1 1
327 1.43.2.2 chap #define MIDI_CAT_STATUS2 2
328 1.43.2.2 chap #define MIDI_CAT_COMMON 3
329 1.43.2.2 chap */
330 1.43.2.2 chap static char const midi_cats[] = "\0\0\0\0\0\0\0\0\2\2\2\2\1\1\2\3";
331 1.43.2.2 chap #define MIDI_CAT(d) (midi_cats[((d)>>4)&15])
332 1.43.2.7 chap #define FST_RETURN(offp,endp,ret) \
333 1.43.2.6 chap return (s->pos=s->msg+(offp)), (s->end=s->msg+(endp)), (ret)
334 1.1 augustss
335 1.43.2.7 chap enum fst_ret { FST_CHN, FST_COM, FST_SYX, FST_RT, FST_MORE, FST_ERR, FST_HUH };
336 1.1 augustss
337 1.43.2.6 chap /*
338 1.43.2.7 chap * A MIDI finite state transducer suitable for receiving or transmitting. It
339 1.43.2.7 chap * will accept correct MIDI input that uses, doesn't use, or sometimes uses the
340 1.43.2.6 chap * 'running status' compression technique, and transduce it to fully expanded
341 1.43.2.6 chap * (compress==0) or fully compressed (compress==1) form.
342 1.43.2.6 chap *
343 1.43.2.7 chap * Returns FST_MORE if a complete message has not been parsed yet (SysEx
344 1.43.2.7 chap * messages are the exception), FST_ERR or FST_HUH if the input does not
345 1.43.2.7 chap * conform to the protocol, or FST_CHN (channel messages), FST_COM (System
346 1.43.2.7 chap * Common messages), FST_RT (System Real-Time messages), or FST_SYX (System
347 1.43.2.6 chap * Exclusive) to broadly categorize the message parsed. s->pos and s->end
348 1.43.2.6 chap * locate the parsed message; while (s->pos<s->end) putchar(*(s->pos++));
349 1.43.2.6 chap * would output it.
350 1.43.2.6 chap *
351 1.43.2.7 chap * FST_HUH means the character c wasn't valid in the original state, but the
352 1.43.2.6 chap * state has now been reset to START and the caller should try again passing
353 1.43.2.7 chap * the same c. FST_ERR means c isn't valid in the start state; the caller
354 1.43.2.6 chap * should kiss it goodbye and continue to try successive characters from the
355 1.43.2.7 chap * input until something other than FST_ERR or FST_HUH is returned, at which
356 1.43.2.6 chap * point things are resynchronized.
357 1.43.2.6 chap *
358 1.43.2.7 chap * A FST_SYX return means that between pos and end are from 1 to 3
359 1.43.2.6 chap * bytes of a system exclusive message. A SysEx message will be delivered in
360 1.43.2.6 chap * one or more chunks of that form, where the first begins with 0xf0 and the
361 1.43.2.6 chap * last (which is the only one that might have length < 3) ends with 0xf7.
362 1.43.2.6 chap *
363 1.43.2.6 chap * Messages corrupted by a protocol error are discarded and won't be seen at
364 1.43.2.6 chap * all; again SysEx is the exception, as one or more chunks of it may already
365 1.43.2.6 chap * have been parsed.
366 1.43.2.6 chap *
367 1.43.2.7 chap * For FST_CHN messages, s->msg[0] always contains the status byte even if
368 1.43.2.6 chap * compression was requested (pos then points to msg[1]). That way, the
369 1.43.2.6 chap * caller can always identify the exact message if there is a need to do so.
370 1.43.2.7 chap * For all other message types except FST_SYX, the status byte is at *pos
371 1.43.2.6 chap * (which may not necessarily be msg[0]!). There is only one SysEx status
372 1.43.2.7 chap * byte, so the return value FST_SYX is sufficient to identify it.
373 1.43.2.6 chap */
374 1.43.2.7 chap static enum fst_ret
375 1.43.2.7 chap midi_fst(struct midi_state *s, u_char c, int compress)
376 1.43.2.6 chap {
377 1.43.2.6 chap int syxpos = 0;
378 1.43.2.6 chap compress = compress ? 1 : 0;
379 1.14 augustss
380 1.43.2.6 chap if ( c >= 0xf8 ) { /* All realtime messages bypass state machine */
381 1.43.2.6 chap if ( c == 0xf9 || c == 0xfd ) {
382 1.43.2.7 chap DPRINTF( ("midi_fst: s=%p c=0x%02x undefined\n",
383 1.43.2.6 chap s, c));
384 1.43.2.6 chap s->bytesDiscarded.ev_count++;
385 1.43.2.7 chap return FST_ERR;
386 1.43.2.2 chap }
387 1.43.2.7 chap DPRINTFN(9, ("midi_fst: s=%p System Real-Time data=0x%02x\n",
388 1.43.2.6 chap s, c));
389 1.43.2.6 chap s->msg[2] = c;
390 1.43.2.7 chap FST_RETURN(2,3,FST_RT);
391 1.43.2.2 chap }
392 1.43.2.2 chap
393 1.43.2.7 chap DPRINTFN(4, ("midi_fst: s=%p data=0x%02x state=%d\n",
394 1.43.2.6 chap s, c, s->state));
395 1.43.2.2 chap
396 1.43.2.7 chap switch ( s->state | MIDI_CAT(c) ) { /* break ==> return FST_MORE */
397 1.43.2.2 chap
398 1.43.2.2 chap case MIDI_IN_START | MIDI_CAT_COMMON:
399 1.43.2.2 chap case MIDI_IN_RUN1_1 | MIDI_CAT_COMMON:
400 1.43.2.2 chap case MIDI_IN_RUN2_2 | MIDI_CAT_COMMON:
401 1.43.2.6 chap s->msg[0] = c;
402 1.43.2.6 chap switch ( c ) {
403 1.43.2.6 chap case 0xf0: s->state = MIDI_IN_SYX1_3; break;
404 1.43.2.6 chap case 0xf1: s->state = MIDI_IN_COM0_1; break;
405 1.43.2.6 chap case 0xf2: s->state = MIDI_IN_COM0_2; break;
406 1.43.2.6 chap case 0xf3: s->state = MIDI_IN_COM0_1; break;
407 1.43.2.7 chap case 0xf6: s->state = MIDI_IN_START; FST_RETURN(0,1,FST_COM);
408 1.43.2.2 chap default: goto protocol_violation;
409 1.1 augustss }
410 1.43.2.2 chap break;
411 1.43.2.2 chap
412 1.43.2.2 chap case MIDI_IN_RUN1_1 | MIDI_CAT_STATUS1:
413 1.43.2.6 chap if ( c == s->msg[0] ) {
414 1.43.2.6 chap s->state = MIDI_IN_RNX0_1;
415 1.43.2.6 chap break;
416 1.43.2.6 chap }
417 1.43.2.6 chap /* FALLTHROUGH */
418 1.43.2.2 chap case MIDI_IN_RUN2_2 | MIDI_CAT_STATUS1:
419 1.43.2.6 chap case MIDI_IN_START | MIDI_CAT_STATUS1:
420 1.43.2.6 chap s->state = MIDI_IN_RUN0_1;
421 1.43.2.6 chap s->msg[0] = c;
422 1.43.2.6 chap break;
423 1.43.2.2 chap
424 1.43.2.2 chap case MIDI_IN_RUN2_2 | MIDI_CAT_STATUS2:
425 1.43.2.6 chap if ( c == s->msg[0] ) {
426 1.43.2.6 chap s->state = MIDI_IN_RNX0_2;
427 1.43.2.6 chap break;
428 1.43.2.6 chap }
429 1.43.2.6 chap /* FALLTHROUGH */
430 1.43.2.6 chap case MIDI_IN_RUN1_1 | MIDI_CAT_STATUS2:
431 1.43.2.6 chap case MIDI_IN_START | MIDI_CAT_STATUS2:
432 1.43.2.6 chap s->state = MIDI_IN_RUN0_2;
433 1.43.2.6 chap s->msg[0] = c;
434 1.43.2.6 chap break;
435 1.43.2.2 chap
436 1.43.2.2 chap case MIDI_IN_COM0_1 | MIDI_CAT_DATA:
437 1.43.2.6 chap s->state = MIDI_IN_START;
438 1.43.2.6 chap s->msg[1] = c;
439 1.43.2.7 chap FST_RETURN(0,2,FST_COM);
440 1.43.2.2 chap
441 1.43.2.2 chap case MIDI_IN_COM0_2 | MIDI_CAT_DATA:
442 1.43.2.6 chap s->state = MIDI_IN_COM1_2;
443 1.43.2.6 chap s->msg[1] = c;
444 1.43.2.6 chap break;
445 1.43.2.2 chap
446 1.43.2.2 chap case MIDI_IN_COM1_2 | MIDI_CAT_DATA:
447 1.43.2.6 chap s->state = MIDI_IN_START;
448 1.43.2.6 chap s->msg[2] = c;
449 1.43.2.7 chap FST_RETURN(0,3,FST_COM);
450 1.43.2.2 chap
451 1.43.2.2 chap case MIDI_IN_RUN0_1 | MIDI_CAT_DATA:
452 1.43.2.6 chap s->state = MIDI_IN_RUN1_1;
453 1.43.2.6 chap s->msg[1] = c;
454 1.43.2.7 chap FST_RETURN(0,2,FST_CHN);
455 1.43.2.6 chap
456 1.43.2.2 chap case MIDI_IN_RUN1_1 | MIDI_CAT_DATA:
457 1.43.2.6 chap case MIDI_IN_RNX0_1 | MIDI_CAT_DATA:
458 1.43.2.6 chap s->state = MIDI_IN_RUN1_1;
459 1.43.2.6 chap s->msg[1] = c;
460 1.43.2.7 chap FST_RETURN(compress,2,FST_CHN);
461 1.43.2.2 chap
462 1.43.2.2 chap case MIDI_IN_RUN0_2 | MIDI_CAT_DATA:
463 1.43.2.6 chap s->state = MIDI_IN_RUN1_2;
464 1.43.2.6 chap s->msg[1] = c;
465 1.43.2.6 chap break;
466 1.43.2.2 chap
467 1.43.2.2 chap case MIDI_IN_RUN1_2 | MIDI_CAT_DATA:
468 1.43.2.6 chap s->state = MIDI_IN_RUN2_2;
469 1.43.2.6 chap s->msg[2] = c;
470 1.43.2.7 chap FST_RETURN(0,3,FST_CHN);
471 1.43.2.6 chap
472 1.43.2.6 chap case MIDI_IN_RUN2_2 | MIDI_CAT_DATA:
473 1.43.2.6 chap s->state = MIDI_IN_RNX1_2;
474 1.43.2.6 chap s->msg[1] = c;
475 1.43.2.6 chap break;
476 1.43.2.6 chap
477 1.43.2.6 chap case MIDI_IN_RNX0_2 | MIDI_CAT_DATA:
478 1.43.2.6 chap s->state = MIDI_IN_RNY1_2;
479 1.43.2.6 chap s->msg[1] = c;
480 1.43.2.6 chap break;
481 1.43.2.6 chap
482 1.43.2.6 chap case MIDI_IN_RNX1_2 | MIDI_CAT_DATA:
483 1.43.2.6 chap case MIDI_IN_RNY1_2 | MIDI_CAT_DATA:
484 1.43.2.6 chap s->state = MIDI_IN_RUN2_2;
485 1.43.2.6 chap s->msg[2] = c;
486 1.43.2.7 chap FST_RETURN(compress,3,FST_CHN);
487 1.43.2.6 chap
488 1.43.2.6 chap case MIDI_IN_SYX1_3 | MIDI_CAT_DATA:
489 1.43.2.6 chap s->state = MIDI_IN_SYX2_3;
490 1.43.2.6 chap s->msg[1] = c;
491 1.43.2.2 chap break;
492 1.43.2.2 chap
493 1.43.2.6 chap case MIDI_IN_SYX2_3 | MIDI_CAT_DATA:
494 1.43.2.6 chap s->state = MIDI_IN_SYX0_3;
495 1.43.2.6 chap s->msg[2] = c;
496 1.43.2.7 chap FST_RETURN(0,3,FST_SYX);
497 1.43.2.6 chap
498 1.43.2.6 chap case MIDI_IN_SYX0_3 | MIDI_CAT_DATA:
499 1.43.2.6 chap s->state = MIDI_IN_SYX1_3;
500 1.43.2.6 chap s->msg[0] = c;
501 1.43.2.6 chap break;
502 1.43.2.6 chap
503 1.43.2.6 chap case MIDI_IN_SYX2_3 | MIDI_CAT_COMMON:
504 1.43.2.6 chap ++ syxpos;
505 1.43.2.6 chap /* FALLTHROUGH */
506 1.43.2.6 chap case MIDI_IN_SYX1_3 | MIDI_CAT_COMMON:
507 1.43.2.6 chap ++ syxpos;
508 1.43.2.6 chap /* FALLTHROUGH */
509 1.43.2.6 chap case MIDI_IN_SYX0_3 | MIDI_CAT_COMMON:
510 1.43.2.6 chap if ( c == 0xf7 ) {
511 1.43.2.6 chap s->state = MIDI_IN_START;
512 1.43.2.6 chap s->msg[syxpos] = c;
513 1.43.2.7 chap FST_RETURN(0,1+syxpos,FST_SYX);
514 1.43.2.2 chap }
515 1.43.2.2 chap /* FALLTHROUGH */
516 1.43.2.2 chap
517 1.43.2.2 chap default:
518 1.43.2.2 chap protocol_violation:
519 1.43.2.7 chap DPRINTF(("midi_fst: unexpected %#02x in state %u\n",
520 1.43.2.6 chap c, s->state));
521 1.43.2.6 chap switch ( s->state ) {
522 1.43.2.3 chap case MIDI_IN_RUN1_1: /* can only get here by seeing an */
523 1.43.2.3 chap case MIDI_IN_RUN2_2: /* INVALID System Common message */
524 1.43.2.6 chap s->state = MIDI_IN_START;
525 1.43.2.3 chap /* FALLTHROUGH */
526 1.43.2.2 chap case MIDI_IN_START:
527 1.43.2.6 chap s->bytesDiscarded.ev_count++;
528 1.43.2.7 chap return FST_ERR;
529 1.43.2.2 chap case MIDI_IN_COM1_2:
530 1.43.2.2 chap case MIDI_IN_RUN1_2:
531 1.43.2.6 chap case MIDI_IN_SYX2_3:
532 1.43.2.6 chap case MIDI_IN_RNY1_2:
533 1.43.2.6 chap s->bytesDiscarded.ev_count++;
534 1.43.2.2 chap /* FALLTHROUGH */
535 1.43.2.2 chap case MIDI_IN_COM0_1:
536 1.43.2.2 chap case MIDI_IN_RUN0_1:
537 1.43.2.6 chap case MIDI_IN_RNX0_1:
538 1.43.2.2 chap case MIDI_IN_COM0_2:
539 1.43.2.2 chap case MIDI_IN_RUN0_2:
540 1.43.2.6 chap case MIDI_IN_RNX0_2:
541 1.43.2.6 chap case MIDI_IN_RNX1_2:
542 1.43.2.6 chap case MIDI_IN_SYX1_3:
543 1.43.2.6 chap s->bytesDiscarded.ev_count++;
544 1.43.2.2 chap /* FALLTHROUGH */
545 1.43.2.6 chap case MIDI_IN_SYX0_3:
546 1.43.2.6 chap s->incompleteMessages.ev_count++;
547 1.43.2.2 chap break;
548 1.43.2.2 chap #if defined(AUDIO_DEBUG) || defined(DIAGNOSTIC)
549 1.43.2.2 chap default:
550 1.43.2.7 chap printf("midi_fst: mishandled %#02x(%u) in state %u?!\n",
551 1.43.2.6 chap c, MIDI_CAT(c), s->state);
552 1.43.2.2 chap #endif
553 1.43.2.2 chap }
554 1.43.2.6 chap s->state = MIDI_IN_START;
555 1.43.2.7 chap return FST_HUH;
556 1.1 augustss }
557 1.43.2.7 chap return FST_MORE;
558 1.43.2.6 chap }
559 1.43.2.2 chap
560 1.43.2.6 chap void
561 1.43.2.6 chap midi_in(void *addr, int data)
562 1.43.2.6 chap {
563 1.43.2.6 chap struct midi_softc *sc = addr;
564 1.43.2.6 chap struct midi_buffer *mb = &sc->inbuf;
565 1.43.2.6 chap int i;
566 1.43.2.6 chap int count;
567 1.43.2.7 chap enum fst_ret got;
568 1.43.2.7 chap int s; /* hw may have various spls so impose our own */
569 1.43.2.7 chap MIDI_BUF_DECLARE(idx);
570 1.43.2.7 chap MIDI_BUF_DECLARE(buf);
571 1.43.2.6 chap
572 1.43.2.6 chap if (!sc->isopen)
573 1.1 augustss return;
574 1.43.2.6 chap
575 1.43.2.6 chap if (!(sc->flags & FREAD))
576 1.43.2.6 chap return; /* discard data if not reading */
577 1.43.2.6 chap
578 1.43.2.6 chap do
579 1.43.2.7 chap got = midi_fst(&sc->rcv, data, 0);
580 1.43.2.7 chap while ( got == FST_HUH );
581 1.43.2.6 chap
582 1.43.2.6 chap switch ( got ) {
583 1.43.2.7 chap case FST_MORE:
584 1.43.2.7 chap case FST_ERR:
585 1.1 augustss return;
586 1.43.2.7 chap case FST_CHN:
587 1.43.2.7 chap case FST_COM:
588 1.43.2.7 chap case FST_RT:
589 1.43.2.6 chap #if NSEQUENCER > 0
590 1.43.2.6 chap if (sc->seqopen) {
591 1.43.2.6 chap extern void midiseq_in(struct midi_dev *,u_char *,int);
592 1.43.2.6 chap count = sc->rcv.end - sc->rcv.pos;
593 1.43.2.6 chap midiseq_in(sc->seq_md, sc->rcv.pos, count);
594 1.43.2.6 chap return;
595 1.43.2.6 chap }
596 1.43.2.6 chap #endif
597 1.43.2.6 chap /*
598 1.43.2.6 chap * Pass Active Sense to the sequencer if it's open, but not to
599 1.43.2.6 chap * a raw reader. (Really should do something intelligent with
600 1.43.2.6 chap * it then, though....)
601 1.43.2.6 chap */
602 1.43.2.7 chap if ( got == FST_RT && MIDI_ACK == sc->rcv.pos[0] )
603 1.43.2.6 chap return;
604 1.43.2.6 chap /* FALLTHROUGH */
605 1.43.2.6 chap /*
606 1.43.2.6 chap * Ultimately SysEx msgs should be offered to the sequencer also; the
607 1.43.2.6 chap * sequencer API addresses them - but maybe our sequencer can't handle
608 1.43.2.6 chap * them yet, so offer only to raw reader. (Which means, ultimately,
609 1.43.2.6 chap * discard them if the sequencer's open, as it's not doing reads!)
610 1.43.2.6 chap */
611 1.43.2.7 chap case FST_SYX:
612 1.43.2.6 chap count = sc->rcv.end - sc->rcv.pos;
613 1.43.2.7 chap MIDI_IN_LOCK(sc,s);
614 1.43.2.7 chap MIDI_BUF_PRODUCER_INIT(mb,idx);
615 1.43.2.7 chap MIDI_BUF_PRODUCER_INIT(mb,buf);
616 1.43.2.7 chap if (count > buf_lim - buf_cur
617 1.43.2.7 chap || 1 > idx_lim - idx_cur) {
618 1.43.2.7 chap sc->rcv.bytesDiscarded.ev_count += count;
619 1.43.2.7 chap MIDI_IN_UNLOCK(sc,s);
620 1.43.2.6 chap DPRINTF(("midi_in: buffer full, discard data=0x%02x\n",
621 1.43.2.6 chap sc->rcv.pos[0]));
622 1.43.2.6 chap return;
623 1.43.2.6 chap }
624 1.43.2.6 chap for (i = 0; i < count; i++) {
625 1.43.2.7 chap *buf_cur++ = sc->rcv.pos[i];
626 1.43.2.7 chap MIDI_BUF_WRAP(buf);
627 1.43.2.6 chap }
628 1.43.2.7 chap *idx_cur++ = PACK_MB_IDX(got,count);
629 1.43.2.7 chap MIDI_BUF_WRAP(idx);
630 1.43.2.7 chap MIDI_BUF_PRODUCER_WBACK(mb,buf);
631 1.43.2.7 chap MIDI_BUF_PRODUCER_WBACK(mb,idx);
632 1.43.2.6 chap midi_wakeup(&sc->rchan);
633 1.43.2.6 chap selnotify(&sc->rsel, 0);
634 1.43.2.6 chap if (sc->async)
635 1.43.2.6 chap psignal(sc->async, SIGIO);
636 1.43.2.7 chap MIDI_IN_UNLOCK(sc,s);
637 1.43.2.6 chap break;
638 1.43.2.6 chap #if defined(AUDIO_DEBUG) || defined(DIAGNOSTIC)
639 1.43.2.6 chap default:
640 1.43.2.7 chap printf("midi_in: midi_fst returned %d?!\n", got);
641 1.43.2.6 chap #endif
642 1.1 augustss }
643 1.1 augustss }
644 1.1 augustss
645 1.1 augustss void
646 1.22 augustss midi_out(void *addr)
647 1.1 augustss {
648 1.1 augustss struct midi_softc *sc = addr;
649 1.3 augustss
650 1.3 augustss if (!sc->isopen)
651 1.3 augustss return;
652 1.43.2.2 chap DPRINTFN(8, ("midi_out: %p\n", sc));
653 1.43.2.7 chap midi_intr_out(sc);
654 1.1 augustss }
655 1.1 augustss
656 1.1 augustss int
657 1.43.2.1 chap midiopen(dev_t dev, int flags, int ifmt, struct proc *p)
658 1.1 augustss {
659 1.1 augustss struct midi_softc *sc;
660 1.43.2.1 chap struct midi_hw_if *hw;
661 1.1 augustss int error;
662 1.1 augustss
663 1.17 thorpej sc = device_lookup(&midi_cd, MIDIUNIT(dev));
664 1.17 thorpej if (sc == NULL)
665 1.17 thorpej return (ENXIO);
666 1.18 tshiozak if (sc->dying)
667 1.18 tshiozak return (EIO);
668 1.17 thorpej
669 1.43.2.2 chap DPRINTFN(3,("midiopen %p\n", sc));
670 1.1 augustss
671 1.1 augustss hw = sc->hw_if;
672 1.1 augustss if (!hw)
673 1.1 augustss return ENXIO;
674 1.1 augustss if (sc->isopen)
675 1.1 augustss return EBUSY;
676 1.43.2.7 chap
677 1.43.2.7 chap /* put both state machines into known states */
678 1.43.2.6 chap sc->rcv.state = MIDI_IN_START;
679 1.43.2.7 chap sc->rcv.pos = sc->rcv.msg;
680 1.43.2.7 chap sc->rcv.end = sc->rcv.msg;
681 1.43.2.6 chap sc->xmt.state = MIDI_IN_START;
682 1.43.2.6 chap sc->xmt.pos = sc->xmt.msg;
683 1.43.2.6 chap sc->xmt.end = sc->xmt.msg;
684 1.43.2.7 chap
685 1.43.2.7 chap /* and the buffers */
686 1.43.2.7 chap midi_initbuf(&sc->outbuf);
687 1.43.2.7 chap midi_initbuf(&sc->inbuf);
688 1.43.2.7 chap
689 1.1 augustss error = hw->open(sc->hw_hdl, flags, midi_in, midi_out, sc);
690 1.1 augustss if (error)
691 1.1 augustss return error;
692 1.1 augustss sc->isopen++;
693 1.1 augustss sc->flags = flags;
694 1.1 augustss sc->rchan = 0;
695 1.1 augustss sc->wchan = 0;
696 1.1 augustss sc->pbus = 0;
697 1.1 augustss sc->async = 0;
698 1.1 augustss
699 1.4 augustss #ifdef MIDI_SAVE
700 1.4 augustss if (midicnt != 0) {
701 1.4 augustss midisave.cnt = midicnt;
702 1.4 augustss midicnt = 0;
703 1.4 augustss }
704 1.4 augustss #endif
705 1.4 augustss
706 1.1 augustss return 0;
707 1.1 augustss }
708 1.1 augustss
709 1.1 augustss int
710 1.43.2.1 chap midiclose(dev_t dev, int flags, int ifmt, struct proc *p)
711 1.1 augustss {
712 1.1 augustss int unit = MIDIUNIT(dev);
713 1.1 augustss struct midi_softc *sc = midi_cd.cd_devs[unit];
714 1.43.2.1 chap struct midi_hw_if *hw = sc->hw_if;
715 1.1 augustss int s, error;
716 1.1 augustss
717 1.43.2.3 chap DPRINTFN(3,("midiclose %p\n", sc));
718 1.1 augustss
719 1.43.2.7 chap /* midi_start_output(sc); anything buffered => pbus already set! */
720 1.1 augustss error = 0;
721 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
722 1.43.2.7 chap while (sc->pbus) {
723 1.43.2.7 chap DPRINTFN(8,("midiclose sleep ...\n"));
724 1.43.2.7 chap error =
725 1.43.2.7 chap midi_sleep_timo(&sc->wchan, "mid_dr", 30*hz, &sc->out_lock);
726 1.1 augustss }
727 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
728 1.43.2.7 chap callout_stop(&sc->sc_callout); /* xxx fix this - sleep? */
729 1.3 augustss sc->isopen = 0;
730 1.1 augustss hw->close(sc->hw_hdl);
731 1.1 augustss #if NSEQUENCER > 0
732 1.1 augustss sc->seqopen = 0;
733 1.7 augustss sc->seq_md = 0;
734 1.1 augustss #endif
735 1.1 augustss return 0;
736 1.1 augustss }
737 1.1 augustss
738 1.1 augustss int
739 1.22 augustss midiread(dev_t dev, struct uio *uio, int ioflag)
740 1.1 augustss {
741 1.1 augustss int unit = MIDIUNIT(dev);
742 1.1 augustss struct midi_softc *sc = midi_cd.cd_devs[unit];
743 1.1 augustss struct midi_buffer *mb = &sc->inbuf;
744 1.1 augustss int error;
745 1.1 augustss int s;
746 1.43.2.7 chap MIDI_BUF_DECLARE(idx);
747 1.43.2.7 chap MIDI_BUF_DECLARE(buf);
748 1.43.2.7 chap int appetite;
749 1.43.2.7 chap int first = 1;
750 1.1 augustss
751 1.43.2.2 chap DPRINTFN(6,("midiread: %p, count=%lu\n", sc,
752 1.11 nathanw (unsigned long)uio->uio_resid));
753 1.1 augustss
754 1.18 tshiozak if (sc->dying)
755 1.18 tshiozak return EIO;
756 1.43.2.4 chap if ( !(sc->props & MIDI_PROP_CAN_INPUT) )
757 1.43.2.4 chap return ENXIO;
758 1.18 tshiozak
759 1.43.2.7 chap MIDI_IN_LOCK(sc,s);
760 1.43.2.7 chap MIDI_BUF_CONSUMER_INIT(mb,idx);
761 1.43.2.7 chap MIDI_BUF_CONSUMER_INIT(mb,buf);
762 1.43.2.7 chap MIDI_IN_UNLOCK(sc,s);
763 1.43.2.7 chap
764 1.1 augustss error = 0;
765 1.43.2.7 chap for ( ;; ) {
766 1.43.2.7 chap /*
767 1.43.2.7 chap * If the used portion of idx wraps around the end, just take
768 1.43.2.7 chap * the first part on this iteration, and we'll get the rest on
769 1.43.2.7 chap * the next.
770 1.43.2.7 chap */
771 1.43.2.7 chap if ( idx_lim > idx_end )
772 1.43.2.7 chap idx_lim = idx_end;
773 1.43.2.7 chap /*
774 1.43.2.7 chap * Count bytes through the last complete message that will
775 1.43.2.7 chap * fit in the requested read.
776 1.43.2.7 chap */
777 1.43.2.7 chap for (appetite = uio->uio_resid; idx_cur < idx_lim; ++idx_cur) {
778 1.43.2.7 chap if ( appetite < MB_IDX_LEN(*idx_cur) )
779 1.43.2.7 chap break;
780 1.43.2.7 chap appetite -= MB_IDX_LEN(*idx_cur);
781 1.43.2.7 chap }
782 1.43.2.7 chap appetite = uio->uio_resid - appetite;
783 1.43.2.7 chap /*
784 1.43.2.7 chap * Only if the read is too small to hold even the first
785 1.43.2.7 chap * complete message will we return a partial one (updating idx
786 1.43.2.7 chap * to reflect the remaining length of the message).
787 1.43.2.7 chap */
788 1.43.2.7 chap if ( appetite == 0 && idx_cur < idx_lim ) {
789 1.43.2.7 chap if ( !first )
790 1.43.2.7 chap goto unlocked_exit; /* idx_cur not advanced */
791 1.43.2.7 chap appetite = uio->uio_resid;
792 1.43.2.7 chap *idx_cur = PACK_MB_IDX(MB_IDX_CAT(*idx_cur),
793 1.43.2.7 chap MB_IDX_LEN(*idx_cur) - appetite);
794 1.43.2.7 chap }
795 1.43.2.7 chap KASSERT(buf_cur + appetite <= buf_lim);
796 1.43.2.7 chap
797 1.43.2.7 chap /* move the bytes */
798 1.43.2.7 chap if ( appetite > 0 ) {
799 1.43.2.7 chap first = 0; /* we know we won't return empty-handed */
800 1.43.2.7 chap /* do two uiomoves if data wrap around end of buf */
801 1.43.2.7 chap if ( buf_cur + appetite > buf_end ) {
802 1.43.2.7 chap DPRINTFN(8,
803 1.43.2.7 chap ("midiread: uiomove cc=%d (prewrap)\n",
804 1.43.2.7 chap buf_end - buf_cur));
805 1.43.2.7 chap error = uiomove(buf_cur, buf_end-buf_cur, uio);
806 1.43.2.7 chap if ( error )
807 1.43.2.7 chap goto unlocked_exit;
808 1.43.2.7 chap appetite -= buf_end - buf_cur;
809 1.43.2.7 chap buf_cur = mb->buf;
810 1.1 augustss }
811 1.43.2.7 chap DPRINTFN(8, ("midiread: uiomove cc=%d\n", appetite));
812 1.43.2.7 chap error = uiomove(buf_cur, appetite, uio);
813 1.43.2.7 chap if ( error )
814 1.43.2.7 chap goto unlocked_exit;
815 1.43.2.7 chap buf_cur += appetite;
816 1.43.2.7 chap }
817 1.43.2.7 chap
818 1.43.2.7 chap MIDI_BUF_WRAP(idx);
819 1.43.2.7 chap MIDI_BUF_WRAP(buf);
820 1.43.2.7 chap
821 1.43.2.7 chap MIDI_IN_LOCK(sc,s);
822 1.43.2.7 chap MIDI_BUF_CONSUMER_WBACK(mb,idx);
823 1.43.2.7 chap MIDI_BUF_CONSUMER_WBACK(mb,buf);
824 1.43.2.7 chap if ( 0 == uio->uio_resid ) /* if read satisfied, we're done */
825 1.43.2.7 chap break;
826 1.43.2.7 chap MIDI_BUF_CONSUMER_REFRESH(mb,idx);
827 1.43.2.7 chap if ( idx_cur == idx_lim ) { /* need to wait for data? */
828 1.43.2.7 chap if ( !first ) /* never block reader if */
829 1.43.2.7 chap break; /* any data already in hand */
830 1.43.2.7 chap if (ioflag & IO_NDELAY) {
831 1.43.2.7 chap error = EWOULDBLOCK;
832 1.43.2.7 chap break;
833 1.1 augustss }
834 1.43.2.7 chap error = midi_sleep(&sc->rchan, "mid rd", &sc->in_lock);
835 1.43.2.7 chap if ( error )
836 1.43.2.7 chap break;
837 1.43.2.7 chap MIDI_BUF_CONSUMER_REFRESH(mb,idx); /* what'd we get? */
838 1.1 augustss }
839 1.43.2.7 chap MIDI_BUF_CONSUMER_REFRESH(mb,buf);
840 1.43.2.7 chap MIDI_IN_UNLOCK(sc,s);
841 1.43.2.7 chap if ( sc->dying )
842 1.18 tshiozak return EIO;
843 1.1 augustss }
844 1.43.2.7 chap MIDI_IN_UNLOCK(sc,s);
845 1.43.2.7 chap
846 1.43.2.7 chap unlocked_exit:
847 1.1 augustss return error;
848 1.1 augustss }
849 1.1 augustss
850 1.1 augustss void
851 1.22 augustss midi_timeout(void *arg)
852 1.1 augustss {
853 1.1 augustss struct midi_softc *sc = arg;
854 1.43.2.7 chap int s;
855 1.43.2.7 chap int error;
856 1.43.2.7 chap int armed;
857 1.1 augustss
858 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
859 1.43.2.7 chap if ( sc->pbus ) {
860 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
861 1.43.2.7 chap return;
862 1.43.2.7 chap }
863 1.43.2.7 chap sc->pbus = 1;
864 1.43.2.2 chap DPRINTFN(8,("midi_timeout: %p\n", sc));
865 1.43.2.7 chap
866 1.43.2.7 chap if ( sc->props & MIDI_PROP_OUT_INTR ) {
867 1.43.2.7 chap error = sc->hw_if->output(sc->hw_hdl, MIDI_ACK);
868 1.43.2.7 chap armed = (error == 0);
869 1.43.2.7 chap } else { /* polled output, do with interrupts unmasked */
870 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
871 1.43.2.7 chap error = sc->hw_if->output(sc->hw_hdl, MIDI_ACK);
872 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
873 1.43.2.7 chap armed = 0;
874 1.43.2.7 chap }
875 1.43.2.7 chap
876 1.43.2.7 chap if ( !armed ) {
877 1.43.2.7 chap sc->pbus = 0;
878 1.43.2.7 chap callout_schedule(&sc->sc_callout, mstohz(275));
879 1.43.2.7 chap }
880 1.43.2.7 chap
881 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
882 1.1 augustss }
883 1.1 augustss
884 1.43.2.5 chap /*
885 1.43.2.8 chap * The way this function was hacked up to plug into poll_out and intr_out
886 1.43.2.8 chap * after they were written won't win it any beauty contests, but it'll work
887 1.43.2.8 chap * (code in haste, refactor at leisure). This may be called with the lock
888 1.43.2.8 chap * (by intr_out) or without the lock (by poll_out) so it only does what could
889 1.43.2.8 chap * be safe either way.
890 1.43.2.8 chap */
891 1.43.2.8 chap int midi_msg_out(struct midi_softc *sc,
892 1.43.2.8 chap u_char **idx, u_char **idxl, u_char **buf, u_char **bufl) {
893 1.43.2.8 chap MIDI_BUF_DECLARE(idx);
894 1.43.2.8 chap MIDI_BUF_DECLARE(buf);
895 1.43.2.8 chap MIDI_BUF_EXTENT_INIT(&sc->outbuf,idx);
896 1.43.2.8 chap MIDI_BUF_EXTENT_INIT(&sc->outbuf,buf);
897 1.43.2.8 chap int length;
898 1.43.2.8 chap int error;
899 1.43.2.8 chap u_char contig[3];
900 1.43.2.8 chap u_char *cp = contig;
901 1.43.2.8 chap
902 1.43.2.8 chap idx_cur = *idx;
903 1.43.2.8 chap idx_lim = *idxl;
904 1.43.2.8 chap buf_cur = *buf;
905 1.43.2.8 chap buf_lim = *bufl;
906 1.43.2.8 chap
907 1.43.2.8 chap length = MB_IDX_LEN(*idx_cur);
908 1.43.2.8 chap
909 1.43.2.8 chap while ( length --> 0 ) {
910 1.43.2.8 chap *cp++ = *buf_cur++;
911 1.43.2.8 chap MIDI_BUF_WRAP(buf);
912 1.43.2.8 chap }
913 1.43.2.8 chap
914 1.43.2.8 chap switch ( MB_IDX_CAT(*idx_cur) ) {
915 1.43.2.8 chap case FST_CHN:
916 1.43.2.8 chap error = sc->hw_if_ext->channel(sc->hw_hdl,
917 1.43.2.8 chap MIDI_GET_STATUS(contig[0]),
918 1.43.2.8 chap MIDI_GET_CHAN(contig[0]),
919 1.43.2.8 chap contig, cp - contig);
920 1.43.2.8 chap break;
921 1.43.2.8 chap case FST_COM:
922 1.43.2.8 chap error = sc->hw_if_ext->common(sc->hw_hdl,
923 1.43.2.8 chap MIDI_GET_STATUS(contig[0]),
924 1.43.2.8 chap contig, cp - contig);
925 1.43.2.8 chap break;
926 1.43.2.8 chap case FST_SYX:
927 1.43.2.8 chap error = sc->hw_if_ext->sysex(sc->hw_hdl,
928 1.43.2.8 chap contig, cp - contig);
929 1.43.2.8 chap break;
930 1.43.2.8 chap case FST_RT:
931 1.43.2.8 chap error = sc->hw_if->output(sc->hw_hdl, **buf);
932 1.43.2.8 chap break;
933 1.43.2.8 chap default:
934 1.43.2.8 chap error = EIO;
935 1.43.2.8 chap }
936 1.43.2.8 chap
937 1.43.2.8 chap if ( !error ) {
938 1.43.2.8 chap ++ idx_cur;
939 1.43.2.8 chap MIDI_BUF_WRAP(idx);
940 1.43.2.8 chap *idx = idx_cur;
941 1.43.2.8 chap *idxl = idx_lim;
942 1.43.2.8 chap *buf = buf_cur;
943 1.43.2.8 chap *bufl = buf_lim;
944 1.43.2.8 chap }
945 1.43.2.8 chap
946 1.43.2.8 chap return error;
947 1.43.2.8 chap }
948 1.43.2.8 chap
949 1.43.2.8 chap /*
950 1.43.2.7 chap * midi_poll_out is intended for the midi hw (the vast majority of MIDI UARTs
951 1.43.2.7 chap * on sound cards, apparently) that _do not have transmit-ready interrupts_.
952 1.43.2.7 chap * Every call to hw_if->output for one of these may busy-wait to output the
953 1.43.2.7 chap * byte; at the standard midi data rate that'll be 320us per byte. The
954 1.43.2.7 chap * technique of writing only MIDI_MAX_WRITE bytes in a row and then waiting
955 1.43.2.7 chap * for MIDI_WAIT does not reduce the total time spent busy-waiting, and it
956 1.43.2.7 chap * adds arbitrary delays in transmission (and, since MIDI_WAIT is roughly the
957 1.43.2.7 chap * same as the time to send MIDI_MAX_WRITE bytes, it effectively halves the
958 1.43.2.7 chap * data rate). Here, a somewhat bolder approach is taken. Since midi traffic
959 1.43.2.7 chap * is bursty but time-sensitive--most of the time there will be none at all,
960 1.43.2.7 chap * but when there is it should go out ASAP--the strategy is to just get it
961 1.43.2.7 chap * over with, and empty the buffer in one go. The effect this can have on
962 1.43.2.7 chap * the rest of the system will be limited by the size of the buffer and the
963 1.43.2.7 chap * sparseness of the traffic. But some precautions are in order. Interrupts
964 1.43.2.7 chap * should all be unmasked when this is called, and midiwrite should not fill
965 1.43.2.7 chap * the buffer more than once (when MIDI_PROP_CAN_INTR is false) without a
966 1.43.2.7 chap * yield() so some other process can get scheduled. If the write is nonblocking,
967 1.43.2.7 chap * midiwrite should return a short count rather than yield.
968 1.43.2.5 chap *
969 1.43.2.7 chap * Someday when there is fine-grained MP support, this should be reworked to
970 1.43.2.7 chap * run in a callout so the writing process really could proceed concurrently.
971 1.43.2.7 chap * But obviously where performance is a concern, interrupt-driven hardware
972 1.43.2.7 chap * such as USB midi or (apparently) clcs will always be preferable.
973 1.43.2.5 chap */
974 1.1 augustss int
975 1.43.2.7 chap midi_poll_out(struct midi_softc *sc)
976 1.1 augustss {
977 1.1 augustss struct midi_buffer *mb = &sc->outbuf;
978 1.1 augustss int error;
979 1.43.2.7 chap int msglen;
980 1.1 augustss int s;
981 1.43.2.7 chap MIDI_BUF_DECLARE(idx);
982 1.43.2.7 chap MIDI_BUF_DECLARE(buf);
983 1.1 augustss
984 1.1 augustss error = 0;
985 1.18 tshiozak
986 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
987 1.43.2.7 chap MIDI_BUF_CONSUMER_INIT(mb,idx);
988 1.43.2.7 chap MIDI_BUF_CONSUMER_INIT(mb,buf);
989 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
990 1.43.2.7 chap
991 1.43.2.7 chap for ( ;; ) {
992 1.43.2.7 chap while ( idx_cur != idx_lim ) {
993 1.43.2.8 chap if ( sc->hw_if_ext ) {
994 1.43.2.8 chap error = midi_msg_out(sc, &idx_cur, &idx_lim,
995 1.43.2.8 chap &buf_cur, &buf_lim);
996 1.43.2.8 chap if ( error )
997 1.43.2.8 chap goto ioerror;
998 1.43.2.8 chap continue;
999 1.43.2.8 chap }
1000 1.43.2.8 chap /* or, lacking hw_if_ext ... */
1001 1.43.2.7 chap msglen = MB_IDX_LEN(*idx_cur);
1002 1.43.2.7 chap error = sc->hw_if->output(sc->hw_hdl, *buf_cur);
1003 1.43.2.7 chap if ( error )
1004 1.43.2.7 chap goto ioerror;
1005 1.43.2.7 chap ++ buf_cur;
1006 1.43.2.7 chap MIDI_BUF_WRAP(buf);
1007 1.43.2.7 chap -- msglen;
1008 1.43.2.7 chap if ( msglen )
1009 1.43.2.7 chap *idx_cur = PACK_MB_IDX(MB_IDX_CAT(*idx_cur),
1010 1.43.2.7 chap msglen);
1011 1.43.2.7 chap else {
1012 1.43.2.7 chap ++ idx_cur;
1013 1.43.2.7 chap MIDI_BUF_WRAP(idx);
1014 1.43.2.5 chap }
1015 1.43.2.5 chap }
1016 1.43.2.7 chap KASSERT(buf_cur == buf_lim);
1017 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
1018 1.43.2.7 chap MIDI_BUF_CONSUMER_WBACK(mb,idx);
1019 1.43.2.7 chap MIDI_BUF_CONSUMER_WBACK(mb,buf);
1020 1.43.2.7 chap MIDI_BUF_CONSUMER_REFRESH(mb,idx); /* any more to transmit? */
1021 1.43.2.7 chap MIDI_BUF_CONSUMER_REFRESH(mb,buf);
1022 1.43.2.7 chap if ( idx_lim == idx_cur )
1023 1.43.2.7 chap break; /* still holding lock */
1024 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
1025 1.43.2.5 chap }
1026 1.43.2.7 chap goto disarm; /* lock held */
1027 1.43.2.7 chap
1028 1.43.2.7 chap ioerror:
1029 1.43.2.7 chap #if defined(AUDIO_DEBUG) || defined(DIAGNOSTIC)
1030 1.43.2.7 chap printf("%s: midi_poll_output error %d\n",
1031 1.43.2.7 chap sc->dev.dv_xname, error);
1032 1.43.2.7 chap #endif
1033 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
1034 1.43.2.7 chap MIDI_BUF_CONSUMER_WBACK(mb,idx);
1035 1.43.2.7 chap MIDI_BUF_CONSUMER_WBACK(mb,buf);
1036 1.43.2.7 chap
1037 1.43.2.7 chap disarm:
1038 1.43.2.7 chap sc->pbus = 0;
1039 1.43.2.7 chap callout_schedule(&sc->sc_callout, mstohz(275));
1040 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
1041 1.43.2.7 chap return error;
1042 1.43.2.7 chap }
1043 1.43.2.7 chap
1044 1.43.2.7 chap /*
1045 1.43.2.7 chap * The interrupt flavor acquires spl and lock once and releases at the end,
1046 1.43.2.7 chap * as it expects to write only one byte or message. The interface convention
1047 1.43.2.7 chap * is that if hw_if->output returns 0, it has initiated transmission and the
1048 1.43.2.7 chap * completion interrupt WILL be forthcoming; if it has not returned 0, NO
1049 1.43.2.7 chap * interrupt will be forthcoming, and if it returns EINPROGRESS it wants
1050 1.43.2.7 chap * another byte right away.
1051 1.43.2.7 chap */
1052 1.43.2.7 chap int
1053 1.43.2.7 chap midi_intr_out(struct midi_softc *sc)
1054 1.43.2.7 chap {
1055 1.43.2.7 chap struct midi_buffer *mb = &sc->outbuf;
1056 1.43.2.7 chap int error;
1057 1.43.2.7 chap int msglen;
1058 1.43.2.7 chap int s;
1059 1.43.2.7 chap MIDI_BUF_DECLARE(idx);
1060 1.43.2.7 chap MIDI_BUF_DECLARE(buf);
1061 1.43.2.7 chap int armed = 0;
1062 1.43.2.7 chap
1063 1.43.2.7 chap error = 0;
1064 1.43.2.7 chap
1065 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
1066 1.43.2.7 chap MIDI_BUF_CONSUMER_INIT(mb,idx);
1067 1.43.2.7 chap MIDI_BUF_CONSUMER_INIT(mb,buf);
1068 1.43.2.5 chap
1069 1.43.2.7 chap while ( idx_cur != idx_lim ) {
1070 1.43.2.8 chap if ( sc->hw_if_ext ) {
1071 1.43.2.8 chap error = midi_msg_out(sc, &idx_cur, &idx_lim,
1072 1.43.2.8 chap &buf_cur, &buf_lim);
1073 1.43.2.8 chap if ( !error ) /* no EINPROGRESS from extended hw_if */
1074 1.43.2.8 chap armed = 1;
1075 1.43.2.8 chap break;
1076 1.43.2.8 chap }
1077 1.43.2.8 chap /* or, lacking hw_if_ext ... */
1078 1.43.2.7 chap msglen = MB_IDX_LEN(*idx_cur);
1079 1.43.2.7 chap error = sc->hw_if->output(sc->hw_hdl, *buf_cur);
1080 1.43.2.7 chap if ( error && error != EINPROGRESS )
1081 1.43.2.5 chap break;
1082 1.43.2.7 chap ++ buf_cur;
1083 1.43.2.7 chap MIDI_BUF_WRAP(buf);
1084 1.43.2.7 chap -- msglen;
1085 1.43.2.7 chap if ( msglen )
1086 1.43.2.7 chap *idx_cur = PACK_MB_IDX(MB_IDX_CAT(*idx_cur),msglen);
1087 1.43.2.7 chap else {
1088 1.43.2.7 chap ++ idx_cur;
1089 1.43.2.7 chap MIDI_BUF_WRAP(idx);
1090 1.43.2.5 chap }
1091 1.43.2.7 chap if ( !error ) {
1092 1.43.2.7 chap armed = 1;
1093 1.43.2.7 chap break;
1094 1.43.2.5 chap }
1095 1.1 augustss }
1096 1.43.2.7 chap MIDI_BUF_CONSUMER_WBACK(mb,idx);
1097 1.43.2.7 chap MIDI_BUF_CONSUMER_WBACK(mb,buf);
1098 1.43.2.7 chap if ( !armed ) {
1099 1.43.2.7 chap sc->pbus = 0;
1100 1.43.2.7 chap callout_schedule(&sc->sc_callout, mstohz(275));
1101 1.43.2.7 chap }
1102 1.43.2.7 chap midi_wakeup(&sc->wchan);
1103 1.43.2.7 chap selnotify(&sc->wsel, 0);
1104 1.43.2.7 chap if ( sc->async )
1105 1.43.2.7 chap psignal(sc->async, SIGIO);
1106 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
1107 1.43.2.5 chap
1108 1.43.2.5 chap #if defined(AUDIO_DEBUG) || defined(DIAGNOSTIC)
1109 1.43.2.7 chap if ( error )
1110 1.43.2.7 chap printf("%s: midi_intr_output error %d\n",
1111 1.43.2.7 chap sc->dev.dv_xname, error);
1112 1.43.2.5 chap #endif
1113 1.43.2.7 chap return error;
1114 1.43.2.7 chap }
1115 1.43.2.5 chap
1116 1.43.2.7 chap int
1117 1.43.2.7 chap midi_start_output(struct midi_softc *sc)
1118 1.43.2.7 chap {
1119 1.43.2.7 chap if (sc->dying)
1120 1.43.2.7 chap return EIO;
1121 1.20 tshiozak
1122 1.43.2.7 chap if ( sc->props & MIDI_PROP_OUT_INTR )
1123 1.43.2.7 chap return midi_intr_out(sc);
1124 1.43.2.7 chap return midi_poll_out(sc);
1125 1.43.2.7 chap }
1126 1.43.2.7 chap
1127 1.43.2.7 chap static int
1128 1.43.2.7 chap real_writebytes(struct midi_softc *sc, u_char *buf, int cc)
1129 1.43.2.7 chap {
1130 1.43.2.7 chap u_char *bufe = buf + cc;
1131 1.43.2.7 chap struct midi_buffer *mb = &sc->outbuf;
1132 1.43.2.7 chap int arming = 0;
1133 1.43.2.7 chap int count;
1134 1.43.2.7 chap int s;
1135 1.43.2.7 chap int got;
1136 1.43.2.7 chap MIDI_BUF_DECLARE(idx);
1137 1.43.2.7 chap MIDI_BUF_DECLARE(buf);
1138 1.43.2.7 chap
1139 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
1140 1.43.2.7 chap MIDI_BUF_PRODUCER_INIT(mb,idx);
1141 1.43.2.7 chap MIDI_BUF_PRODUCER_INIT(mb,buf);
1142 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
1143 1.43.2.7 chap
1144 1.43.2.7 chap if (sc->dying)
1145 1.43.2.7 chap return EIO;
1146 1.43.2.7 chap
1147 1.43.2.7 chap while ( buf < bufe ) {
1148 1.43.2.7 chap do
1149 1.43.2.7 chap got = midi_fst(&sc->xmt, *buf, 0);
1150 1.43.2.7 chap while ( got == FST_HUH );
1151 1.43.2.7 chap ++ buf;
1152 1.43.2.7 chap switch ( got ) {
1153 1.43.2.7 chap case FST_MORE:
1154 1.43.2.7 chap continue;
1155 1.43.2.7 chap case FST_ERR:
1156 1.43.2.7 chap #if defined(EPROTO) /* most appropriate SUSv3 errno, but not in errno.h yet */
1157 1.43.2.7 chap return EPROTO;
1158 1.43.2.7 chap #else
1159 1.43.2.7 chap return EIO;
1160 1.43.2.7 chap #endif
1161 1.43.2.7 chap case FST_CHN:
1162 1.43.2.7 chap case FST_COM:
1163 1.43.2.7 chap case FST_RT:
1164 1.43.2.7 chap case FST_SYX:
1165 1.43.2.7 chap break; /* go add to buffer */
1166 1.43.2.7 chap #if defined(AUDIO_DEBUG) || defined(DIAGNOSTIC)
1167 1.43.2.7 chap default:
1168 1.43.2.7 chap printf("midi_wr: midi_fst returned %d?!\n", got);
1169 1.43.2.7 chap #endif
1170 1.43.2.7 chap }
1171 1.43.2.7 chap count = sc->xmt.end - sc->xmt.pos;
1172 1.43.2.7 chap /*
1173 1.43.2.7 chap * return EWOULDBLOCK if the data passed will not fit in
1174 1.43.2.7 chap * the buffer; the caller should have taken steps to avoid that.
1175 1.43.2.7 chap */
1176 1.43.2.7 chap if ( idx_cur == idx_lim || count > buf_lim - buf_cur ) {
1177 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
1178 1.43.2.7 chap MIDI_BUF_PRODUCER_REFRESH(mb,idx); /* get the most */
1179 1.43.2.7 chap MIDI_BUF_PRODUCER_REFRESH(mb,buf); /* current facts */
1180 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
1181 1.43.2.7 chap if ( idx_cur == idx_lim || count > buf_lim - buf_cur )
1182 1.43.2.7 chap return EWOULDBLOCK; /* caller's problem */
1183 1.43.2.7 chap }
1184 1.43.2.7 chap *idx_cur++ = PACK_MB_IDX(got,count);
1185 1.43.2.7 chap MIDI_BUF_WRAP(idx);
1186 1.43.2.7 chap while ( count ) {
1187 1.43.2.7 chap *buf_cur++ = *(sc->xmt.pos)++;
1188 1.43.2.7 chap MIDI_BUF_WRAP(buf);
1189 1.43.2.7 chap -- count;
1190 1.43.2.7 chap }
1191 1.43.2.7 chap }
1192 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
1193 1.43.2.7 chap MIDI_BUF_PRODUCER_WBACK(mb,buf);
1194 1.43.2.7 chap MIDI_BUF_PRODUCER_WBACK(mb,idx);
1195 1.43.2.7 chap /*
1196 1.43.2.7 chap * If the output transfer is not already busy, and there is a message
1197 1.43.2.7 chap * buffered, mark it busy, stop the Active Sense callout (what if we're
1198 1.43.2.7 chap * too late and it's expired already? No big deal, an extra Active Sense
1199 1.43.2.7 chap * never hurt anybody) and start the output transfer once we're out of
1200 1.43.2.7 chap * the critical section (pbus==1 will stop anyone else doing the same).
1201 1.43.2.7 chap */
1202 1.43.2.7 chap if ( !sc->pbus && idx_cur < MIDI_BUF_PRODUCER_REFRESH(mb,idx) ) {
1203 1.43.2.7 chap sc->pbus = 1;
1204 1.43.2.7 chap callout_stop(&sc->sc_callout);
1205 1.43.2.7 chap arming = 1;
1206 1.43.2.7 chap }
1207 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
1208 1.43.2.7 chap return arming ? midi_start_output(sc) : 0;
1209 1.1 augustss }
1210 1.1 augustss
1211 1.1 augustss int
1212 1.22 augustss midiwrite(dev_t dev, struct uio *uio, int ioflag)
1213 1.1 augustss {
1214 1.1 augustss int unit = MIDIUNIT(dev);
1215 1.1 augustss struct midi_softc *sc = midi_cd.cd_devs[unit];
1216 1.1 augustss struct midi_buffer *mb = &sc->outbuf;
1217 1.1 augustss int error;
1218 1.43.2.7 chap u_char inp[256];
1219 1.1 augustss int s;
1220 1.43.2.7 chap MIDI_BUF_DECLARE(idx);
1221 1.43.2.7 chap MIDI_BUF_DECLARE(buf);
1222 1.43.2.7 chap size_t idxspace;
1223 1.43.2.7 chap size_t bufspace;
1224 1.43.2.7 chap size_t xfrcount;
1225 1.43.2.7 chap int pollout = 0;
1226 1.1 augustss
1227 1.43.2.2 chap DPRINTFN(6, ("midiwrite: %p, unit=%d, count=%lu\n", sc, unit,
1228 1.11 nathanw (unsigned long)uio->uio_resid));
1229 1.1 augustss
1230 1.18 tshiozak if (sc->dying)
1231 1.18 tshiozak return EIO;
1232 1.18 tshiozak
1233 1.1 augustss error = 0;
1234 1.1 augustss while (uio->uio_resid > 0 && !error) {
1235 1.43.2.7 chap
1236 1.43.2.7 chap /*
1237 1.43.2.7 chap * block if necessary for the minimum buffer space to guarantee
1238 1.43.2.7 chap * we can write something.
1239 1.43.2.7 chap */
1240 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
1241 1.43.2.7 chap MIDI_BUF_PRODUCER_INIT(mb,idx); /* init can't go above loop; */
1242 1.43.2.7 chap MIDI_BUF_PRODUCER_INIT(mb,buf); /* real_writebytes moves cur */
1243 1.43.2.7 chap for ( ;; ) {
1244 1.43.2.7 chap idxspace = MIDI_BUF_PRODUCER_REFRESH(mb,idx) - idx_cur;
1245 1.43.2.7 chap bufspace = MIDI_BUF_PRODUCER_REFRESH(mb,buf) - buf_cur;
1246 1.43.2.7 chap if ( idxspace >= 1 && bufspace >= 3 && !pollout )
1247 1.43.2.7 chap break;
1248 1.43.2.7 chap DPRINTFN(8,("midi_write: sleep idx=%d buf=%d\n",
1249 1.43.2.7 chap idxspace, bufspace));
1250 1.1 augustss if (ioflag & IO_NDELAY) {
1251 1.43.2.7 chap error = EWOULDBLOCK;
1252 1.43.2.7 chap /*
1253 1.43.2.7 chap * If some amount has already been transferred,
1254 1.43.2.7 chap * the common syscall code will automagically
1255 1.43.2.7 chap * convert this to success with a short count.
1256 1.43.2.7 chap */
1257 1.43.2.7 chap goto locked_exit;
1258 1.1 augustss }
1259 1.43.2.7 chap if ( pollout ) {
1260 1.43.2.7 chap preempt(0); /* see midi_poll_output */
1261 1.43.2.7 chap pollout = 0;
1262 1.43.2.7 chap } else
1263 1.43.2.7 chap error = midi_sleep(&sc->wchan, "mid wr",
1264 1.43.2.7 chap &sc->out_lock);
1265 1.43.2.7 chap if (error)
1266 1.43.2.7 chap /*
1267 1.43.2.7 chap * Similarly, the common code will handle
1268 1.43.2.7 chap * EINTR and ERESTART properly here, changing to
1269 1.43.2.7 chap * a short count if something transferred.
1270 1.43.2.7 chap */
1271 1.43.2.7 chap goto locked_exit;
1272 1.43.2.7 chap }
1273 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
1274 1.43.2.7 chap
1275 1.43.2.7 chap /*
1276 1.43.2.7 chap * The number of bytes we can safely extract from the uio
1277 1.43.2.7 chap * depends on the available idx and buf space. Worst case,
1278 1.43.2.7 chap * every byte is a message so 1 idx is required per byte.
1279 1.43.2.7 chap * Worst case, the first byte completes a 3-byte msg in prior
1280 1.43.2.7 chap * state, and every subsequent byte is a Program Change or
1281 1.43.2.7 chap * Channel Pressure msg with running status and expands to 2
1282 1.43.2.7 chap * bytes, so the buf space reqd is 3+2(n-1) or 2n+1. So limit
1283 1.43.2.7 chap * the transfer to the min of idxspace and (bufspace-1)>>1.
1284 1.43.2.7 chap */
1285 1.43.2.7 chap xfrcount = (bufspace - 1) >> 1;
1286 1.43.2.7 chap if ( xfrcount > idxspace )
1287 1.43.2.7 chap xfrcount = idxspace;
1288 1.43.2.7 chap if ( xfrcount > sizeof inp )
1289 1.43.2.7 chap xfrcount = sizeof inp;
1290 1.43.2.7 chap if ( xfrcount > uio->uio_resid )
1291 1.43.2.7 chap xfrcount = uio->uio_resid;
1292 1.43.2.7 chap
1293 1.43.2.7 chap error = uiomove(inp, xfrcount, uio);
1294 1.1 augustss #ifdef MIDI_DEBUG
1295 1.1 augustss if (error)
1296 1.9 augustss printf("midi_write:(1) uiomove failed %d; "
1297 1.43.2.7 chap "xfrcount=%d inp=%p\n",
1298 1.43.2.7 chap error, xfrcount, inp);
1299 1.1 augustss #endif
1300 1.43.2.7 chap if ( error )
1301 1.43.2.7 chap break;
1302 1.43.2.7 chap
1303 1.43.2.7 chap /*
1304 1.43.2.7 chap * The number of bytes we extracted being calculated to
1305 1.43.2.7 chap * definitely fit in the buffer even with canonicalization,
1306 1.43.2.7 chap * there is no excuse for real_writebytes to return EWOULDBLOCK.
1307 1.43.2.7 chap */
1308 1.43.2.7 chap error = real_writebytes(sc, inp, xfrcount);
1309 1.43.2.7 chap KASSERT(error != EWOULDBLOCK);
1310 1.43.2.7 chap
1311 1.43.2.7 chap if ( error )
1312 1.1 augustss break;
1313 1.43.2.7 chap /*
1314 1.43.2.7 chap * If this is a polling device and we just sent a buffer, let's
1315 1.43.2.7 chap * not send another without giving some other process a chance.
1316 1.43.2.7 chap */
1317 1.43.2.7 chap if ( ! (sc->props & MIDI_PROP_OUT_INTR) )
1318 1.43.2.7 chap pollout = 1;
1319 1.43.2.7 chap DPRINTFN(8,("midiwrite: uio_resid now %u, props=%d\n",
1320 1.43.2.7 chap uio->uio_resid, sc->props));
1321 1.1 augustss }
1322 1.1 augustss return error;
1323 1.43.2.7 chap
1324 1.43.2.7 chap locked_exit:
1325 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
1326 1.43.2.7 chap return error;
1327 1.5 augustss }
1328 1.5 augustss
1329 1.5 augustss /*
1330 1.9 augustss * This write routine is only called from sequencer code and expects
1331 1.5 augustss * a write that is smaller than the MIDI buffer.
1332 1.5 augustss */
1333 1.5 augustss int
1334 1.43.2.1 chap midi_writebytes(int unit, u_char *buf, int cc)
1335 1.5 augustss {
1336 1.5 augustss struct midi_softc *sc = midi_cd.cd_devs[unit];
1337 1.5 augustss
1338 1.43.2.2 chap DPRINTFN(7, ("midi_writebytes: %p, unit=%d, cc=%d %#02x %#02x %#02x\n",
1339 1.43.2.2 chap sc, unit, cc, buf[0], buf[1], buf[2]));
1340 1.43.2.7 chap return real_writebytes(sc, buf, cc);
1341 1.1 augustss }
1342 1.1 augustss
1343 1.1 augustss int
1344 1.43.2.1 chap midiioctl(dev_t dev, u_long cmd, caddr_t addr, int flag, struct proc *p)
1345 1.1 augustss {
1346 1.1 augustss int unit = MIDIUNIT(dev);
1347 1.1 augustss struct midi_softc *sc = midi_cd.cd_devs[unit];
1348 1.43.2.1 chap struct midi_hw_if *hw = sc->hw_if;
1349 1.1 augustss int error;
1350 1.43.2.7 chap int s;
1351 1.43.2.7 chap MIDI_BUF_DECLARE(buf);
1352 1.1 augustss
1353 1.43.2.2 chap DPRINTFN(5,("midiioctl: %p cmd=0x%08lx\n", sc, cmd));
1354 1.18 tshiozak
1355 1.18 tshiozak if (sc->dying)
1356 1.18 tshiozak return EIO;
1357 1.18 tshiozak
1358 1.1 augustss error = 0;
1359 1.1 augustss switch (cmd) {
1360 1.1 augustss case FIONBIO:
1361 1.1 augustss /* All handled in the upper FS layer. */
1362 1.1 augustss break;
1363 1.43.2.7 chap
1364 1.43.2.7 chap case FIONREAD:
1365 1.43.2.7 chap /*
1366 1.43.2.7 chap * This code relies on the current implementation of midi_in
1367 1.43.2.7 chap * always updating buf and idx together in a critical section,
1368 1.43.2.7 chap * so buf always ends at a message boundary. Document this
1369 1.43.2.7 chap * ioctl as always returning a value such that the last message
1370 1.43.2.7 chap * included is complete (SysEx the only exception), and then
1371 1.43.2.7 chap * make sure the implementation doesn't regress. NB that
1372 1.43.2.7 chap * means if this ioctl returns n and the proc then issues a
1373 1.43.2.7 chap * read of n, n bytes will be read, but if the proc issues a
1374 1.43.2.7 chap * read of m < n, fewer than m bytes may be read to ensure the
1375 1.43.2.7 chap * read ends at a message boundary.
1376 1.43.2.7 chap */
1377 1.43.2.7 chap MIDI_IN_LOCK(sc,s);
1378 1.43.2.7 chap MIDI_BUF_CONSUMER_INIT(&sc->inbuf,buf);
1379 1.43.2.7 chap MIDI_IN_UNLOCK(sc,s);
1380 1.43.2.7 chap *(int *)addr = buf_lim - buf_cur;
1381 1.43.2.7 chap break;
1382 1.1 augustss
1383 1.1 augustss case FIOASYNC:
1384 1.1 augustss if (*(int *)addr) {
1385 1.1 augustss if (sc->async)
1386 1.1 augustss return EBUSY;
1387 1.43.2.1 chap sc->async = p;
1388 1.43.2.2 chap DPRINTFN(5,("midi_ioctl: FIOASYNC %p\n", p));
1389 1.1 augustss } else
1390 1.1 augustss sc->async = 0;
1391 1.1 augustss break;
1392 1.1 augustss
1393 1.1 augustss #if 0
1394 1.1 augustss case MIDI_PRETIME:
1395 1.1 augustss /* XXX OSS
1396 1.1 augustss * This should set up a read timeout, but that's
1397 1.1 augustss * why we have poll(), so there's nothing yet. */
1398 1.1 augustss error = EINVAL;
1399 1.1 augustss break;
1400 1.1 augustss #endif
1401 1.1 augustss
1402 1.4 augustss #ifdef MIDI_SAVE
1403 1.4 augustss case MIDI_GETSAVE:
1404 1.4 augustss error = copyout(&midisave, *(void **)addr, sizeof midisave);
1405 1.4 augustss break;
1406 1.4 augustss #endif
1407 1.4 augustss
1408 1.1 augustss default:
1409 1.1 augustss if (hw->ioctl)
1410 1.43.2.1 chap error = hw->ioctl(sc->hw_hdl, cmd, addr, flag, p);
1411 1.1 augustss else
1412 1.1 augustss error = EINVAL;
1413 1.1 augustss break;
1414 1.1 augustss }
1415 1.1 augustss return error;
1416 1.1 augustss }
1417 1.1 augustss
1418 1.1 augustss int
1419 1.43.2.1 chap midipoll(dev_t dev, int events, struct proc *p)
1420 1.1 augustss {
1421 1.1 augustss int unit = MIDIUNIT(dev);
1422 1.1 augustss struct midi_softc *sc = midi_cd.cd_devs[unit];
1423 1.1 augustss int revents = 0;
1424 1.24 gson int s;
1425 1.43.2.7 chap MIDI_BUF_DECLARE(idx);
1426 1.43.2.7 chap MIDI_BUF_DECLARE(buf);
1427 1.1 augustss
1428 1.43.2.2 chap DPRINTFN(6,("midipoll: %p events=0x%x\n", sc, events));
1429 1.1 augustss
1430 1.18 tshiozak if (sc->dying)
1431 1.43.2.1 chap return EIO;
1432 1.24 gson
1433 1.24 gson s = splaudio();
1434 1.18 tshiozak
1435 1.43.2.7 chap if ((sc->flags&FREAD) && (events & (POLLIN | POLLRDNORM))) {
1436 1.43.2.7 chap simple_lock(&sc->in_lock);
1437 1.43.2.7 chap MIDI_BUF_CONSUMER_INIT(&sc->inbuf,idx);
1438 1.43.2.7 chap if (idx_cur < idx_lim)
1439 1.1 augustss revents |= events & (POLLIN | POLLRDNORM);
1440 1.43.2.7 chap else
1441 1.43.2.1 chap selrecord(p, &sc->rsel);
1442 1.43.2.7 chap simple_unlock(&sc->in_lock);
1443 1.43.2.7 chap }
1444 1.1 augustss
1445 1.43.2.7 chap if ((sc->flags&FWRITE) && (events & (POLLOUT | POLLWRNORM))) {
1446 1.43.2.7 chap simple_lock(&sc->out_lock);
1447 1.43.2.7 chap MIDI_BUF_PRODUCER_INIT(&sc->outbuf,idx);
1448 1.43.2.7 chap MIDI_BUF_PRODUCER_INIT(&sc->outbuf,buf);
1449 1.43.2.7 chap if ( idx_lim - idx_cur >= 1 && buf_lim - buf_cur >= 3 )
1450 1.43.2.7 chap revents |= events & (POLLOUT | POLLWRNORM);
1451 1.43.2.7 chap else
1452 1.43.2.1 chap selrecord(p, &sc->wsel);
1453 1.43.2.7 chap simple_unlock(&sc->out_lock);
1454 1.1 augustss }
1455 1.1 augustss
1456 1.1 augustss splx(s);
1457 1.1 augustss return revents;
1458 1.30 jdolecek }
1459 1.30 jdolecek
1460 1.30 jdolecek static void
1461 1.30 jdolecek filt_midirdetach(struct knote *kn)
1462 1.30 jdolecek {
1463 1.30 jdolecek struct midi_softc *sc = kn->kn_hook;
1464 1.30 jdolecek int s;
1465 1.30 jdolecek
1466 1.30 jdolecek s = splaudio();
1467 1.31 christos SLIST_REMOVE(&sc->rsel.sel_klist, kn, knote, kn_selnext);
1468 1.30 jdolecek splx(s);
1469 1.30 jdolecek }
1470 1.30 jdolecek
1471 1.30 jdolecek static int
1472 1.30 jdolecek filt_midiread(struct knote *kn, long hint)
1473 1.30 jdolecek {
1474 1.30 jdolecek struct midi_softc *sc = kn->kn_hook;
1475 1.43.2.7 chap int s;
1476 1.43.2.7 chap MIDI_BUF_DECLARE(buf);
1477 1.30 jdolecek
1478 1.30 jdolecek /* XXXLUKEM (thorpej): please make sure this is correct. */
1479 1.30 jdolecek
1480 1.43.2.7 chap MIDI_IN_LOCK(sc,s);
1481 1.43.2.7 chap MIDI_BUF_CONSUMER_INIT(&sc->inbuf,buf);
1482 1.43.2.7 chap kn->kn_data = buf_lim - buf_cur;
1483 1.43.2.7 chap MIDI_IN_UNLOCK(sc,s);
1484 1.30 jdolecek return (kn->kn_data > 0);
1485 1.30 jdolecek }
1486 1.30 jdolecek
1487 1.30 jdolecek static const struct filterops midiread_filtops =
1488 1.30 jdolecek { 1, NULL, filt_midirdetach, filt_midiread };
1489 1.30 jdolecek
1490 1.30 jdolecek static void
1491 1.30 jdolecek filt_midiwdetach(struct knote *kn)
1492 1.30 jdolecek {
1493 1.30 jdolecek struct midi_softc *sc = kn->kn_hook;
1494 1.30 jdolecek int s;
1495 1.30 jdolecek
1496 1.30 jdolecek s = splaudio();
1497 1.31 christos SLIST_REMOVE(&sc->wsel.sel_klist, kn, knote, kn_selnext);
1498 1.30 jdolecek splx(s);
1499 1.30 jdolecek }
1500 1.30 jdolecek
1501 1.30 jdolecek static int
1502 1.30 jdolecek filt_midiwrite(struct knote *kn, long hint)
1503 1.30 jdolecek {
1504 1.30 jdolecek struct midi_softc *sc = kn->kn_hook;
1505 1.43.2.7 chap int s;
1506 1.43.2.7 chap MIDI_BUF_DECLARE(idx);
1507 1.43.2.7 chap MIDI_BUF_DECLARE(buf);
1508 1.30 jdolecek
1509 1.30 jdolecek /* XXXLUKEM (thorpej): please make sure this is correct. */
1510 1.30 jdolecek
1511 1.43.2.7 chap MIDI_OUT_LOCK(sc,s);
1512 1.43.2.7 chap MIDI_BUF_PRODUCER_INIT(&sc->outbuf,idx);
1513 1.43.2.7 chap MIDI_BUF_PRODUCER_INIT(&sc->outbuf,buf);
1514 1.43.2.7 chap kn->kn_data = ((buf_lim - buf_cur)-1)>>1;
1515 1.43.2.7 chap if ( kn->kn_data > idx_lim - idx_cur )
1516 1.43.2.7 chap kn->kn_data = idx_lim - idx_cur;
1517 1.43.2.7 chap MIDI_OUT_UNLOCK(sc,s);
1518 1.30 jdolecek return (kn->kn_data > 0);
1519 1.30 jdolecek }
1520 1.30 jdolecek
1521 1.30 jdolecek static const struct filterops midiwrite_filtops =
1522 1.30 jdolecek { 1, NULL, filt_midiwdetach, filt_midiwrite };
1523 1.30 jdolecek
1524 1.30 jdolecek int
1525 1.30 jdolecek midikqfilter(dev_t dev, struct knote *kn)
1526 1.30 jdolecek {
1527 1.30 jdolecek int unit = MIDIUNIT(dev);
1528 1.30 jdolecek struct midi_softc *sc = midi_cd.cd_devs[unit];
1529 1.30 jdolecek struct klist *klist;
1530 1.30 jdolecek int s;
1531 1.30 jdolecek
1532 1.30 jdolecek switch (kn->kn_filter) {
1533 1.30 jdolecek case EVFILT_READ:
1534 1.31 christos klist = &sc->rsel.sel_klist;
1535 1.30 jdolecek kn->kn_fop = &midiread_filtops;
1536 1.30 jdolecek break;
1537 1.30 jdolecek
1538 1.30 jdolecek case EVFILT_WRITE:
1539 1.31 christos klist = &sc->wsel.sel_klist;
1540 1.30 jdolecek kn->kn_fop = &midiwrite_filtops;
1541 1.30 jdolecek break;
1542 1.30 jdolecek
1543 1.30 jdolecek default:
1544 1.30 jdolecek return (1);
1545 1.30 jdolecek }
1546 1.30 jdolecek
1547 1.30 jdolecek kn->kn_hook = sc;
1548 1.30 jdolecek
1549 1.30 jdolecek s = splaudio();
1550 1.30 jdolecek SLIST_INSERT_HEAD(klist, kn, kn_selnext);
1551 1.30 jdolecek splx(s);
1552 1.30 jdolecek
1553 1.30 jdolecek return (0);
1554 1.1 augustss }
1555 1.1 augustss
1556 1.1 augustss void
1557 1.22 augustss midi_getinfo(dev_t dev, struct midi_info *mi)
1558 1.1 augustss {
1559 1.1 augustss struct midi_softc *sc;
1560 1.1 augustss
1561 1.17 thorpej sc = device_lookup(&midi_cd, MIDIUNIT(dev));
1562 1.17 thorpej if (sc == NULL)
1563 1.18 tshiozak return;
1564 1.18 tshiozak if (sc->dying)
1565 1.1 augustss return;
1566 1.17 thorpej
1567 1.1 augustss sc->hw_if->getinfo(sc->hw_hdl, mi);
1568 1.4 augustss }
1569 1.4 augustss
1570 1.10 drochner #endif /* NMIDI > 0 */
1571 1.10 drochner
1572 1.10 drochner #if NMIDI > 0 || NMIDIBUS > 0
1573 1.10 drochner
1574 1.22 augustss int audioprint(void *, const char *);
1575 1.4 augustss
1576 1.12 augustss struct device *
1577 1.43.2.1 chap midi_attach_mi(struct midi_hw_if *mhwp, void *hdlp, struct device *dev)
1578 1.4 augustss {
1579 1.4 augustss struct audio_attach_args arg;
1580 1.4 augustss
1581 1.4 augustss #ifdef DIAGNOSTIC
1582 1.4 augustss if (mhwp == NULL) {
1583 1.32 thorpej aprint_error("midi_attach_mi: NULL\n");
1584 1.12 augustss return (0);
1585 1.4 augustss }
1586 1.4 augustss #endif
1587 1.4 augustss arg.type = AUDIODEV_TYPE_MIDI;
1588 1.4 augustss arg.hwif = mhwp;
1589 1.4 augustss arg.hdl = hdlp;
1590 1.12 augustss return (config_found(dev, &arg, audioprint));
1591 1.1 augustss }
1592 1.1 augustss
1593 1.10 drochner #endif /* NMIDI > 0 || NMIDIBUS > 0 */
1594