- connect->link

Original commit message from CVS:
- connect->link
- add total indexed time (vishnu)

1 files changed, 48 insertions, 27 deletions

diff --git a/examples/indexing/indexmpeg.c b/examples/indexing/indexmpeg.c
index 10215a0e9..a31f2a763 100644
--- a/examples/indexing/indexmpeg.c
+++ b/examples/indexing/indexmpeg.c
@@ -60,40 +60,40 @@ typedef struct
   GstElement    *bin;
   GstElement    *pipeline;
   GstIndex      *index;
-} dyn_connect;
+} dyn_link;
 
 static void
-dynamic_connect (GstPadTemplate *templ, GstPad *newpad, gpointer data)
+dynamic_link (GstPadTemplate *templ, GstPad *newpad, gpointer data)
 {
-  dyn_connect *connect = (dyn_connect *) data;
-
-  if (!strcmp (gst_pad_get_name (newpad), connect->padname)) {
-    gst_element_set_state (connect->pipeline, GST_STATE_PAUSED);
-    gst_bin_add (GST_BIN (connect->pipeline), connect->bin);
-    gst_pad_connect (newpad, connect->target);
-    gst_element_set_index (connect->bin, connect->index);
-    gst_element_set_state (connect->pipeline, GST_STATE_PLAYING);
+  dyn_link *link = (dyn_link *) data;
+
+  if (!strcmp (gst_pad_get_name (newpad), link->padname)) {
+    gst_element_set_state (link->pipeline, GST_STATE_PAUSED);
+    gst_bin_add (GST_BIN (link->pipeline), link->bin);
+    gst_pad_link (newpad, link->target);
+    gst_element_set_index (link->bin, link->index);
+    gst_element_set_state (link->pipeline, GST_STATE_PLAYING);
   }
 }
 
 static void
-setup_dynamic_connection (GstElement *pipeline, 
+setup_dynamic_linking (GstElement *pipeline, 
 		          GstElement *element, 
 			  const gchar *padname, 
 			  GstPad *target, 
 			  GstElement *bin,
 			  GstIndex *index)
 {
-  dyn_connect *connect;
+  dyn_link *link;
 
-  connect = g_new0 (dyn_connect, 1);
-  connect->padname      = g_strdup (padname);
-  connect->target       = target;
-  connect->bin          = bin;
-  connect->pipeline     = pipeline;
-  connect->index     	= index;
+  link = g_new0 (dyn_link, 1);
+  link->padname      = g_strdup (padname);
+  link->target       = target;
+  link->bin          = bin;
+  link->pipeline     = pipeline;
+  link->index        = index;
 
-  g_signal_connect (G_OBJECT (element), "new_pad", G_CALLBACK (dynamic_connect), connect);
+  g_signal_connect (G_OBJECT (element), "new_pad", G_CALLBACK (dynamic_link), link);
 }
 
 static GstElement*
@@ -116,7 +116,7 @@ make_mpeg_systems_pipeline (const gchar *path, GstIndex *index)
     gst_element_set_index (pipeline, index);
   }
 
-  gst_element_connect_pads (src, "src", demux, "sink");
+  gst_element_link_pads (src, "src", demux, "sink");
   
   return pipeline;
 }
@@ -139,16 +139,16 @@ make_mpeg_decoder_pipeline (const gchar *path, GstIndex *index)
   gst_bin_add (GST_BIN (pipeline), src);
   gst_bin_add (GST_BIN (pipeline), demux);
 
-  gst_element_connect_pads (src, "src", demux, "sink");
+  gst_element_link_pads (src, "src", demux, "sink");
 
   video_bin = gst_bin_new ("video_bin");
   video_decoder = gst_element_factory_make ("mpeg2dec", "video_decoder");
 
   gst_bin_add (GST_BIN (video_bin), video_decoder);
   
-  setup_dynamic_connection (pipeline, demux, "video_00", 
-		            gst_element_get_pad (video_decoder, "sink"),
-			    video_bin, index);
+  setup_dynamic_linking (pipeline, demux, "video_00", 
+		         gst_element_get_pad (video_decoder, "sink"),
+			 video_bin, index);
 
   audio_bin = gst_bin_new ("audio_bin");
   audio_decoder = gst_element_factory_make ("mad", "audio_decoder");
@@ -222,8 +222,12 @@ main (gint argc, gchar *argv[])
 
   /* create index that elements can fill */
   index = gst_index_factory_make ("memindex");
-  if (verbose && index)
-    g_signal_connect (G_OBJECT (index), "entry_added", G_CALLBACK (entry_added), NULL);
+  if (index) {
+    if (verbose) 
+      g_signal_connect (G_OBJECT (index), "entry_added", G_CALLBACK (entry_added), NULL);
+
+    g_object_set (G_OBJECT (index), "resolver", 1, NULL);
+  }
 
   /* construct pipeline */
   switch (atoi (argv[1])) {
@@ -269,9 +273,26 @@ main (gint argc, gchar *argv[])
     GST_FLAG_UNSET (index, GST_INDEX_WRITABLE);
 
   src = gst_bin_get_by_name (GST_BIN (pipeline), "video_decoder");
+
+  {
+    gint id;
+    GstIndexEntry *entry;
+    gint64 result;
+    gint total_tm;
+
+    gst_index_get_writer_id (index, GST_OBJECT (src), &id);
+    
+    entry = gst_index_get_assoc_entry (index, id, GST_INDEX_LOOKUP_BEFORE, 0,
+ 				       GST_FORMAT_TIME, G_MAXINT64);
+    g_assert (entry);
+    gst_index_entry_assoc_map (entry, GST_FORMAT_TIME, &result);
+    total_tm = result * 60 / GST_SECOND;
+    g_print ("total time = %.2fs\n", total_tm / 60.0);
+  }
+  
   pad = gst_element_get_pad (src, "src");
   sink = gst_element_factory_make ("fakesink", "sink");
-  gst_element_connect_pads (src, "src", sink, "sink");
+  gst_element_link_pads (src, "src", sink, "sink");
   gst_bin_add (GST_BIN (pipeline), sink);
 
   g_print ("seeking %s...\n", argv [2]);