Blame seq/aplaymidi/aplaymidi.c

Packit Service a9274b
/*
Packit Service a9274b
 * aplaymidi.c - play Standard MIDI Files to sequencer port(s)
Packit Service a9274b
 *
Packit Service a9274b
 * Copyright (c) 2004-2006 Clemens Ladisch <clemens@ladisch.de>
Packit Service a9274b
 *
Packit Service a9274b
 *
Packit Service a9274b
 *  This program is free software; you can redistribute it and/or modify
Packit Service a9274b
 *  it under the terms of the GNU General Public License as published by
Packit Service a9274b
 *  the Free Software Foundation; either version 2 of the License, or
Packit Service a9274b
 *  (at your option) any later version.
Packit Service a9274b
 *
Packit Service a9274b
 *  This program is distributed in the hope that it will be useful,
Packit Service a9274b
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
Packit Service a9274b
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
Packit Service a9274b
 *  GNU General Public License for more details.
Packit Service a9274b
 *
Packit Service a9274b
 *  You should have received a copy of the GNU General Public License
Packit Service a9274b
 *  along with this program; if not, write to the Free Software
Packit Service a9274b
 *  Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
Packit Service a9274b
 */
Packit Service a9274b
Packit Service a9274b
/* TODO: sequencer queue timer selection */
Packit Service a9274b
Packit Service a9274b
#include <stdio.h>
Packit Service a9274b
#include <stdlib.h>
Packit Service a9274b
#include <stdarg.h>
Packit Service a9274b
#include <string.h>
Packit Service a9274b
#include <getopt.h>
Packit Service a9274b
#include <unistd.h>
Packit Service a9274b
#include <alsa/asoundlib.h>
Packit Service a9274b
#include "aconfig.h"
Packit Service a9274b
#include "version.h"
Packit Service a9274b
Packit Service a9274b
/*
Packit Service a9274b
 * 31.25 kbaud, one start bit, eight data bits, two stop bits.
Packit Service a9274b
 * (The MIDI spec says one stop bit, but every transmitter uses two, just to be
Packit Service a9274b
 * sure, so we better not exceed that to avoid overflowing the output buffer.)
Packit Service a9274b
 */
Packit Service a9274b
#define MIDI_BYTES_PER_SEC (31250 / (1 + 8 + 2))
Packit Service a9274b
Packit Service a9274b
/*
Packit Service a9274b
 * A MIDI event after being parsed/loaded from the file.
Packit Service a9274b
 * There could be made a case for using snd_seq_event_t instead.
Packit Service a9274b
 */
