mirror of
https://github.com/xenia-project/FFmpeg.git
synced 2024-11-28 14:01:27 +00:00
lavd/pulse_audio_common: add device detecting code
Signed-off-by: Lukasz Marek <lukasz.m.luki@gmail.com>
This commit is contained in:
Lukasz Marek
parent
cd50a44beb
commit
85ed32d2ed
@ -1,5 +1,6 @@
|
||||
/*
|
||||
* Pulseaudio input
|
||||
* Pulseaudio common
|
||||
* Copyright (c) 2014 Lukasz Marek
|
||||
* Copyright (c) 2011 Luca Barbato <lu_zero@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/mem.h"
|
||||
|
||||
pa_sample_format_t av_cold ff_codec_id_to_pulse_format(enum AVCodecID codec_id)
|
||||
{
|
||||
@ -39,3 +42,175 @@ 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 {
|
||||
AVDeviceInfoList *devices;
|
||||
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)
|
||||
{
|
||||
int ret;
|
||||
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 ((ret = av_dynarray_add_nofree(&info->devices->devices,
|
||||
&info->devices->nb_devices, new_device)) < 0) {
|
||||
info->error_code = ret;
|
||||
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;
|
||||
dev_list.devices = devices;
|
||||
devices->nb_devices = 0;
|
||||
devices->devices = NULL;
|
||||
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;
|
||||
}
|
||||
|
||||
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;
|
||||
pa_operation_unref(pa_op);
|
||||
if (dev_list.error_code < 0)
|
||||
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;
|
||||
pa_operation_unref(pa_op);
|
||||
if (dev_list.error_code < 0)
|
||||
goto fail;
|
||||
|
||||
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_free(dev_list.default_device);
|
||||
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;
|
||||
}
|
||||
|
||||
@ -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 */
|
||||
|
||||
Loading…
Reference in New Issue
Block a user