don't mix tabs and spaces
authorThomas Vander Stichele <thomas@apestaart.org>
Mon, 15 Mar 2004 19:27:17 +0000 (19:27 +0000)
committerThomas Vander Stichele <thomas@apestaart.org>
Mon, 15 Mar 2004 19:27:17 +0000 (19:27 +0000)
Original commit message from CVS:
don't mix tabs and spaces

189 files changed:
ChangeLog
components/bonobo-gstmediaplay/bonobo-gstmediaplay.c
examples/cutter/cutter.c
examples/launch/mp3parselaunch.c
examples/mixer/mixer.c
examples/plugins/example.c
examples/retag/retag.c
examples/retag/transcode.c
examples/xml/runxml.c
gst/autoplug/gstsearchfuncs.c
gst/autoplug/gstspider.c
gst/autoplug/gstspideridentity.c
gst/autoplug/spidertest.c
gst/cothreads.c
gst/elements/gstaggregator.c
gst/elements/gstbufferstore.c
gst/elements/gstelements.c
gst/elements/gstfakesink.c
gst/elements/gstfakesrc.c
gst/elements/gstfdsink.c
gst/elements/gstfdsrc.c
gst/elements/gstfilesink.c
gst/elements/gstfilesrc.c
gst/elements/gstidentity.c
gst/elements/gstmd5sink.c
gst/elements/gstmultifilesrc.c
gst/elements/gstpipefilter.c
gst/elements/gstshaper.c
gst/elements/gststatistics.c
gst/elements/gsttee.c
gst/elements/gsttypefind.c
gst/gst.c
gst/gstbin.c
gst/gstbuffer.c
gst/gstcaps.c
gst/gstclock.c
gst/gstcpu.c
gst/gstdata.c
gst/gstelement.c
gst/gstelementfactory.c
gst/gsterror.c
gst/gstevent.c
gst/gstfilter.c
gst/gstformat.c
gst/gstindex.c
gst/gstinfo.c
gst/gstinterface.c
gst/gstmemchunk.c
gst/gstobject.c
gst/gstpad.c
gst/gstpipeline.c
gst/gstplugin.c
gst/gstpluginfeature.c
gst/gstquery.c
gst/gstqueue.c
gst/gstregistry.c
gst/gstregistrypool.c
gst/gstscheduler.c
gst/gststructure.c
gst/gstsystemclock.c
gst/gsttag.c
gst/gsttaginterface.c
gst/gsttaglist.c
gst/gsttagsetter.c
gst/gstthread.c
gst/gstthreaddummy.c
gst/gsttrace.c
gst/gsttypefind.c
gst/gsturi.c
gst/gstutils.c
gst/gstvalue.c
gst/gstxml.c
gst/indexers/gstfileindex.c
gst/indexers/gstmemindex.c
gst/registries/gstxmlregistry.c
gst/schedulers/gstbasicscheduler.c
libs/gst/bytestream/bytestream.c
libs/gst/control/dparam.c
libs/gst/control/dparam_smooth.c
libs/gst/control/dparammanager.c
libs/gst/control/dplinearinterp.c
libs/gst/control/unitconvert.c
libs/gst/getbits/getbits.c
plugins/elements/gstaggregator.c
plugins/elements/gstbufferstore.c
plugins/elements/gstelements.c
plugins/elements/gstfakesink.c
plugins/elements/gstfakesrc.c
plugins/elements/gstfdsink.c
plugins/elements/gstfdsrc.c
plugins/elements/gstfilesink.c
plugins/elements/gstfilesrc.c
plugins/elements/gstidentity.c
plugins/elements/gstmd5sink.c
plugins/elements/gstmultifilesrc.c
plugins/elements/gstpipefilter.c
plugins/elements/gstqueue.c
plugins/elements/gstshaper.c
plugins/elements/gststatistics.c
plugins/elements/gsttee.c
plugins/elements/gsttypefind.c
plugins/indexers/gstfileindex.c
plugins/indexers/gstmemindex.c
tests/bufspeed/gstmempool.c
tests/lat.c
tests/memchunk/gmemchunktest.c
tests/memchunk/gstmemchunk.c
tests/memchunk/gstmemchunktest.c
tests/negotiation/capsnego1.c
tests/old/examples/cutter/cutter.c
tests/old/examples/launch/mp3parselaunch.c
tests/old/examples/mixer/mixer.c
tests/old/examples/plugins/example.c
tests/old/examples/retag/retag.c
tests/old/examples/retag/transcode.c
tests/old/examples/xml/runxml.c
tests/old/testsuite/bytestream/gstbstest.c
tests/old/testsuite/bytestream/test1.c
tests/old/testsuite/caps/app_fixate.c
tests/old/testsuite/caps/caps.c
tests/old/testsuite/caps/intersect2.c
tests/old/testsuite/caps/intersection.c
tests/old/testsuite/cleanup/cleanup1.c
tests/old/testsuite/cleanup/cleanup2.c
tests/old/testsuite/cleanup/cleanup3.c
tests/old/testsuite/cleanup/cleanup4.c
tests/old/testsuite/cleanup/cleanup5.c
tests/old/testsuite/debug/category.c
tests/old/testsuite/debug/commandline.c
tests/old/testsuite/debug/global.c
tests/old/testsuite/dynparams/dparamstest.c
tests/old/testsuite/elements/fake.c
tests/old/testsuite/elements/name.c
tests/old/testsuite/elements/property.c
tests/old/testsuite/indexers/cache1.c
tests/old/testsuite/indexers/indexdump.c
tests/old/testsuite/parse/parse1.c
tests/old/testsuite/refcounting/pad.c
tests/old/testsuite/refcounting/sched.c
tests/old/testsuite/threads/thread.c
tests/old/testsuite/threads/threadb.c
tests/old/testsuite/threads/threadc.c
tests/old/testsuite/threads/threadd.c
tests/old/testsuite/threads/threade.c
tests/probes/probetest.c
tests/sched/interrupt1.c
tests/sched/interrupt2.c
tests/sched/interrupt3.c
tests/sched/runxml.c
tests/sched/sched-stress.c
tests/seeking/seeking1.c
testsuite/bytestream/gstbstest.c
testsuite/bytestream/test1.c
testsuite/caps/app_fixate.c
testsuite/caps/caps.c
testsuite/caps/intersect2.c
testsuite/caps/intersection.c
testsuite/cleanup/cleanup1.c
testsuite/cleanup/cleanup2.c
testsuite/cleanup/cleanup3.c
testsuite/cleanup/cleanup4.c
testsuite/cleanup/cleanup5.c
testsuite/debug/category.c
testsuite/debug/commandline.c
testsuite/debug/global.c
testsuite/dynparams/dparamstest.c
testsuite/elements/fake.c
testsuite/elements/name.c
testsuite/elements/property.c
testsuite/indexers/cache1.c
testsuite/indexers/indexdump.c
testsuite/parse/parse1.c
testsuite/refcounting/pad.c
testsuite/refcounting/sched.c
testsuite/threads/thread.c
testsuite/threads/threadb.c
testsuite/threads/threadc.c
testsuite/threads/threadd.c
testsuite/threads/threade.c
tools/gst-complete.c
tools/gst-compprep.c
tools/gst-indent
tools/gst-inspect.c
tools/gst-launch.c
tools/gst-md5sum.c
tools/gst-register.c
tools/gst-run.c
tools/gst-typefind.c
tools/gst-xmlinspect.c

index 772ede347643cfa347d8e7b2eacaa4e6c7a74f6e..24f337c12d0cc713a3f3ef5978043bd68b75cc17 100644 (file)
--- a/ChangeLog
+++ b/ChangeLog
@@ -1,3 +1,7 @@
+2004-03-15  Thomas Vander Stichele  <thomas at apestaart dot org>
+
+       * *.c,*.h: don't mix tabs and spaces
+
 2004-03-15  Johan Dahlin  <johan@gnome.org>
 
        * gst/schedulers/gstoptimalscheduler.c
index 4d7610eac6b2c646fb9956d73ca65bdd45cec3ff..de9a148751e2d5de297d1f20468bb3ec84f31615 100644 (file)
@@ -44,7 +44,8 @@ typedef struct
   BonoboUIComponent *uic;
 
   GstPlay *play;
-} control_data_t;
+}
+control_data_t;
 
 /*
  * This callback is invoked when the BonoboControl object
@@ -94,7 +95,8 @@ typedef struct
 {
   control_data_t *control_data;
   GtkFileSelection *selector;
-} file_select_struct;
+}
+file_select_struct;
 
 static void
 filename_selected (GtkButton * ok, gpointer user_data)
@@ -127,14 +129,14 @@ verb_Open_cb (BonoboUIComponent * uic, gpointer user_data, const char *cname)
   data->control_data = control_data;
 
   gtk_signal_connect (GTK_OBJECT (GTK_FILE_SELECTION (file_selector)->
-         ok_button), "clicked", GTK_SIGNAL_FUNC (filename_selected), data);
+          ok_button), "clicked", GTK_SIGNAL_FUNC (filename_selected), data);
 
   gtk_signal_connect_object (GTK_OBJECT (GTK_FILE_SELECTION (file_selector)->
-         ok_button), "clicked", GTK_SIGNAL_FUNC (gtk_widget_destroy),
+          ok_button), "clicked", GTK_SIGNAL_FUNC (gtk_widget_destroy),
       (gpointer) file_selector);
 
   gtk_signal_connect_object (GTK_OBJECT (GTK_FILE_SELECTION (file_selector)->
-         cancel_button), "clicked", GTK_SIGNAL_FUNC (gtk_widget_destroy),
+          cancel_button), "clicked", GTK_SIGNAL_FUNC (gtk_widget_destroy),
       (gpointer) file_selector);
 
   gtk_widget_show (file_selector);
@@ -208,7 +210,7 @@ control_create_menus (control_data_t * control_data)
     node = bonobo_ui_node_from_string (ui);
     bonobo_ui_util_translate_ui (node);
     bonobo_ui_util_fixup_help (control_data->uic, node,
-       DATADIR, "gstmediaplay");
+        DATADIR, "gstmediaplay");
 
     bonobo_ui_component_set_tree (control_data->uic, "/", node, NULL);
 
index fb235d845ee75ab2c023b1d0b8f024eb0e692d0d..b8f32893c4308f2ff23dd761dd75c4ce281cef07 100644 (file)
@@ -20,7 +20,7 @@ gboolean playing = TRUE;
 gboolean cut_start_signalled = FALSE;
 gboolean cut_stop_signalled = FALSE;
 
-int id = 0;                    /* increment this for each new cut */
+int id = 0;                     /* increment this for each new cut */
 GstElement *main_bin;
 GstElement *audiosrc;
 GstElement *queue;
@@ -51,9 +51,9 @@ cut_start (GstElement * element)
     ct = localtime (&seconds);
 /*    sprintf (buffer, "/news/incoming/audio/cutter.%06d.wav", id); */
     sprintf (buffer,
-       "/news/incoming/audio/cutter.%04d%02d%02d.%02d%02d%02d.wav",
-       ct->tm_year + 1900, ct->tm_mon, ct->tm_mday, ct->tm_hour, ct->tm_min,
-       ct->tm_sec);
+        "/news/incoming/audio/cutter.%04d%02d%02d.%02d%02d%02d.wav",
+        ct->tm_year + 1900, ct->tm_mon, ct->tm_mday, ct->tm_hour, ct->tm_min,
+        ct->tm_sec);
   }
   g_print ("DEBUG: cut_start: setting new location to %s\n", buffer);
   g_object_set (G_OBJECT (disksink), "location", buffer, NULL);
index a8009712f52314697c78e6054a4f8b94122b63ef..5fe06de5505ab1de3da650b4674809a189cc4b7a 100644 (file)
@@ -15,8 +15,7 @@ main (int argc, char *argv[])
     return -1;
   }
 
-  pipeline =
-      (GstElement *)
+  pipeline = (GstElement *)
       gst_parse_launch ("filesrc name=my_filesrc ! mad ! osssink", &error);
   if (!pipeline) {
     fprintf (stderr, "Parse error: %s", error->message);
index c2990724fe028d3a2aa7b331c9a012ad38266ab7..6a3acc119f0d6f3272f2a5c0b65b21b2b968b9b0 100644 (file)
@@ -88,7 +88,7 @@ main (int argc, char *argv[])
 
   char buffer[20];
 
-  GList *input_channels;       /* structure holding all the input channels */
+  GList *input_channels;        /* structure holding all the input channels */
 
   input_channel_t *channel_in;
 
@@ -96,7 +96,7 @@ main (int argc, char *argv[])
   GstElement *adder;
   GstElement *audiosink;
 
-  GstPad *pad;                 /* to request pads for the adder */
+  GstPad *pad;                  /* to request pads for the adder */
 
   gst_init (&argc, &argv);
 
@@ -167,17 +167,17 @@ main (int argc, char *argv[])
       /* first song gets special treatment for end style */
       env_register_cp (channel_in->volenv, 0.0, 1.0);
     } else {
-      env_register_cp (channel_in->volenv, 0.0, 0.0000001);    /* start muted */
-      env_register_cp (channel_in->volenv, i * 10.0 - 15.0, 0.0000001);        /* start fade in */
+      env_register_cp (channel_in->volenv, 0.0, 0.0000001);     /* start muted */
+      env_register_cp (channel_in->volenv, i * 10.0 - 15.0, 0.0000001); /* start fade in */
       env_register_cp (channel_in->volenv, i * 10.0 - 10.0, 1.0);
     }
-    env_register_cp (channel_in->volenv, i * 10.0 - 5.0, 1.0); /* end of full level */
+    env_register_cp (channel_in->volenv, i * 10.0 - 5.0, 1.0);  /* end of full level */
 
     if (i != num_channels) {
-      env_register_cp (channel_in->volenv, i * 10.0, 0.0000001);       /* fade to black */
-      env_register_cp (channel_in->volenv, num_channels * 10.0 - 5.0, 0.0000001);      /* start fade in */
+      env_register_cp (channel_in->volenv, i * 10.0, 0.0000001);        /* fade to black */
+      env_register_cp (channel_in->volenv, num_channels * 10.0 - 5.0, 0.0000001);       /* start fade in */
     }
-    env_register_cp (channel_in->volenv, num_channels * 10.0, 1.0 / num_channels);     /* to end level */
+    env_register_cp (channel_in->volenv, num_channels * 10.0, 1.0 / num_channels);      /* to end level */
 
 #ifndef GST_DISABLE_LOADSAVE
     gst_xml_write_file (GST_ELEMENT (main_bin), fopen ("mixer.xml", "w"));
@@ -230,7 +230,7 @@ create_input_channel (int id, char *location)
 
   input_channel_t *channel;
 
-  char buffer[20];             /* hold the names */
+  char buffer[20];              /* hold the names */
 
 /*  GstAutoplug *autoplug;
   GstCaps *srccaps; */
index 42144a0aabe68876f2e47f9579c5b720fb3a47b4..20aba45a8b8964d9f422f83ae9120a001dc2fcee 100644 (file)
@@ -58,13 +58,13 @@ enum
  * can have.  They can be quite complex, but for this example plugin
  * they are rather simple.
  */
-GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink",  /* The name of the pad */
-    GST_PAD_SINK,              /* Direction of the pad */
-    GST_PAD_ALWAYS,            /* The pad exists for every instance */
-    GST_STATIC_CAPS ("unknown/unknown, "       /* The MIME media type */
-       "foo:int=1, "           /* an integer property */
-       "bar:boolean=true, "    /* a boolean property */
-       "baz:int={ 1, 3 }"      /* a list of values */
+GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink",   /* The name of the pad */
+    GST_PAD_SINK,               /* Direction of the pad */
+    GST_PAD_ALWAYS,             /* The pad exists for every instance */
+    GST_STATIC_CAPS ("unknown/unknown, "        /* The MIME media type */
+        "foo:int=1, "           /* an integer property */
+        "bar:boolean=true, "    /* a boolean property */
+        "baz:int={ 1, 3 }"      /* a list of values */
     )
     );
 
@@ -120,9 +120,10 @@ gst_example_get_type (void)
       0,
       (GInstanceInitFunc) gst_example_init,
     };
+
     example_type =
-       g_type_register_static (GST_TYPE_ELEMENT, "GstExample", &example_info,
-       0);
+        g_type_register_static (GST_TYPE_ELEMENT, "GstExample", &example_info,
+        0);
   }
   return example_type;
 }
@@ -152,7 +153,7 @@ gst_example_class_init (GstExampleClass * klass)
   /* Here we add an argument to the object.  This argument is an integer,
    * and can be both read and written.
    */
-  g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_ACTIVE, g_param_spec_int ("active", "active", "active", G_MININT, G_MAXINT, 0, G_PARAM_READWRITE));     /* CHECKME */
+  g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_ACTIVE, g_param_spec_int ("active", "active", "active", G_MININT, G_MAXINT, 0, G_PARAM_READWRITE));      /* CHECKME */
 
   /* Here we add a signal to the object. This is avery useless signal
    * called asdf. The signal will also pass a pointer to the listeners
@@ -261,7 +262,7 @@ gst_example_chain (GstPad * pad, GstData * _data)
 
     /* Then copy the data in the incoming buffer into the new buffer. */
     memcpy (GST_BUFFER_DATA (outbuf), GST_BUFFER_DATA (buf),
-       GST_BUFFER_SIZE (outbuf));
+        GST_BUFFER_SIZE (outbuf));
 
     /* we don't need the incomming buffer anymore so we unref it. When we are
      * the last plugin with a handle to the buffer, its memory will be freed */
@@ -392,7 +393,7 @@ plugin_init (GstPlugin * plugin)
    * when compared to similar plugins and the GType identifier.
    */
   if (!gst_element_register (plugin, "example", GST_RANK_MARGINAL,
-         GST_TYPE_EXAMPLE))
+          GST_TYPE_EXAMPLE))
     return FALSE;
 
   /* Now we can return successfully. */
@@ -410,16 +411,16 @@ plugin_init (GstPlugin * plugin)
  * The symbol pointing to this structure is the only symbol looked up when
  * loading the plugin.
  */
-GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,  /* The major version of the core that this was built with */
-    GST_VERSION_MINOR,         /* The minor version of the core that this was built with */
-    "example",                 /* The name of the plugin.  This must be unique: plugins with
-                                * the same name will be assumed to be identical, and only
-                                * one will be loaded. */
-    "an example plugin",       /* a short description of the plugin in English */
-    plugin_init,               /* Pointer to the initialisation function for the plugin. */
-    "0.1",                     /* The version number of the plugin */
-    "LGPL",                    /* ieffective license the plugin can be shipped with. Must be 
-                                * valid for all libraries it links to, too. */
+GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,   /* The major version of the core that this was built with */
+    GST_VERSION_MINOR,          /* The minor version of the core that this was built with */
+    "example",                  /* The name of the plugin.  This must be unique: plugins with
+                                 * the same name will be assumed to be identical, and only
+                                 * one will be loaded. */
+    "an example plugin",        /* a short description of the plugin in English */
+    plugin_init,                /* Pointer to the initialisation function for the plugin. */
+    "0.1",                      /* The version number of the plugin */
+    "LGPL",                     /* ieffective license the plugin can be shipped with. Must be 
+                                 * valid for all libraries it links to, too. */
     "my nifty plugin package",
     /* package this plugin belongs to. */
     "http://www.mydomain.com"
index 0b10fa3531367a364d9a399c4c6ae30add951cdd..84a594e7c664e11444d0ecad6d61dac6ccc8a151 100644 (file)
@@ -67,7 +67,7 @@ main (int argc, char *argv[])
   g_assert (filesink);
 
   /* set the filenames */
-  filename = g_strdup_printf ("%s.temp", argv[1]);     /* easy solution */
+  filename = g_strdup_printf ("%s.temp", argv[1]);      /* easy solution */
   g_object_set (G_OBJECT (filesrc), "location", argv[1], NULL);
   g_object_set (G_OBJECT (filesink), "location", filename, NULL);
 
index ba0d98634503db47621d1179e96d9a40d460d1fa..0913d916748f367ad72f8bf0ddee1b66b11faade 100644 (file)
@@ -75,7 +75,7 @@ main (int argc, char *argv[])
   g_assert (filesink);
 
   /* set the filenames */
-  filename = g_strdup_printf ("%s.ogg", argv[1]);      /* easy solution */
+  filename = g_strdup_printf ("%s.ogg", argv[1]);       /* easy solution */
   g_object_set (G_OBJECT (filesrc), "location", argv[1], NULL);
   g_object_set (G_OBJECT (filesink), "location", filename, NULL);
   g_free (filename);
index 119d05ec33f803764ca375216c289024feb8a77d..698ea67fbfcd54921e1526493e4788cf0db44d20 100644 (file)
@@ -14,13 +14,13 @@ xml_loaded (GstXML * xml, GstObject * object, xmlNodePtr self, gpointer data)
       xmlNodePtr nodes = children->xmlChildrenNode;
 
       while (nodes) {
-       if (!strcmp (nodes->name, "text")) {
-         gchar *name = g_strdup (xmlNodeGetContent (nodes));
+        if (!strcmp (nodes->name, "text")) {
+          gchar *name = g_strdup (xmlNodeGetContent (nodes));
 
-         g_print ("object %s loaded with comment '%s'\n",
-             gst_object_get_name (object), name);
-       }
-       nodes = nodes->next;
+          g_print ("object %s loaded with comment '%s'\n",
+              gst_object_get_name (object), name);
+        }
+        nodes = nodes->next;
       }
     }
     children = children->next;
index e8e6afc9d821f9b1d3b1d341674783df43b4c8ec..bfc251b74e999d42e53aa41b3d18dc34de24e45b 100644 (file)
@@ -92,8 +92,8 @@ gst_autoplug_can_connect_src (GstElementFactory * fac, const GstCaps * src)
 
   while (templs) {
     if ((GST_PAD_TEMPLATE_DIRECTION (templs->data) == GST_PAD_SINK) &&
-       gst_autoplug_caps_intersect (src,
-           GST_PAD_TEMPLATE_CAPS (templs->data))) {
+        gst_autoplug_caps_intersect (src,
+            GST_PAD_TEMPLATE_CAPS (templs->data))) {
       return GST_PAD_TEMPLATE (templs->data);
     }
     templs = g_list_next (templs);
@@ -122,7 +122,7 @@ gst_autoplug_can_connect_sink (GstElementFactory * fac, const GstCaps * sink)
     GstCaps *caps = GST_PAD_TEMPLATE_CAPS (templs->data);
 
     if ((GST_PAD_TEMPLATE_DIRECTION (templs->data) == GST_PAD_SRC) &&
-       gst_autoplug_caps_intersect (caps, sink)) {
+        gst_autoplug_caps_intersect (caps, sink)) {
       return GST_PAD_TEMPLATE (templs->data);
     }
     templs = g_list_next (templs);
@@ -147,13 +147,13 @@ gst_autoplug_can_match (GstElementFactory * src, GstElementFactory * dest)
       GstPadTemplate *desttemp = (GstPadTemplate *) desttemps->data;
 
       if (srctemp->direction == GST_PAD_SRC &&
-         desttemp->direction == GST_PAD_SINK) {
-       if (gst_autoplug_caps_intersect (gst_pad_template_get_caps (srctemp),
-               gst_pad_template_get_caps (desttemp))) {
-         GST_DEBUG ("factory \"%s\" can connect with factory \"%s\"",
-             GST_OBJECT_NAME (src), GST_OBJECT_NAME (dest));
-         return desttemp;
-       }
+          desttemp->direction == GST_PAD_SINK) {
+        if (gst_autoplug_caps_intersect (gst_pad_template_get_caps (srctemp),
+                gst_pad_template_get_caps (desttemp))) {
+          GST_DEBUG ("factory \"%s\" can connect with factory \"%s\"",
+              GST_OBJECT_NAME (src), GST_OBJECT_NAME (dest));
+          return desttemp;
+        }
       }
 
       desttemps = g_list_next (desttemps);
@@ -219,7 +219,7 @@ gst_autoplug_factories_filters (GList * factories)
   while (factories) {
     /* if you want it faster do src/sink check at once, don't call two functions */
     if (gst_autoplug_factory_has_src (factories->data)
-       && gst_autoplug_factory_has_sink (factories->data))
+        && gst_autoplug_factory_has_sink (factories->data))
       ret = g_list_prepend (ret, factories->data);
     factories = g_list_next (factories);
   }
@@ -256,18 +256,18 @@ gst_autoplug_factories_filters_with_sink_caps (GList * factories)
       gboolean have_sink = FALSE;
 
       while (templs) {
-       if (GST_PAD_TEMPLATE_DIRECTION (templs->data) == GST_PAD_SRC) {
-         have_src = TRUE;
-       }
-       if ((GST_PAD_TEMPLATE_DIRECTION (templs->data) == GST_PAD_SINK)
-           && (GST_PAD_TEMPLATE_CAPS (templs->data) != NULL)) {
-         have_sink = TRUE;
-       }
-       if (have_src && have_sink) {
-         ret = g_list_prepend (ret, factory);
-         break;
-       }
-       templs = g_list_next (templs);
+        if (GST_PAD_TEMPLATE_DIRECTION (templs->data) == GST_PAD_SRC) {
+          have_src = TRUE;
+        }
+        if ((GST_PAD_TEMPLATE_DIRECTION (templs->data) == GST_PAD_SINK)
+            && (GST_PAD_TEMPLATE_CAPS (templs->data) != NULL)) {
+          have_sink = TRUE;
+        }
+        if (have_src && have_sink) {
+          ret = g_list_prepend (ret, factory);
+          break;
+        }
+        templs = g_list_next (templs);
       }
     }
     factories = g_list_next (factories);
@@ -291,10 +291,10 @@ gst_autoplug_factories_at_most_templates (GList * factories,
 
     while (templs) {
       if (GST_PAD_TEMPLATE_DIRECTION (templs->data) == dir) {
-       count++;
+        count++;
       }
       if (count > maxtemplates)
-       break;
+        break;
       templs = g_list_next (templs);
     }
     if (count <= maxtemplates)
@@ -326,8 +326,8 @@ gst_autoplug_sp (const GstCaps * srccaps, const GstCaps * sinkcaps,
     GList * factories)
 {
   GList *factory_nodes = NULL;
-  guint curcost = GST_AUTOPLUG_MAX_COST;       /* below this cost, there is no path */
-  GstAutoplugNode *bestnode = NULL;    /* best (unconnected) endpoint currently */
+  guint curcost = GST_AUTOPLUG_MAX_COST;        /* below this cost, there is no path */
+  GstAutoplugNode *bestnode = NULL;     /* best (unconnected) endpoint currently */
 
   g_return_val_if_fail (srccaps != NULL, NULL);
   g_return_val_if_fail (sinkcaps != NULL, NULL);
@@ -345,15 +345,15 @@ gst_autoplug_sp (const GstCaps * srccaps, const GstCaps * sinkcaps,
     GST_DEBUG ("trying with %s", node->fac->details.longname);
     node->templ = gst_autoplug_can_connect_src (node->fac, srccaps);
     node->cost = (node->templ ? gst_autoplug_get_cost (node->fac)
-       : GST_AUTOPLUG_MAX_COST);
+        : GST_AUTOPLUG_MAX_COST);
     node->endpoint = gst_autoplug_can_connect_sink (node->fac, sinkcaps);
     if (node->templ && node->endpoint)
       GST_DEBUG ("%s makes connection possible", node->fac->details.longname);
     else
       GST_DEBUG ("direct connection with %s not possible",
-         node->fac->details.longname);
+          node->fac->details.longname);
     if ((node->endpoint != NULL) &&
-       ((bestnode == NULL) || (node->cost < bestnode->cost))) {
+        ((bestnode == NULL) || (node->cost < bestnode->cost))) {
       bestnode = node;
     }
     factory_nodes = g_list_prepend (factory_nodes, node);
@@ -372,22 +372,22 @@ gst_autoplug_sp (const GstCaps * srccaps, const GstCaps * sinkcaps,
   /* iterate until we found the best path */
   while (curcost < GST_AUTOPLUG_MAX_COST) {
     GList *nodes = factory_nodes;
-    guint nextcost = GST_AUTOPLUG_MAX_COST;    /* next cost to check */
+    guint nextcost = GST_AUTOPLUG_MAX_COST;     /* next cost to check */
 
     GST_DEBUG ("iterating at current cost %d, bestnode %s at %d", curcost,
-       GST_OBJECT_NAME (bestnode->fac), bestnode->cost);
+        GST_OBJECT_NAME (bestnode->fac), bestnode->cost);
     /* check if we already have a valid best connection to the sink */
     if (bestnode->cost <= curcost) {
       GList *ret;
 
       GST_DEBUG ("found a way to connect via %s",
-         GST_OBJECT_NAME ((GstObject *) bestnode->fac));
+          GST_OBJECT_NAME ((GstObject *) bestnode->fac));
       /* enter all factories into the return list */
       ret = g_list_prepend (NULL, bestnode->fac);
       bestnode = bestnode->prev;
       while (bestnode != NULL) {
-       ret = g_list_prepend (ret, bestnode->fac);
-       bestnode = bestnode->prev;
+        ret = g_list_prepend (ret, bestnode->fac);
+        bestnode = bestnode->prev;
       }
       g_list_free_list_and_elements (factory_nodes);
       return ret;
@@ -399,36 +399,35 @@ gst_autoplug_sp (const GstCaps * srccaps, const GstCaps * sinkcaps,
      */
     while (nodes) {
       if (((GstAutoplugNode *) nodes->data)->cost == curcost) {
-       /* now check all elements if we got a shorter path */
-       GList *sinknodes = factory_nodes;
-       GstAutoplugNode *srcnode = (GstAutoplugNode *) nodes->data;
-
-       while (sinknodes) {
-         GstAutoplugNode *sinknode = (GstAutoplugNode *) sinknodes->data;
-         GstPadTemplate *templ;
-
-         if ((sinknode->cost >
-                 srcnode->cost + gst_autoplug_get_cost (sinknode->fac))
-             && (templ =
-                 gst_autoplug_can_match (srcnode->fac, sinknode->fac))) {
-           /* we got a shorter path
-            * now enter that path to that node */
-           sinknode->prev = srcnode;
-           sinknode->templ = templ;
-           sinknode->cost =
-               srcnode->cost + gst_autoplug_get_cost (sinknode->fac);
-           /* make sure to set which cost to view next */
-           nextcost = (nextcost > sinknode->cost) ? sinknode->cost : nextcost;
-           /* did we get a new best node? */
-           if (sinknode->endpoint && (sinknode->cost < bestnode->cost)) {
-             bestnode = sinknode;
-           }
-         }
-         sinknodes = g_list_next (sinknodes);
-       }
-       /* FIXME: for speed remove the item we just iterated with from the factory_nodes
-        * but don't free it yet and don't forget to free it.
-        */
+        /* now check all elements if we got a shorter path */
+        GList *sinknodes = factory_nodes;
+        GstAutoplugNode *srcnode = (GstAutoplugNode *) nodes->data;
+
+        while (sinknodes) {
+          GstAutoplugNode *sinknode = (GstAutoplugNode *) sinknodes->data;
+          GstPadTemplate *templ;
+
+          if ((sinknode->cost >
+                  srcnode->cost + gst_autoplug_get_cost (sinknode->fac))
+              && (templ = gst_autoplug_can_match (srcnode->fac, sinknode->fac))) {
+            /* we got a shorter path
+             * now enter that path to that node */
+            sinknode->prev = srcnode;
+            sinknode->templ = templ;
+            sinknode->cost =
+                srcnode->cost + gst_autoplug_get_cost (sinknode->fac);
+            /* make sure to set which cost to view next */
+            nextcost = (nextcost > sinknode->cost) ? sinknode->cost : nextcost;
+            /* did we get a new best node? */
+            if (sinknode->endpoint && (sinknode->cost < bestnode->cost)) {
+              bestnode = sinknode;
+            }
+          }
+          sinknodes = g_list_next (sinknodes);
+        }
+        /* FIXME: for speed remove the item we just iterated with from the factory_nodes
+         * but don't free it yet and don't forget to free it.
+         */
       }
       nodes = g_list_next (nodes);
     }
index 58e98844f8588601d9ebe5ffae56c8526998f2f6..62c290fc32d4e6a129ea57ff43d785233ba1d7c2 100644 (file)
@@ -138,8 +138,9 @@ gst_spider_get_type (void)
       0,
       (GInstanceInitFunc) gst_spider_init,
     };
+
     spider_type =
-       g_type_register_static (GST_TYPE_BIN, "GstSpider", &spider_info, 0);
+        g_type_register_static (GST_TYPE_BIN, "GstSpider", &spider_info, 0);
   }
   return spider_type;
 }
@@ -158,7 +159,7 @@ gst_spider_class_init (GstSpiderClass * klass)
   /* properties */
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_FACTORIES,
       g_param_spec_pointer ("factories", "allowed factories",
-         "allowed factories for autoplugging", G_PARAM_READWRITE));
+          "allowed factories for autoplugging", G_PARAM_READWRITE));
 
   gobject_class->set_property = gst_spider_set_property;
   gobject_class->get_property = gst_spider_get_property;
@@ -251,9 +252,9 @@ gst_spider_set_property (GObject * object, guint prop_id, const GValue * value,
     case ARG_FACTORIES:
       list = (GList *) g_value_get_pointer (value);
       while (list) {
-       g_return_if_fail (list->data != NULL);
-       g_return_if_fail (GST_IS_ELEMENT_FACTORY (list->data));
-       list = g_list_next (list);
+        g_return_if_fail (list->data != NULL);
+        g_return_if_fail (GST_IS_ELEMENT_FACTORY (list->data));
+        list = g_list_next (list);
       }
       g_list_free (spider->factories);
       spider->factories = (GList *) g_value_get_pointer (value);
@@ -304,7 +305,7 @@ gst_spider_link_sometimes (GstElement * src, GstPad * pad,
   /* try to autoplug the elements */
   if (gst_spider_plug_from_srcpad (conn, pad) != GST_PAD_LINK_REFUSED) {
     GST_DEBUG ("%s:%s was autoplugged to %s:%s, removing callback",
-       GST_DEBUG_PAD_NAME (pad), GST_DEBUG_PAD_NAME (conn->src->sink));
+        GST_DEBUG_PAD_NAME (pad), GST_DEBUG_PAD_NAME (conn->src->sink));
     g_signal_handler_disconnect (src, signal_id);
     signal_id = 0;
   }
@@ -425,24 +426,24 @@ gst_spider_identity_plug (GstSpiderIdentity * ident)
 
       factories = spider->factories;
       while (factories) {
-       if ((padtemp =
-               gst_autoplug_can_connect_src (factories->data, src_caps))) {
-         const GstCaps *caps = gst_pad_template_get_caps (padtemp);
-
-         GST_DEBUG ("can connect src to pad template: %" GST_PTR_FORMAT, caps);
-         found = TRUE;
-       }
-       factories = factories->next;
+        if ((padtemp =
+                gst_autoplug_can_connect_src (factories->data, src_caps))) {
+          const GstCaps *caps = gst_pad_template_get_caps (padtemp);
+
+          GST_DEBUG ("can connect src to pad template: %" GST_PTR_FORMAT, caps);
+          found = TRUE;
+        }
+        factories = factories->next;
       }
       if (!found) {
-       const char *mime;
+        const char *mime;
 
-       mime = gst_structure_get_name (gst_caps_get_structure (src_caps, 0));
+        mime = gst_structure_get_name (gst_caps_get_structure (src_caps, 0));
 
-       GST_ELEMENT_ERROR (spider, STREAM, CODEC_NOT_FOUND,
-           (_("There is no element present to handle the stream's mime type %s."), mime), (NULL));
-       gst_caps_free (src_caps);
-       return;
+        GST_ELEMENT_ERROR (spider, STREAM, CODEC_NOT_FOUND,
+            (_("There is no element present to handle the stream's mime type %s."), mime), (NULL));
+        gst_caps_free (src_caps);
+        return;
       }
     }
     gst_caps_free (src_caps);
