1 files changed, 317 insertions, 294 deletions

diff --git a/src/plugins/gstreamer_extractor.c b/src/plugins/gstreamer_extractor.c
index 31568a7..87f0153 100644
--- a/src/plugins/gstreamer_extractor.c
+++ b/src/plugins/gstreamer_extractor.c
@@ -64,8 +64,7 @@ struct KnownTag
 /**
  * Struct mapping known tags (that do occur in GST API) to LE tags.
  */
-static struct KnownTag __known_tags[] =
-{
+static struct KnownTag __known_tags[] = {
   /**
    * GST_TAG_TITLE:
    *
@@ -562,7 +561,8 @@ static struct KnownTag __known_tags[] =
    * Represents the expected error on the horizontal positioning in
    * meters (double).
    */
-  {GST_TAG_GEO_LOCATION_HORIZONTAL_ERROR, EXTRACTOR_METATYPE_LOCATION_HORIZONTAL_ERROR},
+  {GST_TAG_GEO_LOCATION_HORIZONTAL_ERROR,
+   EXTRACTOR_METATYPE_LOCATION_HORIZONTAL_ERROR},
 
   /**
    * GST_TAG_GEO_LOCATION_MOVEMENT_SPEED:
@@ -572,7 +572,8 @@ static struct KnownTag __known_tags[] =
    *
    * See also #GST_TAG_GEO_LOCATION_MOVEMENT_DIRECTION
    */
-  {GST_TAG_GEO_LOCATION_MOVEMENT_SPEED, EXTRACTOR_METATYPE_LOCATION_MOVEMENT_SPEED},
+  {GST_TAG_GEO_LOCATION_MOVEMENT_SPEED,
+   EXTRACTOR_METATYPE_LOCATION_MOVEMENT_SPEED},
 
   /**
    * GST_TAG_GEO_LOCATION_MOVEMENT_DIRECTION:
@@ -583,7 +584,8 @@ static struct KnownTag __known_tags[] =
    *
    * See also #GST_TAG_GEO_LOCATION_CAPTURE_DIRECTION
    */
-  {GST_TAG_GEO_LOCATION_MOVEMENT_DIRECTION, EXTRACTOR_METATYPE_LOCATION_MOVEMENT_DIRECTION},
+  {GST_TAG_GEO_LOCATION_MOVEMENT_DIRECTION,
+   EXTRACTOR_METATYPE_LOCATION_MOVEMENT_DIRECTION},
 
   /**
    * GST_TAG_GEO_LOCATION_CAPTURE_DIRECTION:
@@ -594,7 +596,8 @@ static struct KnownTag __known_tags[] =
    *
    * See also #GST_TAG_GEO_LOCATION_MOVEMENT_DIRECTION
    */
-  {GST_TAG_GEO_LOCATION_CAPTURE_DIRECTION, EXTRACTOR_METATYPE_LOCATION_CAPTURE_DIRECTION},
+  {GST_TAG_GEO_LOCATION_CAPTURE_DIRECTION,
+   EXTRACTOR_METATYPE_LOCATION_CAPTURE_DIRECTION},
 
   /**
    * GST_TAG_SHOW_NAME:
@@ -735,23 +738,22 @@ struct NamedTag
  * Mapping from GST tag names to LE types for tags that are not in
  * the public GST API.
  */
-struct NamedTag named_tags[] =
-  {
-    { "FPS", EXTRACTOR_METATYPE_FRAME_RATE },
-    { "PLAY_COUNTER", EXTRACTOR_METATYPE_PLAY_COUNTER },
-    { "RATING", EXTRACTOR_METATYPE_RATING },
-    { "SUMMARY", EXTRACTOR_METATYPE_SUMMARY },
-    { "SUBJECT", EXTRACTOR_METATYPE_SUBJECT },
-    { "MOOD", EXTRACTOR_METATYPE_MOOD },
-    { "LEAD_PERFORMER", EXTRACTOR_METATYPE_PERFORMER },
-    { "DIRECTOR", EXTRACTOR_METATYPE_MOVIE_DIRECTOR },
-    { "WRITTEN_BY", EXTRACTOR_METATYPE_WRITER },
-    { "PRODUCER", EXTRACTOR_METATYPE_PRODUCER },
-    { "PUBLISHER", EXTRACTOR_METATYPE_PUBLISHER },
-    { "ORIGINAL/ARTIST", EXTRACTOR_METATYPE_ORIGINAL_ARTIST },
-    { "ORIGINAL/TITLE", EXTRACTOR_METATYPE_ORIGINAL_TITLE },
-    { NULL, EXTRACTOR_METATYPE_UNKNOWN }
-  };
+struct NamedTag named_tags[] = {
+  { "FPS", EXTRACTOR_METATYPE_FRAME_RATE },
+  { "PLAY_COUNTER", EXTRACTOR_METATYPE_PLAY_COUNTER },
+  { "RATING", EXTRACTOR_METATYPE_RATING },
+  { "SUMMARY", EXTRACTOR_METATYPE_SUMMARY },
+  { "SUBJECT", EXTRACTOR_METATYPE_SUBJECT },
+  { "MOOD", EXTRACTOR_METATYPE_MOOD },
+  { "LEAD_PERFORMER", EXTRACTOR_METATYPE_PERFORMER },
+  { "DIRECTOR", EXTRACTOR_METATYPE_MOVIE_DIRECTOR },
+  { "WRITTEN_BY", EXTRACTOR_METATYPE_WRITER },
+  { "PRODUCER", EXTRACTOR_METATYPE_PRODUCER },
+  { "PUBLISHER", EXTRACTOR_METATYPE_PUBLISHER },
+  { "ORIGINAL/ARTIST", EXTRACTOR_METATYPE_ORIGINAL_ARTIST },
+  { "ORIGINAL/TITLE", EXTRACTOR_METATYPE_ORIGINAL_TITLE },
+  { NULL, EXTRACTOR_METATYPE_UNKNOWN }
+};
 
 
 /**
@@ -914,9 +916,9 @@ _data_timeout (struct PrivStruct *ps)
  * @param ps our execution context
  */
 static void
-feed_data (GstElement * appsrc,
-           guint size,
-           struct PrivStruct * ps)
+feed_data (GstElement *appsrc,
+           guint size,
+           struct PrivStruct *ps)
 {
   ssize_t data_len;
   uint8_t *le_data;
@@ -929,7 +931,8 @@ feed_data (GstElement * appsrc,
 
   if (ps->timeout_id > 0)
     g_source_remove (ps->timeout_id);
-  ps->timeout_id = g_timeout_add (DATA_TIMEOUT, (GSourceFunc) _data_timeout, ps);
+  ps->timeout_id = g_timeout_add (DATA_TIMEOUT, (GSourceFunc) _data_timeout,
+                                  ps);
 
   if ( (ps->length > 0) && (ps->offset >= ps->length) )
   {
@@ -938,11 +941,11 @@ feed_data (GstElement * appsrc,
     return;
   }
 
-  if (ps->length > 0 && ps->offset + size > ps->length)
+  if ((ps->length > 0) && (ps->offset + size > ps->length))
     size = ps->length - ps->offset;
 
   mem = gst_allocator_alloc (NULL, size, NULL);
-  if (!gst_memory_map (mem, &mi, GST_MAP_WRITE))
+  if (! gst_memory_map (mem, &mi, GST_MAP_WRITE))
   {
     gst_memory_unref (mem);
     GST_DEBUG ("Failed to map the memory");
@@ -955,7 +958,8 @@ feed_data (GstElement * appsrc,
   pthread_mutex_lock (&pipe_mutex);
   while ( (accumulated < size) && (data_len > 0) )
   {
-    data_len = ps->ec->read (ps->ec->cls, (void **) &le_data, size - accumulated);
+    data_len = ps->ec->read (ps->ec->cls, (void **) &le_data, size
+                             - accumulated);
     if (data_len > 0)
     {
       memcpy (&mi.data[accumulated], le_data, data_len);
@@ -974,7 +978,7 @@ feed_data (GstElement * appsrc,
     GST_BUFFER_OFFSET_END (buffer) = ps->offset + size;
 
     GST_DEBUG ("feed buffer %p, offset %" G_GUINT64_FORMAT "-%u",
-               buffer, ps->offset, size);
+               buffer, ps->offset, size);
     gst_app_src_push_buffer (GST_APP_SRC (ps->source), buffer);
     ps->offset += size;
   }
@@ -987,7 +991,8 @@ feed_data (GstElement * appsrc,
 
   if (ps->timeout_id > 0)
     g_source_remove (ps->timeout_id);
-  ps->timeout_id = g_timeout_add (DATA_TIMEOUT, (GSourceFunc) _data_timeout, ps);
+  ps->timeout_id = g_timeout_add (DATA_TIMEOUT, (GSourceFunc) _data_timeout,
+                                  ps);
 }
 
 
@@ -1001,9 +1006,9 @@ feed_data (GstElement * appsrc,
  * @return TRUE if seeking succeeded, FALSE if not
  */
 static gboolean
-seek_data (GstElement * appsrc,
-           guint64 position,
-           struct PrivStruct * ps)
+seek_data (GstElement *appsrc,
+           guint64 position,
+           struct PrivStruct *ps)
 {
   GST_DEBUG ("seek to offset %" G_GUINT64_FORMAT, position);
   pthread_mutex_lock (&pipe_mutex);
@@ -1011,7 +1016,8 @@ seek_data (GstElement * appsrc,
   pthread_mutex_unlock (&pipe_mutex);
   if (ps->timeout_id > 0)
     g_source_remove (ps->timeout_id);
-  ps->timeout_id = g_timeout_add (DATA_TIMEOUT, (GSourceFunc) _data_timeout, ps);
+  ps->timeout_id = g_timeout_add (DATA_TIMEOUT, (GSourceFunc) _data_timeout,
+                                  ps);
   return ps->offset == position;
 }
 
@@ -1026,8 +1032,8 @@ seek_data (GstElement * appsrc,
  */
 static gboolean
 send_structure_foreach (GQuark field_id,
-                        const GValue *value,
-                        gpointer user_data)
+                        const GValue *value,
+                        gpointer user_data)
 {
   struct PrivStruct *ps = user_data;
   gchar *str;
@@ -1095,20 +1101,21 @@ send_structure_foreach (GQuark field_id,
   {
     unsigned int i;
 
-    for (i=0; NULL != named_tags[i].tag; i++)
+    for (i = 0; NULL != named_tags[i].tag; i++)
       if (0 == strcmp (named_tags[i].tag, field_name))
-        {
-          ps->time_to_leave = ps->ec->proc (ps->ec->cls, "gstreamer",
-                                            named_tags[i].le_type,
-                                            EXTRACTOR_METAFORMAT_UTF8, "text/plain",
-                                            (const char *) str, strlen (str) + 1);
-          if (NULL != str)
-            {
-              g_free (str);
-              str = NULL;
-            }
-          break;
-        }
+      {
+        ps->time_to_leave = ps->ec->proc (ps->ec->cls, "gstreamer",
+                                          named_tags[i].le_type,
+                                          EXTRACTOR_METAFORMAT_UTF8,
+                                          "text/plain",
+                                          (const char *) str, strlen (str) + 1);
+        if (NULL != str)
+        {
+          g_free (str);
+          str = NULL;
+        }
+        break;
+      }
   }
   if (NULL != str)
   {
@@ -1116,16 +1123,16 @@ send_structure_foreach (GQuark field_id,
                                        field_name,
                                        str);
     if (NULL != senddata)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_UNKNOWN,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) senddata,
-                                          strlen (senddata) + 1);
-        g_free (senddata);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_UNKNOWN,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) senddata,
+                                        strlen (senddata) + 1);
+      g_free (senddata);
+    }
   }
   if (NULL != str)
     g_free (str);
@@ -1143,7 +1150,7 @@ send_structure_foreach (GQuark field_id,
  */
 static gboolean
 send_audio_info (GstDiscovererAudioInfo *info,
-                 struct PrivStruct *ps)
+                 struct PrivStruct *ps)
 {
   gchar *tmp;
   const gchar *ctmp;
@@ -1152,10 +1159,11 @@ send_audio_info (GstDiscovererAudioInfo *info,
   ctmp = gst_discoverer_audio_info_get_language (info);
   if (ctmp)
     if ((ps->time_to_leave = ps->ec->proc (ps->ec->cls, "gstreamer",
-                                           EXTRACTOR_METATYPE_AUDIO_LANGUAGE,
-                                           EXTRACTOR_METAFORMAT_UTF8,
-                                           "text/plain",
-                                           (const char *) ctmp, strlen (ctmp) + 1)))
+                                           EXTRACTOR_METATYPE_AUDIO_LANGUAGE,
+                                           EXTRACTOR_METAFORMAT_UTF8,
+                                           "text/plain",
+                                           (const char *) ctmp, strlen (ctmp)
+                                           + 1)))
       return TRUE;
 
   u = gst_discoverer_audio_info_get_channels (info);
@@ -1163,16 +1171,16 @@ send_audio_info (GstDiscovererAudioInfo *info,
   {
     tmp = g_strdup_printf ("%u", u);
     if (NULL != tmp)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_CHANNELS,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) tmp,
-                                          strlen (tmp) + 1);
-        g_free (tmp);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_CHANNELS,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) tmp,
+                                        strlen (tmp) + 1);
+      g_free (tmp);
+    }
     if (ps->time_to_leave)
       return TRUE;
   }
@@ -1182,16 +1190,16 @@ send_audio_info (GstDiscovererAudioInfo *info,
   {
     tmp = g_strdup_printf ("%u", u);
     if (NULL != tmp)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_SAMPLE_RATE,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) tmp,
-                                          strlen (tmp) + 1);
-        g_free (tmp);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_SAMPLE_RATE,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) tmp,
+                                        strlen (tmp) + 1);
+      g_free (tmp);
+    }
     if (ps->time_to_leave)
       return TRUE;
   }
