[FFmpeg-devel] [PATCH 2/4] lavd/pulse_audio_common: add device detecting code
Lukasz Marek
lukasz.m.luki at gmail.com
Tue Feb 25 01:06:07 CET 2014
Signed-off-by: Lukasz Marek <lukasz.m.luki at gmail.com>
---
libavdevice/pulse_audio_common.c | 179 ++++++++++++++++++++++++++++++++++++++-
libavdevice/pulse_audio_common.h | 5 +-
2 files changed, 182 insertions(+), 2 deletions(-)
diff --git a/libavdevice/pulse_audio_common.c b/libavdevice/pulse_audio_common.c
index f7227f6..6b91ce1 100644
--- a/libavdevice/pulse_audio_common.c
+++ b/libavdevice/pulse_audio_common.c
@@ -1,5 +1,6 @@
/*
- * Pulseaudio input
+ * Pulseaudio common
+ * Copyright (c) 2014 Lukasz Marek
* Copyright (c) 2011 Luca Barbato <lu_zero at gentoo.org>
*
* This file is part of FFmpeg.
@@ -21,6 +22,8 @@
#include "pulse_audio_common.h"
#include "libavutil/attributes.h"
+#include "libavutil/avstring.h"
+#include "libavutil/array.h"
pa_sample_format_t av_cold ff_codec_id_to_pulse_format(enum AVCodecID codec_id)
{
@@ -39,3 +42,177 @@ pa_sample_format_t av_cold ff_codec_id_to_pulse_format(enum AVCodecID codec_id)
default: return PA_SAMPLE_INVALID;
}
}
+
+enum PulseAudioLoopState {
+ PA_LOOP_INITIALIZING,
+ PA_LOOP_READY,
+ PA_LOOP_FINISHED
+};
+
+typedef struct PulseAudioDeviceList {
+ AVArrayBuffer *buffer;
+ int error_code;
+ int output;
+ char *default_device;
+} PulseAudioDeviceList;
+
+static void pa_state_cb(pa_context *c, void *userdata)
+{
+ enum PulseAudioLoopState *loop_status = userdata;
+
+ switch (pa_context_get_state(c)) {
+ case PA_CONTEXT_FAILED:
+ case PA_CONTEXT_TERMINATED:
+ *loop_status = PA_LOOP_FINISHED;
+ break;
+ case PA_CONTEXT_READY:
+ *loop_status = PA_LOOP_READY;
+ break;
+ default:
+ break;
+ }
+}
+
+static void pulse_add_detected_device(PulseAudioDeviceList *info,
+ const char *name, const char *description)
+{
+ AVDeviceInfo *new_device = NULL;
+
+ if (info->error_code)
+ return;
+
+ new_device = av_mallocz(sizeof(AVDeviceInfo));
+ if (!new_device) {
+ info->error_code = AVERROR(ENOMEM);
+ return;
+ }
+
+ new_device->device_description = av_strdup(description);
+ new_device->device_name = av_strdup(name);
+
+ if (!new_device->device_description || !new_device->device_name) {
+ info->error_code = AVERROR(ENOMEM);
+ goto fail;
+ }
+
+ if ((info->error_code = av_array_append(info->buffer, new_device)) < 0)
+ goto fail;
+ return;
+
+ fail:
+ av_free(new_device->device_description);
+ av_free(new_device->device_name);
+ av_free(new_device);
+
+}
+
+static void pulse_audio_source_device_cb(pa_context *c, const pa_source_info *dev,
+ int eol, void *userdata)
+{
+ if (!eol)
+ pulse_add_detected_device(userdata, dev->name, dev->description);
+}
+
+static void pulse_audio_sink_device_cb(pa_context *c, const pa_sink_info *dev,
+ int eol, void *userdata)
+{
+ if (!eol)
+ pulse_add_detected_device(userdata, dev->name, dev->description);
+}
+
+static void pulse_server_info_cb(pa_context *c, const pa_server_info *i, void *userdata)
+{
+ PulseAudioDeviceList *info = userdata;
+ if (info->output)
+ info->default_device = av_strdup(i->default_sink_name);
+ else
+ info->default_device = av_strdup(i->default_source_name);
+ if (!info->default_device)
+ info->error_code = AVERROR(ENOMEM);
+}
+
+int ff_pulse_audio_get_devices(AVDeviceInfoList *devices, const char *server, int output)
+{
+ pa_mainloop *pa_ml = NULL;
+ pa_mainloop_api *pa_mlapi = NULL;
+ pa_operation *pa_op = NULL;
+ pa_context *pa_ctx = NULL;
+ enum pa_operation_state op_state;
+ enum PulseAudioLoopState loop_state = PA_LOOP_INITIALIZING;
+ PulseAudioDeviceList dev_list = { 0 };
+ int i;
+
+ dev_list.output = output;
+ if (!devices)
+ return AVERROR(EINVAL);
+ if (!(pa_ml = pa_mainloop_new()))
+ return AVERROR(ENOMEM);
+ if (!(pa_mlapi = pa_mainloop_get_api(pa_ml))) {
+ dev_list.error_code = AVERROR_EXTERNAL;
+ goto fail;
+ }
+ if (!(pa_ctx = pa_context_new(pa_mlapi, "Query devices"))) {
+ dev_list.error_code = AVERROR(ENOMEM);
+ goto fail;
+ }
+ pa_context_set_state_callback(pa_ctx, pa_state_cb, &loop_state);
+ if (pa_context_connect(pa_ctx, server, 0, NULL) < 0) {
+ dev_list.error_code = AVERROR_EXTERNAL;
+ goto fail;
+ }
+
+ while (loop_state == PA_LOOP_INITIALIZING)
+ pa_mainloop_iterate(pa_ml, 1, NULL);
+ if (loop_state == PA_LOOP_FINISHED) {
+ dev_list.error_code = AVERROR_EXTERNAL;
+ goto fail;
+ }
+
+ dev_list.buffer = av_array_alloc(2, NULL);
+ if (!dev_list.buffer) {
+ dev_list.error_code = AVERROR(ENOMEM);
+ goto fail;
+ }
+
+ if (output)
+ pa_op = pa_context_get_sink_info_list(pa_ctx, pulse_audio_sink_device_cb, &dev_list);
+ else
+ pa_op = pa_context_get_source_info_list(pa_ctx, pulse_audio_source_device_cb, &dev_list);
+ while ((op_state = pa_operation_get_state(pa_op)) == PA_OPERATION_RUNNING)
+ pa_mainloop_iterate(pa_ml, 1, NULL);
+ if (op_state != PA_OPERATION_DONE)
+ dev_list.error_code = AVERROR_EXTERNAL;
+ if (dev_list.error_code)
+ goto fail;
+
+ pa_op = pa_context_get_server_info(pa_ctx, pulse_server_info_cb, &dev_list);
+ while ((op_state = pa_operation_get_state(pa_op)) == PA_OPERATION_RUNNING)
+ pa_mainloop_iterate(pa_ml, 1, NULL);
+ if (op_state != PA_OPERATION_DONE)
+ dev_list.error_code = AVERROR_EXTERNAL;
+ if (dev_list.error_code)
+ goto fail;
+
+ devices->nb_devices = av_array_size(dev_list.buffer);
+ av_array_release(&dev_list.buffer, (void **)&devices->devices);
+
+ devices->default_device = -1;
+ for (i = 0; i < devices->nb_devices; i++) {
+ if (!strcmp(devices->devices[i]->device_name, dev_list.default_device)) {
+ devices->default_device = i;
+ break;
+ }
+ }
+
+ fail:
+ av_array_free(&dev_list.buffer);
+ if (pa_op)
+ pa_operation_unref(pa_op);
+ if(pa_ctx)
+ pa_context_disconnect(pa_ctx);
+ if (pa_ctx)
+ pa_context_unref(pa_ctx);
+ if (pa_ml)
+ pa_mainloop_free(pa_ml);
+ return dev_list.error_code;
+}
diff --git a/libavdevice/pulse_audio_common.h b/libavdevice/pulse_audio_common.h
index 99ba6a3..b049cde 100644
--- a/libavdevice/pulse_audio_common.h
+++ b/libavdevice/pulse_audio_common.h
@@ -22,9 +22,12 @@
#ifndef AVDEVICE_PULSE_AUDIO_COMMON_H
#define AVDEVICE_PULSE_AUDIO_COMMON_H
-#include <pulse/simple.h>
+#include <pulse/pulseaudio.h>
#include "libavcodec/avcodec.h"
+#include "avdevice.h"
pa_sample_format_t ff_codec_id_to_pulse_format(enum AVCodecID codec_id);
+int ff_pulse_audio_get_devices(AVDeviceInfoList *devices, const char *server, int output);
+
#endif /* AVDEVICE_PULSE_AUDIO_COMMON_H */
--
1.8.3.2
More information about the ffmpeg-devel
mailing list