Packit Service a9274b
struct event {
Packit Service a9274b
	struct event *next;		/* linked list */
Packit Service a9274b
Packit Service a9274b
	unsigned char type;		/* SND_SEQ_EVENT_xxx */
Packit Service a9274b
	unsigned char port;		/* port index */
Packit Service a9274b
	unsigned int tick;
Packit Service a9274b
	union {
Packit Service a9274b
		unsigned char d[3];	/* channel and data bytes */
Packit Service a9274b
		int tempo;
Packit Service a9274b
		unsigned int length;	/* length of sysex data */
Packit Service a9274b
	} data;
Packit Service a9274b
	unsigned char sysex[0];
Packit Service a9274b
};
Packit Service a9274b
Packit Service a9274b
struct track {
Packit Service a9274b
	struct event *first_event;	/* list of all events in this track */
Packit Service a9274b
	int end_tick;			/* length of this track */
Packit Service a9274b
Packit Service a9274b
	struct event *current_event;	/* used while loading and playing */
Packit Service a9274b
};
Packit Service a9274b
Packit Service a9274b
static snd_seq_t *seq;
Packit Service a9274b
static int client;
Packit Service a9274b
static int port_count;
Packit Service a9274b
static snd_seq_addr_t *ports;
Packit Service a9274b
static int queue;
Packit Service a9274b
static int end_delay = 2;
Packit Service a9274b
static const char *file_name;
Packit Service a9274b
static FILE *file;
Packit Service a9274b
static int file_offset;		/* current offset in input file */
Packit Service a9274b
static int num_tracks;
Packit Service a9274b
static struct track *tracks;
Packit Service a9274b
static int smpte_timing;
Packit Service a9274b
Packit Service a9274b
/* prints an error message to stderr */
Packit Service a9274b
static void errormsg(const char *msg, ...)
Packit Service a9274b
{
Packit Service a9274b
	va_list ap;
Packit Service a9274b
Packit Service a9274b
	va_start(ap, msg);
Packit Service a9274b
	vfprintf(stderr, msg, ap);
Packit Service a9274b
	va_end(ap);
Packit Service a9274b
	fputc('\n', stderr);
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
/* prints an error message to stderr, and dies */
Packit Service a9274b
static void fatal(const char *msg, ...)
Packit Service a9274b
{
Packit Service a9274b
	va_list ap;
Packit Service a9274b
Packit Service a9274b
	va_start(ap, msg);
Packit Service a9274b
	vfprintf(stderr, msg, ap);
Packit Service a9274b
	va_end(ap);
Packit Service a9274b
	fputc('\n', stderr);
Packit Service a9274b
	exit(EXIT_FAILURE);
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
/* memory allocation error handling */
Packit Service a9274b
static void check_mem(void *p)
Packit Service a9274b
{
Packit Service a9274b
	if (!p)
Packit Service a9274b
		fatal("Out of memory");
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
/* error handling for ALSA functions */
Packit Service a9274b
static void check_snd(const char *operation, int err)
Packit Service a9274b
{
Packit Service a9274b
	if (err < 0)
Packit Service a9274b
		fatal("Cannot %s - %s", operation, snd_strerror(err));
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void init_seq(void)
Packit Service a9274b
{
Packit Service a9274b
	int err;
Packit Service a9274b
Packit Service a9274b
	/* open sequencer */
Packit Service a9274b
	err = snd_seq_open(&seq, "default", SND_SEQ_OPEN_DUPLEX, 0);
Packit Service a9274b
	check_snd("open sequencer", err);
Packit Service a9274b
Packit Service a9274b
	/* set our name (otherwise it's "Client-xxx") */
Packit Service a9274b
	err = snd_seq_set_client_name(seq, "aplaymidi");
Packit Service a9274b
	check_snd("set client name", err);
Packit Service a9274b
Packit Service a9274b
	/* find out who we actually are */
Packit Service a9274b
	client = snd_seq_client_id(seq);
Packit Service a9274b
	check_snd("get client id", client);
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
/* parses one or more port addresses from the string */
Packit Service a9274b
static void parse_ports(const char *arg)
Packit Service a9274b
{
Packit Service a9274b
	char *buf, *s, *port_name;
Packit Service a9274b
	int err;
Packit Service a9274b
Packit Service a9274b
	/* make a copy of the string because we're going to modify it */
Packit Service a9274b
	buf = strdup(arg);
Packit Service a9274b
	check_mem(buf);
Packit Service a9274b
Packit Service a9274b
	for (port_name = s = buf; s; port_name = s + 1) {
Packit Service a9274b
		/* Assume that ports are separated by commas.  We don't use
Packit Service a9274b
		 * spaces because those are valid in client names. */
Packit Service a9274b
		s = strchr(port_name, ',');
Packit Service a9274b
		if (s)
Packit Service a9274b
			*s = '\0';
Packit Service a9274b
Packit Service a9274b
		++port_count;
Packit Service a9274b
		ports = realloc(ports, port_count * sizeof(snd_seq_addr_t));
Packit Service a9274b
		check_mem(ports);
Packit Service a9274b
Packit Service a9274b
		err = snd_seq_parse_address(seq, &ports[port_count - 1], port_name);
Packit Service a9274b
		if (err < 0)
Packit Service a9274b
			fatal("Invalid port %s - %s", port_name, snd_strerror(err));
Packit Service a9274b
	}
Packit Service a9274b
Packit Service a9274b
	free(buf);
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void create_source_port(void)
Packit Service a9274b
{
Packit Service a9274b
	snd_seq_port_info_t *pinfo;
Packit Service a9274b
	int err;
Packit Service a9274b
Packit Service a9274b
	snd_seq_port_info_alloca(&pinfo);
Packit Service a9274b
Packit Service a9274b
	/* the first created port is 0 anyway, but let's make sure ... */
Packit Service a9274b
	snd_seq_port_info_set_port(pinfo, 0);
Packit Service a9274b
	snd_seq_port_info_set_port_specified(pinfo, 1);
Packit Service a9274b
Packit Service a9274b
	snd_seq_port_info_set_name(pinfo, "aplaymidi");
Packit Service a9274b
Packit Service a9274b
	snd_seq_port_info_set_capability(pinfo, 0); /* sic */
Packit Service a9274b
	snd_seq_port_info_set_type(pinfo,
Packit Service a9274b
				   SND_SEQ_PORT_TYPE_MIDI_GENERIC |
Packit Service a9274b
				   SND_SEQ_PORT_TYPE_APPLICATION);
Packit Service a9274b
Packit Service a9274b
	err = snd_seq_create_port(seq, pinfo);
Packit Service a9274b
	check_snd("create port", err);
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void create_queue(void)
Packit Service a9274b
{
Packit Service a9274b
	queue = snd_seq_alloc_named_queue(seq, "aplaymidi");
Packit Service a9274b
	check_snd("create queue", queue);
Packit Service a9274b
	/* the queue is now locked, which is just fine */
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void connect_ports(void)
Packit Service a9274b
{
Packit Service a9274b
	int i, err;
Packit Service a9274b
Packit Service a9274b
	/*
Packit Service a9274b
	 * We send MIDI events with explicit destination addresses, so we don't
Packit Service a9274b
	 * need any connections to the playback ports.  But we connect to those
Packit Service a9274b
	 * anyway to force any underlying RawMIDI ports to remain open while
Packit Service a9274b
	 * we're playing - otherwise, ALSA would reset the port after every
Packit Service a9274b
	 * event.
Packit Service a9274b
	 */
Packit Service a9274b
	for (i = 0; i < port_count; ++i) {
Packit Service a9274b
		err = snd_seq_connect_to(seq, 0, ports[i].client, ports[i].port);
Packit Service a9274b
		if (err < 0)
Packit Service a9274b
			fatal("Cannot connect to port %d:%d - %s",
Packit Service a9274b
			      ports[i].client, ports[i].port, snd_strerror(err));
Packit Service a9274b
	}
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static int read_byte(void)
Packit Service a9274b
{
Packit Service a9274b
	++file_offset;
Packit Service a9274b
	return getc(file);
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
/* reads a little-endian 32-bit integer */
Packit Service a9274b
static int read_32_le(void)
Packit Service a9274b
{
Packit Service a9274b
	int value;
Packit Service a9274b
	value = read_byte();
Packit Service a9274b
	value |= read_byte() << 8;
Packit Service a9274b
	value |= read_byte() << 16;
Packit Service a9274b
	value |= read_byte() << 24;
Packit Service a9274b
	return !feof(file) ? value : -1;
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
/* reads a 4-character identifier */
Packit Service a9274b
static int read_id(void)
Packit Service a9274b
{
Packit Service a9274b
	return read_32_le();
Packit Service a9274b
}
Packit Service a9274b
#define MAKE_ID(c1, c2, c3, c4) ((c1) | ((c2) << 8) | ((c3) << 16) | ((c4) << 24))
Packit Service a9274b
Packit Service a9274b
/* reads a fixed-size big-endian number */
Packit Service a9274b
static int read_int(int bytes)
Packit Service a9274b
{
Packit Service a9274b
	int c, value = 0;
Packit Service a9274b
Packit Service a9274b
	do {
Packit Service a9274b
		c = read_byte();
Packit Service a9274b
		if (c == EOF)
Packit Service a9274b
			return -1;
Packit Service a9274b
		value = (value << 8) | c;
Packit Service a9274b
	} while (--bytes);
Packit Service a9274b
	return value;
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
/* reads a variable-length number */
Packit Service a9274b
static int read_var(void)
Packit Service a9274b
{
Packit Service a9274b
	int value, c;
Packit Service a9274b
Packit Service a9274b
	c = read_byte();
Packit Service a9274b
	value = c & 0x7f;
Packit Service a9274b
	if (c & 0x80) {
Packit Service a9274b
		c = read_byte();
Packit Service a9274b
		value = (value << 7) | (c & 0x7f);
Packit Service a9274b
		if (c & 0x80) {
Packit Service a9274b
			c = read_byte();
Packit Service a9274b
			value = (value << 7) | (c & 0x7f);
Packit Service a9274b
			if (c & 0x80) {
Packit Service a9274b
				c = read_byte();
Packit Service a9274b
				value = (value << 7) | c;
Packit Service a9274b
				if (c & 0x80)
Packit Service a9274b
					return -1;
Packit Service a9274b
			}
Packit Service a9274b
		}
Packit Service a9274b
	}
Packit Service a9274b
	return !feof(file) ? value : -1;
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
/* allocates a new event */
Packit Service a9274b
static struct event *new_event(struct track *track, int sysex_length)
Packit Service a9274b
{
Packit Service a9274b
	struct event *event;
Packit Service a9274b
Packit Service a9274b
	event = malloc(sizeof(struct event) + sysex_length);
Packit Service a9274b
	check_mem(event);
Packit Service a9274b
Packit Service a9274b
	event->next = NULL;
Packit Service a9274b
Packit Service a9274b
	/* append at the end of the track's linked list */
Packit Service a9274b
	if (track->current_event)
Packit Service a9274b
		track->current_event->next = event;
Packit Service a9274b
	else
Packit Service a9274b
		track->first_event = event;
Packit Service a9274b
	track->current_event = event;
Packit Service a9274b
Packit Service a9274b
	return event;
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void skip(int bytes)
Packit Service a9274b
{
Packit Service a9274b
	while (bytes > 0)
Packit Service a9274b
		read_byte(), --bytes;
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
/* reads one complete track from the file */
Packit Service a9274b
static int read_track(struct track *track, int track_end)
Packit Service a9274b
{
Packit Service a9274b
	int tick = 0;
Packit Service a9274b
	unsigned char last_cmd = 0;
Packit Service a9274b
	unsigned char port = 0;
Packit Service a9274b
Packit Service a9274b
	/* the current file position is after the track ID and length */
Packit Service a9274b
	while (file_offset < track_end) {
Packit Service a9274b
		unsigned char cmd;
Packit Service a9274b
		struct event *event;
Packit Service a9274b
		int delta_ticks, len, c;
Packit Service a9274b
Packit Service a9274b
		delta_ticks = read_var();
Packit Service a9274b
		if (delta_ticks < 0)
Packit Service a9274b
			break;
Packit Service a9274b
		tick += delta_ticks;
Packit Service a9274b
Packit Service a9274b
		c = read_byte();
Packit Service a9274b
		if (c < 0)
Packit Service a9274b
			break;
Packit Service a9274b
Packit Service a9274b
		if (c & 0x80) {
Packit Service a9274b
			/* have command */
Packit Service a9274b
			cmd = c;
Packit Service a9274b
			if (cmd < 0xf0)
Packit Service a9274b
				last_cmd = cmd;
Packit Service a9274b
		} else {
Packit Service a9274b
			/* running status */
Packit Service a9274b
			ungetc(c, file);
Packit Service a9274b
			file_offset--;
Packit Service a9274b
			cmd = last_cmd;
Packit Service a9274b
			if (!cmd)
Packit Service a9274b
				goto _error;
Packit Service a9274b
		}
Packit Service a9274b
Packit Service a9274b
		switch (cmd >> 4) {
Packit Service a9274b
			/* maps SMF events to ALSA sequencer events */
Packit Service a9274b
			static const unsigned char cmd_type[] = {
Packit Service a9274b
				[0x8] = SND_SEQ_EVENT_NOTEOFF,
Packit Service a9274b
				[0x9] = SND_SEQ_EVENT_NOTEON,
Packit Service a9274b
				[0xa] = SND_SEQ_EVENT_KEYPRESS,
Packit Service a9274b
				[0xb] = SND_SEQ_EVENT_CONTROLLER,
Packit Service a9274b
				[0xc] = SND_SEQ_EVENT_PGMCHANGE,
Packit Service a9274b
				[0xd] = SND_SEQ_EVENT_CHANPRESS,
Packit Service a9274b
				[0xe] = SND_SEQ_EVENT_PITCHBEND
Packit Service a9274b
			};
Packit Service a9274b
Packit Service a9274b
		case 0x8: /* channel msg with 2 parameter bytes */
Packit Service a9274b
		case 0x9:
Packit Service a9274b
		case 0xa:
Packit Service a9274b
		case 0xb:
Packit Service a9274b
		case 0xe:
Packit Service a9274b
			event = new_event(track, 0);
Packit Service a9274b
			event->type = cmd_type[cmd >> 4];
Packit Service a9274b
			event->port = port;
Packit Service a9274b
			event->tick = tick;
Packit Service a9274b
			event->data.d[0] = cmd & 0x0f;
Packit Service a9274b
			event->data.d[1] = read_byte() & 0x7f;
Packit Service a9274b
			event->data.d[2] = read_byte() & 0x7f;
Packit Service a9274b
			break;
Packit Service a9274b
Packit Service a9274b
		case 0xc: /* channel msg with 1 parameter byte */
Packit Service a9274b
		case 0xd:
Packit Service a9274b
			event = new_event(track, 0);
Packit Service a9274b
			event->type = cmd_type[cmd >> 4];
Packit Service a9274b
			event->port = port;
Packit Service a9274b
			event->tick = tick;
Packit Service a9274b
			event->data.d[0] = cmd & 0x0f;
Packit Service a9274b
			event->data.d[1] = read_byte() & 0x7f;
Packit Service a9274b
			break;
Packit Service a9274b
Packit Service a9274b
		case 0xf:
Packit Service a9274b
			switch (cmd) {
Packit Service a9274b
			case 0xf0: /* sysex */
Packit Service a9274b
			case 0xf7: /* continued sysex, or escaped commands */
Packit Service a9274b
				len = read_var();
Packit Service a9274b
				if (len < 0)
Packit Service a9274b
					goto _error;
Packit Service a9274b
				if (cmd == 0xf0)
Packit Service a9274b
					++len;
Packit Service a9274b
				event = new_event(track, len);
Packit Service a9274b
				event->type = SND_SEQ_EVENT_SYSEX;
Packit Service a9274b
				event->port = port;
Packit Service a9274b
				event->tick = tick;
Packit Service a9274b
				event->data.length = len;
Packit Service a9274b
				if (cmd == 0xf0) {
Packit Service a9274b
					event->sysex[0] = 0xf0;
Packit Service a9274b
					c = 1;
Packit Service a9274b
				} else {
Packit Service a9274b
					c = 0;
Packit Service a9274b
				}
Packit Service a9274b
				for (; c < len; ++c)
Packit Service a9274b
					event->sysex[c] = read_byte();
Packit Service a9274b
				break;
Packit Service a9274b
Packit Service a9274b
			case 0xff: /* meta event */
Packit Service a9274b
				c = read_byte();
Packit Service a9274b
				len = read_var();
Packit Service a9274b
				if (len < 0)
Packit Service a9274b
					goto _error;
Packit Service a9274b
Packit Service a9274b
				switch (c) {
Packit Service a9274b
				case 0x21: /* port number */
Packit Service a9274b
					if (len < 1)
Packit Service a9274b
						goto _error;
Packit Service a9274b
					port = read_byte() % port_count;
Packit Service a9274b
					skip(len - 1);
Packit Service a9274b
					break;
Packit Service a9274b
Packit Service a9274b
				case 0x2f: /* end of track */
Packit Service a9274b
					track->end_tick = tick;
Packit Service a9274b
					skip(track_end - file_offset);
Packit Service a9274b
					return 1;
Packit Service a9274b
Packit Service a9274b
				case 0x51: /* tempo */
Packit Service a9274b
					if (len < 3)
Packit Service a9274b
						goto _error;
Packit Service a9274b
					if (smpte_timing) {
Packit Service a9274b
						/* SMPTE timing doesn't change */
Packit Service a9274b
						skip(len);
Packit Service a9274b
					} else {
Packit Service a9274b
						event = new_event(track, 0);
Packit Service a9274b
						event->type = SND_SEQ_EVENT_TEMPO;
Packit Service a9274b
						event->port = port;
Packit Service a9274b
						event->tick = tick;
Packit Service a9274b
						event->data.tempo = read_byte() << 16;
Packit Service a9274b
						event->data.tempo |= read_byte() << 8;
Packit Service a9274b
						event->data.tempo |= read_byte();
Packit Service a9274b
						skip(len - 3);
Packit Service a9274b
					}
Packit Service a9274b
					break;
Packit Service a9274b
Packit Service a9274b
				default: /* ignore all other meta events */
Packit Service a9274b
					skip(len);
Packit Service a9274b
					break;
Packit Service a9274b
				}
Packit Service a9274b
				break;
Packit Service a9274b
Packit Service a9274b
			default: /* invalid Fx command */
Packit Service a9274b
				goto _error;
Packit Service a9274b
			}
Packit Service a9274b
			break;
Packit Service a9274b
Packit Service a9274b
		default: /* cannot happen */
Packit Service a9274b
			goto _error;
Packit Service a9274b
		}
Packit Service a9274b
	}
Packit Service a9274b
_error:
Packit Service a9274b
	errormsg("%s: invalid MIDI data (offset %#x)", file_name, file_offset);
Packit Service a9274b
	return 0;
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
/* reads an entire MIDI file */
Packit Service a9274b
static int read_smf(void)
Packit Service a9274b
{
Packit Service a9274b
	int header_len, type, time_division, i, err;
Packit Service a9274b
	snd_seq_queue_tempo_t *queue_tempo;
Packit Service a9274b
Packit Service a9274b
	/* the curren position is immediately after the "MThd" id */
Packit Service a9274b
	header_len = read_int(4);
Packit Service a9274b
	if (header_len < 6) {
Packit Service a9274b
invalid_format:
Packit Service a9274b
		errormsg("%s: invalid file format", file_name);
Packit Service a9274b
		return 0;
Packit Service a9274b
	}
Packit Service a9274b
Packit Service a9274b
	type = read_int(2);
Packit Service a9274b
	if (type != 0 && type != 1) {
Packit Service a9274b
		errormsg("%s: type %d format is not supported", file_name, type);
Packit Service a9274b
		return 0;
Packit Service a9274b
	}
Packit Service a9274b
Packit Service a9274b
	num_tracks = read_int(2);
Packit Service a9274b
	if (num_tracks < 1 || num_tracks > 1000) {
Packit Service a9274b
		errormsg("%s: invalid number of tracks (%d)", file_name, num_tracks);
Packit Service a9274b
		num_tracks = 0;
Packit Service a9274b
		return 0;
Packit Service a9274b
	}
Packit Service a9274b
	tracks = calloc(num_tracks, sizeof(struct track));
Packit Service a9274b
	if (!tracks) {
Packit Service a9274b
		errormsg("out of memory");
Packit Service a9274b
		num_tracks = 0;
Packit Service a9274b
		return 0;
Packit Service a9274b
	}
Packit Service a9274b
Packit Service a9274b
	time_division = read_int(2);
Packit Service a9274b
	if (time_division < 0)
Packit Service a9274b
		goto invalid_format;
Packit Service a9274b
Packit Service a9274b
	/* interpret and set tempo */
Packit Service a9274b
	snd_seq_queue_tempo_alloca(&queue_tempo);
Packit Service a9274b
	smpte_timing = !!(time_division & 0x8000);
Packit Service a9274b
	if (!smpte_timing) {
Packit Service a9274b
		/* time_division is ticks per quarter */
Packit Service a9274b
		snd_seq_queue_tempo_set_tempo(queue_tempo, 500000); /* default: 120 bpm */
Packit Service a9274b
		snd_seq_queue_tempo_set_ppq(queue_tempo, time_division);
Packit Service a9274b
	} else {
Packit Service a9274b
		/* upper byte is negative frames per second */
Packit Service a9274b
		i = 0x80 - ((time_division >> 8) & 0x7f);
Packit Service a9274b
		/* lower byte is ticks per frame */
Packit Service a9274b
		time_division &= 0xff;
Packit Service a9274b
		/* now pretend that we have quarter-note based timing */
Packit Service a9274b
		switch (i) {
Packit Service a9274b
		case 24:
Packit Service a9274b
			snd_seq_queue_tempo_set_tempo(queue_tempo, 500000);
Packit Service a9274b
			snd_seq_queue_tempo_set_ppq(queue_tempo, 12 * time_division);
Packit Service a9274b
			break;
Packit Service a9274b
		case 25:
Packit Service a9274b
			snd_seq_queue_tempo_set_tempo(queue_tempo, 400000);
Packit Service a9274b
			snd_seq_queue_tempo_set_ppq(queue_tempo, 10 * time_division);
Packit Service a9274b
			break;
Packit Service a9274b
		case 29: /* 30 drop-frame */
Packit Service a9274b
			snd_seq_queue_tempo_set_tempo(queue_tempo, 100000000);
Packit Service a9274b
			snd_seq_queue_tempo_set_ppq(queue_tempo, 2997 * time_division);
Packit Service a9274b
			break;
Packit Service a9274b
		case 30:
Packit Service a9274b
			snd_seq_queue_tempo_set_tempo(queue_tempo, 500000);
Packit Service a9274b
			snd_seq_queue_tempo_set_ppq(queue_tempo, 15 * time_division);
Packit Service a9274b
			break;
Packit Service a9274b
		default:
Packit Service a9274b
			errormsg("%s: invalid number of SMPTE frames per second (%d)",
Packit Service a9274b
				 file_name, i);
Packit Service a9274b
			return 0;
Packit Service a9274b
		}
Packit Service a9274b
	}
Packit Service a9274b
	err = snd_seq_set_queue_tempo(seq, queue, queue_tempo);
Packit Service a9274b
	if (err < 0) {
Packit Service a9274b
		errormsg("Cannot set queue tempo (%u/%i)",
Packit Service a9274b
			 snd_seq_queue_tempo_get_tempo(queue_tempo),
Packit Service a9274b
			 snd_seq_queue_tempo_get_ppq(queue_tempo));
Packit Service a9274b
		return 0;
Packit Service a9274b
	}
Packit Service a9274b
Packit Service a9274b
	/* read tracks */
Packit Service a9274b
	for (i = 0; i < num_tracks; ++i) {
Packit Service a9274b
		int len;
Packit Service a9274b
Packit Service a9274b
		/* search for MTrk chunk */
Packit Service a9274b
		for (;;) {
Packit Service a9274b
			int id = read_id();
Packit Service a9274b
			len = read_int(4);
Packit Service a9274b
			if (feof(file)) {
Packit Service a9274b
				errormsg("%s: unexpected end of file", file_name);
Packit Service a9274b
				return 0;
Packit Service a9274b
			}
Packit Service a9274b
			if (len < 0 || len >= 0x10000000) {
Packit Service a9274b
				errormsg("%s: invalid chunk length %d", file_name, len);
Packit Service a9274b
				return 0;
Packit Service a9274b
			}
Packit Service a9274b
			if (id == MAKE_ID('M', 'T', 'r', 'k'))
Packit Service a9274b
				break;
Packit Service a9274b
			skip(len);
Packit Service a9274b
		}
Packit Service a9274b
		if (!read_track(&tracks[i], file_offset + len))
Packit Service a9274b
			return 0;
Packit Service a9274b
	}
Packit Service a9274b
	return 1;
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static int read_riff(void)
Packit Service a9274b
{
Packit Service a9274b
	/* skip file length */
Packit Service a9274b
	read_byte();
Packit Service a9274b
	read_byte();
Packit Service a9274b
	read_byte();
Packit Service a9274b
	read_byte();
Packit Service a9274b
Packit Service a9274b
	/* check file type ("RMID" = RIFF MIDI) */
Packit Service a9274b
	if (read_id() != MAKE_ID('R', 'M', 'I', 'D')) {
Packit Service a9274b
invalid_format:
Packit Service a9274b
		errormsg("%s: invalid file format", file_name);
Packit Service a9274b
		return 0;
Packit Service a9274b
	}
Packit Service a9274b
	/* search for "data" chunk */
Packit Service a9274b
	for (;;) {
Packit Service a9274b
		int id = read_id();
Packit Service a9274b
		int len = read_32_le();
Packit Service a9274b
		if (feof(file)) {
Packit Service a9274b
data_not_found:
Packit Service a9274b
			errormsg("%s: data chunk not found", file_name);
Packit Service a9274b
			return 0;
Packit Service a9274b
		}
Packit Service a9274b
		if (id == MAKE_ID('d', 'a', 't', 'a'))
Packit Service a9274b
			break;
Packit Service a9274b
		if (len < 0)
Packit Service a9274b
			goto data_not_found;
Packit Service a9274b
		skip((len + 1) & ~1);
Packit Service a9274b
	}
Packit Service a9274b
	/* the "data" chunk must contain data in SMF format */
Packit Service a9274b
	if (read_id() != MAKE_ID('M', 'T', 'h', 'd'))
Packit Service a9274b
		goto invalid_format;
Packit Service a9274b
	return read_smf();
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void cleanup_file_data(void)
Packit Service a9274b
{
Packit Service a9274b
	int i;
Packit Service a9274b
	struct event *event;
Packit Service a9274b
Packit Service a9274b
	for (i = 0; i < num_tracks; ++i) {
Packit Service a9274b
		event = tracks[i].first_event;
Packit Service a9274b
		while (event) {
Packit Service a9274b
			struct event *next = event->next;
Packit Service a9274b
			free(event);
Packit Service a9274b
			event = next;
Packit Service a9274b
		}
Packit Service a9274b
	}
Packit Service a9274b
	num_tracks = 0;
Packit Service a9274b
	free(tracks);
Packit Service a9274b
	tracks = NULL;
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void handle_big_sysex(snd_seq_event_t *ev)
Packit Service a9274b
{
Packit Service a9274b
	unsigned int length;
Packit Service a9274b
	ssize_t event_size;
Packit Service a9274b
	int err;
Packit Service a9274b
Packit Service a9274b
	length = ev->data.ext.len;
Packit Service a9274b
	if (length > MIDI_BYTES_PER_SEC)
Packit Service a9274b
		ev->data.ext.len = MIDI_BYTES_PER_SEC;
Packit Service a9274b
	event_size = snd_seq_event_length(ev);
Packit Service a9274b
	if (event_size + 1 > snd_seq_get_output_buffer_size(seq)) {
Packit Service a9274b
		err = snd_seq_drain_output(seq);
Packit Service a9274b
		check_snd("drain output", err);
Packit Service a9274b
		err = snd_seq_set_output_buffer_size(seq, event_size + 1);
Packit Service a9274b
		check_snd("set output buffer size", err);
Packit Service a9274b
	}
Packit Service a9274b
	while (length > MIDI_BYTES_PER_SEC) {
Packit Service a9274b
		err = snd_seq_event_output(seq, ev);
Packit Service a9274b
		check_snd("output event", err);
Packit Service a9274b
		err = snd_seq_drain_output(seq);
Packit Service a9274b
		check_snd("drain output", err);
Packit Service a9274b
		err = snd_seq_sync_output_queue(seq);
Packit Service a9274b
		check_snd("sync output", err);
Packit Service a9274b
		if (sleep(1))
Packit Service a9274b
			fatal("aborted");
Packit Service a9274b
		ev->data.ext.ptr = (char *)ev->data.ext.ptr + MIDI_BYTES_PER_SEC;
Packit Service a9274b
		length -= MIDI_BYTES_PER_SEC;
Packit Service a9274b
	}
Packit Service a9274b
	ev->data.ext.len = length;
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void play_midi(void)
Packit Service a9274b
{
Packit Service a9274b
	snd_seq_event_t ev;
Packit Service a9274b
	int i, max_tick, err;
Packit Service a9274b
Packit Service a9274b
	/* calculate length of the entire file */
Packit Service a9274b
	max_tick = -1;
Packit Service a9274b
	for (i = 0; i < num_tracks; ++i) {
Packit Service a9274b
		if (tracks[i].end_tick > max_tick)
Packit Service a9274b
			max_tick = tracks[i].end_tick;
Packit Service a9274b
	}
Packit Service a9274b
Packit Service a9274b
	/* initialize current position in each track */
Packit Service a9274b
	for (i = 0; i < num_tracks; ++i)
Packit Service a9274b
		tracks[i].current_event = tracks[i].first_event;
Packit Service a9274b
Packit Service a9274b
	/* common settings for all our events */
Packit Service a9274b
	snd_seq_ev_clear(&ev;;
Packit Service a9274b
	ev.queue = queue;
Packit Service a9274b
	ev.source.port = 0;
Packit Service a9274b
	ev.flags = SND_SEQ_TIME_STAMP_TICK;
Packit Service a9274b
Packit Service a9274b
	err = snd_seq_start_queue(seq, queue, NULL);
Packit Service a9274b
	check_snd("start queue", err);
Packit Service a9274b
	/* The queue won't be started until the START_QUEUE event is
Packit Service a9274b
	 * actually drained to the kernel, which is exactly what we want. */
Packit Service a9274b
Packit Service a9274b
	for (;;) {
Packit Service a9274b
		struct event* event = NULL;
Packit Service a9274b
		struct track* event_track = NULL;
Packit Service a9274b
		int i, min_tick = max_tick + 1;
Packit Service a9274b
Packit Service a9274b
		/* search next event */
Packit Service a9274b
		for (i = 0; i < num_tracks; ++i) {
Packit Service a9274b
			struct track *track = &tracks[i];
Packit Service a9274b
			struct event *e2 = track->current_event;
Packit Service a9274b
			if (e2 && e2->tick < min_tick) {
Packit Service a9274b
				min_tick = e2->tick;
Packit Service a9274b
				event = e2;
Packit Service a9274b
				event_track = track;
Packit Service a9274b
			}
Packit Service a9274b
		}
Packit Service a9274b
		if (!event)
Packit Service a9274b
			break; /* end of song reached */
Packit Service a9274b
Packit Service a9274b
		/* advance pointer to next event */
Packit Service a9274b
		event_track->current_event = event->next;
Packit Service a9274b
Packit Service a9274b
		/* output the event */
Packit Service a9274b
		ev.type = event->type;
Packit Service a9274b
		ev.time.tick = event->tick;
Packit Service a9274b
		ev.dest = ports[event->port];
Packit Service a9274b
		switch (ev.type) {
Packit Service a9274b
		case SND_SEQ_EVENT_NOTEON:
Packit Service a9274b
		case SND_SEQ_EVENT_NOTEOFF:
Packit Service a9274b
		case SND_SEQ_EVENT_KEYPRESS:
Packit Service a9274b
			snd_seq_ev_set_fixed(&ev;;
Packit Service a9274b
			ev.data.note.channel = event->data.d[0];
Packit Service a9274b
			ev.data.note.note = event->data.d[1];
Packit Service a9274b
			ev.data.note.velocity = event->data.d[2];
Packit Service a9274b
			break;
Packit Service a9274b
		case SND_SEQ_EVENT_CONTROLLER:
Packit Service a9274b
			snd_seq_ev_set_fixed(&ev;;
Packit Service a9274b
			ev.data.control.channel = event->data.d[0];
Packit Service a9274b
			ev.data.control.param = event->data.d[1];
Packit Service a9274b
			ev.data.control.value = event->data.d[2];
Packit Service a9274b
			break;
Packit Service a9274b
		case SND_SEQ_EVENT_PGMCHANGE:
Packit Service a9274b
		case SND_SEQ_EVENT_CHANPRESS:
Packit Service a9274b
			snd_seq_ev_set_fixed(&ev;;
Packit Service a9274b
			ev.data.control.channel = event->data.d[0];
Packit Service a9274b
			ev.data.control.value = event->data.d[1];
Packit Service a9274b
			break;
Packit Service a9274b
		case SND_SEQ_EVENT_PITCHBEND:
Packit Service a9274b
			snd_seq_ev_set_fixed(&ev;;
Packit Service a9274b
			ev.data.control.channel = event->data.d[0];
Packit Service a9274b
			ev.data.control.value =
Packit Service a9274b
				((event->data.d[1]) |
Packit Service a9274b
				 ((event->data.d[2]) << 7)) - 0x2000;
Packit Service a9274b
			break;
Packit Service a9274b
		case SND_SEQ_EVENT_SYSEX:
Packit Service a9274b
			snd_seq_ev_set_variable(&ev, event->data.length,
Packit Service a9274b
						event->sysex);
Packit Service a9274b
			handle_big_sysex(&ev;;
Packit Service a9274b
			break;
Packit Service a9274b
		case SND_SEQ_EVENT_TEMPO:
Packit Service a9274b
			snd_seq_ev_set_fixed(&ev;;
Packit Service a9274b
			ev.dest.client = SND_SEQ_CLIENT_SYSTEM;
Packit Service a9274b
			ev.dest.port = SND_SEQ_PORT_SYSTEM_TIMER;
Packit Service a9274b
			ev.data.queue.queue = queue;
Packit Service a9274b
			ev.data.queue.param.value = event->data.tempo;
Packit Service a9274b
			break;
Packit Service a9274b
		default:
Packit Service a9274b
			fatal("Invalid event type %d!", ev.type);
Packit Service a9274b
		}
Packit Service a9274b
Packit Service a9274b
		/* this blocks when the output pool has been filled */
Packit Service a9274b
		err = snd_seq_event_output(seq, &ev;;
Packit Service a9274b
		check_snd("output event", err);
Packit Service a9274b
	}
Packit Service a9274b
Packit Service a9274b
	/* schedule queue stop at end of song */
Packit Service a9274b
	snd_seq_ev_set_fixed(&ev;;
Packit Service a9274b
	ev.type = SND_SEQ_EVENT_STOP;
Packit Service a9274b
	ev.time.tick = max_tick;
Packit Service a9274b
	ev.dest.client = SND_SEQ_CLIENT_SYSTEM;
Packit Service a9274b
	ev.dest.port = SND_SEQ_PORT_SYSTEM_TIMER;
Packit Service a9274b
	ev.data.queue.queue = queue;
Packit Service a9274b
	err = snd_seq_event_output(seq, &ev;;
Packit Service a9274b
	check_snd("output event", err);
Packit Service a9274b
Packit Service a9274b
	/* make sure that the sequencer sees all our events */
Packit Service a9274b
	err = snd_seq_drain_output(seq);
Packit Service a9274b
	check_snd("drain output", err);
Packit Service a9274b
Packit Service a9274b
	/*
Packit Service a9274b
	 * There are three possibilities how to wait until all events have
Packit Service a9274b
	 * been played:
Packit Service a9274b
	 * 1) send an event back to us (like pmidi does), and wait for it;
Packit Service a9274b
	 * 2) wait for the EVENT_STOP notification for our queue which is sent
Packit Service a9274b
	 *    by the system timer port (this would require a subscription);
Packit Service a9274b
	 * 3) wait until the output pool is empty.
Packit Service a9274b
	 * The last is the simplest.
Packit Service a9274b
	 */
Packit Service a9274b
	err = snd_seq_sync_output_queue(seq);
Packit Service a9274b
	check_snd("sync output", err);
Packit Service a9274b
Packit Service a9274b
	/* give the last notes time to die away */
Packit Service a9274b
	if (end_delay > 0)
Packit Service a9274b
		sleep(end_delay);
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void play_file(void)
Packit Service a9274b
{
Packit Service a9274b
	int ok;
Packit Service a9274b
Packit Service a9274b
	if (!strcmp(file_name, "-"))
Packit Service a9274b
		file = stdin;
Packit Service a9274b
	else
Packit Service a9274b
		file = fopen(file_name, "rb");
Packit Service a9274b
	if (!file) {
Packit Service a9274b
		errormsg("Cannot open %s - %s", file_name, strerror(errno));
Packit Service a9274b
		return;
Packit Service a9274b
	}
Packit Service a9274b
Packit Service a9274b
	file_offset = 0;
Packit Service a9274b
	ok = 0;
Packit Service a9274b
Packit Service a9274b
	switch (read_id()) {
Packit Service a9274b
	case MAKE_ID('M', 'T', 'h', 'd'):
Packit Service a9274b
		ok = read_smf();
Packit Service a9274b
		break;
Packit Service a9274b
	case MAKE_ID('R', 'I', 'F', 'F'):
Packit Service a9274b
		ok = read_riff();
Packit Service a9274b
		break;
Packit Service a9274b
	default:
Packit Service a9274b
		errormsg("%s is not a Standard MIDI File", file_name);
Packit Service a9274b
		break;
Packit Service a9274b
	}
Packit Service a9274b
Packit Service a9274b
	if (file != stdin)
Packit Service a9274b
		fclose(file);
Packit Service a9274b
Packit Service a9274b
	if (ok)
Packit Service a9274b
		play_midi();
Packit Service a9274b
Packit Service a9274b
	cleanup_file_data();
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void list_ports(void)
Packit Service a9274b
{
Packit Service a9274b
	snd_seq_client_info_t *cinfo;
Packit Service a9274b
	snd_seq_port_info_t *pinfo;
Packit Service a9274b
Packit Service a9274b
	snd_seq_client_info_alloca(&cinfo);
Packit Service a9274b
	snd_seq_port_info_alloca(&pinfo);
Packit Service a9274b
Packit Service a9274b
	puts(" Port    Client name                      Port name");
Packit Service a9274b
Packit Service a9274b
	snd_seq_client_info_set_client(cinfo, -1);
Packit Service a9274b
	while (snd_seq_query_next_client(seq, cinfo) >= 0) {
Packit Service a9274b
		int client = snd_seq_client_info_get_client(cinfo);
Packit Service a9274b
Packit Service a9274b
		snd_seq_port_info_set_client(pinfo, client);
Packit Service a9274b
		snd_seq_port_info_set_port(pinfo, -1);
Packit Service a9274b
		while (snd_seq_query_next_port(seq, pinfo) >= 0) {
Packit Service a9274b
			/* port must understand MIDI messages */
Packit Service a9274b
			if (!(snd_seq_port_info_get_type(pinfo)
Packit Service a9274b
			      & SND_SEQ_PORT_TYPE_MIDI_GENERIC))
Packit Service a9274b
				continue;
Packit Service a9274b
			/* we need both WRITE and SUBS_WRITE */
Packit Service a9274b
			if ((snd_seq_port_info_get_capability(pinfo)
Packit Service a9274b
			     & (SND_SEQ_PORT_CAP_WRITE | SND_SEQ_PORT_CAP_SUBS_WRITE))
Packit Service a9274b
			    != (SND_SEQ_PORT_CAP_WRITE | SND_SEQ_PORT_CAP_SUBS_WRITE))
Packit Service a9274b
				continue;
Packit Service a9274b
			printf("%3d:%-3d  %-32.32s %s\n",
Packit Service a9274b
			       snd_seq_port_info_get_client(pinfo),
Packit Service a9274b
			       snd_seq_port_info_get_port(pinfo),
Packit Service a9274b
			       snd_seq_client_info_get_name(cinfo),
Packit Service a9274b
			       snd_seq_port_info_get_name(pinfo));
Packit Service a9274b
		}
Packit Service a9274b
	}
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void usage(const char *argv0)
Packit Service a9274b
{
Packit Service a9274b
	printf(
Packit Service a9274b
		"Usage: %s -p client:port[,...] [-d delay] midifile ...\n"
Packit Service a9274b
		"-h, --help                  this help\n"
Packit Service a9274b
		"-V, --version               print current version\n"
Packit Service a9274b
		"-l, --list                  list all possible output ports\n"
Packit Service a9274b
		"-p, --port=client:port,...  set port(s) to play to\n"
Packit Service a9274b
		"-d, --delay=seconds         delay after song ends\n",
Packit Service a9274b
		argv0);
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
static void version(void)
Packit Service a9274b
{
Packit Service a9274b
	puts("aplaymidi version " SND_UTIL_VERSION_STR);
Packit Service a9274b
}
Packit Service a9274b
Packit Service a9274b
int main(int argc, char *argv[])
Packit Service a9274b
{
Packit Service a9274b
	static const char short_options[] = "hVlp:d:";
Packit Service a9274b
	static const struct option long_options[] = {
Packit Service a9274b
		{"help", 0, NULL, 'h'},
Packit Service a9274b
		{"version", 0, NULL, 'V'},
Packit Service a9274b
		{"list", 0, NULL, 'l'},
Packit Service a9274b
		{"port", 1, NULL, 'p'},
Packit Service a9274b
		{"delay", 1, NULL, 'd'},
Packit Service a9274b
		{0}
Packit Service a9274b
	};
Packit Service a9274b
	int c;
Packit Service a9274b
	int do_list = 0;
Packit Service a9274b
Packit Service a9274b
	init_seq();
Packit Service a9274b
Packit Service a9274b
	while ((c = getopt_long(argc, argv, short_options,
Packit Service a9274b
				long_options, NULL)) != -1) {
Packit Service a9274b
		switch (c) {
Packit Service a9274b
		case 'h':
Packit Service a9274b
			usage(argv[0]);
Packit Service a9274b
			return 0;
Packit Service a9274b
		case 'V':
Packit Service a9274b
			version();
Packit Service a9274b
			return 0;
Packit Service a9274b
		case 'l':
Packit Service a9274b
			do_list = 1;
Packit Service a9274b
			break;
Packit Service a9274b
		case 'p':
Packit Service a9274b
			parse_ports(optarg);
Packit Service a9274b
			break;
Packit Service a9274b
		case 'd':
Packit Service a9274b
			end_delay = atoi(optarg);
Packit Service a9274b
			break;
Packit Service a9274b
		default:
Packit Service a9274b
			usage(argv[0]);
Packit Service a9274b
			return 1;
Packit Service a9274b
		}
Packit Service a9274b
	}
Packit Service a9274b
Packit Service a9274b
	if (do_list) {
Packit Service a9274b
		list_ports();
Packit Service a9274b
	} else {
Packit Service a9274b
		if (port_count < 1) {
Packit Service a9274b
			/* use env var for compatibility with pmidi */
Packit Service a9274b
			const char *ports_str = getenv("ALSA_OUTPUT_PORTS");
Packit Service a9274b
			if (ports_str)
Packit Service a9274b
				parse_ports(ports_str);
Packit Service a9274b
			if (port_count < 1) {
Packit Service a9274b
				errormsg("Please specify at least one port with --port.");
Packit Service a9274b
				return 1;
Packit Service a9274b
			}
Packit Service a9274b
		}
Packit Service a9274b
		if (optind >= argc) {
Packit Service a9274b
			errormsg("Please specify a file to play.");
Packit Service a9274b
			return 1;
Packit Service a9274b
		}
Packit Service a9274b
Packit Service a9274b
		create_source_port();
Packit Service a9274b
		create_queue();
Packit Service a9274b
		connect_ports();
Packit Service a9274b
Packit Service a9274b
		for (; optind < argc; ++optind) {
Packit Service a9274b
			file_name = argv[optind];
Packit Service a9274b
			play_file();
Packit Service a9274b
		}
Packit Service a9274b
	}
Packit Service a9274b
	snd_seq_close(seq);
Packit Service a9274b
	return 0;
Packit Service a9274b
}