@@ -1201,16 +1209,16 @@ send_audio_info (GstDiscovererAudioInfo *info,
   {
     tmp = g_strdup_printf ("%u", u);
     if (NULL != tmp)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_AUDIO_DEPTH,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) tmp,
-                                          strlen (tmp) + 1);
-        g_free (tmp);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_AUDIO_DEPTH,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) tmp,
+                                        strlen (tmp) + 1);
+      g_free (tmp);
+    }
     if (ps->time_to_leave)
       return TRUE;
   }
@@ -1220,16 +1228,16 @@ send_audio_info (GstDiscovererAudioInfo *info,
   {
     tmp = g_strdup_printf ("%u", u);
     if (NULL != tmp)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_AUDIO_BITRATE,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) tmp,
-                                          strlen (tmp) + 1);
-        g_free (tmp);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_AUDIO_BITRATE,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) tmp,
+                                        strlen (tmp) + 1);
+      g_free (tmp);
+    }
     if (ps->time_to_leave)
       return TRUE;
   }
@@ -1239,16 +1247,16 @@ send_audio_info (GstDiscovererAudioInfo *info,
   {
     tmp = g_strdup_printf ("%u", u);
     if (NULL != tmp)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_MAXIMUM_AUDIO_BITRATE,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) tmp,
-                                          strlen (tmp) + 1);
-        g_free (tmp);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_MAXIMUM_AUDIO_BITRATE,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) tmp,
+                                        strlen (tmp) + 1);
+      g_free (tmp);
+    }
     if (ps->time_to_leave)
       return TRUE;
   }