@@ -482,15 +483,15 @@ gst_spider_identity_plug (GstSpiderIdentity * ident)
     if (dir != GST_PAD_DIRECTION (otherpad)) {
       /* we only link to plugged in elements */
       if (peer->plugged == TRUE) {
-       /* plug in the right direction */
-       if (dir == GST_PAD_SINK) {
-         conn = gst_spider_link_get (peer);
-       } else {
-         conn = gst_spider_link_get (ident);
-       }
-       if ((GstElement *) spider->sink_ident == conn->current) {
-         gst_spider_plug (conn);
-       }
+        /* plug in the right direction */
+        if (dir == GST_PAD_SINK) {
+          conn = gst_spider_link_get (peer);
+        } else {
+          conn = gst_spider_link_get (ident);
+        }
+        if ((GstElement *) spider->sink_ident == conn->current) {
+          gst_spider_plug (conn);
+        }
       }
     }
     padlist = g_list_next (padlist);
@@ -536,9 +537,9 @@ gst_spider_create_and_plug (GstSpiderConnection * conn, GList * plugpath)
     templist = g_list_last (plugpath);
     element = (GstElement *) conn->src;
     while ((plugpath != NULL)
-       && (element =
-           gst_spider_find_element_to_plug (element,
-               (GstElementFactory *) plugpath->data, GST_PAD_SINK))) {
+        && (element =
+            gst_spider_find_element_to_plug (element,
+                (GstElementFactory *) plugpath->data, GST_PAD_SINK))) {
       GList *cur = templist;
 
       endelements = g_list_prepend (endelements, element);
@@ -549,18 +550,18 @@ gst_spider_create_and_plug (GstSpiderConnection * conn, GList * plugpath)
 
   /* do the linking */
   while (conn->current != (GstElement *) (endelements ==
-         NULL ? conn->src : endelements->data)) {
+          NULL ? conn->src : endelements->data)) {
     /* get sink element to plug, src is conn->current */
     if (plugpath == NULL) {
       element =
-         (GstElement *) (endelements == NULL ? conn->src : endelements->data);
+          (GstElement *) (endelements == NULL ? conn->src : endelements->data);
     } else {
       element =
-         gst_element_factory_create ((GstElementFactory *) plugpath->data,
-         NULL);
+          gst_element_factory_create ((GstElementFactory *) plugpath->data,
+          NULL);
       GST_DEBUG
-         ("Adding element %s of type %s and syncing state with autoplugger",
-         GST_ELEMENT_NAME (element), GST_PLUGIN_FEATURE_NAME (plugpath->data));
+          ("Adding element %s of type %s and syncing state with autoplugger",
+          GST_ELEMENT_NAME (element), GST_PLUGIN_FEATURE_NAME (plugpath->data));
       gst_bin_add (GST_BIN (spider), element);
     }
     /* insert and link new element */
@@ -572,30 +573,30 @@ gst_spider_create_and_plug (GstSpiderConnection * conn, GList * plugpath)
 
       /* remove element that couldn't be linked, if it wasn't the endpoint */
       if (element != (GstElement *) conn->src)
-       gst_bin_remove (GST_BIN (spider), element);
+        gst_bin_remove (GST_BIN (spider), element);
 
       while (templs) {
-       GstPadTemplate *templ = (GstPadTemplate *) templs->data;
-
-       if ((GST_PAD_TEMPLATE_DIRECTION (templ) == GST_PAD_SRC)
-           && (GST_PAD_TEMPLATE_PRESENCE (templ) == GST_PAD_SOMETIMES)) {
-         GST_DEBUG ("adding callback to link element %s to %s",
-             GST_ELEMENT_NAME (conn->current), GST_ELEMENT_NAME (conn->src));
-         conn->signal_id =
-             g_signal_connect (G_OBJECT (conn->current), "new_pad",
-             G_CALLBACK (gst_spider_link_sometimes), conn);
-         g_list_free (plugpath);
-         return GST_PAD_LINK_DELAYED;
-       }
-       templs = g_list_next (templs);
+        GstPadTemplate *templ = (GstPadTemplate *) templs->data;
+
+        if ((GST_PAD_TEMPLATE_DIRECTION (templ) == GST_PAD_SRC)
+            && (GST_PAD_TEMPLATE_PRESENCE (templ) == GST_PAD_SOMETIMES)) {
+          GST_DEBUG ("adding callback to link element %s to %s",
+              GST_ELEMENT_NAME (conn->current), GST_ELEMENT_NAME (conn->src));
+          conn->signal_id =
+              g_signal_connect (G_OBJECT (conn->current), "new_pad",
+              G_CALLBACK (gst_spider_link_sometimes), conn);
+          g_list_free (plugpath);
+          return GST_PAD_LINK_DELAYED;
+        }
+        templs = g_list_next (templs);
       }
       GST_DEBUG ("no chance to link element %s to %s",
-         GST_ELEMENT_NAME (conn->current), GST_ELEMENT_NAME (conn->src));
+          GST_ELEMENT_NAME (conn->current), GST_ELEMENT_NAME (conn->src));
       g_list_free (plugpath);
       return GST_PAD_LINK_REFUSED;
     }
     GST_DEBUG ("added element %s and attached it to element %s",
-       GST_ELEMENT_NAME (element), GST_ELEMENT_NAME (conn->current));
+        GST_ELEMENT_NAME (element), GST_ELEMENT_NAME (conn->current));
     gst_spider_link_add (conn, element);
     if (plugpath != NULL)
       plugpath = g_list_delete_link (plugpath, plugpath);
@@ -622,13 +623,13 @@ gst_spider_find_element_to_plug (GstElement * src, GstElementFactory * fac,
 
     /* is the pad on the right side and is it linked? */
     if ((GST_PAD_DIRECTION (pad) == dir)
-       && (pad = (GstPad *) (GST_RPAD_PEER (pad)))) {
+        && (pad = (GstPad *) (GST_RPAD_PEER (pad)))) {
       /* is the element the pad is linked to of the right type? */
       GstElement *element = GST_PAD_PARENT (pad);
 
       if (G_TYPE_FROM_INSTANCE (element) ==
-         gst_element_factory_get_element_type (fac)) {
-       return element;
+          gst_element_factory_get_element_type (fac)) {
+        return element;
       }
     }
     padlist = g_list_next (padlist);
@@ -671,7 +672,7 @@ gst_spider_plug_from_srcpad (GstSpiderConnection * conn, GstPad * srcpad)
   /* see if they match already */
   if (gst_pad_link (srcpad, conn->src->sink)) {
     GST_DEBUG ("%s:%s and %s:%s can link directly",
-       GST_DEBUG_PAD_NAME (srcpad), GST_DEBUG_PAD_NAME (conn->src->sink));
+        GST_DEBUG_PAD_NAME (srcpad), GST_DEBUG_PAD_NAME (conn->src->sink));
     gst_pad_unlink (srcpad, conn->src->sink);
     gst_spider_create_and_plug (conn, NULL);
     return GST_PAD_LINK_OK;
@@ -696,7 +697,7 @@ gst_spider_plug_from_srcpad (GstSpiderConnection * conn, GstPad * srcpad)
   /* if there is no way to plug: return */
   if (plugpath == NULL) {
     GST_DEBUG ("no chance to plug from %s to %s",
-       GST_ELEMENT_NAME (conn->current), GST_ELEMENT_NAME (conn->src));
+        GST_ELEMENT_NAME (conn->current), GST_ELEMENT_NAME (conn->src));
     return GST_PAD_LINK_REFUSED;
   }
   GST_DEBUG ("found a link that needs %d elements", g_list_length (plugpath));
@@ -708,8 +709,8 @@ gst_spider_plug_from_srcpad (GstSpiderConnection * conn, GstPad * srcpad)
   element = conn->current;
   while ((plugpath != NULL)
       && (element =
-         gst_spider_find_element_to_plug (element,
-             (GstElementFactory *) plugpath->data, GST_PAD_SRC))) {
+          gst_spider_find_element_to_plug (element,
+              (GstElementFactory *) plugpath->data, GST_PAD_SRC))) {
     gst_spider_link_add (conn, element);
     plugpath = g_list_delete_link (plugpath, plugpath);
   }
@@ -739,10 +740,10 @@ plugin_init (GstPlugin * plugin)
       "spider autoplugging element");
 
   if (!gst_element_register (plugin, "spider", GST_RANK_SECONDARY,
-         GST_TYPE_SPIDER))
+          GST_TYPE_SPIDER))
     return FALSE;
   if (!gst_element_register (plugin, "spideridentity", GST_RANK_NONE,
-         GST_TYPE_SPIDER_IDENTITY))
+          GST_TYPE_SPIDER_IDENTITY))
     return FALSE;
 
   return TRUE;
index caefdffdad92819b9d1e485653f95f8e3e62ff59..1e638d88c8392fcab618932de4c3498b66e25d9e 100644 (file)
@@ -109,11 +109,12 @@ gst_spider_identity_get_type (void)
       0,
       (GInstanceInitFunc) gst_spider_identity_init,
     };
+
     spider_identity_type =
-       g_type_register_static (GST_TYPE_ELEMENT, "GstSpiderIdentity",
-       &spider_identity_info, 0);
+        g_type_register_static (GST_TYPE_ELEMENT, "GstSpiderIdentity",
+        &spider_identity_info, 0);
     GST_DEBUG_CATEGORY_INIT (gst_spider_identity_debug, "spideridentity", 0,
-       "spider autoplugging proxy element");
+        "spider autoplugging proxy element");
   }
   return spider_identity_type;
 }
@@ -189,16 +190,16 @@ gst_spider_identity_chain (GstPad * pad, GstBuffer * buf)
       GList *list = spider->links;
 
       while (list) {
-       GstSpiderConnection *conn = (GstSpiderConnection *) list->data;
-
-       list = g_list_next (list);
-       if (conn->current != (GstElement *) conn->src) {
-         GST_DEBUG ("sending EOS to unconnected element %s from %s",
-             GST_ELEMENT_NAME (conn->src), GST_ELEMENT_NAME (ident));
-         gst_pad_push (conn->src->src,
-             GST_DATA (GST_BUFFER (gst_event_new (GST_EVENT_EOS))));
-         gst_element_set_eos (GST_ELEMENT (conn->src));
-       }
+        GstSpiderConnection *conn = (GstSpiderConnection *) list->data;
+
+        list = g_list_next (list);
+        if (conn->current != (GstElement *) conn->src) {
+          GST_DEBUG ("sending EOS to unconnected element %s from %s",
+              GST_ELEMENT_NAME (conn->src), GST_ELEMENT_NAME (ident));
+          gst_pad_push (conn->src->src,
+              GST_DATA (GST_BUFFER (gst_event_new (GST_EVENT_EOS))));
+          gst_element_set_eos (GST_ELEMENT (conn->src));
+        }
       }
     }
     /* end hack for current event stuff here */
@@ -221,8 +222,7 @@ gst_spider_identity_new_src (gchar * name)
   GstSpiderIdentity *ret =
       (GstSpiderIdentity *) gst_element_factory_make ("spideridentity", name);
   /* set the right functions */
-  gst_element_set_loop_function (GST_ELEMENT (ret),
-      (GstElementLoopFunction)
+  gst_element_set_loop_function (GST_ELEMENT (ret), (GstElementLoopFunction)
       GST_DEBUG_FUNCPTR (gst_spider_identity_src_loop));
 
   return ret;
@@ -235,8 +235,7 @@ gst_spider_identity_new_sink (gchar * name)
       (GstSpiderIdentity *) gst_element_factory_make ("spideridentity", name);
 
   /* set the right functions */
-  gst_element_set_loop_function (GST_ELEMENT (ret),
-      (GstElementLoopFunction)
+  gst_element_set_loop_function (GST_ELEMENT (ret), (GstElementLoopFunction)
       GST_DEBUG_FUNCPTR (gst_spider_identity_dumb_loop));
 
   return ret;
@@ -278,10 +277,10 @@ gst_spider_identity_getcaps (GstPad * pad)
       GstCaps *ret = gst_pad_get_allowed_caps (otherpad);
 
       if (ident->caps) {
-       GstCaps *ret2 = gst_caps_intersect (ident->caps, ret);
+        GstCaps *ret2 = gst_caps_intersect (ident->caps, ret);
 
-       gst_caps_free (ret);
-       ret = ret2;
+        gst_caps_free (ret);
+        ret = ret2;
       }
       return ret;
     }
@@ -308,29 +307,29 @@ gst_spider_identity_request_new_pad (GstElement * element,
   switch (GST_PAD_TEMPLATE_DIRECTION (templ)) {
     case GST_PAD_SINK:
       if (ident->sink != NULL)
-       break;
+        break;
       /* sink */
       GST_DEBUG ("element %s requests new sink pad", GST_ELEMENT_NAME (ident));
       ident->sink = gst_pad_new ("sink", GST_PAD_SINK);
       gst_element_add_pad (GST_ELEMENT (ident), ident->sink);
       gst_pad_set_link_function (ident->sink,
-         GST_DEBUG_FUNCPTR (gst_spider_identity_link));
+          GST_DEBUG_FUNCPTR (gst_spider_identity_link));
       gst_pad_set_getcaps_function (ident->sink,
-         GST_DEBUG_FUNCPTR (gst_spider_identity_getcaps));
+          GST_DEBUG_FUNCPTR (gst_spider_identity_getcaps));
       return ident->sink;
     case GST_PAD_SRC:
       /* src */
       if (ident->src != NULL)
-       break;
+        break;
       GST_DEBUG ("element %s requests new src pad", GST_ELEMENT_NAME (ident));
       ident->src = gst_pad_new ("src", GST_PAD_SRC);
       gst_element_add_pad (GST_ELEMENT (ident), ident->src);
       gst_pad_set_link_function (ident->src,
-         GST_DEBUG_FUNCPTR (gst_spider_identity_link));
+          GST_DEBUG_FUNCPTR (gst_spider_identity_link));
       gst_pad_set_getcaps_function (ident->src,
-         GST_DEBUG_FUNCPTR (gst_spider_identity_getcaps));
+          GST_DEBUG_FUNCPTR (gst_spider_identity_getcaps));
       gst_pad_set_event_function (ident->src,
-         GST_DEBUG_FUNCPTR (gst_spider_identity_handle_src_event));
+          GST_DEBUG_FUNCPTR (gst_spider_identity_handle_src_event));
       return ident->src;
     default:
       break;
@@ -370,22 +369,22 @@ gst_spider_identity_change_state (GstElement * element)
 
       /* start typefinding or plugging */
       if ((GST_RPAD_PEER (ident->sink) != NULL)
-         && (GST_RPAD_PEER (ident->src) == NULL)) {
-       GstCaps *caps =
-           gst_pad_get_caps ((GstPad *) GST_PAD_PEER (ident->sink));
-       if (gst_caps_is_any (caps) || gst_caps_is_empty (caps)) {
-         gst_spider_identity_start_type_finding (ident);
-         gst_caps_free (caps);
-         break;
-       } else {
-         gst_spider_identity_plug (ident);
-       }
-       gst_caps_free (caps);
+          && (GST_RPAD_PEER (ident->src) == NULL)) {
+        GstCaps *caps =
+            gst_pad_get_caps ((GstPad *) GST_PAD_PEER (ident->sink));
+        if (gst_caps_is_any (caps) || gst_caps_is_empty (caps)) {
+          gst_spider_identity_start_type_finding (ident);
+          gst_caps_free (caps);
+          break;
+        } else {
+          gst_spider_identity_plug (ident);
+        }
+        gst_caps_free (caps);
       }
       /* autoplug on src */
       if ((GST_RPAD_PEER (ident->src) != NULL)
-         && (GST_RPAD_PEER (ident->sink) == NULL)) {
-       gst_spider_identity_plug (ident);
+          && (GST_RPAD_PEER (ident->sink) == NULL)) {
+        gst_spider_identity_plug (ident);
       }
     default:
       break;
@@ -408,17 +407,16 @@ gst_spider_identity_start_type_finding (GstSpiderIdentity * ident)
   GST_DEBUG ("element %s starts typefinding", GST_ELEMENT_NAME (ident));
   if (GST_STATE (GST_ELEMENT_PARENT (ident)) == GST_STATE_PLAYING) {
     gst_element_set_state (GST_ELEMENT (GST_ELEMENT_PARENT (ident)),
-       GST_STATE_PAUSED);
+        GST_STATE_PAUSED);
     restart = TRUE;
   }
 
-  gst_element_set_loop_function (GST_ELEMENT (ident),
-      (GstElementLoopFunction)
+  gst_element_set_loop_function (GST_ELEMENT (ident), (GstElementLoopFunction)
       GST_DEBUG_FUNCPTR (gst_spider_identity_sink_loop_type_finding));
 
   if (restart) {
     gst_element_set_state (GST_ELEMENT (GST_ELEMENT_PARENT (ident)),
-       GST_STATE_PLAYING);
+        GST_STATE_PLAYING);
   }
 }
 
@@ -450,9 +448,8 @@ gst_spider_identity_src_loop (GstSpiderIdentity * ident)
 
   /* we don't want a loop function if we're plugged */
   if (ident->sink && GST_PAD_PEER (ident->sink)) {
-    gst_element_set_loop_function (GST_ELEMENT (ident),
-       (GstElementLoopFunction)
-       GST_DEBUG_FUNCPTR (gst_spider_identity_dumb_loop));
+    gst_element_set_loop_function (GST_ELEMENT (ident), (GstElementLoopFunction)
+        GST_DEBUG_FUNCPTR (gst_spider_identity_dumb_loop));
     gst_spider_identity_dumb_loop (ident);
     return;
   }
@@ -466,7 +463,8 @@ typedef struct
   GstBuffer *buffer;
   guint best_probability;
   GstCaps *caps;
-} SpiderTypeFind;
+}
+SpiderTypeFind;
 guint8 *
 spider_find_peek (gpointer data, gint64 offset, guint size)
 {
@@ -532,7 +530,7 @@ gst_spider_identity_sink_loop_type_finding (GstSpiderIdentity * ident)
     GstTypeFindFactory *factory = GST_TYPE_FIND_FACTORY (walk->data);
 
     GST_DEBUG ("trying typefind function %s",
-       GST_PLUGIN_FEATURE_NAME (factory));
+        GST_PLUGIN_FEATURE_NAME (factory));
     gst_type_find_factory_call_function (factory, &gst_find);
     if (find.best_probability >= GST_TYPE_FIND_MAXIMUM)
       goto plug;
@@ -545,8 +543,7 @@ gst_spider_identity_sink_loop_type_finding (GstSpiderIdentity * ident)
 
 end:
   /* remove loop function */
-  gst_element_set_loop_function (GST_ELEMENT (ident),
-      (GstElementLoopFunction)
+  gst_element_set_loop_function (GST_ELEMENT (ident), (GstElementLoopFunction)
       GST_DEBUG_FUNCPTR (gst_spider_identity_dumb_loop));
 
   /* push the buffer */
index c2c8e563bbebe13557d932e8bfaa8eda4f004cea..3c147c6c3099b6d2fd7150598eb9ea4259190549 100644 (file)
@@ -15,10 +15,10 @@ gst_factories_at_most_templates (GList * factories, GstPadDirection dir,
 
     while (templs) {
       if (GST_PAD_TEMPLATE_DIRECTION (templs->data) == dir) {
-       count++;
+        count++;
       }
       if (count > maxtemplates)
-       break;
+        break;
       templs = g_list_next (templs);
     }
     if (count <= maxtemplates)
@@ -33,7 +33,7 @@ static void
 property_change_callback (GObject * object, GstObject * orig,
     GParamSpec * pspec)
 {
-  GValue value = { 0, };       /* the important thing is that value.type = 0 */
+  GValue value = { 0, };        /* the important thing is that value.type = 0 */
   gchar *str = 0;
 
   if (pspec->flags & G_PARAM_READABLE) {
@@ -121,8 +121,8 @@ main (int argc, char *argv[])
 
   /* link objects */
   if (!(gst_element_link (filesrc, decoder) &&
-         gst_element_link (decoder, osssink) &&
-         gst_element_link (decoder, videosink))) {
+          gst_element_link (decoder, osssink) &&
+          gst_element_link (decoder, videosink))) {
     g_print ("the pipeline could not be linked\n");
     exit (-4);
   }
index 60e4a3a44e22609f416c72b2258c82272a5bc62c..9ce96ec55406738857cf9e607d24046f42f675ea 100644 (file)
@@ -63,7 +63,7 @@ static void cothread_destroy (cothread_state * cothread);
 
 struct _cothread_context
 {
-  cothread_state *cothreads[COTHREAD_MAXTHREADS];      /* array of cothread states */
+  cothread_state *cothreads[COTHREAD_MAXTHREADS];       /* array of cothread states */
   int ncothreads;
   int current;
   unsigned long stack_top;
@@ -112,7 +112,7 @@ cothread_context *
 cothread_context_init (void)
 {
   char __csf;
-  void *current_stack_frame = &__csf;  /* Get pointer inside current stack frame */
+  void *current_stack_frame = &__csf;   /* Get pointer inside current stack frame */
   cothread_context *ctx;
 
   /* if there already is a cotread context for this thread,
@@ -120,7 +120,7 @@ cothread_context_init (void)
   ctx = g_static_private_get (&_cothread_ctx_key);
   if (ctx) {
     GST_CAT_INFO (GST_CAT_COTHREADS,
-       "returning private _cothread_ctx_key %p", ctx);
+        "returning private _cothread_ctx_key %p", ctx);
     return ctx;
   }
 
@@ -243,7 +243,7 @@ cothread_create (cothread_context * ctx)
     if (ctx->cothreads[slot] == NULL)
       break;
     else if (ctx->cothreads[slot]->flags & COTHREAD_DESTROYED &&
-       slot != ctx->current) {
+        slot != ctx->current) {
       cothread_destroy (ctx->cothreads[slot]);
       break;
     }
@@ -263,7 +263,7 @@ cothread_create (cothread_context * ctx)
     unsigned long ptr;
 
     for (ptr = ctx->stack_top - 4096; ptr > (unsigned long) cothread;
-       ptr -= 4096) {
+        ptr -= 4096) {
       GST_CAT_DEBUG (GST_CAT_COTHREADS, "touching location 0x%08lx", ptr);
       *(volatile unsigned int *) ptr = *(volatile unsigned int *) ptr;
       GST_CAT_DEBUG (GST_CAT_COTHREADS, "ok (0x%08x)", *(unsigned int *) ptr);
@@ -478,11 +478,11 @@ cothread_stub (void)
     cothread->func (cothread->argc, cothread->argv);
 
     GST_CAT_DEBUG (GST_CAT_COTHREADS, "cothread[%d] thread->func exited",
-       ctx->current);
+        ctx->current);
 
     GST_CAT_DEBUG (GST_CAT_COTHREADS, "sp=%p", current_stack_frame);
     GST_CAT_DEBUG (GST_CAT_COTHREADS, "ctx=%p current=%p", ctx,
-       cothread_get_current_context ());
+        cothread_get_current_context ());
     g_assert (ctx == cothread_get_current_context ());
 
     g_assert (ctx->current != 0);
@@ -623,8 +623,8 @@ cothread_switch (cothread_state * cothread)
   enter = setjmp (current->jmp);
   if (enter != 0) {
     GST_CAT_DEBUG (GST_CAT_COTHREADS,
-       "enter cothread #%d %d sp=%p jmpbuf=%p",
-       current->cothreadnum, enter, current->sp, current->jmp);
+        "enter cothread #%d %d sp=%p jmpbuf=%p",
+        current->cothreadnum, enter, current->sp, current->jmp);
     return;
   }
   GST_CAT_DEBUG (GST_CAT_COTHREADS, "exit cothread #%d %d sp=%p jmpbuf=%p",
index 1ad3b2a9807176cba11bd932575bfb5827d0b0a4..f79b7b525200618a1e69b07f257264951365ea32 100644 (file)
@@ -69,9 +69,10 @@ gst_aggregator_sched_get_type (void)
     {AGGREGATOR_CHAIN, "4", "Chain Based"},
     {0, NULL, NULL},
   };
+
   if (!aggregator_sched_type) {
     aggregator_sched_type =
-       g_enum_register_static ("GstAggregatorSched", aggregator_sched);
+        g_enum_register_static ("GstAggregatorSched", aggregator_sched);
   }
   return aggregator_sched_type;
 }
@@ -117,17 +118,17 @@ gst_aggregator_class_init (GstAggregatorClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_NUM_PADS,
       g_param_spec_int ("num_pads", "Num pads", "The number of source pads",
-         0, G_MAXINT, 0, G_PARAM_READABLE));
+          0, G_MAXINT, 0, G_PARAM_READABLE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SILENT,
       g_param_spec_boolean ("silent", "Silent", "Don't produce messages",
-         FALSE, G_PARAM_READWRITE));
+          FALSE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SCHED,
       g_param_spec_enum ("sched", "Scheduling",
-         "The type of scheduling this element should use",
-         GST_TYPE_AGGREGATOR_SCHED, AGGREGATOR_CHAIN, G_PARAM_READWRITE));
+          "The type of scheduling this element should use",
+          GST_TYPE_AGGREGATOR_SCHED, AGGREGATOR_CHAIN, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LAST_MESSAGE,
       g_param_spec_string ("last_message", "Last message",
-         "The current state of the element", NULL, G_PARAM_READABLE));
+          "The current state of the element", NULL, G_PARAM_READABLE));
 
   gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_aggregator_set_property);
   gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_aggregator_get_property);
@@ -192,7 +193,7 @@ gst_aggregator_update_functions (GstAggregator * aggregator)
 
   if (AGGREGATOR_IS_LOOP_BASED (aggregator)) {
     gst_element_set_loop_function (GST_ELEMENT (aggregator),
-       GST_DEBUG_FUNCPTR (gst_aggregator_loop));
+        GST_DEBUG_FUNCPTR (gst_aggregator_loop));
   } else {
     gst_element_set_loop_function (GST_ELEMENT (aggregator), NULL);
   }
@@ -271,9 +272,9 @@ gst_aggregator_push (GstAggregator * aggregator, GstPad * pad, GstBuffer * buf,
     g_free (aggregator->last_message);
 
     aggregator->last_message =
-       g_strdup_printf ("%10.10s ******* (%s:%s)a (%d bytes, %"
-       G_GUINT64_FORMAT ")", debug, GST_DEBUG_PAD_NAME (pad),
-       GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf));
+        g_strdup_printf ("%10.10s ******* (%s:%s)a (%d bytes, %"
+        G_GUINT64_FORMAT ")", debug, GST_DEBUG_PAD_NAME (pad),
+        GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf));
 
     g_object_notify (G_OBJECT (aggregator), "last_message");
   }
@@ -306,11 +307,11 @@ gst_aggregator_loop (GstElement * element)
        * and that the peer pad is also enabled.
        */
       if (GST_PAD_IS_USABLE (pad)) {
-       buf = GST_BUFFER (gst_pad_pull (pad));
-       debug = "loop";
+        buf = GST_BUFFER (gst_pad_pull (pad));
+        debug = "loop";
 
-       /* then push it forward */
-       gst_aggregator_push (aggregator, pad, buf, debug);
+        /* then push it forward */
+        gst_aggregator_push (aggregator, pad, buf, debug);
       }
     }
   } else {
index a942f78d24a0c6cd11bf40374144148311962a8f..dcb00da9953de3efd83b3eb76476c8c286689984 100644 (file)
@@ -64,7 +64,7 @@ debug_buffers (GstBufferStore * store)
   g_printerr ("BUFFERS in store:\n");
   while (walk) {
     g_print ("%15" G_GUINT64_FORMAT " - %7u\n", GST_BUFFER_OFFSET (walk->data),
-       GST_BUFFER_SIZE (walk->data));
+        GST_BUFFER_SIZE (walk->data));
     walk = g_list_next (walk);
   }
   g_printerr ("\n");
@@ -127,14 +127,14 @@ gst_buffer_store_add_buffer_func (GstBufferStore * store, GstBuffer * buffer)
       store->buffers && GST_BUFFER_OFFSET_IS_VALID (store->buffers->data)) {
     /* we assumed valid offsets, but suddenly they are not anymore */
     GST_DEBUG_OBJECT (store,
-       "attempting to add buffer %p with invalid offset to store with valid offset, abort",
-       buffer);
+        "attempting to add buffer %p with invalid offset to store with valid offset, abort",
+        buffer);
     return FALSE;
   } else if (!store->buffers
       || !GST_BUFFER_OFFSET_IS_VALID (store->buffers->data)) {
     /* the starting buffer had an invalid offset, in that case we assume continuous buffers */
     GST_LOG_OBJECT (store, "adding buffer %p with invalid offset and size %u",
-       buffer, GST_BUFFER_SIZE (buffer));
+        buffer, GST_BUFFER_SIZE (buffer));
     gst_data_ref (GST_DATA (buffer));
     store->buffers = g_list_append (store->buffers, buffer);
     return TRUE;
@@ -145,9 +145,9 @@ gst_buffer_store_add_buffer_func (GstBufferStore * store, GstBuffer * buffer)
 
     g_assert (GST_BUFFER_OFFSET_IS_VALID (buffer));
     GST_LOG_OBJECT (store,
-       "attempting to add buffer %p with offset %" G_GUINT64_FORMAT
-       " and size %u", buffer, GST_BUFFER_OFFSET (buffer),
-       GST_BUFFER_SIZE (buffer));
+        "attempting to add buffer %p with offset %" G_GUINT64_FORMAT
+        " and size %u", buffer, GST_BUFFER_OFFSET (buffer),
+        GST_BUFFER_SIZE (buffer));
     /* we keep a sorted list of non-overlapping buffers */
     walk = store->buffers;
     while (walk) {
@@ -155,88 +155,88 @@ gst_buffer_store_add_buffer_func (GstBufferStore * store, GstBuffer * buffer)
       current_list = walk;
       walk = g_list_next (walk);
       if (GST_BUFFER_OFFSET (current) < GST_BUFFER_OFFSET (buffer)) {
-       continue;
+        continue;
       } else if (GST_BUFFER_OFFSET (current) == GST_BUFFER_OFFSET (buffer)) {
-       guint needed_size;
-
-       if (walk) {
-         needed_size = MIN (GST_BUFFER_SIZE (buffer),
-             GST_BUFFER_OFFSET (walk->data) - GST_BUFFER_OFFSET (current));
-       } else {
-         needed_size = GST_BUFFER_SIZE (buffer);
-       }
-       if (needed_size <= GST_BUFFER_SIZE (current)) {
-         buffer = NULL;
-         break;
-       } else {
-         if (needed_size < GST_BUFFER_SIZE (buffer)) {
-           /* need to create subbuffer to not have overlapping data */
-           GstBuffer *sub = gst_buffer_create_sub (buffer, 0, needed_size);
-
-           g_assert (sub);
-           buffer = sub;
-         } else {
-           gst_data_ref (GST_DATA (buffer));
-         }
-         /* replace current buffer with new one */
-         GST_INFO_OBJECT (store,
-             "replacing buffer %p with buffer %p with offset %" G_GINT64_FORMAT
-             " and size %u", current_list->data, buffer,
-             GST_BUFFER_OFFSET (buffer), GST_BUFFER_SIZE (buffer));
-         gst_data_unref (GST_DATA (current_list->data));
-         current_list->data = buffer;
-         buffer = NULL;
-         break;
-       }
+        guint needed_size;
+
+        if (walk) {
+          needed_size = MIN (GST_BUFFER_SIZE (buffer),
+              GST_BUFFER_OFFSET (walk->data) - GST_BUFFER_OFFSET (current));
+        } else {
+          needed_size = GST_BUFFER_SIZE (buffer);
+        }
+        if (needed_size <= GST_BUFFER_SIZE (current)) {
+          buffer = NULL;
+          break;
+        } else {
+          if (needed_size < GST_BUFFER_SIZE (buffer)) {
+            /* need to create subbuffer to not have overlapping data */
+            GstBuffer *sub = gst_buffer_create_sub (buffer, 0, needed_size);
+
+            g_assert (sub);
+            buffer = sub;
+          } else {
+            gst_data_ref (GST_DATA (buffer));
+          }
+          /* replace current buffer with new one */
+          GST_INFO_OBJECT (store,
+              "replacing buffer %p with buffer %p with offset %" G_GINT64_FORMAT
+              " and size %u", current_list->data, buffer,
+              GST_BUFFER_OFFSET (buffer), GST_BUFFER_SIZE (buffer));
+          gst_data_unref (GST_DATA (current_list->data));
+          current_list->data = buffer;
+          buffer = NULL;
+          break;
+        }
       } else if (GST_BUFFER_OFFSET (current) > GST_BUFFER_OFFSET (buffer)) {
-       GList *previous = g_list_previous (current_list);
-       guint64 start_offset = previous ?
-           GST_BUFFER_OFFSET (previous->data) +
-           GST_BUFFER_SIZE (previous->data) : 0;
-
-       if (start_offset == GST_BUFFER_OFFSET (current)) {
-         buffer = NULL;
-         break;
-       } else {
-         /* we have data to insert */
-         if (start_offset > GST_BUFFER_OFFSET (buffer) ||
-             GST_BUFFER_OFFSET (buffer) + GST_BUFFER_SIZE (buffer) >
-             GST_BUFFER_OFFSET (current)) {
-           GstBuffer *sub;
-
-           /* need a subbuffer */
-           start_offset = GST_BUFFER_OFFSET (buffer) > start_offset ? 0 :
-               start_offset - GST_BUFFER_OFFSET (buffer);
-           sub = gst_buffer_create_sub (buffer, start_offset,
-               MIN (GST_BUFFER_SIZE (buffer),
-                   GST_BUFFER_OFFSET (current) - start_offset -
-                   GST_BUFFER_OFFSET (buffer)));
-           g_assert (sub);
-           GST_BUFFER_OFFSET (sub) = start_offset + GST_BUFFER_OFFSET (buffer);
-           buffer = sub;
-         } else {
-           gst_data_ref (GST_DATA (buffer));
-         }
-         GST_INFO_OBJECT (store,
-             "adding buffer %p with offset %" G_GINT64_FORMAT " and size %u",
-             buffer, GST_BUFFER_OFFSET (buffer), GST_BUFFER_SIZE (buffer));
-         store->buffers =
-             g_list_insert_before (store->buffers, current_list, buffer);
-         buffer = NULL;
-         break;
-       }
+        GList *previous = g_list_previous (current_list);
+        guint64 start_offset = previous ?
+            GST_BUFFER_OFFSET (previous->data) +
+            GST_BUFFER_SIZE (previous->data) : 0;
+
+        if (start_offset == GST_BUFFER_OFFSET (current)) {
+          buffer = NULL;
+          break;
+        } else {
+          /* we have data to insert */
+          if (start_offset > GST_BUFFER_OFFSET (buffer) ||
+              GST_BUFFER_OFFSET (buffer) + GST_BUFFER_SIZE (buffer) >
+              GST_BUFFER_OFFSET (current)) {
+            GstBuffer *sub;
+
+            /* need a subbuffer */
+            start_offset = GST_BUFFER_OFFSET (buffer) > start_offset ? 0 :
+                start_offset - GST_BUFFER_OFFSET (buffer);
+            sub = gst_buffer_create_sub (buffer, start_offset,
+                MIN (GST_BUFFER_SIZE (buffer),
+                    GST_BUFFER_OFFSET (current) - start_offset -
+                    GST_BUFFER_OFFSET (buffer)));
+            g_assert (sub);
+            GST_BUFFER_OFFSET (sub) = start_offset + GST_BUFFER_OFFSET (buffer);
+            buffer = sub;
+          } else {
+            gst_data_ref (GST_DATA (buffer));
+          }
+          GST_INFO_OBJECT (store,
+              "adding buffer %p with offset %" G_GINT64_FORMAT " and size %u",
+              buffer, GST_BUFFER_OFFSET (buffer), GST_BUFFER_SIZE (buffer));
+          store->buffers =
+              g_list_insert_before (store->buffers, current_list, buffer);
+          buffer = NULL;
+          break;
+        }
       }
     }
     if (buffer) {
       gst_data_ref (GST_DATA (buffer));
       GST_INFO_OBJECT (store,
-         "adding buffer %p with offset %" G_GINT64_FORMAT " and size %u",
-         buffer, GST_BUFFER_OFFSET (buffer), GST_BUFFER_SIZE (buffer));
+          "adding buffer %p with offset %" G_GINT64_FORMAT " and size %u",
+          buffer, GST_BUFFER_OFFSET (buffer), GST_BUFFER_SIZE (buffer));
       if (current_list) {
-       g_list_append (current_list, buffer);
+        g_list_append (current_list, buffer);
       } else {
-       g_assert (store->buffers == NULL);
-       store->buffers = g_list_prepend (NULL, buffer);
+        g_assert (store->buffers == NULL);
+        store->buffers = g_list_prepend (NULL, buffer);
       }
     }
     return TRUE;
