midirecord.c revision 1.10.2.1 1 1.10.2.1 pgoyette /* $NetBSD: midirecord.c,v 1.10.2.1 2017/01/07 08:56:58 pgoyette Exp $ */
2 1.1 mrg
3 1.1 mrg /*
4 1.10.2.1 pgoyette * Copyright (c) 2014, 2015 Matthew R. Green
5 1.1 mrg * All rights reserved.
6 1.1 mrg *
7 1.1 mrg * Redistribution and use in source and binary forms, with or without
8 1.1 mrg * modification, are permitted provided that the following conditions
9 1.1 mrg * are met:
10 1.1 mrg * 1. Redistributions of source code must retain the above copyright
11 1.1 mrg * notice, this list of conditions and the following disclaimer.
12 1.1 mrg * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 mrg * notice, this list of conditions and the following disclaimer in the
14 1.1 mrg * documentation and/or other materials provided with the distribution.
15 1.1 mrg *
16 1.1 mrg * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
17 1.1 mrg * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18 1.1 mrg * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19 1.1 mrg * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
20 1.1 mrg * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
21 1.1 mrg * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
22 1.1 mrg * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
23 1.1 mrg * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
24 1.1 mrg * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25 1.1 mrg * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26 1.1 mrg * SUCH DAMAGE.
27 1.1 mrg */
28 1.1 mrg
29 1.1 mrg /*
30 1.1 mrg * midirecord(1), similar to audiorecord(1).
31 1.1 mrg */
32 1.1 mrg
33 1.1 mrg #include <sys/cdefs.h>
34 1.1 mrg
35 1.1 mrg #ifndef lint
36 1.10.2.1 pgoyette __RCSID("$NetBSD: midirecord.c,v 1.10.2.1 2017/01/07 08:56:58 pgoyette Exp $");
37 1.1 mrg #endif
38 1.1 mrg
39 1.1 mrg #include <sys/param.h>
40 1.1 mrg #include <sys/midiio.h>
41 1.1 mrg #include <sys/ioctl.h>
42 1.1 mrg #include <sys/time.h>
43 1.1 mrg #include <sys/uio.h>
44 1.1 mrg
45 1.1 mrg #include <err.h>
46 1.1 mrg #include <errno.h>
47 1.1 mrg #include <ctype.h>
48 1.1 mrg #include <fcntl.h>
49 1.1 mrg #include <paths.h>
50 1.1 mrg #include <signal.h>
51 1.1 mrg #include <stdio.h>
52 1.1 mrg #include <stdlib.h>
53 1.1 mrg #include <string.h>
54 1.1 mrg #include <unistd.h>
55 1.1 mrg #include <util.h>
56 1.1 mrg #include <assert.h>
57 1.1 mrg #include <stdbool.h>
58 1.1 mrg
59 1.1 mrg #include "libaudio.h"
60 1.1 mrg
61 1.1 mrg static const char *midi_device;
62 1.1 mrg static unsigned *filt_devnos = NULL;
63 1.1 mrg static unsigned *filt_chans = NULL;
64 1.1 mrg static unsigned num_filt_devnos, num_filt_chans;
65 1.1 mrg static char *raw_output;
66 1.1 mrg static int midifd;
67 1.1 mrg static int aflag, qflag, oflag;
68 1.1 mrg static bool debug = false;
69 1.1 mrg int verbose;
70 1.1 mrg static int outfd, rawfd = -1;
71 1.1 mrg static ssize_t data_size;
72 1.1 mrg static struct timeval record_time;
73 1.1 mrg static struct timeval start_time;
74 1.1 mrg static int tempo = 120;
75 1.10 mrg static unsigned round_beats = 1;
76 1.1 mrg static unsigned notes_per_beat = 24;
77 1.1 mrg static bool ignore_timer_fail = false;
78 1.7 mrg static bool stdout_mode = false;
79 1.1 mrg
80 1.6 joerg static void debug_log(const char *, size_t, const char *, ...)
81 1.6 joerg __printflike(3, 4);
82 1.1 mrg static size_t midi_event_local_to_output(seq_event_t, u_char *, size_t);
83 1.1 mrg static size_t midi_event_timer_wait_abs_to_output(seq_event_t, u_char *,
84 1.1 mrg size_t);
85 1.1 mrg static size_t midi_event_timer_to_output(seq_event_t, u_char *, size_t);
86 1.1 mrg static size_t midi_event_chn_common_to_output(seq_event_t, u_char *, size_t);
87 1.1 mrg static size_t midi_event_chn_voice_to_output(seq_event_t, u_char *, size_t);
88 1.1 mrg static size_t midi_event_sysex_to_output(seq_event_t, u_char *, size_t);
89 1.1 mrg static size_t midi_event_fullsize_to_output(seq_event_t, u_char *, size_t);
90 1.1 mrg static size_t midi_event_to_output(seq_event_t, u_char *, size_t);
91 1.1 mrg static int timeleft(struct timeval *, struct timeval *);
92 1.1 mrg static bool filter_array(unsigned, unsigned *, size_t);
93 1.1 mrg static bool filter_dev(unsigned);
94 1.1 mrg static bool filter_chan(unsigned);
95 1.1 mrg static bool filter_devchan(unsigned, unsigned);
96 1.1 mrg static void parse_ints(const char *, unsigned **, unsigned *, const char *);
97 1.1 mrg static void cleanup(int) __dead;
98 1.1 mrg static void rewrite_header(void);
99 1.1 mrg static void write_midi_header(void);
100 1.1 mrg static void write_midi_trailer(void);
101 1.1 mrg static void usage(void) __dead;
102 1.1 mrg
103 1.1 mrg #define PATH_DEV_MUSIC "/dev/music"
104 1.1 mrg
105 1.1 mrg int
106 1.1 mrg main(int argc, char *argv[])
107 1.1 mrg {
108 1.1 mrg u_char *buffer;
109 1.1 mrg size_t bufsize = 0;
110 1.1 mrg int ch, no_time_limit = 1;
111 1.1 mrg
112 1.4 mrg while ((ch = getopt(argc, argv, "aB:c:Dd:f:hn:oqr:t:T:V")) != -1) {
113 1.1 mrg switch (ch) {
114 1.1 mrg case 'a':
115 1.1 mrg aflag++;
116 1.1 mrg break;
117 1.1 mrg case 'B':
118 1.1 mrg bufsize = strsuftoll("read buffer size", optarg,
119 1.1 mrg 1, UINT_MAX);
120 1.1 mrg break;
121 1.1 mrg case 'c':
122 1.1 mrg parse_ints(optarg, &filt_chans, &num_filt_chans,
123 1.1 mrg "channels");
124 1.1 mrg break;
125 1.1 mrg case 'D':
126 1.8 christos debug = true;
127 1.1 mrg break;
128 1.1 mrg case 'd':
129 1.1 mrg parse_ints(optarg, &filt_devnos, &num_filt_devnos,
130 1.1 mrg "devices");
131 1.1 mrg break;
132 1.1 mrg case 'f':
133 1.1 mrg midi_device = optarg;
134 1.1 mrg ignore_timer_fail = true;
135 1.1 mrg break;
136 1.1 mrg case 'n':
137 1.1 mrg decode_uint(optarg, ¬es_per_beat);
138 1.1 mrg break;
139 1.1 mrg case 'o':
140 1.1 mrg oflag++; /* time stamp starts at proc start */
141 1.1 mrg break;
142 1.1 mrg case 'q':
143 1.1 mrg qflag++;
144 1.1 mrg break;
145 1.1 mrg case 'r':
146 1.1 mrg raw_output = optarg;
147 1.1 mrg break;
148 1.10 mrg case 'R':
149 1.10 mrg decode_uint(optarg, &round_beats);
150 1.10 mrg if (round_beats == 0)
151 1.10 mrg errx(1, "-R <round_beats> must be a positive integer");
152 1.10 mrg break;
153 1.1 mrg case 't':
154 1.1 mrg no_time_limit = 0;
155 1.1 mrg decode_time(optarg, &record_time);
156 1.1 mrg break;
157 1.1 mrg case 'T':
158 1.1 mrg decode_int(optarg, &tempo);
159 1.1 mrg break;
160 1.1 mrg case 'V':
161 1.1 mrg verbose++;
162 1.1 mrg break;
163 1.1 mrg /* case 'h': */
164 1.1 mrg default:
165 1.1 mrg usage();
166 1.1 mrg /* NOTREACHED */
167 1.1 mrg }
168 1.1 mrg }
169 1.1 mrg argc -= optind;
170 1.1 mrg argv += optind;
171 1.1 mrg
172 1.1 mrg if (argc != 1)
173 1.1 mrg usage();
174 1.1 mrg
175 1.1 mrg /*
176 1.1 mrg * work out the buffer size to use, and allocate it. don't allow it
177 1.1 mrg * to be too small.
178 1.1 mrg */
179 1.1 mrg if (bufsize < 32)
180 1.1 mrg bufsize = 32 * 1024;
181 1.1 mrg buffer = malloc(bufsize);
182 1.1 mrg if (buffer == NULL)
183 1.1 mrg err(1, "couldn't malloc buffer of %d size", (int)bufsize);
184 1.1 mrg
185 1.1 mrg /*
186 1.1 mrg * open the music device
187 1.1 mrg */
188 1.1 mrg if (midi_device == NULL && (midi_device = getenv("MIDIDEVICE")) == NULL)
189 1.1 mrg midi_device = PATH_DEV_MUSIC;
190 1.1 mrg midifd = open(midi_device, O_RDONLY);
191 1.1 mrg if (midifd < 0)
192 1.1 mrg err(1, "failed to open %s", midi_device);
193 1.1 mrg
194 1.1 mrg /* open the output file */
195 1.1 mrg if (argv[0][0] != '-' || argv[0][1] != '\0') {
196 1.1 mrg int mode = O_CREAT|(aflag ? O_APPEND : O_TRUNC)|O_WRONLY;
197 1.1 mrg
198 1.1 mrg outfd = open(*argv, mode, 0666);
199 1.1 mrg if (outfd < 0)
200 1.1 mrg err(1, "could not open %s", *argv);
201 1.7 mrg } else {
202 1.7 mrg stdout_mode = true;
203 1.1 mrg outfd = STDOUT_FILENO;
204 1.7 mrg }
205 1.1 mrg
206 1.1 mrg /* open the raw output file */
207 1.1 mrg if (raw_output) {
208 1.1 mrg int mode = O_CREAT|(aflag ? O_APPEND : O_TRUNC)|O_WRONLY;
209 1.1 mrg
210 1.1 mrg rawfd = open(raw_output, mode, 0666);
211 1.1 mrg if (rawfd < 0)
212 1.1 mrg err(1, "could not open %s", raw_output);
213 1.1 mrg }
214 1.1 mrg
215 1.1 mrg /* start the midi timer */
216 1.1 mrg if (ioctl(midifd, SEQUENCER_TMR_START, NULL) < 0) {
217 1.1 mrg if (ignore_timer_fail)
218 1.1 mrg warn("failed to start midi timer");
219 1.1 mrg else
220 1.1 mrg err(1, "failed to start midi timer");
221 1.1 mrg }
222 1.1 mrg
223 1.1 mrg /* set the timebase */
224 1.1 mrg if (ioctl(midifd, SEQUENCER_TMR_TIMEBASE, ¬es_per_beat) < 0) {
225 1.1 mrg if (ignore_timer_fail)
226 1.1 mrg warn("SEQUENCER_TMR_TIMEBASE: notes_per_beat %d",
227 1.1 mrg notes_per_beat);
228 1.1 mrg else
229 1.1 mrg err(1, "SEQUENCER_TMR_TIMEBASE: notes_per_beat %d",
230 1.1 mrg notes_per_beat);
231 1.1 mrg }
232 1.1 mrg
233 1.1 mrg /* set the tempo */
234 1.1 mrg if (ioctl(midifd, SEQUENCER_TMR_TEMPO, &tempo) < 0) {
235 1.1 mrg if (ignore_timer_fail)
236 1.1 mrg warn("SEQUENCER_TMR_TIMEBASE: tempo %d", tempo);
237 1.1 mrg else
238 1.1 mrg err(1, "SEQUENCER_TMR_TIMEBASE: tempo %d", tempo);
239 1.1 mrg }
240 1.1 mrg
241 1.1 mrg signal(SIGINT, cleanup);
242 1.1 mrg
243 1.1 mrg data_size = 0;
244 1.1 mrg
245 1.1 mrg if (verbose)
246 1.8 christos fprintf(stderr, "tempo=%d notes_per_beat=%u\n",
247 1.1 mrg tempo, notes_per_beat);
248 1.1 mrg
249 1.1 mrg if (!no_time_limit && verbose)
250 1.1 mrg fprintf(stderr, "recording for %lu seconds, %lu microseconds\n",
251 1.1 mrg (u_long)record_time.tv_sec, (u_long)record_time.tv_usec);
252 1.1 mrg
253 1.1 mrg /* Create a midi header. */
254 1.1 mrg write_midi_header();
255 1.1 mrg
256 1.1 mrg (void)gettimeofday(&start_time, NULL);
257 1.1 mrg while (no_time_limit || timeleft(&start_time, &record_time)) {
258 1.1 mrg seq_event_t e;
259 1.1 mrg size_t wrsize;
260 1.1 mrg size_t rdsize;
261 1.1 mrg
262 1.1 mrg rdsize = (size_t)read(midifd, &e, sizeof e);
263 1.1 mrg if (rdsize == 0)
264 1.1 mrg break;
265 1.1 mrg
266 1.1 mrg if (rdsize != sizeof e)
267 1.1 mrg err(1, "read failed");
268 1.1 mrg
269 1.1 mrg if (rawfd != -1 && write(rawfd, &e, sizeof e) != sizeof e)
270 1.1 mrg err(1, "write to raw file failed");
271 1.1 mrg
272 1.1 mrg /* convert 'e' into something useful for output */
273 1.1 mrg wrsize = midi_event_to_output(e, buffer, bufsize);
274 1.1 mrg
275 1.1 mrg if (wrsize) {
276 1.1 mrg if ((size_t)write(outfd, buffer, wrsize) != wrsize)
277 1.1 mrg err(1, "write failed");
278 1.1 mrg data_size += wrsize;
279 1.1 mrg }
280 1.1 mrg }
281 1.1 mrg cleanup(0);
282 1.1 mrg }
283 1.1 mrg
284 1.1 mrg static void
285 1.1 mrg debug_log(const char *file, size_t line, const char *fmt, ...)
286 1.1 mrg {
287 1.1 mrg va_list ap;
288 1.1 mrg
289 1.1 mrg if (!debug)
290 1.1 mrg return;
291 1.8 christos fprintf(stderr, "%s:%zu: ", file, line);
292 1.1 mrg va_start(ap, fmt);
293 1.1 mrg vfprintf(stderr, fmt, ap);
294 1.1 mrg va_end(ap);
295 1.1 mrg fprintf(stderr, "\n");
296 1.1 mrg }
297 1.1 mrg
298 1.1 mrg #define LOG(fmt...) \
299 1.1 mrg debug_log(__func__, __LINE__, fmt)
300 1.1 mrg
301 1.1 mrg
302 1.1 mrg /*
303 1.1 mrg * handle a SEQ_LOCAL event. NetBSD /dev/music doesn't generate these.
304 1.1 mrg */
305 1.1 mrg static size_t
306 1.1 mrg midi_event_local_to_output(seq_event_t e, u_char *buffer, size_t bufsize)
307 1.1 mrg {
308 1.1 mrg size_t size = 0;
309 1.1 mrg
310 1.9 mrg LOG("UNHANDLED SEQ_LOCAL");
311 1.1 mrg
312 1.1 mrg return size;
313 1.1 mrg }
314 1.1 mrg
315 1.1 mrg /*
316 1.1 mrg * convert a midi absolute time event to a variable length delay
317 1.1 mrg */
318 1.1 mrg static size_t
319 1.1 mrg midi_event_timer_wait_abs_to_output(
320 1.1 mrg seq_event_t e,
321 1.1 mrg u_char *buffer,
322 1.1 mrg size_t bufsize)
323 1.1 mrg {
324 1.2 mrg static unsigned prev_div;
325 1.10 mrg static int prev_leftover;
326 1.2 mrg unsigned cur_div;
327 1.5 christos unsigned val = 0, xdiv;
328 1.1 mrg int vallen = 0, i;
329 1.1 mrg
330 1.1 mrg if (prev_div == 0 && !oflag)
331 1.1 mrg prev_div = e.t_WAIT_ABS.divisions;
332 1.1 mrg cur_div = e.t_WAIT_ABS.divisions;
333 1.1 mrg
334 1.10 mrg xdiv = cur_div - prev_div + prev_leftover;
335 1.10 mrg if (round_beats != 1) {
336 1.10 mrg // round to closest
337 1.10 mrg prev_leftover = xdiv % round_beats;
338 1.10 mrg xdiv -= prev_leftover;
339 1.10 mrg if (verbose)
340 1.10 mrg fprintf(stderr, "adjusted beat value to %x (leftover = %d)\n",
341 1.10 mrg xdiv, prev_leftover);
342 1.10 mrg }
343 1.5 christos if (xdiv) {
344 1.5 christos while (xdiv) {
345 1.1 mrg uint32_t extra = val ? 0x80 : 0;
346 1.1 mrg
347 1.1 mrg val <<= 8;
348 1.5 christos val |= (xdiv & 0x7f) | extra;
349 1.5 christos xdiv >>= 7;
350 1.1 mrg vallen++;
351 1.1 mrg }
352 1.1 mrg } else
353 1.2 mrg vallen = 1;
354 1.1 mrg
355 1.1 mrg for (i = 0; i < vallen; i++) {
356 1.1 mrg buffer[i] = val & 0xff;
357 1.1 mrg val >>= 8;
358 1.1 mrg }
359 1.1 mrg for (; i < 4; i++)
360 1.1 mrg buffer[i] = 0;
361 1.1 mrg LOG("TMR_WAIT_ABS: new div %x (cur %x prev %x): bufval (len=%u): "
362 1.1 mrg "%02x:%02x:%02x:%02x",
363 1.1 mrg cur_div - prev_div, cur_div, prev_div,
364 1.1 mrg vallen, buffer[0], buffer[1], buffer[2], buffer[3]);
365 1.1 mrg
366 1.1 mrg prev_div = cur_div;
367 1.1 mrg
368 1.1 mrg return vallen;
369 1.1 mrg }
370 1.1 mrg
371 1.1 mrg /*
372 1.1 mrg * handle a SEQ_TIMING event.
373 1.1 mrg */
374 1.1 mrg static size_t
375 1.1 mrg midi_event_timer_to_output(seq_event_t e, u_char *buffer, size_t bufsize)
376 1.1 mrg {
377 1.1 mrg size_t size = 0;
378 1.1 mrg
379 1.1 mrg LOG("SEQ_TIMING");
380 1.1 mrg switch (e.timing.op) {
381 1.1 mrg case TMR_WAIT_REL:
382 1.1 mrg /* NetBSD /dev/music doesn't generate these. */
383 1.1 mrg LOG("UNHANDLED TMR_WAIT_REL: divisions: %x", e.t_WAIT_REL.divisions);
384 1.1 mrg break;
385 1.1 mrg
386 1.1 mrg case TMR_WAIT_ABS:
387 1.1 mrg size = midi_event_timer_wait_abs_to_output(e, buffer, bufsize);
388 1.1 mrg break;
389 1.1 mrg
390 1.1 mrg case TMR_STOP:
391 1.1 mrg case TMR_START:
392 1.1 mrg case TMR_CONTINUE:
393 1.1 mrg case TMR_TEMPO:
394 1.1 mrg case TMR_ECHO:
395 1.1 mrg case TMR_CLOCK:
396 1.1 mrg case TMR_SPP:
397 1.1 mrg case TMR_TIMESIG:
398 1.1 mrg /* NetBSD /dev/music doesn't generate these. */
399 1.1 mrg LOG("UNHANDLED timer op: %x", e.timing.op);
400 1.1 mrg break;
401 1.1 mrg
402 1.1 mrg default:
403 1.1 mrg LOG("unknown timer op: %x", e.timing.op);
404 1.1 mrg break;
405 1.1 mrg }
406 1.1 mrg
407 1.1 mrg return size;
408 1.1 mrg }
409 1.1 mrg
410 1.1 mrg /*
411 1.1 mrg * handle a SEQ_CHN_COMMON event.
412 1.1 mrg */
413 1.1 mrg static size_t
414 1.1 mrg midi_event_chn_common_to_output(seq_event_t e, u_char *buffer, size_t bufsize)
415 1.1 mrg {
416 1.1 mrg size_t size = 0;
417 1.1 mrg
418 1.1 mrg assert(e.common.channel < 16);
419 1.1 mrg LOG("SEQ_CHN_COMMON");
420 1.1 mrg
421 1.1 mrg if (filter_devchan(e.common.device, e.common.channel))
422 1.1 mrg return 0;
423 1.1 mrg
424 1.1 mrg switch (e.common.op) {
425 1.1 mrg case MIDI_CTL_CHANGE:
426 1.1 mrg buffer[0] = MIDI_CTL_CHANGE | e.c_CTL_CHANGE.channel;
427 1.1 mrg buffer[1] = e.c_CTL_CHANGE.controller;
428 1.1 mrg buffer[2] = e.c_CTL_CHANGE.value;
429 1.1 mrg LOG("MIDI_CTL_CHANGE: channel %x ctrl %x val %x",
430 1.1 mrg e.c_CTL_CHANGE.channel, e.c_CTL_CHANGE.controller,
431 1.1 mrg e.c_CTL_CHANGE.value);
432 1.1 mrg size = 3;
433 1.1 mrg break;
434 1.1 mrg
435 1.1 mrg case MIDI_PGM_CHANGE:
436 1.1 mrg buffer[0] = MIDI_PGM_CHANGE | e.c_PGM_CHANGE.channel;
437 1.1 mrg buffer[1] = e.c_PGM_CHANGE.program;
438 1.1 mrg LOG("MIDI_PGM_CHANGE: channel %x program %x",
439 1.1 mrg e.c_PGM_CHANGE.channel, e.c_PGM_CHANGE.program);
440 1.1 mrg size = 2;
441 1.1 mrg break;
442 1.1 mrg
443 1.1 mrg case MIDI_CHN_PRESSURE:
444 1.1 mrg buffer[0] = MIDI_CHN_PRESSURE | e.c_CHN_PRESSURE.channel;
445 1.1 mrg buffer[1] = e.c_CHN_PRESSURE.pressure;
446 1.1 mrg LOG("MIDI_CHN_PRESSURE: channel %x pressure %x",
447 1.1 mrg e.c_CHN_PRESSURE.channel, e.c_CHN_PRESSURE.pressure);
448 1.1 mrg size = 2;
449 1.1 mrg break;
450 1.1 mrg
451 1.1 mrg case MIDI_PITCH_BEND:
452 1.1 mrg buffer[0] = MIDI_PITCH_BEND | e.c_PITCH_BEND.channel;
453 1.1 mrg /* 14 bits split over 2 data bytes, lsb first */
454 1.1 mrg buffer[1] = e.c_PITCH_BEND.value & 0x7f;
455 1.1 mrg buffer[2] = (e.c_PITCH_BEND.value >> 7) & 0x7f;
456 1.1 mrg LOG("MIDI_PITCH_BEND: channel %x val %x",
457 1.1 mrg e.c_PITCH_BEND.channel, e.c_PITCH_BEND.value);
458 1.1 mrg size = 3;
459 1.1 mrg break;
460 1.1 mrg
461 1.1 mrg default:
462 1.1 mrg LOG("unknown common op: %x", e.voice.op);
463 1.1 mrg break;
464 1.1 mrg }
465 1.1 mrg
466 1.1 mrg return size;
467 1.1 mrg }
468 1.1 mrg
469 1.1 mrg /*
470 1.1 mrg * handle a SEQ_CHN_VOICE event.
471 1.1 mrg */
472 1.1 mrg static size_t
473 1.1 mrg midi_event_chn_voice_to_output(seq_event_t e, u_char *buffer, size_t bufsize)
474 1.1 mrg {
475 1.1 mrg size_t size = 0;
476 1.1 mrg
477 1.1 mrg assert(e.common.channel < 16);
478 1.1 mrg LOG("SEQ_CHN_VOICE");
479 1.1 mrg
480 1.1 mrg if (filter_devchan(e.voice.device, e.voice.channel))
481 1.1 mrg return 0;
482 1.1 mrg
483 1.1 mrg switch (e.voice.op) {
484 1.1 mrg case MIDI_NOTEOFF:
485 1.1 mrg buffer[0] = MIDI_NOTEOFF | e.c_NOTEOFF.channel;
486 1.1 mrg buffer[1] = e.c_NOTEOFF.key;
487 1.1 mrg buffer[2] = e.c_NOTEOFF.velocity;
488 1.1 mrg
489 1.2 mrg LOG("MIDI_NOTEOFF: channel %x key %x velocity %x",
490 1.2 mrg e.c_NOTEOFF.channel, e.c_NOTEOFF.key, e.c_NOTEOFF.velocity);
491 1.1 mrg size = 3;
492 1.1 mrg break;
493 1.1 mrg
494 1.1 mrg case MIDI_NOTEON:
495 1.1 mrg buffer[0] = MIDI_NOTEON | e.c_NOTEON.channel;
496 1.1 mrg buffer[1] = e.c_NOTEON.key;
497 1.1 mrg buffer[2] = e.c_NOTEON.velocity;
498 1.1 mrg
499 1.2 mrg LOG("MIDI_NOTEON: channel %x key %x velocity %x",
500 1.2 mrg e.c_NOTEON.channel, e.c_NOTEON.key, e.c_NOTEON.velocity);
501 1.1 mrg size = 3;
502 1.1 mrg break;
503 1.1 mrg
504 1.1 mrg case MIDI_KEY_PRESSURE:
505 1.1 mrg buffer[0] = MIDI_KEY_PRESSURE | e.c_KEY_PRESSURE.channel;
506 1.1 mrg buffer[1] = e.c_KEY_PRESSURE.key;
507 1.1 mrg buffer[2] = e.c_KEY_PRESSURE.pressure;
508 1.1 mrg
509 1.1 mrg LOG("MIDI_KEY_PRESSURE: channel %x key %x pressure %x",
510 1.1 mrg e.c_KEY_PRESSURE.channel, e.c_KEY_PRESSURE.key,
511 1.1 mrg e.c_KEY_PRESSURE.pressure);
512 1.1 mrg size = 3;
513 1.1 mrg break;
514 1.1 mrg
515 1.1 mrg default:
516 1.1 mrg LOG("unknown voice op: %x", e.voice.op);
517 1.1 mrg break;
518 1.1 mrg }
519 1.1 mrg
520 1.1 mrg return size;
521 1.1 mrg }
522 1.1 mrg
523 1.1 mrg /*
524 1.1 mrg * handle a SEQ_SYSEX event. NetBSD /dev/music doesn't generate these.
525 1.1 mrg */
526 1.1 mrg static size_t
527 1.1 mrg midi_event_sysex_to_output(seq_event_t e, u_char *buffer, size_t bufsize)
528 1.1 mrg {
529 1.1 mrg size_t size = 0;
530 1.1 mrg
531 1.1 mrg LOG("UNHANDLED SEQ_SYSEX");
532 1.1 mrg
533 1.1 mrg return size;
534 1.1 mrg }
535 1.1 mrg
536 1.1 mrg /*
537 1.1 mrg * handle a SEQ_FULLSIZE event. NetBSD /dev/music doesn't generate these.
538 1.1 mrg */
539 1.1 mrg static size_t
540 1.1 mrg midi_event_fullsize_to_output(seq_event_t e, u_char *buffer, size_t bufsize)
541 1.1 mrg {
542 1.1 mrg size_t size = 0;
543 1.1 mrg
544 1.1 mrg LOG("UNHANDLED SEQ_FULLSIZE");
545 1.1 mrg
546 1.1 mrg return size;
547 1.1 mrg }
548 1.1 mrg
549 1.1 mrg /*
550 1.1 mrg * main handler for MIDI events.
551 1.1 mrg */
552 1.1 mrg static size_t
553 1.1 mrg midi_event_to_output(seq_event_t e, u_char *buffer, size_t bufsize)
554 1.1 mrg {
555 1.1 mrg size_t size = 0;
556 1.1 mrg
557 1.1 mrg /* XXX so far we only process 4 byte returns */
558 1.1 mrg assert(bufsize >= 4);
559 1.1 mrg
560 1.1 mrg LOG("event: %02x:%02x:%02x:%02x %02x:%02x:%02x:%02x", e.tag,
561 1.1 mrg e.unknown.byte[0], e.unknown.byte[1],
562 1.1 mrg e.unknown.byte[2], e.unknown.byte[3],
563 1.1 mrg e.unknown.byte[4], e.unknown.byte[5],
564 1.1 mrg e.unknown.byte[6]);
565 1.1 mrg
566 1.1 mrg switch (e.tag) {
567 1.1 mrg case SEQ_LOCAL:
568 1.1 mrg size = midi_event_local_to_output(e, buffer, bufsize);
569 1.1 mrg break;
570 1.1 mrg
571 1.1 mrg case SEQ_TIMING:
572 1.1 mrg size = midi_event_timer_to_output(e, buffer, bufsize);
573 1.1 mrg break;
574 1.1 mrg
575 1.1 mrg case SEQ_CHN_COMMON:
576 1.1 mrg size = midi_event_chn_common_to_output(e, buffer, bufsize);
577 1.1 mrg break;
578 1.1 mrg
579 1.1 mrg case SEQ_CHN_VOICE:
580 1.1 mrg size = midi_event_chn_voice_to_output(e, buffer, bufsize);
581 1.1 mrg break;
582 1.1 mrg
583 1.1 mrg case SEQ_SYSEX:
584 1.1 mrg size = midi_event_sysex_to_output(e, buffer, bufsize);
585 1.1 mrg break;
586 1.1 mrg
587 1.1 mrg case SEQ_FULLSIZE:
588 1.1 mrg size = midi_event_fullsize_to_output(e, buffer, bufsize);
589 1.1 mrg break;
590 1.1 mrg
591 1.1 mrg default:
592 1.1 mrg errx(1, "don't understand midi tag %x", e.tag);
593 1.1 mrg }
594 1.1 mrg
595 1.1 mrg return size;
596 1.1 mrg }
597 1.1 mrg
598 1.1 mrg static bool
599 1.1 mrg filter_array(unsigned val, unsigned *array, size_t arraylen)
600 1.1 mrg {
601 1.1 mrg
602 1.1 mrg if (array == NULL)
603 1.1 mrg return false;
604 1.1 mrg
605 1.1 mrg for (; arraylen; arraylen--)
606 1.1 mrg if (array[arraylen - 1] == val)
607 1.1 mrg return false;
608 1.1 mrg
609 1.1 mrg return true;
610 1.1 mrg }
611 1.1 mrg
612 1.1 mrg static bool
613 1.1 mrg filter_dev(unsigned device)
614 1.1 mrg {
615 1.1 mrg
616 1.1 mrg if (filter_array(device, filt_devnos, num_filt_devnos))
617 1.1 mrg return true;
618 1.1 mrg
619 1.1 mrg return false;
620 1.1 mrg }
621 1.1 mrg
622 1.1 mrg static bool
623 1.1 mrg filter_chan(unsigned channel)
624 1.1 mrg {
625 1.1 mrg
626 1.1 mrg if (filter_array(channel, filt_chans, num_filt_chans))
627 1.1 mrg return true;
628 1.1 mrg
629 1.1 mrg return false;
630 1.1 mrg }
631 1.1 mrg
632 1.1 mrg static bool
633 1.1 mrg filter_devchan(unsigned device, unsigned channel)
634 1.1 mrg {
635 1.1 mrg
636 1.1 mrg if (filter_dev(device) || filter_chan(channel))
637 1.1 mrg return true;
638 1.1 mrg
639 1.1 mrg return false;
640 1.1 mrg }
641 1.1 mrg
642 1.1 mrg static int
643 1.1 mrg timeleft(struct timeval *start_tvp, struct timeval *record_tvp)
644 1.1 mrg {
645 1.1 mrg struct timeval now, diff;
646 1.1 mrg
647 1.1 mrg (void)gettimeofday(&now, NULL);
648 1.1 mrg timersub(&now, start_tvp, &diff);
649 1.1 mrg timersub(record_tvp, &diff, &now);
650 1.1 mrg
651 1.1 mrg return (now.tv_sec > 0 || (now.tv_sec == 0 && now.tv_usec > 0));
652 1.1 mrg }
653 1.1 mrg
654 1.1 mrg static void
655 1.1 mrg parse_ints(const char *str, unsigned **arrayp, unsigned *sizep, const char *msg)
656 1.1 mrg {
657 1.1 mrg unsigned count = 1, u, longest = 0, c = 0;
658 1.1 mrg unsigned *ip;
659 1.1 mrg const char *s, *os;
660 1.1 mrg char *num_buf;
661 1.1 mrg
662 1.1 mrg /*
663 1.1 mrg * count all the comma separated values, and figre out
664 1.1 mrg * the longest one.
665 1.1 mrg */
666 1.1 mrg for (s = str; *s; s++) {
667 1.1 mrg c++;
668 1.1 mrg if (*s == ',') {
669 1.1 mrg count++;
670 1.1 mrg if (c > longest)
671 1.1 mrg longest = c;
672 1.1 mrg c = 0;
673 1.1 mrg }
674 1.1 mrg }
675 1.1 mrg *sizep = count;
676 1.1 mrg
677 1.1 mrg num_buf = malloc(longest + 1);
678 1.1 mrg ip = malloc(sizeof(*ip) * count);
679 1.1 mrg if (!ip || !num_buf)
680 1.1 mrg errx(1, "malloc failed");
681 1.1 mrg
682 1.1 mrg for (count = 0, s = os = str, u = 0; *s; s++) {
683 1.1 mrg if (*s == ',') {
684 1.1 mrg num_buf[u] = '\0';
685 1.1 mrg decode_uint(num_buf, &ip[count++]);
686 1.1 mrg os = s + 1;
687 1.1 mrg u = 0;
688 1.1 mrg } else
689 1.1 mrg num_buf[u++] = *s;
690 1.1 mrg }
691 1.1 mrg num_buf[u] = '\0';
692 1.1 mrg decode_uint(num_buf, &ip[count++]);
693 1.1 mrg *arrayp = ip;
694 1.1 mrg
695 1.1 mrg if (verbose) {
696 1.1 mrg fprintf(stderr, "Filtering %s in:", msg);
697 1.1 mrg for (size_t i = 0; i < *sizep; i++)
698 1.1 mrg fprintf(stderr, " %u", ip[i]);
699 1.1 mrg fprintf(stderr, "\n");
700 1.1 mrg }
701 1.1 mrg
702 1.1 mrg free(num_buf);
703 1.1 mrg }
704 1.1 mrg
705 1.1 mrg static void
706 1.1 mrg cleanup(int signo)
707 1.1 mrg {
708 1.1 mrg
709 1.1 mrg write_midi_trailer();
710 1.1 mrg rewrite_header();
711 1.1 mrg
712 1.1 mrg if (ioctl(midifd, SEQUENCER_TMR_STOP, NULL) < 0) {
713 1.1 mrg if (ignore_timer_fail)
714 1.1 mrg warn("failed to stop midi timer");
715 1.1 mrg else
716 1.1 mrg err(1, "failed to stop midi timer");
717 1.1 mrg }
718 1.1 mrg
719 1.1 mrg close(outfd);
720 1.1 mrg close(midifd);
721 1.1 mrg if (signo != 0)
722 1.1 mrg (void)raise_default_signal(signo);
723 1.1 mrg
724 1.1 mrg exit(0);
725 1.1 mrg }
726 1.1 mrg
727 1.1 mrg static void
728 1.1 mrg rewrite_header(void)
729 1.1 mrg {
730 1.1 mrg
731 1.1 mrg /* can't do this here! */
732 1.7 mrg if (stdout_mode)
733 1.1 mrg return;
734 1.1 mrg
735 1.1 mrg if (lseek(outfd, (off_t)0, SEEK_SET) == (off_t)-1)
736 1.1 mrg err(1, "could not seek to start of file for header rewrite");
737 1.1 mrg write_midi_header();
738 1.1 mrg }
739 1.1 mrg
740 1.1 mrg #define BYTE1(x) ((x) & 0xff)
741 1.1 mrg #define BYTE2(x) (((x) >> 8) & 0xff)
742 1.1 mrg #define BYTE3(x) (((x) >> 16) & 0xff)
743 1.1 mrg #define BYTE4(x) (((x) >> 24) & 0xff)
744 1.1 mrg
745 1.1 mrg static void
746 1.1 mrg write_midi_header(void)
747 1.1 mrg {
748 1.1 mrg unsigned char header[] = {
749 1.1 mrg 'M', 'T', 'h', 'd',
750 1.1 mrg 0, 0, 0, 6,
751 1.1 mrg 0, 1,
752 1.1 mrg 0, 0, /* ntracks */
753 1.1 mrg 0, 0, /* notes per beat */
754 1.1 mrg };
755 1.7 mrg /* XXX only support one track so far */
756 1.1 mrg unsigned ntracks = 1;
757 1.1 mrg unsigned char track[] = {
758 1.1 mrg 'M', 'T', 'r', 'k',
759 1.1 mrg 0, 0, 0, 0,
760 1.1 mrg };
761 1.1 mrg unsigned char bpm[] = {
762 1.1 mrg 0, 0xff, 0x51, 0x3,
763 1.1 mrg 0, 0, 0, /* inverse tempo */
764 1.1 mrg };
765 1.1 mrg unsigned total_size = data_size + sizeof header + sizeof track + sizeof bpm;
766 1.1 mrg
767 1.1 mrg header[10] = BYTE2(ntracks);
768 1.1 mrg header[11] = BYTE1(ntracks);
769 1.1 mrg header[12] = BYTE2(notes_per_beat);
770 1.1 mrg header[13] = BYTE1(notes_per_beat);
771 1.1 mrg
772 1.1 mrg track[4] = BYTE4(total_size);
773 1.1 mrg track[5] = BYTE3(total_size);
774 1.1 mrg track[6] = BYTE2(total_size);
775 1.1 mrg track[7] = BYTE1(total_size);
776 1.1 mrg
777 1.1 mrg #define TEMPO_INV(x) (60000000UL / (x))
778 1.1 mrg bpm[4] = BYTE3(TEMPO_INV(tempo));
779 1.1 mrg bpm[5] = BYTE2(TEMPO_INV(tempo));
780 1.1 mrg bpm[6] = BYTE1(TEMPO_INV(tempo));
781 1.1 mrg
782 1.1 mrg if (write(outfd, header, sizeof header) != sizeof header)
783 1.1 mrg err(1, "write of header failed");
784 1.1 mrg if (write(outfd, track, sizeof track) != sizeof track)
785 1.1 mrg err(1, "write of track header failed");
786 1.1 mrg if (write(outfd, bpm, sizeof bpm) != sizeof bpm)
787 1.1 mrg err(1, "write of bpm header failed");
788 1.1 mrg
789 1.1 mrg LOG("wrote header: ntracks=%u notes_per_beat=%u tempo=%d total_size=%u",
790 1.1 mrg ntracks, notes_per_beat, tempo, total_size);
791 1.1 mrg }
792 1.1 mrg
793 1.1 mrg static void
794 1.1 mrg write_midi_trailer(void)
795 1.1 mrg {
796 1.1 mrg unsigned char trailer[] = {
797 1.1 mrg 0, 0xff, 0x2f, 0,
798 1.1 mrg };
799 1.1 mrg
800 1.1 mrg if (write(outfd, trailer, sizeof trailer) != sizeof trailer)
801 1.1 mrg err(1, "write of trailer failed");
802 1.1 mrg }
803 1.1 mrg
804 1.1 mrg static void
805 1.1 mrg usage(void)
806 1.1 mrg {
807 1.1 mrg
808 1.3 wiz fprintf(stderr, "Usage: %s [-aDfhqV] [options] {outfile|-}\n",
809 1.1 mrg getprogname());
810 1.1 mrg fprintf(stderr, "Options:\n"
811 1.1 mrg "\t-B buffer size\n"
812 1.3 wiz "\t-c channels\n"
813 1.3 wiz "\t-d devices\n"
814 1.1 mrg "\t-f sequencerdev\n"
815 1.3 wiz "\t-n notesperbeat\n"
816 1.1 mrg "\t-r raw_output\n"
817 1.3 wiz "\t-T tempo\n"
818 1.3 wiz "\t-t recording time\n");
819 1.1 mrg exit(EXIT_FAILURE);
820 1.1 mrg }
821