aboutsummaryrefslogtreecommitdiffstats
path: root/src/audioOutputs
diff options
context:
space:
mode:
Diffstat (limited to 'src/audioOutputs')
-rw-r--r--src/audioOutputs/audioOutput_jack.c380
1 files changed, 380 insertions, 0 deletions
diff --git a/src/audioOutputs/audioOutput_jack.c b/src/audioOutputs/audioOutput_jack.c
new file mode 100644
index 000000000..8f67cfcdf
--- /dev/null
+++ b/src/audioOutputs/audioOutput_jack.c
@@ -0,0 +1,380 @@
+/* jack plug in for the Music Player Daemon (MPD)
+ * (c)2006 by anarch(anarchsss@gmail.com)
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 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 General Public License for more details.
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
+ */
+
+
+#include "../audioOutput.h"
+
+#ifdef HAVE_JACK
+
+#include <stdlib.h>
+#include <errno.h>
+
+#include "../conf.h"
+#include "../log.h"
+#include "../sig_handlers.h"
+
+#include <sys/types.h>
+#include <string.h>
+#include <assert.h>
+#include <signal.h>
+#include <unistd.h>
+
+#include <jack/jack.h>
+#include <jack/types.h>
+#include <jack/ringbuffer.h>
+
+#define MIN(a, b) ((a) < (b) ? (a) : (b))
+int ringbuf_sz = 32768;
+char *ports[2] = {NULL, NULL};
+
+typedef struct _JackData {
+ jack_options_t options;
+ jack_port_t *ports[2];
+ jack_client_t *client;
+ jack_default_audio_sample_t **in;
+ jack_ringbuffer_t *ringbuffer[2];
+ int bps;
+ int shutdown;
+ int nports;
+ int our_xrun;
+} JackData;
+
+JackData *jd = NULL;
+
+static JackData *newJackData (void)
+{
+ JackData *ret;
+
+ ret = calloc (sizeof (JackData), 1);
+ ret->options = JackNullOption;
+
+ return ret;
+}
+
+static void disconnect_jack (JackData *jd)
+{
+ jack_deactivate (jd->client);
+ jack_client_close (jd->client);
+
+ ERROR ("disconnect_jack (pid=%d)\n", getpid ());
+}
+
+static void jack_finishDriver (AudioOutput * audioOutput)
+{
+ JackData *jd = audioOutput->data;
+
+ disconnect_jack (jd);
+
+ free (jd);
+ free (ports[0]);
+ free (ports[1]);
+}
+
+static int srate (jack_nframes_t rate, void *data)
+{
+ JackData *jd = (JackData *) ((AudioOutput*) data)->data;
+ AudioFormat *audioFormat = &(((AudioOutput*) data)->outAudioFormat);
+
+ audioFormat->sampleRate = (int) jack_get_sample_rate (jd->client);
+
+ return 0;
+}
+
+static int process (jack_nframes_t nframes, void *arg)
+{
+ size_t i;
+ JackData *jd = (JackData *) arg;
+ jack_default_audio_sample_t *out[2];
+ size_t avail_data, avail_frames;
+
+ if ( nframes <= 0 )
+ return 0;
+
+ out[0] = jack_port_get_buffer (jd->ports[0], nframes);
+ out[1] = jack_port_get_buffer (jd->ports[1], nframes);
+
+ avail_data = jack_ringbuffer_read_space (jd->ringbuffer[1]);
+
+ if ( avail_data > 0 ) {
+ avail_frames = avail_data / sizeof (jack_default_audio_sample_t);
+ if (avail_frames > nframes) {
+ avail_frames = nframes;
+ avail_data = nframes * sizeof (jack_default_audio_sample_t);
+ }
+ jack_ringbuffer_read (jd->ringbuffer[0], (char *)out[0], avail_data);
+ jack_ringbuffer_read (jd->ringbuffer[1], (char *)out[1], avail_data);
+
+ if (avail_frames < nframes) {
+ jd->our_xrun = 1;
+ for (i = avail_frames; i < nframes; i++) {
+ out[0][i] = out[1][i] = 0.0;
+ }
+ }
+ } else {
+ //ERROR ("avail_data=%d, no play (pid=%d)!\n", avail_data, getpid ());
+
+ for (i = 0; i < nframes; i++) {
+ out[0][i] = 0.0;
+ out[1][i] = 0.0;
+ }
+ }
+
+ return 0;
+}
+
+static void shutdown_callback (void *arg)
+{
+ JackData *jd = (JackData *) arg;
+ jd->shutdown = 1;
+}
+
+static void set_audioformat (AudioOutput *audioOutput)
+{
+ JackData *jd = audioOutput->data;
+ AudioFormat *audioFormat = &audioOutput->outAudioFormat;
+
+ audioFormat->sampleRate = (int) jack_get_sample_rate (jd->client);
+ ERROR ("samplerate = %d\n", audioFormat->sampleRate);
+ jd->nports = audioFormat->channels = 2;
+ audioFormat->bits = 16;
+ jd->bps = audioFormat->channels *
+ audioFormat->channels *
+ audioFormat->sampleRate;
+}
+
+static int connect_jack (AudioOutput *audioOutput)
+{
+ JackData *jd = audioOutput->data;
+ const char **jports;
+
+ if ( (jd->client = jack_client_new ("mpd")) == NULL ) {
+ ERROR ("jack server not running?\n");
+ return -1;
+ }
+
+ jd->ringbuffer[0] = jack_ringbuffer_create (ringbuf_sz);
+ jd->ringbuffer[1] = jack_ringbuffer_create (ringbuf_sz);
+
+ jack_set_process_callback (jd->client, process, (void *)jd);
+ jack_set_sample_rate_callback (jd->client, (JackProcessCallback)srate,
+ (void *)audioOutput);
+ jack_on_shutdown (jd->client, shutdown_callback, (void *)jd);
+
+ if ( jack_activate (jd->client) ) {
+ ERROR ("cannot activate client");
+ jack_ringbuffer_free (jd->ringbuffer[0]);
+ jack_ringbuffer_free (jd->ringbuffer[1]);
+ return -1;
+ }
+
+ jd->ports[0] = jack_port_register (jd->client, "left",
+ JACK_DEFAULT_AUDIO_TYPE,
+ JackPortIsOutput, 0);
+ if ( !jd->ports[0] ) {
+ ERROR ("Cannot register output port.\n");
+ jack_ringbuffer_free (jd->ringbuffer[0]);
+ jack_ringbuffer_free (jd->ringbuffer[1]);
+ return -1;
+ }
+
+ jd->ports[1] = jack_port_register (jd->client, "right",
+ JACK_DEFAULT_AUDIO_TYPE,
+ JackPortIsOutput, 0);
+ if ( !jd->ports[1] ) {
+ ERROR ("Cannot register output port.\n");
+ jack_ringbuffer_free (jd->ringbuffer[0]);
+ jack_ringbuffer_free (jd->ringbuffer[1]);
+ return -1;
+ }
+
+ memset (jd->ringbuffer[0]->buf, 0, jd->ringbuffer[0]->size);
+ memset (jd->ringbuffer[1]->buf, 0, jd->ringbuffer[1]->size);
+
+ /* hay que buscar que hay */
+ if ( !ports[1] && (jports = jack_get_ports (jd->client, NULL, NULL,
+ JackPortIsPhysical|
+ JackPortIsInput)) ) {
+ ports[0] = (char *) jports[0];
+ ports[1] = (char *) ( jports[1] ? jports[1] : jports[0] );
+ ERROR ("jports: %s %s\n", ports[0], ports[1]);
+ free (jports);
+ }
+
+ if ( ports[1] ) {
+ if ( (jack_connect (jd->client, "mpd:left", ports[0])) != 0 ) {
+ ERROR ("%s is not a valid Jack Client / Port ", ports[0]);
+ jack_ringbuffer_free (jd->ringbuffer[0]);
+ jack_ringbuffer_free (jd->ringbuffer[1]);
+ return -1;
+ }
+ if ( (jack_connect (jd->client, "mpd:right", ports[1])) != 0 ) {
+ ERROR ("%s is not a valid Jack Client / Port ", ports[1]);
+ jack_ringbuffer_free (jd->ringbuffer[0]);
+ jack_ringbuffer_free (jd->ringbuffer[1]);
+ return -1;
+ }
+ }
+
+ ERROR ("connect_jack (pid=%d)\n", getpid ());
+ return 1;
+}
+
+static int jack_initDriver (AudioOutput *audioOutput, ConfigParam *param)
+{
+ BlockParam *bp;
+ char *endptr;
+ int val;
+ char *cp = NULL;
+
+ if ( param ) {
+ bp = getBlockParam (param, "ports");
+ if ( bp ) {
+ cp = strdup (bp->value);
+ ports[0] = strdup (strtok (cp, " ,"));
+ ports[1] = strdup (strtok (NULL, " ,"));
+ free (cp);
+ }
+
+ bp = getBlockParam (param, "ringbuffer_size");
+ if ( bp ) {
+ errno = 0;
+ val = strtol (bp->value, &endptr, 10);
+
+ if ( errno == 0 && endptr != bp->value) {
+ ringbuf_sz = val;
+ ERROR ("ringbuffer_size=%d\n", ringbuf_sz);
+ } else {
+ ERROR ("%s is not a number; ringbuf_size=%d\n",
+ bp->value, ringbuf_sz);
+ }
+ }
+ }
+
+ ERROR ("jack_initDriver (pid=%d)\n", getpid ());
+
+ return 0;
+
+}
+
+static int jack_testDefault(void)
+{
+ return 0;
+}
+
+static int jack_openDevice (AudioOutput *audioOutput)
+{
+ if ( !jd ) {
+ jd = newJackData ();
+ audioOutput->data = jd;
+
+ if ( !connect_jack (audioOutput) ) {
+ free (jd);
+ return -1;
+ }
+ }
+
+ set_audioformat (audioOutput);
+ audioOutput->open = 1;
+
+ ERROR ("jack_openDevice (pid=%d)!\n", getpid ());
+ return 0;
+}
+
+
+static void jack_closeDevice(AudioOutput * audioOutput)
+{
+ audioOutput->open = 0;
+ ERROR ("jack_closeDevice (pid=%d)!\n", getpid ());
+}
+
+static void jack_dropBufferedAudio (AudioOutput * audioOutput)
+{
+
+}
+
+static int jack_playAudio(AudioOutput * audioOutput, char *buff, int size)
+{
+ JackData *jd = audioOutput->data;
+ size_t remain = size;
+ size_t pos = 0;
+
+ if ( jd->shutdown ) {
+ ERROR ("Refusing to play, because there is no client thread.\n");
+ return 0;
+ }
+
+ if ( jd->our_xrun ) {
+ ERROR ("xrun\n");
+ jd->our_xrun = 0;
+ }
+
+ while (remain && !jd->shutdown) {
+ size_t space;
+
+ if ( (space = jack_ringbuffer_write_space (jd->ringbuffer[0]))
+ > sizeof (jack_default_audio_sample_t) ) {
+ size_t to_write;
+
+ to_write = MIN (space, remain);
+ remain -= to_write;
+ to_write /= 4;
+ //ERROR ("\t\tto_write=%d remain=%d (%d)\n", to_write, remain, to_write * 2 * 2);
+ while (to_write--) {
+ jack_default_audio_sample_t sample;
+
+ sample = *(short *)(buff + pos);
+ sample /= 32768;
+ pos += 2;
+ jack_ringbuffer_write (jd->ringbuffer[0],
+ (char *)&sample,
+ sizeof (sample));
+
+
+ sample = *(short *)(buff + pos);
+ sample /= 32768;
+ pos += 2;
+ jack_ringbuffer_write (jd->ringbuffer[1],
+ (char *)&sample,
+ sizeof (sample));
+ }
+ } else {
+ usleep (ringbuf_sz / (float)(jd->bps) * 100000.0);
+ }
+ }
+
+ return 0;
+
+}
+
+AudioOutputPlugin jackPlugin = {
+ "jack",
+ jack_testDefault,
+ jack_initDriver,
+ jack_finishDriver,
+ jack_openDevice,
+ jack_playAudio,
+ jack_dropBufferedAudio,
+ jack_closeDevice,
+ NULL, /* sendMetadataFunc */
+};
+
+
+#else /* HAVE JACK */
+
+DISABLED_AUDIO_OUTPUT_PLUGIN(jackPlugin)
+
+#endif /* HAVE_JACK */
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-11 00:35:39 +0000