@@ -1266,7 +1274,7 @@ send_audio_info (GstDiscovererAudioInfo *info,
  */
 static int
 send_video_info (GstDiscovererVideoInfo *info,
-                 struct PrivStruct *ps)
+                 struct PrivStruct *ps)
 {
   gchar *tmp;
   guint u;
@@ -1278,16 +1286,16 @@ send_video_info (GstDiscovererVideoInfo *info,
   {
     tmp = g_strdup_printf ("%ux%u", u, u2);
     if (NULL != tmp)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_VIDEO_DIMENSIONS,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) tmp,
-                                          strlen (tmp) + 1);
-        g_free (tmp);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_VIDEO_DIMENSIONS,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) tmp,
+                                        strlen (tmp) + 1);
+      g_free (tmp);
+    }
     if (ps->time_to_leave)
       return TRUE;
   }
@@ -1297,16 +1305,16 @@ send_video_info (GstDiscovererVideoInfo *info,
   {
     tmp = g_strdup_printf ("%u", u);
     if (NULL != tmp)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_VIDEO_DEPTH,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) tmp,
-                                          strlen (tmp) + 1);
-        g_free (tmp);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_VIDEO_DEPTH,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) tmp,
+                                        strlen (tmp) + 1);
+      g_free (tmp);
+    }
     if (ps->time_to_leave)
       return TRUE;
   }