@@ -352,47 +352,47 @@ gst_buffer_store_get_buffer (GstBufferStore * store, guint64 offset, guint size)
          do_nothing_loop (); */
     } else if (cur_offset == offset && GST_BUFFER_SIZE (current) == size) {
       GST_LOG_OBJECT (store,
-         "found matching buffer %p for offset %" G_GUINT64_FORMAT
-         " and size %u", current, offset, size);
+          "found matching buffer %p for offset %" G_GUINT64_FORMAT
+          " and size %u", current, offset, size);
       ret = current;
       gst_data_ref (GST_DATA (ret));
       GST_LOG_OBJECT (store, "refcount %d", GST_DATA_REFCOUNT_VALUE (ret));
       break;
     } else if (cur_offset + GST_BUFFER_SIZE (current) > offset) {
       if (cur_offset + GST_BUFFER_SIZE (current) >= offset + size) {
-       ret = gst_buffer_create_sub (current, offset - cur_offset, size);
-       GST_LOG_OBJECT (store,
-           "created subbuffer %p from buffer %p for offset %llu and size %u",
-           ret, current, offset, size);
-       break;
+        ret = gst_buffer_create_sub (current, offset - cur_offset, size);
+        GST_LOG_OBJECT (store,
+            "created subbuffer %p from buffer %p for offset %llu and size %u",
+            ret, current, offset, size);
+        break;
       }
       /* uh, the requested data spans some buffers */
       ret = gst_buffer_new_and_alloc (size);
       GST_LOG_OBJECT (store, "created buffer %p for offset %" G_GUINT64_FORMAT
-         " and size %u, will fill with data now", ret, offset, size);
+          " and size %u, will fill with data now", ret, offset, size);
       data = GST_BUFFER_DATA (ret);
       tmp = GST_BUFFER_SIZE (current) - offset + cur_offset;
       memcpy (data, GST_BUFFER_DATA (current) + offset - cur_offset, tmp);
       data += tmp;
       size -= tmp;
       while (size) {
-       if (walk == NULL ||
-           (have_offset &&
-               GST_BUFFER_OFFSET (current) + GST_BUFFER_SIZE (current) !=
-               GST_BUFFER_OFFSET (walk->data))) {
-         GST_DEBUG_OBJECT (store,
-             "not all data for offset %" G_GUINT64_FORMAT
-             " and remaining size %u available, aborting", offset, size);
-         gst_data_unref (GST_DATA (ret));
-         ret = NULL;
-         goto out;
-       }
-       current = GST_BUFFER (walk->data);
-       walk = g_list_next (walk);
-       tmp = MIN (GST_BUFFER_SIZE (current), size);
-       memcpy (data, GST_BUFFER_DATA (current), tmp);
-       data += tmp;
-       size -= tmp;
+        if (walk == NULL ||
+            (have_offset &&
+                GST_BUFFER_OFFSET (current) + GST_BUFFER_SIZE (current) !=
+                GST_BUFFER_OFFSET (walk->data))) {
+          GST_DEBUG_OBJECT (store,
+              "not all data for offset %" G_GUINT64_FORMAT
+              " and remaining size %u available, aborting", offset, size);
+          gst_data_unref (GST_DATA (ret));
+          ret = NULL;
+          goto out;
+        }
+        current = GST_BUFFER (walk->data);
+        walk = g_list_next (walk);
+        tmp = MIN (GST_BUFFER_SIZE (current), size);
+        memcpy (data, GST_BUFFER_DATA (current), tmp);
+        data += tmp;
+        size -= tmp;
       }
     }
     if (!have_offset) {
@@ -437,8 +437,8 @@ gst_buffer_store_get_size (GstBufferStore * store, guint64 offset)
   }
   while (walk) {
     if (have_offset && counting &&
-       cur_offset + GST_BUFFER_SIZE (current) !=
-       GST_BUFFER_OFFSET (walk->data)) {
+        cur_offset + GST_BUFFER_SIZE (current) !=
+        GST_BUFFER_OFFSET (walk->data)) {
       break;
     }
     current = GST_BUFFER (walk->data);
@@ -450,11 +450,11 @@ gst_buffer_store_get_size (GstBufferStore * store, guint64 offset)
       ret += GST_BUFFER_SIZE (current);
     } else {
       if (cur_offset > offset)
-       return 0;
+        return 0;
       if (cur_offset + GST_BUFFER_SIZE (current) > offset) {
-       /* we have at least some bytes */
-       ret = cur_offset + GST_BUFFER_SIZE (current) - offset;
-       counting = TRUE;
+        /* we have at least some bytes */
+        ret = cur_offset + GST_BUFFER_SIZE (current) - offset;
+        counting = TRUE;
       }
     }
     if (!have_offset) {
index 12e19d4c73868e2be8ce62aff074bc608a50dc13..8c9af2f06d42ff827e1ebbd2aeed11baff6c1730 100644 (file)
@@ -81,7 +81,7 @@ plugin_init (GstPlugin * plugin)
 
   while ((*my_elements).name) {
     if (!gst_element_register (plugin, (*my_elements).name, (*my_elements).rank,
-           ((*my_elements).type) ()))
+            ((*my_elements).type) ()))
       return FALSE;
     my_elements++;
   }
index 78ecac6cf2cc5427198492608c5e6c42362e3db1..6778cfb72bec1dbc3077467c3867b92a832733bd 100644 (file)
@@ -70,22 +70,23 @@ gst_fakesink_state_error_get_type (void)
   static GEnumValue fakesink_state_error[] = {
     {FAKESINK_STATE_ERROR_NONE, "0", "No state change errors"},
     {FAKESINK_STATE_ERROR_NULL_READY, "1",
-         "Fail state change from NULL to READY"},
+        "Fail state change from NULL to READY"},
     {FAKESINK_STATE_ERROR_READY_PAUSED, "2",
-         "Fail state change from READY to PAUSED"},
+        "Fail state change from READY to PAUSED"},
     {FAKESINK_STATE_ERROR_PAUSED_PLAYING, "3",
-         "Fail state change from PAUSED to PLAYING"},
+        "Fail state change from PAUSED to PLAYING"},
     {FAKESINK_STATE_ERROR_PLAYING_PAUSED, "4",
-         "Fail state change from PLAYING to PAUSED"},
+        "Fail state change from PLAYING to PAUSED"},
     {FAKESINK_STATE_ERROR_PAUSED_READY, "5",
-         "Fail state change from PAUSED to READY"},
+        "Fail state change from PAUSED to READY"},
     {FAKESINK_STATE_ERROR_READY_NULL, "6",
-         "Fail state change from READY to NULL"},
+        "Fail state change from READY to NULL"},
     {0, NULL, NULL},
   };
+
   if (!fakesink_state_error_type) {
     fakesink_state_error_type =
-       g_enum_register_static ("GstFakeSinkStateError", fakesink_state_error);
+        g_enum_register_static ("GstFakeSinkStateError", fakesink_state_error);
   }
   return fakesink_state_error_type;
 }
@@ -133,27 +134,27 @@ gst_fakesink_class_init (GstFakeSinkClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_NUM_SINKS,
       g_param_spec_int ("num_sinks", "Number of sinks",
-         "The number of sinkpads", 1, G_MAXINT, 1, G_PARAM_READABLE));
+          "The number of sinkpads", 1, G_MAXINT, 1, G_PARAM_READABLE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_STATE_ERROR,
       g_param_spec_enum ("state_error", "State Error",
-         "Generate a state change error", GST_TYPE_FAKESINK_STATE_ERROR,
-         FAKESINK_STATE_ERROR_NONE, G_PARAM_READWRITE));
+          "Generate a state change error", GST_TYPE_FAKESINK_STATE_ERROR,
+          FAKESINK_STATE_ERROR_NONE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LAST_MESSAGE,
       g_param_spec_string ("last_message", "Last Message",
-         "The message describing current status", NULL, G_PARAM_READABLE));
+          "The message describing current status", NULL, G_PARAM_READABLE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SYNC,
       g_param_spec_boolean ("sync", "Sync", "Sync on the clock", FALSE,
-         G_PARAM_READWRITE));
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SIGNAL_HANDOFFS,
       g_param_spec_boolean ("signal-handoffs", "Signal handoffs",
-         "Send a signal before unreffing the buffer", FALSE,
-         G_PARAM_READWRITE));
+          "Send a signal before unreffing the buffer", FALSE,
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SILENT,
       g_param_spec_boolean ("silent", "Silent",
-         "Don't produce last_message events", FALSE, G_PARAM_READWRITE));
+          "Don't produce last_message events", FALSE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_DUMP,
       g_param_spec_boolean ("dump", "Dump", "Dump received bytes to stdout",
-         FALSE, G_PARAM_READWRITE));
+          FALSE, G_PARAM_READWRITE));
 
   gst_fakesink_signals[SIGNAL_HANDOFF] =
       g_signal_new ("handoff", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_LAST,
@@ -316,22 +317,22 @@ gst_fakesink_chain (GstPad * pad, GstData * _data)
       g_free (fakesink->last_message);
 
       fakesink->last_message =
-         g_strdup_printf ("chain   ******* (%s:%s)E (type: %d) %p",
-         GST_DEBUG_PAD_NAME (pad), GST_EVENT_TYPE (event), event);
+          g_strdup_printf ("chain   ******* (%s:%s)E (type: %d) %p",
+          GST_DEBUG_PAD_NAME (pad), GST_EVENT_TYPE (event), event);
 
       g_object_notify (G_OBJECT (fakesink), "last_message");
     }
 
     switch (GST_EVENT_TYPE (event)) {
       case GST_EVENT_DISCONTINUOUS:
-       if (fakesink->sync && fakesink->clock) {
-         gint64 value = GST_EVENT_DISCONT_OFFSET (event, 0).value;
+        if (fakesink->sync && fakesink->clock) {
+          gint64 value = GST_EVENT_DISCONT_OFFSET (event, 0).value;
 
-         gst_element_set_time (GST_ELEMENT (fakesink), value);
-       }
+          gst_element_set_time (GST_ELEMENT (fakesink), value);
+        }
       default:
-       gst_pad_event_default (pad, event);
-       break;
+        gst_pad_event_default (pad, event);
+        break;
     }
     return;
   }
@@ -344,19 +345,19 @@ gst_fakesink_chain (GstPad * pad, GstData * _data)
     g_free (fakesink->last_message);
 
     fakesink->last_message =
-       g_strdup_printf ("chain   ******* (%s:%s)< (%d bytes, timestamp: %"
-       G_GINT64_FORMAT ", duration: %" G_GINT64_FORMAT ", offset: %"
-       G_GINT64_FORMAT ", flags: %d) %p", GST_DEBUG_PAD_NAME (pad),
-       GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf),
-       GST_BUFFER_DURATION (buf), GST_BUFFER_OFFSET (buf),
-       GST_BUFFER_FLAGS (buf), buf);
+        g_strdup_printf ("chain   ******* (%s:%s)< (%d bytes, timestamp: %"
+        G_GINT64_FORMAT ", duration: %" G_GINT64_FORMAT ", offset: %"
+        G_GINT64_FORMAT ", flags: %d) %p", GST_DEBUG_PAD_NAME (pad),
+        GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf),
+        GST_BUFFER_DURATION (buf), GST_BUFFER_OFFSET (buf),
+        GST_BUFFER_FLAGS (buf), buf);
 
     g_object_notify (G_OBJECT (fakesink), "last_message");
   }
 
   if (fakesink->signal_handoffs)
     g_signal_emit (G_OBJECT (fakesink), gst_fakesink_signals[SIGNAL_HANDOFF], 0,
-       buf, pad);
+        buf, pad);
 
   if (fakesink->dump) {
     gst_util_dump_mem (GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf));
@@ -373,27 +374,27 @@ gst_fakesink_change_state (GstElement * element)
   switch (GST_STATE_TRANSITION (element)) {
     case GST_STATE_NULL_TO_READY:
       if (fakesink->state_error == FAKESINK_STATE_ERROR_NULL_READY)
-       goto error;
+        goto error;
       break;
     case GST_STATE_READY_TO_PAUSED:
       if (fakesink->state_error == FAKESINK_STATE_ERROR_READY_PAUSED)
-       goto error;
+        goto error;
       break;
     case GST_STATE_PAUSED_TO_PLAYING:
       if (fakesink->state_error == FAKESINK_STATE_ERROR_PAUSED_PLAYING)
-       goto error;
+        goto error;
       break;
     case GST_STATE_PLAYING_TO_PAUSED:
       if (fakesink->state_error == FAKESINK_STATE_ERROR_PLAYING_PAUSED)
-       goto error;
+        goto error;
       break;
     case GST_STATE_PAUSED_TO_READY:
       if (fakesink->state_error == FAKESINK_STATE_ERROR_PAUSED_READY)
-       goto error;
+        goto error;
       break;
     case GST_STATE_READY_TO_NULL:
       if (fakesink->state_error == FAKESINK_STATE_ERROR_READY_NULL)
-       goto error;
+        goto error;
       g_free (fakesink->last_message);
       fakesink->last_message = NULL;
       break;
index 2443b81321a680b0bdc156e8937a335c13cacc4e..1901d217b31ee4fd5a76da8532bf6abb2f76e2ad 100644 (file)
@@ -95,9 +95,10 @@ gst_fakesrc_output_get_type (void)
     {FAKESRC_GET_ALWAYS_SUCEEDS, "8", "'_get' Always succeeds"},
     {0, NULL, NULL},
   };
+
   if (!fakesrc_output_type) {
     fakesrc_output_type =
-       g_enum_register_static ("GstFakeSrcOutput", fakesrc_output);
+        g_enum_register_static ("GstFakeSrcOutput", fakesrc_output);
   }
   return fakesrc_output_type;
 }
@@ -112,6 +113,7 @@ gst_fakesrc_data_get_type (void)
     {FAKESRC_DATA_SUBBUFFER, "2", "Subbuffer data"},
     {0, NULL, NULL},
   };
+
   if (!fakesrc_data_type) {
     fakesrc_data_type = g_enum_register_static ("GstFakeSrcData", fakesrc_data);
   }
@@ -127,12 +129,13 @@ gst_fakesrc_sizetype_get_type (void)
     {FAKESRC_SIZETYPE_NULL, "1", "Send empty buffers"},
     {FAKESRC_SIZETYPE_FIXED, "2", "Fixed size buffers (sizemax sized)"},
     {FAKESRC_SIZETYPE_RANDOM, "3",
-         "Random sized buffers (sizemin <= size <= sizemax)"},
+        "Random sized buffers (sizemin <= size <= sizemax)"},
     {0, NULL, NULL},
   };
+
   if (!fakesrc_sizetype_type) {
     fakesrc_sizetype_type =
-       g_enum_register_static ("GstFakeSrcSizeType", fakesrc_sizetype);
+        g_enum_register_static ("GstFakeSrcSizeType", fakesrc_sizetype);
   }
   return fakesrc_sizetype_type;
 }
@@ -148,12 +151,13 @@ gst_fakesrc_filltype_get_type (void)
     {FAKESRC_FILLTYPE_RANDOM, "3", "Fill buffers with random crap"},
     {FAKESRC_FILLTYPE_PATTERN, "4", "Fill buffers with pattern 0x00 -> 0xff"},
     {FAKESRC_FILLTYPE_PATTERN_CONT, "5",
-         "Fill buffers with pattern 0x00 -> 0xff that spans buffers"},
+        "Fill buffers with pattern 0x00 -> 0xff that spans buffers"},
     {0, NULL, NULL},
   };
+
   if (!fakesrc_filltype_type) {
     fakesrc_filltype_type =
-       g_enum_register_static ("GstFakeSrcFillType", fakesrc_filltype);
+        g_enum_register_static ("GstFakeSrcFillType", fakesrc_filltype);
   }
   return fakesrc_filltype_type;
 }
@@ -201,56 +205,56 @@ gst_fakesrc_class_init (GstFakeSrcClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_NUM_SOURCES,
       g_param_spec_int ("num-sources", "num-sources", "Number of sources",
-         1, G_MAXINT, 1, G_PARAM_READABLE));
+          1, G_MAXINT, 1, G_PARAM_READABLE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LOOP_BASED,
       g_param_spec_boolean ("loop-based", "loop-based",
-         "Enable loop-based operation", FALSE, G_PARAM_READWRITE));
+          "Enable loop-based operation", FALSE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_OUTPUT,
       g_param_spec_enum ("output", "output", "Output method (currently unused)",
-         GST_TYPE_FAKESRC_OUTPUT, FAKESRC_FIRST_LAST_LOOP, G_PARAM_READWRITE));
+          GST_TYPE_FAKESRC_OUTPUT, FAKESRC_FIRST_LAST_LOOP, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_DATA,
       g_param_spec_enum ("data", "data", "Data allocation method",
-         GST_TYPE_FAKESRC_DATA, FAKESRC_DATA_ALLOCATE, G_PARAM_READWRITE));
+          GST_TYPE_FAKESRC_DATA, FAKESRC_DATA_ALLOCATE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SIZETYPE,
       g_param_spec_enum ("sizetype", "sizetype",
-         "How to determine buffer sizes", GST_TYPE_FAKESRC_SIZETYPE,
-         FAKESRC_SIZETYPE_NULL, G_PARAM_READWRITE));
+          "How to determine buffer sizes", GST_TYPE_FAKESRC_SIZETYPE,
+          FAKESRC_SIZETYPE_NULL, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SIZEMIN,
       g_param_spec_int ("sizemin", "sizemin", "Minimum buffer size", 0,
-         G_MAXINT, DEFAULT_SIZEMIN, G_PARAM_READWRITE));
+          G_MAXINT, DEFAULT_SIZEMIN, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SIZEMAX,
       g_param_spec_int ("sizemax", "sizemax", "Maximum buffer size", 0,
-         G_MAXINT, DEFAULT_SIZEMAX, G_PARAM_READWRITE));
+          G_MAXINT, DEFAULT_SIZEMAX, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_PARENTSIZE,
       g_param_spec_int ("parentsize", "parentsize",
-         "Size of parent buffer for sub-buffered allocation", 0, G_MAXINT,
-         DEFAULT_PARENTSIZE, G_PARAM_READWRITE));
+          "Size of parent buffer for sub-buffered allocation", 0, G_MAXINT,
+          DEFAULT_PARENTSIZE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_FILLTYPE,
       g_param_spec_enum ("filltype", "filltype",
-         "How to fill the buffer, if at all", GST_TYPE_FAKESRC_FILLTYPE,
-         FAKESRC_FILLTYPE_NULL, G_PARAM_READWRITE));
+          "How to fill the buffer, if at all", GST_TYPE_FAKESRC_FILLTYPE,
+          FAKESRC_FILLTYPE_NULL, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_PATTERN,
       g_param_spec_string ("pattern", "pattern", "pattern", NULL,
-         G_PARAM_READWRITE));
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_NUM_BUFFERS,
       g_param_spec_int ("num-buffers", "num-buffers",
-         "Number of buffers to output before sending EOS", G_MININT, G_MAXINT,
-         0, G_PARAM_READWRITE));
+          "Number of buffers to output before sending EOS", G_MININT, G_MAXINT,
+          0, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_EOS,
       g_param_spec_boolean ("eos", "eos", "Send out the EOS event?", TRUE,
-         G_PARAM_READWRITE));
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LAST_MESSAGE,
       g_param_spec_string ("last-message", "last-message",
-         "The last status message", NULL, G_PARAM_READABLE));
+          "The last status message", NULL, G_PARAM_READABLE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SILENT,
       g_param_spec_boolean ("silent", "Silent",
-         "Don't produce last_message events", FALSE, G_PARAM_READWRITE));
+          "Don't produce last_message events", FALSE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SIGNAL_HANDOFFS,
       g_param_spec_boolean ("signal-handoffs", "Signal handoffs",
-         "Send a signal before pushing the buffer", FALSE, G_PARAM_READWRITE));
+          "Send a signal before pushing the buffer", FALSE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_DUMP,
       g_param_spec_boolean ("dump", "Dump", "Dump produced bytes to stdout",
-         FALSE, G_PARAM_READWRITE));
+          FALSE, G_PARAM_READWRITE));
 
   gst_fakesrc_signals[SIGNAL_HANDOFF] =
       g_signal_new ("handoff", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_LAST,
@@ -334,6 +338,7 @@ gst_fakesrc_get_formats (GstPad * pad)
     GST_FORMAT_DEFAULT,
     0,
   };
+
   return formats;
 }
 
@@ -347,6 +352,7 @@ gst_fakesrc_get_query_types (GstPad * pad)
     GST_QUERY_SEGMENT_END,
     0,
   };
+
   return types;
 }
 
@@ -384,6 +390,7 @@ gst_fakesrc_get_event_mask (GstPad * pad)
     {GST_EVENT_FLUSH, 0},
     {0, 0},
   };
+
   return masks;
 }
 
@@ -399,7 +406,7 @@ gst_fakesrc_event_handler (GstPad * pad, GstEvent * event)
       src->buffer_count = GST_EVENT_SEEK_OFFSET (event);
 
       if (!GST_EVENT_SEEK_FLAGS (event) & GST_SEEK_FLAG_FLUSH) {
-       break;
+        break;
       }
       /* else we do a flush too */
     case GST_EVENT_SEEK_SEGMENT:
@@ -407,7 +414,7 @@ gst_fakesrc_event_handler (GstPad * pad, GstEvent * event)
       src->segment_end = GST_EVENT_SEEK_ENDOFFSET (event);
       src->buffer_count = src->segment_start;
       src->segment_loop =
-         GST_EVENT_SEEK_FLAGS (event) & GST_SEEK_FLAG_SEGMENT_LOOP;
+          GST_EVENT_SEEK_FLAGS (event) & GST_SEEK_FLAG_SEGMENT_LOOP;
       break;
     case GST_EVENT_FLUSH:
       src->need_flush = TRUE;
@@ -427,7 +434,7 @@ gst_fakesrc_update_functions (GstFakeSrc * src)
 
   if (src->loop_based) {
     gst_element_set_loop_function (GST_ELEMENT (src),
-       GST_DEBUG_FUNCPTR (gst_fakesrc_loop));
+        GST_DEBUG_FUNCPTR (gst_fakesrc_loop));
   } else {
     gst_element_set_loop_function (GST_ELEMENT (src), NULL);
   }
@@ -485,13 +492,13 @@ gst_fakesrc_set_property (GObject * object, guint prop_id, const GValue * value,
       src->data = g_value_get_enum (value);
 
       if (src->data == FAKESRC_DATA_SUBBUFFER) {
-       if (!src->parent)
-         gst_fakesrc_alloc_parent (src);
+        if (!src->parent)
+          gst_fakesrc_alloc_parent (src);
       } else {
-       if (src->parent) {
-         gst_buffer_unref (src->parent);
-         src->parent = NULL;
-       }
+        if (src->parent) {
+          gst_buffer_unref (src->parent);
+          src->parent = NULL;
+        }
       }
       break;
     case ARG_SIZETYPE:
@@ -614,7 +621,7 @@ gst_fakesrc_prepare_buffer (GstFakeSrc * src, GstBuffer * buf)
       guint8 *ptr = GST_BUFFER_DATA (buf);
 
       for (i = GST_BUFFER_SIZE (buf); i; i--) {
-       *ptr++ = (gint8) ((255.0) * rand () / (RAND_MAX));
+        *ptr++ = (gint8) ((255.0) * rand () / (RAND_MAX));
       }
       break;
     }
@@ -626,7 +633,7 @@ gst_fakesrc_prepare_buffer (GstFakeSrc * src, GstBuffer * buf)
       guint8 *ptr = GST_BUFFER_DATA (buf);
 
       for (i = GST_BUFFER_SIZE (buf); i; i--) {
-       *ptr++ = src->pattern_byte++;
+        *ptr++ = src->pattern_byte++;
       }
       break;
     }
@@ -647,18 +654,18 @@ gst_fakesrc_alloc_buffer (GstFakeSrc * src, guint size)
   if (size != 0) {
     switch (src->filltype) {
       case FAKESRC_FILLTYPE_NOTHING:
-       GST_BUFFER_DATA (buf) = g_malloc (size);
-       break;
+        GST_BUFFER_DATA (buf) = g_malloc (size);
+        break;
       case FAKESRC_FILLTYPE_NULL:
-       GST_BUFFER_DATA (buf) = g_malloc0 (size);
-       break;
+        GST_BUFFER_DATA (buf) = g_malloc0 (size);
+        break;
       case FAKESRC_FILLTYPE_RANDOM:
       case FAKESRC_FILLTYPE_PATTERN:
       case FAKESRC_FILLTYPE_PATTERN_CONT:
       default:
-       GST_BUFFER_DATA (buf) = g_malloc (size);
-       gst_fakesrc_prepare_buffer (src, buf);
-       break;
+        GST_BUFFER_DATA (buf) = g_malloc (size);
+        gst_fakesrc_prepare_buffer (src, buf);
+        break;
     }
   }
 
@@ -676,9 +683,9 @@ gst_fakesrc_get_size (GstFakeSrc * src)
       break;
     case FAKESRC_SIZETYPE_RANDOM:
       size =
-         src->sizemin +
-         (guint8) (((gfloat) src->sizemax) * rand () / (RAND_MAX +
-             (gfloat) src->sizemin));
+          src->sizemin +
+          (guint8) (((gfloat) src->sizemax) * rand () / (RAND_MAX +
+              (gfloat) src->sizemin));
       break;
     case FAKESRC_SIZETYPE_NULL:
     default:
@@ -707,19 +714,19 @@ gst_fakesrc_create_buffer (GstFakeSrc * src)
     case FAKESRC_DATA_SUBBUFFER:
       /* see if we have a parent to subbuffer */
       if (!src->parent) {
-       gst_fakesrc_alloc_parent (src);
-       g_assert (src->parent);
+        gst_fakesrc_alloc_parent (src);
+        g_assert (src->parent);
       }
       /* see if it's large enough */
       if ((GST_BUFFER_SIZE (src->parent) - src->parentoffset) >= size) {
-       buf = gst_buffer_create_sub (src->parent, src->parentoffset, size);
-       src->parentoffset += size;
+        buf = gst_buffer_create_sub (src->parent, src->parentoffset, size);
+        src->parentoffset += size;
       } else {
-       /* the parent is useless now */
-       gst_buffer_unref (src->parent);
-       src->parent = NULL;
-       /* try again (this will allocate a new parent) */
-       return gst_fakesrc_create_buffer (src);
+        /* the parent is useless now */
+        gst_buffer_unref (src->parent);
+        src->parent = NULL;
+        /* try again (this will allocate a new parent) */
+        return gst_fakesrc_create_buffer (src);
       }
       gst_fakesrc_prepare_buffer (src, buf);
       break;
@@ -781,9 +788,9 @@ gst_fakesrc_get (GstPad * pad)
     g_free (src->last_message);
 
     src->last_message =
-       g_strdup_printf ("get      ******* (%s:%s)> (%d bytes, %"
-       G_GUINT64_FORMAT " ) %p", GST_DEBUG_PAD_NAME (pad),
-       GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf), buf);
+        g_strdup_printf ("get      ******* (%s:%s)> (%d bytes, %"
+        G_GUINT64_FORMAT " ) %p", GST_DEBUG_PAD_NAME (pad),
+        GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf), buf);
 
     g_object_notify (G_OBJECT (src), "last_message");
   }
@@ -791,7 +798,7 @@ gst_fakesrc_get (GstPad * pad)
   if (src->signal_handoffs) {
     GST_LOG_OBJECT (src, "pre handoff emit");
     g_signal_emit (G_OBJECT (src), gst_fakesrc_signals[SIGNAL_HANDOFF], 0,
-       buf, pad);
+        buf, pad);
     GST_LOG_OBJECT (src, "post handoff emit");
   }
 
@@ -856,8 +863,8 @@ gst_fakesrc_change_state (GstElement * element)
       break;
     case GST_STATE_PAUSED_TO_READY:
       if (fakesrc->parent) {
-       gst_buffer_unref (fakesrc->parent);
-       fakesrc->parent = NULL;
+        gst_buffer_unref (fakesrc->parent);
+        fakesrc->parent = NULL;
       }
       g_free (fakesrc->last_message);
       fakesrc->last_message = NULL;
index 707b66dca920c0a25e1f12029729ea611b844b20..d003e167a883bfda1f58555967fd8829ecc325f1 100644 (file)
@@ -82,7 +82,7 @@ gst_fdsink_class_init (GstFdSinkClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_FD,
       g_param_spec_int ("fd", "fd", "An open file descriptor to write to",
-         0, G_MAXINT, 1, G_PARAM_READWRITE));
+          0, G_MAXINT, 1, G_PARAM_READWRITE));
 
   gobject_class->set_property = gst_fdsink_set_property;
   gobject_class->get_property = gst_fdsink_get_property;
@@ -114,7 +114,7 @@ gst_fdsink_chain (GstPad * pad, GstData * _data)
 
   if (GST_BUFFER_DATA (buf)) {
     GST_DEBUG ("writing %d bytes to file descriptor %d", GST_BUFFER_SIZE (buf),
-       fdsink->fd);
+        fdsink->fd);
     write (fdsink->fd, GST_BUFFER_DATA (buf), GST_BUFFER_SIZE (buf));
   }
 
index 18984cf696cafb6281c87edf061f97eacd899ccb..e723cbc158b89d130c7cc44cd74c132f61fb00be 100644 (file)
@@ -92,14 +92,14 @@ gst_fdsrc_class_init (GstFdSrcClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_FD,
       g_param_spec_int ("fd", "fd", "An open file descriptor to read from",
-         0, G_MAXINT, 0, G_PARAM_READWRITE));
+          0, G_MAXINT, 0, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_BLOCKSIZE,
       g_param_spec_ulong ("blocksize", "Block size",
-         "Size in bytes to read per buffer", 1, G_MAXULONG, DEFAULT_BLOCKSIZE,
-         G_PARAM_READWRITE));
+          "Size in bytes to read per buffer", 1, G_MAXULONG, DEFAULT_BLOCKSIZE,
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_TIMEOUT,
       g_param_spec_uint64 ("timeout", "Timeout", "Read timeout in nanoseconds",
-         0, G_MAXUINT64, 0, G_PARAM_READWRITE));
+          0, G_MAXUINT64, 0, G_PARAM_READWRITE));
 
   gst_fdsrc_signals[SIGNAL_TIMEOUT] =
       g_signal_new ("timeout", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_LAST,
@@ -204,11 +204,11 @@ gst_fdsrc_get (GstPad * pad)
 
   do {
     retval = select (1, &readfds, NULL, NULL, tp);
-  } while (retval == -1 && errno == EINTR);    /* retry if interrupted */
+  } while (retval == -1 && errno == EINTR);     /* retry if interrupted */
 
   if (retval == -1) {
     GST_ELEMENT_ERROR (src, RESOURCE, READ, (NULL),
-       ("select on file descriptor: %s.", g_strerror (errno)));
+        ("select on file descriptor: %s.", g_strerror (errno)));
     gst_element_set_eos (GST_ELEMENT (src));
     return GST_DATA (gst_event_new (GST_EVENT_EOS));
   } else if (retval == 0) {
@@ -219,7 +219,7 @@ gst_fdsrc_get (GstPad * pad)
 
   do {
     readbytes = read (src->fd, GST_BUFFER_DATA (buf), src->blocksize);
-  } while (readbytes == -1 && errno == EINTR); /* retry if interrupted */
+  } while (readbytes == -1 && errno == EINTR);  /* retry if interrupted */
 
   if (readbytes > 0) {
     GST_BUFFER_OFFSET (buf) = src->curoffset;
@@ -234,7 +234,7 @@ gst_fdsrc_get (GstPad * pad)
     return GST_DATA (gst_event_new (GST_EVENT_EOS));
   } else {
     GST_ELEMENT_ERROR (src, RESOURCE, READ, (NULL),
-       ("read on file descriptor: %s.", g_strerror (errno)));
+        ("read on file descriptor: %s.", g_strerror (errno)));
     gst_element_set_eos (GST_ELEMENT (src));
     return GST_DATA (gst_event_new (GST_EVENT_EOS));
   }
index e52eb80fecfab3e406cc3a72e48931ce149cd8d6..f5b5eacf42884e1bbf2d948560fef44a604337ec 100644 (file)
@@ -66,6 +66,7 @@ gst_filesink_get_formats (GstPad * pad)
     GST_FORMAT_BYTES,
     0,
   };
+
   return formats;
 }
 
@@ -77,6 +78,7 @@ gst_filesink_get_query_types (GstPad * pad)
     GST_QUERY_POSITION,
     0
   };
+
   return types;
 }
 
@@ -110,6 +112,7 @@ _do_init (GType filesink_type)
     NULL,
     NULL
   };
+
   g_type_add_interface_static (filesink_type, GST_TYPE_URI_HANDLER,
       &urihandler_info);
   GST_DEBUG_CATEGORY_INIT (gst_filesink_debug, "filesink", 0,
@@ -136,7 +139,7 @@ gst_filesink_class_init (GstFileSinkClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LOCATION,
       g_param_spec_string ("location", "File Location",
-         "Location of the file to write", NULL, G_PARAM_READWRITE));
+          "Location of the file to write", NULL, G_PARAM_READWRITE));
 
   gst_filesink_signals[SIGNAL_HANDOFF] =
       g_signal_new ("handoff", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_LAST,
@@ -251,15 +254,15 @@ gst_filesink_open_file (GstFileSink * sink)
   /* open the file */
   if (sink->filename == NULL || sink->filename[0] == '\0') {
     GST_ELEMENT_ERROR (sink, RESOURCE, NOT_FOUND,
-       (_("No file name specified for writing.")), (NULL));
+        (_("No file name specified for writing.")), (NULL));
     return FALSE;
   }
 
   sink->file = fopen (sink->filename, "w");
   if (sink->file == NULL) {
     GST_ELEMENT_ERROR (sink, RESOURCE, OPEN_WRITE,
-       (_("Could not open file \"%s\" for writing."), sink->filename),
-       GST_ERROR_SYSTEM);
+        (_("Could not open file \"%s\" for writing."), sink->filename),
+        GST_ERROR_SYSTEM);
     return FALSE;
   }
 
