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