Home | History | Annotate | Line # | Download | only in midirecord
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, &notes_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, &notes_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