@@ -277,7 +280,7 @@ gst_filesink_close_file (GstFileSink * sink)
 
   if (fclose (sink->file) != 0) {
     GST_ELEMENT_ERROR (sink, RESOURCE, CLOSE,
-       (_("Error closing file \"%s\"."), sink->filename), GST_ERROR_SYSTEM);
+        (_("Error closing file \"%s\"."), sink->filename), GST_ERROR_SYSTEM);
   } else {
     GST_FLAG_UNSET (sink, GST_FILESINK_OPEN);
   }
@@ -292,25 +295,25 @@ gst_filesink_pad_query (GstPad * pad, GstQueryType type,
   switch (type) {
     case GST_QUERY_TOTAL:
       switch (*format) {
-       case GST_FORMAT_BYTES:
-         if (GST_FLAG_IS_SET (GST_ELEMENT (sink), GST_FILESINK_OPEN)) {
-           *value = sink->data_written;        /* FIXME - doesn't the kernel provide
-                                                  such a function? */
-           break;
-         }
-       default:
-         return FALSE;
+        case GST_FORMAT_BYTES:
+          if (GST_FLAG_IS_SET (GST_ELEMENT (sink), GST_FILESINK_OPEN)) {
+            *value = sink->data_written;        /* FIXME - doesn't the kernel provide
+                                                   such a function? */
+            break;
+          }
+        default:
+          return FALSE;
       }
       break;
     case GST_QUERY_POSITION:
       switch (*format) {
-       case GST_FORMAT_BYTES:
-         if (GST_FLAG_IS_SET (GST_ELEMENT (sink), GST_FILESINK_OPEN)) {
-           *value = ftell (sink->file);
-           break;
-         }
-       default:
-         return FALSE;
+        case GST_FORMAT_BYTES:
+          if (GST_FLAG_IS_SET (GST_ELEMENT (sink), GST_FILESINK_OPEN)) {
+            *value = ftell (sink->file);
+            break;
+          }
+        default:
+          return FALSE;
       }
       break;
     default:
@@ -336,27 +339,27 @@ gst_filesink_handle_event (GstPad * pad, GstEvent * event)
   switch (type) {
     case GST_EVENT_SEEK:
       g_return_val_if_fail (GST_EVENT_SEEK_FORMAT (event) == GST_FORMAT_BYTES,
-         FALSE);
+          FALSE);
 
       if (GST_EVENT_SEEK_FLAGS (event) & GST_SEEK_FLAG_FLUSH)
-       if (fflush (filesink->file))
-         GST_ELEMENT_ERROR (filesink, RESOURCE, WRITE,
-             (_("Error while writing to file \"%s\"."), filesink->filename),
-             GST_ERROR_SYSTEM);
+        if (fflush (filesink->file))
+          GST_ELEMENT_ERROR (filesink, RESOURCE, WRITE,
+              (_("Error while writing to file \"%s\"."), filesink->filename),
+              GST_ERROR_SYSTEM);
 
       switch (GST_EVENT_SEEK_METHOD (event)) {
-       case GST_SEEK_METHOD_SET:
-         fseek (filesink->file, GST_EVENT_SEEK_OFFSET (event), SEEK_SET);
-         break;
-       case GST_SEEK_METHOD_CUR:
-         fseek (filesink->file, GST_EVENT_SEEK_OFFSET (event), SEEK_CUR);
-         break;
-       case GST_SEEK_METHOD_END:
-         fseek (filesink->file, GST_EVENT_SEEK_OFFSET (event), SEEK_END);
-         break;
-       default:
-         g_warning ("unknown seek method!");
-         break;
+        case GST_SEEK_METHOD_SET:
+          fseek (filesink->file, GST_EVENT_SEEK_OFFSET (event), SEEK_SET);
+          break;
+        case GST_SEEK_METHOD_CUR:
+          fseek (filesink->file, GST_EVENT_SEEK_OFFSET (event), SEEK_CUR);
+          break;
+        case GST_SEEK_METHOD_END:
+          fseek (filesink->file, GST_EVENT_SEEK_OFFSET (event), SEEK_END);
+          break;
+        default:
+          g_warning ("unknown seek method!");
+          break;
       }
       break;
     case GST_EVENT_DISCONTINUOUS:
@@ -364,16 +367,16 @@ gst_filesink_handle_event (GstPad * pad, GstEvent * event)
       gint64 offset;
 
       if (gst_event_discont_get_value (event, GST_FORMAT_BYTES, &offset))
-       fseek (filesink->file, offset, SEEK_SET);
+        fseek (filesink->file, offset, SEEK_SET);
 
       gst_event_unref (event);
       break;
     }
     case GST_EVENT_FLUSH:
       if (fflush (filesink->file)) {
-       GST_ELEMENT_ERROR (filesink, RESOURCE, WRITE,
-           (_("Error while writing to file \"%s\"."), filesink->filename),
-           GST_ERROR_SYSTEM);
+        GST_ELEMENT_ERROR (filesink, RESOURCE, WRITE,
+            (_("Error while writing to file \"%s\"."), filesink->filename),
+            GST_ERROR_SYSTEM);
       }
       break;
     case GST_EVENT_EOS:
@@ -419,15 +422,15 @@ gst_filesink_chain (GstPad * pad, GstData * _data)
       back_pending = filesink->data_written - ftell (filesink->file);
     while (bytes_written < GST_BUFFER_SIZE (buf)) {
       size_t wrote = fwrite (GST_BUFFER_DATA (buf) + bytes_written, 1,
-         GST_BUFFER_SIZE (buf) - bytes_written,
-         filesink->file);
+          GST_BUFFER_SIZE (buf) - bytes_written,
+          filesink->file);
 
       if (wrote <= 0) {
-       GST_ELEMENT_ERROR (filesink, RESOURCE, WRITE,
-           (_("Error while writing to file \"%s\"."), filesink->filename),
-           ("Only %d of %d bytes written: %s",
-               bytes_written, GST_BUFFER_SIZE (buf), strerror (errno)));
-       break;
+        GST_ELEMENT_ERROR (filesink, RESOURCE, WRITE,
+            (_("Error while writing to file \"%s\"."), filesink->filename),
+            ("Only %d of %d bytes written: %s",
+                bytes_written, GST_BUFFER_SIZE (buf), strerror (errno)));
+        break;
       }
       bytes_written += wrote;
     }
@@ -449,13 +452,13 @@ gst_filesink_change_state (GstElement * element)
   switch (GST_STATE_TRANSITION (element)) {
     case GST_STATE_PAUSED_TO_READY:
       if (GST_FLAG_IS_SET (element, GST_FILESINK_OPEN))
-       gst_filesink_close_file (GST_FILESINK (element));
+        gst_filesink_close_file (GST_FILESINK (element));
       break;
 
     case GST_STATE_READY_TO_PAUSED:
       if (!GST_FLAG_IS_SET (element, GST_FILESINK_OPEN)) {
-       if (!gst_filesink_open_file (GST_FILESINK (element)))
-         return GST_STATE_FAILURE;
+        if (!gst_filesink_open_file (GST_FILESINK (element)))
+          return GST_STATE_FAILURE;
       }
       break;
   }
@@ -477,6 +480,7 @@ static gchar **
 gst_filesink_uri_get_protocols (void)
 {
   static gchar *protocols[] = { "file", NULL };
+
   return protocols;
 }
 static const gchar *
index 1f7ae1ed8ffa123c1f77756fc94f863f39fedeff..b37f370c2a0a6d62b96a3baab9e1901512546339 100644 (file)
@@ -107,11 +107,12 @@ gst_filesrc_get_event_mask (GstPad * pad)
 {
   static const GstEventMask masks[] = {
     {GST_EVENT_SEEK, GST_SEEK_METHOD_CUR |
-         GST_SEEK_METHOD_SET | GST_SEEK_METHOD_END | GST_SEEK_FLAG_FLUSH},
+          GST_SEEK_METHOD_SET | GST_SEEK_METHOD_END | GST_SEEK_FLAG_FLUSH},
     {GST_EVENT_FLUSH, 0},
     {GST_EVENT_SIZE, 0},
     {0, 0}
   };
+
   return masks;
 }
 
@@ -123,6 +124,7 @@ gst_filesrc_get_query_types (GstPad * pad)
     GST_QUERY_POSITION,
     0
   };
+
   return types;
 }
 
@@ -133,6 +135,7 @@ gst_filesrc_get_formats (GstPad * pad)
     GST_FORMAT_BYTES,
     0,
   };
+
   return formats;
 }
 
@@ -162,6 +165,7 @@ _do_init (GType filesrc_type)
     NULL,
     NULL
   };
+
   g_type_add_interface_static (filesrc_type, GST_TYPE_URI_HANDLER,
       &urihandler_info);
   GST_DEBUG_CATEGORY_INIT (gst_filesrc_debug, "filesrc", 0, "filesrc element");
@@ -188,22 +192,22 @@ gst_filesrc_class_init (GstFileSrcClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_FD,
       g_param_spec_int ("fd", "File-descriptor",
-         "File-descriptor for the file being mmap()d", 0, G_MAXINT, 0,
-         G_PARAM_READABLE));
+          "File-descriptor for the file being mmap()d", 0, G_MAXINT, 0,
+          G_PARAM_READABLE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LOCATION,
       g_param_spec_string ("location", "File Location",
-         "Location of the file to read", NULL, G_PARAM_READWRITE));
+          "Location of the file to read", NULL, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_BLOCKSIZE,
       g_param_spec_ulong ("blocksize", "Block size",
-         "Size in bytes to read per buffer", 1, G_MAXULONG, DEFAULT_BLOCKSIZE,
-         G_PARAM_READWRITE));
+          "Size in bytes to read per buffer", 1, G_MAXULONG, DEFAULT_BLOCKSIZE,
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_MMAPSIZE,
       g_param_spec_ulong ("mmapsize", "mmap() Block Size",
-         "Size in bytes of mmap()d regions", 0, G_MAXULONG, DEFAULT_MMAPSIZE,
-         G_PARAM_READWRITE));
+          "Size in bytes of mmap()d regions", 0, G_MAXULONG, DEFAULT_MMAPSIZE,
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_TOUCH,
       g_param_spec_boolean ("touch", "Touch read data",
-         "Touch data to force disk read", FALSE, G_PARAM_READWRITE));
+          "Touch data to force disk read", FALSE, G_PARAM_READWRITE));
 
   gobject_class->dispose = gst_filesrc_dispose;
   gobject_class->set_property = gst_filesrc_set_property;
@@ -235,7 +239,7 @@ gst_filesrc_init (GstFileSrc * src)
   src->touch = FALSE;
 
   src->mapbuf = NULL;
-  src->mapsize = DEFAULT_MMAPSIZE;     /* default is 4MB */
+  src->mapsize = DEFAULT_MMAPSIZE;      /* default is 4MB */
 
   src->seek_happened = FALSE;
 }
@@ -301,12 +305,12 @@ gst_filesrc_set_property (GObject * object, guint prop_id, const GValue * value,
       break;
     case ARG_MMAPSIZE:
       if ((src->mapsize % src->pagesize) == 0) {
-       src->mapsize = g_value_get_ulong (value);
-       g_object_notify (G_OBJECT (src), "mmapsize");
+        src->mapsize = g_value_get_ulong (value);
+        g_object_notify (G_OBJECT (src), "mmapsize");
       } else {
-       GST_INFO_OBJECT (src,
-           "invalid mapsize, must be a multiple of pagesize, which is %d",
-           src->pagesize);
+        GST_INFO_OBJECT (src,
+            "invalid mapsize, must be a multiple of pagesize, which is %d",
+            src->pagesize);
       }
       break;
     case ARG_TOUCH:
@@ -390,7 +394,7 @@ gst_filesrc_map_region (GstFileSrc * src, off_t offset, size_t size)
     return NULL;
   } else if (mmapregion == MAP_FAILED) {
     GST_WARNING_OBJECT (src, "mmap (0x%08lx, %d, 0x%llx) failed: %s",
-       (unsigned long) size, src->fd, offset, strerror (errno));
+        (unsigned long) size, src->fd, offset, strerror (errno));
     return NULL;
   }
   GST_LOG_OBJECT (src, "mapped region %08lx+%08lx from file into memory at %p",
@@ -435,7 +439,7 @@ gst_filesrc_map_small_region (GstFileSrc * src, off_t offset, size_t size)
 
     mapbase = offset - mod;
     mapsize =
-       ((size + mod + src->pagesize - 1) / src->pagesize) * src->pagesize;
+        ((size + mod + src->pagesize - 1) / src->pagesize) * src->pagesize;
 /*    printf("not on page boundaries, resizing map to %d+%d\n",mapbase,mapsize);*/
     map = gst_filesrc_map_region (src, mapbase, mapsize);
     if (map == NULL)
@@ -468,10 +472,10 @@ gst_filesrc_get_mmap (GstFileSrc * src)
 
   /* calculate end pointers so we don't have to do so repeatedly later */
   readsize = src->block_size;
-  readend = src->curoffset + src->block_size;  /* note this is the byte *after* the read */
+  readend = src->curoffset + src->block_size;   /* note this is the byte *after* the read */
   mapstart = GST_BUFFER_OFFSET (src->mapbuf);
   mapsize = GST_BUFFER_SIZE (src->mapbuf);
-  mapend = mapstart + mapsize; /* note this is the byte *after* the map */
+  mapend = mapstart + mapsize;  /* note this is the byte *after* the map */
 
   /* check to see if we're going to overflow the end of the file */
   if (readend > src->filelen) {
@@ -491,22 +495,22 @@ gst_filesrc_get_mmap (GstFileSrc * src)
     /* ('cause by definition if readend is in the buffer, so's readstart) */
     if (readend <= mapend) {
       GST_LOG_OBJECT (src,
-         "read buf %llu+%d lives in current mapbuf %lld+%d, creating subbuffer of mapbuf",
-         src->curoffset, (int) readsize, mapstart, mapsize);
+          "read buf %llu+%d lives in current mapbuf %lld+%d, creating subbuffer of mapbuf",
+          src->curoffset, (int) readsize, mapstart, mapsize);
       buf =
-         gst_buffer_create_sub (src->mapbuf, src->curoffset - mapstart,
-         readsize);
+          gst_buffer_create_sub (src->mapbuf, src->curoffset - mapstart,
+          readsize);
       GST_BUFFER_OFFSET (buf) = src->curoffset;
 
       /* if the start actually is within the current mmap region, map an overlap buffer */
     } else if (src->curoffset < mapend) {
       GST_LOG_OBJECT (src,
-         "read buf %llu+%d starts in mapbuf %d+%d but ends outside, creating new mmap",
-         (unsigned long long) src->curoffset, (gint) readsize, (gint) mapstart,
-         (gint) mapsize);
+          "read buf %llu+%d starts in mapbuf %d+%d but ends outside, creating new mmap",
+          (unsigned long long) src->curoffset, (gint) readsize, (gint) mapstart,
+          (gint) mapsize);
       buf = gst_filesrc_map_small_region (src, src->curoffset, readsize);
       if (buf == NULL)
-       return NULL;
+        return NULL;
     }
 
     /* the only other option is that buffer is totally outside, which means we search for it */
@@ -518,9 +522,9 @@ gst_filesrc_get_mmap (GstFileSrc * src)
     /* or the read buffer fully contains the current mmap region    */
     /* either way, it's really not relevant, we just create a new region anyway */
     GST_LOG_OBJECT (src,
-       "read buf %llu+%d starts before mapbuf %d+%d, but overlaps it",
-       (unsigned long long) src->curoffset, (gint) readsize, (gint) mapstart,
-       (gint) mapsize);
+        "read buf %llu+%d starts before mapbuf %d+%d, but overlaps it",
+        (unsigned long long) src->curoffset, (gint) readsize, (gint) mapstart,
+        (gint) mapsize);
     buf = gst_filesrc_map_small_region (src, src->curoffset, readsize);
     if (buf == NULL)
       return NULL;
@@ -530,16 +534,16 @@ gst_filesrc_get_mmap (GstFileSrc * src)
   if (buf == NULL) {
     /* first check to see if there's a map that covers the right region already */
     GST_LOG_OBJECT (src, "searching for mapbuf to cover %llu+%d",
-       src->curoffset, (int) readsize);
+        src->curoffset, (int) readsize);
 
     /* if the read buffer crosses a mmap region boundary, create a one-off region */
     if ((src->curoffset / src->mapsize) != (readend / src->mapsize)) {
       GST_LOG_OBJECT (src,
-         "read buf %llu+%d crosses a %d-byte boundary, creating a one-off",
-         src->curoffset, (int) readsize, (int) src->mapsize);
+          "read buf %llu+%d crosses a %d-byte boundary, creating a one-off",
+          src->curoffset, (int) readsize, (int) src->mapsize);
       buf = gst_filesrc_map_small_region (src, src->curoffset, readsize);
       if (buf == NULL)
-       return NULL;
+        return NULL;
 
       /* otherwise we will create a new mmap region and set it to the default */
     } else {
@@ -548,29 +552,29 @@ gst_filesrc_get_mmap (GstFileSrc * src)
       off_t nextmap = src->curoffset - (src->curoffset % src->mapsize);
 
       GST_LOG_OBJECT (src,
-         "read buf %llu+%d in new mapbuf at %llu+%d, mapping and subbuffering",
-         src->curoffset, readsize, nextmap, src->mapsize);
+          "read buf %llu+%d in new mapbuf at %llu+%d, mapping and subbuffering",
+          src->curoffset, readsize, nextmap, src->mapsize);
       /* first, we're done with the old mapbuf */
       gst_buffer_unref (src->mapbuf);
       mapsize = src->mapsize;
 
       /* double the mapsize as long as the readsize is smaller */
       while (readsize - (src->curoffset - nextmap) > mapsize) {
-       GST_LOG_OBJECT (src, "readsize smaller then mapsize %08x %d",
-           readsize, (int) mapsize);
-       mapsize <<= 1;
+        GST_LOG_OBJECT (src, "readsize smaller then mapsize %08x %d",
+            readsize, (int) mapsize);
+        mapsize <<= 1;
       }
       /* create a new one */
       src->mapbuf = gst_filesrc_map_region (src, nextmap, mapsize);
       if (src->mapbuf == NULL)
-       return NULL;
+        return NULL;
 
       /* subbuffer it */
       buf =
-         gst_buffer_create_sub (src->mapbuf, src->curoffset - nextmap,
-         readsize);
+          gst_buffer_create_sub (src->mapbuf, src->curoffset - nextmap,
+          readsize);
       GST_BUFFER_OFFSET (buf) =
-         GST_BUFFER_OFFSET (src->mapbuf) + src->curoffset - nextmap;
+          GST_BUFFER_OFFSET (src->mapbuf) + src->curoffset - nextmap;
     }
   }
 
@@ -598,7 +602,7 @@ gst_filesrc_get_read (GstFileSrc * src)
   readsize = src->block_size;
   if (src->curoffset + readsize > src->filelen) {
     if (!gst_filesrc_check_filesize (src)
-       || src->curoffset + readsize > src->filelen) {
+        || src->curoffset + readsize > src->filelen) {
       readsize = src->filelen - src->curoffset;
     }
   }
@@ -613,7 +617,7 @@ gst_filesrc_get_read (GstFileSrc * src)
   }
   if (ret < readsize) {
     GST_ELEMENT_ERROR (src, RESOURCE, READ, (NULL),
-       ("unexpected end of file."));
+        ("unexpected end of file."));
     return NULL;
   }
 
@@ -648,8 +652,8 @@ gst_filesrc_get (GstPad * pad)
     src->seek_happened = FALSE;
     GST_DEBUG_OBJECT (src, "sending discont");
     event =
-       gst_event_new_discontinuous (FALSE, GST_FORMAT_BYTES, src->curoffset,
-       NULL);
+        gst_event_new_discontinuous (FALSE, GST_FORMAT_BYTES, src->curoffset,
+        NULL);
     return GST_DATA (event);
   }
 
@@ -658,7 +662,7 @@ gst_filesrc_get (GstPad * pad)
   if (src->curoffset == src->filelen) {
     if (!gst_filesrc_check_filesize (src) || src->curoffset >= src->filelen) {
       GST_DEBUG_OBJECT (src, "eos %" G_GINT64_FORMAT " %" G_GINT64_FORMAT,
-         src->curoffset, src->filelen);
+          src->curoffset, src->filelen);
       gst_element_set_eos (GST_ELEMENT (src));
       return GST_DATA (gst_event_new (GST_EVENT_EOS));
     }
@@ -697,7 +701,7 @@ gst_filesrc_open_file (GstFileSrc * src)
 
   if (src->filename == NULL || src->filename[0] == '\0') {
     GST_ELEMENT_ERROR (src, RESOURCE, NOT_FOUND,
-       (_("No file name specified for reading.")), (NULL));
+        (_("No file name specified for reading.")), (NULL));
     return FALSE;
   }
 
@@ -711,8 +715,8 @@ gst_filesrc_open_file (GstFileSrc * src)
       GST_ELEMENT_ERROR (src, RESOURCE, NOT_FOUND, (NULL), (NULL));
     else
       GST_ELEMENT_ERROR (src, RESOURCE, OPEN_READ,
-         (_("Could not open file \"%s\" for reading."), src->filename),
-         GST_ERROR_SYSTEM);
+          (_("Could not open file \"%s\" for reading."), src->filename),
+          GST_ERROR_SYSTEM);
     return FALSE;
   } else {
     /* check if it is a regular file, otherwise bail out */
@@ -722,7 +726,7 @@ gst_filesrc_open_file (GstFileSrc * src)
 
     if (!S_ISREG (stat_results.st_mode)) {
       GST_ELEMENT_ERROR (src, RESOURCE, OPEN_READ,
-         (_("File \"%s\" isn't a regular file."), src->filename), (NULL));
+          (_("File \"%s\" isn't a regular file."), src->filename), (NULL));
       close (src->fd);
       return FALSE;
     }
@@ -780,13 +784,13 @@ gst_filesrc_change_state (GstElement * element)
       break;
     case GST_STATE_READY_TO_PAUSED:
       if (!GST_FLAG_IS_SET (element, GST_FILESRC_OPEN)) {
-       if (!gst_filesrc_open_file (GST_FILESRC (element)))
-         return GST_STATE_FAILURE;
+        if (!gst_filesrc_open_file (GST_FILESRC (element)))
+          return GST_STATE_FAILURE;
       }
       break;
     case GST_STATE_PAUSED_TO_READY:
       if (GST_FLAG_IS_SET (element, GST_FILESRC_OPEN))
-       gst_filesrc_close_file (GST_FILESRC (element));
+        gst_filesrc_close_file (GST_FILESRC (element));
       src->seek_happened = TRUE;
       break;
     default:
@@ -808,23 +812,23 @@ gst_filesrc_srcpad_query (GstPad * pad, GstQueryType type,
   switch (type) {
     case GST_QUERY_TOTAL:
       if (*format != GST_FORMAT_BYTES) {
-       return FALSE;
+        return FALSE;
       }
       gst_filesrc_check_filesize (src);
       *value = src->filelen;
       break;
     case GST_QUERY_POSITION:
       switch (*format) {
-       case GST_FORMAT_BYTES:
-         *value = src->curoffset;
-         break;
-       case GST_FORMAT_PERCENT:
-         if (src->filelen == 0)
-           return FALSE;
-         *value = src->curoffset * GST_FORMAT_PERCENT_MAX / src->filelen;
-         break;
-       default:
-         return FALSE;
+        case GST_FORMAT_BYTES:
+          *value = src->curoffset;
+          break;
+        case GST_FORMAT_PERCENT:
+          if (src->filelen == 0)
+            return FALSE;
+          *value = src->curoffset * GST_FORMAT_PERCENT_MAX / src->filelen;
+          break;
+        default:
+          return FALSE;
       }
       break;
     default:
@@ -847,44 +851,44 @@ gst_filesrc_srcpad_event (GstPad * pad, GstEvent * event)
       gint64 offset;
 
       if (GST_EVENT_SEEK_FORMAT (event) != GST_FORMAT_BYTES) {
-       goto error;
+        goto error;
       }
 
       offset = GST_EVENT_SEEK_OFFSET (event);
 
       switch (GST_EVENT_SEEK_METHOD (event)) {
-       case GST_SEEK_METHOD_SET:
-         if (offset > src->filelen && (!gst_filesrc_check_filesize (src)
-                 || offset > src->filelen)) {
-           goto error;
-         }
-         src->curoffset = offset;
-         GST_DEBUG_OBJECT (src, "seek set pending to %" G_GINT64_FORMAT,
-             src->curoffset);
-         break;
-       case GST_SEEK_METHOD_CUR:
-         if (offset + src->curoffset > src->filelen)
-           if (!gst_filesrc_check_filesize (src)
-               || offset + src->curoffset > src->filelen)
-             goto error;
-         src->curoffset += offset;
-         GST_DEBUG_OBJECT (src, "seek cur pending to %" G_GINT64_FORMAT,
-             src->curoffset);
-         break;
-       case GST_SEEK_METHOD_END:
-         if (ABS (offset) > src->filelen) {
-           if (!gst_filesrc_check_filesize (src)
-               || ABS (offset) > src->filelen)
-             goto error;
-           goto error;
-         }
-         src->curoffset = src->filelen - ABS (offset);
-         GST_DEBUG_OBJECT (src, "seek end pending to %" G_GINT64_FORMAT,
-             src->curoffset);
-         break;
-       default:
-         goto error;
-         break;
+        case GST_SEEK_METHOD_SET:
+          if (offset > src->filelen && (!gst_filesrc_check_filesize (src)
+                  || offset > src->filelen)) {
+            goto error;
+          }
+          src->curoffset = offset;
+          GST_DEBUG_OBJECT (src, "seek set pending to %" G_GINT64_FORMAT,
+              src->curoffset);
+          break;
+        case GST_SEEK_METHOD_CUR:
+          if (offset + src->curoffset > src->filelen)
+            if (!gst_filesrc_check_filesize (src)
+                || offset + src->curoffset > src->filelen)
+              goto error;
+          src->curoffset += offset;
+          GST_DEBUG_OBJECT (src, "seek cur pending to %" G_GINT64_FORMAT,
+              src->curoffset);
+          break;
+        case GST_SEEK_METHOD_END:
+          if (ABS (offset) > src->filelen) {
+            if (!gst_filesrc_check_filesize (src)
+                || ABS (offset) > src->filelen)
+              goto error;
+            goto error;
+          }
+          src->curoffset = src->filelen - ABS (offset);
+          GST_DEBUG_OBJECT (src, "seek end pending to %" G_GINT64_FORMAT,
+              src->curoffset);
+          break;
+        default:
+          goto error;
+          break;
       }
       src->seek_happened = TRUE;
       src->need_flush = GST_EVENT_SEEK_FLAGS (event) & GST_SEEK_FLAG_FLUSH;
@@ -892,7 +896,7 @@ gst_filesrc_srcpad_event (GstPad * pad, GstEvent * event)
     }
     case GST_EVENT_SIZE:
       if (GST_EVENT_SIZE_FORMAT (event) != GST_FORMAT_BYTES) {
-       goto error;
+        goto error;
       }
       src->block_size = GST_EVENT_SIZE_VALUE (event);
       g_object_notify (G_OBJECT (src), "blocksize");
@@ -923,6 +927,7 @@ static gchar **
 gst_filesrc_uri_get_protocols (void)
 {
   static gchar *protocols[] = { "file", NULL };
+
   return protocols;
 }
 static const gchar *
index 832f33d74bbedb5bd47e08eb065d9395de95c752..44b98f2fb5a1acd354b536d38971423f7f55ffdf 100644 (file)
@@ -94,31 +94,31 @@ gst_identity_class_init (GstIdentityClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LOOP_BASED,
       g_param_spec_boolean ("loop-based", "Loop-based",
-         "Set to TRUE to use loop-based rather than chain-based scheduling",
-         TRUE, G_PARAM_READWRITE));
+          "Set to TRUE to use loop-based rather than chain-based scheduling",
+          TRUE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SLEEP_TIME,
       g_param_spec_uint ("sleep-time", "Sleep time",
-         "Microseconds to sleep between processing", 0, G_MAXUINT, 0,
-         G_PARAM_READWRITE));
+          "Microseconds to sleep between processing", 0, G_MAXUINT, 0,
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_DUPLICATE,
       g_param_spec_uint ("duplicate", "Duplicate Buffers",
-         "Push the buffers N times", 0, G_MAXUINT, 1, G_PARAM_READWRITE));
+          "Push the buffers N times", 0, G_MAXUINT, 1, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_ERROR_AFTER,
       g_param_spec_int ("error_after", "Error After", "Error after N buffers",
-         G_MININT, G_MAXINT, -1, G_PARAM_READWRITE));
+          G_MININT, G_MAXINT, -1, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_DROP_PROBABILITY,
       g_param_spec_float ("drop_probability", "Drop Probability",
-         "The Probability a buffer is dropped", 0.0, 1.0, 0.0,
-         G_PARAM_READWRITE));
+          "The Probability a buffer is dropped", 0.0, 1.0, 0.0,
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SILENT,
       g_param_spec_boolean ("silent", "silent", "silent", FALSE,
-         G_PARAM_READWRITE));
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LAST_MESSAGE,
       g_param_spec_string ("last-message", "last-message", "last-message", NULL,
-         G_PARAM_READABLE));
+          G_PARAM_READABLE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_DUMP,
       g_param_spec_boolean ("dump", "Dump", "Dump buffer contents", FALSE,
-         G_PARAM_READWRITE));
+          G_PARAM_READWRITE));
 
   gst_identity_signals[SIGNAL_HANDOFF] =
       g_signal_new ("handoff", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_LAST,
@@ -173,7 +173,7 @@ gst_identity_chain (GstPad * pad, GstData * _data)
     if (identity->error_after == 0) {
       gst_buffer_unref (buf);
       GST_ELEMENT_ERROR (identity, CORE, FAILED,
-         (_("Failed after iterations as requested.")), (NULL));
+          (_("Failed after iterations as requested.")), (NULL));
       return;
     }
   }
@@ -181,12 +181,12 @@ gst_identity_chain (GstPad * pad, GstData * _data)
   if (identity->drop_probability > 0.0) {
     if ((gfloat) (1.0 * rand () / (RAND_MAX)) < identity->drop_probability) {
       if (identity->last_message != NULL) {
-       g_free (identity->last_message);
+        g_free (identity->last_message);
       }
       identity->last_message =
-         g_strdup_printf ("dropping   ******* (%s:%s)i (%d bytes, %"
-         G_GINT64_FORMAT ")", GST_DEBUG_PAD_NAME (identity->sinkpad),
-         GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf));
+          g_strdup_printf ("dropping   ******* (%s:%s)i (%d bytes, %"
+          G_GINT64_FORMAT ")", GST_DEBUG_PAD_NAME (identity->sinkpad),
+          GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf));
       g_object_notify (G_OBJECT (identity), "last-message");
       gst_buffer_unref (buf);
       return;
@@ -200,14 +200,14 @@ gst_identity_chain (GstPad * pad, GstData * _data)
     if (!identity->silent) {
       g_free (identity->last_message);
       identity->last_message =
-         g_strdup_printf ("chain   ******* (%s:%s)i (%d bytes, %"
-         G_GINT64_FORMAT ")", GST_DEBUG_PAD_NAME (identity->sinkpad),
-         GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf));
+          g_strdup_printf ("chain   ******* (%s:%s)i (%d bytes, %"
+          G_GINT64_FORMAT ")", GST_DEBUG_PAD_NAME (identity->sinkpad),
+          GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf));
       g_object_notify (G_OBJECT (identity), "last-message");
     }
 
     g_signal_emit (G_OBJECT (identity), gst_identity_signals[SIGNAL_HANDOFF], 0,
-       buf);
+        buf);
 
     if (i > 1)
       gst_buffer_ref (buf);
@@ -259,12 +259,12 @@ gst_identity_set_property (GObject * object, guint prop_id,
     case ARG_LOOP_BASED:
       identity->loop_based = g_value_get_boolean (value);
       if (identity->loop_based) {
-       gst_element_set_loop_function (GST_ELEMENT (identity),
-           gst_identity_loop);
-       gst_pad_set_chain_function (identity->sinkpad, NULL);
+        gst_element_set_loop_function (GST_ELEMENT (identity),
+            gst_identity_loop);
+        gst_pad_set_chain_function (identity->sinkpad, NULL);
       } else {
-       gst_pad_set_chain_function (identity->sinkpad, gst_identity_chain);
-       gst_element_set_loop_function (GST_ELEMENT (identity), NULL);
+        gst_pad_set_chain_function (identity->sinkpad, gst_identity_chain);
+        gst_element_set_loop_function (GST_ELEMENT (identity), NULL);
       }
       break;
     case ARG_SLEEP_TIME:
index 72e6f3b460f17ca33c44caa99dced0b6a7c24f24..5a3e40b80b45865124ebb5be3084300a56982908 100644 (file)
@@ -397,7 +397,7 @@ gst_md5sink_class_init (GstMD5SinkClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_MD5,
       g_param_spec_string ("md5", "md5", "current value of the md5 sum",
-         "", G_PARAM_READABLE));
+          "", G_PARAM_READABLE));
 
   gstelement_class->change_state = GST_DEBUG_FUNCPTR (gst_md5sink_change_state);
 }
@@ -467,7 +467,7 @@ gst_md5sink_get_property (GObject * object, guint prop_id, GValue * value,
       guchar *md5string = g_malloc0 (33);
 
       for (i = 0; i < 16; ++i)
-       sprintf (md5string + i * 2, "%02x", sink->md5[i]);
+        sprintf (md5string + i * 2, "%02x", sink->md5[i]);
       g_value_set_string (value, md5string);
       g_free (md5string);
     }
index d819c3e4ed763e84a3fc3e180706f5539f63f43c..a406ce0388af83109c8eebe5d5417f2617b36016 100644 (file)
@@ -105,7 +105,7 @@ gst_multifilesrc_class_init (GstMultiFileSrcClass * klass)
       G_STRUCT_OFFSET (GstMultiFileSrcClass, new_file), NULL, NULL,
       g_cclosure_marshal_VOID__STRING, G_TYPE_NONE, 1, G_TYPE_STRING);
 
-  g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LOCATIONS, g_param_spec_pointer ("locations", "locations", "locations", G_PARAM_READWRITE));    /* CHECKME */
+  g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LOCATIONS, g_param_spec_pointer ("locations", "locations", "locations", G_PARAM_READWRITE));     /* CHECKME */
 
   gobject_class->set_property = gst_multifilesrc_set_property;
   gobject_class->get_property = gst_multifilesrc_get_property;
