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 #include <gst/audio/multichannel.h>
  28
  29 #ifdef HAVE_UNISTD_H
  30 # include <unistd.h>            /* getpid on UNIX */
  31 #endif
  32 #ifdef HAVE_PROCESS_H
  33 # include <process.h>           /* getpid on win32 */
  34 #endif
  35
  36 static const pa_channel_position_t gst_pos_to_pa[GST_AUDIO_CHANNEL_POSITION_NUM]
  37     = {
  38   [GST_AUDIO_CHANNEL_POSITION_FRONT_MONO] = PA_CHANNEL_POSITION_MONO,
  39   [GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT] = PA_CHANNEL_POSITION_FRONT_LEFT,
  40   [GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT] = PA_CHANNEL_POSITION_FRONT_RIGHT,
  41   [GST_AUDIO_CHANNEL_POSITION_REAR_CENTER] = PA_CHANNEL_POSITION_REAR_CENTER,
  42   [GST_AUDIO_CHANNEL_POSITION_REAR_LEFT] = PA_CHANNEL_POSITION_REAR_LEFT,
  43   [GST_AUDIO_CHANNEL_POSITION_REAR_RIGHT] = PA_CHANNEL_POSITION_REAR_RIGHT,
  44   [GST_AUDIO_CHANNEL_POSITION_LFE] = PA_CHANNEL_POSITION_LFE,
  45   [GST_AUDIO_CHANNEL_POSITION_FRONT_CENTER] = PA_CHANNEL_POSITION_FRONT_CENTER,
  46   [GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT_OF_CENTER] =
  47       PA_CHANNEL_POSITION_FRONT_LEFT_OF_CENTER,
  48   [GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT_OF_CENTER] =
  49       PA_CHANNEL_POSITION_FRONT_RIGHT_OF_CENTER,
  50   [GST_AUDIO_CHANNEL_POSITION_SIDE_LEFT] = PA_CHANNEL_POSITION_SIDE_LEFT,
  51   [GST_AUDIO_CHANNEL_POSITION_SIDE_RIGHT] = PA_CHANNEL_POSITION_SIDE_RIGHT,
  52   [GST_AUDIO_CHANNEL_POSITION_NONE] = PA_CHANNEL_POSITION_INVALID
  53 };
  54
  55 /* All index are increased by one because PA_CHANNEL_POSITION_INVALID == -1 */
  56 static const GstAudioChannelPosition
  57     pa_to_gst_pos[GST_AUDIO_CHANNEL_POSITION_NUM]
  58     = {
  59   [PA_CHANNEL_POSITION_MONO + 1] = GST_AUDIO_CHANNEL_POSITION_FRONT_MONO,
  60   [PA_CHANNEL_POSITION_FRONT_LEFT + 1] = GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT,
  61   [PA_CHANNEL_POSITION_FRONT_RIGHT + 1] =
  62       GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT,
  63   [PA_CHANNEL_POSITION_REAR_CENTER + 1] =
  64       GST_AUDIO_CHANNEL_POSITION_REAR_CENTER,
  65   [PA_CHANNEL_POSITION_REAR_LEFT + 1] = GST_AUDIO_CHANNEL_POSITION_REAR_LEFT,
  66   [PA_CHANNEL_POSITION_REAR_RIGHT + 1] = GST_AUDIO_CHANNEL_POSITION_REAR_RIGHT,
  67   [PA_CHANNEL_POSITION_LFE + 1] = GST_AUDIO_CHANNEL_POSITION_LFE,
  68   [PA_CHANNEL_POSITION_FRONT_CENTER + 1] =
  69       GST_AUDIO_CHANNEL_POSITION_FRONT_CENTER,
  70   [PA_CHANNEL_POSITION_FRONT_LEFT_OF_CENTER + 1] =
  71       GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT_OF_CENTER,
  72   [PA_CHANNEL_POSITION_FRONT_RIGHT_OF_CENTER + 1] =
  73       GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT_OF_CENTER,
  74   [PA_CHANNEL_POSITION_SIDE_LEFT + 1] = GST_AUDIO_CHANNEL_POSITION_SIDE_LEFT,
  75   [PA_CHANNEL_POSITION_SIDE_RIGHT + 1] = GST_AUDIO_CHANNEL_POSITION_SIDE_RIGHT,
  76   [PA_CHANNEL_POSITION_INVALID + 1] = GST_AUDIO_CHANNEL_POSITION_NONE,
  77 };
  78
  79 gboolean
  80 gst_pulse_fill_sample_spec (GstRingBufferSpec * spec, pa_sample_spec * ss)
  81 {
  82
  83   if (spec->format == GST_MU_LAW && spec->width == 8)
  84     ss->format = PA_SAMPLE_ULAW;
  85   else if (spec->format == GST_A_LAW && spec->width == 8)
  86     ss->format = PA_SAMPLE_ALAW;
  87   else if (spec->format == GST_U8 && spec->width == 8)
  88     ss->format = PA_SAMPLE_U8;
  89   else if (spec->format == GST_S16_LE && spec->width == 16)
  90     ss->format = PA_SAMPLE_S16LE;
  91   else if (spec->format == GST_S16_BE && spec->width == 16)
  92     ss->format = PA_SAMPLE_S16BE;
  93   else if (spec->format == GST_FLOAT32_LE && spec->width == 32)
  94     ss->format = PA_SAMPLE_FLOAT32LE;
  95   else if (spec->format == GST_FLOAT32_BE && spec->width == 32)
  96     ss->format = PA_SAMPLE_FLOAT32BE;
  97   else if (spec->format == GST_S32_LE && spec->width == 32)
  98     ss->format = PA_SAMPLE_S32LE;
  99   else if (spec->format == GST_S32_BE && spec->width == 32)
 100     ss->format = PA_SAMPLE_S32BE;
 101 #ifdef HAVE_PULSE_0_9_15
 102   else if (spec->format == GST_S24_3LE && spec->width == 24)
 103     ss->format = PA_SAMPLE_S24LE;
 104   else if (spec->format == GST_S24_3BE && spec->width == 24)
 105     ss->format = PA_SAMPLE_S24BE;
 106   else if (spec->format == GST_S24_LE && spec->width == 32)
 107     ss->format = PA_SAMPLE_S24_32LE;
 108   else if (spec->format == GST_S24_BE && spec->width == 32)
 109     ss->format = PA_SAMPLE_S24_32BE;
 110 #endif
 111   else
 112     return FALSE;
 113
 114   ss->channels = spec->channels;
 115   ss->rate = spec->rate;
 116
 117   if (!pa_sample_spec_valid (ss))
 118     return FALSE;
 119
 120   return TRUE;
 121 }
 122
 123 gchar *
 124 gst_pulse_client_name (void)
 125 {
 126   gchar buf[PATH_MAX];
 127
 128   const char *c;
 129
 130   if ((c = g_get_application_name ()))
 131     return g_strdup (c);
 132   else if (pa_get_binary_name (buf, sizeof (buf)))
 133     return g_strdup (buf);
 134   else
 135     return g_strdup_printf ("GStreamer-pid-%lu", (gulong) getpid ());
 136 }
 137
 138 pa_channel_map *
 139 gst_pulse_gst_to_channel_map (pa_channel_map * map,
 140     const GstRingBufferSpec * spec)
 141 {
 142   int i;
 143   GstAudioChannelPosition *pos;
 144
 145   pa_channel_map_init (map);
 146
 147   if (!(pos =
 148           gst_audio_get_channel_positions (gst_caps_get_structure (spec->caps,
 149                   0)))) {
 150     return NULL;
 151   }
 152
 153   for (i = 0; i < spec->channels; i++) {
 154     if (pos[i] == GST_AUDIO_CHANNEL_POSITION_NONE) {
 155       /* no valid mappings for these channels */
 156       g_free (pos);
 157       return NULL;
 158     } else if (pos[i] < GST_AUDIO_CHANNEL_POSITION_NUM)
 159       map->map[i] = gst_pos_to_pa[pos[i]];
 160     else
 161       map->map[i] = PA_CHANNEL_POSITION_INVALID;
 162   }
 163
 164   g_free (pos);
 165   map->channels = spec->channels;
 166
 167   if (!pa_channel_map_valid (map)) {
 168     return NULL;
 169   }
 170
 171   return map;
 172 }
 173
 174 GstRingBufferSpec *
 175 gst_pulse_channel_map_to_gst (const pa_channel_map * map,
 176     GstRingBufferSpec * spec)
 177 {
 178   int i;
 179   GstAudioChannelPosition *pos;
 180   gboolean invalid = FALSE;
 181
 182   g_return_val_if_fail (map->channels == spec->channels, NULL);
 183
 184   pos = g_new0 (GstAudioChannelPosition, spec->channels + 1);
 185
 186   for (i = 0; i < spec->channels; i++) {
 187     if (map->map[i] == PA_CHANNEL_POSITION_INVALID) {
 188       invalid = TRUE;
 189       break;
 190     } else if ((int) map->map[i] < (int) GST_AUDIO_CHANNEL_POSITION_NUM) {
 191       pos[i] = pa_to_gst_pos[map->map[i] + 1];
 192     } else {
 193       invalid = TRUE;
 194       break;
 195     }
 196   }
 197
 198   if (!invalid && !gst_audio_check_channel_positions (pos, spec->channels))
 199     invalid = TRUE;
 200
 201   if (invalid) {
 202     for (i = 0; i < spec->channels; i++)
 203       pos[i] = GST_AUDIO_CHANNEL_POSITION_NONE;
 204   }
 205
 206   gst_audio_set_channel_positions (gst_caps_get_structure (spec->caps, 0), pos);
 207
 208   g_free (pos);
 209
 210   return spec;
 211 }
 212
 213 void
 214 gst_pulse_cvolume_from_linear (pa_cvolume * v, unsigned channels,
 215     gdouble volume)
 216 {
 217   pa_cvolume_set (v, channels, pa_sw_volume_from_linear (volume));
 218 }
 219
 220 static gboolean
 221 make_proplist_item (GQuark field_id, const GValue * value, gpointer user_data)
 222 {
 223   pa_proplist *p = (pa_proplist *) user_data;
 224   gchar *prop_id = (gchar *) g_quark_to_string (field_id);
 225
 226   /* http://0pointer.de/lennart/projects/pulseaudio/doxygen/proplist_8h.html */
 227
 228   /* match prop id */
 229
 230   /* check type */
 231   switch (G_VALUE_TYPE (value)) {
 232     case G_TYPE_STRING:
 233       pa_proplist_sets (p, prop_id, g_value_get_string (value));
 234       break;
 235     default:
 236       GST_WARNING ("unmapped property type %s", G_VALUE_TYPE_NAME (value));
 237       break;
 238   }
 239
 240   return TRUE;
 241 }
 242
 243 pa_proplist *
 244 gst_pulse_make_proplist (const GstStructure * properties)
 245 {
 246   pa_proplist *proplist = pa_proplist_new ();
 247
 248   /* iterate the structure and fill the proplist */
 249   gst_structure_foreach (properties, make_proplist_item, proplist);
 250   return proplist;
 251 }