@@ -1317,16 +1325,16 @@ send_video_info (GstDiscovererVideoInfo *info,
   {
     tmp = g_strdup_printf ("%u/%u", u, u2);
     if (NULL != tmp)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_FRAME_RATE,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) tmp,
-                                          strlen (tmp) + 1);
-        g_free (tmp);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_FRAME_RATE,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) tmp,
+                                        strlen (tmp) + 1);
+      g_free (tmp);
+    }
     if (ps->time_to_leave)
       return TRUE;
   }
@@ -1337,16 +1345,16 @@ send_video_info (GstDiscovererVideoInfo *info,
   {
     tmp = g_strdup_printf ("%u/%u", u, u2);
     if (NULL != tmp)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_PIXEL_ASPECT_RATIO,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) tmp,
-                                          strlen (tmp) + 1);
-        g_free (tmp);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_PIXEL_ASPECT_RATIO,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) tmp,
+                                        strlen (tmp) + 1);
+      g_free (tmp);
+    }
     if (ps->time_to_leave)
       return TRUE;
   }
@@ -1358,16 +1366,16 @@ send_video_info (GstDiscovererVideoInfo *info,
   {
     tmp = g_strdup_printf ("%u", u);
     if (NULL != tmp)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_VIDEO_BITRATE,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) tmp,
-                                          strlen (tmp) + 1);
-        g_free (tmp);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_VIDEO_BITRATE,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) tmp,
+                                        strlen (tmp) + 1);
+      g_free (tmp);
+    }
     if (ps->time_to_leave)
       return TRUE;
   }
@@ -1377,16 +1385,16 @@ send_video_info (GstDiscovererVideoInfo *info,
   {
     tmp = g_strdup_printf ("%u", u);
     if (NULL != tmp)
-      {
-        ps->time_to_leave = ps->ec->proc (ps->ec->cls,
-                                          "gstreamer",
-                                          EXTRACTOR_METATYPE_MAXIMUM_VIDEO_BITRATE,
-                                          EXTRACTOR_METAFORMAT_UTF8,
-                                          "text/plain",
-                                          (const char *) tmp,
-                                          strlen (tmp) + 1);
-        g_free (tmp);
-      }
+    {
+      ps->time_to_leave = ps->ec->proc (ps->ec->cls,
+                                        "gstreamer",
+                                        EXTRACTOR_METATYPE_MAXIMUM_VIDEO_BITRATE,
+                                        EXTRACTOR_METAFORMAT_UTF8,
+                                        "text/plain",
+                                        (const char *) tmp,
+                                        strlen (tmp) + 1);
+      g_free (tmp);
+    }
     if (ps->time_to_leave)
       return TRUE;
   }
@@ -1404,26 +1412,27 @@ send_video_info (GstDiscovererVideoInfo *info,
  */
 static int
 send_subtitle_info (GstDiscovererSubtitleInfo *info,
-                    struct PrivStruct *ps)
+                    struct PrivStruct *ps)
 {
   const gchar *ctmp;
 
   ctmp = gst_discoverer_subtitle_info_get_language (info);
   if ( (NULL != ctmp) &&
        (0 != (ps->time_to_leave = ps->ec->proc (ps->ec->cls, "gstreamer",
-                                                EXTRACTOR_METATYPE_SUBTITLE_LANGUAGE,
-                                                EXTRACTOR_METAFORMAT_UTF8,
-                                                "text/plain",
-                                                (const char *) ctmp, strlen (ctmp) + 1))) )
+                                                EXTRACTOR_METATYPE_SUBTITLE_LANGUAGE,
+                                                EXTRACTOR_METAFORMAT_UTF8,
+                                                "text/plain",
+                                                (const char *) ctmp, strlen (
+                                                  ctmp) + 1))) )
     return TRUE;
   return FALSE;
 }
 
 
 static void
