ext/pulse/pulseutil.c

   1 /*
   2  *  GStreamer pulseaudio plugin
   3  *
   4  *  Copyright (c) 2004-2008 Lennart Poettering
   5  *
   6  *  gst-pulse is free software; you can redistribute it and/or modify
   7  *  it under the terms of the GNU Lesser General Public License as
   8  *  published by the Free Software Foundation; either version 2.1 of the
   9  *  License, or (at your option) any later version.
  10  *
  11  *  gst-pulse is distributed in the hope that it will be useful, but
  12  *  WITHOUT ANY WARRANTY; without even the implied warranty of
  13  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  14  *  Lesser General Public License for more details.
  15  *
  16  *  You should have received a copy of the GNU Lesser General Public
  17  *  License along with gst-pulse; if not, write to the Free Software
  18  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
  19  *  USA.
  20  */
  21
  22 #ifdef HAVE_CONFIG_H
  23 #include "config.h"
  24 #endif
  25
  26 #include "pulseutil.h"
  27
  28 #ifdef HAVE_UNISTD_H
  29 # include <unistd.h>            /* getpid on UNIX */
  30 #endif
  31 #ifdef HAVE_PROCESS_H
  32 # include <process.h>           /* getpid on win32 */
  33 #endif
  34
  35 static const struct
  36 {
  37   GstAudioChannelPosition gst_pos;
  38   pa_channel_position_t pa_pos;
  39 } gst_pa_pos_table[] = {
  40   {
  41   GST_AUDIO_CHANNEL_POSITION_MONO, PA_CHANNEL_POSITION_MONO}, {
  42   GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT, PA_CHANNEL_POSITION_FRONT_LEFT}, {
  43   GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT, PA_CHANNEL_POSITION_FRONT_RIGHT}, {
  44   GST_AUDIO_CHANNEL_POSITION_REAR_CENTER, PA_CHANNEL_POSITION_REAR_CENTER}, {
  45   GST_AUDIO_CHANNEL_POSITION_REAR_LEFT, PA_CHANNEL_POSITION_REAR_LEFT}, {
  46   GST_AUDIO_CHANNEL_POSITION_REAR_RIGHT, PA_CHANNEL_POSITION_REAR_RIGHT}, {
  47   GST_AUDIO_CHANNEL_POSITION_LFE1, PA_CHANNEL_POSITION_LFE}, {
  48   GST_AUDIO_CHANNEL_POSITION_FRONT_CENTER, PA_CHANNEL_POSITION_FRONT_CENTER}, {
  49   GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT_OF_CENTER,
  50         PA_CHANNEL_POSITION_FRONT_LEFT_OF_CENTER}, {
  51   GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT_OF_CENTER,
  52         PA_CHANNEL_POSITION_FRONT_RIGHT_OF_CENTER}, {
  53   GST_AUDIO_CHANNEL_POSITION_SIDE_LEFT, PA_CHANNEL_POSITION_SIDE_LEFT}, {
  54   GST_AUDIO_CHANNEL_POSITION_SIDE_RIGHT, PA_CHANNEL_POSITION_SIDE_RIGHT}, {
  55   GST_AUDIO_CHANNEL_POSITION_TOP_CENTER, PA_CHANNEL_POSITION_TOP_CENTER}, {
  56   GST_AUDIO_CHANNEL_POSITION_TOP_FRONT_LEFT,
  57         PA_CHANNEL_POSITION_TOP_FRONT_LEFT}, {
  58   GST_AUDIO_CHANNEL_POSITION_TOP_FRONT_RIGHT,
  59         PA_CHANNEL_POSITION_TOP_FRONT_RIGHT}, {
  60   GST_AUDIO_CHANNEL_POSITION_TOP_FRONT_CENTER,
  61         PA_CHANNEL_POSITION_TOP_FRONT_CENTER}, {
  62   GST_AUDIO_CHANNEL_POSITION_TOP_REAR_LEFT, PA_CHANNEL_POSITION_TOP_REAR_LEFT}, {
  63   GST_AUDIO_CHANNEL_POSITION_TOP_REAR_RIGHT,
  64         PA_CHANNEL_POSITION_TOP_REAR_RIGHT}, {
  65   GST_AUDIO_CHANNEL_POSITION_TOP_REAR_CENTER,
  66         PA_CHANNEL_POSITION_TOP_REAR_CENTER}, {
  67   GST_AUDIO_CHANNEL_POSITION_NONE, PA_CHANNEL_POSITION_INVALID}
  68 };
  69
  70 static gboolean
  71 gstaudioformat_to_pasampleformat (GstAudioFormat format,
  72     pa_sample_format_t * sf)
  73 {
  74   switch (format) {
  75     case GST_AUDIO_FORMAT_U8:
  76       *sf = PA_SAMPLE_U8;
  77       break;
  78     case GST_AUDIO_FORMAT_S16LE:
  79       *sf = PA_SAMPLE_S16LE;
  80       break;
  81     case GST_AUDIO_FORMAT_S16BE:
  82       *sf = PA_SAMPLE_S16BE;
  83       break;
  84     case GST_AUDIO_FORMAT_F32LE:
  85       *sf = PA_SAMPLE_FLOAT32LE;
  86       break;
  87     case GST_AUDIO_FORMAT_F32BE:
  88       *sf = PA_SAMPLE_FLOAT32BE;
  89       break;
  90     case GST_AUDIO_FORMAT_S32LE:
  91       *sf = PA_SAMPLE_S32LE;
  92       break;
  93     case GST_AUDIO_FORMAT_S32BE:
  94       *sf = PA_SAMPLE_S32BE;
  95       break;
  96     case GST_AUDIO_FORMAT_S24LE:
  97       *sf = PA_SAMPLE_S24LE;
  98       break;
  99     case GST_AUDIO_FORMAT_S24BE:
 100       *sf = PA_SAMPLE_S24BE;
 101       break;
 102     case GST_AUDIO_FORMAT_S24_32LE:
 103       *sf = PA_SAMPLE_S24_32LE;
 104       break;
 105     case GST_AUDIO_FORMAT_S24_32BE:
 106       *sf = PA_SAMPLE_S24_32BE;
 107       break;
 108     default:
 109       return FALSE;
 110   }
 111   return TRUE;
 112 }
 113
 114 gboolean
 115 gst_pulse_fill_sample_spec (GstAudioRingBufferSpec * spec, pa_sample_spec * ss)
 116 {
 117   if (spec->type == GST_AUDIO_RING_BUFFER_FORMAT_TYPE_RAW) {
 118     if (!gstaudioformat_to_pasampleformat (GST_AUDIO_INFO_FORMAT (&spec->info),
 119             &ss->format))
 120       return FALSE;
 121   } else if (spec->type == GST_AUDIO_RING_BUFFER_FORMAT_TYPE_MU_LAW) {
 122     ss->format = PA_SAMPLE_ULAW;
 123   } else if (spec->type == GST_AUDIO_RING_BUFFER_FORMAT_TYPE_A_LAW) {
 124     ss->format = PA_SAMPLE_ALAW;
 125   } else
 126     return FALSE;
 127
 128   ss->channels = GST_AUDIO_INFO_CHANNELS (&spec->info);
 129   ss->rate = GST_AUDIO_INFO_RATE (&spec->info);
 130
 131   if (!pa_sample_spec_valid (ss))
 132     return FALSE;
 133
 134   return TRUE;
 135 }
 136
 137 gboolean
 138 gst_pulse_fill_format_info (GstAudioRingBufferSpec * spec, pa_format_info ** f,
 139     guint * channels)
 140 {
 141   pa_format_info *format;
 142   pa_sample_format_t sf = PA_SAMPLE_INVALID;
 143   GstAudioInfo *ainfo = &spec->info;
 144
 145   format = pa_format_info_new ();
 146
 147   if (spec->type == GST_AUDIO_RING_BUFFER_FORMAT_TYPE_MU_LAW
 148       && GST_AUDIO_INFO_WIDTH (ainfo) == 8) {
 149     format->encoding = PA_ENCODING_PCM;
 150     sf = PA_SAMPLE_ULAW;
 151   } else if (spec->type == GST_AUDIO_RING_BUFFER_FORMAT_TYPE_A_LAW
 152       && GST_AUDIO_INFO_WIDTH (ainfo) == 8) {
 153     format->encoding = PA_ENCODING_PCM;
 154     sf = PA_SAMPLE_ALAW;
 155   } else if (spec->type == GST_AUDIO_RING_BUFFER_FORMAT_TYPE_RAW) {
 156     format->encoding = PA_ENCODING_PCM;
 157     if (!gstaudioformat_to_pasampleformat (GST_AUDIO_INFO_FORMAT (ainfo), &sf))
 158       goto fail;
 159   } else if (spec->type == GST_AUDIO_RING_BUFFER_FORMAT_TYPE_AC3) {
 160     format->encoding = PA_ENCODING_AC3_IEC61937;
 161   } else if (spec->type == GST_AUDIO_RING_BUFFER_FORMAT_TYPE_EAC3) {
 162     format->encoding = PA_ENCODING_EAC3_IEC61937;
 163   } else if (spec->type == GST_AUDIO_RING_BUFFER_FORMAT_TYPE_DTS) {
 164     format->encoding = PA_ENCODING_DTS_IEC61937;
 165   } else if (spec->type == GST_AUDIO_RING_BUFFER_FORMAT_TYPE_MPEG) {
 166     format->encoding = PA_ENCODING_MPEG_IEC61937;
 167   } else {
 168     goto fail;
 169   }
 170
 171   if (format->encoding == PA_ENCODING_PCM) {
 172     pa_format_info_set_sample_format (format, sf);
 173     pa_format_info_set_channels (format, GST_AUDIO_INFO_CHANNELS (ainfo));
 174   }
 175
 176   pa_format_info_set_rate (format, GST_AUDIO_INFO_RATE (ainfo));
 177
 178   if (!pa_format_info_valid (format))
 179     goto fail;
 180
 181   *f = format;
 182   *channels = GST_AUDIO_INFO_CHANNELS (ainfo);
 183
 184   return TRUE;
 185
 186 fail:
 187   if (format)
 188     pa_format_info_free (format);
 189   return FALSE;
 190 }
 191
 192 /* PATH_MAX is not defined everywhere, e.g. on GNU Hurd */
 193 #ifndef PATH_MAX
 194 #define PATH_MAX 4096
 195 #endif
 196
 197 gchar *
 198 gst_pulse_client_name (void)
 199 {
 200   gchar buf[PATH_MAX];
 201
 202   const char *c;
 203
 204   if ((c = g_get_application_name ()))
 205     return g_strdup (c);
 206   else if (pa_get_binary_name (buf, sizeof (buf)))
 207     return g_strdup (buf);
 208   else
 209     return g_strdup_printf ("GStreamer-pid-%lu", (gulong) getpid ());
 210 }
 211
 212 pa_channel_map *
 213 gst_pulse_gst_to_channel_map (pa_channel_map * map,
 214     const GstAudioRingBufferSpec * spec)
 215 {
 216   gint i, j;
 217   gint channels;
 218   const GstAudioChannelPosition *pos;
 219
 220   pa_channel_map_init (map);
 221
 222   channels = GST_AUDIO_INFO_CHANNELS (&spec->info);
 223   pos = spec->info.position;
 224
 225   for (j = 0; j < channels; j++) {
 226     for (i = 0; i < G_N_ELEMENTS (gst_pa_pos_table); i++) {
 227       if (pos[j] == gst_pa_pos_table[i].gst_pos) {
 228         map->map[j] = gst_pa_pos_table[i].pa_pos;
 229         break;
 230       }
 231     }
 232     if (i == G_N_ELEMENTS (gst_pa_pos_table))
 233       return NULL;
 234   }
 235
 236   if (j != spec->info.channels) {
 237     return NULL;
 238   }
 239
 240   map->channels = spec->info.channels;
 241
 242   if (!pa_channel_map_valid (map)) {
 243     return NULL;
 244   }
 245
 246   return map;
 247 }
 248
 249 GstAudioRingBufferSpec *
 250 gst_pulse_channel_map_to_gst (const pa_channel_map * map,
 251     GstAudioRingBufferSpec * spec)
 252 {
 253   gint i, j;
 254   gboolean invalid = FALSE;
 255   gint channels;
 256   GstAudioChannelPosition *pos;
 257
 258   channels = GST_AUDIO_INFO_CHANNELS (&spec->info);
 259
 260   g_return_val_if_fail (map->channels == channels, NULL);
 261
 262   pos = spec->info.position;
 263
 264   for (j = 0; j < channels; j++) {
 265     for (i = 0; j < channels && i < G_N_ELEMENTS (gst_pa_pos_table); i++) {
 266       if (map->map[j] == gst_pa_pos_table[i].pa_pos) {
 267         pos[j] = gst_pa_pos_table[i].gst_pos;
 268         break;
 269       }
 270     }
 271     if (i == G_N_ELEMENTS (gst_pa_pos_table))
 272       return NULL;
 273   }
 274
 275   if (!invalid
 276       && !gst_audio_check_valid_channel_positions (pos, channels, FALSE))
 277     invalid = TRUE;
 278
 279   if (invalid) {
 280     for (i = 0; i < channels; i++)
 281       pos[i] = GST_AUDIO_CHANNEL_POSITION_NONE;
 282   }
 283
 284   return spec;
 285 }
 286
 287 void
 288 gst_pulse_cvolume_from_linear (pa_cvolume * v, unsigned channels,
 289     gdouble volume)
 290 {
 291   pa_cvolume_set (v, channels, pa_sw_volume_from_linear (volume));
 292 }
 293
 294 static gboolean
 295 make_proplist_item (GQuark field_id, const GValue * value, gpointer user_data)
 296 {
 297   pa_proplist *p = (pa_proplist *) user_data;
 298   gchar *prop_id = (gchar *) g_quark_to_string (field_id);
 299
 300   /* http://0pointer.de/lennart/projects/pulseaudio/doxygen/proplist_8h.html */
 301
 302   /* match prop id */
 303
 304   /* check type */
 305   switch (G_VALUE_TYPE (value)) {
 306     case G_TYPE_STRING:
 307       pa_proplist_sets (p, prop_id, g_value_get_string (value));
 308       break;
 309     default:
 310       GST_WARNING ("unmapped property type %s", G_VALUE_TYPE_NAME (value));
 311       break;
 312   }
 313
 314   return TRUE;
 315 }
 316
 317 pa_proplist *
 318 gst_pulse_make_proplist (const GstStructure * properties)
 319 {
 320   pa_proplist *proplist = pa_proplist_new ();
 321
 322   /* iterate the structure and fill the proplist */
 323   gst_structure_foreach (properties, make_proplist_item, proplist);
 324   return proplist;
 325 }