@@ -149,11 +149,11 @@ gst_multifilesrc_set_property (GObject * object, guint prop_id,
 
       /* clear the filename if we get a NULL */
       if (g_value_get_pointer (value) == NULL) {
-       gst_element_set_state (GST_ELEMENT (object), GST_STATE_NULL);
-       src->listptr = NULL;
-       /* otherwise set the new filenames */
+        gst_element_set_state (GST_ELEMENT (object), GST_STATE_NULL);
+        src->listptr = NULL;
+        /* otherwise set the new filenames */
       } else {
-       src->listptr = g_value_get_pointer (value);
+        src->listptr = g_value_get_pointer (value);
       }
       break;
     default:
@@ -244,7 +244,7 @@ gst_multifilesrc_open_file (GstMultiFileSrc * src, GstPad * srcpad)
 
   if (src->currentfilename == NULL || src->currentfilename[0] == '\0') {
     GST_ELEMENT_ERROR (src, RESOURCE, NOT_FOUND,
-       (_("No file name specified for reading.")), (NULL));
+        (_("No file name specified for reading.")), (NULL));
     return FALSE;
   }
 
@@ -252,8 +252,8 @@ gst_multifilesrc_open_file (GstMultiFileSrc * src, GstPad * srcpad)
   src->fd = open ((const char *) src->currentfilename, O_RDONLY);
   if (src->fd < 0) {
     GST_ELEMENT_ERROR (src, RESOURCE, OPEN_READ,
-       (_("Could not open file \"%s\" for reading."), src->currentfilename),
-       GST_ERROR_SYSTEM);
+        (_("Could not open file \"%s\" for reading."), src->currentfilename),
+        GST_ERROR_SYSTEM);
     return FALSE;
 
   } else {
@@ -267,7 +267,7 @@ gst_multifilesrc_open_file (GstMultiFileSrc * src, GstPad * srcpad)
     if (src->map == NULL) {
       close (src->fd);
       GST_ELEMENT_ERROR (src, RESOURCE, TOO_LAZY, (NULL),
-         ("mmap call failed."));
+          ("mmap call failed."));
       return FALSE;
     }
     GST_FLAG_SET (src, GST_MULTIFILESRC_OPEN);
index 0ba8bfc9d667fdf01269d59c4d6f237c2b99c1f9..ec5d8879c51826d467ab2f66c1d1958f9c632334 100644 (file)
@@ -98,7 +98,7 @@ gst_pipefilter_class_init (GstPipefilterClass * klass)
   gobject_class->set_property = gst_pipefilter_set_property;
   gobject_class->get_property = gst_pipefilter_get_property;
 
-  g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_COMMAND, g_param_spec_string ("command", "command", "command", NULL, G_PARAM_READWRITE));       /* CHECKME */
+  g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_COMMAND, g_param_spec_string ("command", "command", "command", NULL, G_PARAM_READWRITE));        /* CHECKME */
 
   gstelement_class->change_state = gst_pipefilter_change_state;
 }
@@ -134,9 +134,9 @@ gst_pipefilter_handle_event (GstPad * pad, GstEvent * event)
   switch (GST_EVENT_TYPE (event)) {
     case GST_EVENT_EOS:
       if (close (pipefilter->fdin[1]) < 0)
-       perror ("close");
+        perror ("close");
       if (close (pipefilter->fdout[0]) < 0)
-       perror ("close");
+        perror ("close");
       break;
     default:
       break;
@@ -279,8 +279,8 @@ gst_pipefilter_open_file (GstPipefilter * src)
     close (src->fdin[1]);
     close (src->fdout[0]);
     /* child */
-    dup2 (src->fdin[0], STDIN_FILENO); /* set the childs input stream */
-    dup2 (src->fdout[1], STDOUT_FILENO);       /* set the childs output stream */
+    dup2 (src->fdin[0], STDIN_FILENO);  /* set the childs input stream */
+    dup2 (src->fdout[1], STDOUT_FILENO);        /* set the childs output stream */
     execvp (src->command[0], &src->command[0]);
     /* will only be reached if execvp has an error */
     GST_ELEMENT_ERROR (src, RESOURCE, TOO_LAZY, (NULL), GST_ERROR_SYSTEM);
@@ -327,7 +327,7 @@ gst_pipefilter_change_state (GstElement * element)
   } else {
     if (!GST_FLAG_IS_SET (element, GST_PIPEFILTER_OPEN)) {
       if (!gst_pipefilter_open_file (GST_PIPEFILTER (element)))
-       return GST_STATE_FAILURE;
+        return GST_STATE_FAILURE;
     }
   }
 
index afa1666bc960d1e3cb53b4e51c8b8f22e82ab131..d63a7aa8bcccfb6bf95e22d9da09687a29eaadee 100644 (file)
@@ -58,7 +58,8 @@ typedef struct
   GstPad *sinkpad;
   GstPad *srcpad;
   GstBuffer *buffer;
-} GstShaperConnection;
+}
+GstShaperConnection;
 
 GstStaticPadTemplate shaper_src_template = GST_STATIC_PAD_TEMPLATE ("src%d",
     GST_PAD_SRC,
@@ -80,9 +81,10 @@ gst_shaper_policy_get_type (void)
     {SHAPER_POLICY_BUFFERSIZE, "2", "sync on buffer size"},
     {0, NULL, NULL},
   };
+
   if (!shaper_policy_type) {
     shaper_policy_type =
-       g_enum_register_static ("GstShaperPolicy", shaper_policy);
+        g_enum_register_static ("GstShaperPolicy", shaper_policy);
   }
   return shaper_policy_type;
 }
@@ -128,13 +130,13 @@ gst_shaper_class_init (GstShaperClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_POLICY,
       g_param_spec_enum ("policy", "Policy", "Shaper policy",
-         GST_TYPE_SHAPER_POLICY, SHAPER_POLICY_TIMESTAMPS, G_PARAM_READWRITE));
+          GST_TYPE_SHAPER_POLICY, SHAPER_POLICY_TIMESTAMPS, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SILENT,
       g_param_spec_boolean ("silent", "silent", "silent",
-         FALSE, G_PARAM_READWRITE));
+          FALSE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LAST_MESSAGE,
       g_param_spec_string ("last-message", "last-message", "last-message",
-         NULL, G_PARAM_READABLE));
+          NULL, G_PARAM_READABLE));
 
   gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_shaper_set_property);
   gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_shaper_get_property);
@@ -279,30 +281,30 @@ gst_shaper_loop (GstElement * element)
 
       /* events are simply pushed ASAP */
       if (GST_IS_EVENT (buffer)) {
-       /* save event type as it will be unreffed after the next push */
-       GstEventType type = GST_EVENT_TYPE (buffer);
-
-       gst_pad_push (connection->srcpad, GST_DATA (buffer));
-
-       switch (type) {
-           /* on EOS we disable the pad so that we don't pull on
-            * it again and never get more data */
-         case GST_EVENT_EOS:
-           gst_pad_set_active (connection->sinkpad, FALSE);
-           break;
-         default:
-           break;
-       }
+        /* save event type as it will be unreffed after the next push */
+        GstEventType type = GST_EVENT_TYPE (buffer);
+
+        gst_pad_push (connection->srcpad, GST_DATA (buffer));
+
+        switch (type) {
+            /* on EOS we disable the pad so that we don't pull on
+             * it again and never get more data */
+          case GST_EVENT_EOS:
+            gst_pad_set_active (connection->sinkpad, FALSE);
+            break;
+          default:
+            break;
+        }
       } else {
-       /* we store the buffer */
-       connection->buffer = buffer;
+        /* we store the buffer */
+        connection->buffer = buffer;
       }
     }
     /* FIXME policy stuff goes here */
     /* find connection with lowest timestamp */
     if (min == NULL || (connection->buffer != NULL &&
-           (GST_BUFFER_TIMESTAMP (connection->buffer) <
-               GST_BUFFER_TIMESTAMP (min->buffer)))) {
+            (GST_BUFFER_TIMESTAMP (connection->buffer) <
+                GST_BUFFER_TIMESTAMP (min->buffer)))) {
       min = connection;
     }
     connections = g_slist_next (connections);
index 73f656fb3e790a1698896c390aefe99c5cd09dab..e5c59002e49cdd9fbb5b51a3b09351dc9313a8ee 100644 (file)
@@ -95,34 +95,34 @@ gst_statistics_class_init (GstStatisticsClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_BUFFERS,
       g_param_spec_int64 ("buffers", "buffers", "total buffers count",
-         0, G_MAXINT64, 0, G_PARAM_READABLE));
+          0, G_MAXINT64, 0, G_PARAM_READABLE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_BYTES,
       g_param_spec_int64 ("bytes", "bytes", "total bytes count",
-         0, G_MAXINT64, 0, G_PARAM_READABLE));
+          0, G_MAXINT64, 0, G_PARAM_READABLE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_EVENTS,
       g_param_spec_int64 ("events", "events", "total event count",
-         0, G_MAXINT64, 0, G_PARAM_READABLE));
+          0, G_MAXINT64, 0, G_PARAM_READABLE));
   g_object_class_install_property (G_OBJECT_CLASS (klass),
       ARG_BUFFER_UPDATE_FREQ, g_param_spec_int64 ("buffer_update_freq",
-         "buffer update freq", "buffer update frequency", 0, G_MAXINT64, 0,
-         G_PARAM_READWRITE));
+          "buffer update freq", "buffer update frequency", 0, G_MAXINT64, 0,
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass),
       ARG_BYTES_UPDATE_FREQ, g_param_spec_int64 ("bytes_update_freq",
-         "bytes update freq", "bytes update frequency", 0, G_MAXINT64, 0,
-         G_PARAM_READWRITE));
+          "bytes update freq", "bytes update frequency", 0, G_MAXINT64, 0,
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass),
       ARG_EVENT_UPDATE_FREQ, g_param_spec_int64 ("event_update_freq",
-         "event update freq", "event update frequency", 0, G_MAXINT64, 0,
-         G_PARAM_READWRITE));
+          "event update freq", "event update frequency", 0, G_MAXINT64, 0,
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_UPDATE_ON_EOS,
       g_param_spec_boolean ("update_on_eos", "update on EOS",
-         "update on EOS event", TRUE, G_PARAM_READWRITE));
+          "update on EOS event", TRUE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_UPDATE,
       g_param_spec_boolean ("update", "update", "update", TRUE,
-         G_PARAM_READWRITE));
+          G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SILENT,
       g_param_spec_boolean ("silent", "silent", "silent", TRUE,
-         G_PARAM_READWRITE));
+          G_PARAM_READWRITE));
 
   gst_statistics_signals[SIGNAL_UPDATE] =
       g_signal_new ("update", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_LAST,
@@ -253,14 +253,14 @@ gst_statistics_chain (GstPad * pad, GstData * _data)
     if (GST_EVENT_TYPE (event) == GST_EVENT_EOS) {
       gst_element_set_eos (GST_ELEMENT (statistics));
       if (statistics->update_on_eos) {
-       update = TRUE;
+        update = TRUE;
       }
     }
     if (statistics->update_freq.events) {
       statistics->update_count.events += 1;
       if (statistics->update_count.events == statistics->update_freq.events) {
-       statistics->update_count.events = 0;
-       update = TRUE;
+        statistics->update_count.events = 0;
+        update = TRUE;
       }
     }
   } else {
@@ -268,8 +268,8 @@ gst_statistics_chain (GstPad * pad, GstData * _data)
     if (statistics->update_freq.buffers) {
       statistics->update_count.buffers += 1;
       if (statistics->update_count.buffers == statistics->update_freq.buffers) {
-       statistics->update_count.buffers = 0;
-       update = TRUE;
+        statistics->update_count.buffers = 0;
+        update = TRUE;
       }
     }
 
@@ -277,8 +277,8 @@ gst_statistics_chain (GstPad * pad, GstData * _data)
     if (statistics->update_freq.bytes) {
       statistics->update_count.bytes += GST_BUFFER_SIZE (buf);
       if (statistics->update_count.bytes >= statistics->update_freq.bytes) {
-       statistics->update_count.bytes = 0;
-       update = TRUE;
+        statistics->update_count.bytes = 0;
+        update = TRUE;
       }
     }
   }
@@ -287,7 +287,7 @@ gst_statistics_chain (GstPad * pad, GstData * _data)
     if (statistics->update) {
       GST_DEBUG ("[%s]: pre update emit", GST_ELEMENT_NAME (statistics));
       g_signal_emit (G_OBJECT (statistics),
-         gst_statistics_signals[SIGNAL_UPDATE], 0);
+          gst_statistics_signals[SIGNAL_UPDATE], 0);
       GST_DEBUG ("[%s]: post update emit", GST_ELEMENT_NAME (statistics));
     }
     if (!statistics->silent) {
index 310a587e12cc5e27080cdc9d746a7e13f4161c20..be45ad719c15015adbb7b189e11d64b615e4ed3e 100644 (file)
@@ -95,13 +95,13 @@ gst_tee_class_init (GstTeeClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_NUM_PADS,
       g_param_spec_int ("num_pads", "num_pads", "num_pads",
-         0, G_MAXINT, 0, G_PARAM_READABLE));
+          0, G_MAXINT, 0, G_PARAM_READABLE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_SILENT,
       g_param_spec_boolean ("silent", "silent", "silent",
-         TRUE, G_PARAM_CONSTRUCT | G_PARAM_READWRITE));
+          TRUE, G_PARAM_CONSTRUCT | G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_LAST_MESSAGE,
       g_param_spec_string ("last_message", "last_message", "last_message",
-         NULL, G_PARAM_READABLE));
+          NULL, G_PARAM_READABLE));
 
 
   gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_tee_set_property);
@@ -134,7 +134,7 @@ name_pad_compare (gconstpointer a, gconstpointer b)
 
   g_assert (GST_IS_PAD (pad));
 
-  return strcmp (name, gst_pad_get_name (pad));        /* returns 0 if match */
+  return strcmp (name, gst_pad_get_name (pad)); /* returns 0 if match */
 }
 
 static GstPad *
@@ -163,7 +163,7 @@ gst_tee_request_new_pad (GstElement * element, GstPadTemplate * templ,
   while (!name) {
     name = g_strdup_printf ("src%d", i);
     if (g_list_find_custom ((GList *) pads, (gconstpointer) name,
-           name_pad_compare) != NULL) {
+            name_pad_compare) != NULL) {
       /* this name is taken, use the next one */
       ++i;
       g_free (name);
@@ -276,9 +276,9 @@ gst_tee_chain (GstPad * pad, GstData * _data)
     if (!tee->silent) {
       g_free (tee->last_message);
       tee->last_message =
-         g_strdup_printf ("chain        ******* (%s:%s)t (%d bytes, %"
-         G_GUINT64_FORMAT ") %p", GST_DEBUG_PAD_NAME (outpad),
-         GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf), buf);
+          g_strdup_printf ("chain        ******* (%s:%s)t (%d bytes, %"
+          G_GUINT64_FORMAT ") %p", GST_DEBUG_PAD_NAME (outpad),
+          GST_BUFFER_SIZE (buf), GST_BUFFER_TIMESTAMP (buf), buf);
       g_object_notify (G_OBJECT (tee), "last_message");
     }
 
index 0e70b988974621474caa646f0f6280ccd64a5f47..d6c31675cd661217dcda62fbe0936811fbe20f94 100644 (file)
@@ -83,8 +83,8 @@ enum
 };
 enum
 {
-  MODE_NORMAL,                 /* act as identity */
-  MODE_TYPEFIND,               /* do typefinding */
+  MODE_NORMAL,                  /* act as identity */
+  MODE_TYPEFIND,                /* do typefinding */
 };
 
 
@@ -146,16 +146,16 @@ gst_type_find_element_class_init (GstTypeFindElementClass * typefind_class)
 
   g_object_class_install_property (gobject_class, ARG_CAPS,
       g_param_spec_boxed ("caps", _("caps"),
-         _("detected capabilities in stream"), gst_caps_get_type (),
-         G_PARAM_READABLE));
+          _("detected capabilities in stream"), gst_caps_get_type (),
+          G_PARAM_READABLE));
   g_object_class_install_property (gobject_class, ARG_MINIMUM,
       g_param_spec_uint ("minimum", _("minimum"),
-         "minimum probability required to accept caps", GST_TYPE_FIND_MINIMUM,
-         GST_TYPE_FIND_MAXIMUM, GST_TYPE_FIND_MINIMUM, G_PARAM_READWRITE));
+          "minimum probability required to accept caps", GST_TYPE_FIND_MINIMUM,
+          GST_TYPE_FIND_MAXIMUM, GST_TYPE_FIND_MINIMUM, G_PARAM_READWRITE));
   g_object_class_install_property (gobject_class, ARG_MINIMUM,
       g_param_spec_uint ("maximum", _("maximum"),
-         "probability to stop typefinding", GST_TYPE_FIND_MINIMUM,
-         GST_TYPE_FIND_MAXIMUM, GST_TYPE_FIND_MAXIMUM, G_PARAM_READWRITE));
+          "probability to stop typefinding", GST_TYPE_FIND_MINIMUM,
+          GST_TYPE_FIND_MAXIMUM, GST_TYPE_FIND_MAXIMUM, G_PARAM_READWRITE));
 
   gst_type_find_element_signals[HAVE_TYPE] = g_signal_new ("have_type",
       G_TYPE_FROM_CLASS (typefind_class), G_SIGNAL_RUN_LAST,
@@ -259,8 +259,8 @@ gst_type_find_element_src_event_mask (GstPad * pad)
 {
   static const GstEventMask mask[] = {
     {GST_EVENT_SEEK,
-         GST_SEEK_METHOD_SET | GST_SEEK_METHOD_CUR | GST_SEEK_METHOD_END |
-         GST_SEEK_FLAG_FLUSH},
+        GST_SEEK_METHOD_SET | GST_SEEK_METHOD_CUR | GST_SEEK_METHOD_END |
+          GST_SEEK_FLAG_FLUSH},
     /* add more if you want, event masks suck and need to die anyway */
     {0,}
   };
@@ -290,7 +290,8 @@ typedef struct
 
   GList *buffers;
   GstTypeFindElement *self;
-} TypeFindEntry;
+}
+TypeFindEntry;
 
 static inline TypeFindEntry *
 new_entry (void)
@@ -336,7 +337,7 @@ stop_typefinding (GstTypeFindElement * typefind)
   if (typefind->possibilities != NULL) {
     /* this should only happen on PAUSED => READY or EOS */
     GST_LOG_OBJECT (typefind, "freeing remaining %u typefind functions",
-       g_list_length (typefind->possibilities));
+        g_list_length (typefind->possibilities));
     g_list_foreach (typefind->possibilities, (GFunc) free_entry, NULL);
     g_list_free (typefind->possibilities);
     typefind->possibilities = NULL;
@@ -349,7 +350,7 @@ stop_typefinding (GstTypeFindElement * typefind)
     guint size = gst_buffer_store_get_size (typefind->store, 0);
 
     if (size
-       && (buffer = gst_buffer_store_get_buffer (typefind->store, 0, size))) {
+        && (buffer = gst_buffer_store_get_buffer (typefind->store, 0, size))) {
       GST_LOG_OBJECT (typefind, "pushing cached data (%u bytes)", size);
       gst_pad_push (typefind->src, GST_DATA (buffer));
     } else {
@@ -357,10 +358,10 @@ stop_typefinding (GstTypeFindElement * typefind)
     }
     GST_LOG_OBJECT (typefind, "seeking back to current position %u", size);
     if (!gst_pad_send_event (GST_PAD_PEER (typefind->sink),
-           gst_event_new_seek (GST_SEEK_METHOD_SET | GST_FORMAT_BYTES,
-               size))) {
+            gst_event_new_seek (GST_SEEK_METHOD_SET | GST_FORMAT_BYTES,
+                size))) {
       GST_WARNING_OBJECT (typefind,
-         "could not seek to required position %u, hope for the best", size);
+          "could not seek to required position %u, hope for the best", size);
     }
   }
   gst_buffer_store_clear (typefind->store);
@@ -375,25 +376,25 @@ find_element_get_length (gpointer data)
 
   if (!typefind->stream_length_available) {
     GST_LOG_OBJECT (entry->self,
-       "'%s' called get_length () but we know it's not available",
-       GST_PLUGIN_FEATURE_NAME (entry->factory));
+        "'%s' called get_length () but we know it's not available",
+        GST_PLUGIN_FEATURE_NAME (entry->factory));
     return 0;
   }
   if (entry->self->stream_length == 0) {
     typefind->stream_length_available =
-       gst_pad_query (GST_PAD_PEER (entry->self->sink), GST_QUERY_TOTAL,
-       &format, &entry->self->stream_length);
+        gst_pad_query (GST_PAD_PEER (entry->self->sink), GST_QUERY_TOTAL,
+        &format, &entry->self->stream_length);
     if (format != GST_FORMAT_BYTES)
       typefind->stream_length_available = FALSE;
     if (!typefind->stream_length_available) {
       GST_DEBUG_OBJECT (entry->self,
-         "'%s' called get_length () but it's not available",
-         GST_PLUGIN_FEATURE_NAME (entry->factory));
+          "'%s' called get_length () but it's not available",
+          GST_PLUGIN_FEATURE_NAME (entry->factory));
       return 0;
     } else {
       GST_DEBUG_OBJECT (entry->self,
-         "'%s' called get_length () and it's %" G_GUINT64_FORMAT " bytes",
-         GST_PLUGIN_FEATURE_NAME (entry->factory), entry->self->stream_length);
+          "'%s' called get_length () and it's %" G_GUINT64_FORMAT " bytes",
+          GST_PLUGIN_FEATURE_NAME (entry->factory), entry->self->stream_length);
     }
   }
 
@@ -409,23 +410,23 @@ gst_type_find_element_handle_event (GstPad * pad, GstEvent * event)
     /* need to do more? */
     switch (GST_EVENT_TYPE (event)) {
       case GST_EVENT_EOS:
-       /* this should only happen when we got all available data */
-       entry =
-           (TypeFindEntry *) typefind->possibilities ? typefind->
-           possibilities->data : NULL;
-       if (entry && entry->probability >= typefind->min_probability) {
-         GST_INFO_OBJECT (typefind,
-             "'%s' is the best typefind left after we got all data, using it now (probability %u)",
-             GST_PLUGIN_FEATURE_NAME (entry->factory), entry->probability);
-         g_signal_emit (typefind, gst_type_find_element_signals[HAVE_TYPE], 0,
-             entry->probability, entry->caps);
-       }
-       stop_typefinding (typefind);
-       gst_pad_event_default (pad, event);
-       break;
+        /* this should only happen when we got all available data */
+        entry =
+            (TypeFindEntry *) typefind->possibilities ? typefind->
+            possibilities->data : NULL;
+        if (entry && entry->probability >= typefind->min_probability) {
+          GST_INFO_OBJECT (typefind,
+              "'%s' is the best typefind left after we got all data, using it now (probability %u)",
+              GST_PLUGIN_FEATURE_NAME (entry->factory), entry->probability);
+          g_signal_emit (typefind, gst_type_find_element_signals[HAVE_TYPE], 0,
+              entry->probability, entry->caps);
+        }
+        stop_typefinding (typefind);
+        gst_pad_event_default (pad, event);
+        break;
       default:
-       gst_data_unref (GST_DATA (event));
-       break;
+        gst_data_unref (GST_DATA (event));
+        break;
     }
   } else {
     gst_pad_event_default (pad, event);
@@ -449,8 +450,8 @@ find_peek (gpointer data, gint64 offset, guint size)
       buf = NULL;
     } else {
       buf =
-         gst_buffer_store_get_buffer (entry->self->store, length + offset,
-         size);
+          gst_buffer_store_get_buffer (entry->self->store, length + offset,
+          size);
     }
   }
 
@@ -460,8 +461,8 @@ find_peek (gpointer data, gint64 offset, guint size)
   } else {
     if (entry->requested_size == 0) {
       GST_LOG_OBJECT (entry->self,
-         "setting requested peek (%" G_GINT64_FORMAT ", %u) on '%s'", offset,
-         size, GST_PLUGIN_FEATURE_NAME (entry->factory));
+          "setting requested peek (%" G_GINT64_FORMAT ", %u) on '%s'", offset,
+          size, GST_PLUGIN_FEATURE_NAME (entry->factory));
       entry->requested_offset = offset;
       entry->requested_size = size;
     }
@@ -521,160 +522,160 @@ gst_type_find_element_chain (GstPad * pad, GstData * data)
 
       gst_buffer_store_add_buffer (typefind->store, GST_BUFFER (data));
       current_offset = GST_BUFFER_OFFSET_IS_VALID (data) ?
-         GST_BUFFER_OFFSET (data) + GST_BUFFER_SIZE (data) :
-         gst_buffer_store_get_size (typefind->store, 0);
+          GST_BUFFER_OFFSET (data) + GST_BUFFER_SIZE (data) :
+          gst_buffer_store_get_size (typefind->store, 0);
       gst_data_unref (data);
       if (typefind->possibilities == NULL) {
-       /* not yet started, get all typefinding functions into our "queue" */
-       GList *all_factories = gst_type_find_factory_get_list ();
-
-       GST_INFO_OBJECT (typefind, "starting with %u typefinding functions",
-           g_list_length ((GList *) all_factories));
-
-       all_factories = g_list_sort (all_factories, compare_type_find_factory);
-       walk = all_factories;
-       while (all_factories) {
-         entry = new_entry ();
-
-         entry->factory = GST_TYPE_FIND_FACTORY (all_factories->data);
-         entry->self = typefind;
-         entry->probability = 0;
-         typefind->possibilities =
-             g_list_prepend (typefind->possibilities, entry);
-         all_factories = g_list_next (all_factories);
-       }
-       g_list_free (all_factories);
+        /* not yet started, get all typefinding functions into our "queue" */
+        GList *all_factories = gst_type_find_factory_get_list ();
+
+        GST_INFO_OBJECT (typefind, "starting with %u typefinding functions",
+            g_list_length ((GList *) all_factories));
+
+        all_factories = g_list_sort (all_factories, compare_type_find_factory);
+        walk = all_factories;
+        while (all_factories) {
+          entry = new_entry ();
+
+          entry->factory = GST_TYPE_FIND_FACTORY (all_factories->data);
+          entry->self = typefind;
+          entry->probability = 0;
+          typefind->possibilities =
+              g_list_prepend (typefind->possibilities, entry);
+          all_factories = g_list_next (all_factories);
+        }
+        g_list_free (all_factories);
       }
       /* call every typefind function once */
       walk = entries = typefind->possibilities;
       GST_INFO_OBJECT (typefind, "iterating %u typefinding functions",
-         g_list_length (entries));
+          g_list_length (entries));
       typefind->possibilities = NULL;
       while (walk) {
-       find.data = entry = (TypeFindEntry *) walk->data;
-       walk = g_list_next (walk);
-       entry->probability = 0;
-       entry->requested_offset = 0;
-       entry->requested_size = 0;
-       gst_type_find_factory_call_function (entry->factory, &find);
-       free_entry_buffers (entry);
-       if (entry->probability == 0 && entry->requested_size == 0) {
-         GST_DEBUG_OBJECT (typefind,
-             "'%s' was removed - no chance of being the right plugin",
-             GST_PLUGIN_FEATURE_NAME (entry->factory));
-         free_entry (entry);
-       } else if (entry->probability >= typefind->max_probability) {
-         /* wooha, got caps */
-         GstCaps *found_caps = entry->caps;
-         guint probability = entry->probability;
-
-         GST_INFO_OBJECT (typefind,
-             "'%s' returned %u/%u probability, using it NOW",
-             GST_PLUGIN_FEATURE_NAME (entry->factory), probability,
-             typefind->max_probability);
-         while (walk) {
-           free_entry ((TypeFindEntry *) walk->data);
-           walk = g_list_next (walk);
-         }
-         walk = typefind->possibilities;
-         while (walk) {
-           free_entry (walk->data);
-           walk = g_list_next (walk);
-         }
-         typefind->possibilities = NULL;
-         g_list_free (typefind->possibilities);
-         g_signal_emit (typefind, gst_type_find_element_signals[HAVE_TYPE], 0,
-             probability, found_caps);
-         free_entry (entry);
-       } else {
-         typefind->possibilities =
-             g_list_prepend (typefind->possibilities, entry);
-       }
+        find.data = entry = (TypeFindEntry *) walk->data;
+        walk = g_list_next (walk);
+        entry->probability = 0;
+        entry->requested_offset = 0;
+        entry->requested_size = 0;
+        gst_type_find_factory_call_function (entry->factory, &find);
+        free_entry_buffers (entry);
+        if (entry->probability == 0 && entry->requested_size == 0) {
+          GST_DEBUG_OBJECT (typefind,
+              "'%s' was removed - no chance of being the right plugin",
+              GST_PLUGIN_FEATURE_NAME (entry->factory));
+          free_entry (entry);
+        } else if (entry->probability >= typefind->max_probability) {
+          /* wooha, got caps */
+          GstCaps *found_caps = entry->caps;
+          guint probability = entry->probability;
+
+          GST_INFO_OBJECT (typefind,
+              "'%s' returned %u/%u probability, using it NOW",
+              GST_PLUGIN_FEATURE_NAME (entry->factory), probability,
+              typefind->max_probability);
+          while (walk) {
+            free_entry ((TypeFindEntry *) walk->data);
+            walk = g_list_next (walk);
+          }
+          walk = typefind->possibilities;
+          while (walk) {
+            free_entry (walk->data);
+            walk = g_list_next (walk);
+          }
+          typefind->possibilities = NULL;
+          g_list_free (typefind->possibilities);
+          g_signal_emit (typefind, gst_type_find_element_signals[HAVE_TYPE], 0,
+              probability, found_caps);
+          free_entry (entry);
+        } else {
+          typefind->possibilities =
+              g_list_prepend (typefind->possibilities, entry);
+        }
       }
       g_list_free (entries);
       /* we may now already have caps or we might be left without functions to try */
       if (typefind->caps) {
-       stop_typefinding (typefind);
+        stop_typefinding (typefind);
       } else if (typefind->possibilities == NULL) {
-       GST_ELEMENT_ERROR (typefind, STREAM, TYPE_NOT_FOUND, (NULL), (NULL));
+        GST_ELEMENT_ERROR (typefind, STREAM, TYPE_NOT_FOUND, (NULL), (NULL));
       } else {
-       /* set up typefind element for next iteration */
-       typefind->possibilities =
-           g_list_sort (typefind->possibilities, compare_type_find_entry);
-
-       /* look for typefind functions that require data without seeking */
-       for (walk = typefind->possibilities; walk; walk = g_list_next (walk)) {
-         entry = (TypeFindEntry *) walk->data;
-         if (entry->requested_offset <= current_offset &&
-             entry->requested_offset + entry->requested_size > current_offset)
-           break;
-       }
-       if (!walk) {
-         /* find out if we should seek */
-         for (walk = typefind->possibilities; walk; walk = g_list_next (walk)) {
-           entry = (TypeFindEntry *) walk->data;
-           if (entry->requested_size > 0) {
-             /* FIXME: need heuristic to find out if we should seek */
-             gint64 seek_offset;
-             GstEvent *event;
-
-             seek_offset =
-                 entry->requested_offset >
-                 0 ? entry->
-                 requested_offset : find_element_get_length (entry) +
-                 entry->requested_offset;
-             seek_offset +=
-                 gst_buffer_store_get_size (typefind->store, seek_offset);
-             event =
-                 gst_event_new_seek (GST_FORMAT_BYTES | GST_SEEK_METHOD_SET,
-                 seek_offset);
-             if (gst_pad_send_event (GST_PAD_PEER (typefind->sink), event)) {
-               /* done seeking */
-               GST_DEBUG_OBJECT (typefind,
-                   "'%s' was reset - seeked to %" G_GINT64_FORMAT,
-                   GST_PLUGIN_FEATURE_NAME (entry->factory), seek_offset);
-               break;
-             } else if (entry->requested_offset < 0) {
-               /* impossible to seek */
-               GST_DEBUG_OBJECT (typefind,
-                   "'%s' was reset - couldn't seek to %" G_GINT64_FORMAT,
-                   GST_PLUGIN_FEATURE_NAME (entry->factory), seek_offset);
-               entry->requested_size = 0;
-               entry->requested_offset = 0;
-             }
-           }
-         }
-       }
-       /* throw out all entries that can't get more data */
-       walk = g_list_next (typefind->possibilities);
-       while (walk) {
-         GList *cur = walk;
-
-         entry = (TypeFindEntry *) walk->data;
-         walk = g_list_next (walk);
-         if (entry->requested_size == 0) {
-           GST_DEBUG_OBJECT (typefind,
-               "'%s' was removed - higher possibilities available",
-               GST_PLUGIN_FEATURE_NAME (entry->factory));
-           free_entry (entry);
-           typefind->possibilities =
-               g_list_delete_link (typefind->possibilities, cur);
-         }
-       }
-       if (g_list_next (typefind->possibilities) == NULL) {
-         entry = (TypeFindEntry *) typefind->possibilities->data;
-         if (entry->probability > typefind->min_probability) {
-           GST_INFO_OBJECT (typefind,
-               "'%s' is the only typefind left, using it now (probability %u)",
-               GST_PLUGIN_FEATURE_NAME (entry->factory), entry->probability);
-           g_signal_emit (typefind, gst_type_find_element_signals[HAVE_TYPE],
-               0, entry->probability, entry->caps);
-           free_entry (entry);
-           g_list_free (typefind->possibilities);
-           typefind->possibilities = NULL;
-           stop_typefinding (typefind);
-         }
-       }
+        /* set up typefind element for next iteration */
+        typefind->possibilities =
+            g_list_sort (typefind->possibilities, compare_type_find_entry);
+
+        /* look for typefind functions that require data without seeking */
+        for (walk = typefind->possibilities; walk; walk = g_list_next (walk)) {
+          entry = (TypeFindEntry *) walk->data;
+          if (entry->requested_offset <= current_offset &&
+              entry->requested_offset + entry->requested_size > current_offset)
+            break;
+        }
+        if (!walk) {
+          /* find out if we should seek */
+          for (walk = typefind->possibilities; walk; walk = g_list_next (walk)) {
+            entry = (TypeFindEntry *) walk->data;
+            if (entry->requested_size > 0) {
+              /* FIXME: need heuristic to find out if we should seek */
+              gint64 seek_offset;
+              GstEvent *event;
+
+              seek_offset =
+                  entry->requested_offset >
+                  0 ? entry->
+                  requested_offset : find_element_get_length (entry) +
+                  entry->requested_offset;
+              seek_offset +=
+                  gst_buffer_store_get_size (typefind->store, seek_offset);
+              event =
+                  gst_event_new_seek (GST_FORMAT_BYTES | GST_SEEK_METHOD_SET,
+                  seek_offset);
+              if (gst_pad_send_event (GST_PAD_PEER (typefind->sink), event)) {
+                /* done seeking */
+                GST_DEBUG_OBJECT (typefind,
+                    "'%s' was reset - seeked to %" G_GINT64_FORMAT,
+                    GST_PLUGIN_FEATURE_NAME (entry->factory), seek_offset);
+                break;
+              } else if (entry->requested_offset < 0) {
+                /* impossible to seek */
+                GST_DEBUG_OBJECT (typefind,
+                    "'%s' was reset - couldn't seek to %" G_GINT64_FORMAT,
+                    GST_PLUGIN_FEATURE_NAME (entry->factory), seek_offset);
+                entry->requested_size = 0;
+                entry->requested_offset = 0;
+              }
+            }
+          }
+        }
+        /* throw out all entries that can't get more data */
+        walk = g_list_next (typefind->possibilities);
+        while (walk) {
+          GList *cur = walk;
+
+          entry = (TypeFindEntry *) walk->data;
+          walk = g_list_next (walk);
+          if (entry->requested_size == 0) {
+            GST_DEBUG_OBJECT (typefind,
+                "'%s' was removed - higher possibilities available",
+                GST_PLUGIN_FEATURE_NAME (entry->factory));
+            free_entry (entry);
+            typefind->possibilities =
+                g_list_delete_link (typefind->possibilities, cur);
+          }
+        }
+        if (g_list_next (typefind->possibilities) == NULL) {
+          entry = (TypeFindEntry *) typefind->possibilities->data;
+          if (entry->probability > typefind->min_probability) {
+            GST_INFO_OBJECT (typefind,
+                "'%s' is the only typefind left, using it now (probability %u)",
+                GST_PLUGIN_FEATURE_NAME (entry->factory), entry->probability);
+            g_signal_emit (typefind, gst_type_find_element_signals[HAVE_TYPE],
+                0, entry->probability, entry->caps);
+            free_entry (entry);
+            g_list_free (typefind->possibilities);
+            typefind->possibilities = NULL;
+            stop_typefinding (typefind);
+          }
+        }
       }
       break;
     }
