mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-09-19 18:40:31 +00:00
ac7cad431c
This adds support for various compressed formats (AC3, E-AC3, DTS and MP3) payloaded in IEC 61937 format (used for transmission over S/PDIF, HDMI and Bluetooth). The acceptcaps() function allows bins to probe for what formats the sink being connected to support. This only works after the element is set to at least READY. If the underlying sink changes and the format we are streaming is not available, we emit a message that will allow upstream elements/bins to block and renegotiate a new format.
337 lines
11 KiB
C
337 lines
11 KiB
C
/*
|
|
* GStreamer pulseaudio plugin
|
|
*
|
|
* Copyright (c) 2004-2008 Lennart Poettering
|
|
*
|
|
* gst-pulse 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.
|
|
*
|
|
* gst-pulse 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 gst-pulse; if not, write to the Free Software
|
|
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
|
|
* USA.
|
|
*/
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
#include "config.h"
|
|
#endif
|
|
|
|
#include "pulseutil.h"
|
|
#include <gst/audio/multichannel.h>
|
|
|
|
#ifdef HAVE_UNISTD_H
|
|
# include <unistd.h> /* getpid on UNIX */
|
|
#endif
|
|
#ifdef HAVE_PROCESS_H
|
|
# include <process.h> /* getpid on win32 */
|
|
#endif
|
|
|
|
static const pa_channel_position_t gst_pos_to_pa[GST_AUDIO_CHANNEL_POSITION_NUM]
|
|
= {
|
|
[GST_AUDIO_CHANNEL_POSITION_FRONT_MONO] = PA_CHANNEL_POSITION_MONO,
|
|
[GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT] = PA_CHANNEL_POSITION_FRONT_LEFT,
|
|
[GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT] = PA_CHANNEL_POSITION_FRONT_RIGHT,
|
|
[GST_AUDIO_CHANNEL_POSITION_REAR_CENTER] = PA_CHANNEL_POSITION_REAR_CENTER,
|
|
[GST_AUDIO_CHANNEL_POSITION_REAR_LEFT] = PA_CHANNEL_POSITION_REAR_LEFT,
|
|
[GST_AUDIO_CHANNEL_POSITION_REAR_RIGHT] = PA_CHANNEL_POSITION_REAR_RIGHT,
|
|
[GST_AUDIO_CHANNEL_POSITION_LFE] = PA_CHANNEL_POSITION_LFE,
|
|
[GST_AUDIO_CHANNEL_POSITION_FRONT_CENTER] = PA_CHANNEL_POSITION_FRONT_CENTER,
|
|
[GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT_OF_CENTER] =
|
|
PA_CHANNEL_POSITION_FRONT_LEFT_OF_CENTER,
|
|
[GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT_OF_CENTER] =
|
|
PA_CHANNEL_POSITION_FRONT_RIGHT_OF_CENTER,
|
|
[GST_AUDIO_CHANNEL_POSITION_SIDE_LEFT] = PA_CHANNEL_POSITION_SIDE_LEFT,
|
|
[GST_AUDIO_CHANNEL_POSITION_SIDE_RIGHT] = PA_CHANNEL_POSITION_SIDE_RIGHT,
|
|
[GST_AUDIO_CHANNEL_POSITION_NONE] = PA_CHANNEL_POSITION_INVALID
|
|
};
|
|
|
|
/* All index are increased by one because PA_CHANNEL_POSITION_INVALID == -1 */
|
|
static const GstAudioChannelPosition
|
|
pa_to_gst_pos[GST_AUDIO_CHANNEL_POSITION_NUM]
|
|
= {
|
|
[PA_CHANNEL_POSITION_MONO + 1] = GST_AUDIO_CHANNEL_POSITION_FRONT_MONO,
|
|
[PA_CHANNEL_POSITION_FRONT_LEFT + 1] = GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT,
|
|
[PA_CHANNEL_POSITION_FRONT_RIGHT + 1] =
|
|
GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT,
|
|
[PA_CHANNEL_POSITION_REAR_CENTER + 1] =
|
|
GST_AUDIO_CHANNEL_POSITION_REAR_CENTER,
|
|
[PA_CHANNEL_POSITION_REAR_LEFT + 1] = GST_AUDIO_CHANNEL_POSITION_REAR_LEFT,
|
|
[PA_CHANNEL_POSITION_REAR_RIGHT + 1] = GST_AUDIO_CHANNEL_POSITION_REAR_RIGHT,
|
|
[PA_CHANNEL_POSITION_LFE + 1] = GST_AUDIO_CHANNEL_POSITION_LFE,
|
|
[PA_CHANNEL_POSITION_FRONT_CENTER + 1] =
|
|
GST_AUDIO_CHANNEL_POSITION_FRONT_CENTER,
|
|
[PA_CHANNEL_POSITION_FRONT_LEFT_OF_CENTER + 1] =
|
|
GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT_OF_CENTER,
|
|
[PA_CHANNEL_POSITION_FRONT_RIGHT_OF_CENTER + 1] =
|
|
GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT_OF_CENTER,
|
|
[PA_CHANNEL_POSITION_SIDE_LEFT + 1] = GST_AUDIO_CHANNEL_POSITION_SIDE_LEFT,
|
|
[PA_CHANNEL_POSITION_SIDE_RIGHT + 1] = GST_AUDIO_CHANNEL_POSITION_SIDE_RIGHT,
|
|
[PA_CHANNEL_POSITION_INVALID + 1] = GST_AUDIO_CHANNEL_POSITION_NONE,
|
|
};
|
|
|
|
gboolean
|
|
gst_pulse_fill_sample_spec (GstRingBufferSpec * spec, pa_sample_spec * ss)
|
|
{
|
|
|
|
if (spec->format == GST_MU_LAW && spec->width == 8)
|
|
ss->format = PA_SAMPLE_ULAW;
|
|
else if (spec->format == GST_A_LAW && spec->width == 8)
|
|
ss->format = PA_SAMPLE_ALAW;
|
|
else if (spec->format == GST_U8 && spec->width == 8)
|
|
ss->format = PA_SAMPLE_U8;
|
|
else if (spec->format == GST_S16_LE && spec->width == 16)
|
|
ss->format = PA_SAMPLE_S16LE;
|
|
else if (spec->format == GST_S16_BE && spec->width == 16)
|
|
ss->format = PA_SAMPLE_S16BE;
|
|
else if (spec->format == GST_FLOAT32_LE && spec->width == 32)
|
|
ss->format = PA_SAMPLE_FLOAT32LE;
|
|
else if (spec->format == GST_FLOAT32_BE && spec->width == 32)
|
|
ss->format = PA_SAMPLE_FLOAT32BE;
|
|
else if (spec->format == GST_S32_LE && spec->width == 32)
|
|
ss->format = PA_SAMPLE_S32LE;
|
|
else if (spec->format == GST_S32_BE && spec->width == 32)
|
|
ss->format = PA_SAMPLE_S32BE;
|
|
else if (spec->format == GST_S24_3LE && spec->width == 24)
|
|
ss->format = PA_SAMPLE_S24LE;
|
|
else if (spec->format == GST_S24_3BE && spec->width == 24)
|
|
ss->format = PA_SAMPLE_S24BE;
|
|
else if (spec->format == GST_S24_LE && spec->width == 32)
|
|
ss->format = PA_SAMPLE_S24_32LE;
|
|
else if (spec->format == GST_S24_BE && spec->width == 32)
|
|
ss->format = PA_SAMPLE_S24_32BE;
|
|
else
|
|
return FALSE;
|
|
|
|
ss->channels = spec->channels;
|
|
ss->rate = spec->rate;
|
|
|
|
if (!pa_sample_spec_valid (ss))
|
|
return FALSE;
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
#ifdef HAVE_PULSE_1_0
|
|
gboolean
|
|
gst_pulse_fill_format_info (GstRingBufferSpec * spec, pa_format_info ** f,
|
|
guint * channels)
|
|
{
|
|
pa_format_info *format;
|
|
pa_sample_format_t sf = PA_SAMPLE_INVALID;
|
|
|
|
format = pa_format_info_new ();
|
|
|
|
if (spec->format == GST_MU_LAW && spec->width == 8) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_ULAW;
|
|
} else if (spec->format == GST_A_LAW && spec->width == 8) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_ALAW;
|
|
} else if (spec->format == GST_U8 && spec->width == 8) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_U8;
|
|
} else if (spec->format == GST_S16_LE && spec->width == 16) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_S16LE;
|
|
} else if (spec->format == GST_S16_BE && spec->width == 16) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_S16BE;
|
|
} else if (spec->format == GST_FLOAT32_LE && spec->width == 32) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_FLOAT32LE;
|
|
} else if (spec->format == GST_FLOAT32_BE && spec->width == 32) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_FLOAT32BE;
|
|
} else if (spec->format == GST_S32_LE && spec->width == 32) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_S32LE;
|
|
} else if (spec->format == GST_S32_BE && spec->width == 32) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_S32BE;
|
|
} else if (spec->format == GST_S24_3LE && spec->width == 24) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_S24LE;
|
|
} else if (spec->format == GST_S24_3BE && spec->width == 24) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_S24BE;
|
|
} else if (spec->format == GST_S24_LE && spec->width == 32) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_S24_32LE;
|
|
} else if (spec->format == GST_S24_BE && spec->width == 32) {
|
|
format->encoding = PA_ENCODING_PCM;
|
|
sf = PA_SAMPLE_S24_32BE;
|
|
} else if (spec->format == GST_AC3) {
|
|
format->encoding = PA_ENCODING_AC3_IEC61937;
|
|
} else if (spec->format == GST_EAC3) {
|
|
format->encoding = PA_ENCODING_EAC3_IEC61937;
|
|
} else if (spec->format == GST_DTS) {
|
|
format->encoding = PA_ENCODING_DTS_IEC61937;
|
|
} else if (spec->format == GST_MPEG) {
|
|
format->encoding = PA_ENCODING_MPEG_IEC61937;
|
|
} else {
|
|
goto fail;
|
|
}
|
|
|
|
if (format->encoding == PA_ENCODING_PCM) {
|
|
pa_format_info_set_sample_format (format, sf);
|
|
pa_format_info_set_channels (format, spec->channels);
|
|
}
|
|
|
|
pa_format_info_set_rate (format, spec->rate);
|
|
|
|
if (!pa_format_info_valid (format))
|
|
goto fail;
|
|
|
|
*f = format;
|
|
*channels = spec->channels;
|
|
|
|
return TRUE;
|
|
|
|
fail:
|
|
if (format)
|
|
pa_format_info_free (format);
|
|
return FALSE;
|
|
}
|
|
#endif
|
|
|
|
/* PATH_MAX is not defined everywhere, e.g. on GNU Hurd */
|
|
#ifndef PATH_MAX
|
|
#define PATH_MAX 4096
|
|
#endif
|
|
|
|
gchar *
|
|
gst_pulse_client_name (void)
|
|
{
|
|
gchar buf[PATH_MAX];
|
|
|
|
const char *c;
|
|
|
|
if ((c = g_get_application_name ()))
|
|
return g_strdup (c);
|
|
else if (pa_get_binary_name (buf, sizeof (buf)))
|
|
return g_strdup (buf);
|
|
else
|
|
return g_strdup_printf ("GStreamer-pid-%lu", (gulong) getpid ());
|
|
}
|
|
|
|
pa_channel_map *
|
|
gst_pulse_gst_to_channel_map (pa_channel_map * map,
|
|
const GstRingBufferSpec * spec)
|
|
{
|
|
int i;
|
|
GstAudioChannelPosition *pos;
|
|
|
|
pa_channel_map_init (map);
|
|
|
|
if (!(pos =
|
|
gst_audio_get_channel_positions (gst_caps_get_structure (spec->caps,
|
|
0)))) {
|
|
return NULL;
|
|
}
|
|
|
|
for (i = 0; i < spec->channels; i++) {
|
|
if (pos[i] == GST_AUDIO_CHANNEL_POSITION_NONE) {
|
|
/* no valid mappings for these channels */
|
|
g_free (pos);
|
|
return NULL;
|
|
} else if (pos[i] < GST_AUDIO_CHANNEL_POSITION_NUM)
|
|
map->map[i] = gst_pos_to_pa[pos[i]];
|
|
else
|
|
map->map[i] = PA_CHANNEL_POSITION_INVALID;
|
|
}
|
|
|
|
g_free (pos);
|
|
map->channels = spec->channels;
|
|
|
|
if (!pa_channel_map_valid (map)) {
|
|
return NULL;
|
|
}
|
|
|
|
return map;
|
|
}
|
|
|
|
GstRingBufferSpec *
|
|
gst_pulse_channel_map_to_gst (const pa_channel_map * map,
|
|
GstRingBufferSpec * spec)
|
|
{
|
|
int i;
|
|
GstAudioChannelPosition *pos;
|
|
gboolean invalid = FALSE;
|
|
|
|
g_return_val_if_fail (map->channels == spec->channels, NULL);
|
|
|
|
pos = g_new0 (GstAudioChannelPosition, spec->channels + 1);
|
|
|
|
for (i = 0; i < spec->channels; i++) {
|
|
if (map->map[i] == PA_CHANNEL_POSITION_INVALID) {
|
|
invalid = TRUE;
|
|
break;
|
|
} else if ((int) map->map[i] < (int) GST_AUDIO_CHANNEL_POSITION_NUM) {
|
|
pos[i] = pa_to_gst_pos[map->map[i] + 1];
|
|
} else {
|
|
invalid = TRUE;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (!invalid && !gst_audio_check_channel_positions (pos, spec->channels))
|
|
invalid = TRUE;
|
|
|
|
if (invalid) {
|
|
for (i = 0; i < spec->channels; i++)
|
|
pos[i] = GST_AUDIO_CHANNEL_POSITION_NONE;
|
|
}
|
|
|
|
gst_audio_set_channel_positions (gst_caps_get_structure (spec->caps, 0), pos);
|
|
|
|
g_free (pos);
|
|
|
|
return spec;
|
|
}
|
|
|
|
void
|
|
gst_pulse_cvolume_from_linear (pa_cvolume * v, unsigned channels,
|
|
gdouble volume)
|
|
{
|
|
pa_cvolume_set (v, channels, pa_sw_volume_from_linear (volume));
|
|
}
|
|
|
|
static gboolean
|
|
make_proplist_item (GQuark field_id, const GValue * value, gpointer user_data)
|
|
{
|
|
pa_proplist *p = (pa_proplist *) user_data;
|
|
gchar *prop_id = (gchar *) g_quark_to_string (field_id);
|
|
|
|
/* http://0pointer.de/lennart/projects/pulseaudio/doxygen/proplist_8h.html */
|
|
|
|
/* match prop id */
|
|
|
|
/* check type */
|
|
switch (G_VALUE_TYPE (value)) {
|
|
case G_TYPE_STRING:
|
|
pa_proplist_sets (p, prop_id, g_value_get_string (value));
|
|
break;
|
|
default:
|
|
GST_WARNING ("unmapped property type %s", G_VALUE_TYPE_NAME (value));
|
|
break;
|
|
}
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
pa_proplist *
|
|
gst_pulse_make_proplist (const GstStructure * properties)
|
|
{
|
|
pa_proplist *proplist = pa_proplist_new ();
|
|
|
|
/* iterate the structure and fill the proplist */
|
|
gst_structure_foreach (properties, make_proplist_item, proplist);
|
|
return proplist;
|
|
}
|