summaryrefslogtreecommitdiffstats
path: root/pcm/jack/pcm_jack.c
diff options
context:
space:
mode:
Diffstat (limited to 'pcm/jack/pcm_jack.c')
-rw-r--r--pcm/jack/pcm_jack.c428
1 files changed, 0 insertions, 428 deletions
diff --git a/pcm/jack/pcm_jack.c b/pcm/jack/pcm_jack.c
deleted file mode 100644
index 855f837..0000000
--- a/pcm/jack/pcm_jack.c
+++ /dev/null
@@ -1,428 +0,0 @@
-/*
- * PCM - JACK plugin
- *
- * Copyright (c) 2003 by Maarten de Boer <mdeboer@iua.upf.es>
- * 2005 Takashi Iwai <tiwai@suse.de>
- *
- * This library is free software; you can redistribute it and/or modify
- * it under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this library; if not, write to the Free Software
- * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
- *
- */
-
-#include <byteswap.h>
-#include <sys/shm.h>
-#include <sys/types.h>
-#include <sys/socket.h>
-#include <jack/jack.h>
-#include <alsa/asoundlib.h>
-#include <alsa/pcm_external.h>
-
-typedef enum _jack_format {
- SND_PCM_JACK_FORMAT_RAW
-} snd_pcm_jack_format_t;
-
-typedef struct {
- snd_pcm_ioplug_t io;
-
- int fd;
- int activated; /* jack is activated? */
-
- char **port_names;
- unsigned int num_ports;
- unsigned int hw_ptr;
- unsigned int sample_bits;
-
- unsigned int channels;
- snd_pcm_channel_area_t *areas;
-
- jack_port_t **ports;
- jack_client_t *client;
-} snd_pcm_jack_t;
-
-static void snd_pcm_jack_free(snd_pcm_jack_t *jack)
-{
- if (jack) {
- unsigned int i;
- if (jack->client)
- jack_client_close(jack->client);
- if (jack->port_names) {
- for (i = 0; i < jack->num_ports; i++)
- free(jack->port_names[i]);
- free(jack->port_names);
- }
- close(jack->fd);
- close(jack->io.poll_fd);
- free(jack->areas);
- free(jack);
- }
-}
-
-static int snd_pcm_jack_close(snd_pcm_ioplug_t *io)
-{
- snd_pcm_jack_t *jack = io->private_data;
- snd_pcm_jack_free(jack);
- return 0;
-}
-
-static int snd_pcm_jack_poll_revents(snd_pcm_ioplug_t *io,
- struct pollfd *pfds, unsigned int nfds,
- unsigned short *revents)
-{
- static char buf[1];
-
- assert(pfds && nfds == 1 && revents);
-
- read(pfds[0].fd, buf, 1);
-
- *revents = pfds[0].revents;
- return 0;
-}
-
-static snd_pcm_sframes_t snd_pcm_jack_pointer(snd_pcm_ioplug_t *io)
-{
- snd_pcm_jack_t *jack = io->private_data;
- return jack->hw_ptr;
-}
-
-static int
-snd_pcm_jack_process_cb(jack_nframes_t nframes, snd_pcm_ioplug_t *io)
-{
- snd_pcm_jack_t *jack = io->private_data;
- const snd_pcm_channel_area_t *areas;
- snd_pcm_uframes_t xfer = 0;
- static char buf[1];
- unsigned int channel;
-
- for (channel = 0; channel < io->channels; channel++) {
- jack->areas[channel].addr =
- jack_port_get_buffer (jack->ports[channel], nframes);
- jack->areas[channel].first = 0;
- jack->areas[channel].step = jack->sample_bits;
- }
-
- if (io->state != SND_PCM_STATE_RUNNING) {
- if (io->stream == SND_PCM_STREAM_PLAYBACK) {
- for (channel = 0; channel < io->channels; channel++)
- snd_pcm_area_silence(&jack->areas[channel], 0, nframes, io->format);
- return 0;
- }
- }
-
- areas = snd_pcm_ioplug_mmap_areas(io);
-
- while (xfer < nframes) {
- snd_pcm_uframes_t frames = nframes - xfer;
- snd_pcm_uframes_t offset = jack->hw_ptr;
- snd_pcm_uframes_t cont = io->buffer_size - offset;
-
- if (cont < frames)
- frames = cont;
-
- for (channel = 0; channel < io->channels; channel++) {
- if (io->stream == SND_PCM_STREAM_PLAYBACK)
- snd_pcm_area_copy(&jack->areas[channel], xfer, &areas[channel], offset, frames, io->format);
- else
- snd_pcm_area_copy(&areas[channel], offset, &jack->areas[channel], xfer, frames, io->format);
- }
-
- jack->hw_ptr += frames;
- jack->hw_ptr %= io->buffer_size;
- xfer += frames;
- }
-
- write(jack->fd, buf, 1); /* for polling */
-
- return 0;
-}
-
-static int snd_pcm_jack_prepare(snd_pcm_ioplug_t *io)
-{
- snd_pcm_jack_t *jack = io->private_data;
- unsigned int i;
-
- jack->hw_ptr = 0;
-
- if (jack->ports)
- return 0;
-
- jack->ports = calloc(io->channels, sizeof(jack_port_t*));
-
- for (i = 0; i < io->channels; i++) {
- char port_name[32];
- if (io->stream == SND_PCM_STREAM_PLAYBACK) {
-
- sprintf(port_name, "out_%03d\n", i);
- jack->ports[i] = jack_port_register(jack->client, port_name,
- JACK_DEFAULT_AUDIO_TYPE,
- JackPortIsOutput, 0);
- } else {
- sprintf(port_name, "in_%03d\n", i);
- jack->ports[i] = jack_port_register(jack->client, port_name,
- JACK_DEFAULT_AUDIO_TYPE,
- JackPortIsInput, 0);
- }
- }
-
- jack_set_process_callback(jack->client,
- (JackProcessCallback)snd_pcm_jack_process_cb, io);
- return 0;
-}
-
-static int snd_pcm_jack_start(snd_pcm_ioplug_t *io)
-{
- snd_pcm_jack_t *jack = io->private_data;
- unsigned int i;
-
- if (jack_activate (jack->client))
- return -EIO;
-
- jack->activated = 1;
-
- for (i = 0; i < io->channels && i < jack->num_ports; i++) {
- if (jack->port_names[i]) {
- const char *src, *dst;
- if (io->stream == SND_PCM_STREAM_PLAYBACK) {
- src = jack_port_name(jack->ports[i]);
- dst = jack->port_names[i];
- } else {
- src = jack->port_names[i];
- dst = jack_port_name(jack->ports[i]);
- }
- if (jack_connect(jack->client, src, dst)) {
- fprintf(stderr, "cannot connect %s to %s\n", src, dst);
- return -EIO;
- }
- }
- }
-
- return 0;
-}
-
-static int snd_pcm_jack_stop(snd_pcm_ioplug_t *io)
-{
- snd_pcm_jack_t *jack = io->private_data;
-
- if (jack->activated) {
- jack_deactivate(jack->client);
- jack->activated = 0;
- }
-#if 0
- unsigned i;
- for (i = 0; i < io->channels; i++) {
- if (jack->ports[i]) {
- jack_port_unregister(jack->client, jack->ports[i]);
- jack->ports[i] = NULL;
- }
- }
-#endif
- return 0;
-}
-
-static snd_pcm_ioplug_callback_t jack_pcm_callback = {
- .close = snd_pcm_jack_close,
- .start = snd_pcm_jack_start,
- .stop = snd_pcm_jack_stop,
- .pointer = snd_pcm_jack_pointer,
- .prepare = snd_pcm_jack_prepare,
- .poll_revents = snd_pcm_jack_poll_revents,
-};
-
-#define ARRAY_SIZE(ary) (sizeof(ary)/sizeof(ary[0]))
-
-static int jack_set_hw_constraint(snd_pcm_jack_t *jack)
-{
- unsigned int access_list[] = {
- SND_PCM_ACCESS_MMAP_INTERLEAVED,
- SND_PCM_ACCESS_MMAP_NONINTERLEAVED,
- SND_PCM_ACCESS_RW_INTERLEAVED,
- SND_PCM_ACCESS_RW_NONINTERLEAVED
- };
- unsigned int format = SND_PCM_FORMAT_FLOAT;
- unsigned int rate = jack_get_sample_rate(jack->client);
- int err;
-
- jack->sample_bits = snd_pcm_format_physical_width(format);
- if ((err = snd_pcm_ioplug_set_param_list(&jack->io, SND_PCM_IOPLUG_HW_ACCESS,
- ARRAY_SIZE(access_list), access_list)) < 0 ||
- (err = snd_pcm_ioplug_set_param_list(&jack->io, SND_PCM_IOPLUG_HW_FORMAT,
- 1, &format)) < 0 ||
- (err = snd_pcm_ioplug_set_param_minmax(&jack->io, SND_PCM_IOPLUG_HW_CHANNELS,
- jack->channels, jack->channels)) < 0 ||
- (err = snd_pcm_ioplug_set_param_minmax(&jack->io, SND_PCM_IOPLUG_HW_RATE,
- rate, rate)) < 0 ||
- (err = snd_pcm_ioplug_set_param_minmax(&jack->io, SND_PCM_IOPLUG_HW_PERIOD_BYTES,
- 128, 64*1024)) < 0 ||
- (err = snd_pcm_ioplug_set_param_minmax(&jack->io, SND_PCM_IOPLUG_HW_PERIODS,
- 2, 64)) < 0)
- return err;
-
- return 0;
-}
-
-static int parse_ports(snd_pcm_jack_t *jack, snd_config_t *conf)
-{
- snd_config_iterator_t i, next;
- char **ports = NULL;
- unsigned int cnt = 0;
- unsigned int channel;
-
- if (conf) {
- snd_config_for_each(i, next, conf) {
- snd_config_t *n = snd_config_iterator_entry(i);
- const char *id;
- if (snd_config_get_id(n, &id) < 0)
- continue;
- cnt++;
- }
- jack->port_names = ports = calloc(cnt, sizeof(char*));
- if (ports == NULL)
- return -ENOMEM;
- jack->num_ports = cnt;
- snd_config_for_each(i, next, conf) {
- snd_config_t *n = snd_config_iterator_entry(i);
- const char *id;
- const char *port;
-
- if (snd_config_get_id(n, &id) < 0)
- continue;
- channel = atoi(id);
- if (snd_config_get_string(n, &port) < 0)
- continue;
- ports[channel] = port ? strdup(port) : NULL;
- }
- }
- return 0;
-}
-
-static int snd_pcm_jack_open(snd_pcm_t **pcmp, const char *name,
- snd_config_t *playback_conf,
- snd_config_t *capture_conf,
- snd_pcm_stream_t stream, int mode)
-{
- snd_pcm_jack_t *jack;
- int err;
- int fd[2];
- static unsigned int num = 0;
- char jack_client_name[32];
-
- assert(pcmp);
- jack = calloc(1, sizeof(*jack));
- if (!jack)
- return -ENOMEM;
-
- err = parse_ports(jack, stream == SND_PCM_STREAM_PLAYBACK ?
- playback_conf : capture_conf);
- if (err) {
- snd_pcm_jack_free(jack);
- return err;
- }
-
- jack->channels = jack->num_ports;
- if (jack->channels == 0) {
- SNDERR("define the %s_ports section",
- stream == SND_PCM_STREAM_PLAYBACK ? "playback" : "capture");
- snd_pcm_jack_free(jack);
- return -EINVAL;
- }
-
- if (snprintf(jack_client_name, sizeof(jack_client_name), "alsa-jack.%s%s.%d.%d", name,
- stream == SND_PCM_STREAM_PLAYBACK ? "P" : "C", getpid(), num++)
- >= (int)sizeof(jack_client_name)) {
- fprintf(stderr, "%s: WARNING: JACK client name '%s' truncated to %d characters, might not be unique\n",
- __func__, jack_client_name, (int)strlen(jack_client_name));
- }
-
- jack->client = jack_client_new(jack_client_name);
-
- if (jack->client == 0) {
- snd_pcm_jack_free(jack);
- return -ENOENT;
- }
-
- jack->areas = calloc(jack->channels, sizeof(snd_pcm_channel_area_t));
- if (! jack->areas) {
- snd_pcm_jack_free(jack);
- return -ENOMEM;
- }
-
- socketpair(AF_LOCAL, SOCK_STREAM, 0, fd);
-
- jack->fd = fd[0];
-
- jack->io.version = SND_PCM_IOPLUG_VERSION;
- jack->io.name = "ALSA <-> JACK PCM I/O Plugin";
- jack->io.callback = &jack_pcm_callback;
- jack->io.private_data = jack;
- jack->io.poll_fd = fd[1];
- jack->io.poll_events = POLLIN;
- jack->io.mmap_rw = 1;
-
- err = snd_pcm_ioplug_create(&jack->io, name, stream, mode);
- if (err < 0) {
- snd_pcm_jack_free(jack);
- return err;
- }
-
- err = jack_set_hw_constraint(jack);
- if (err < 0) {
- snd_pcm_ioplug_delete(&jack->io);
- return err;
- }
-
- *pcmp = jack->io.pcm;
-
- return 0;
-}
-
-
-SND_PCM_PLUGIN_DEFINE_FUNC(jack)
-{
- snd_config_iterator_t i, next;
- snd_config_t *playback_conf = NULL;
- snd_config_t *capture_conf = NULL;
- int err;
-
- snd_config_for_each(i, next, conf) {
- snd_config_t *n = snd_config_iterator_entry(i);
- const char *id;
- if (snd_config_get_id(n, &id) < 0)
- continue;
- if (strcmp(id, "comment") == 0 || strcmp(id, "type") == 0)
- continue;
- if (strcmp(id, "playback_ports") == 0) {
- if (snd_config_get_type(n) != SND_CONFIG_TYPE_COMPOUND) {
- SNDERR("Invalid type for %s", id);
- return -EINVAL;
- }
- playback_conf = n;
- continue;
- }
- if (strcmp(id, "capture_ports") == 0) {
- if (snd_config_get_type(n) != SND_CONFIG_TYPE_COMPOUND) {
- SNDERR("Invalid type for %s", id);
- return -EINVAL;
- }
- capture_conf = n;
- continue;
- }
- SNDERR("Unknown field %s", id);
- return -EINVAL;
- }
-
- err = snd_pcm_jack_open(pcmp, name, playback_conf, capture_conf, stream, mode);
-
- return err;
-}
-
-SND_PCM_PLUGIN_SYMBOL(jack);