index b12000cc6a3df493cc45d8239197ee25d0409c7a..8c0a2248b90427063a239d210af0444a43c012af 100644 (file)
--- a/gst/gst.c
+++ b/gst/gst.c
@@ -25,7 +25,7 @@
 
 #include "gst_private.h"
 #include "gst-i18n-lib.h"
-#include <locale.h>            /* for LC_ALL */
+#include <locale.h>             /* for LC_ALL */
 
 #include "gst.h"
 #include "gstqueue.h"
@@ -114,55 +114,55 @@ enum
  */
 static const GstPoptOption gstreamer_options[] = {
   {NULL, NUL, POPT_ARG_CALLBACK | POPT_CBFLAG_PRE | POPT_CBFLAG_POST,
-       (void *) &init_popt_callback, 0, NULL, NULL},
+      (void *) &init_popt_callback, 0, NULL, NULL},
   /* make sure we use our GETTEXT_PACKAGE as the domain for popt translations */
   {NULL, NUL, POPT_ARG_INTL_DOMAIN, GETTEXT_PACKAGE, 0, NULL, NULL},
   {"gst-version", NUL, POPT_ARG_NONE | POPT_ARGFLAG_STRIP, NULL, ARG_VERSION,
-       N_("Print the GStreamer version"), NULL},
+      N_("Print the GStreamer version"), NULL},
   {"gst-fatal-warnings", NUL, POPT_ARG_NONE | POPT_ARGFLAG_STRIP, NULL,
-       ARG_FATAL_WARNINGS, N_("Make all warnings fatal"), NULL},
+      ARG_FATAL_WARNINGS, N_("Make all warnings fatal"), NULL},
 
 #ifndef GST_DISABLE_GST_DEBUG
   {"gst-debug-help", NUL, POPT_ARG_NONE | POPT_ARGFLAG_STRIP, NULL,
-       ARG_DEBUG_HELP, N_("Print available debug categories and exit"), NULL},
+      ARG_DEBUG_HELP, N_("Print available debug categories and exit"), NULL},
   {"gst-debug-level", NUL, POPT_ARG_INT | POPT_ARGFLAG_STRIP, NULL,
-       ARG_DEBUG_LEVEL,
-       N_
-       ("Default debug level from 1 (only error) to 5 (anything) or 0 for no output"),
-       N_("LEVEL")},
+        ARG_DEBUG_LEVEL,
+        N_
+        ("Default debug level from 1 (only error) to 5 (anything) or 0 for no output"),
+      N_("LEVEL")},
   {"gst-debug", NUL, POPT_ARG_STRING | POPT_ARGFLAG_STRIP, NULL, ARG_DEBUG,
-       N_
-       ("Comma-separated list of category_name:level pairs to set specific levels for the individual categories. Example: GST_AUTOPLUG:5,GST_ELEMENT_*:3"),
-       N_("LIST")},
+        N_
+        ("Comma-separated list of category_name:level pairs to set specific levels for the individual categories. Example: GST_AUTOPLUG:5,GST_ELEMENT_*:3"),
+      N_("LIST")},
   {"gst-debug-no-color", NUL, POPT_ARG_NONE | POPT_ARGFLAG_STRIP, NULL,
-       ARG_DEBUG_NO_COLOR, N_("Disable colored debugging output"), NULL},
+      ARG_DEBUG_NO_COLOR, N_("Disable colored debugging output"), NULL},
   {"gst-debug-disable", NUL, POPT_ARG_NONE | POPT_ARGFLAG_STRIP, NULL,
-       ARG_DEBUG_DISABLE, N_("Disable debugging")},
+      ARG_DEBUG_DISABLE, N_("Disable debugging")},
 #endif
 
   {"gst-disable-cpu-opt", NUL, POPT_ARG_NONE | POPT_ARGFLAG_STRIP, NULL,
-       ARG_DISABLE_CPU_OPT, N_("Disable accelerated CPU instructions"), NULL},
+      ARG_DISABLE_CPU_OPT, N_("Disable accelerated CPU instructions"), NULL},
   {"gst-plugin-spew", NUL, POPT_ARG_NONE | POPT_ARGFLAG_STRIP, NULL,
-       ARG_PLUGIN_SPEW, N_("Enable verbose plugin loading diagnostics"), NULL},
+      ARG_PLUGIN_SPEW, N_("Enable verbose plugin loading diagnostics"), NULL},
   {"gst-plugin-path", NUL, POPT_ARG_STRING | POPT_ARGFLAG_STRIP, NULL,
-       ARG_PLUGIN_PATH,
-       N_("path list for loading plugins (separated by '"
-           G_SEARCHPATH_SEPARATOR_S "')"), N_("PATHS")},
+        ARG_PLUGIN_PATH,
+      N_("path list for loading plugins (separated by '"
+            G_SEARCHPATH_SEPARATOR_S "')"), N_("PATHS")},
   {"gst-plugin-load", NUL, POPT_ARG_STRING | POPT_ARGFLAG_STRIP, NULL,
-       ARG_PLUGIN_LOAD,
-       N_
-       ("Comma-separated list of plugins to preload in addition to the list stored in env variable GST_PLUGIN_PATH"),
-       N_("PLUGINS")},
+        ARG_PLUGIN_LOAD,
+        N_
+        ("Comma-separated list of plugins to preload in addition to the list stored in env variable GST_PLUGIN_PATH"),
+      N_("PLUGINS")},
   {"gst-disable-segtrap", NUL, POPT_ARG_NONE | POPT_ARGFLAG_STRIP, NULL,
-       ARG_SEGTRAP_DISABLE,
-       N_("Disable trapping of segmentation faults during plugin loading"),
-       NULL},
+        ARG_SEGTRAP_DISABLE,
+        N_("Disable trapping of segmentation faults during plugin loading"),
+      NULL},
   {"gst-scheduler", NUL, POPT_ARG_STRING | POPT_ARGFLAG_STRIP, NULL,
-       ARG_SCHEDULER,
-       N_("Scheduler to use ('" GST_SCHEDULER_DEFAULT_NAME
-           "' is the default)"), N_("SCHEDULER")},
+        ARG_SCHEDULER,
+      N_("Scheduler to use ('" GST_SCHEDULER_DEFAULT_NAME
+            "' is the default)"), N_("SCHEDULER")},
   {"gst-registry", NUL, POPT_ARG_STRING | POPT_ARGFLAG_STRIP, NULL,
-       ARG_REGISTRY, N_("Registry to use"), N_("REGISTRY")},
+      ARG_REGISTRY, N_("Registry to use"), N_("REGISTRY")},
   POPT_TABLEEND
 };
 
@@ -269,18 +269,18 @@ gst_init_check_with_popt_table (int *argc, char **argv[],
   GstPoptOption *options;
   GstPoptOption options_with[] = {
     {NULL, NUL, POPT_ARG_INCLUDE_TABLE, poptHelpOptions, 0, "Help options:",
-         NULL},
+        NULL},
     {NULL, NUL, POPT_ARG_INCLUDE_TABLE, (GstPoptOption *) gstreamer_options, 0,
-         "GStreamer options:", NULL},
+        "GStreamer options:", NULL},
     {NULL, NUL, POPT_ARG_INCLUDE_TABLE, (GstPoptOption *) popt_options, 0,
-         "Application options:", NULL},
+        "Application options:", NULL},
     POPT_TABLEEND
   };
   GstPoptOption options_without[] = {
     {NULL, NUL, POPT_ARG_INCLUDE_TABLE, poptHelpOptions, 0, "Help options:",
-         NULL},
+        NULL},
     {NULL, NUL, POPT_ARG_INCLUDE_TABLE, (GstPoptOption *) gstreamer_options, 0,
-         "GStreamer options:", NULL},
+        "GStreamer options:", NULL},
     POPT_TABLEEND
   };
 
@@ -317,8 +317,8 @@ gst_init_check_with_popt_table (int *argc, char **argv[],
 
   if (nextopt != -1) {
     g_print ("Error on option %s: %s.\nRun '%s --help' "
-       "to see a full list of available command line options.\n",
-       poptBadOption (context, 0), poptStrerror (nextopt), (*argv)[0]);
+        "to see a full list of available command line options.\n",
+        poptBadOption (context, 0), poptStrerror (nextopt), (*argv)[0]);
 
     poptFreeContext (context);
     return FALSE;
@@ -368,9 +368,9 @@ parse_debug_list (const gchar * list)
       g_strstrip (values[1]);
       level = strtol (values[1], NULL, 0);
       if (level >= 0 && level < GST_LEVEL_COUNT) {
-       GST_DEBUG ("setting debugging to level %d for name \"%s\"",
-           level, values[0]);
-       gst_debug_set_threshold_for_name (values[0], level);
+        GST_DEBUG ("setting debugging to level %d for name \"%s\"",
+            level, values[0]);
+        gst_debug_set_threshold_for_name (values[0], level);
       }
     }
     g_strfreev (values);
@@ -415,10 +415,10 @@ split_and_iterate (const gchar * stringlist, gchar * separator, GFunc iterator,
     while (strings[j]) {
       iterator (strings[j], user_data);
       if (++j == MAX_PATH_SPLIT) {
-       lastlist = g_strdup (strings[j]);
-       g_strfreev (strings);
-       j = 0;
-       break;
+        lastlist = g_strdup (strings[j]);
+        g_strfreev (strings);
+        j = 0;
+        break;
       }
     }
   }
@@ -463,7 +463,7 @@ init_pre (void)
     const gchar *homedir;
 
     _global_registry =
-       gst_xml_registry_new ("global_registry", GLOBAL_REGISTRY_FILE);
+        gst_xml_registry_new ("global_registry", GLOBAL_REGISTRY_FILE);
 
 #ifdef PLUGINS_USE_BUILDDIR
     /* location libgstelements.so */
@@ -472,7 +472,7 @@ init_pre (void)
     gst_registry_add_path (_global_registry, PLUGINS_BUILDDIR "/gst/types");
     gst_registry_add_path (_global_registry, PLUGINS_BUILDDIR "/gst/autoplug");
     gst_registry_add_path (_global_registry,
-       PLUGINS_BUILDDIR "/gst/schedulers");
+        PLUGINS_BUILDDIR "/gst/schedulers");
     gst_registry_add_path (_global_registry, PLUGINS_BUILDDIR "/gst/indexers");
 #else
     /* add the main (installed) library path */
@@ -499,13 +499,13 @@ gst_register_core_elements (GstPlugin * plugin)
 {
   /* register some standard builtin types */
   g_assert (gst_element_register (plugin, "bin", GST_RANK_PRIMARY,
-         GST_TYPE_BIN));
+          GST_TYPE_BIN));
   g_assert (gst_element_register (plugin, "pipeline", GST_RANK_PRIMARY,
-         GST_TYPE_PIPELINE));
+          GST_TYPE_PIPELINE));
   g_assert (gst_element_register (plugin, "thread", GST_RANK_PRIMARY,
-         GST_TYPE_THREAD));
+          GST_TYPE_THREAD));
   g_assert (gst_element_register (plugin, "queue", GST_RANK_PRIMARY,
-         GST_TYPE_QUEUE));
+          GST_TYPE_QUEUE));
 
   return TRUE;
 }
@@ -593,7 +593,7 @@ init_post (void)
     /* don't override command-line options */
     if (g_getenv ("GST_REGISTRY")) {
       g_object_set (_global_registry, "location", g_getenv ("GST_REGISTRY"),
-         NULL);
+          NULL);
       _gst_registry_fixed = TRUE;
     }
   }
@@ -655,12 +655,12 @@ gst_debug_help (void)
     if (!gst_plugin_is_loaded (plugin)) {
 #ifndef GST_DISABLE_REGISTRY
       if (GST_IS_REGISTRY (plugin->manager)) {
-       GST_CAT_LOG (GST_CAT_PLUGIN_LOADING, "loading plugin %s",
-           plugin->desc.name);
-       if (gst_registry_load_plugin (GST_REGISTRY (plugin->manager),
-               plugin) != GST_REGISTRY_OK)
-         GST_CAT_WARNING (GST_CAT_PLUGIN_LOADING, "loading plugin %s failed",
-             plugin->desc.name);
+        GST_CAT_LOG (GST_CAT_PLUGIN_LOADING, "loading plugin %s",
+            plugin->desc.name);
+        if (gst_registry_load_plugin (GST_REGISTRY (plugin->manager),
+                plugin) != GST_REGISTRY_OK)
+          GST_CAT_WARNING (GST_CAT_PLUGIN_LOADING, "loading plugin %s failed",
+              plugin->desc.name);
       }
 #endif /* GST_DISABLE_REGISTRY */
     }
@@ -681,17 +681,17 @@ gst_debug_help (void)
       gchar *color = gst_debug_construct_term_color (cat->color);
 
       g_print ("%s%-20s\033[00m  %1d %s  %s%s\033[00m\n",
-         color,
-         gst_debug_category_get_name (cat),
-         gst_debug_category_get_threshold (cat),
-         gst_debug_level_get_name (gst_debug_category_get_threshold (cat)),
-         color, gst_debug_category_get_description (cat));
+          color,
+          gst_debug_category_get_name (cat),
+          gst_debug_category_get_threshold (cat),
+          gst_debug_level_get_name (gst_debug_category_get_threshold (cat)),
+          color, gst_debug_category_get_description (cat));
       g_free (color);
     } else {
       g_print ("%-20s  %1d %s  %s\n", gst_debug_category_get_name (cat),
-         gst_debug_category_get_threshold (cat),
-         gst_debug_level_get_name (gst_debug_category_get_threshold (cat)),
-         gst_debug_category_get_description (cat));
+          gst_debug_category_get_threshold (cat),
+          gst_debug_level_get_name (gst_debug_category_get_threshold (cat)),
+          gst_debug_category_get_description (cat));
     }
     walk = g_slist_next (walk);
   }
@@ -711,75 +711,75 @@ init_popt_callback (poptContext context, enum poptCallbackReason reason,
   switch (reason) {
     case POPT_CALLBACK_REASON_PRE:
       if (!init_pre ())
-       _gst_initialization_failure = TRUE;
+        _gst_initialization_failure = TRUE;
       break;
     case POPT_CALLBACK_REASON_OPTION:
       switch (option->val) {
-       case ARG_VERSION:
-         g_print ("GStreamer Core Library version %s\n", GST_VERSION);
-         exit (0);
-       case ARG_FATAL_WARNINGS:
-         fatal_mask = g_log_set_always_fatal (G_LOG_FATAL_MASK);
-         fatal_mask |= G_LOG_LEVEL_WARNING | G_LOG_LEVEL_CRITICAL;
-         g_log_set_always_fatal (fatal_mask);
-         break;
+        case ARG_VERSION:
+          g_print ("GStreamer Core Library version %s\n", GST_VERSION);
+          exit (0);
+        case ARG_FATAL_WARNINGS:
+          fatal_mask = g_log_set_always_fatal (G_LOG_FATAL_MASK);
+          fatal_mask |= G_LOG_LEVEL_WARNING | G_LOG_LEVEL_CRITICAL;
+          g_log_set_always_fatal (fatal_mask);
+          break;
 #ifndef GST_DISABLE_GST_DEBUG
-       case ARG_DEBUG_LEVEL:{
-         gint tmp = 0;
-
-         tmp = strtol (arg, NULL, 0);
-         if (tmp >= 0 && tmp < GST_LEVEL_COUNT) {
-           gst_debug_set_default_threshold (tmp);
-         }
-         break;
-       }
-       case ARG_DEBUG:
-         parse_debug_list (arg);
-         break;
-       case ARG_DEBUG_NO_COLOR:
-         gst_debug_set_colored (FALSE);
-         break;
-       case ARG_DEBUG_DISABLE:
-         gst_debug_set_active (FALSE);
-         break;
-       case ARG_DEBUG_HELP:
-         gst_debug_help ();
-         exit (0);
+        case ARG_DEBUG_LEVEL:{
+          gint tmp = 0;
+
+          tmp = strtol (arg, NULL, 0);
+          if (tmp >= 0 && tmp < GST_LEVEL_COUNT) {
+            gst_debug_set_default_threshold (tmp);
+          }
+          break;
+        }
+        case ARG_DEBUG:
+          parse_debug_list (arg);
+          break;
+        case ARG_DEBUG_NO_COLOR:
+          gst_debug_set_colored (FALSE);
+          break;
+        case ARG_DEBUG_DISABLE:
+          gst_debug_set_active (FALSE);
+          break;
+        case ARG_DEBUG_HELP:
+          gst_debug_help ();
+          exit (0);
 #endif
-       case ARG_DISABLE_CPU_OPT:
-         _gst_enable_cpu_opt = FALSE;
-         break;
-       case ARG_PLUGIN_SPEW:
-         break;
-       case ARG_PLUGIN_PATH:
+        case ARG_DISABLE_CPU_OPT:
+          _gst_enable_cpu_opt = FALSE;
+          break;
+        case ARG_PLUGIN_SPEW:
+          break;
+        case ARG_PLUGIN_PATH:
 #ifndef GST_DISABLE_REGISTRY
-         split_and_iterate (arg, G_SEARCHPATH_SEPARATOR_S, add_path_func,
-             _user_registry);
+          split_and_iterate (arg, G_SEARCHPATH_SEPARATOR_S, add_path_func,
+              _user_registry);
 #endif /* GST_DISABLE_REGISTRY */
-         break;
-       case ARG_PLUGIN_LOAD:
-         split_and_iterate (arg, ",", prepare_for_load_plugin_func, NULL);
-         break;
-       case ARG_SEGTRAP_DISABLE:
-         _gst_disable_segtrap = TRUE;
-         break;
-       case ARG_SCHEDULER:
-         gst_scheduler_factory_set_default_name (arg);
-         break;
-       case ARG_REGISTRY:
+          break;
+        case ARG_PLUGIN_LOAD:
+          split_and_iterate (arg, ",", prepare_for_load_plugin_func, NULL);
+          break;
+        case ARG_SEGTRAP_DISABLE:
+          _gst_disable_segtrap = TRUE;
+          break;
+        case ARG_SCHEDULER:
+          gst_scheduler_factory_set_default_name (arg);
+          break;
+        case ARG_REGISTRY:
 #ifndef GST_DISABLE_REGISTRY
-         g_object_set (G_OBJECT (_user_registry), "location", arg, NULL);
-         _gst_registry_fixed = TRUE;
+          g_object_set (G_OBJECT (_user_registry), "location", arg, NULL);
+          _gst_registry_fixed = TRUE;
 #endif /* GST_DISABLE_REGISTRY */
-         break;
-       default:
-         g_warning ("option %d not recognized", option->val);
-         break;
+          break;
+        default:
+          g_warning ("option %d not recognized", option->val);
+          break;
       }
       break;
     case POPT_CALLBACK_REASON_POST:
       if (!init_post ())
-       _gst_initialization_failure = TRUE;
+        _gst_initialization_failure = TRUE;
       gst_initialized = TRUE;
       break;
   }
index 37907a18f66dee275e035c7b5bc574ed7d9a9525..f7bd00e6ddb9f5e84c541460438952ffb861d8d1 100644 (file)
@@ -107,7 +107,7 @@ gst_bin_get_type (void)
     };
 
     _gst_bin_type =
-       g_type_register_static (GST_TYPE_ELEMENT, "GstBin", &bin_info, 0);
+        g_type_register_static (GST_TYPE_ELEMENT, "GstBin", &bin_info, 0);
   }
   return _gst_bin_type;
 }
@@ -292,19 +292,19 @@ gst_bin_set_element_sched (GstElement * element, GstScheduler * sched)
   if (GST_IS_BIN (element)) {
     if (GST_FLAG_IS_SET (element, GST_BIN_FLAG_MANAGER)) {
       GST_CAT_DEBUG_OBJECT (GST_CAT_PARENTAGE, element,
-         "child is already a manager, not resetting sched");
+          "child is already a manager, not resetting sched");
       if (GST_ELEMENT_SCHED (element))
-       gst_scheduler_add_scheduler (sched, GST_ELEMENT_SCHED (element));
+        gst_scheduler_add_scheduler (sched, GST_ELEMENT_SCHED (element));
       return;
     }
 
     GST_CAT_DEBUG_OBJECT (GST_CAT_PARENTAGE, element,
-       "setting child bin's scheduler to be the same as the parent's");
+        "setting child bin's scheduler to be the same as the parent's");
     gst_scheduler_add_element (sched, element);
 
     /* set the children's schedule */
     g_list_foreach (GST_BIN (element)->children,
-       (GFunc) gst_bin_set_element_sched, sched);
+        (GFunc) gst_bin_set_element_sched, sched);
   }
   /* otherwise, if it's just a regular old element */
   else {
@@ -322,19 +322,19 @@ gst_bin_set_element_sched (GstElement * element, GstScheduler * sched)
 
       /* we only operate on real pads */
       if (!GST_IS_REAL_PAD (pad))
-       continue;
+        continue;
 
       /* if the peer element exists and is a candidate */
       if (GST_PAD_PEER (pad)) {
-       if (gst_pad_get_scheduler (GST_PAD_PEER (pad)) == sched) {
-         GST_CAT_LOG (GST_CAT_SCHEDULING,
-             "peer is in same scheduler, telling scheduler");
-
-         if (GST_PAD_IS_SRC (pad))
-           gst_scheduler_pad_link (sched, pad, GST_PAD_PEER (pad));
-         else
-           gst_scheduler_pad_link (sched, GST_PAD_PEER (pad), pad);
-       }
+        if (gst_pad_get_scheduler (GST_PAD_PEER (pad)) == sched) {
+          GST_CAT_LOG (GST_CAT_SCHEDULING,
+              "peer is in same scheduler, telling scheduler");
+
+          if (GST_PAD_IS_SRC (pad))
+            gst_scheduler_pad_link (sched, pad, GST_PAD_PEER (pad));
+          else
+            gst_scheduler_pad_link (sched, GST_PAD_PEER (pad), pad);
+        }
       }
     }
   }
@@ -346,7 +346,7 @@ gst_bin_unset_element_sched (GstElement * element, GstScheduler * sched)
 {
   if (GST_ELEMENT_SCHED (element) == NULL) {
     GST_CAT_DEBUG (GST_CAT_SCHEDULING, "element \"%s\" has no scheduler",
-       GST_ELEMENT_NAME (element));
+        GST_ELEMENT_NAME (element));
     return;
   }
 
@@ -359,15 +359,15 @@ gst_bin_unset_element_sched (GstElement * element, GstScheduler * sched)
 
     if (GST_FLAG_IS_SET (element, GST_BIN_FLAG_MANAGER)) {
       GST_CAT_DEBUG_OBJECT (GST_CAT_PARENTAGE, element,
-         "child is already a manager, not unsetting sched");
+          "child is already a manager, not unsetting sched");
       if (sched) {
-       gst_scheduler_remove_scheduler (sched, GST_ELEMENT_SCHED (element));
+        gst_scheduler_remove_scheduler (sched, GST_ELEMENT_SCHED (element));
       }
       return;
     }
     /* for each child, remove them from their schedule */
     g_list_foreach (GST_BIN (element)->children,
-       (GFunc) gst_bin_unset_element_sched, sched);
+        (GFunc) gst_bin_unset_element_sched, sched);
 
     gst_scheduler_remove_element (GST_ELEMENT_SCHED (element), element);
   }
@@ -385,19 +385,19 @@ gst_bin_unset_element_sched (GstElement * element, GstScheduler * sched)
 
       /* we only operate on real pads */
       if (!GST_IS_REAL_PAD (pad))
-       continue;
+        continue;
 
       /* if the peer element exists and is a candidate */
       if (GST_PAD_PEER (pad)) {
-       if (gst_pad_get_scheduler (GST_PAD_PEER (pad)) == sched) {
-         GST_CAT_LOG (GST_CAT_SCHEDULING,
-             "peer is in same scheduler, telling scheduler");
-
-         if (GST_PAD_IS_SRC (pad))
-           gst_scheduler_pad_unlink (sched, pad, GST_PAD_PEER (pad));
-         else
-           gst_scheduler_pad_unlink (sched, GST_PAD_PEER (pad), pad);
-       }
+        if (gst_pad_get_scheduler (GST_PAD_PEER (pad)) == sched) {
+          GST_CAT_LOG (GST_CAT_SCHEDULING,
+              "peer is in same scheduler, telling scheduler");
+
+          if (GST_PAD_IS_SRC (pad))
+            gst_scheduler_pad_unlink (sched, pad, GST_PAD_PEER (pad));
+          else
+            gst_scheduler_pad_unlink (sched, GST_PAD_PEER (pad), pad);
+        }
       }
     }
     gst_scheduler_remove_element (GST_ELEMENT_SCHED (element), element);
@@ -444,9 +444,9 @@ gst_bin_add_func (GstBin * bin, GstElement * element)
 
   /* then check to see if the element's name is already taken in the bin */
   if (gst_object_check_uniqueness (bin->children,
-         GST_ELEMENT_NAME (element)) == FALSE) {
+          GST_ELEMENT_NAME (element)) == FALSE) {
     g_warning ("Name %s is not unique in bin %s, not adding\n",
-       GST_ELEMENT_NAME (element), GST_ELEMENT_NAME (bin));
+        GST_ELEMENT_NAME (element), GST_ELEMENT_NAME (bin));
     return;
   }
 
@@ -501,8 +501,8 @@ gst_bin_add (GstBin * bin, GstElement * element)
     bclass->add_element (bin, element);
   } else {
     GST_ELEMENT_ERROR (bin, CORE, FAILED, (NULL),
-       ("cannot add element %s to bin %s",
-           GST_ELEMENT_NAME (element), GST_ELEMENT_NAME (bin)));
+        ("cannot add element %s to bin %s",
+            GST_ELEMENT_NAME (element), GST_ELEMENT_NAME (bin)));
   }
 }
 
@@ -518,7 +518,7 @@ gst_bin_remove_func (GstBin * bin, GstElement * element)
   /* the element must be in the bin's list of children */
   if (g_list_find (bin->children, element) == NULL) {
     g_warning ("no element \"%s\" in bin \"%s\"\n", GST_ELEMENT_NAME (element),
-       GST_ELEMENT_NAME (bin));
+        GST_ELEMENT_NAME (bin));
     return;
   }
 
@@ -642,7 +642,7 @@ gst_bin_child_state_change (GstBin * bin, GstElementState oldstate,
     bclass->child_state_change (bin, oldstate, newstate, child);
   } else {
     g_warning ("cannot signal state change of child %s to bin %s\n",
-       GST_ELEMENT_NAME (child), GST_ELEMENT_NAME (bin));
+        GST_ELEMENT_NAME (child), GST_ELEMENT_NAME (bin));
   }
 }
 
@@ -666,17 +666,17 @@ gst_bin_child_state_change_func (GstBin * bin, GstElementState oldstate,
       gint state = (1 << i);
 
       if (GST_STATE (bin) != state) {
-       GST_CAT_DEBUG_OBJECT (GST_CAT_STATES, bin,
-           "highest child state is %s, changing bin state accordingly",
-           gst_element_state_get_name (state));
-       GST_STATE_PENDING (bin) = state;
-       GST_UNLOCK (bin);
-       gst_bin_change_state_norecurse (bin);
-       if (state != GST_STATE (bin)) {
-         g_warning ("%s: state change in callback %d %d",
-             GST_ELEMENT_NAME (bin), state, GST_STATE (bin));
-       }
-       return;
+        GST_CAT_DEBUG_OBJECT (GST_CAT_STATES, bin,
+            "highest child state is %s, changing bin state accordingly",
+            gst_element_state_get_name (state));
+        GST_STATE_PENDING (bin) = state;
+        GST_UNLOCK (bin);
+        gst_bin_change_state_norecurse (bin);
+        if (state != GST_STATE (bin)) {
+          g_warning ("%s: state change in callback %d %d",
+              GST_ELEMENT_NAME (bin), state, GST_STATE (bin));
+        }
+        return;
       }
       break;
     }
@@ -713,8 +713,8 @@ gst_bin_change_state (GstElement * element)
 
   if (old_state == pending) {
     GST_CAT_LOG_OBJECT (GST_CAT_STATES, element,
-       "old and pending state are both %s, returning",
-       gst_element_state_get_name (pending));
+        "old and pending state are both %s, returning",
+        gst_element_state_get_name (pending));
     return GST_STATE_SUCCESS;
   }
 
@@ -732,38 +732,38 @@ gst_bin_change_state (GstElement * element)
     old_child_state = GST_STATE (child);
 
     GST_CAT_DEBUG_OBJECT (GST_CAT_STATES, element,
-       "changing state of child %s from current %s to pending %s",
-       GST_ELEMENT_NAME (child), gst_element_state_get_name (old_child_state),
-       gst_element_state_get_name (pending));
+        "changing state of child %s from current %s to pending %s",
+        GST_ELEMENT_NAME (child), gst_element_state_get_name (old_child_state),
+        gst_element_state_get_name (pending));
 
     switch (gst_element_set_state (child, pending)) {
       case GST_STATE_FAILURE:
-       GST_CAT_INFO_OBJECT (GST_CAT_STATES, element,
-           "child '%s' failed to go to state %d(%s)",
-           GST_ELEMENT_NAME (child),
-           pending, gst_element_state_get_name (pending));
-
-       gst_element_set_state (child, old_child_state);
-       /* There was a check for elements being in the same scheduling group
-          here. Removed by dolphy <julien@moutte.net>. No matter the 
-          scheduling group we should always return a failure. This change
-          seems to work on my machine and fixes tons of issues. If anyone
-          want to revert please tell me what it breaks first, Thanks. */
-       GST_STATE_PENDING (element) = old_state;
-       return GST_STATE_FAILURE;
-       break;
+        GST_CAT_INFO_OBJECT (GST_CAT_STATES, element,
+            "child '%s' failed to go to state %d(%s)",
+            GST_ELEMENT_NAME (child),
+            pending, gst_element_state_get_name (pending));
+
+        gst_element_set_state (child, old_child_state);
+        /* There was a check for elements being in the same scheduling group
+           here. Removed by dolphy <julien@moutte.net>. No matter the 
+           scheduling group we should always return a failure. This change
+           seems to work on my machine and fixes tons of issues. If anyone
+           want to revert please tell me what it breaks first, Thanks. */
+        GST_STATE_PENDING (element) = old_state;
+        return GST_STATE_FAILURE;
+        break;
       case GST_STATE_ASYNC:
-       GST_CAT_INFO_OBJECT (GST_CAT_STATES, element,
-           "child '%s' is changing state asynchronously",
-           GST_ELEMENT_NAME (child));
-       have_async = TRUE;
-       break;
+        GST_CAT_INFO_OBJECT (GST_CAT_STATES, element,
+            "child '%s' is changing state asynchronously",
+            GST_ELEMENT_NAME (child));
+        have_async = TRUE;
+        break;
       case GST_STATE_SUCCESS:
-       GST_CAT_DEBUG (GST_CAT_STATES,
-           "child '%s' changed state to %d(%s) successfully",
-           GST_ELEMENT_NAME (child), pending,
-           gst_element_state_get_name (pending));
-       break;
+        GST_CAT_DEBUG (GST_CAT_STATES,
+            "child '%s' changed state to %d(%s) successfully",
+            GST_ELEMENT_NAME (child), pending,
+            gst_element_state_get_name (pending));
+        break;
     }
   }
 
@@ -858,7 +858,7 @@ gst_bin_get_by_name (GstBin * bin, const gchar * name)
       GstElement *res = gst_bin_get_by_name (GST_BIN (child), name);
 
       if (res)
-       return res;
+        return res;
     }
     children = g_list_next (children);
   }
@@ -945,7 +945,7 @@ gst_bin_get_by_interface (GstBin * bin, GType interface)
 
       ret = gst_bin_get_by_interface (GST_BIN (walk->data), interface);
       if (ret)
-       return ret;
+        return ret;
     }
     walk = g_list_next (walk);
   }
@@ -979,7 +979,7 @@ gst_bin_get_all_by_interface (GstBin * bin, GType interface)
       ret = g_list_prepend (ret, walk->data);
     if (GST_IS_BIN (walk->data)) {
       ret = g_list_concat (ret,
-         gst_bin_get_all_by_interface (GST_BIN (walk->data), interface));
+          gst_bin_get_all_by_interface (GST_BIN (walk->data), interface));
     }
     walk = g_list_next (walk);
   }
@@ -1020,17 +1020,17 @@ gst_bin_sync_children_state (GstBin * bin)
     children = children->next;
     if (GST_STATE (element) != state) {
       switch (gst_element_set_state (element, state)) {
-       case GST_STATE_SUCCESS:
-         break;
-       case GST_STATE_ASYNC:
-         if (ret == GST_STATE_SUCCESS)
-           ret = GST_STATE_ASYNC;
-         break;
-       case GST_STATE_FAILURE:
-         ret = GST_STATE_FAILURE;
-       default:
-         /* make sure gst_element_set_state never returns this */
-         g_assert_not_reached ();
+        case GST_STATE_SUCCESS:
+          break;
+        case GST_STATE_ASYNC:
+          if (ret == GST_STATE_SUCCESS)
+            ret = GST_STATE_ASYNC;
+          break;
+        case GST_STATE_FAILURE:
+          ret = GST_STATE_FAILURE;
+        default:
+          /* make sure gst_element_set_state never returns this */
+          g_assert_not_reached ();
       }
     }
   }
@@ -1075,21 +1075,21 @@ gst_bin_restore_thyself (GstObject * object, xmlNodePtr self)
   while (field) {
     if (!strcmp (field->name, "children")) {
       GST_CAT_INFO (GST_CAT_XML, "[%s]: loading children",
-         GST_ELEMENT_NAME (object));
+          GST_ELEMENT_NAME (object));
       childlist = field->xmlChildrenNode;
       while (childlist) {
-       if (!strcmp (childlist->name, "element")) {
-         GstElement *element =
-             gst_xml_make_element (childlist, GST_OBJECT (bin));
-
-         /* it had to be parented to find the pads, now we ref and unparent so
-          * we can add it to the bin */
-         gst_object_ref (GST_OBJECT (element));
-         gst_object_unparent (GST_OBJECT (element));
-
-         gst_bin_add (bin, element);
-       }
-       childlist = childlist->next;
+        if (!strcmp (childlist->name, "element")) {
+          GstElement *element =
+              gst_xml_make_element (childlist, GST_OBJECT (bin));
+
+          /* it had to be parented to find the pads, now we ref and unparent so
+           * we can add it to the bin */
+          gst_object_ref (GST_OBJECT (element));
+          gst_object_unparent (GST_OBJECT (element));
+
+          gst_bin_add (bin, element);
+        }
+        childlist = childlist->next;
       }
     }
 
