summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/audio_out/Makefile.am10
-rw-r--r--src/audio_out/audio_pulse_out.c584
2 files changed, 594 insertions, 0 deletions
diff --git a/src/audio_out/Makefile.am b/src/audio_out/Makefile.am
index 5c3dac5aa..996b61925 100644
--- a/src/audio_out/Makefile.am
+++ b/src/audio_out/Makefile.am
@@ -43,6 +43,10 @@ if HAVE_POLYPAUDIO
polypaudio_module = xineplug_ao_out_polypaudio.la
endif
+if HAVE_PULSEAUDIO
+pulseaudio_module = xineplug_ao_out_pulseaudio.la
+endif
+
if HAVE_FUSIONSOUND
fusionsound_module = xineplug_ao_out_fusionsound.la
endif
@@ -63,6 +67,7 @@ lib_LTLIBRARIES = xineplug_ao_out_none.la xineplug_ao_out_file.la \
$(directx_module) \
$(coreaudio_module) \
$(polypaudio_module) \
+ $(pulseaudio_module) \
$(directx2_module) \
$(fusionsound_module)
@@ -134,6 +139,11 @@ xineplug_ao_out_polypaudio_la_LIBADD = $(POLYPAUDIO_LIBS) $(XINE_LIB)
xineplug_ao_out_polypaudio_la_CFLAGS = $(VISIBILITY_FLAG) $(POLYPAUDIO_CFLAGS)
xineplug_ao_out_polypaudio_la_LDFLAGS = -avoid-version -module
+xineplug_ao_out_pulseaudio_la_SOURCES = audio_pulse_out.c
+xineplug_ao_out_pulseaudio_la_LIBADD = $(PULSEAUDIO_LIBS) $(XINE_LIB)
+xineplug_ao_out_pulseaudio_la_CFLAGS = $(VISIBILITY_FLAG) $(PULSEAUDIO_CFLAGS)
+xineplug_ao_out_pulseaudio_la_LDFLAGS = -avoid-version -module
+
xineplug_ao_out_directx2_la_SOURCES = audio_directx2_out.c
xineplug_ao_out_directx2_la_CPPFLAGS = $(DIRECTX_CPPFLAGS)
xineplug_ao_out_directx2_la_LIBADD = $(XINE_LIB) $(DIRECTX_AUDIO_LIBS) $(THREAD_LIBS)
diff --git a/src/audio_out/audio_pulse_out.c b/src/audio_out/audio_pulse_out.c
new file mode 100644
index 000000000..08fe731e6
--- /dev/null
+++ b/src/audio_out/audio_pulse_out.c
@@ -0,0 +1,584 @@
+/*
+ * Copyright (C) 2000-2003 the xine project
+ *
+ * This file is part of xine, a free video player.
+ *
+ * xine 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.
+ *
+ * xine 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
+ *
+ * $Id: audio_pulse_out.c,v 1.1 2006/07/11 05:20:32 dgp85 Exp $
+ *
+ * ao plugin for pulseaudio (rename of polypaudio):
+ * http://0pointer.de/lennart/projects/pulsaudio/
+ *
+ * originally written for polypaudio simple api. Lennart then suggested
+ * using the async api for better control (such as volume), therefore, a lot
+ * of this code comes from Lennart's patch to mplayer.
+ *
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include <stdio.h>
+#include <errno.h>
+#include <string.h>
+#include <stdlib.h>
+#include <fcntl.h>
+#include <math.h>
+#include <unistd.h>
+#include <inttypes.h>
+#include <assert.h>
+#include <pthread.h>
+
+#include <pulse/pulseaudio.h>
+#include <pulse/error.h>
+#include <pulse/mainloop.h>
+
+#include "xine_internal.h"
+#include "xineutils.h"
+#include "audio_out.h"
+#include "bswap.h"
+
+#define GAP_TOLERANCE AO_MAX_GAP
+
+typedef struct pulse_driver_s {
+
+ ao_driver_t ao_driver;
+
+ xine_t *xine;
+
+ /** The host to connect to */
+ char *host;
+
+ /** The sink to connect to */
+ char *sink;
+
+ /** Pulseaudio playback stream object */
+ struct pa_stream *stream;
+
+ /** Pulseaudio connection context */
+ struct pa_context *context;
+
+ /** Main event loop object */
+ struct pa_mainloop *mainloop;
+
+ pa_volume_t swvolume;
+ pa_cvolume cvolume;
+
+ int capabilities;
+ int mode;
+
+ int32_t sample_rate;
+ uint32_t num_channels;
+ uint32_t bits_per_sample;
+ uint32_t bytes_per_frame;
+
+ uint32_t frames_written;
+
+ pthread_mutex_t lock;
+
+} pulse_driver_t;
+
+typedef struct {
+ audio_driver_class_t driver_class;
+
+ xine_t *xine;
+} pulse_class_t;
+
+
+/** Make sure that the connection context doesn't starve to death */
+static void keep_alive(pulse_driver_t *this) {
+ assert(this->context && this->mainloop);
+
+ while (pa_mainloop_iterate(this->mainloop, 0, NULL) > 0);
+}
+
+/** Wait until no further actions are pending on the connection context */
+static void wait_for_completion(pulse_driver_t *this) {
+ assert(this->context && this->mainloop);
+
+ while (pa_context_is_pending(this->context)) {
+ int r = pa_mainloop_iterate(this->mainloop, 1, NULL);
+ assert(r >= 0);
+ }
+}
+
+/** Wait until the specified operation completes */
+static void wait_for_operation(pulse_driver_t *this, struct pa_operation *o) {
+ assert(o && this->context && this->mainloop);
+
+ while (pa_operation_get_state(o) == PA_OPERATION_RUNNING) {
+ int r = pa_mainloop_iterate(this->mainloop, 1, NULL);
+ assert(r >= 0);
+ }
+
+ pa_operation_unref(o);
+}
+
+/*
+ * open the audio device for writing to
+ */
+static int ao_pulse_open(ao_driver_t *this_gen,
+ uint32_t bits, uint32_t rate, int mode)
+{
+ pulse_driver_t *this = (pulse_driver_t *) this_gen;
+ struct pa_sample_spec ss;
+ struct pa_buffer_attr a;
+
+ xprintf (this->xine, XINE_VERBOSITY_DEBUG,
+ "audio_pulse_out: ao_open bits=%d rate=%d, mode=%d\n", bits, rate, mode);
+
+ if ( (mode & this->capabilities) == 0 ) {
+ xprintf (this->xine, XINE_VERBOSITY_DEBUG, "audio_pulse_out: unsupported mode %08x\n", mode);
+ return 0;
+ }
+
+ if (this->stream) {
+
+ if ( mode == this->mode && rate == this->sample_rate &&
+ bits == this->bits_per_sample )
+ return this->sample_rate;
+
+ this_gen->close(this_gen);
+ }
+
+ this->mode = mode;
+ this->sample_rate = rate;
+ this->bits_per_sample = bits;
+ this->num_channels = _x_ao_mode2channels( mode );
+ this->bytes_per_frame = (this->bits_per_sample*this->num_channels)/8;
+
+ ss.rate = rate;
+ ss.channels = this->num_channels;
+ switch (bits) {
+ case 8:
+ ss.format = PA_SAMPLE_U8;
+ break;
+ case 16:
+#ifdef WORDS_BIGENDIAN
+ ss.format = PA_SAMPLE_S16BE;
+#else
+ ss.format = PA_SAMPLE_S16LE;
+#endif
+ break;
+ case 32:
+ ss.format = PA_SAMPLE_FLOAT32;
+ break;
+ }
+
+ pthread_mutex_lock(&this->lock);
+
+ if (!pa_sample_spec_valid(&ss)) {
+ xprintf (this->xine, XINE_VERBOSITY_DEBUG, "audio_pulse_out: Invalid sample spec\n");
+ goto fail;
+ }
+
+ this->mainloop = pa_mainloop_new();
+ assert(this->mainloop);
+
+ this->context = pa_context_new(pa_mainloop_get_api(this->mainloop), "xine");
+ assert(this->context);
+
+ pa_context_connect(this->context, this->host, 1, NULL);
+
+ wait_for_completion(this);
+
+ if (pa_context_get_state(this->context) != PA_CONTEXT_READY) {
+ xprintf (this->xine, XINE_VERBOSITY_DEBUG, "audio_pulse_out: Failed to connect to server: %s\n",
+ pa_strerror(pa_context_errno(this->context)));
+ goto fail;
+ }
+
+ this->stream = pa_stream_new(this->context, "audio stream", &ss, NULL);
+ assert(this->stream);
+
+ a.maxlength = pa_bytes_per_second(&ss)*1;
+ a.tlength = a.maxlength*9/10;
+ a.prebuf = a.tlength/2;
+ a.minreq = a.tlength/10;
+
+ pa_cvolume_set(&this->cvolume, pa_stream_get_sample_spec(this->stream)->channels, this->swvolume);
+ pa_stream_connect_playback(this->stream, this->sink, &a, PA_STREAM_INTERPOLATE_TIMING, &this->cvolume, NULL);
+
+ wait_for_completion(this);
+
+ if (pa_stream_get_state(this->stream) != PA_STREAM_READY) {
+ xprintf (this->xine, XINE_VERBOSITY_DEBUG, "audio_pulse_out: Failed to connect to server: %s\n",
+ pa_strerror(pa_context_errno(this->context)));
+ goto fail;
+ }
+ pthread_mutex_unlock(&this->lock);
+
+ this->frames_written = 0;
+
+ return this->sample_rate;
+
+fail:
+ pthread_mutex_unlock(&this->lock);
+ this_gen->close(this_gen);
+ return 0;
+}
+
+
+static int ao_pulse_num_channels(ao_driver_t *this_gen)
+{
+ pulse_driver_t *this = (pulse_driver_t *) this_gen;
+ return this->num_channels;
+}
+
+static int ao_pulse_bytes_per_frame(ao_driver_t *this_gen)
+{
+ pulse_driver_t *this = (pulse_driver_t *) this_gen;
+ return this->bytes_per_frame;
+}
+
+static int ao_pulse_get_gap_tolerance (ao_driver_t *this_gen)
+{
+ return GAP_TOLERANCE;
+}
+
+static int ao_pulse_write(ao_driver_t *this_gen, int16_t *data,
+ uint32_t num_frames)
+{
+ pulse_driver_t *this = (pulse_driver_t *) this_gen;
+ int size = num_frames * this->bytes_per_frame;
+ int ret = 0;
+
+ assert(this->stream && this->context);
+
+ pthread_mutex_lock(&this->lock);
+
+ if (pa_stream_get_state(this->stream) == PA_STREAM_READY) {
+
+ while (size > 0) {
+ size_t l;
+
+ keep_alive(this);
+
+ while (!(l = pa_stream_writable_size(this->stream))) {
+ pthread_mutex_unlock(&this->lock);
+ xine_usec_sleep (10000);
+ pthread_mutex_lock(&this->lock);
+ keep_alive(this);
+ }
+
+ if (l > size)
+ l = size;
+
+ pa_stream_write(this->stream, data, l, NULL, 0, PA_SEEK_RELATIVE);
+ data = (int16_t *) ((uint8_t*) data + l);
+ size -= l;
+
+ wait_for_completion(this);
+ }
+
+ this->frames_written += num_frames;
+
+ if (pa_stream_get_state(this->stream) == PA_STREAM_READY)
+ ret = 1;
+ }
+ pthread_mutex_unlock(&this->lock);
+
+ return ret;
+}
+
+
+static int ao_pulse_delay (ao_driver_t *this_gen)
+{
+ pulse_driver_t *this = (pulse_driver_t *) this_gen;
+ pa_usec_t latency;
+ int delay_frames;
+
+#if 0 /* TODO: This part has to be ported to new pulseaudio API */
+ pthread_mutex_lock(&this->lock);
+ keep_alive(this);
+ latency = pa_stream_get_interpolated_latency(this->stream, NULL);
+ pthread_mutex_unlock(&this->lock);
+
+ /* convert latency (us) to frame units. */
+ delay_frames = (int)(latency * this->sample_rate / 1000000);
+#else
+ delay_frames = 0;
+#endif
+
+ if( delay_frames > this->frames_written )
+ return this->frames_written;
+ else
+ return delay_frames;
+}
+
+static void ao_pulse_close(ao_driver_t *this_gen)
+{
+ pulse_driver_t *this = (pulse_driver_t *) this_gen;
+
+ pthread_mutex_lock(&this->lock);
+ if (this->stream) {
+ if (pa_stream_get_state(this->stream) == PA_STREAM_READY)
+ wait_for_operation(this, pa_stream_drain(this->stream, NULL, NULL));
+ pa_stream_disconnect(this->stream);
+ pa_stream_unref(this->stream);
+ this->stream = NULL;
+ }
+
+ if (this->context) {
+ pa_context_disconnect(this->context);
+ pa_context_unref(this->context);
+ this->context = NULL;
+ }
+
+ if (this->mainloop) {
+ pa_mainloop_free(this->mainloop);
+ this->mainloop = NULL;
+ }
+ pthread_mutex_unlock(&this->lock);
+}
+
+static uint32_t ao_pulse_get_capabilities (ao_driver_t *this_gen) {
+ pulse_driver_t *this = (pulse_driver_t *) this_gen;
+ return this->capabilities;
+}
+
+static void ao_pulse_exit(ao_driver_t *this_gen)
+{
+ pulse_driver_t *this = (pulse_driver_t *) this_gen;
+
+ free (this);
+}
+
+/** A callback function that is called when the
+ * pa_context_get_sink_input_info() operation completes. Saves the
+ * volume field of the specified structure to the global variable volume. */
+static void info_func(struct pa_context *c, const struct pa_sink_input_info *i, int is_last, void *userdata) {
+
+ pulse_driver_t *this = (pulse_driver_t *) userdata;
+ if (is_last < 0) {
+ xprintf (this->xine, XINE_VERBOSITY_DEBUG, "audio_pulse_out: Failed to get sink input info: %s\n",
+ pa_strerror(pa_context_errno(this->context)));
+ return;
+ }
+
+ if (!i)
+ return;
+
+ this->cvolume = i->volume;
+}
+
+
+static int ao_pulse_get_property (ao_driver_t *this_gen, int property) {
+ pulse_driver_t *this = (pulse_driver_t *) this_gen;
+
+ switch(property) {
+ case AO_PROP_PCM_VOL:
+ case AO_PROP_MIXER_VOL:
+ pthread_mutex_lock(&this->lock);
+ if( this->stream && this->context )
+ wait_for_operation(this,
+ pa_context_get_sink_input_info(this->context, pa_stream_get_index(this->stream), info_func, this));
+ pthread_mutex_unlock(&this->lock);
+ return (int) (pa_sw_volume_to_linear(this->swvolume)*100);
+ break;
+ case AO_PROP_MUTE_VOL:
+ break;
+ }
+
+ return 0;
+}
+
+static int ao_pulse_set_property (ao_driver_t *this_gen, int property, int value) {
+ pulse_driver_t *this = (pulse_driver_t *) this_gen;
+
+ switch(property) {
+ case AO_PROP_PCM_VOL:
+ case AO_PROP_MIXER_VOL:
+ pthread_mutex_lock(&this->lock);
+ this->swvolume = pa_sw_volume_from_linear((double)value/100.0);
+ if( this->stream && this->context ) {
+ pa_cvolume_set(&this->cvolume, pa_stream_get_sample_spec(this->stream)->channels, this->swvolume);
+ wait_for_operation(this,
+ pa_context_set_sink_input_volume(this->context, pa_stream_get_index(this->stream),
+ &this->cvolume, NULL, NULL));
+ }
+ pthread_mutex_unlock(&this->lock);
+ break;
+ case AO_PROP_MUTE_VOL:
+ break;
+ }
+
+ return 0;
+}
+
+static int ao_pulse_ctrl(ao_driver_t *this_gen, int cmd, ...) {
+ pulse_driver_t *this = (pulse_driver_t *) this_gen;
+
+ pthread_mutex_lock(&this->lock);
+ switch (cmd) {
+
+ case AO_CTRL_PLAY_PAUSE:
+ assert(this->stream && this->context );
+ if(pa_stream_get_state(this->stream) == PA_STREAM_READY)
+ wait_for_operation(this,pa_stream_cork(this->stream, 1, NULL, NULL));
+ break;
+
+ case AO_CTRL_PLAY_RESUME:
+ assert(this->stream && this->context);
+ if(pa_stream_get_state(this->stream) == PA_STREAM_READY) {
+ struct pa_operation *o2, *o1;
+ o1 = pa_stream_prebuf(this->stream, NULL, NULL);
+ o2 = pa_stream_cork(this->stream, 0, NULL, NULL);
+ assert(o1 && o2);
+ wait_for_operation(this,o1);
+ wait_for_operation(this,o2);
+ wait_for_completion(this);
+ }
+ break;
+
+ case AO_CTRL_FLUSH_BUFFERS:
+ assert(this->stream && this->context);
+ if(pa_stream_get_state(this->stream) == PA_STREAM_READY)
+ wait_for_operation(this,pa_stream_flush(this->stream, NULL, NULL));
+ this->frames_written = 0;
+ break;
+ }
+ pthread_mutex_unlock(&this->lock);
+
+ return 0;
+}
+
+static ao_driver_t *open_plugin (audio_driver_class_t *class_gen, const void *data) {
+ pulse_class_t *class = (pulse_class_t *) class_gen;
+ pulse_driver_t *this;
+ char hn[128];
+ char *device;
+
+ lprintf ("audio_pulse_out: open_plugin called\n");
+
+ this = (pulse_driver_t *) xine_xmalloc (sizeof (pulse_driver_t));
+ this->xine = class->xine;
+
+ /*
+ * set capabilities
+ */
+ this->capabilities = AO_CAP_MODE_MONO | AO_CAP_MODE_STEREO | AO_CAP_MIXER_VOL |
+ AO_CAP_PCM_VOL | AO_CAP_MUTE_VOL | AO_CAP_8BITS |
+ AO_CAP_16BITS | AO_CAP_FLOAT32;
+
+ this->sample_rate = 0;
+ this->swvolume = PA_VOLUME_NORM;
+
+ this->ao_driver.get_capabilities = ao_pulse_get_capabilities;
+ this->ao_driver.get_property = ao_pulse_get_property;
+ this->ao_driver.set_property = ao_pulse_set_property;
+ this->ao_driver.open = ao_pulse_open;
+ this->ao_driver.num_channels = ao_pulse_num_channels;
+ this->ao_driver.bytes_per_frame = ao_pulse_bytes_per_frame;
+ this->ao_driver.delay = ao_pulse_delay;
+ this->ao_driver.write = ao_pulse_write;
+ this->ao_driver.close = ao_pulse_close;
+ this->ao_driver.exit = ao_pulse_exit;
+ this->ao_driver.get_gap_tolerance = ao_pulse_get_gap_tolerance;
+ this->ao_driver.control = ao_pulse_ctrl;
+
+ device = this->xine->config->register_string(this->xine->config,
+ "audio.pulseaudio_device",
+ "",
+ _("device used for pulseaudio"),
+ _("use 'server[:sink]' for setting the "
+ "pulseaudio sink device."),
+ 10, NULL,
+ NULL);
+
+ if (device && strlen(device)) {
+ int i = strcspn(device, ":");
+ if (i >= sizeof(hn))
+ i = sizeof(hn)-1;
+
+ if (i > 0) {
+ strncpy(this->host = hn, device, i);
+ hn[i] = 0;
+ }
+
+ if (device[i] == ':')
+ this->sink = device+i+1;
+ }
+
+ xprintf (class->xine, XINE_VERBOSITY_DEBUG, "audio_pulse_out: host %s sink %s\n",
+ this->host ? this->host : "(null)", this->sink ? this->sink : "(null)");
+
+ pthread_mutex_init (&this->lock, NULL);
+
+ /* test pulseaudio connection */
+ if( this->ao_driver.open(&this->ao_driver, 16, 44100, AO_CAP_MODE_STEREO) != 0 ) {
+ this->ao_driver.close(&this->ao_driver);
+ } else {
+ free(this);
+ xprintf (class->xine, XINE_VERBOSITY_DEBUG, "audio_pulse_out: open_plugin failed.\n");
+ return NULL;
+ }
+
+ return &this->ao_driver;
+}
+
+/*
+ * class functions
+ */
+
+static char* get_identifier (audio_driver_class_t *this_gen) {
+ return "pulseaudio";
+}
+
+static char* get_description (audio_driver_class_t *this_gen) {
+ return _("xine audio output plugin using pulseaudio sound server");
+}
+
+static void dispose_class (audio_driver_class_t *this_gen) {
+
+ pulse_class_t *this = (pulse_class_t *) this_gen;
+
+ free (this);
+}
+
+static void *init_class (xine_t *xine, void *data) {
+
+ pulse_class_t *this;
+
+ lprintf ("audio_pulse_out: init class\n");
+
+ this = (pulse_class_t *) xine_xmalloc (sizeof (pulse_class_t));
+
+ this->driver_class.open_plugin = open_plugin;
+ this->driver_class.get_identifier = get_identifier;
+ this->driver_class.get_description = get_description;
+ this->driver_class.dispose = dispose_class;
+
+ this->xine = xine;
+
+ return this;
+}
+
+static const ao_info_t ao_info_pulse = {
+ 6
+};
+
+/*
+ * exported plugin catalog entry
+ */
+
+const plugin_info_t xine_plugin_info[] EXPORTED = {
+ /* type, API, "name", version, special_info, init_function */
+ { PLUGIN_AUDIO_OUT, 8, "pulseaudio", XINE_VERSION_CODE, &ao_info_pulse, init_class },
+ { PLUGIN_NONE, 0, "", 0, NULL, NULL }
+};
+
generated by cgit v1.2.3 (git 2.25.1) at 2025-04-22 23:33:37 +0000