-send_tag_foreach (const GstTagList * tags,
-                  const gchar * tag,
-                  gpointer user_data)
+send_tag_foreach (const GstTagList *tags,
+                  const gchar *tag,
+                  gpointer user_data)
 {
   static struct KnownTag unknown_tag = {NULL, EXTRACTOR_METATYPE_UNKNOWN};
   struct PrivStruct *ps = user_data;
@@ -1480,7 +1489,9 @@ send_tag_foreach (const GstTagList * tags,
       str = gst_value_serialize (&val);
       break;
     default:
-      if (G_VALUE_TYPE (&val) == GST_TYPE_SAMPLE && (sample = gst_value_get_sample (&val)))
+      if ((G_VALUE_TYPE (&val) == GST_TYPE_SAMPLE) && (sample =
+                                                         gst_value_get_sample (
+                                                           &val)))
       {
         GstMapInfo mi;
         GstCaps *caps;
@@ -1498,7 +1509,9 @@ send_tag_foreach (const GstTagList * tags,
           info = gst_sample_get_info (sample);
 
           if ( (NULL == info) ||
-               (!gst_structure_get (info, "image-type", GST_TYPE_TAG_IMAGE_TYPE, &imagetype, NULL)) )
+               (! gst_structure_get (info, "image-type",
+                                     GST_TYPE_TAG_IMAGE_TYPE, &imagetype,
+                                     NULL)) )
             le_type = EXTRACTOR_METATYPE_PICTURE;
           else
           {
@@ -1545,12 +1558,12 @@ send_tag_foreach (const GstTagList * tags,
                                             le_type,
                                             EXTRACTOR_METAFORMAT_BINARY,
                                             mime_type,
-              (const char *) mi.data, mi.size);
+                                            (const char *) mi.data, mi.size);
           gst_buffer_unmap (buf, &mi);
         }
       }
       else if ((G_VALUE_TYPE (&val) == G_TYPE_UINT64) &&
-          (tag_quark == duration_quark))
+               (tag_quark == duration_quark))
       {
         GstClockTime duration = (GstClockTime) g_value_get_uint64 (&val);
         if ((GST_CLOCK_TIME_IS_VALID (duration)) && (duration > 0))
@@ -1566,14 +1579,12 @@ send_tag_foreach (const GstTagList * tags,
        * ignore these tags to avoid duplicates.
        * This MIGHT be fixed in new GStreamer versions, but won't affect
        * this code (we simply won't get the tags that we think we should skip).
-       */
-      gboolean skip = FALSE;
+       */gboolean skip = FALSE;
       /* We have one tag-processing routine and use it for different
        * stream types. However, tags themselves don't know the type of the
        * stream they are attached to. We remember that before listing the
        * tags, and adjust LE type accordingly.
-       */
-      enum EXTRACTOR_MetaType le_type = kt->le_type;
+       */enum EXTRACTOR_MetaType le_type = kt->le_type;
       switch (kt->le_type)
       {
       case EXTRACTOR_METATYPE_LANGUAGE:
@@ -1662,7 +1673,7 @@ send_tag_foreach (const GstTagList * tags,
         {
           gchar *new_str;
           /* GST_TAG_EXTENDED_COMMENT is already in key=value form */
-          if ((0 != strcmp (tag, "extended-comment")) || !strchr (str, '='))
+          if ((0 != strcmp (tag, "extended-comment")) || ! strchr (str, '='))
           {
             new_str = g_strdup_printf ("%s=%s", tag, str);
             if (NULL != str)
@@ -1693,12 +1704,12 @@ send_tag_foreach (const GstTagList * tags,
 
 static void
 send_streams (GstDiscovererStreamInfo *info,
-              struct PrivStruct *ps);
+              struct PrivStruct *ps);
 
 
 static void
-send_stream_info (GstDiscovererStreamInfo * info,
-                  struct PrivStruct *ps)
+send_stream_info (GstDiscovererStreamInfo *info,
+                  struct PrivStruct *ps)
 {
   const GstStructure *misc;
   GstCaps *caps;
@@ -1722,9 +1733,11 @@ send_stream_info (GstDiscovererStreamInfo * info,
     if (g_str_has_prefix (structname, "image/"))
       ps->st = STREAM_TYPE_IMAGE;
     ps->time_to_leave = ps->ec->proc (ps->ec->cls, "gstreamer",
-      EXTRACTOR_METATYPE_MIMETYPE, EXTRACTOR_METAFORMAT_UTF8, "text/plain",
-      (const char *) structname, strlen (structname) + 1);
-    if (!ps->time_to_leave)
+                                      EXTRACTOR_METATYPE_MIMETYPE,
+                                      EXTRACTOR_METAFORMAT_UTF8, "text/plain",
+                                      (const char *) structname, strlen (
+                                        structname) + 1);
+    if (! ps->time_to_leave)
     {
       gst_structure_foreach (structure, send_structure_foreach, ps);
     }
@@ -1770,8 +1783,8 @@ send_stream_info (GstDiscovererStreamInfo * info,
     GList *child;
     GstDiscovererContainerInfo *c = GST_DISCOVERER_CONTAINER_INFO (info);
     GList *children = gst_discoverer_container_info_get_streams (c);
-    for (child = children; (NULL != child) && (!ps->time_to_leave);
-        child = child->next)
+    for (child = children; (NULL != child) && (! ps->time_to_leave);
+         child = child->next)
     {
       GstDiscovererStreamInfo *sinfo = child->data;
       /* send_streams () will unref it */
@@ -1786,7 +1799,7 @@ send_stream_info (GstDiscovererStreamInfo * info,
 
 static void
 send_streams (GstDiscovererStreamInfo *info,
-              struct PrivStruct *ps)
+              struct PrivStruct *ps)
 {
   GstDiscovererStreamInfo *next;
 
@@ -1808,9 +1821,9 @@ send_streams (GstDiscovererStreamInfo *info,
  * @param user_data the 'struct PrivStruct' with the 'toc' string we are assembling
  */
 static void
-send_toc_tags_foreach (const GstTagList * tags,
-                       const gchar * tag,
-                       gpointer user_data)
+send_toc_tags_foreach (const GstTagList *tags,
+                       const gchar *tag,
+                       gpointer user_data)
 {
   struct PrivStruct *ps = user_data;
   GValue val = { 0 };
@@ -1899,9 +1912,11 @@ send_toc_foreach (gpointer data, gpointer user_data)
     return;
   gst_toc_entry_get_start_stop_times (entry, &start, &stop);
   s = g_strdup_printf ("%*.*s<%s start=\"%" GST_TIME_FORMAT "\" stop=\"%"
-                       GST_TIME_FORMAT"\">\n", ps->toc_depth * 2, ps->toc_depth * 2, " ",
-                       gst_toc_entry_type_get_nick (entype), GST_TIME_ARGS (start),
-                       GST_TIME_ARGS (stop));
+                       GST_TIME_FORMAT "\">\n", ps->toc_depth * 2,
+                       ps->toc_depth * 2, " ",
+                       gst_toc_entry_type_get_nick (entype), GST_TIME_ARGS (
+                         start),
+                       GST_TIME_ARGS (stop));
   if (NULL != s)
   {
     if (ps->toc_print_phase)
@@ -1916,21 +1931,25 @@ send_toc_foreach (gpointer data, gpointer user_data)
   ps->toc_depth++;
   tags = gst_toc_entry_get_tags (entry);
   if (tags)
-    {
-      if (ps->toc_print_phase)
-        ps->toc_pos += g_snprintf (&ps->toc[ps->toc_pos], ps->toc_length - ps->toc_pos,
-                                   "%*.*s<tags>\n", ps->toc_depth * 2, ps->toc_depth * 2, " ");
-      else
-        ps->toc_length += strlen ("<tags>\n") + ps->toc_depth * 2;
-      ps->toc_depth++;
-      gst_tag_list_foreach (tags, &send_toc_tags_foreach, ps);
-      ps->toc_depth--;
-      if (ps->toc_print_phase)
-        ps->toc_pos += g_snprintf (&ps->toc[ps->toc_pos], ps->toc_length - ps->toc_pos,
-                                   "%*.*s</tags>\n", ps->toc_depth * 2, ps->toc_depth * 2, " ");
-      else
-        ps->toc_length += strlen ("</tags>\n") + ps->toc_depth * 2;
-    }
+  {
+    if (ps->toc_print_phase)
+      ps->toc_pos += g_snprintf (&ps->toc[ps->toc_pos], ps->toc_length
+                                 - ps->toc_pos,
+                                 "%*.*s<tags>\n", ps->toc_depth * 2,
+                                 ps->toc_depth * 2, " ");
+    else
+      ps->toc_length += strlen ("<tags>\n") + ps->toc_depth * 2;
+    ps->toc_depth++;
+    gst_tag_list_foreach (tags, &send_toc_tags_foreach, ps);
+    ps->toc_depth--;
+    if (ps->toc_print_phase)
+      ps->toc_pos += g_snprintf (&ps->toc[ps->toc_pos], ps->toc_length
+                                 - ps->toc_pos,
+                                 "%*.*s</tags>\n", ps->toc_depth * 2,
+                                 ps->toc_depth * 2, " ");
+    else
+      ps->toc_length += strlen ("</tags>\n") + ps->toc_depth * 2;
+  }
 
   subentries = gst_toc_entry_get_sub_entries (entry);
   g_list_foreach (subentries, send_toc_foreach, ps);
@@ -1939,11 +1958,12 @@ send_toc_foreach (gpointer data, gpointer user_data)
   s = g_strdup_printf ("%*.*s</%s>\n",
                        ps->toc_depth * 2,
                        ps->toc_depth * 2, " ",
-                       gst_toc_entry_type_get_nick (entype));
+                       gst_toc_entry_type_get_nick (entype));
   if (NULL != s)
   {
     if (ps->toc_print_phase)
-      ps->toc_pos += g_snprintf (&ps->toc[ps->toc_pos], ps->toc_length - ps->toc_pos, "%s", s);
+      ps->toc_pos += g_snprintf (&ps->toc[ps->toc_pos], ps->toc_length
+                                 - ps->toc_pos, "%s", s);
     else
       ps->toc_length += strlen (s);
     g_free (s);
@@ -1958,8 +1978,8 @@ send_toc_foreach (gpointer data, gpointer user_data)
 
 
 static void
-send_info (GstDiscovererInfo * info,
-           struct PrivStruct *ps)
+send_info (GstDiscovererInfo *info,
+           struct PrivStruct *ps)
 {
   const GstToc *toc;
   gchar *s;
@@ -1992,9 +2012,7 @@ send_info (GstDiscovererInfo * info,
   {
     gst_tag_list_foreach (tags, send_tag_foreach, ps);
   }
-  */
-
-  if (ps->time_to_leave)
+  */if (ps->time_to_leave)
     return;
 
   if ((toc = gst_discoverer_info_get_toc (info)))
@@ -2040,8 +2058,8 @@ send_info (GstDiscovererInfo * info,
 
 
 static void
-send_discovered_info (GstDiscovererInfo * info,
-                      struct PrivStruct * ps)
+send_discovered_info (GstDiscovererInfo *info,
+                      struct PrivStruct *ps)
 {
   GstDiscovererResult result;
 
@@ -2051,20 +2069,20 @@ send_discovered_info (GstDiscovererInfo * info,
   result = gst_discoverer_info_get_result (info);
 
   switch (result)
-    {
-    case GST_DISCOVERER_OK:
-      break;
-    case GST_DISCOVERER_URI_INVALID:
-      break;
-    case GST_DISCOVERER_ERROR:
-      break;
-    case GST_DISCOVERER_TIMEOUT:
-      break;
-    case GST_DISCOVERER_BUSY:
-      break;
-    case GST_DISCOVERER_MISSING_PLUGINS:
-      break;
-    }
+  {
+  case GST_DISCOVERER_OK:
+    break;
+  case GST_DISCOVERER_URI_INVALID:
+    break;
+  case GST_DISCOVERER_ERROR:
+    break;
+  case GST_DISCOVERER_TIMEOUT:
+    break;
+  case GST_DISCOVERER_BUSY:
+    break;
+  case GST_DISCOVERER_MISSING_PLUGINS:
+    break;
+  }
   pthread_mutex_lock (&pipe_mutex);
   send_info (info, ps);
   pthread_mutex_unlock (&pipe_mutex);
@@ -2072,20 +2090,21 @@ send_discovered_info (GstDiscovererInfo * info,
 
 
 static void
-_new_discovered_uri (GstDiscoverer * dc,
-                     GstDiscovererInfo * info,
-                     GError * err,
-                     struct PrivStruct *ps)
+_new_discovered_uri (GstDiscoverer *dc,
+                     GstDiscovererInfo *info,
+                     GError *err,
+                     struct PrivStruct *ps)
 {
   send_discovered_info (info, ps);
   if (ps->timeout_id > 0)
     g_source_remove (ps->timeout_id);
-  ps->timeout_id = g_timeout_add (DATA_TIMEOUT, (GSourceFunc) _data_timeout, ps);
+  ps->timeout_id = g_timeout_add (DATA_TIMEOUT, (GSourceFunc) _data_timeout,
+                                  ps);
 }
 
 
 static void
-_discoverer_finished (GstDiscoverer * dc, struct PrivStruct *ps)
+_discoverer_finished (GstDiscoverer *dc, struct PrivStruct *ps)
 {
   if (ps->timeout_id > 0)
     g_source_remove (ps->timeout_id);
@@ -2105,9 +2124,9 @@ _discoverer_finished (GstDiscoverer * dc, struct PrivStruct *ps)
  * @param ps
  */
 static void
-_source_setup (GstDiscoverer * dc,
-               GstElement * source,
-               struct PrivStruct *ps)
+_source_setup (GstDiscoverer *dc,
+               GstElement *source,
+               struct PrivStruct *ps)
 {
   if (ps->source)
     gst_object_unref (GST_OBJECT (ps->source));
@@ -2120,7 +2139,8 @@ _source_setup (GstDiscoverer * dc,
   if (ps->length > 0)
   {
     g_object_set (ps->source, "size", (gint64) ps->length, NULL);
-    gst_util_set_object_arg (G_OBJECT (ps->source), "stream-type", "random-access");
+    gst_util_set_object_arg (G_OBJECT (ps->source), "stream-type",
+                             "random-access");
   }
   else
     gst_util_set_object_arg (G_OBJECT (ps->source), "stream-type", "seekable");
@@ -2129,16 +2149,16 @@ _source_setup (GstDiscoverer * dc,
    * data */
   g_signal_connect (ps->source, "need-data", G_CALLBACK (feed_data), ps);
   g_signal_connect (ps->source, "seek-data", G_CALLBACK (seek_data), ps);
-  ps->timeout_id = g_timeout_add (DATA_TIMEOUT, (GSourceFunc) _data_timeout, ps);
+  ps->timeout_id = g_timeout_add (DATA_TIMEOUT, (GSourceFunc) _data_timeout,
+                                  ps);
 }
 
 
-
 static void
 log_handler (const gchar *log_domain,
-             GLogLevelFlags log_level,
-             const gchar *message,
-             gpointer unused_data)
+             GLogLevelFlags log_level,
+             const gchar *message,
+             gpointer unused_data)
 {
   /* do nothing */
 }
@@ -2151,11 +2171,12 @@ log_handler (const gchar *log_domain,
  * @return FALSE (always)
  */
 static gboolean
-_run_async (struct PrivStruct * ps)
+_run_async (struct PrivStruct *ps)
 {
   g_log_set_default_handler (&log_handler, NULL);
-  g_log_set_handler (NULL, G_LOG_LEVEL_MASK | G_LOG_FLAG_FATAL | G_LOG_FLAG_RECURSION,
-                     &log_handler, NULL);
+  g_log_set_handler (NULL, G_LOG_LEVEL_MASK | G_LOG_FLAG_FATAL
+                     | G_LOG_FLAG_RECURSION,
+                     &log_handler, NULL);
   gst_discoverer_discover_uri_async (ps->dc, "appsrc://");
   return FALSE;
 }
@@ -2178,11 +2199,11 @@ EXTRACTOR_gstreamer_extract_method (struct EXTRACTOR_ExtractContext *ec)
   memset (&ps, 0, sizeof (ps));
   ps.dc = gst_discoverer_new (8 * GST_SECOND, &err);
   if (NULL == ps.dc)
-    {
-      if (NULL != err)
-        g_error_free (err);
-      return;
-    }
+  {
+    if (NULL != err)
+      g_error_free (err);
+    return;
+  }
   if (NULL != err)
     g_error_free (err);
   /* connect signals */
@@ -2195,10 +2216,11 @@ EXTRACTOR_gstreamer_extract_method (struct EXTRACTOR_ExtractContext *ec)
   if (ps.length == UINT_MAX)
     ps.length = 0;
   g_log_set_default_handler (&log_handler, NULL);
-  g_log_set_handler (NULL, G_LOG_LEVEL_MASK | G_LOG_FLAG_FATAL | G_LOG_FLAG_RECURSION,
-                     &log_handler, NULL);
+  g_log_set_handler (NULL, G_LOG_LEVEL_MASK | G_LOG_FLAG_FATAL
+                     | G_LOG_FLAG_RECURSION,
+                     &log_handler, NULL);
   gst_discoverer_start (ps.dc);
-  g_idle_add ((GSourceFunc) &_run_async, &ps);
+  g_idle_add ((GSourceFunc) & _run_async, &ps);
   g_main_loop_run (ps.loop);
   if (ps.timeout_id > 0)
     g_source_remove (ps.timeout_id);
@@ -2216,35 +2238,36 @@ gstreamer_init ()
 {
   gst_init (NULL, NULL);
   g_log_set_default_handler (&log_handler, NULL);
-  g_log_set_handler (NULL, G_LOG_LEVEL_MASK | G_LOG_FLAG_FATAL | G_LOG_FLAG_RECURSION,
-                     &log_handler, NULL);
+  g_log_set_handler (NULL, G_LOG_LEVEL_MASK | G_LOG_FLAG_FATAL
+                     | G_LOG_FLAG_RECURSION,
+                     &log_handler, NULL);
   GST_DEBUG_CATEGORY_INIT (gstreamer_extractor, "GstExtractor",
-                         0, "GStreamer-based libextractor plugin");
+                           0, "GStreamer-based libextractor plugin");
 
   audio_quarks = g_new0 (GQuark, 4);
   if (NULL != audio_quarks)
-    {
-      audio_quarks[0] = g_quark_from_string ("rate");
-      audio_quarks[1] = g_quark_from_string ("channels");
-      audio_quarks[2] = g_quark_from_string ("depth");
-      audio_quarks[3] = g_quark_from_string (NULL);
-    }
+  {
+    audio_quarks[0] = g_quark_from_string ("rate");
+    audio_quarks[1] = g_quark_from_string ("channels");
+    audio_quarks[2] = g_quark_from_string ("depth");
+    audio_quarks[3] = g_quark_from_string (NULL);
+  }
   video_quarks = g_new0 (GQuark, 6);
   if (NULL != video_quarks)
-    {
-      video_quarks[0] = g_quark_from_string ("width");
-      video_quarks[1] = g_quark_from_string ("height");
-      video_quarks[2] = g_quark_from_string ("framerate");
-      video_quarks[3] = g_quark_from_string ("max-framerate");
-      video_quarks[4] = g_quark_from_string ("pixel-aspect-ratio");
-      video_quarks[5] = g_quark_from_string (NULL);
-    }
+  {
+    video_quarks[0] = g_quark_from_string ("width");
+    video_quarks[1] = g_quark_from_string ("height");
+    video_quarks[2] = g_quark_from_string ("framerate");
+    video_quarks[3] = g_quark_from_string ("max-framerate");
+    video_quarks[4] = g_quark_from_string ("pixel-aspect-ratio");
+    video_quarks[5] = g_quark_from_string (NULL);
+  }
   subtitle_quarks = g_new0 (GQuark, 2);
   if (NULL != subtitle_quarks)
-    {
-      subtitle_quarks[0] = g_quark_from_string ("language-code");
-      subtitle_quarks[1] = g_quark_from_string (NULL);
-    }
+  {
+    subtitle_quarks[0] = g_quark_from_string ("language-code");
+    subtitle_quarks[1] = g_quark_from_string (NULL);
+  }
 
   duration_quark = g_quark_from_string ("duration");