@@ -1115,7 +1115,7 @@ gst_bin_iterate_func (GstBin * bin)
     }
   } else {
     g_warning ("bin \"%s\" is not the managing bin, can't be iterated on!\n",
-       GST_ELEMENT_NAME (bin));
+        GST_ELEMENT_NAME (bin));
   }
 
   return FALSE;
@@ -1149,10 +1149,10 @@ gst_bin_iterate (GstBin * bin)
 
   if (!running) {
     if (GST_STATE (bin) == GST_STATE_PLAYING &&
-       GST_STATE_PENDING (bin) == GST_STATE_VOID_PENDING) {
+        GST_STATE_PENDING (bin) == GST_STATE_VOID_PENDING) {
       GST_CAT_DEBUG (GST_CAT_DATAFLOW,
-         "[%s]: polling for child shutdown after useless iteration",
-         GST_ELEMENT_NAME (bin));
+          "[%s]: polling for child shutdown after useless iteration",
+          GST_ELEMENT_NAME (bin));
       g_usleep (1);
       running = TRUE;
     }
index bcf88194416db3f398ab5fab4f2e37dce62b0893..187760795a54e35b3d16b0070a4d2407e0a2188b 100644 (file)
@@ -397,10 +397,10 @@ gst_buffer_span (GstBuffer * buf1, guint32 offset, GstBuffer * buf2,
 
     /* we simply create a subbuffer of the common parent */
     newbuf = gst_buffer_create_sub (parent,
-       buf1->data - parent->data + offset, len);
+        buf1->data - parent->data + offset, len);
   } else {
     GST_CAT_DEBUG (GST_CAT_BUFFER,
-       "slow path taken while spanning buffers %p and %p", buf1, buf2);
+        "slow path taken while spanning buffers %p and %p", buf1, buf2);
     /* otherwise we simply have to brute-force copy the buffers */
     newbuf = gst_buffer_new_and_alloc (len);
 
@@ -408,7 +408,7 @@ gst_buffer_span (GstBuffer * buf1, guint32 offset, GstBuffer * buf2,
     memcpy (newbuf->data, buf1->data + offset, buf1->size - offset);
     /* copy the second buffer's data across */
     memcpy (newbuf->data + (buf1->size - offset), buf2->data,
-       len - (buf1->size - offset));
+        len - (buf1->size - offset));
     /* if the offset is 0, the new buffer has the same timestamp as buf1 */
     if (offset == 0) {
       GST_BUFFER_OFFSET (newbuf) = GST_BUFFER_OFFSET (buf1);
@@ -420,10 +420,10 @@ gst_buffer_span (GstBuffer * buf1, guint32 offset, GstBuffer * buf2,
    * invalid DURATIONS */
   if (offset == 0 && buf1->size + buf2->size == len) {
     if (GST_BUFFER_DURATION_IS_VALID (buf1) &&
-       GST_BUFFER_DURATION_IS_VALID (buf2)) {
+        GST_BUFFER_DURATION_IS_VALID (buf2)) {
       /* add duration */
       GST_BUFFER_DURATION (newbuf) = GST_BUFFER_DURATION (buf1) +
-         GST_BUFFER_DURATION (buf2);
+          GST_BUFFER_DURATION (buf2);
     }
     if (GST_BUFFER_OFFSET_END_IS_VALID (buf2)) {
       /* add offset_end */
index 4d079f199abbcf0b66fd60114a7450a7fb28b58e..f447e533c8425615de3e6d5ca16d2d2496d1492a 100644 (file)
@@ -53,11 +53,11 @@ gst_caps_get_type (void)
 
   if (!gst_caps_type) {
     gst_caps_type = g_boxed_type_register_static ("GstCaps",
-       (GBoxedCopyFunc) gst_caps_copy_conditional,
-       (GBoxedFreeFunc) gst_caps_free);
+        (GBoxedCopyFunc) gst_caps_copy_conditional,
+        (GBoxedFreeFunc) gst_caps_free);
 
     g_value_register_transform_func (gst_caps_type,
-       G_TYPE_STRING, gst_caps_transform_to_string);
+        G_TYPE_STRING, gst_caps_transform_to_string);
   }
 
   return gst_caps_type;
@@ -680,7 +680,8 @@ typedef struct
   GstStructure *dest;
   const GstStructure *intersect;
   gboolean first_run;
-} IntersectData;
+}
+IntersectData;
 
 static gboolean
 gst_caps_structure_intersect_field (GQuark id, GValue * val1, gpointer data)
@@ -719,13 +720,13 @@ gst_caps_structure_intersect (const GstStructure * struct1,
   data.intersect = struct2;
   data.first_run = TRUE;
   if (!gst_structure_foreach ((GstStructure *) struct1,
-         gst_caps_structure_intersect_field, &data))
+          gst_caps_structure_intersect_field, &data))
     goto error;
 
   data.intersect = struct1;
   data.first_run = FALSE;
   if (!gst_structure_foreach ((GstStructure *) struct2,
-         gst_caps_structure_intersect_field, &data))
+          gst_caps_structure_intersect_field, &data))
     goto error;
 
   return data.dest;
@@ -763,10 +764,10 @@ gst_caps_structure_union (const GstStructure * struct1,
       continue;
     } else {
       if (gst_value_union (&dest_value, &field1->value, &field2->value)) {
-       gst_structure_set_value (dest, g_quark_to_string (field1->name),
-           &dest_value);
+        gst_structure_set_value (dest, g_quark_to_string (field1->name),
+            &dest_value);
       } else {
-       ret = gst_value_compare (&field1->value, &field2->value);
+        ret = gst_value_compare (&field1->value, &field2->value);
       }
     }
   }
@@ -862,7 +863,8 @@ typedef struct _NormalizeForeach
 {
   GstCaps *caps;
   GstStructure *structure;
-} NormalizeForeach;
+}
+NormalizeForeach;
 
 static gboolean
 gst_caps_normalize_foreach (GQuark field_id, GValue * value, gpointer ptr)
@@ -915,7 +917,7 @@ gst_caps_normalize (const GstCaps * caps)
     nf.structure = gst_caps_get_structure (newcaps, i);
 
     while (!gst_structure_foreach (nf.structure,
-           gst_caps_normalize_foreach, &nf));
+            gst_caps_normalize_foreach, &nf));
   }
 
   return newcaps;
@@ -982,7 +984,7 @@ gst_caps_simplify (const GstCaps * caps)
     for (j = 0; j < gst_caps_get_size (newcaps); j++) {
       struct2 = gst_caps_get_structure (caps, i);
       if (gst_caps_structure_simplify (struct2, structure)) {
-       break;
+        break;
       }
     }
     if (j == gst_caps_get_size (newcaps)) {
@@ -1023,7 +1025,7 @@ gst_caps_load_thyself (xmlNodePtr parent)
 void
 gst_caps_replace (GstCaps ** caps, GstCaps * newcaps)
 {
-#if 0                          /* disable this, since too many plugins rely on undefined behavior */
+#if 0                           /* disable this, since too many plugins rely on undefined behavior */
 #ifdef USE_POISONING
   //if (newcaps) CAPS_POISON (newcaps);
 #endif
@@ -1203,12 +1205,12 @@ gst_caps_structure_fixate_field_nearest_int (GstStructure * structure,
     for (i = 0; i < n; i++) {
       list_value = gst_value_list_get_value (value, i);
       if (G_VALUE_TYPE (list_value) == G_TYPE_INT) {
-       int x = g_value_get_int (list_value);
+        int x = g_value_get_int (list_value);
 
-       if (best_index == -1 || (ABS (target - x) < ABS (best - x))) {
-         best_index = i;
-         best = x;
-       }
+        if (best_index == -1 || (ABS (target - x) < ABS (best - x))) {
+          best_index = i;
+          best = x;
+        }
       }
     }
     if (best_index != -1) {
@@ -1255,12 +1257,12 @@ gst_caps_structure_fixate_field_nearest_double (GstStructure * structure,
     for (i = 0; i < n; i++) {
       list_value = gst_value_list_get_value (value, i);
       if (G_VALUE_TYPE (list_value) == G_TYPE_DOUBLE) {
-       double x = g_value_get_double (list_value);
+        double x = g_value_get_double (list_value);
 
-       if (best_index == -1 || (ABS (target - x) < ABS (best - x))) {
-         best_index = i;
-         best = x;
-       }
+        if (best_index == -1 || (ABS (target - x) < ABS (best - x))) {
+          best_index = i;
+          best = x;
+        }
       }
     }
     if (best_index != -1) {
index fcf1b70efa6f087b9a61ae37e7dd6b4dfeddae40..ccacd759c7498ca05e4ab800b009d41c77732398 100644 (file)
@@ -346,8 +346,9 @@ gst_clock_get_type (void)
       (GInstanceInitFunc) gst_clock_init,
       NULL
     };
+
     clock_type = g_type_register_static (GST_TYPE_OBJECT, "GstClock",
-       &clock_info, G_TYPE_FLAG_ABSTRACT);
+        &clock_info, G_TYPE_FLAG_ABSTRACT);
   }
   return clock_type;
 }
@@ -380,16 +381,16 @@ gst_clock_class_init (GstClockClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_STATS,
       g_param_spec_boolean ("stats", "Stats", "Enable clock stats",
-         FALSE, G_PARAM_READWRITE));
+          FALSE, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_MAX_DIFF,
       g_param_spec_int64 ("max-diff", "Max diff",
-         "The maximum amount of time to wait in nanoseconds", 0, G_MAXINT64,
-         DEFAULT_MAX_DIFF, G_PARAM_READWRITE));
+          "The maximum amount of time to wait in nanoseconds", 0, G_MAXINT64,
+          DEFAULT_MAX_DIFF, G_PARAM_READWRITE));
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_EVENT_DIFF,
       g_param_spec_uint64 ("event-diff", "event diff",
-         "The amount of time that may elapse until 2 events are treated as happening at different times",
-         0, G_MAXUINT64, DEFAULT_EVENT_DIFF,
-         G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
+          "The amount of time that may elapse until 2 events are treated as happening at different times",
+          0, G_MAXUINT64, DEFAULT_EVENT_DIFF,
+          G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
 }
 
 static void
@@ -475,7 +476,7 @@ gst_clock_set_resolution (GstClock * clock, guint64 resolution)
 
   if (cclass->change_resolution)
     clock->resolution =
-       cclass->change_resolution (clock, clock->resolution, resolution);
+        cclass->change_resolution (clock, clock->resolution, resolution);
 
   return clock->resolution;
 }
@@ -642,10 +643,10 @@ gst_clock_get_event_time (GstClock * clock)
 
   if (clock->last_event + clock->max_event_diff >= time) {
     GST_LOG_OBJECT (clock, "reporting last event time %" G_GUINT64_FORMAT,
-       clock->last_event);
+        clock->last_event);
   } else {
     GST_LOG_OBJECT (clock, "reporting new event time %" G_GUINT64_FORMAT,
-       clock->last_event);
+        clock->last_event);
     clock->last_event = time;
   }
 
index 8d47f86c51f06390478f67eb2b130c79473cdb1c..7606b748a7bd64786061af1219eeba146a7728bf 100644 (file)
@@ -94,12 +94,12 @@ _gst_cpu_initialize_i386 (gulong * flags, GString * featurelist)
       gst_cpuid_i386 (0x80000001, &eax, &ebx, &ecx, &edx);
 
       if (edx & (1 << 31)) {
-       _gst_cpu_flags |= GST_CPU_FLAG_3DNOW;
-       g_string_append (featurelist, "3DNOW ");
+        _gst_cpu_flags |= GST_CPU_FLAG_3DNOW;
+        g_string_append (featurelist, "3DNOW ");
       }
       if (AMD && (edx & (1 << 22))) {
-       _gst_cpu_flags |= GST_CPU_FLAG_MMXEXT;
-       g_string_append (featurelist, "MMXEXT ");
+        _gst_cpu_flags |= GST_CPU_FLAG_MMXEXT;
+        g_string_append (featurelist, "MMXEXT ");
       }
     }
   }
index 27664820f017927701b98e9d179772aeee6bb219..359748b44bf5c2151bb0f2c604d799cb588234fe 100644 (file)
@@ -34,7 +34,7 @@ gst_data_get_type (void)
 
   if (!type)
     type = g_boxed_type_register_static ("GstData",
-       (GBoxedCopyFunc) gst_data_copy, (GBoxedFreeFunc) gst_data_unref);
+        (GBoxedCopyFunc) gst_data_copy, (GBoxedFreeFunc) gst_data_unref);
   return type;
 }
 
index cc7c129d274d73acffa313e8440da36c6b9060fb..e1d28dd1a1c1533d94abb87d624610fd741c0826 100644 (file)
@@ -103,8 +103,9 @@ gst_element_get_type (void)
       (GInstanceInitFunc) gst_element_init,
       NULL
     };
+
     _gst_element_type = g_type_register_static (GST_TYPE_OBJECT, "GstElement",
-       &element_info, G_TYPE_FLAG_ABSTRACT);
+        &element_info, G_TYPE_FLAG_ABSTRACT);
   }
   return _gst_element_type;
 }
@@ -260,7 +261,8 @@ typedef struct
 {
   const GParamSpec *pspec;
   GValue value;
-} prop_value_t;
+}
+prop_value_t;
 
 static void
 element_set_property (GstElement * element, const GParamSpec * pspec,
@@ -352,7 +354,7 @@ gst_element_set_pending_properties (GstElement * element)
 
   while ((prop_value = g_async_queue_try_pop (element->prop_value_queue))) {
     g_object_set_property ((GObject *) element, prop_value->pspec->name,
-       &prop_value->value);
+        &prop_value->value);
     g_value_unset (&prop_value->value);
     g_free (prop_value);
   }
@@ -446,12 +448,12 @@ gst_element_set_valist (GstElement * element, const gchar * first_property_name,
 
     if (!pspec) {
       g_warning ("%s: object class `%s' has no property named `%s'",
-         G_STRLOC, G_OBJECT_TYPE_NAME (object), name);
+          G_STRLOC, G_OBJECT_TYPE_NAME (object), name);
       break;
     }
     if (!(pspec->flags & G_PARAM_WRITABLE)) {
       g_warning ("%s: property `%s' of object class `%s' is not writable",
-         G_STRLOC, pspec->name, G_OBJECT_TYPE_NAME (object));
+          G_STRLOC, pspec->name, G_OBJECT_TYPE_NAME (object));
       break;
     }
 
@@ -515,12 +517,12 @@ gst_element_get_valist (GstElement * element, const gchar * first_property_name,
 
     if (!pspec) {
       g_warning ("%s: object class `%s' has no property named `%s'",
-         G_STRLOC, G_OBJECT_TYPE_NAME (object), name);
+          G_STRLOC, G_OBJECT_TYPE_NAME (object), name);
       break;
     }
     if (!(pspec->flags & G_PARAM_READABLE)) {
       g_warning ("%s: property `%s' of object class `%s' is not readable",
-         G_STRLOC, pspec->name, G_OBJECT_TYPE_NAME (object));
+          G_STRLOC, pspec->name, G_OBJECT_TYPE_NAME (object));
       break;
     }
 
@@ -580,7 +582,7 @@ gst_element_set_property (GstElement * element, const gchar * property_name,
 
   if (!pspec)
     g_warning ("%s: object class `%s' has no property named `%s'",
-       G_STRLOC, G_OBJECT_TYPE_NAME (object), property_name);
+        G_STRLOC, G_OBJECT_TYPE_NAME (object), property_name);
   else
     element_set_property (element, pspec, value);
 
@@ -621,7 +623,7 @@ gst_element_get_property (GstElement * element, const gchar * property_name,
 
   if (!pspec)
     g_warning ("%s: object class `%s' has no property named `%s'",
-       G_STRLOC, G_OBJECT_TYPE_NAME (object), property_name);
+        G_STRLOC, G_OBJECT_TYPE_NAME (object), property_name);
   else {
     GValue *prop_value, tmp_value = { 0, };
 
@@ -631,11 +633,11 @@ gst_element_get_property (GstElement * element, const gchar * property_name,
       g_value_reset (value);
       prop_value = value;
     } else if (!g_value_type_transformable (G_PARAM_SPEC_VALUE_TYPE (pspec),
-           G_VALUE_TYPE (value))) {
+            G_VALUE_TYPE (value))) {
       g_warning
-         ("can't retrieve property `%s' of type `%s' as value of type `%s'",
-         pspec->name, g_type_name (G_PARAM_SPEC_VALUE_TYPE (pspec)),
-         G_VALUE_TYPE_NAME (value));
+          ("can't retrieve property `%s' of type `%s' as value of type `%s'",
+          pspec->name, g_type_name (G_PARAM_SPEC_VALUE_TYPE (pspec)),
+          G_VALUE_TYPE_NAME (value));
       g_object_unref (object);
       return;
     } else {
@@ -787,8 +789,8 @@ gst_element_clock_wait (GstElement * element, GstClockID id,
   if (GST_ELEMENT_SCHED (element)) {
     GST_CAT_DEBUG (GST_CAT_CLOCK, "waiting on scheduler clock");
     res =
-       gst_scheduler_clock_wait (GST_ELEMENT_SCHED (element), element, id,
-       jitter);
+        gst_scheduler_clock_wait (GST_ELEMENT_SCHED (element), element, id,
+        jitter);
   } else {
     GST_CAT_DEBUG (GST_CAT_CLOCK, "no scheduler, returning GST_CLOCK_TIMEOUT");
     res = GST_CLOCK_TIMEOUT;
@@ -894,7 +896,7 @@ gst_element_set_time (GstElement * element, GstClockTime time)
     case GST_STATE_PLAYING:
       event_time = gst_clock_get_event_time (element->clock);
       GST_CAT_LOG_OBJECT (GST_CAT_CLOCK, element,
-         "clock time %llu: setting element time to %llu", event_time, time);
+          "clock time %llu: setting element time to %llu", event_time, time);
       element->base_time = event_time - time;
       break;
     default:
@@ -925,21 +927,21 @@ gst_element_adjust_time (GstElement * element, GstClockTimeDiff diff)
   switch (element->current_state) {
     case GST_STATE_PAUSED:
       if (diff < 0 && element->base_time < abs (diff)) {
-       g_warning ("attempted to set the current time of element %s below 0",
-           GST_OBJECT_NAME (element));
-       element->base_time = 0;
+        g_warning ("attempted to set the current time of element %s below 0",
+            GST_OBJECT_NAME (element));
+        element->base_time = 0;
       } else {
-       element->base_time += diff;
+        element->base_time += diff;
       }
       break;
     case GST_STATE_PLAYING:
       time = gst_clock_get_time (element->clock);
       if (time < element->base_time - diff) {
-       g_warning ("attempted to set the current time of element %s below 0",
-           GST_OBJECT_NAME (element));
-       element->base_time = time;
+        g_warning ("attempted to set the current time of element %s below 0",
+            GST_OBJECT_NAME (element));
+        element->base_time = time;
       } else {
-       element->base_time -= diff;
+        element->base_time -= diff;
       }
       break;
     default:
@@ -1059,7 +1061,7 @@ gst_element_add_pad (GstElement * element, GstPad * pad)
 
   /* then check to see if there's already a pad by that name here */
   g_return_if_fail (gst_object_check_uniqueness (element->pads,
-         GST_PAD_NAME (pad)) == TRUE);
+          GST_PAD_NAME (pad)) == TRUE);
 
   GST_CAT_INFO_OBJECT (GST_CAT_ELEMENT_PADS, element, "adding pad '%s'",
       GST_STR_NULL (GST_OBJECT_NAME (pad)));
@@ -1114,7 +1116,7 @@ gst_element_add_ghost_pad (GstElement * element, GstPad * pad,
 
   /* then check to see if there's already a pad by that name here */
   g_return_val_if_fail (gst_object_check_uniqueness (element->pads,
-         name) == TRUE, NULL);
+          name) == TRUE, NULL);
 
   ghostpad = gst_ghost_pad_new (name, pad);
 
@@ -1244,7 +1246,7 @@ gst_element_get_static_pad (GstElement * element, const gchar * name)
     pad = GST_PAD (walk->data);
     if (strcmp (GST_PAD_NAME (pad), name) == 0) {
       GST_CAT_INFO (GST_CAT_ELEMENT_PADS, "found pad %s:%s",
-         GST_DEBUG_PAD_NAME (pad));
+          GST_DEBUG_PAD_NAME (pad));
       return pad;
     }
     walk = g_list_next (walk);
@@ -1291,31 +1293,31 @@ gst_element_get_request_pad (GstElement * element, const gchar * name)
     while (!templ_found && list) {
       templ = (GstPadTemplate *) list->data;
       if (templ->presence == GST_PAD_REQUEST) {
-       /* Because of sanity checks in gst_pad_template_new(), we know that %s
-          and %d, occurring at the end of the name_template, are the only
-          possibilities. */
-       GST_CAT_DEBUG (GST_CAT_PADS, "comparing %s to %s", name,
-           templ->name_template);
-       if ((str = strchr (templ->name_template, '%'))
-           && strncmp (templ->name_template, name,
-               str - templ->name_template) == 0
-           && strlen (name) > str - templ->name_template) {
-         data = name + (str - templ->name_template);
-         if (*(str + 1) == 'd') {
-           /* it's an int */
-           n = (gint) strtol (data, &endptr, 10);
-           if (endptr && *endptr == '\0') {
-             templ_found = TRUE;
-             req_name = name;
-             break;
-           }
-         } else {
-           /* it's a string */
-           templ_found = TRUE;
-           req_name = name;
-           break;
-         }
-       }
+        /* Because of sanity checks in gst_pad_template_new(), we know that %s
+           and %d, occurring at the end of the name_template, are the only
+           possibilities. */
+        GST_CAT_DEBUG (GST_CAT_PADS, "comparing %s to %s", name,
+            templ->name_template);
+        if ((str = strchr (templ->name_template, '%'))
+            && strncmp (templ->name_template, name,
+                str - templ->name_template) == 0
+            && strlen (name) > str - templ->name_template) {
+          data = name + (str - templ->name_template);
+          if (*(str + 1) == 'd') {
+            /* it's an int */
+            n = (gint) strtol (data, &endptr, 10);
+            if (endptr && *endptr == '\0') {
+              templ_found = TRUE;
+              req_name = name;
+              break;
+            }
+          } else {
+            /* it's a string */
+            templ_found = TRUE;
+            req_name = name;
+            break;
+          }
+        }
       }
       list = list->next;
     }
@@ -1365,7 +1367,7 @@ gst_element_class_add_pad_template (GstElementClass * klass,
 
   /* avoid registering pad templates with the same name */
   g_return_if_fail (gst_element_class_get_pad_template (klass,
-         templ->name_template) == NULL);
+          templ->name_template) == NULL);
 
   klass->padtemplates = g_list_append (klass->padtemplates,
       gst_object_ref (GST_OBJECT (templ)));
@@ -1521,21 +1523,21 @@ gst_element_get_compatible_pad_template (GstElement * element,
      */
     if (padtempl->direction != compattempl->direction) {
       GST_CAT_DEBUG (GST_CAT_CAPS,
-         "compatible direction: found %s pad template \"%s\"",
-         padtempl->direction == GST_PAD_SRC ? "src" : "sink",
-         padtempl->name_template);
+          "compatible direction: found %s pad template \"%s\"",
+          padtempl->direction == GST_PAD_SRC ? "src" : "sink",
+          padtempl->name_template);
 
       intersection = gst_caps_intersect (GST_PAD_TEMPLATE_CAPS (compattempl),
-         GST_PAD_TEMPLATE_CAPS (padtempl));
+          GST_PAD_TEMPLATE_CAPS (padtempl));
 
       GST_CAT_DEBUG (GST_CAT_CAPS, "caps are %scompatible",
-         (intersection ? "" : "not "));
+          (intersection ? "" : "not "));
 
       if (!gst_caps_is_empty (intersection))
-       newtempl = padtempl;
+        newtempl = padtempl;
       gst_caps_free (intersection);
       if (newtempl)
-       break;
+        break;
     }
 
     padlist = g_list_next (padlist);
@@ -1572,9 +1574,9 @@ gst_element_get_pad_from_template (GstElement * element, GstPadTemplate * templ)
     case GST_PAD_SOMETIMES:
       ret = gst_element_get_static_pad (element, templ->name_template);
       if (!ret && presence == GST_PAD_ALWAYS)
-       g_warning
-           ("Element %s has an ALWAYS template %s, but no pad of the same name",
-           GST_OBJECT_NAME (element), templ->name_template);
+        g_warning
+            ("Element %s has an ALWAYS template %s, but no pad of the same name",
+            GST_OBJECT_NAME (element), templ->name_template);
       break;
 
     case GST_PAD_REQUEST:
@@ -1658,7 +1660,7 @@ gst_element_get_compatible_pad_filtered (GstElement * element, GstPad * pad,
     GstPad *current = GST_PAD (pads->data);
 
     if (GST_PAD_PEER (current) == NULL &&
-       gst_pad_can_link_filtered (pad, current, filtercaps)) {
+        gst_pad_can_link_filtered (pad, current, filtercaps)) {
       return current;
     }
     pads = g_list_next (pads);
@@ -1745,18 +1747,18 @@ gst_element_link_pads_filtered (GstElement * src, const gchar * srcpadname,
     srcpad = gst_element_get_pad (src, srcpadname);
     if (!srcpad) {
       GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "no pad %s:%s",
-         GST_ELEMENT_NAME (src), srcpadname);
+          GST_ELEMENT_NAME (src), srcpadname);
       return FALSE;
     } else {
       if (!(GST_PAD_DIRECTION (srcpad) == GST_PAD_SRC)) {
-       GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "pad %s:%s is no src pad",
-           GST_DEBUG_PAD_NAME (srcpad));
-       return FALSE;
+        GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "pad %s:%s is no src pad",
+            GST_DEBUG_PAD_NAME (srcpad));
+        return FALSE;
       }
       if (GST_PAD_PEER (srcpad) != NULL) {
-       GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "pad %s:%s is already linked",
-           GST_DEBUG_PAD_NAME (srcpad));
-       return FALSE;
+        GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "pad %s:%s is already linked",
+            GST_DEBUG_PAD_NAME (srcpad));
+        return FALSE;
       }
     }
     srcpads = NULL;
@@ -1768,18 +1770,18 @@ gst_element_link_pads_filtered (GstElement * src, const gchar * srcpadname,
     destpad = gst_element_get_pad (dest, destpadname);
     if (!destpad) {
       GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "no pad %s:%s",
-         GST_ELEMENT_NAME (dest), destpadname);
+          GST_ELEMENT_NAME (dest), destpadname);
       return FALSE;
     } else {
       if (!(GST_PAD_DIRECTION (destpad) == GST_PAD_SINK)) {
-       GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "pad %s:%s is no sink pad",
-           GST_DEBUG_PAD_NAME (destpad));
-       return FALSE;
+        GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "pad %s:%s is no sink pad",
+            GST_DEBUG_PAD_NAME (destpad));
+        return FALSE;
       }
       if (GST_PAD_PEER (destpad) != NULL) {
-       GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "pad %s:%s is already linked",
-           GST_DEBUG_PAD_NAME (destpad));
-       return FALSE;
+        GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "pad %s:%s is already linked",
+            GST_DEBUG_PAD_NAME (destpad));
+        return FALSE;
       }
     }
     destpads = NULL;
@@ -1796,60 +1798,60 @@ gst_element_link_pads_filtered (GstElement * src, const gchar * srcpadname,
     /* loop through the allowed pads in the source, trying to find a
      * compatible destination pad */
     GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS,
-       "looping through allowed src and dest pads");
+        "looping through allowed src and dest pads");
     do {
       GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "trying src pad %s:%s",
-         GST_DEBUG_PAD_NAME (srcpad));
+          GST_DEBUG_PAD_NAME (srcpad));
       if ((GST_PAD_DIRECTION (srcpad) == GST_PAD_SRC) &&
-         (GST_PAD_PEER (srcpad) == NULL)) {
-       GstPad *temp = gst_element_get_compatible_pad_filtered (dest, srcpad,
-           filtercaps);
-
-       if (temp && gst_pad_link_filtered (srcpad, temp, filtercaps)) {
-         GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "linked pad %s:%s to pad %s:%s",
-             GST_DEBUG_PAD_NAME (srcpad), GST_DEBUG_PAD_NAME (temp));
-         return TRUE;
-       }
+          (GST_PAD_PEER (srcpad) == NULL)) {
+        GstPad *temp = gst_element_get_compatible_pad_filtered (dest, srcpad,
+            filtercaps);
+
+        if (temp && gst_pad_link_filtered (srcpad, temp, filtercaps)) {
+          GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "linked pad %s:%s to pad %s:%s",
+              GST_DEBUG_PAD_NAME (srcpad), GST_DEBUG_PAD_NAME (temp));
+          return TRUE;
+        }
       }
       /* find a better way for this mess */
       if (srcpads) {
-       srcpads = g_list_next (srcpads);
-       if (srcpads)
-         srcpad = (GstPad *) GST_PAD_REALIZE (srcpads->data);
+        srcpads = g_list_next (srcpads);
+        if (srcpads)
+          srcpad = (GstPad *) GST_PAD_REALIZE (srcpads->data);
       }
     } while (srcpads);
   }
   if (srcpadname) {
     GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "no link possible from %s:%s to %s",
-       GST_DEBUG_PAD_NAME (srcpad), GST_ELEMENT_NAME (dest));
+        GST_DEBUG_PAD_NAME (srcpad), GST_ELEMENT_NAME (dest));
     return FALSE;
   }
   if (destpad) {
     /* loop through the existing pads in the destination */
     do {
       GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "trying dest pad %s:%s",
-         GST_DEBUG_PAD_NAME (destpad));
+          GST_DEBUG_PAD_NAME (destpad));
       if ((GST_PAD_DIRECTION (destpad) == GST_PAD_SINK) &&
-         (GST_PAD_PEER (destpad) == NULL)) {
-       GstPad *temp = gst_element_get_compatible_pad_filtered (src, destpad,
-           filtercaps);
-
-       if (temp && gst_pad_link_filtered (temp, destpad, filtercaps)) {
-         GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "linked pad %s:%s to pad %s:%s",
-             GST_DEBUG_PAD_NAME (temp), GST_DEBUG_PAD_NAME (destpad));
-         return TRUE;
-       }
+          (GST_PAD_PEER (destpad) == NULL)) {
+        GstPad *temp = gst_element_get_compatible_pad_filtered (src, destpad,
+            filtercaps);
+
+        if (temp && gst_pad_link_filtered (temp, destpad, filtercaps)) {
+          GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "linked pad %s:%s to pad %s:%s",
+              GST_DEBUG_PAD_NAME (temp), GST_DEBUG_PAD_NAME (destpad));
+          return TRUE;
+        }
       }
       if (destpads) {
-       destpads = g_list_next (destpads);
-       if (destpads)
-         destpad = (GstPad *) GST_PAD_REALIZE (destpads->data);
+        destpads = g_list_next (destpads);
+        if (destpads)
+          destpad = (GstPad *) GST_PAD_REALIZE (destpads->data);
       }
     } while (destpads);
   }
   if (destpadname) {
     GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "no link possible from %s to %s:%s",
-       GST_ELEMENT_NAME (src), GST_DEBUG_PAD_NAME (destpad));
+        GST_ELEMENT_NAME (src), GST_DEBUG_PAD_NAME (destpad));
     return FALSE;
   }
 
@@ -1862,28 +1864,28 @@ gst_element_link_pads_filtered (GstElement * src, const gchar * srcpadname,
     while (srctempls) {
       srctempl = (GstPadTemplate *) srctempls->data;
       if (srctempl->presence == GST_PAD_REQUEST) {
-       for (l = desttempls; l; l = l->next) {
-         desttempl = (GstPadTemplate *) l->data;
-         if (desttempl->presence == GST_PAD_REQUEST &&
-             desttempl->direction != srctempl->direction) {
-           if (gst_caps_is_always_compatible (gst_pad_template_get_caps
-                   (srctempl), gst_pad_template_get_caps (desttempl))) {
-             srcpad =
-                 gst_element_get_request_pad (src, srctempl->name_template);
-             destpad =
-                 gst_element_get_request_pad (dest, desttempl->name_template);
-             if (gst_pad_link_filtered (srcpad, destpad, filtercaps)) {
-               GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS,
-                   "linked pad %s:%s to pad %s:%s",
-                   GST_DEBUG_PAD_NAME (srcpad), GST_DEBUG_PAD_NAME (destpad));
-               return TRUE;
-             }
-             /* it failed, so we release the request pads */
-             gst_element_release_request_pad (src, srcpad);
-             gst_element_release_request_pad (dest, destpad);
-           }
-         }
-       }
+        for (l = desttempls; l; l = l->next) {
+          desttempl = (GstPadTemplate *) l->data;
+          if (desttempl->presence == GST_PAD_REQUEST &&
+              desttempl->direction != srctempl->direction) {
+            if (gst_caps_is_always_compatible (gst_pad_template_get_caps
+                    (srctempl), gst_pad_template_get_caps (desttempl))) {
+              srcpad =
+                  gst_element_get_request_pad (src, srctempl->name_template);
+              destpad =
+                  gst_element_get_request_pad (dest, desttempl->name_template);
+              if (gst_pad_link_filtered (srcpad, destpad, filtercaps)) {
+                GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS,
+                    "linked pad %s:%s to pad %s:%s",
+                    GST_DEBUG_PAD_NAME (srcpad), GST_DEBUG_PAD_NAME (destpad));
+                return TRUE;
+              }
+              /* it failed, so we release the request pads */
+              gst_element_release_request_pad (src, srcpad);
+              gst_element_release_request_pad (dest, destpad);
+            }
+          }
+        }
       }
       srctempls = srctempls->next;
     }
@@ -2017,7 +2019,7 @@ gst_element_unlink_pads (GstElement * src, const gchar * srcpadname,
   destpad = gst_element_get_pad (dest, destpadname);
   if (srcpad == NULL) {
     GST_WARNING_OBJECT (dest, "destination element has no pad \"%s\"",
-       destpadname);
+        destpadname);
     return;
   }
 
@@ -2085,7 +2087,7 @@ gst_element_unlink (GstElement * src, GstElement * dest)
       /* see if the pad is connected and is really a pad
        * of dest */
       if (peerpad && (GST_OBJECT_PARENT (peerpad) == (GstObject *) dest)) {
-       gst_pad_unlink (pad, peerpad);
+        gst_pad_unlink (pad, peerpad);
       }
     }
 
@@ -2100,17 +2102,17 @@ gst_element_error_func (GstElement * element, GstElement * source,
   /* tell the parent */
   if (GST_OBJECT_PARENT (element)) {
     GST_CAT_DEBUG (GST_CAT_ERROR_SYSTEM,
-       "forwarding error \"%s\" from %s to %s", error->message,
-       GST_ELEMENT_NAME (element),
-       GST_OBJECT_NAME (GST_OBJECT_PARENT (element)));
+        "forwarding error \"%s\" from %s to %s", error->message,
+        GST_ELEMENT_NAME (element),
+        GST_OBJECT_NAME (GST_OBJECT_PARENT (element)));
 
     gst_object_ref (GST_OBJECT (element));
     g_signal_emit (G_OBJECT (GST_OBJECT_PARENT (element)),
-       gst_element_signals[ERROR], 0, source, error, debug);
+        gst_element_signals[ERROR], 0, source, error, debug);
     gst_object_unref (GST_OBJECT (element));
     GST_CAT_DEBUG (GST_CAT_ERROR_SYSTEM, "forwarded error \"%s\" from %s to %s",
-       error->message, GST_ELEMENT_NAME (element),
-       GST_OBJECT_NAME (GST_OBJECT_PARENT (element)));
+        error->message, GST_ELEMENT_NAME (element),
+        GST_OBJECT_NAME (GST_OBJECT_PARENT (element)));
   }
 }
 
@@ -2124,18 +2126,18 @@ gst_element_get_random_pad (GstElement * element, GstPadDirection dir)
     GstPad *pad = GST_PAD (pads->data);
 
     GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "checking pad %s:%s",
-       GST_DEBUG_PAD_NAME (pad));
+        GST_DEBUG_PAD_NAME (pad));
 
     if (GST_PAD_DIRECTION (pad) == dir) {
       if (GST_PAD_IS_LINKED (pad)) {
-       return pad;
+        return pad;
       } else {
-       GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "pad %s:%s is not linked",
-           GST_DEBUG_PAD_NAME (pad));
+        GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "pad %s:%s is not linked",
+            GST_DEBUG_PAD_NAME (pad));
       }
     } else {
       GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "pad %s:%s is in wrong direction",
-         GST_DEBUG_PAD_NAME (pad));
+          GST_DEBUG_PAD_NAME (pad));
     }
 
     pads = g_list_next (pads);
@@ -2203,7 +2205,7 @@ gst_element_send_event (GstElement * element, GstEvent * event)
 
     if (pad) {
       GST_CAT_DEBUG (GST_CAT_ELEMENT_PADS, "sending event to random pad %s:%s",
-         GST_DEBUG_PAD_NAME (pad));
+          GST_DEBUG_PAD_NAME (pad));
       return gst_pad_send_event (GST_PAD_PEER (pad), event);
     }
   }
@@ -2371,13 +2373,13 @@ gst_element_convert (GstElement * element,
 
   if (oclass->convert)
     return oclass->convert (element,
-       src_format, src_value, dest_format, dest_value);
+        src_format, src_value, dest_format, dest_value);
   else {
     GstPad *pad = gst_element_get_random_pad (element, GST_PAD_SINK);
 
     if (pad)
       return gst_pad_convert (GST_PAD_PEER (pad),
-         src_format, src_value, dest_format, dest_value);
+          src_format, src_value, dest_format, dest_value);
   }
 
   return FALSE;
@@ -2456,7 +2458,7 @@ void gst_element_error_full
   /* if the element was already in error, stop now */
   if (GST_FLAG_IS_SET (element, GST_ELEMENT_IN_ERROR)) {
     GST_CAT_INFO (GST_CAT_ERROR_SYSTEM, "recursive ERROR detected in %s",
-       GST_ELEMENT_NAME (element));
+        GST_ELEMENT_NAME (element));
     g_free (sent_message);
     if (debug)
       g_free (debug);
@@ -2470,7 +2472,7 @@ void gst_element_error_full
   name = gst_object_get_path_string (GST_OBJECT (element));
   if (debug)
     sent_debug = g_strdup_printf ("%s(%d): %s: %s:\n%s",
-       file, line, function, name, debug ? debug : "");
+        file, line, function, name, debug ? debug : "");
   else
     sent_debug = NULL;
   g_free (debug);
@@ -2491,7 +2493,7 @@ void gst_element_error_full
     ret = gst_element_set_state (element, GST_STATE_PAUSED);
     if (ret != GST_STATE_SUCCESS) {
       g_warning ("could not PAUSE element \"%s\" after error, help!",
-         GST_ELEMENT_NAME (element));
+          GST_ELEMENT_NAME (element));
     }
   }
 
@@ -2546,11 +2548,11 @@ gst_element_set_locked_state (GstElement * element, gboolean locked_state)
 
   if (locked_state) {
     GST_CAT_DEBUG (GST_CAT_STATES, "locking state of element %s",
-       GST_ELEMENT_NAME (element));
+        GST_ELEMENT_NAME (element));
     GST_FLAG_SET (element, GST_ELEMENT_LOCKED_STATE);
   } else {
     GST_CAT_DEBUG (GST_CAT_STATES, "unlocking state of element %s",
-       GST_ELEMENT_NAME (element));
+        GST_ELEMENT_NAME (element));
     GST_FLAG_UNSET (element, GST_ELEMENT_LOCKED_STATE);
   }
 }
@@ -2640,8 +2642,8 @@ gst_element_set_state (GstElement * element, GstElementState state)
 
   if (state == curpending) {
     GST_CAT_DEBUG_OBJECT (GST_CAT_STATES, element,
-       "element is already in requested state %s",
-       gst_element_state_get_name (state));
+        "element is already in requested state %s",
+        gst_element_state_get_name (state));
     return (GST_STATE_SUCCESS);
   }
 
@@ -2664,9 +2666,9 @@ gst_element_set_state (GstElement * element, GstElementState state)
 
     if (curpending != state) {
       GST_CAT_DEBUG_OBJECT (GST_CAT_STATES, element,
-         "intermediate: setting state from %s to %s",
-         gst_element_state_get_name (GST_STATE (element)),
-         gst_element_state_get_name (curpending));
+          "intermediate: setting state from %s to %s",
+          gst_element_state_get_name (GST_STATE (element)),
+          gst_element_state_get_name (curpending));
     }
 
     /* call the state change function so it can set the state */
@@ -2676,31 +2678,31 @@ gst_element_set_state (GstElement * element, GstElementState state)
 
     switch (return_val) {
       case GST_STATE_FAILURE:
-       GST_CAT_INFO_OBJECT (GST_CAT_STATES, element,
-           "have failed change_state return");
-       goto exit;
+        GST_CAT_INFO_OBJECT (GST_CAT_STATES, element,
+            "have failed change_state return");
+        goto exit;
       case GST_STATE_ASYNC:
-       GST_CAT_INFO_OBJECT (GST_CAT_STATES, element,
-           "element will change state async");
-       goto exit;
+        GST_CAT_INFO_OBJECT (GST_CAT_STATES, element,
+            "element will change state async");
+        goto exit;
       case GST_STATE_SUCCESS:
-       /* Last thing we do is verify that a successful state change really
-        * did change the state... */
-       /* if it did not, this is an error - fix the element that does this */
-       if (GST_STATE (element) != curpending) {
-         g_warning ("element %s claimed state-change success,"
-             "but state didn't change to %s. State is %s (%s pending), fix the element",
-             GST_ELEMENT_NAME (element),
-             gst_element_state_get_name (curpending),
-             gst_element_state_get_name (GST_STATE (element)),
-             gst_element_state_get_name (GST_STATE_PENDING (element)));
-         return_val = GST_STATE_FAILURE;
-         goto exit;
-       }
-       break;
+        /* Last thing we do is verify that a successful state change really
+         * did change the state... */
+        /* if it did not, this is an error - fix the element that does this */
+        if (GST_STATE (element) != curpending) {
+          g_warning ("element %s claimed state-change success,"
+              "but state didn't change to %s. State is %s (%s pending), fix the element",
+              GST_ELEMENT_NAME (element),
+              gst_element_state_get_name (curpending),
+              gst_element_state_get_name (GST_STATE (element)),
+              gst_element_state_get_name (GST_STATE_PENDING (element)));
+          return_val = GST_STATE_FAILURE;
+          goto exit;
+        }
+        break;
       default:
-       /* somebody added a GST_STATE_ and forgot to do stuff here ! */
-       g_assert_not_reached ();
+        /* somebody added a GST_STATE_ and forgot to do stuff here ! */
+        g_assert_not_reached ();
     }
   }
 exit:
@@ -2738,35 +2740,35 @@ gst_element_negotiate_pads (GstElement * element)
       /* check the parent of the peer pad, if there is no parent do nothing */
       parent = GST_PAD_PARENT (sinkpad);
       if (!parent)
-       continue;
+        continue;
 
       /* skips pads that were already negotiating */
       if (GST_FLAG_IS_SET (sinkpad, GST_PAD_NEGOTIATING) ||
-         GST_FLAG_IS_SET (srcpad, GST_PAD_NEGOTIATING))
-       continue;
+          GST_FLAG_IS_SET (srcpad, GST_PAD_NEGOTIATING))
+        continue;
 
       otherstate = GST_STATE (parent);
 
       /* swap pads if needed */
       if (!GST_PAD_IS_SRC (srcpad)) {
-       GstRealPad *temp;
+        GstRealPad *temp;
 
-       temp = srcpad;
-       srcpad = sinkpad;
-       sinkpad = temp;
+        temp = srcpad;
+        srcpad = sinkpad;
+        sinkpad = temp;
       }
 
       /* only try to negotiate if the peer element is in PAUSED or higher too */
       if (otherstate >= GST_STATE_READY) {
-       GST_CAT_DEBUG_OBJECT (GST_CAT_CAPS, element,
-           "perform negotiate for %s:%s and %s:%s",
-           GST_DEBUG_PAD_NAME (srcpad), GST_DEBUG_PAD_NAME (sinkpad));
-       if (gst_pad_renegotiate (pad) == GST_PAD_LINK_REFUSED)
-         return FALSE;
+        GST_CAT_DEBUG_OBJECT (GST_CAT_CAPS, element,
+            "perform negotiate for %s:%s and %s:%s",
+            GST_DEBUG_PAD_NAME (srcpad), GST_DEBUG_PAD_NAME (sinkpad));
+        if (gst_pad_renegotiate (pad) == GST_PAD_LINK_REFUSED)
+          return FALSE;
       } else {
-       GST_CAT_DEBUG_OBJECT (GST_CAT_CAPS, element,
-           "not negotiating %s:%s and %s:%s, not in READY yet",
-           GST_DEBUG_PAD_NAME (srcpad), GST_DEBUG_PAD_NAME (sinkpad));
+        GST_CAT_DEBUG_OBJECT (GST_CAT_CAPS, element,
+            "not negotiating %s:%s and %s:%s, not in READY yet",
+            GST_DEBUG_PAD_NAME (srcpad), GST_DEBUG_PAD_NAME (sinkpad));
       }
     }
   }
@@ -2826,8 +2828,8 @@ gst_element_change_state (GstElement * element)
   if (old_pending == GST_STATE_VOID_PENDING ||
       old_state == GST_STATE_PENDING (element)) {
     GST_CAT_DEBUG_OBJECT (GST_CAT_STATES, element,
-       "element is already in the %s state",
-       gst_element_state_get_name (old_state));
+        "element is already in the %s state",
+        gst_element_state_get_name (old_state));
     return GST_STATE_SUCCESS;
   }
 
@@ -2843,30 +2845,30 @@ gst_element_change_state (GstElement * element)
   switch (old_transition) {
     case GST_STATE_PLAYING_TO_PAUSED:
       if (element->clock) {
-       GstClockTime time = gst_clock_get_event_time (element->clock);
+        GstClockTime time = gst_clock_get_event_time (element->clock);
 
-       g_assert (time >= element->base_time);
-       element->base_time = time - element->base_time;
-       GST_CAT_LOG_OBJECT (GST_CAT_CLOCK, element, "setting base time to %"
-           G_GINT64_FORMAT, element->base_time);
+        g_assert (time >= element->base_time);
+        element->base_time = time - element->base_time;
+        GST_CAT_LOG_OBJECT (GST_CAT_CLOCK, element, "setting base time to %"
+            G_GINT64_FORMAT, element->base_time);
       }
       gst_element_pads_activate (element, FALSE);
       break;
     case GST_STATE_PAUSED_TO_PLAYING:
       gst_element_pads_activate (element, TRUE);
       if (element->clock) {
-       GstClockTime time = gst_clock_get_event_time (element->clock);
+        GstClockTime time = gst_clock_get_event_time (element->clock);
 
-       element->base_time = time - element->base_time;
-       GST_CAT_LOG_OBJECT (GST_CAT_CLOCK, element, "setting base time to %"
-           G_GINT64_FORMAT, element->base_time);
+        element->base_time = time - element->base_time;
+        GST_CAT_LOG_OBJECT (GST_CAT_CLOCK, element, "setting base time to %"
+            G_GINT64_FORMAT, element->base_time);
       }
       break;
       /* if we are going to paused, we try to negotiate the pads */
     case GST_STATE_READY_TO_PAUSED:
       g_assert (element->base_time == 0);
       if (!gst_element_negotiate_pads (element))
-       goto failure;
+        goto failure;
       break;
       /* going to the READY state clears all pad caps */
       /* FIXME: Why doesn't this happen on READY => NULL? -- Company */
@@ -2888,9 +2890,9 @@ gst_element_change_state (GstElement * element)
   /* tell the scheduler if we have one */
   if (element->sched) {
     if (gst_scheduler_state_transition (element->sched, element,
-           old_transition) != GST_STATE_SUCCESS) {
+            old_transition) != GST_STATE_SUCCESS) {
       GST_CAT_INFO_OBJECT (GST_CAT_STATES, element,
-         "scheduler could not change state");
+          "scheduler could not change state");
       goto failure;
     }
   }
@@ -2898,7 +2900,7 @@ gst_element_change_state (GstElement * element)
   /* tell our parent about the state change */
   if (parent && GST_IS_BIN (parent)) {
     gst_bin_child_state_change (GST_BIN (parent), old_state,
-       GST_STATE (element), element);
+        GST_STATE (element), element);
   }
   /* at this point the state of the element could have changed again */
 
@@ -2956,9 +2958,9 @@ gst_element_dispose (GObject * object)
       pad = GST_PAD (pads->data);
 
       if (GST_PAD_PEER (pad)) {
-       GST_CAT_DEBUG (GST_CAT_REFCOUNTING, "unlinking pad '%s'",
-           GST_OBJECT_NAME (GST_OBJECT (GST_PAD (GST_PAD_PEER (pad)))));
-       gst_pad_unlink (pad, GST_PAD (GST_PAD_PEER (pad)));
+        GST_CAT_DEBUG (GST_CAT_REFCOUNTING, "unlinking pad '%s'",
+            GST_OBJECT_NAME (GST_OBJECT (GST_PAD (GST_PAD_PEER (pad)))));
+        gst_pad_unlink (pad, GST_PAD (GST_PAD_PEER (pad)));
       }
       gst_element_remove_pad (element, pad);
 
@@ -3046,14 +3048,14 @@ gst_element_save_thyself (GstObject * object, xmlNodePtr parent)
       xmlNewChild (param, NULL, "name", spec->name);
 
       if (G_IS_PARAM_SPEC_STRING (spec))
-       contents = g_value_dup_string (&value);
+        contents = g_value_dup_string (&value);
       else if (G_IS_PARAM_SPEC_ENUM (spec))
-       contents = g_strdup_printf ("%d", g_value_get_enum (&value));
+        contents = g_strdup_printf ("%d", g_value_get_enum (&value));
       else if (G_IS_PARAM_SPEC_INT64 (spec))
-       contents = g_strdup_printf ("%" G_GINT64_FORMAT,
-           g_value_get_int64 (&value));
+        contents = g_strdup_printf ("%" G_GINT64_FORMAT,
+            g_value_get_int64 (&value));
       else
-       contents = g_strdup_value_contents (&value);
+        contents = g_strdup_value_contents (&value);
 
       xmlNewChild (param, NULL, "value", contents);
       g_free (contents);
@@ -3097,12 +3099,12 @@ gst_element_restore_thyself (GstObject * object, xmlNodePtr self)
       xmlNodePtr child = children->xmlChildrenNode;
 
       while (child) {
-       if (!strcmp (child->name, "name")) {
-         name = xmlNodeGetContent (child);
-       } else if (!strcmp (child->name, "value")) {
-         value = xmlNodeGetContent (child);
-       }
-       child = child->next;
+        if (!strcmp (child->name, "name")) {
+          name = xmlNodeGetContent (child);
+        } else if (!strcmp (child->name, "value")) {
+          value = xmlNodeGetContent (child);
+        }
+        child = child->next;
       }
       /* FIXME: can this just be g_object_set ? */
       gst_util_set_object_arg (G_OBJECT (element), name, value);
@@ -3250,9 +3252,9 @@ gst_element_found_tag_func (GstElement * element, GstElement * source,
   /* tell the parent */
   if (GST_OBJECT_PARENT (element)) {
     GST_CAT_LOG_OBJECT (GST_CAT_EVENT, element, "forwarding tag event to %s",
-       GST_OBJECT_NAME (GST_OBJECT_PARENT (element)));
+        GST_OBJECT_NAME (GST_OBJECT_PARENT (element)));
     gst_element_emit_found_tag (GST_ELEMENT (GST_OBJECT_PARENT (element)),
-       source, tag_list);
+        source, tag_list);
   }
 }
 
@@ -3439,45 +3441,45 @@ gst_element_populate_std_props (GObjectClass * klass, const gchar * prop_name,
 
   if (prop_id == fd_id) {
     pspec = g_param_spec_int ("fd", "File-descriptor",
-       "File-descriptor for the file being read", 0, G_MAXINT, 0, flags);
+        "File-descriptor for the file being read", 0, G_MAXINT, 0, flags);
   } else if (prop_id == blocksize_id) {
     pspec = g_param_spec_ulong ("blocksize", "Block Size",
-       "Block size to read per buffer", 0, G_MAXULONG, 4096, flags);
+        "Block size to read per buffer", 0, G_MAXULONG, 4096, flags);
 
   } else if (prop_id == bytesperread_id) {
     pspec = g_param_spec_int ("bytesperread", "Bytes per read",
-       "Number of bytes to read per buffer", G_MININT, G_MAXINT, 0, flags);
+        "Number of bytes to read per buffer", G_MININT, G_MAXINT, 0, flags);
 
   } else if (prop_id == dump_id) {
     pspec = g_param_spec_boolean ("dump", "Dump",
-       "Dump bytes to stdout", FALSE, flags);
+        "Dump bytes to stdout", FALSE, flags);
 
   } else if (prop_id == filesize_id) {
     pspec = g_param_spec_int64 ("filesize", "File Size",
-       "Size of the file being read", 0, G_MAXINT64, 0, flags);
+        "Size of the file being read", 0, G_MAXINT64, 0, flags);
 
   } else if (prop_id == mmapsize_id) {
     pspec = g_param_spec_ulong ("mmapsize", "mmap() Block Size",
-       "Size in bytes of mmap()d regions", 0, G_MAXULONG, 4 * 1048576, flags);
+        "Size in bytes of mmap()d regions", 0, G_MAXULONG, 4 * 1048576, flags);
 
   } else if (prop_id == location_id) {
     pspec = g_param_spec_string ("location", "File Location",
-       "Location of the file to read", NULL, flags);
+        "Location of the file to read", NULL, flags);
 
   } else if (prop_id == offset_id) {
     pspec = g_param_spec_int64 ("offset", "File Offset",
-       "Byte offset of current read pointer", 0, G_MAXINT64, 0, flags);
+        "Byte offset of current read pointer", 0, G_MAXINT64, 0, flags);
 
   } else if (prop_id == silent_id) {
     pspec = g_param_spec_boolean ("silent", "Silent", "Don't produce events",
-       FALSE, flags);
+        FALSE, flags);
 
   } else if (prop_id == touch_id) {
     pspec = g_param_spec_boolean ("touch", "Touch read data",
-       "Touch data to force disk read before " "push ()", TRUE, flags);
+        "Touch data to force disk read before " "push ()", TRUE, flags);
   } else {
     g_warning ("Unknown - 'standard' property '%s' id %d from klass %s",
-       prop_name, arg_id, g_type_name (G_OBJECT_CLASS_TYPE (klass)));
+        prop_name, arg_id, g_type_name (G_OBJECT_CLASS_TYPE (klass)));
     pspec = NULL;
   }
 
@@ -3517,7 +3519,7 @@ gst_element_class_install_std_props (GstElementClass * klass,
     int flags = va_arg (args, int);
 
     gst_element_populate_std_props ((GObjectClass *) klass, name, arg_id,
-       flags);
+        flags);
 
     name = va_arg (args, char *);
   }
index 508c450cdae3679707668dcb529743392cd93b82..14c8c78adfab4b876add3a03b27d45c2262fb452 100644 (file)
@@ -58,11 +58,12 @@ gst_element_factory_get_type (void)
       (GInstanceInitFunc) gst_element_factory_init,
       NULL
     };
+
     elementfactory_type = g_type_register_static (GST_TYPE_PLUGIN_FEATURE,
-       "GstElementFactory", &elementfactory_info, 0);
+        "GstElementFactory", &elementfactory_info, 0);
     GST_DEBUG_CATEGORY_INIT (element_factory_debug, "GST_ELEMENT_FACTORY",
-       GST_DEBUG_BOLD | GST_DEBUG_FG_WHITE | GST_DEBUG_BG_RED,
-       "element factories keep information about installed elements");
+        GST_DEBUG_BOLD | GST_DEBUG_FG_WHITE | GST_DEBUG_BG_RED,
+        "element factories keep information about installed elements");
   }
   return elementfactory_type;
 }
@@ -202,16 +203,16 @@ gst_element_register (GstPlugin * plugin, const gchar * name, guint rank,
   if (!factory) {
     klass = GST_ELEMENT_CLASS (g_type_class_ref (type));
     factory =
-       GST_ELEMENT_FACTORY (g_object_new (GST_TYPE_ELEMENT_FACTORY, NULL));
+        GST_ELEMENT_FACTORY (g_object_new (GST_TYPE_ELEMENT_FACTORY, NULL));
     gst_plugin_feature_set_name (GST_PLUGIN_FEATURE (factory), name);
     GST_LOG_OBJECT (factory, "Created new elementfactory for type %s",
-       g_type_name (type));
+        g_type_name (type));
   } else {
     g_return_val_if_fail (factory->type == 0, FALSE);
     klass = GST_ELEMENT_CLASS (g_type_class_ref (type));
     gst_element_factory_cleanup (factory);
     GST_LOG_OBJECT (factory, "Reuse existing elementfactory for type %s",
-       g_type_name (type));
+        g_type_name (type));
   }
 
   factory->type = type;
@@ -223,7 +224,7 @@ gst_element_register (GstPlugin * plugin, const gchar * name, guint rank,
   /* special stuff for URI handling */
   if (g_type_is_a (type, GST_TYPE_URI_HANDLER)) {
     GstURIHandlerInterface *iface = (GstURIHandlerInterface *)
-       g_type_interface_peek (klass, GST_TYPE_URI_HANDLER);
+        g_type_interface_peek (klass, GST_TYPE_URI_HANDLER);
 
     if (!iface || !iface->get_type || !iface->get_protocols)
       goto error;
@@ -277,13 +278,13 @@ gst_element_factory_create (GstElementFactory * factory, const gchar * name)
 
   if (name)
     GST_INFO ("creating \"%s\" named \"%s\"", GST_PLUGIN_FEATURE_NAME (factory),
-       GST_STR_NULL (name));
+        GST_STR_NULL (name));
   else
     GST_INFO ("creating \"%s\"", GST_PLUGIN_FEATURE_NAME (factory));
 
   if (factory->type == 0) {
     g_critical ("Factory for `%s' has no type",
-       GST_PLUGIN_FEATURE_NAME (factory));
+        GST_PLUGIN_FEATURE_NAME (factory));
     return NULL;
   }
 
@@ -464,7 +465,7 @@ __gst_element_factory_add_interface (GstElementFactory * elementfactory,
 {
   g_return_if_fail (GST_IS_ELEMENT_FACTORY (elementfactory));
   g_return_if_fail (interfacename != NULL);
-  g_return_if_fail (interfacename[0] != '\0'); /* no empty string */
+  g_return_if_fail (interfacename[0] != '\0');  /* no empty string */
 
   elementfactory->interfaces =
       g_list_prepend (elementfactory->interfaces, g_strdup (interfacename));
@@ -545,8 +546,8 @@ gst_element_factory_can_src_caps (GstElementFactory * factory,
 
     if (template->direction == GST_PAD_SRC) {
       if (gst_caps_is_always_compatible (GST_PAD_TEMPLATE_CAPS (template),
-             caps))
-       return TRUE;
+              caps))
+        return TRUE;
     }
     templates = g_list_next (templates);
   }
@@ -579,8 +580,8 @@ gst_element_factory_can_sink_caps (GstElementFactory * factory,
 
     if (template->direction == GST_PAD_SINK) {
       if (gst_caps_is_always_compatible (caps,
-             GST_PAD_TEMPLATE_CAPS (template)))
-       return TRUE;
+              GST_PAD_TEMPLATE_CAPS (template)))
+        return TRUE;
     }
     templates = g_list_next (templates);
   }
index b5d10d5f3763a996d9245025e2fd5e90de2cedf9..974b2a6f5ff95efe6ddf48b60cf847f33678d667 100644 (file)
@@ -40,7 +40,7 @@ gst_g_error_get_type (void)
 
   if (!type)
     type = g_boxed_type_register_static ("GstGError",
-       (GBoxedCopyFunc) g_error_copy, (GBoxedFreeFunc) g_error_free);
+        (GBoxedCopyFunc) g_error_copy, (GBoxedFreeFunc) g_error_free);
   return type;
 }
 
@@ -56,7 +56,7 @@ _gst_core_errors_init ()
       N_("GStreamer encountered a general core library error."));
   TABLE (t, CORE, TOO_LAZY,
       N_("GStreamer developers were too lazy to assign an error code "
-         "to this error.  Please file a bug."));
+          "to this error.  Please file a bug."));
   TABLE (t, CORE, NOT_IMPLEMENTED,
       N_("Internal GStreamer error: code not implemented.  File a bug."));
   TABLE (t, CORE, STATE_CHANGE,
@@ -93,7 +93,7 @@ _gst_library_errors_init ()
       N_("GStreamer encountered a general supporting library error."));
   TABLE (t, LIBRARY, TOO_LAZY,
       N_("GStreamer developers were too lazy to assign an error code "
-         "to this error.  Please file a bug."));
+          "to this error.  Please file a bug."));
   TABLE (t, LIBRARY, INIT, N_("Could not initialize supporting library."));
   TABLE (t, LIBRARY, SHUTDOWN, N_("Could not close supporting library."));
   TABLE (t, LIBRARY, SETTINGS, N_("Could not close supporting library."));
@@ -113,7 +113,7 @@ _gst_resource_errors_init ()
       N_("GStreamer encountered a general supporting library error."));
   TABLE (t, RESOURCE, TOO_LAZY,
       N_("GStreamer developers were too lazy to assign an error code "
-         "to this error.  Please file a bug."));
+          "to this error.  Please file a bug."));
   TABLE (t, RESOURCE, NOT_FOUND, N_("Resource not found."));
   TABLE (t, RESOURCE, BUSY, N_("Resource busy or not available."));
   TABLE (t, RESOURCE, OPEN_READ, N_("Could not open resource for reading."));
@@ -143,10 +143,10 @@ _gst_stream_errors_init ()
       N_("GStreamer encountered a general supporting library error."));
   TABLE (t, STREAM, TOO_LAZY,
       N_("GStreamer developers were too lazy to assign an error code "
-         "to this error.  Please file a bug."));
+          "to this error.  Please file a bug."));
   TABLE (t, STREAM, NOT_IMPLEMENTED,
       N_("Element doesn't implement handling of this stream. "
-         "Please file a bug."));
+          "Please file a bug."));
   TABLE (t, STREAM, TYPE_NOT_FOUND, N_("Could not determine type of stream."));
   TABLE (t, STREAM, WRONG_TYPE,
       N_("The stream is of a different type than handled by this element."));
@@ -205,13 +205,13 @@ QUARK_FUNC (core)
   else {
     g_warning ("No error messages for domain %s", g_quark_to_string (domain));
     return g_strdup_printf (_("No error message for domain %s."),
-       g_quark_to_string (domain));
+        g_quark_to_string (domain));
   }
   if (message)
     return g_strdup (_(message));
   else
     return
-       g_strdup_printf (_
-       ("No standard error message for domain %s and code %d."),
-       g_quark_to_string (domain), code);
+        g_strdup_printf (_
+        ("No standard error message for domain %s and code %d."),
+        g_quark_to_string (domain), code);
 }
index c42e1b10e703a75ef5aaa93044071af1db58c754..d07748202f4f2f2db513074c610803c3b1dff08e 100644 (file)
@@ -20,7 +20,7 @@
  * Boston, MA 02111-1307, USA.
  */
 
-#include <string.h>            /* memcpy */
+#include <string.h>             /* memcpy */
 
 #include "gst_private.h"
 #include "gstdata_private.h"
@@ -74,12 +74,12 @@ _gst_event_copy (GstEvent * event)
   switch (GST_EVENT_TYPE (event)) {
     case GST_EVENT_TAG:
       copy->event_data.structure.structure =
-         gst_tag_list_copy ((GstTagList *) event->event_data.structure.
-         structure);
+          gst_tag_list_copy ((GstTagList *) event->event_data.structure.
+          structure);
       break;
     case GST_EVENT_NAVIGATION:
       copy->event_data.structure.structure =
-         gst_structure_copy (event->event_data.structure.structure);
+          gst_structure_copy (event->event_data.structure.structure);
     default:
       break;
   }
@@ -98,10 +98,10 @@ _gst_event_free (GstEvent * event)
   switch (GST_EVENT_TYPE (event)) {
     case GST_EVENT_TAG:
       if (GST_IS_TAG_LIST (event->event_data.structure.structure)) {
-       gst_tag_list_free (event->event_data.structure.structure);
+        gst_tag_list_free (event->event_data.structure.structure);
       } else {
-       g_warning ("tag event %p didn't contain a valid tag list!", event);
-       GST_ERROR ("tag event %p didn't contain a valid tag list!", event);
+        g_warning ("tag event %p didn't contain a valid tag list!", event);
+        GST_ERROR ("tag event %p didn't contain a valid tag list!", event);
       }
       break;
     case GST_EVENT_NAVIGATION:
@@ -136,7 +136,7 @@ gst_event_masks_contains (const GstEventMask * masks, GstEventMask * mask)
 
   while (masks->type) {
     if (masks->type == mask->type &&
-       (masks->flags & mask->flags) == mask->flags)
+        (masks->flags & mask->flags) == mask->flags)
       return TRUE;
 
     masks++;
@@ -233,7 +233,7 @@ gst_event_new_discontinuous_valist (gboolean new_media, GstFormat format1,
   while (format1 != GST_FORMAT_UNDEFINED && count < 8) {
 
     GST_EVENT_DISCONT_OFFSET (event, count).format =
-       format1 & GST_SEEK_FORMAT_MASK;
+        format1 & GST_SEEK_FORMAT_MASK;
     GST_EVENT_DISCONT_OFFSET (event, count).value = va_arg (var_args, gint64);
 
     format1 = va_arg (var_args, GstFormat);
index 4f1395ef675d573529c17e37a256fe2e76815be5..777df08b0e997bfe37373bc8d6435877bc0ebec0 100644 (file)
@@ -39,7 +39,7 @@ gst_filter_run (const GList * list, GstFilterFunc func, gboolean first,
       result = g_list_prepend (result, data);
 
       if (first)
-       break;
+        break;
     }
   }
 
index 6881a0179a14bb810f3be2909e3d2cf767a04d04..334e5c0655e12ceb25aae99bc36e915e237f9698 100644 (file)
@@ -29,7 +29,7 @@
 static GList *_gst_formats = NULL;
 static GHashTable *_nick_to_format = NULL;
 static GHashTable *_format_to_nick = NULL;
-static gint _n_values = 1;     /* we start from 1 because 0 reserved for UNDEFINED */
+static gint _n_values = 1;      /* we start from 1 because 0 reserved for UNDEFINED */
 
 static GstFormatDefinition standard_definitions[] = {
   {GST_FORMAT_DEFAULT, "default", "Default format for the media type"},
@@ -53,7 +53,7 @@ _gst_format_initialize (void)
   while (standards->nick) {
     g_hash_table_insert (_nick_to_format, standards->nick, standards);
     g_hash_table_insert (_format_to_nick, GINT_TO_POINTER (standards->value),
-       standards);
+        standards);
 
     _gst_formats = g_list_append (_gst_formats, standards);
     standards++;
index f7e74d06db395347e31b497f6ef8d192741d6a27..e6ac119caefdcf2648be19b607f018fb4e41ca63 100644 (file)
@@ -66,7 +66,8 @@ typedef struct
   GstIndexResolverMethod method;
   GstIndexResolver resolver;
   gpointer user_data;
-} ResolverEntry;
+}
+ResolverEntry;
 
 static const ResolverEntry resolvers[] = {
   {GST_INDEX_RESOLVER_CUSTOM, NULL, NULL},
@@ -81,16 +82,17 @@ gst_index_resolver_get_type (void)
   static GType index_resolver_type = 0;
   static GEnumValue index_resolver[] = {
     {GST_INDEX_RESOLVER_CUSTOM, "GST_INDEX_RESOLVER_CUSTOM",
-         "Use a custom resolver"},
+        "Use a custom resolver"},
     {GST_INDEX_RESOLVER_GTYPE, "GST_INDEX_RESOLVER_GTYPE",
-         "Resolve an object to its GType[.padname]"},
+        "Resolve an object to its GType[.padname]"},
     {GST_INDEX_RESOLVER_PATH, "GST_INDEX_RESOLVER_PATH",
-         "Resolve an object to its path in the pipeline"},
+        "Resolve an object to its path in the pipeline"},
     {0, NULL, NULL},
   };
+
   if (!index_resolver_type) {
     index_resolver_type =
-       g_enum_register_static ("GstIndexResolver", index_resolver);
+        g_enum_register_static ("GstIndexResolver", index_resolver);
   }
   return index_resolver_type;
 }
@@ -102,8 +104,8 @@ gst_index_entry_get_type (void)
 
   if (!index_entry_type) {
     index_entry_type = g_boxed_type_register_static ("GstIndexEntry",
-       (GBoxedCopyFunc) gst_index_entry_copy,
-       (GBoxedFreeFunc) gst_index_entry_free);
+        (GBoxedCopyFunc) gst_index_entry_copy,
+        (GBoxedFreeFunc) gst_index_entry_free);
   }
   return index_entry_type;
 }
@@ -127,8 +129,9 @@ gst_index_get_type (void)
       (GInstanceInitFunc) gst_index_init,
       NULL
     };
+
     index_type =
-       g_type_register_static (GST_TYPE_OBJECT, "GstIndex", &index_info, 0);
+        g_type_register_static (GST_TYPE_OBJECT, "GstIndex", &index_info, 0);
   }
   return index_type;
 }
@@ -154,8 +157,8 @@ gst_index_class_init (GstIndexClass * klass)
 
   g_object_class_install_property (G_OBJECT_CLASS (klass), ARG_RESOLVER,
       g_param_spec_enum ("resolver", "Resolver",
-         "Select a predefined object to string mapper",
-         GST_TYPE_INDEX_RESOLVER, GST_INDEX_RESOLVER_PATH, G_PARAM_READWRITE));
+          "Select a predefined object to string mapper",
+          GST_TYPE_INDEX_RESOLVER, GST_INDEX_RESOLVER_PATH, G_PARAM_READWRITE));
 }
 
 static void
@@ -513,10 +516,10 @@ gst_index_gtype_resolver (GstIndex * index, GstObject * writer,
     GstElement *element = gst_pad_get_parent (GST_PAD (writer));
 
     *writer_string = g_strdup_printf ("%s.%s",
-       g_type_name (G_OBJECT_TYPE (element)), gst_object_get_name (writer));
+        g_type_name (G_OBJECT_TYPE (element)), gst_object_get_name (writer));
   } else {
     *writer_string =